diff options
| author | Christian Grothoff <christian@grothoff.org> | 2016-06-24 20:17:39 +0000 |
|---|---|---|
| committer | Christian Grothoff <christian@grothoff.org> | 2016-06-24 20:17:39 +0000 |
| commit | 3140154d46212e08e0d73ed891a66213a6813075 (patch) | |
| tree | 018a55a3899207664b388fcf47a679ca54ca6fbf /src/fs/fs_unindex.c | |
| parent | d5fd881c2a044474b54ddf03b6ab8be8d2b75927 (diff) | |
refactoring datastore API to use MQ API, also fixing misc. bugs in new mysql backend
Diffstat (limited to 'src/fs/fs_unindex.c')
| -rw-r--r-- | src/fs/fs_unindex.c | 5 |
1 files changed, 1 insertions, 4 deletions
diff --git a/src/fs/fs_unindex.c b/src/fs/fs_unindex.c index 2e9c17217a..2c4cb6ae67 100644 --- a/src/fs/fs_unindex.c +++ b/src/fs/fs_unindex.c @@ -215,7 +215,7 @@ unindex_process (void *cls, GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Sending REMOVE request to DATASTORE service\n"); GNUNET_DATASTORE_remove (uc->dsh, &chk->query, size, data, -2, 1, - GNUNET_CONSTANTS_SERVICE_TIMEOUT, &process_cont, uc); + &process_cont, uc); uc->chk = *chk; } @@ -552,7 +552,6 @@ process_kblock_for_unindex (void *cls, data, 0 /* priority */, 1 /* queue size */, - GNUNET_TIME_UNIT_FOREVER_REL, &continue_after_remove, uc); return; @@ -563,7 +562,6 @@ process_kblock_for_unindex (void *cls, GNUNET_BLOCK_TYPE_FS_UBLOCK, 0 /* priority */, 1 /* queue size */, - GNUNET_TIME_UNIT_FOREVER_REL, &process_kblock_for_unindex, uc); } @@ -615,7 +613,6 @@ GNUNET_FS_unindex_do_remove_kblocks_ (struct GNUNET_FS_UnindexContext *uc) GNUNET_BLOCK_TYPE_FS_UBLOCK, 0 /* priority */, 1 /* queue size */, - GNUNET_TIME_UNIT_FOREVER_REL, &process_kblock_for_unindex, uc); } |