diff options
| author | Christian Grothoff <christian@grothoff.org> | 2016-09-20 02:28:01 +0000 |
|---|---|---|
| committer | Christian Grothoff <christian@grothoff.org> | 2016-09-20 02:28:01 +0000 |
| commit | 6a131ab255bb3419eb0e59a24879556d5b1c75d3 (patch) | |
| tree | 3d5a543eb36d2184fbc9d390ecd3c9e092614e13 /src/util/mq.c | |
| parent | 102ef991828f70f8a4baa9755be02e5a17a67110 (diff) | |
convert statistics service to new service MQ API
Diffstat (limited to 'src/util/mq.c')
| -rw-r--r-- | src/util/mq.c | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/src/util/mq.c b/src/util/mq.c index e69d1c483a..61b5471e1b 100644 --- a/src/util/mq.c +++ b/src/util/mq.c @@ -1046,7 +1046,10 @@ GNUNET_MQ_destroy (struct GNUNET_MQ_Handle *mq) } GNUNET_assert (0 == mq->queue_length); while (NULL != (dnh = mq->dnh_head)) + { dnh->cb (dnh->cb_cls); + GNUNET_MQ_destroy_notify_cancel (dnh); + } if (NULL != mq->assoc_map) { GNUNET_CONTAINER_multihashmap32_destroy (mq->assoc_map); |