diff options
author | Martin Schanzenbach <mschanzenbach@posteo.de> | 2021-02-24 10:47:42 +0100 |
---|---|---|
committer | Martin Schanzenbach <mschanzenbach@posteo.de> | 2021-02-24 10:47:42 +0100 |
commit | e3c79b5a5d77ee22e78d503cf2318d809551ee2c (patch) | |
tree | 2c47dac334dc93f37ba5d90c8908ec95b9f4a7dc /src/transport | |
parent | 64c18a74e38a1cb74042d14a4211622a3bde3bee (diff) | |
download | gnunet-e3c79b5a5d77ee22e78d503cf2318d809551ee2c.tar.gz gnunet-e3c79b5a5d77ee22e78d503cf2318d809551ee2c.zip |
-fix mtu; neighbour send
Diffstat (limited to 'src/transport')
-rw-r--r-- | src/transport/gnunet-communicator-tcp.c | 2 | ||||
-rw-r--r-- | src/transport/gnunet-service-tng.c | 7 |
2 files changed, 4 insertions, 5 deletions
diff --git a/src/transport/gnunet-communicator-tcp.c b/src/transport/gnunet-communicator-tcp.c index ed82dba9f..273dbac48 100644 --- a/src/transport/gnunet-communicator-tcp.c +++ b/src/transport/gnunet-communicator-tcp.c | |||
@@ -1778,7 +1778,7 @@ try_handle_plaintext (struct Queue *queue) | |||
1778 | queue->qh = GNUNET_TRANSPORT_communicator_mq_add (ch, | 1778 | queue->qh = GNUNET_TRANSPORT_communicator_mq_add (ch, |
1779 | &queue->target, | 1779 | &queue->target, |
1780 | foreign_addr, | 1780 | foreign_addr, |
1781 | 0 /* no MTU */, | 1781 | UINT32_MAX, /* no MTU */ |
1782 | GNUNET_TRANSPORT_QUEUE_LENGTH_UNLIMITED, | 1782 | GNUNET_TRANSPORT_QUEUE_LENGTH_UNLIMITED, |
1783 | 0, /* Priority */ | 1783 | 0, /* Priority */ |
1784 | queue->nt, | 1784 | queue->nt, |
diff --git a/src/transport/gnunet-service-tng.c b/src/transport/gnunet-service-tng.c index 7e1953663..bfa5ca772 100644 --- a/src/transport/gnunet-service-tng.c +++ b/src/transport/gnunet-service-tng.c | |||
@@ -7765,8 +7765,8 @@ handle_validation_challenge ( | |||
7765 | /* Use route via neighbour */ | 7765 | /* Use route via neighbour */ |
7766 | n = lookup_neighbour (&sender); | 7766 | n = lookup_neighbour (&sender); |
7767 | if (NULL != n) | 7767 | if (NULL != n) |
7768 | for (struct Queue *q = n->queue_head; NULL != q; q = q->next_neighbour) | 7768 | route_via_neighbour (n, &tvr.header, |
7769 | queue_send_msg (q, NULL, &tvr, sizeof(tvr)); | 7769 | RMO_ANYTHING_GOES | RMO_REDUNDANT); |
7770 | } | 7770 | } |
7771 | 7771 | ||
7772 | finish_cmc_handling (cmc); | 7772 | finish_cmc_handling (cmc); |
@@ -9550,8 +9550,7 @@ handle_add_queue_message (void *cls, | |||
9550 | const char *addr; | 9550 | const char *addr; |
9551 | uint16_t addr_len; | 9551 | uint16_t addr_len; |
9552 | 9552 | ||
9553 | if ((0 != ntohl (aqm->mtu)) && | 9553 | if (ntohl (aqm->mtu) <= sizeof(struct TransportFragmentBoxMessage)) |
9554 | (ntohl (aqm->mtu) <= sizeof(struct TransportFragmentBoxMessage))) | ||
9555 | { | 9554 | { |
9556 | /* MTU so small as to be useless for transmissions, | 9555 | /* MTU so small as to be useless for transmissions, |
9557 | required for #fragment_message()! */ | 9556 | required for #fragment_message()! */ |