aboutsummaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorBart Polot <bart@net.in.tum.de>2013-07-15 17:44:52 +0000
committerBart Polot <bart@net.in.tum.de>2013-07-15 17:44:52 +0000
commit4fd6ddfbdb8c2de62ffad1abf1c8808ea897b1f9 (patch)
treedf1e797d4f4cc7f3ab0d4709b642ab04a200ba6d /src
parent3a373a240a1f38d064428223d8cbd453fe652288 (diff)
downloadgnunet-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.c10
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);