messenger_api_message_control.h File Reference

#include "gnunet_common.h"
#include "gnunet_messenger_service.h"
#include "gnunet_util_lib.h"

Include dependency graph for messenger_api_message_control.h:

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Data Structures
struct	GNUNET_MESSENGER_MessageControlQueue
struct	GNUNET_MESSENGER_MessageControl

Functions
struct GNUNET_MESSENGER_MessageControl *	create_message_control (struct GNUNET_MESSENGER_Room *room)
	Creates and allocates a new message control for a room of the client API. More...
void	destroy_message_control (struct GNUNET_MESSENGER_MessageControl *control)
	Destroys a message control and frees its memory fully from the client API. More...
void	process_message_control (struct GNUNET_MESSENGER_MessageControl *control, const struct GNUNET_HashCode *sender, const struct GNUNET_HashCode *context, const struct GNUNET_HashCode *hash, const struct GNUNET_MESSENGER_Message *message, enum GNUNET_MESSENGER_MessageFlags flags)
	Processes a new message with its hash and regarding information about sender, context and message flags using a selected message control. More...

Function Documentation

create_message_control()

struct GNUNET_MESSENGER_MessageControl * create_message_control

(

struct GNUNET_MESSENGER_Room *

room

)

Creates and allocates a new message control for a room of the client API.

Parameters

[in,out]

room

Room

Returns

New message control

Definition at line 38 of file messenger_api_message_control.c.

{
  GNUNET_assert (room);
 
  struct GNUNET_MESSENGER_MessageControl *control;
 
  control = GNUNET_new (struct GNUNET_MESSENGER_MessageControl);
  control->room = room;
 
  control->peer_messages = GNUNET_CONTAINER_multishortmap_create (8, GNUNET_NO);
  control->member_messages = GNUNET_CONTAINER_multishortmap_create (8,
                                                                    GNUNET_NO);
 
  control->head = NULL;
  control->tail = NULL;
 
  return control;
}

References GNUNET_assert, GNUNET_CONTAINER_multishortmap_create(), GNUNET_new, GNUNET_NO, GNUNET_MESSENGER_MessageControl::head, GNUNET_MESSENGER_MessageControl::member_messages, GNUNET_MESSENGER_MessageControl::peer_messages, GNUNET_MESSENGER_MessageControl::room, and GNUNET_MESSENGER_MessageControl::tail.

Referenced by create_room().

Here is the call graph for this function:

Here is the caller graph for this function:

destroy_message_control()

void destroy_message_control

(

struct GNUNET_MESSENGER_MessageControl *

control

)

Destroys a message control and frees its memory fully from the client API.

Parameters

[in,out]

control

Message control

Definition at line 59 of file messenger_api_message_control.c.

{
  GNUNET_assert (control);
 
  struct GNUNET_MESSENGER_MessageControlQueue *queue;
  while (control->head)
  {
    queue = control->head;
 
    if (queue->task)
      GNUNET_SCHEDULER_cancel (queue->task);
 
    destroy_message (queue->message);
 
    GNUNET_CONTAINER_DLL_remove (control->head, control->tail, queue);
    GNUNET_free (queue);
  }
 
  GNUNET_CONTAINER_multishortmap_destroy (control->peer_messages);
  GNUNET_CONTAINER_multishortmap_destroy (control->member_messages);
 
  GNUNET_free (control);
}

References GNUNET_MESSENGER_MessageControlQueue::control, destroy_message(), GNUNET_assert, GNUNET_CONTAINER_DLL_remove, GNUNET_CONTAINER_multishortmap_destroy(), GNUNET_free, GNUNET_SCHEDULER_cancel(), GNUNET_MESSENGER_MessageControl::head, GNUNET_MESSENGER_MessageControl::member_messages, GNUNET_MESSENGER_MessageControl::peer_messages, queue(), and GNUNET_MESSENGER_MessageControl::tail.

Referenced by destroy_room().

Here is the call graph for this function:

Here is the caller graph for this function:

process_message_control()

void process_message_control	(	struct GNUNET_MESSENGER_MessageControl *	control,
		const struct GNUNET_HashCode *	sender,
		const struct GNUNET_HashCode *	context,
		const struct GNUNET_HashCode *	hash,
		const struct GNUNET_MESSENGER_Message *	message,
		enum GNUNET_MESSENGER_MessageFlags	flags
	)

Processes a new message with its hash and regarding information about sender, context and message flags using a selected message control.

The message control will ensure order of messages so that senders of messages can be identified via previously processed messages.

Parameters

[in,out]	control	Message control
[in]	sender	Sender hash
[in]	context	Context hash
[in]	hash	Message hash
[in]	message	Message
[in]	flags	Message flags

Definition at line 199 of file messenger_api_message_control.c.

{
  GNUNET_assert ((control) && (sender) && (context) && (hash) && (message));
 
  struct GNUNET_MESSENGER_Handle *handle = get_room_handle (control->room);
  struct GNUNET_MESSENGER_ContactStore *store = get_handle_contact_store (
    handle);
 
  struct GNUNET_MESSENGER_Contact *contact = get_store_contact_raw (
    store, context, sender);
 
  if ((! contact) &&
      (GNUNET_MESSENGER_KIND_JOIN != message->header.kind) &&
      (GNUNET_MESSENGER_KIND_PEER != message->header.kind))
    enqueue_message_control (control, sender, context, hash, message, flags);
  else
    handle_message_control (control, contact, hash, message, flags);
 
  struct GNUNET_CONTAINER_MultiShortmap *map = NULL;
  const struct GNUNET_ShortHashCode *id = &(message->header.sender_id);
 
  if (GNUNET_YES == is_peer_message(message))
    map = control->peer_messages;
 
  switch (message->header.kind)
  {
  case GNUNET_MESSENGER_KIND_JOIN:
    map = control->member_messages;
    break;
  case GNUNET_MESSENGER_KIND_PEER:
    map = control->peer_messages;
    break;
  case GNUNET_MESSENGER_KIND_ID:
    map = control->member_messages;
    id = &(message->body.id.id);
    break;
  default:
    break;
  }
 
  if (! map)
    return;
 
  GNUNET_CONTAINER_multishortmap_get_multiple (map,
                                               id,
                                               iterate_message_control,
                                               NULL);
}

References GNUNET_MESSENGER_Message::body, context, GNUNET_MESSENGER_MessageControlQueue::control, enqueue_message_control(), get_handle_contact_store(), get_room_handle(), get_store_contact_raw(), GNUNET_assert, GNUNET_CONTAINER_multishortmap_get_multiple(), GNUNET_MESSENGER_KIND_ID, GNUNET_MESSENGER_KIND_JOIN, GNUNET_MESSENGER_KIND_PEER, GNUNET_YES, handle, handle_message_control(), GNUNET_MESSENGER_MessageControlQueue::hash, GNUNET_MESSENGER_Message::header, GNUNET_MESSENGER_MessageId::id, GNUNET_MESSENGER_MessageBody::id, is_peer_message(), iterate_message_control(), GNUNET_MESSENGER_MessageHeader::kind, map, GNUNET_MESSENGER_MessageControl::member_messages, GNUNET_MESSENGER_MessageControlQueue::message, GNUNET_MESSENGER_MessageControl::peer_messages, GNUNET_MESSENGER_MessageControl::room, GNUNET_MESSENGER_MessageControlQueue::sender, and GNUNET_MESSENGER_MessageHeader::sender_id.

Referenced by handle_recv_message().

Here is the call graph for this function:

Here is the caller graph for this function: