aboutsummaryrefslogtreecommitdiff
path: root/src/datastore
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2012-01-01 21:12:17 +0000
committerChristian Grothoff <christian@grothoff.org>2012-01-01 21:12:17 +0000
commit64c442461b84953230d3dc4e78cb649db6c54abc (patch)
tree49ec875b32ce171aac2bbae1b5fcaad516a94cf6 /src/datastore
parent0413c7690e087a0514447a87bc8118b2a244c902 (diff)
downloadgnunet-64c442461b84953230d3dc4e78cb649db6c54abc.tar.gz
gnunet-64c442461b84953230d3dc4e78cb649db6c54abc.zip
changing scheduler priorities to revert to DEFAULT instead of inheriting parent-task priority unless something else is explicitly specified
Diffstat (limited to 'src/datastore')
-rw-r--r--src/datastore/gnunet-service-datastore.c12
1 files changed, 9 insertions, 3 deletions
diff --git a/src/datastore/gnunet-service-datastore.c b/src/datastore/gnunet-service-datastore.c
index bf89c1bc2..1d7e8cd2b 100644
--- a/src/datastore/gnunet-service-datastore.c
+++ b/src/datastore/gnunet-service-datastore.c
@@ -326,7 +326,9 @@ expired_processor (void *cls, const GNUNET_HashCode * key, uint32_t size,
326 if (key == NULL) 326 if (key == NULL)
327 { 327 {
328 expired_kill_task = 328 expired_kill_task =
329 GNUNET_SCHEDULER_add_delayed (MAX_EXPIRE_DELAY, &delete_expired, NULL); 329 GNUNET_SCHEDULER_add_delayed_with_priority (MAX_EXPIRE_DELAY,
330 GNUNET_SCHEDULER_PRIORITY_IDLE,
331 &delete_expired, NULL);
330 return GNUNET_SYSERR; 332 return GNUNET_SYSERR;
331 } 333 }
332 now = GNUNET_TIME_absolute_get (); 334 now = GNUNET_TIME_absolute_get ();
@@ -334,7 +336,9 @@ expired_processor (void *cls, const GNUNET_HashCode * key, uint32_t size,
334 { 336 {
335 /* finished processing */ 337 /* finished processing */
336 expired_kill_task = 338 expired_kill_task =
337 GNUNET_SCHEDULER_add_delayed (MAX_EXPIRE_DELAY, &delete_expired, NULL); 339 GNUNET_SCHEDULER_add_delayed_with_priority (MAX_EXPIRE_DELAY,
340 GNUNET_SCHEDULER_PRIORITY_IDLE,
341 &delete_expired, NULL);
338 return GNUNET_SYSERR; 342 return GNUNET_SYSERR;
339 } 343 }
340#if DEBUG_DATASTORE 344#if DEBUG_DATASTORE
@@ -348,7 +352,9 @@ expired_processor (void *cls, const GNUNET_HashCode * key, uint32_t size,
348 GNUNET_YES); 352 GNUNET_YES);
349 GNUNET_CONTAINER_bloomfilter_remove (filter, key); 353 GNUNET_CONTAINER_bloomfilter_remove (filter, key);
350 expired_kill_task = 354 expired_kill_task =
351 GNUNET_SCHEDULER_add_delayed (MIN_EXPIRE_DELAY, &delete_expired, NULL); 355 GNUNET_SCHEDULER_add_delayed_with_priority (MIN_EXPIRE_DELAY,
356 GNUNET_SCHEDULER_PRIORITY_IDLE,
357 &delete_expired, NULL);
352 return GNUNET_NO; 358 return GNUNET_NO;
353} 359}
354 360