aboutsummaryrefslogtreecommitdiff
path: root/src/fs/gnunet-service-fs_pr.c
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2022-05-31 23:43:05 +0200
committerChristian Grothoff <christian@grothoff.org>2022-05-31 23:43:05 +0200
commitedddc9384e9bc4331d57291de7318bbe401e49b0 (patch)
treebe9387df3a4fa4e8cb71590501fb3740920c5bb6 /src/fs/gnunet-service-fs_pr.c
parent02a2c3560aa08c3c7f389706b0e24007e2010bc5 (diff)
downloadgnunet-edddc9384e9bc4331d57291de7318bbe401e49b0.tar.gz
gnunet-edddc9384e9bc4331d57291de7318bbe401e49b0.zip
protocol change: swap xquery and result filter, integrate mutator with result filter
Diffstat (limited to 'src/fs/gnunet-service-fs_pr.c')
-rw-r--r--src/fs/gnunet-service-fs_pr.c10
1 files changed, 1 insertions, 9 deletions
diff --git a/src/fs/gnunet-service-fs_pr.c b/src/fs/gnunet-service-fs_pr.c
index 154c454ca..f05194907 100644
--- a/src/fs/gnunet-service-fs_pr.c
+++ b/src/fs/gnunet-service-fs_pr.c
@@ -260,9 +260,6 @@ refresh_bloomfilter (enum GNUNET_BLOCK_Type type,
260 pr->bg = 260 pr->bg =
261 GNUNET_BLOCK_group_create (GSF_block_ctx, 261 GNUNET_BLOCK_group_create (GSF_block_ctx,
262 type, 262 type,
263 GNUNET_CRYPTO_random_u32 (
264 GNUNET_CRYPTO_QUALITY_WEAK,
265 UINT32_MAX),
266 NULL, 263 NULL,
267 0, 264 0,
268 "seen-set-size", 265 "seen-set-size",
@@ -286,7 +283,6 @@ refresh_bloomfilter (enum GNUNET_BLOCK_Type type,
286 * @param target preferred target for the request, NULL for none 283 * @param target preferred target for the request, NULL for none
287 * @param bf_data raw data for bloom filter for known replies, can be NULL 284 * @param bf_data raw data for bloom filter for known replies, can be NULL
288 * @param bf_size number of bytes in @a bf_data 285 * @param bf_size number of bytes in @a bf_data
289 * @param mingle mingle value for bf
290 * @param anonymity_level desired anonymity level 286 * @param anonymity_level desired anonymity level
291 * @param priority maximum outgoing cumulative request priority to use 287 * @param priority maximum outgoing cumulative request priority to use
292 * @param ttl current time-to-live for the request 288 * @param ttl current time-to-live for the request
@@ -305,7 +301,6 @@ GSF_pending_request_create_ (enum GSF_PendingRequestOptions options,
305 const struct GNUNET_PeerIdentity *target, 301 const struct GNUNET_PeerIdentity *target,
306 const char *bf_data, 302 const char *bf_data,
307 size_t bf_size, 303 size_t bf_size,
308 uint32_t mingle,
309 uint32_t anonymity_level, 304 uint32_t anonymity_level,
310 uint32_t priority, 305 uint32_t priority,
311 int32_t ttl, 306 int32_t ttl,
@@ -376,7 +371,6 @@ GSF_pending_request_create_ (enum GSF_PendingRequestOptions options,
376 { 371 {
377 pr->bg = GNUNET_BLOCK_group_create (GSF_block_ctx, 372 pr->bg = GNUNET_BLOCK_group_create (GSF_block_ctx,
378 pr->public_data.type, 373 pr->public_data.type,
379 mingle,
380 bf_data, 374 bf_data,
381 bf_size, 375 bf_size,
382 "seen-set-size", 376 "seen-set-size",
@@ -533,7 +527,6 @@ GSF_pending_request_get_message_ (struct GSF_PendingRequest *pr)
533 int64_t ttl; 527 int64_t ttl;
534 int do_route; 528 int do_route;
535 void *bf_data; 529 void *bf_data;
536 uint32_t bf_nonce;
537 530
538 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, 531 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
539 "Building request message for `%s' of type %d\n", 532 "Building request message for `%s' of type %d\n",
@@ -559,7 +552,6 @@ GSF_pending_request_get_message_ (struct GSF_PendingRequest *pr)
559 } 552 }
560 if (GNUNET_OK != 553 if (GNUNET_OK !=
561 GNUNET_BLOCK_group_serialize (pr->bg, 554 GNUNET_BLOCK_group_serialize (pr->bg,
562 &bf_nonce,
563 &bf_data, 555 &bf_data,
564 &bf_size)) 556 &bf_size))
565 { 557 {
@@ -582,7 +574,7 @@ GSF_pending_request_get_message_ (struct GSF_PendingRequest *pr)
582 now = GNUNET_TIME_absolute_get (); 574 now = GNUNET_TIME_absolute_get ();
583 ttl = (int64_t) (pr->public_data.ttl.abs_value_us - now.abs_value_us); 575 ttl = (int64_t) (pr->public_data.ttl.abs_value_us - now.abs_value_us);
584 gm->ttl = htonl (ttl / 1000LL / 1000LL); 576 gm->ttl = htonl (ttl / 1000LL / 1000LL);
585 gm->filter_mutator = htonl (bf_nonce); 577 gm->reserved = htonl (0);
586 gm->hash_bitmap = htonl (bm); 578 gm->hash_bitmap = htonl (bm);
587 gm->query = pr->public_data.query; 579 gm->query = pr->public_data.query;
588 ext = (struct GNUNET_PeerIdentity *) &gm[1]; 580 ext = (struct GNUNET_PeerIdentity *) &gm[1];