From 3a682d79308224dbb6ea46300f5ca1766eac9422 Mon Sep 17 00:00:00 2001 From: Bart Polot Date: Thu, 5 Sep 2013 03:28:43 +0000 Subject: [PATCH] - fix queue unlocking --- src/mesh/gnunet-service-mesh-enc.c | 22 ++-------------------- 1 file changed, 2 insertions(+), 20 deletions(-) diff --git a/src/mesh/gnunet-service-mesh-enc.c b/src/mesh/gnunet-service-mesh-enc.c index f0dc89960..d1a8970f8 100644 --- a/src/mesh/gnunet-service-mesh-enc.c +++ b/src/mesh/gnunet-service-mesh-enc.c @@ -2591,27 +2591,9 @@ connection_unlock_queue (struct MeshConnection *c, int fwd) "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; } -- 2.25.1