summaryrefslogtreecommitdiff
path: root/src/transport/transport-testing2.c
diff options
context:
space:
mode:
authort3sserakt <t3ss@posteo.de>2020-10-15 08:36:32 +0200
committert3sserakt <t3ss@posteo.de>2020-10-15 08:37:01 +0200
commit2c529c7009239b4c9068069bb63f3978a9a41b1a (patch)
treeaeeb94d8f3cd611fa3088ebffd688a79b94c30bc /src/transport/transport-testing2.c
parent032f5c0850c7034752be1c4c86a68fb9914ec3e0 (diff)
- backchannel alternativ 1
Diffstat (limited to 'src/transport/transport-testing2.c')
-rw-r--r--src/transport/transport-testing2.c10
1 files changed, 6 insertions, 4 deletions
diff --git a/src/transport/transport-testing2.c b/src/transport/transport-testing2.c
index 1e2579048..076fbf331 100644
--- a/src/transport/transport-testing2.c
+++ b/src/transport/transport-testing2.c
@@ -554,9 +554,10 @@ handle_update_queue_message (void *cls,
tc_queue->cs = msg->cs;
tc_queue->priority = ntohl (msg->priority);
// Uncomment this for alternativ 1 of backchannel functionality
- // tc_queue->q_len += GNUNET_ntohll (msg->q_len);
+ tc_queue->q_len += GNUNET_ntohll (msg->q_len);
+ // Until here for alternativ 1
// Uncomment this for alternativ 2 of backchannel functionality
- tc_queue->q_len = GNUNET_ntohll (msg->q_len);
+ // tc_queue->q_len = GNUNET_ntohll (msg->q_len);
// Until here for alternativ 2
GNUNET_SERVICE_client_continue (client->client);
}
@@ -1135,8 +1136,9 @@ GNUNET_TRANSPORT_TESTING_transport_communicator_send
}
GNUNET_assert (NULL != tc_queue);
// Uncomment this for alternativ 1 of backchannel functionality
- /*if (tc_queue->q_len != GNUNET_TRANSPORT_QUEUE_LENGTH_UNLIMITED)
- tc_queue->q_len--;*/
+ if (tc_queue->q_len != GNUNET_TRANSPORT_QUEUE_LENGTH_UNLIMITED)
+ tc_queue->q_len--;
+ // Until here for alternativ 1
GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
"Sending message\n");
inbox_size = sizeof (struct GNUNET_MessageHeader) + payload_size;