diff options
author | Christian Grothoff <christian@grothoff.org> | 2022-05-31 23:43:05 +0200 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2022-05-31 23:43:05 +0200 |
commit | edddc9384e9bc4331d57291de7318bbe401e49b0 (patch) | |
tree | be9387df3a4fa4e8cb71590501fb3740920c5bb6 /src/fs/gnunet-service-fs_pr.c | |
parent | 02a2c3560aa08c3c7f389706b0e24007e2010bc5 (diff) | |
download | gnunet-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.c | 10 |
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]; |