diff options
Diffstat (limited to 'src/dv/gnunet-service-dv.c')
-rw-r--r-- | src/dv/gnunet-service-dv.c | 8 |
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 | */ |
1351 | static void | 1352 | static void |
1352 | handle_set_union_result (void *cls, | 1353 | handle_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; |