diff options
author | t3sserakt <t3ss@posteo.de> | 2022-03-17 14:28:40 +0100 |
---|---|---|
committer | t3sserakt <t3ss@posteo.de> | 2022-03-17 14:28:40 +0100 |
commit | 95a1edacccd9b3bf769a144a12d41946d0ac25dc (patch) | |
tree | b84608361cd836d29649f076589dd42943d1301f /src/util | |
parent | 16c9959d9b395b179446ee4a2cb70f3563c4fb20 (diff) | |
download | gnunet-95a1edacccd9b3bf769a144a12d41946d0ac25dc.tar.gz gnunet-95a1edacccd9b3bf769a144a12d41946d0ac25dc.zip |
- Trying to exchange iptables with nft, first shot failed.
- Fixed small bug in UDP communicator.
- Fixed bug in DV circle test case
- Introduced a default value to wait for a reliability ack.
- Introduced a FC retransmission threshold together with a retransmission count.
- Introduced a original size value for TransportDVBoxMessage
- Checking if we have the root pending messge, when removing the pending message from virtual link.
- Added delay value to schedule_transmit_on_queue to wait for retransmitting.
- Checking for confirmed virtual link, before routing.
- Allow unconfirmed queues or DV routes when doing dv encapsulation for control traffic.
- Changed check_vl_transmission to also check window size for DV next hop peer.
- Fixed fragment box handling to also handle reliability boxed message which needed to be fragmented.
- Fixed completing a message which was not only fragmented but also DV boxed.
- Added logic to notify core about a new virtual link using distance vector without having validated next neighbour.
- Added logic to create a virtual link to handle flow control messages.
- fixed several smaller bugs in fragmentation logic.
- Changed logic for adding the next_attempt value of PendingMessage.
Diffstat (limited to 'src/util')
-rw-r--r-- | src/util/mq.c | 11 |
1 files changed, 7 insertions, 4 deletions
diff --git a/src/util/mq.c b/src/util/mq.c index b09837459..40ac97bbe 100644 --- a/src/util/mq.c +++ b/src/util/mq.c | |||
@@ -273,7 +273,7 @@ GNUNET_MQ_handle_message (const struct GNUNET_MQ_MessageHandler *handlers, | |||
273 | break; | 273 | break; |
274 | } | 274 | } |
275 | } | 275 | } |
276 | done: | 276 | done: |
277 | if (GNUNET_NO == handled) | 277 | if (GNUNET_NO == handled) |
278 | { | 278 | { |
279 | LOG (GNUNET_ERROR_TYPE_INFO, | 279 | LOG (GNUNET_ERROR_TYPE_INFO, |
@@ -384,8 +384,9 @@ GNUNET_MQ_send (struct GNUNET_MQ_Handle *mq, | |||
384 | mq->current_envelope = ev; | 384 | mq->current_envelope = ev; |
385 | 385 | ||
386 | LOG (GNUNET_ERROR_TYPE_DEBUG, | 386 | LOG (GNUNET_ERROR_TYPE_DEBUG, |
387 | "sending message of type %u, queue empty (MQ: %p)\n", | 387 | "sending message of type %u and size %u, queue empty (MQ: %p)\n", |
388 | ntohs (ev->mh->type), | 388 | ntohs (ev->mh->type), |
389 | ntohs (ev->mh->size), | ||
389 | mq); | 390 | mq); |
390 | 391 | ||
391 | mq->send_impl (mq, | 392 | mq->send_impl (mq, |
@@ -479,8 +480,10 @@ impl_send_continue (void *cls) | |||
479 | mq->current_envelope); | 480 | mq->current_envelope); |
480 | 481 | ||
481 | LOG (GNUNET_ERROR_TYPE_DEBUG, | 482 | LOG (GNUNET_ERROR_TYPE_DEBUG, |
482 | "sending message of type %u from queue\n", | 483 | "sending message of type %u and size %u from queue (MQ: %p)\n", |
483 | ntohs (mq->current_envelope->mh->type)); | 484 | ntohs (mq->current_envelope->mh->type), |
485 | ntohs (mq->current_envelope->mh->size), | ||
486 | mq); | ||
484 | 487 | ||
485 | mq->send_impl (mq, | 488 | mq->send_impl (mq, |
486 | mq->current_envelope->mh, | 489 | mq->current_envelope->mh, |