From: Bart Polot <bart@net.in.tum.de>
Date: Tue, 12 Jun 2012 12:42:50 +0000 (+0000)
Subject: - keep track of queue occupancy
X-Git-Tag: initial-import-from-subversion-38251~13126
X-Git-Url: https://git.librecmc.org/?a=commitdiff_plain;h=5a48ee09998ddd6748d286b927cef50634e93181;p=oweals%2Fgnunet.git

- keep track of queue occupancy
---

diff --git a/src/mesh/gnunet-service-mesh_new.c b/src/mesh/gnunet-service-mesh_new.c
index 884d96dbb..26984836e 100644
--- a/src/mesh/gnunet-service-mesh_new.c
+++ b/src/mesh/gnunet-service-mesh_new.c
@@ -2811,6 +2811,7 @@ queue_send (void *cls, size_t size, void *buf)
             GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "*********   type unknown\n");
             data_size = 0;
     }
+    queue->tunnel->queue_n--;
 
     /* Free queue, but cls was freed by send_core_* */
     queue_destroy(queue, GNUNET_NO);
@@ -2860,6 +2861,7 @@ queue_add (void *cls, uint16_t type, size_t size,
         GNUNET_break(0);
       return;                       // Drop message
     }
+    t->queue_n++;
     queue = GNUNET_malloc (sizeof (struct MeshPeerQueue));
     queue->cls = cls;
     queue->type = type;