diff options
author | t3sserakt <t3ss@posteo.de> | 2020-10-09 18:14:23 +0200 |
---|---|---|
committer | t3sserakt <t3ss@posteo.de> | 2020-10-09 18:14:23 +0200 |
commit | 03199f7f246e1d636c9feb921d66be48c907130f (patch) | |
tree | 11c7eeb26ad4038bfa0aaa1b9e8caa4064312093 /src/transport/transport-testing2.c | |
parent | c25c3fd24b691d35674b1e67cbcf1066c427c7d3 (diff) | |
download | gnunet-03199f7f246e1d636c9feb921d66be48c907130f.tar.gz gnunet-03199f7f246e1d636c9feb921d66be48c907130f.zip |
- new udp backchannel logic. Two alternatives. Test not working.
Diffstat (limited to 'src/transport/transport-testing2.c')
-rw-r--r-- | src/transport/transport-testing2.c | 10 |
1 files changed, 7 insertions, 3 deletions
diff --git a/src/transport/transport-testing2.c b/src/transport/transport-testing2.c index 98cfd5e29..baafff249 100644 --- a/src/transport/transport-testing2.c +++ b/src/transport/transport-testing2.c | |||
@@ -553,7 +553,10 @@ handle_update_queue_message (void *cls, | |||
553 | tc_queue->mtu = ntohl (msg->mtu); | 553 | tc_queue->mtu = ntohl (msg->mtu); |
554 | tc_queue->cs = msg->cs; | 554 | tc_queue->cs = msg->cs; |
555 | tc_queue->priority = ntohl (msg->priority); | 555 | tc_queue->priority = ntohl (msg->priority); |
556 | tc_queue->q_len += GNUNET_ntohll (msg->q_len); | 556 | // Uncomment this for alternativ 1 of backchannel functionality |
557 | // tc_queue->q_len += GNUNET_ntohll (msg->q_len); | ||
558 | // Uncomment this for alternativ 2 of backchannel functionality | ||
559 | tc_queue->q_len = GNUNET_ntohll (msg->q_len); | ||
557 | GNUNET_SERVICE_client_continue (client->client); | 560 | GNUNET_SERVICE_client_continue (client->client); |
558 | } | 561 | } |
559 | 562 | ||
@@ -1130,8 +1133,9 @@ GNUNET_TRANSPORT_TESTING_transport_communicator_send | |||
1130 | } | 1133 | } |
1131 | } | 1134 | } |
1132 | GNUNET_assert (NULL != tc_queue); | 1135 | GNUNET_assert (NULL != tc_queue); |
1133 | if (tc_queue->q_len != GNUNET_TRANSPORT_QUEUE_LENGTH_UNLIMITED) | 1136 | // Uncomment this for alternativ 1 of backchannel functionality |
1134 | tc_queue->q_len--; | 1137 | /*if (tc_queue->q_len != GNUNET_TRANSPORT_QUEUE_LENGTH_UNLIMITED) |
1138 | tc_queue->q_len--;*/ | ||
1135 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 1139 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
1136 | "Sending message\n"); | 1140 | "Sending message\n"); |
1137 | inbox_size = sizeof (struct GNUNET_MessageHeader) + payload_size; | 1141 | inbox_size = sizeof (struct GNUNET_MessageHeader) + payload_size; |