aboutsummaryrefslogtreecommitdiff
path: root/src/messenger/messenger_api_queue_messages.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/messenger/messenger_api_queue_messages.c')
-rw-r--r--src/messenger/messenger_api_queue_messages.c12
1 files changed, 8 insertions, 4 deletions
diff --git a/src/messenger/messenger_api_queue_messages.c b/src/messenger/messenger_api_queue_messages.c
index bd99698cd..415fa6a3e 100644
--- a/src/messenger/messenger_api_queue_messages.c
+++ b/src/messenger/messenger_api_queue_messages.c
@@ -34,6 +34,7 @@ init_queue_messages (struct GNUNET_MESSENGER_QueueMessages *messages)
34 messages->tail = NULL; 34 messages->tail = NULL;
35} 35}
36 36
37
37void 38void
38clear_queue_messages (struct GNUNET_MESSENGER_QueueMessages *messages) 39clear_queue_messages (struct GNUNET_MESSENGER_QueueMessages *messages)
39{ 40{
@@ -55,6 +56,7 @@ clear_queue_messages (struct GNUNET_MESSENGER_QueueMessages *messages)
55 messages->tail = NULL; 56 messages->tail = NULL;
56} 57}
57 58
59
58void 60void
59enqueue_to_messages (struct GNUNET_MESSENGER_QueueMessages *messages, 61enqueue_to_messages (struct GNUNET_MESSENGER_QueueMessages *messages,
60 const struct GNUNET_IDENTITY_PrivateKey *sender, 62 const struct GNUNET_IDENTITY_PrivateKey *sender,
@@ -62,9 +64,10 @@ enqueue_to_messages (struct GNUNET_MESSENGER_QueueMessages *messages,
62{ 64{
63 GNUNET_assert ((messages) && (message)); 65 GNUNET_assert ((messages) && (message));
64 66
65 struct GNUNET_MESSENGER_QueueMessage *element = GNUNET_new (struct GNUNET_MESSENGER_QueueMessage); 67 struct GNUNET_MESSENGER_QueueMessage *element = GNUNET_new (struct
68 GNUNET_MESSENGER_QueueMessage);
66 69
67 if (!element) 70 if (! element)
68 return; 71 return;
69 72
70 element->message = copy_message (message); 73 element->message = copy_message (message);
@@ -72,7 +75,7 @@ enqueue_to_messages (struct GNUNET_MESSENGER_QueueMessages *messages,
72 if (sender) 75 if (sender)
73 GNUNET_memcpy (&(element->sender), sender, sizeof (element->sender)); 76 GNUNET_memcpy (&(element->sender), sender, sizeof (element->sender));
74 77
75 if (!element->message) 78 if (! element->message)
76 { 79 {
77 GNUNET_free (element); 80 GNUNET_free (element);
78 return; 81 return;
@@ -81,6 +84,7 @@ enqueue_to_messages (struct GNUNET_MESSENGER_QueueMessages *messages,
81 GNUNET_CONTAINER_DLL_insert_tail (messages->head, messages->tail, element); 84 GNUNET_CONTAINER_DLL_insert_tail (messages->head, messages->tail, element);
82} 85}
83 86
87
84struct GNUNET_MESSENGER_Message* 88struct GNUNET_MESSENGER_Message*
85dequeue_from_messages (struct GNUNET_MESSENGER_QueueMessages *messages, 89dequeue_from_messages (struct GNUNET_MESSENGER_QueueMessages *messages,
86 struct GNUNET_IDENTITY_PrivateKey *sender) 90 struct GNUNET_IDENTITY_PrivateKey *sender)
@@ -89,7 +93,7 @@ dequeue_from_messages (struct GNUNET_MESSENGER_QueueMessages *messages,
89 93
90 struct GNUNET_MESSENGER_QueueMessage *element = messages->head; 94 struct GNUNET_MESSENGER_QueueMessage *element = messages->head;
91 95
92 if (!element) 96 if (! element)
93 return NULL; 97 return NULL;
94 98
95 struct GNUNET_MESSENGER_Message *message = element->message; 99 struct GNUNET_MESSENGER_Message *message = element->message;