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) | |
download | gnunet-3140154d46212e08e0d73ed891a66213a6813075.tar.gz gnunet-3140154d46212e08e0d73ed891a66213a6813075.zip |
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 2e9c17217..2c4cb6ae6 100644 --- a/src/fs/fs_unindex.c +++ b/src/fs/fs_unindex.c | |||
@@ -215,7 +215,7 @@ unindex_process (void *cls, | |||
215 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 215 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
216 | "Sending REMOVE request to DATASTORE service\n"); | 216 | "Sending REMOVE request to DATASTORE service\n"); |
217 | GNUNET_DATASTORE_remove (uc->dsh, &chk->query, size, data, -2, 1, | 217 | GNUNET_DATASTORE_remove (uc->dsh, &chk->query, size, data, -2, 1, |
218 | GNUNET_CONSTANTS_SERVICE_TIMEOUT, &process_cont, uc); | 218 | &process_cont, uc); |
219 | uc->chk = *chk; | 219 | uc->chk = *chk; |
220 | } | 220 | } |
221 | 221 | ||
@@ -552,7 +552,6 @@ process_kblock_for_unindex (void *cls, | |||
552 | data, | 552 | data, |
553 | 0 /* priority */, | 553 | 0 /* priority */, |
554 | 1 /* queue size */, | 554 | 1 /* queue size */, |
555 | GNUNET_TIME_UNIT_FOREVER_REL, | ||
556 | &continue_after_remove, | 555 | &continue_after_remove, |
557 | uc); | 556 | uc); |
558 | return; | 557 | return; |
@@ -563,7 +562,6 @@ process_kblock_for_unindex (void *cls, | |||
563 | GNUNET_BLOCK_TYPE_FS_UBLOCK, | 562 | GNUNET_BLOCK_TYPE_FS_UBLOCK, |
564 | 0 /* priority */, | 563 | 0 /* priority */, |
565 | 1 /* queue size */, | 564 | 1 /* queue size */, |
566 | GNUNET_TIME_UNIT_FOREVER_REL, | ||
567 | &process_kblock_for_unindex, | 565 | &process_kblock_for_unindex, |
568 | uc); | 566 | uc); |
569 | } | 567 | } |
@@ -615,7 +613,6 @@ GNUNET_FS_unindex_do_remove_kblocks_ (struct GNUNET_FS_UnindexContext *uc) | |||
615 | GNUNET_BLOCK_TYPE_FS_UBLOCK, | 613 | GNUNET_BLOCK_TYPE_FS_UBLOCK, |
616 | 0 /* priority */, | 614 | 0 /* priority */, |
617 | 1 /* queue size */, | 615 | 1 /* queue size */, |
618 | GNUNET_TIME_UNIT_FOREVER_REL, | ||
619 | &process_kblock_for_unindex, | 616 | &process_kblock_for_unindex, |
620 | uc); | 617 | uc); |
621 | } | 618 | } |