aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorJacki <jacki@thejackimonster.de>2024-07-04 18:28:15 +0200
committerJacki <jacki@thejackimonster.de>2024-07-04 19:54:09 +0200
commit4ba0256369aaa141e558329d59df058acd5e3e64 (patch)
tree91d650be3734e462c197bcd0518ba56cedcbe689
parent8b6e3aa6899db445622ce6b23176cb8584100a76 (diff)
downloadgnunet-4ba0256369aaa141e558329d59df058acd5e3e64.tar.gz
gnunet-4ba0256369aaa141e558329d59df058acd5e3e64.zip
MQ: Enqueue message during send process if queue is not empty
Signed-off-by: Jacki <jacki@thejackimonster.de>
-rw-r--r--src/lib/util/mq.c5
1 files changed, 3 insertions, 2 deletions
diff --git a/src/lib/util/mq.c b/src/lib/util/mq.c
index de0cff0c2..18ec3deda 100644
--- a/src/lib/util/mq.c
+++ b/src/lib/util/mq.c
@@ -1,6 +1,6 @@
1/* 1/*
2 This file is part of GNUnet. 2 This file is part of GNUnet.
3 Copyright (C) 2012-2019 GNUnet e.V. 3 Copyright (C) 2012-2024 GNUnet e.V.
4 4
5 GNUnet is free software: you can redistribute it and/or modify it 5 GNUnet is free software: you can redistribute it and/or modify it
6 under the terms of the GNU Affero General Public License as published 6 under the terms of the GNU Affero General Public License as published
@@ -318,7 +318,8 @@ GNUNET_MQ_send (struct GNUNET_MQ_Handle *mq,
318 } 318 }
319 ev->parent_queue = mq; 319 ev->parent_queue = mq;
320 /* is the implementation busy? queue it! */ 320 /* is the implementation busy? queue it! */
321 if ((NULL != mq->current_envelope) || (NULL != mq->send_task)) 321 if ((NULL != mq->current_envelope) || (NULL != mq->send_task) ||
322 (NULL != mq->envelope_head))
322 { 323 {
323 GNUNET_CONTAINER_DLL_insert_tail (mq->envelope_head, 324 GNUNET_CONTAINER_DLL_insert_tail (mq->envelope_head,
324 mq->envelope_tail, 325 mq->envelope_tail,