aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorTheJackiMonster <thejackimonster@gmail.com>2024-03-05 16:00:11 +0100
committerTheJackiMonster <thejackimonster@gmail.com>2024-03-05 16:05:37 +0100
commit48dfc68132cd19013b5a3ce6b170099b988de96e (patch)
tree87140398c14472d3355b24165f89682b4e2441d4
parentabbd40ba2df305e6c8b2573f074e9037760640a4 (diff)
downloadgnunet-dev/thejackimonster/messenger.tar.gz
gnunet-dev/thejackimonster/messenger.zip
MESSENGER: Fix potential infinite delay of peer messagesdev/thejackimonster/messenger
Signed-off-by: TheJackiMonster <thejackimonster@gmail.com>
-rw-r--r--src/service/messenger/messenger_api_message_control.c5
1 files changed, 4 insertions, 1 deletions
diff --git a/src/service/messenger/messenger_api_message_control.c b/src/service/messenger/messenger_api_message_control.c
index 30c52587f..c46c047c4 100644
--- a/src/service/messenger/messenger_api_message_control.c
+++ b/src/service/messenger/messenger_api_message_control.c
@@ -183,7 +183,7 @@ iterate_message_control (void *cls,
183 const struct GNUNET_ShortHashCode *key, 183 const struct GNUNET_ShortHashCode *key,
184 void *value) 184 void *value)
185{ 185{
186 GNUNET_assert ((cls) && (key) && (value)); 186 GNUNET_assert ((key) && (value));
187 187
188 struct GNUNET_MESSENGER_MessageControlQueue *queue = value; 188 struct GNUNET_MESSENGER_MessageControlQueue *queue = value;
189 189
@@ -222,6 +222,9 @@ process_message_control (struct GNUNET_MESSENGER_MessageControl *control,
222 struct GNUNET_CONTAINER_MultiShortmap *map = NULL; 222 struct GNUNET_CONTAINER_MultiShortmap *map = NULL;
223 const struct GNUNET_ShortHashCode *id = &(message->header.sender_id); 223 const struct GNUNET_ShortHashCode *id = &(message->header.sender_id);
224 224
225 if (GNUNET_YES == is_peer_message(message))
226 map = control->peer_messages;
227
225 switch (message->header.kind) 228 switch (message->header.kind)
226 { 229 {
227 case GNUNET_MESSENGER_KIND_JOIN: 230 case GNUNET_MESSENGER_KIND_JOIN: