[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[GNUnet-SVN] r29003 - gnunet/src/mesh
From: |
gnunet |
Subject: |
[GNUnet-SVN] r29003 - gnunet/src/mesh |
Date: |
Thu, 5 Sep 2013 05:28:43 +0200 |
Author: bartpolot
Date: 2013-09-05 05:28:43 +0200 (Thu, 05 Sep 2013)
New Revision: 29003
Modified:
gnunet/src/mesh/gnunet-service-mesh-enc.c
Log:
- fix queue unlocking
Modified: gnunet/src/mesh/gnunet-service-mesh-enc.c
===================================================================
--- gnunet/src/mesh/gnunet-service-mesh-enc.c 2013-09-05 03:21:40 UTC (rev
29002)
+++ gnunet/src/mesh/gnunet-service-mesh-enc.c 2013-09-05 03:28:43 UTC (rev
29003)
@@ -2591,27 +2591,9 @@
"connection_unlock_queue %s on %s\n",
fwd ? "FWD" : "BCK", GNUNET_h2s (&c->id));
- if (connection_is_origin (c, fwd))
+ if (connection_is_terminal (c, fwd))
{
- struct MeshTunnel2 *t = c->t;
- struct MeshChannel *ch;
- struct MeshChannelReliability *rel;
-
- GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, " is origin!\n");
- /* FIXME randomize channel selection, not always first channel */
- for (ch = t->channel_head; NULL != ch; ch = ch->next)
- {
- rel = fwd ? ch->root_rel : ch->dest_rel;
-
- GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, " channel %X - %s\n",
- ch->gid, rel->client_ready ? "ready " : "not ready");
- if (GNUNET_NO == rel->client_ready)
- {
- GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, " sending local ack!\n");
- send_local_ack (ch, fwd);
- return; /* FIXME authorize all channels? */
- }
- }
+ GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, " is terminal!\n");
return;
}
[Prev in Thread] |
Current Thread |
[Next in Thread] |
- [GNUnet-SVN] r29003 - gnunet/src/mesh,
gnunet <=