aboutsummaryrefslogtreecommitdiff
path: root/src/fs/fs_unindex.c
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2016-06-24 20:17:39 +0000
committerChristian Grothoff <christian@grothoff.org>2016-06-24 20:17:39 +0000
commit3140154d46212e08e0d73ed891a66213a6813075 (patch)
tree018a55a3899207664b388fcf47a679ca54ca6fbf /src/fs/fs_unindex.c
parentd5fd881c2a044474b54ddf03b6ab8be8d2b75927 (diff)
downloadgnunet-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.c5
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}