diff options
author | TheJackiMonster <thejackimonster@gmail.com> | 2024-03-05 16:00:11 +0100 |
---|---|---|
committer | TheJackiMonster <thejackimonster@gmail.com> | 2024-03-05 16:05:37 +0100 |
commit | 48dfc68132cd19013b5a3ce6b170099b988de96e (patch) | |
tree | 87140398c14472d3355b24165f89682b4e2441d4 | |
parent | abbd40ba2df305e6c8b2573f074e9037760640a4 (diff) | |
download | gnunet-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.c | 5 |
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: |