[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[gnunet] 06/10: Transport: We need to check if a message was cached when
From: |
gnunet |
Subject: |
[gnunet] 06/10: Transport: We need to check if a message was cached when resuming communicators. |
Date: |
Sat, 09 Dec 2023 12:45:11 +0100 |
This is an automated email from the git hooks/post-receive script.
t3sserakt pushed a commit to branch master
in repository gnunet.
commit bc81b0acb9b4c8aed5562293f900320ce4099bca
Author: t3sserakt <t3ss@posteo.de>
AuthorDate: Sat Dec 9 12:35:13 2023 +0100
Transport: We need to check if a message was cached when resuming
communicators.
---
src/service/transport/gnunet-service-transport.c | 8 +++++++-
1 file changed, 7 insertions(+), 1 deletion(-)
diff --git a/src/service/transport/gnunet-service-transport.c
b/src/service/transport/gnunet-service-transport.c
index 4fa301d4a..7499a7a36 100644
--- a/src/service/transport/gnunet-service-transport.c
+++ b/src/service/transport/gnunet-service-transport.c
@@ -1192,6 +1192,11 @@ struct CommunicatorMessageContext
* FIXME: make use of this in ACK handling!
*/
uint16_t total_hops;
+
+ /**
+ * Did we already call GNUNET_SERVICE_client_continue?
+ */
+ unsigned int continue_send;
};
@@ -4354,7 +4359,7 @@ handle_client_recv_ok (void *cls, const struct
RecvOkMessage *rom)
while (NULL != (cmc = vl->cmc_tail))
{
GNUNET_CONTAINER_DLL_remove (vl->cmc_head, vl->cmc_tail, cmc);
- finish_cmc_handling (cmc);
+ finish_cmc_handling_with_continue (cmc, GNUNET_YES == cmc->continue_send ?
GNUNET_NO : GNUNET_YES);
}
}
@@ -5889,6 +5894,7 @@ handle_raw_message (void *cls, const struct
GNUNET_MessageHeader *mh)
(unsigned int) ntohs (mh->size));
finish_cmc_handling (cmc);*/
GNUNET_SERVICE_client_continue (cmc->tc->client);
+ cmc->continue_send = GNUNET_YES;
// GNUNET_free (cmc);
return;
}
--
To stop receiving notification emails like this one, please contact
gnunet@gnunet.org.
- [gnunet] branch master updated (a5dfa2db4 -> e5e1586bb), gnunet, 2023/12/09
- [gnunet] 01/10: Transport: Destroy closed ProtoQueue., gnunet, 2023/12/09
- [gnunet] 04/10: Transport: Removed misplaced removal of QueueEntry., gnunet, 2023/12/09
- [gnunet] 02/10: Transport: Added logging in case of UDP errors, and destroy queue in case of errors., gnunet, 2023/12/09
- [gnunet] 03/10: Transport: Fixed bug in handling of AckPending., gnunet, 2023/12/09
- [gnunet] 06/10: Transport: We need to check if a message was cached when resuming communicators.,
gnunet <=
- [gnunet] 09/10: Transport: More useful debug logging für service., gnunet, 2023/12/09
- [gnunet] 07/10: Transport: Fixed bug handling queue length and QueueEntry when queue has no capacity., gnunet, 2023/12/09
- [gnunet] 05/10: Transport: Fixed bugs in core message cache., gnunet, 2023/12/09
- [gnunet] 08/10: Transport: Fixed bug to check each queue for validity separately., gnunet, 2023/12/09
- [gnunet] 10/10: Merge branch 'master' of ssh://git.gnunet.org/gnunet, gnunet, 2023/12/09