aboutsummaryrefslogtreecommitdiff
path: root/src/set
diff options
context:
space:
mode:
authorChristian Fuchs <christian.fuchs@cfuchs.net>2013-12-09 16:31:38 +0000
committerChristian Fuchs <christian.fuchs@cfuchs.net>2013-12-09 16:31:38 +0000
commit0dd7d4cbec94a444e809907126b75e0f48a1547f (patch)
tree02b125859df711968665d135d90919031ff08d29 /src/set
parent119238db5e4b71e477a0ea2c9085eaa4251e026a (diff)
downloadgnunet-0dd7d4cbec94a444e809907126b75e0f48a1547f.tar.gz
gnunet-0dd7d4cbec94a444e809907126b75e0f48a1547f.zip
- jummy, multiparts!
- Hatchet
Diffstat (limited to 'src/set')
-rw-r--r--src/set/gnunet-service-set_intersection.c4
1 files changed, 2 insertions, 2 deletions
diff --git a/src/set/gnunet-service-set_intersection.c b/src/set/gnunet-service-set_intersection.c
index 627b96fda..9fa51e4f1 100644
--- a/src/set/gnunet-service-set_intersection.c
+++ b/src/set/gnunet-service-set_intersection.c
@@ -356,11 +356,10 @@ send_bloomfilter_multipart (struct Operation *op, uint32_t offset)
356 ev = GNUNET_MQ_msg_extra (msg, chunk_size, GNUNET_MESSAGE_TYPE_SET_INTERSECTION_P2P_BF); 356 ev = GNUNET_MQ_msg_extra (msg, chunk_size, GNUNET_MESSAGE_TYPE_SET_INTERSECTION_P2P_BF);
357 357
358 msg->reserved = 0; 358 msg->reserved = 0;
359 msg->sender_element_count = htonl (op->state->my_element_count);
360 msg->bloomfilter_total_length = htonl (op->state->local_bf_data_size); 359 msg->bloomfilter_total_length = htonl (op->state->local_bf_data_size);
361 msg->bloomfilter_length = htonl (chunk_size); 360 msg->bloomfilter_length = htonl (chunk_size);
362 msg->bloomfilter_offset = htonl (offset); 361 msg->bloomfilter_offset = htonl (offset);
363 msg->sender_mutator = htonl (op->spec->salt); 362 memcpy(&msg[1], op->state->local_bf, chunk_size);
364 363
365 GNUNET_MQ_send (op->mq, ev); 364 GNUNET_MQ_send (op->mq, ev);
366 365
@@ -369,6 +368,7 @@ send_bloomfilter_multipart (struct Operation *op, uint32_t offset)
369 // done 368 // done
370 GNUNET_CONTAINER_bloomfilter_free (op->state->local_bf); 369 GNUNET_CONTAINER_bloomfilter_free (op->state->local_bf);
371 GNUNET_free(op->state->local_bf_data); 370 GNUNET_free(op->state->local_bf_data);
371 op->state->local_bf_data = NULL;
372 op->state->local_bf = NULL; 372 op->state->local_bf = NULL;
373 return; 373 return;
374 } 374 }