aboutsummaryrefslogtreecommitdiff
path: root/src/dv/gnunet-service-dv.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/dv/gnunet-service-dv.c')
-rw-r--r--src/dv/gnunet-service-dv.c8
1 files changed, 6 insertions, 2 deletions
diff --git a/src/dv/gnunet-service-dv.c b/src/dv/gnunet-service-dv.c
index 6adaa04d9..fa1c16be8 100644
--- a/src/dv/gnunet-service-dv.c
+++ b/src/dv/gnunet-service-dv.c
@@ -399,7 +399,7 @@ send_data_to_plugin (const struct GNUNET_MessageHeader *message,
399 (unsigned int) distance); 399 (unsigned int) distance);
400 size = sizeof (struct GNUNET_DV_ReceivedMessage) + 400 size = sizeof (struct GNUNET_DV_ReceivedMessage) +
401 ntohs (message->size); 401 ntohs (message->size);
402 if (size >= GNUNET_SERVER_MAX_MESSAGE_SIZE) 402 if (size >= GNUNET_MAX_MESSAGE_SIZE)
403 { 403 {
404 GNUNET_break (0); /* too big */ 404 GNUNET_break (0); /* too big */
405 return; 405 return;
@@ -537,7 +537,7 @@ forward_payload (struct DirectNeighbor *target,
537 return; 537 return;
538 } 538 }
539 if (sizeof (struct RouteMessage) + ntohs (payload->size) 539 if (sizeof (struct RouteMessage) + ntohs (payload->size)
540 >= GNUNET_SERVER_MAX_MESSAGE_SIZE) 540 >= GNUNET_MAX_MESSAGE_SIZE)
541 { 541 {
542 GNUNET_break (0); 542 GNUNET_break (0);
543 return; 543 return;
@@ -1346,11 +1346,13 @@ check_target_added (void *cls,
1346 * 1346 *
1347 * @param cls the `struct DirectNeighbor` we're building the consensus with 1347 * @param cls the `struct DirectNeighbor` we're building the consensus with
1348 * @param element a result element, only valid if status is #GNUNET_SET_STATUS_OK 1348 * @param element a result element, only valid if status is #GNUNET_SET_STATUS_OK
1349 * @param current_size current set size
1349 * @param status see `enum GNUNET_SET_Status` 1350 * @param status see `enum GNUNET_SET_Status`
1350 */ 1351 */
1351static void 1352static void
1352handle_set_union_result (void *cls, 1353handle_set_union_result (void *cls,
1353 const struct GNUNET_SET_Element *element, 1354 const struct GNUNET_SET_Element *element,
1355 uint64_t current_size,
1354 enum GNUNET_SET_Status status) 1356 enum GNUNET_SET_Status status)
1355{ 1357{
1356 struct DirectNeighbor *neighbor = cls; 1358 struct DirectNeighbor *neighbor = cls;
@@ -1528,6 +1530,7 @@ listen_set_union (void *cls,
1528 GNUNET_SET_OPERATION_UNION); 1530 GNUNET_SET_OPERATION_UNION);
1529 neighbor->set_op = GNUNET_SET_accept (request, 1531 neighbor->set_op = GNUNET_SET_accept (request,
1530 GNUNET_SET_RESULT_ADDED, 1532 GNUNET_SET_RESULT_ADDED,
1533 (struct GNUNET_SET_Option[]) {{ 0 }},
1531 &handle_set_union_result, 1534 &handle_set_union_result,
1532 neighbor); 1535 neighbor);
1533 neighbor->consensus_insertion_offset = 0; 1536 neighbor->consensus_insertion_offset = 0;
@@ -1558,6 +1561,7 @@ initiate_set_union (void *cls)
1558 &neighbor->real_session_id, 1561 &neighbor->real_session_id,
1559 NULL, 1562 NULL,
1560 GNUNET_SET_RESULT_ADDED, 1563 GNUNET_SET_RESULT_ADDED,
1564 (struct GNUNET_SET_Option[]) {{ 0 }},
1561 &handle_set_union_result, 1565 &handle_set_union_result,
1562 neighbor); 1566 neighbor);
1563 neighbor->consensus_insertion_offset = 0; 1567 neighbor->consensus_insertion_offset = 0;