diff options
author | Martin Schanzenbach <mschanzenbach@posteo.de> | 2021-02-26 16:26:23 +0100 |
---|---|---|
committer | Martin Schanzenbach <mschanzenbach@posteo.de> | 2021-02-26 16:26:23 +0100 |
commit | ad3e581f24153c42d3c39b4af4b83b830f18fecd (patch) | |
tree | 5fe8133780f7c9c3cd7cfc50cb046b57dcb3d0d9 /src/transport/gnunet-service-tng.c | |
parent | 0236c3a219f89826532e8b9134a81be01fda0369 (diff) | |
download | gnunet-ad3e581f24153c42d3c39b4af4b83b830f18fecd.tar.gz gnunet-ad3e581f24153c42d3c39b4af4b83b830f18fecd.zip |
-rework idle handling
Diffstat (limited to 'src/transport/gnunet-service-tng.c')
-rw-r--r-- | src/transport/gnunet-service-tng.c | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/src/transport/gnunet-service-tng.c b/src/transport/gnunet-service-tng.c index 1bdd6fa7b..f5a318b96 100644 --- a/src/transport/gnunet-service-tng.c +++ b/src/transport/gnunet-service-tng.c | |||
@@ -4210,7 +4210,7 @@ queue_send_msg (struct Queue *queue, | |||
4210 | * idle in the code. Now it is, but it is unclear if the | 4210 | * idle in the code. Now it is, but it is unclear if the |
4211 | * expected logic is preserved. | 4211 | * expected logic is preserved. |
4212 | */ | 4212 | */ |
4213 | //queue->idle = GNUNET_NO; | 4213 | queue->idle = GNUNET_NO; |
4214 | GNUNET_log ( | 4214 | GNUNET_log ( |
4215 | GNUNET_ERROR_TYPE_DEBUG, | 4215 | GNUNET_ERROR_TYPE_DEBUG, |
4216 | "Queueing %u bytes of payload for transmission <%llu> on queue %llu to %s\n", | 4216 | "Queueing %u bytes of payload for transmission <%llu> on queue %llu to %s\n", |
@@ -9107,6 +9107,7 @@ handle_send_message_ack (void *cls, | |||
9107 | qe->queue->queue_length, | 9107 | qe->queue->queue_length, |
9108 | tc->details.communicator.total_queue_length); | 9108 | tc->details.communicator.total_queue_length); |
9109 | GNUNET_SERVICE_client_continue (tc->client); | 9109 | GNUNET_SERVICE_client_continue (tc->client); |
9110 | qe->queue->idle = GNUNET_YES; | ||
9110 | 9111 | ||
9111 | /* if applicable, resume transmissions that waited on ACK */ | 9112 | /* if applicable, resume transmissions that waited on ACK */ |
9112 | if (COMMUNICATOR_TOTAL_QUEUE_LIMIT - 1 == | 9113 | if (COMMUNICATOR_TOTAL_QUEUE_LIMIT - 1 == |
@@ -9123,7 +9124,6 @@ handle_send_message_ack (void *cls, | |||
9123 | NULL != queue; | 9124 | NULL != queue; |
9124 | queue = queue->next_client) | 9125 | queue = queue->next_client) |
9125 | { | 9126 | { |
9126 | queue->idle = GNUNET_YES; | ||
9127 | schedule_transmit_on_queue (queue, GNUNET_SCHEDULER_PRIORITY_DEFAULT); | 9127 | schedule_transmit_on_queue (queue, GNUNET_SCHEDULER_PRIORITY_DEFAULT); |
9128 | } | 9128 | } |
9129 | } | 9129 | } |
@@ -9134,7 +9134,6 @@ handle_send_message_ack (void *cls, | |||
9134 | "# Transmission throttled due to queue queue limit", | 9134 | "# Transmission throttled due to queue queue limit", |
9135 | -1, | 9135 | -1, |
9136 | GNUNET_NO); | 9136 | GNUNET_NO); |
9137 | qe->queue->idle = GNUNET_YES; | ||
9138 | schedule_transmit_on_queue (qe->queue, GNUNET_SCHEDULER_PRIORITY_DEFAULT); | 9137 | schedule_transmit_on_queue (qe->queue, GNUNET_SCHEDULER_PRIORITY_DEFAULT); |
9139 | } | 9138 | } |
9140 | 9139 | ||