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) | |
| download | gnunet-6a131ab255bb3419eb0e59a24879556d5b1c75d3.tar.gz gnunet-6a131ab255bb3419eb0e59a24879556d5b1c75d3.zip | |
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 e69d1c483..61b5471e1 100644 --- a/src/util/mq.c +++ b/src/util/mq.c | |||
| @@ -1046,7 +1046,10 @@ GNUNET_MQ_destroy (struct GNUNET_MQ_Handle *mq) | |||
| 1046 | } | 1046 | } |
| 1047 | GNUNET_assert (0 == mq->queue_length); | 1047 | GNUNET_assert (0 == mq->queue_length); |
| 1048 | while (NULL != (dnh = mq->dnh_head)) | 1048 | while (NULL != (dnh = mq->dnh_head)) |
| 1049 | { | ||
| 1049 | dnh->cb (dnh->cb_cls); | 1050 | dnh->cb (dnh->cb_cls); |
| 1051 | GNUNET_MQ_destroy_notify_cancel (dnh); | ||
| 1052 | } | ||
| 1050 | if (NULL != mq->assoc_map) | 1053 | if (NULL != mq->assoc_map) |
| 1051 | { | 1054 | { |
| 1052 | GNUNET_CONTAINER_multihashmap32_destroy (mq->assoc_map); | 1055 | GNUNET_CONTAINER_multihashmap32_destroy (mq->assoc_map); |