aboutsummaryrefslogtreecommitdiff
path: root/src/util
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2016-09-20 02:28:01 +0000
committerChristian Grothoff <christian@grothoff.org>2016-09-20 02:28:01 +0000
commit6a131ab255bb3419eb0e59a24879556d5b1c75d3 (patch)
tree3d5a543eb36d2184fbc9d390ecd3c9e092614e13 /src/util
parent102ef991828f70f8a4baa9755be02e5a17a67110 (diff)
downloadgnunet-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.c3
-rw-r--r--src/util/service_new.c1
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,