diff options
author | Christian Grothoff <christian@grothoff.org> | 2016-04-30 08:17:37 +0000 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2016-04-30 08:17:37 +0000 |
commit | 95f9076a2139f5fb042b944a0658b6cda2fa35db (patch) | |
tree | b0826a2a1dcf812e6b4450fe6b05d47cd53ae49d /src/namecache | |
parent | 7746f68db77b9ca3c4aaca24ab2ce5253461240b (diff) | |
download | gnunet-95f9076a2139f5fb042b944a0658b6cda2fa35db.tar.gz gnunet-95f9076a2139f5fb042b944a0658b6cda2fa35db.zip |
implementing new scheduler shutdown semantics
Diffstat (limited to 'src/namecache')
-rw-r--r-- | src/namecache/gnunet-namecache.c | 6 | ||||
-rw-r--r-- | src/namecache/gnunet-service-namecache.c | 4 | ||||
-rw-r--r-- | src/namecache/test_namecache_api_cache_block.c | 7 |
3 files changed, 8 insertions, 9 deletions
diff --git a/src/namecache/gnunet-namecache.c b/src/namecache/gnunet-namecache.c index 6abcb7b92..490197b1e 100644 --- a/src/namecache/gnunet-namecache.c +++ b/src/namecache/gnunet-namecache.c | |||
@@ -202,10 +202,8 @@ run (void *cls, char *const *args, const char *cfgfile, | |||
202 | return; | 202 | return; |
203 | } | 203 | } |
204 | 204 | ||
205 | 205 | GNUNET_SCHEDULER_add_shutdown (&do_shutdown, | |
206 | GNUNET_SCHEDULER_add_delayed (GNUNET_TIME_UNIT_FOREVER_REL, | 206 | NULL); |
207 | &do_shutdown, | ||
208 | NULL); | ||
209 | ns = GNUNET_NAMECACHE_connect (cfg); | 207 | ns = GNUNET_NAMECACHE_connect (cfg); |
210 | GNUNET_GNSRECORD_query_from_public_key (&pubkey, | 208 | GNUNET_GNSRECORD_query_from_public_key (&pubkey, |
211 | name, | 209 | name, |
diff --git a/src/namecache/gnunet-service-namecache.c b/src/namecache/gnunet-service-namecache.c index 81b1cce9b..e01dfcdf3 100644 --- a/src/namecache/gnunet-service-namecache.c +++ b/src/namecache/gnunet-service-namecache.c | |||
@@ -404,8 +404,8 @@ run (void *cls, struct GNUNET_SERVER_Handle *server, | |||
404 | GNUNET_SERVER_disconnect_notify (server, | 404 | GNUNET_SERVER_disconnect_notify (server, |
405 | &client_disconnect_notification, | 405 | &client_disconnect_notification, |
406 | NULL); | 406 | NULL); |
407 | GNUNET_SCHEDULER_add_delayed (GNUNET_TIME_UNIT_FOREVER_REL, &cleanup_task, | 407 | GNUNET_SCHEDULER_add_shutdown (&cleanup_task, |
408 | NULL); | 408 | NULL); |
409 | } | 409 | } |
410 | 410 | ||
411 | 411 | ||
diff --git a/src/namecache/test_namecache_api_cache_block.c b/src/namecache/test_namecache_api_cache_block.c index 5522b207d..7b0e6e318 100644 --- a/src/namecache/test_namecache_api_cache_block.c +++ b/src/namecache/test_namecache_api_cache_block.c | |||
@@ -108,10 +108,11 @@ rd_decrypt_cb (void *cls, | |||
108 | 108 | ||
109 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 109 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
110 | "Block was decrypted successfully \n"); | 110 | "Block was decrypted successfully \n"); |
111 | 111 | ||
112 | GNUNET_SCHEDULER_add_now (&end, NULL); | 112 | GNUNET_SCHEDULER_add_now (&end, NULL); |
113 | } | 113 | } |
114 | 114 | ||
115 | |||
115 | static void | 116 | static void |
116 | name_lookup_proc (void *cls, | 117 | name_lookup_proc (void *cls, |
117 | const struct GNUNET_GNSRECORD_Block *block) | 118 | const struct GNUNET_GNSRECORD_Block *block) |
@@ -131,7 +132,7 @@ name_lookup_proc (void *cls, | |||
131 | { | 132 | { |
132 | GNUNET_log (GNUNET_ERROR_TYPE_ERROR, | 133 | GNUNET_log (GNUNET_ERROR_TYPE_ERROR, |
133 | _("Namecache returned no block\n")); | 134 | _("Namecache returned no block\n")); |
134 | if (endbadly_task != NULL) | 135 | if (NULL != endbadly_task) |
135 | GNUNET_SCHEDULER_cancel (endbadly_task); | 136 | GNUNET_SCHEDULER_cancel (endbadly_task); |
136 | endbadly_task = GNUNET_SCHEDULER_add_now (&endbadly, NULL); | 137 | endbadly_task = GNUNET_SCHEDULER_add_now (&endbadly, NULL); |
137 | return; | 138 | return; |