diff options
Diffstat (limited to 'src/messenger/messenger_api_queue_messages.c')
-rw-r--r-- | src/messenger/messenger_api_queue_messages.c | 12 |
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 | |||
37 | void | 38 | void |
38 | clear_queue_messages (struct GNUNET_MESSENGER_QueueMessages *messages) | 39 | clear_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 | |||
58 | void | 60 | void |
59 | enqueue_to_messages (struct GNUNET_MESSENGER_QueueMessages *messages, | 61 | enqueue_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 | |||
84 | struct GNUNET_MESSENGER_Message* | 88 | struct GNUNET_MESSENGER_Message* |
85 | dequeue_from_messages (struct GNUNET_MESSENGER_QueueMessages *messages, | 89 | dequeue_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; |