aboutsummaryrefslogtreecommitdiff
path: root/src/util
diff options
context:
space:
mode:
authort3sserakt <t3ss@posteo.de>2022-03-17 14:28:40 +0100
committert3sserakt <t3ss@posteo.de>2022-03-17 14:28:40 +0100
commit95a1edacccd9b3bf769a144a12d41946d0ac25dc (patch)
treeb84608361cd836d29649f076589dd42943d1301f /src/util
parent16c9959d9b395b179446ee4a2cb70f3563c4fb20 (diff)
downloadgnunet-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.c11
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 }
276done: 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,