[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[GNUnet-SVN] r28054 - gnunet/src/mesh
From: |
gnunet |
Subject: |
[GNUnet-SVN] r28054 - gnunet/src/mesh |
Date: |
Mon, 15 Jul 2013 19:44:52 +0200 |
Author: bartpolot
Date: 2013-07-15 19:44:52 +0200 (Mon, 15 Jul 2013)
New Revision: 28054
Modified:
gnunet/src/mesh/gnunet-service-mesh.c
Log:
- Poll whenever the queue is not empty
Modified: gnunet/src/mesh/gnunet-service-mesh.c
===================================================================
--- gnunet/src/mesh/gnunet-service-mesh.c 2013-07-15 17:35:13 UTC (rev
28053)
+++ gnunet/src/mesh/gnunet-service-mesh.c 2013-07-15 17:44:52 UTC (rev
28054)
@@ -3473,11 +3473,8 @@
&queue_send,
peer);
}
- else if (NULL != peer->queue_head)
+ if (NULL != peer->queue_head)
{
- GNUNET_log (GNUNET_ERROR_TYPE_INFO,
- "* %s stalled\n",
- GNUNET_i2s (&my_full_id));
if (peer->id == t->next_hop)
fc = &t->next_fc;
else if (peer->id == t->prev_hop)
@@ -3487,8 +3484,11 @@
GNUNET_break (0);
return data_size;
}
- if (NULL != fc && GNUNET_SCHEDULER_NO_TASK == fc->poll_task)
+ if (GNUNET_SCHEDULER_NO_TASK == fc->poll_task && fc->queue_n > 0)
{
+ GNUNET_log (GNUNET_ERROR_TYPE_INFO,
+ "* %s starting poll timeout\n",
+ GNUNET_i2s (&my_full_id));
fc->t = t;
fc->poll_task = GNUNET_SCHEDULER_add_delayed (fc->poll_time,
&tunnel_poll, fc);
[Prev in Thread] |
Current Thread |
[Next in Thread] |
- [GNUnet-SVN] r28054 - gnunet/src/mesh,
gnunet <=