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 | |
parent | 102ef991828f70f8a4baa9755be02e5a17a67110 (diff) | |
download | gnunet-6a131ab255bb3419eb0e59a24879556d5b1c75d3.tar.gz gnunet-6a131ab255bb3419eb0e59a24879556d5b1c75d3.zip |
convert statistics service to new service MQ API
Diffstat (limited to 'src/util')
-rw-r--r-- | src/util/mq.c | 3 | ||||
-rw-r--r-- | src/util/service_new.c | 1 |
2 files changed, 4 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); |
diff --git a/src/util/service_new.c b/src/util/service_new.c index fe8e79f17..123b40d5b 100644 --- a/src/util/service_new.c +++ b/src/util/service_new.c | |||
@@ -1954,6 +1954,7 @@ service_client_mst_cb (void *cls, | |||
1954 | client->needs_continue = GNUNET_YES; | 1954 | client->needs_continue = GNUNET_YES; |
1955 | client->warn_type = ntohs (message->type); | 1955 | client->warn_type = ntohs (message->type); |
1956 | client->warn_start = GNUNET_TIME_absolute_get (); | 1956 | client->warn_start = GNUNET_TIME_absolute_get (); |
1957 | GNUNET_assert (NULL == client->warn_task); | ||
1957 | client->warn_task | 1958 | client->warn_task |
1958 | = GNUNET_SCHEDULER_add_delayed (GNUNET_TIME_UNIT_MINUTES, | 1959 | = GNUNET_SCHEDULER_add_delayed (GNUNET_TIME_UNIT_MINUTES, |
1959 | &warn_no_client_continue, | 1960 | &warn_no_client_continue, |