gnunet-svn
[Top][All Lists]
Advanced

[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;
   }
 




reply via email to

[Prev in Thread] Current Thread [Next in Thread]