aboutsummaryrefslogtreecommitdiff
path: root/src/fs/gnunet-service-fs_pr.c
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2012-11-10 21:36:00 +0000
committerChristian Grothoff <christian@grothoff.org>2012-11-10 21:36:00 +0000
commit9cf1bc6a99fe52225cb216150f65035c4faeb227 (patch)
tree29ac0e6db989517d5cd4ded30e2cd1b1d1646220 /src/fs/gnunet-service-fs_pr.c
parent3b2b7374d2d31f7b2638c82711f40f7113e9f7f0 (diff)
downloadgnunet-9cf1bc6a99fe52225cb216150f65035c4faeb227.tar.gz
gnunet-9cf1bc6a99fe52225cb216150f65035c4faeb227.zip
use new DHT API to block known results when searching in the DHT
Diffstat (limited to 'src/fs/gnunet-service-fs_pr.c')
-rw-r--r--src/fs/gnunet-service-fs_pr.c10
1 files changed, 9 insertions, 1 deletions
diff --git a/src/fs/gnunet-service-fs_pr.c b/src/fs/gnunet-service-fs_pr.c
index e866f10ab..f65ed66a6 100644
--- a/src/fs/gnunet-service-fs_pr.c
+++ b/src/fs/gnunet-service-fs_pr.c
@@ -478,6 +478,10 @@ GSF_pending_request_update_ (struct GSF_PendingRequest *pr,
478 } 478 }
479 } 479 }
480 } 480 }
481 if (NULL != pr->gh)
482 GNUNET_DHT_get_filter_known_results (pr->gh,
483 replies_seen_count,
484 replies_seen);
481} 485}
482 486
483 487
@@ -1117,8 +1121,12 @@ GSF_dht_lookup_ (struct GSF_PendingRequest *pr)
1117 pr->public_data.type, &pr->public_data.query, 1121 pr->public_data.type, &pr->public_data.query,
1118 5 /* DEFAULT_GET_REPLICATION */ , 1122 5 /* DEFAULT_GET_REPLICATION */ ,
1119 GNUNET_DHT_RO_DEMULTIPLEX_EVERYWHERE, 1123 GNUNET_DHT_RO_DEMULTIPLEX_EVERYWHERE,
1120 /* FIXME: can no longer pass pr->bf/pr->mingle... */
1121 xquery, xquery_size, &handle_dht_reply, pr); 1124 xquery, xquery_size, &handle_dht_reply, pr);
1125 if ( (NULL != pr->gh) &&
1126 (0 != pr->replies_seen_count) )
1127 GNUNET_DHT_get_filter_known_results (pr->gh,
1128 pr->replies_seen_count,
1129 pr->replies_seen);
1122} 1130}
1123 1131
1124 1132