aboutsummaryrefslogtreecommitdiff
path: root/src/datastore/gnunet-service-datastore.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/datastore/gnunet-service-datastore.c')
-rw-r--r--src/datastore/gnunet-service-datastore.c23
1 files changed, 7 insertions, 16 deletions
diff --git a/src/datastore/gnunet-service-datastore.c b/src/datastore/gnunet-service-datastore.c
index 3a22f9bda..27b1cd58e 100644
--- a/src/datastore/gnunet-service-datastore.c
+++ b/src/datastore/gnunet-service-datastore.c
@@ -260,9 +260,6 @@ expired_processor (void *cls,
260 { 260 {
261 expired_kill_task 261 expired_kill_task
262 = GNUNET_SCHEDULER_add_delayed (sched, 262 = GNUNET_SCHEDULER_add_delayed (sched,
263 GNUNET_NO,
264 GNUNET_SCHEDULER_PRIORITY_IDLE,
265 GNUNET_SCHEDULER_NO_TASK,
266 MAX_EXPIRE_DELAY, 263 MAX_EXPIRE_DELAY,
267 &delete_expired, 264 &delete_expired,
268 NULL); 265 NULL);
@@ -1209,7 +1206,7 @@ cleaning_task (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc)
1209 GNUNET_CONTAINER_bloomfilter_free (filter); 1206 GNUNET_CONTAINER_bloomfilter_free (filter);
1210 filter = NULL; 1207 filter = NULL;
1211 } 1208 }
1212 // GNUNET_ARM_stop_services (cfg, tc->sched, "statistics", NULL); 1209 GNUNET_ARM_stop_services (cfg, tc->sched, "statistics", NULL);
1213} 1210}
1214 1211
1215 1212
@@ -1307,28 +1304,22 @@ run (void *cls,
1307 _("Failed to initialize bloomfilter.\n")); 1304 _("Failed to initialize bloomfilter.\n"));
1308 return; 1305 return;
1309 } 1306 }
1310// GNUNET_ARM_start_services (cfg, sched, "statistics", NULL); 1307 GNUNET_ARM_start_services (cfg, sched, "statistics", NULL);
1311 plugin = load_plugin (); 1308 plugin = load_plugin ();
1312 if (NULL == plugin) 1309 if (NULL == plugin)
1313 { 1310 {
1314 GNUNET_CONTAINER_bloomfilter_free (filter); 1311 GNUNET_CONTAINER_bloomfilter_free (filter);
1315 filter = NULL; 1312 filter = NULL;
1316// GNUNET_ARM_stop_services (cfg, sched, "statistics", NULL); 1313 GNUNET_ARM_stop_services (cfg, sched, "statistics", NULL);
1317 return; 1314 return;
1318 } 1315 }
1319 GNUNET_SERVER_disconnect_notify (server, &cleanup_reservations, NULL); 1316 GNUNET_SERVER_disconnect_notify (server, &cleanup_reservations, NULL);
1320 GNUNET_SERVER_add_handlers (server, handlers); 1317 GNUNET_SERVER_add_handlers (server, handlers);
1321 expired_kill_task 1318 expired_kill_task
1322 = GNUNET_SCHEDULER_add_delayed (sched, 1319 = GNUNET_SCHEDULER_add_with_priority (sched,
1323 GNUNET_NO, 1320 GNUNET_SCHEDULER_PRIORITY_IDLE,
1324 GNUNET_SCHEDULER_PRIORITY_IDLE, 1321 &delete_expired, NULL);
1325 GNUNET_SCHEDULER_NO_TASK,
1326 GNUNET_TIME_UNIT_ZERO,
1327 &delete_expired, NULL);
1328 GNUNET_SCHEDULER_add_delayed (sched, 1322 GNUNET_SCHEDULER_add_delayed (sched,
1329 GNUNET_YES,
1330 GNUNET_SCHEDULER_PRIORITY_IDLE,
1331 GNUNET_SCHEDULER_NO_TASK,
1332 GNUNET_TIME_UNIT_FOREVER_REL, 1323 GNUNET_TIME_UNIT_FOREVER_REL,
1333 &cleaning_task, NULL); 1324 &cleaning_task, NULL);
1334 1325
@@ -1350,7 +1341,7 @@ main (int argc, char *const *argv)
1350 ret = (GNUNET_OK == 1341 ret = (GNUNET_OK ==
1351 GNUNET_SERVICE_run (argc, 1342 GNUNET_SERVICE_run (argc,
1352 argv, 1343 argv,
1353 "datastore", &run, NULL, NULL, NULL)) ? 0 : 1; 1344 "datastore", &run, NULL)) ? 0 : 1;
1354 return ret; 1345 return ret;
1355} 1346}
1356 1347