aboutsummaryrefslogtreecommitdiff
path: root/src/fs/gnunet-service-fs_lc.c
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2011-12-13 14:36:14 +0000
committerChristian Grothoff <christian@grothoff.org>2011-12-13 14:36:14 +0000
commit0359b6a7261026c230056c121d4344f82814cef6 (patch)
treea2a8a5f810c23e42308fe50f927b5aa6f603fe27 /src/fs/gnunet-service-fs_lc.c
parente9a2275de31a09124c983716a611c7a8fc3ee167 (diff)
downloadgnunet-0359b6a7261026c230056c121d4344f82814cef6.tar.gz
gnunet-0359b6a7261026c230056c121d4344f82814cef6.zip
trying to fix #2000
Diffstat (limited to 'src/fs/gnunet-service-fs_lc.c')
-rw-r--r--src/fs/gnunet-service-fs_lc.c10
1 files changed, 5 insertions, 5 deletions
diff --git a/src/fs/gnunet-service-fs_lc.c b/src/fs/gnunet-service-fs_lc.c
index 502cef941..d8f7d5cb3 100644
--- a/src/fs/gnunet-service-fs_lc.c
+++ b/src/fs/gnunet-service-fs_lc.c
@@ -332,15 +332,15 @@ GSF_local_client_start_search_handler_ (struct GNUNET_SERVER_Client *client,
332 if ((type == GNUNET_BLOCK_TYPE_FS_KBLOCK) || 332 if ((type == GNUNET_BLOCK_TYPE_FS_KBLOCK) ||
333 (type == GNUNET_BLOCK_TYPE_FS_NBLOCK) || (type == GNUNET_BLOCK_TYPE_ANY)) 333 (type == GNUNET_BLOCK_TYPE_FS_NBLOCK) || (type == GNUNET_BLOCK_TYPE_ANY))
334 { 334 {
335 /* FIXME: this does currently not work to filter duplicate
336 * results from *local* datastore since the local store is
337 * queried before we continue to process additional
338 * messages from the client! -- fix protocol? */
339 cr = lc->cr_head; 335 cr = lc->cr_head;
340 while (cr != NULL) 336 while (cr != NULL)
341 { 337 {
342 prd = GSF_pending_request_get_data_ (cr->pr); 338 prd = GSF_pending_request_get_data_ (cr->pr);
343 if ((0 != memcmp (&prd->query, &sm->query, sizeof (GNUNET_HashCode))) && 339 /* only unify with queries that hae not yet started local processing
340 (SEARCH_MESSAGE_OPTION_CONTINUED was always set) and that have a
341 matching query and type */
342 if ((GNUNET_YES != prd->has_started) &&
343 (0 != memcmp (&prd->query, &sm->query, sizeof (GNUNET_HashCode))) &&
344 (prd->type == type)) 344 (prd->type == type))
345 break; 345 break;
346 cr = cr->next; 346 cr = cr->next;