diff options
author | Christian Grothoff <christian@grothoff.org> | 2011-12-13 14:36:14 +0000 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2011-12-13 14:36:14 +0000 |
commit | 0359b6a7261026c230056c121d4344f82814cef6 (patch) | |
tree | a2a8a5f810c23e42308fe50f927b5aa6f603fe27 /src/fs/gnunet-service-fs_lc.c | |
parent | e9a2275de31a09124c983716a611c7a8fc3ee167 (diff) | |
download | gnunet-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.c | 10 |
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; |