messenger_api_queue_messages.c File Reference

#include "messenger_api_queue_messages.h"
#include "gnunet_messenger_service.h"
#include "messenger_api_message.h"

Include dependency graph for messenger_api_queue_messages.c:

Go to the source code of this file.

Functions
void	init_queue_messages (struct GNUNET_MESSENGER_QueueMessages *messages)
	Initializes queue of messages as empty queue.
void	clear_queue_messages (struct GNUNET_MESSENGER_QueueMessages *messages)
	Clears the queue of messages.
void	enqueue_to_messages (struct GNUNET_MESSENGER_QueueMessages *messages, const struct GNUNET_CRYPTO_PrivateKey *sender, const struct GNUNET_HashCode *epoch, struct GNUNET_MESSENGER_Message *message, struct GNUNET_MESSENGER_Message *transcript)
	Adds a specific message to the end or the beginning of the queue.
struct GNUNET_MESSENGER_Message *	dequeue_from_messages (struct GNUNET_MESSENGER_QueueMessages *messages, struct GNUNET_CRYPTO_PrivateKey *sender, struct GNUNET_HashCode *epoch, struct GNUNET_MESSENGER_Message **transcript)
	Remove the message from the front of the queue and returns it.

Function Documentation

init_queue_messages()

void init_queue_messages

(

struct GNUNET_MESSENGER_QueueMessages *

messages

)

Initializes queue of messages as empty queue.

Parameters

[out]

messages

Queue of messages

Definition at line 32 of file messenger_api_queue_messages.c.

{
  GNUNET_assert (messages);
 
  messages->head = NULL;
  messages->tail = NULL;
}

References GNUNET_assert, GNUNET_MESSENGER_QueueMessages::head, and GNUNET_MESSENGER_QueueMessages::tail.

Referenced by create_room().

Here is the caller graph for this function:

clear_queue_messages()

void clear_queue_messages

(

struct GNUNET_MESSENGER_QueueMessages *

messages

)

Clears the queue of messages.

Parameters

[in,out]

messages

Queue of messages

Definition at line 42 of file messenger_api_queue_messages.c.

{
  GNUNET_assert (messages);
 
  while (messages->head)
  {
    struct GNUNET_MESSENGER_QueueMessage *element;
    element = messages->head;
 
    GNUNET_CONTAINER_DLL_remove (messages->head, messages->tail, element);
 
    if (element->message)
      destroy_message (element->message);
 
    if (element->transcript)
      destroy_message (element->transcript);
 
    GNUNET_free (element);
  }
 
  messages->head = NULL;
  messages->tail = NULL;
}

References destroy_message(), GNUNET_assert, GNUNET_CONTAINER_DLL_remove, GNUNET_free, GNUNET_MESSENGER_QueueMessages::head, GNUNET_MESSENGER_QueueMessage::message, GNUNET_MESSENGER_QueueMessages::tail, and GNUNET_MESSENGER_QueueMessage::transcript.

Referenced by destroy_room().

Here is the call graph for this function:

Here is the caller graph for this function:

enqueue_to_messages()

void enqueue_to_messages	(	struct GNUNET_MESSENGER_QueueMessages *	messages,
		const struct GNUNET_CRYPTO_PrivateKey *	sender,
		const struct GNUNET_HashCode *	epoch,
		struct GNUNET_MESSENGER_Message *	message,
		struct GNUNET_MESSENGER_Message *	transcript
	)

Adds a specific message to the end or the beginning of the queue.

Parameters

[in,out]	messages	Queue of messages
[in]	sender	Private sender key
[in]	epoch	Epoch hash
[in]	message	Message
[in]	transcript	Message transcript

Definition at line 68 of file messenger_api_queue_messages.c.

{
  struct GNUNET_MESSENGER_QueueMessage *element;
  enum GNUNET_MESSENGER_MessageKind kind;
 
  GNUNET_assert ((messages) && (sender) && (message));
 
  element = GNUNET_new (struct GNUNET_MESSENGER_QueueMessage);
  if (! element)
    return;
 
  kind = message->header.kind;
 
  element->message = message;
  element->transcript = transcript;
 
  GNUNET_memcpy (&(element->sender), sender, sizeof (element->sender));
  GNUNET_memcpy (&(element->epoch), epoch, sizeof (element->epoch));
 
  if (! element->message)
  {
    if (element->transcript)
      destroy_message (element->transcript);
 
    GNUNET_free (element);
    return;
  }
 
  if (GNUNET_MESSENGER_KIND_JOIN == kind)
    GNUNET_CONTAINER_DLL_insert (messages->head, messages->tail, element);
  else if (GNUNET_MESSENGER_KIND_SUBSCRIBTION == kind)
  {
    struct GNUNET_MESSENGER_QueueMessage *other;
 
    other = messages->head;
    while (other)
    {
      if (GNUNET_MESSENGER_KIND_TALK == other->message->header.kind)
        break;
 
      other = other->next;
    }
 
    GNUNET_CONTAINER_DLL_insert_before (messages->head, messages->tail, other,
                                        element);
  }
  else
    GNUNET_CONTAINER_DLL_insert_tail (messages->head, messages->tail, element);
}

References destroy_message(), GNUNET_MESSENGER_QueueMessage::epoch, GNUNET_assert, GNUNET_CONTAINER_DLL_insert, GNUNET_CONTAINER_DLL_insert_before, GNUNET_CONTAINER_DLL_insert_tail, GNUNET_free, GNUNET_memcpy, GNUNET_MESSENGER_KIND_JOIN, GNUNET_MESSENGER_KIND_SUBSCRIBTION, GNUNET_MESSENGER_KIND_TALK, GNUNET_new, GNUNET_MESSENGER_QueueMessages::head, GNUNET_MESSENGER_Message::header, GNUNET_MESSENGER_MessageHeader::kind, GNUNET_MESSENGER_QueueMessage::message, GNUNET_MESSENGER_QueueMessage::next, GNUNET_MESSENGER_QueueMessage::sender, GNUNET_MESSENGER_QueueMessages::tail, and GNUNET_MESSENGER_QueueMessage::transcript.

Referenced by enqueue_message_to_room().

Here is the call graph for this function:

Here is the caller graph for this function:

dequeue_from_messages()

struct GNUNET_MESSENGER_Message * dequeue_from_messages	(	struct GNUNET_MESSENGER_QueueMessages *	messages,
		struct GNUNET_CRYPTO_PrivateKey *	sender,
		struct GNUNET_HashCode *	epoch,
		struct GNUNET_MESSENGER_Message **	transcript
	)

Remove the message from the front of the queue and returns it.

Parameters

[in,out]	messages	Queue of messages
[out]	sender	Private sender key
[out]	epoch	Epoch hash
[out]	transcript	Message transcript

Returns

Message from front or NULL

Definition at line 124 of file messenger_api_queue_messages.c.

{
  struct GNUNET_MESSENGER_QueueMessage *element;
  struct GNUNET_MESSENGER_Message *message;
 
  GNUNET_assert (messages);
 
  element = messages->head;
  if (! element)
  {
    if (transcript)
      *transcript = NULL;
 
    return NULL;
  }
 
  message = element->message;
 
  if (transcript)
    *transcript = element->transcript;
  else if (element->transcript)
    destroy_message (element->transcript);
 
  GNUNET_CONTAINER_DLL_remove (messages->head, messages->tail, element);
 
  if (sender)
    GNUNET_memcpy (sender, &(element->sender), sizeof (*sender));
 
  if (epoch)
    GNUNET_memcpy (epoch, &(element->epoch), sizeof (*epoch));
 
  GNUNET_free (element);
  return message;
}

References destroy_message(), GNUNET_MESSENGER_QueueMessage::epoch, GNUNET_assert, GNUNET_CONTAINER_DLL_remove, GNUNET_free, GNUNET_memcpy, GNUNET_MESSENGER_QueueMessages::head, GNUNET_MESSENGER_QueueMessage::message, GNUNET_MESSENGER_QueueMessage::sender, GNUNET_MESSENGER_QueueMessages::tail, and GNUNET_MESSENGER_QueueMessage::transcript.

Referenced by dequeue_message_from_room().

Here is the call graph for this function:

Here is the caller graph for this function: