diff options
author | Christian Grothoff <christian@grothoff.org> | 2012-01-01 21:12:17 +0000 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2012-01-01 21:12:17 +0000 |
commit | 64c442461b84953230d3dc4e78cb649db6c54abc (patch) | |
tree | 49ec875b32ce171aac2bbae1b5fcaad516a94cf6 /src/datastore | |
parent | 0413c7690e087a0514447a87bc8118b2a244c902 (diff) | |
download | gnunet-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.c | 12 |
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 | ||