diff options
author | Bart Polot <bart@net.in.tum.de> | 2013-07-15 17:44:52 +0000 |
---|---|---|
committer | Bart Polot <bart@net.in.tum.de> | 2013-07-15 17:44:52 +0000 |
commit | 4fd6ddfbdb8c2de62ffad1abf1c8808ea897b1f9 (patch) | |
tree | df1e797d4f4cc7f3ab0d4709b642ab04a200ba6d /src | |
parent | 3a373a240a1f38d064428223d8cbd453fe652288 (diff) | |
download | gnunet-4fd6ddfbdb8c2de62ffad1abf1c8808ea897b1f9.tar.gz gnunet-4fd6ddfbdb8c2de62ffad1abf1c8808ea897b1f9.zip |
- Poll whenever the queue is not empty
Diffstat (limited to 'src')
-rw-r--r-- | src/mesh/gnunet-service-mesh.c | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/src/mesh/gnunet-service-mesh.c b/src/mesh/gnunet-service-mesh.c index bada66388..0610dcd33 100644 --- a/src/mesh/gnunet-service-mesh.c +++ b/src/mesh/gnunet-service-mesh.c | |||
@@ -3473,11 +3473,8 @@ queue_send (void *cls, size_t size, void *buf) | |||
3473 | &queue_send, | 3473 | &queue_send, |
3474 | peer); | 3474 | peer); |
3475 | } | 3475 | } |
3476 | else if (NULL != peer->queue_head) | 3476 | if (NULL != peer->queue_head) |
3477 | { | 3477 | { |
3478 | GNUNET_log (GNUNET_ERROR_TYPE_INFO, | ||
3479 | "* %s stalled\n", | ||
3480 | GNUNET_i2s (&my_full_id)); | ||
3481 | if (peer->id == t->next_hop) | 3478 | if (peer->id == t->next_hop) |
3482 | fc = &t->next_fc; | 3479 | fc = &t->next_fc; |
3483 | else if (peer->id == t->prev_hop) | 3480 | else if (peer->id == t->prev_hop) |
@@ -3487,8 +3484,11 @@ queue_send (void *cls, size_t size, void *buf) | |||
3487 | GNUNET_break (0); | 3484 | GNUNET_break (0); |
3488 | return data_size; | 3485 | return data_size; |
3489 | } | 3486 | } |
3490 | if (NULL != fc && GNUNET_SCHEDULER_NO_TASK == fc->poll_task) | 3487 | if (GNUNET_SCHEDULER_NO_TASK == fc->poll_task && fc->queue_n > 0) |
3491 | { | 3488 | { |
3489 | GNUNET_log (GNUNET_ERROR_TYPE_INFO, | ||
3490 | "* %s starting poll timeout\n", | ||
3491 | GNUNET_i2s (&my_full_id)); | ||
3492 | fc->t = t; | 3492 | fc->t = t; |
3493 | fc->poll_task = GNUNET_SCHEDULER_add_delayed (fc->poll_time, | 3493 | fc->poll_task = GNUNET_SCHEDULER_add_delayed (fc->poll_time, |
3494 | &tunnel_poll, fc); | 3494 | &tunnel_poll, fc); |