From 5a48ee09998ddd6748d286b927cef50634e93181 Mon Sep 17 00:00:00 2001 From: Bart Polot Date: Tue, 12 Jun 2012 12:42:50 +0000 Subject: [PATCH] - keep track of queue occupancy --- src/mesh/gnunet-service-mesh_new.c | 2 ++ 1 file changed, 2 insertions(+) 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; -- 2.25.1