#include "gnunet_common.h"
#include "gnunet_messenger_service.h"
#include "gnunet-service-messenger.h"
#include "gnunet_time_lib.h"
#include "gnunet_util_lib.h"
#include "messenger_api.h"
#include "messenger_api_contact.h"
#include "messenger_api_contact_store.h"
#include "messenger_api_epoch.h"
#include "messenger_api_epoch_announcement.h"
#include "messenger_api_handle.h"
#include "messenger_api_message.h"
#include "messenger_api_message_control.h"
#include "messenger_api_message_kind.h"
#include "messenger_api_room.h"
#include "messenger_api_util.h"

Include dependency graph for messenger_api.c:

Data Structures
struct	GNUNET_MESSENGER_RoomFind

Functions
const char *	GNUNET_MESSENGER_name_of_kind (enum GNUNET_MESSENGER_MessageKind kind)
	Get the name of a message kind.

void	GNUNET_MESSENGER_create_room_key (union GNUNET_MESSENGER_RoomKey key, const char input, enum GNUNET_GenericReturnValue is_public, enum GNUNET_GenericReturnValue is_group, enum GNUNET_GenericReturnValue is_feed)
	Creates a room key from given optional input string using certain properties for this targeted room.

static void	dequeue_messages_from_room (struct GNUNET_MESSENGER_Room *room)

static void	handle_room_open (void cls, const struct GNUNET_MESSENGER_RoomMessage msg)

static void	handle_room_entry (void cls, const struct GNUNET_MESSENGER_RoomMessage msg)

static void	handle_room_close (void cls, const struct GNUNET_MESSENGER_RoomMessage msg)

static void	handle_room_sync (void cls, const struct GNUNET_MESSENGER_RoomMessage msg)

static void	handle_member_id (void cls, const struct GNUNET_MESSENGER_MemberMessage msg)

static enum GNUNET_GenericReturnValue	check_recv_message (void cls, const struct GNUNET_MESSENGER_RecvMessage msg)

static void	handle_recv_message (void cls, const struct GNUNET_MESSENGER_RecvMessage msg)

static void	handle_miss_message (void cls, const struct GNUNET_MESSENGER_GetMessage msg)

static void	reconnect (struct GNUNET_MESSENGER_Handle *handle)

static void	send_open_room (struct GNUNET_MESSENGER_Handle handle, struct GNUNET_MESSENGER_Room room)

static void	send_enter_room (struct GNUNET_MESSENGER_Handle handle, struct GNUNET_MESSENGER_Room room, const struct GNUNET_PeerIdentity *door)

static void	send_close_room (struct GNUNET_MESSENGER_Handle handle, struct GNUNET_MESSENGER_Room room)

static void	send_sync_room (struct GNUNET_MESSENGER_Handle handle, struct GNUNET_MESSENGER_Room room)

static enum GNUNET_GenericReturnValue	iterate_reset_room (void cls, const struct GNUNET_HashCode key, void *value)

static void	callback_reconnect (void *cls)

static enum GNUNET_GenericReturnValue	iterate_close_room (void cls, const struct GNUNET_HashCode key, void *value)

static void	callback_mq_error (void *cls, enum GNUNET_MQ_Error error)

struct GNUNET_MESSENGER_Handle *	GNUNET_MESSENGER_connect (const struct GNUNET_CONFIGURATION_Handle cfg, const char name, const struct GNUNET_CRYPTO_PrivateKey key, GNUNET_MESSENGER_MessageCallback msg_callback, void msg_cls)
	Set up a handle for the messenger related functions and connects to all necessary services.

void	GNUNET_MESSENGER_disconnect (struct GNUNET_MESSENGER_Handle *handle)
	Disconnect all of the messengers used services and clears up its used memory.

static void	callback_leave_message_sent (void *cls)

static void	keep_subscription_alive (void *cls)

static void	handle_discourse_subscription (struct GNUNET_MESSENGER_Room room, struct GNUNET_MESSENGER_Message message)

static void	send_message_to_room (struct GNUNET_MESSENGER_Room room, struct GNUNET_MESSENGER_Message message, const struct GNUNET_CRYPTO_PrivateKey key, const struct GNUNET_HashCode epoch, struct GNUNET_HashCode *hash)

void	enqueue_message_to_room (struct GNUNET_MESSENGER_Room room, const struct GNUNET_HashCode epoch, struct GNUNET_MESSENGER_Message message, struct GNUNET_MESSENGER_Message transcript, enum GNUNET_GenericReturnValue sync)
	Enqueus a message and its optional transcript for sending it to a given room and epoch.

static void	dequeue_message_from_room (void *cls)

const char *	GNUNET_MESSENGER_get_name (const struct GNUNET_MESSENGER_Handle *handle)
	Get the name (if specified, otherwise NULL) used by the messenger.

static enum GNUNET_GenericReturnValue	iterate_send_name_to_room (void cls, struct GNUNET_MESSENGER_Room room, const struct GNUNET_MESSENGER_Contact *contact)

enum GNUNET_GenericReturnValue	GNUNET_MESSENGER_set_name (struct GNUNET_MESSENGER_Handle handle, const char name)
	Set the name for the messenger handle and sends messages renaming your contact in currently open rooms.

static const struct GNUNET_CRYPTO_PublicKey *	get_non_anonymous_key (const struct GNUNET_CRYPTO_PublicKey *public_key)

const struct GNUNET_CRYPTO_PublicKey *	GNUNET_MESSENGER_get_key (const struct GNUNET_MESSENGER_Handle *handle)
	Get the public key used by the messenger or NULL if the anonymous key was used.

static enum GNUNET_GenericReturnValue	iterate_send_key_to_room (void cls, struct GNUNET_MESSENGER_Room room, const struct GNUNET_MESSENGER_Contact *contact)

enum GNUNET_GenericReturnValue	GNUNET_MESSENGER_set_key (struct GNUNET_MESSENGER_Handle handle, const struct GNUNET_CRYPTO_PrivateKey key)
	Set the private key used by the messenger or NULL if the anonymous key should be used instead.

struct GNUNET_MESSENGER_Room *	GNUNET_MESSENGER_open_room (struct GNUNET_MESSENGER_Handle handle, const union GNUNET_MESSENGER_RoomKey key)
	Open a room to send and receive messages.

struct GNUNET_MESSENGER_Room *	GNUNET_MESSENGER_enter_room (struct GNUNET_MESSENGER_Handle handle, const struct GNUNET_PeerIdentity door, const union GNUNET_MESSENGER_RoomKey *key)
	Enter a room to send and receive messages through a door opened using GNUNET_MESSENGER_open_room.

void	GNUNET_MESSENGER_close_room (struct GNUNET_MESSENGER_Room *room)
	Close a room which was entered, opened or both in various order and variety.

static enum GNUNET_GenericReturnValue	iterate_find_room (void cls, const struct GNUNET_HashCode key, void *value)

int	GNUNET_MESSENGER_find_rooms (const struct GNUNET_MESSENGER_Handle handle, const struct GNUNET_MESSENGER_Contact contact, GNUNET_MESSENGER_MemberCallback callback, void *cls)
	Searches for a specific contact in a given room and calls a selected callback with a given closure for each of them containing the contact as a member.

const struct GNUNET_HashCode *	GNUNET_MESSENGER_room_get_key (const struct GNUNET_MESSENGER_Room *room)
	Get the key of a given room.

const struct GNUNET_MESSENGER_Contact *	GNUNET_MESSENGER_get_sender (const struct GNUNET_MESSENGER_Room room, const struct GNUNET_HashCode hash)
	Get the contact of a member in a room which sent a specific message identified with a given hash.

const struct GNUNET_MESSENGER_Contact *	GNUNET_MESSENGER_get_recipient (const struct GNUNET_MESSENGER_Room room, const struct GNUNET_HashCode hash)
	Get the contact of a member in a room which has been targeted as recipient of a specific message identified with a given hash.

const char *	GNUNET_MESSENGER_contact_get_name (const struct GNUNET_MESSENGER_Contact *contact)
	Get the name used by the contact.

const struct GNUNET_CRYPTO_PublicKey *	GNUNET_MESSENGER_contact_get_key (const struct GNUNET_MESSENGER_Contact *contact)
	Get the public key used by the contact or NULL if the anonymous key was used.

size_t	GNUNET_MESSENGER_contact_get_id (const struct GNUNET_MESSENGER_Contact *contact)
	Get the locally unique id of the contact.

static void	send_message_to_room_with_key (struct GNUNET_MESSENGER_Room room, struct GNUNET_MESSENGER_Message message, const struct GNUNET_CRYPTO_PublicKey *public_key)

void	GNUNET_MESSENGER_send_message (struct GNUNET_MESSENGER_Room room, const struct GNUNET_MESSENGER_Message message, const struct GNUNET_MESSENGER_Contact *contact)
	Send a message into a room.

void	GNUNET_MESSENGER_delete_message (struct GNUNET_MESSENGER_Room room, const struct GNUNET_HashCode hash, const struct GNUNET_TIME_Relative delay)
	Delete a message identified by its hash from a room.

void	request_message_from_room (const struct GNUNET_MESSENGER_Room room, const struct GNUNET_HashCode hash)
	Requests a specific message from a given room which can be identified by its hash.

const struct GNUNET_MESSENGER_Message *	GNUNET_MESSENGER_get_message (struct GNUNET_MESSENGER_Room room, const struct GNUNET_HashCode hash)
	Get the message in a room identified by its hash and requests it if necessary.

int	GNUNET_MESSENGER_iterate_members (struct GNUNET_MESSENGER_Room room, GNUNET_MESSENGER_MemberCallback callback, void cls)
	Iterates through all members of a given room and calls a selected callback for each of them with a provided closure.

Function Documentation

◆ dequeue_messages_from_room()

static void dequeue_messages_from_room ( struct GNUNET_MESSENGER_Room * room )

static

Definition at line 1180 of file messenger_api.c.

{
  if ((GNUNET_YES != is_room_available (room)) || (! (room->handle)))
    return;
 
  if (room->handle->mq)
    dequeue_message_from_room (room);
  else if (! (room->queue_task))
    room->queue_task = GNUNET_SCHEDULER_add_with_priority (
      GNUNET_SCHEDULER_PRIORITY_HIGH, dequeue_message_from_room, room);
}

References dequeue_message_from_room(), GNUNET_SCHEDULER_add_with_priority(), GNUNET_SCHEDULER_PRIORITY_HIGH, GNUNET_YES, GNUNET_MESSENGER_Room::handle, is_room_available(), GNUNET_MESSENGER_Handle::mq, and GNUNET_MESSENGER_Room::queue_task.

Referenced by enqueue_message_to_room(), handle_room_entry(), handle_room_open(), and handle_room_sync().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ handle_room_open()

static void handle_room_open	(	void *	cls,
		const struct GNUNET_MESSENGER_RoomMessage *	msg
	)

static

Definition at line 140 of file messenger_api.c.

{
  struct GNUNET_MESSENGER_Handle *handle;
  const struct GNUNET_HashCode *key;
  const struct GNUNET_HashCode *prev;
  const struct GNUNET_HashCode *epoch;
  struct GNUNET_MESSENGER_Room *room;
 
  GNUNET_assert ((cls) && (msg));
 
  handle = cls;
 
  key = &(msg->key);
  prev = &(msg->previous);
  epoch = &(msg->epoch);
 
  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Opened room: %s\n", GNUNET_h2s (key));
 
  open_handle_room (handle, key);
 
  room = get_handle_room (handle, key);
  if (! room)
    return;
 
  update_room_last_message (room, prev, epoch);
  dequeue_messages_from_room (room);
}

References dequeue_messages_from_room(), get_handle_room(), GNUNET_assert, GNUNET_ERROR_TYPE_DEBUG, GNUNET_h2s(), GNUNET_log, handle, key, msg, open_handle_room(), and update_room_last_message().

Here is the call graph for this function:

◆ handle_room_entry()

static void handle_room_entry	(	void *	cls,
		const struct GNUNET_MESSENGER_RoomMessage *	msg
	)

static

Definition at line 171 of file messenger_api.c.

{
  struct GNUNET_MESSENGER_Handle *handle;
  const struct GNUNET_PeerIdentity *door;
  const struct GNUNET_HashCode *key;
  const struct GNUNET_HashCode *prev;
  const struct GNUNET_HashCode *epoch;
  struct GNUNET_MESSENGER_Room *room;
 
  GNUNET_assert ((cls) && (msg));
 
  handle = cls;
 
  door = &(msg->door);
  key = &(msg->key);
  prev = &(msg->previous);
  epoch = &(msg->epoch);
 
  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Entered room: %s\n", GNUNET_h2s (key));
 
  entry_handle_room_at (handle, door, key);
 
  room = get_handle_room (handle, key);
  if (! room)
    return;
 
  update_room_last_message (room, prev, epoch);
  dequeue_messages_from_room (room);
}

References dequeue_messages_from_room(), entry_handle_room_at(), get_handle_room(), GNUNET_assert, GNUNET_ERROR_TYPE_DEBUG, GNUNET_h2s(), GNUNET_log, handle, key, msg, and update_room_last_message().

Here is the call graph for this function:

◆ handle_room_close()

static void handle_room_close	(	void *	cls,
		const struct GNUNET_MESSENGER_RoomMessage *	msg
	)

static

Definition at line 204 of file messenger_api.c.

{
  struct GNUNET_MESSENGER_Handle *handle;
  const struct GNUNET_HashCode *key;
  const struct GNUNET_HashCode *prev;
  const struct GNUNET_HashCode *epoch;
  struct GNUNET_MESSENGER_Room *room;
 
  GNUNET_assert ((cls) && (msg));
 
  handle = cls;
 
  key = &(msg->key);
  prev = &(msg->previous);
  epoch = &(msg->epoch);
 
  room = get_handle_room (handle, key);
  if (room)
    update_room_last_message (room, prev, epoch);
 
  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Closed room: %s\n", GNUNET_h2s (key));
 
  close_handle_room (handle, key);
}

References close_handle_room(), get_handle_room(), GNUNET_assert, GNUNET_ERROR_TYPE_DEBUG, GNUNET_h2s(), GNUNET_log, handle, key, msg, and update_room_last_message().

Here is the call graph for this function:

◆ handle_room_sync()

static void handle_room_sync	(	void *	cls,
		const struct GNUNET_MESSENGER_RoomMessage *	msg
	)

static

Definition at line 232 of file messenger_api.c.

{
  struct GNUNET_MESSENGER_Handle *handle;
  const struct GNUNET_HashCode *key;
  const struct GNUNET_HashCode *prev;
  const struct GNUNET_HashCode *epoch;
  struct GNUNET_MESSENGER_Room *room;
 
  GNUNET_assert ((cls) && (msg));
 
  handle = cls;
 
  key = &(msg->key);
  prev = &(msg->previous);
  epoch = &(msg->epoch);
 
  room = get_handle_room (handle, key);
  if (! room)
    return;
 
  update_room_last_message (room, prev, epoch);
 
  room->wait_for_sync = GNUNET_NO;
  dequeue_messages_from_room (room);
}

References dequeue_messages_from_room(), get_handle_room(), GNUNET_assert, GNUNET_NO, handle, key, msg, update_room_last_message(), and GNUNET_MESSENGER_Room::wait_for_sync.

Here is the call graph for this function:

◆ handle_member_id()

static void handle_member_id	(	void *	cls,
		const struct GNUNET_MESSENGER_MemberMessage *	msg
	)

static

Definition at line 261 of file messenger_api.c.

{
  struct GNUNET_MESSENGER_Handle *handle;
  const struct GNUNET_HashCode *key;
  const struct GNUNET_ShortHashCode *id;
  struct GNUNET_MESSENGER_Room *room;
  struct GNUNET_MESSENGER_Message *message;
  uint32_t reset;
 
  GNUNET_assert ((cls) && (msg));
 
  handle = cls;
 
  key = &(msg->key);
  id = &(msg->id);
  reset = msg->reset;
 
  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Changed member id in room: %s\n",
              GNUNET_h2s (key));
 
  room = get_handle_room (handle, key);
  if (! room)
  {
    GNUNET_log (GNUNET_ERROR_TYPE_WARNING, "Room is unknown to handle: %s\n",
                GNUNET_h2s (key));
    return;
  }
 
  if ((! get_room_sender_id (room)) || (GNUNET_YES == reset))
  {
    set_room_sender_id (room, id);
    message = create_message_join (get_handle_key (handle));
  }
  else
    message = create_message_id (id);
 
  if (! message)
    return;
 
  enqueue_message_to_room (room, NULL, message, NULL, GNUNET_NO);
}

References create_message_id(), create_message_join(), enqueue_message_to_room(), get_handle_key(), get_handle_room(), get_room_sender_id(), GNUNET_assert, GNUNET_ERROR_TYPE_DEBUG, GNUNET_ERROR_TYPE_WARNING, GNUNET_h2s(), GNUNET_log, GNUNET_NO, GNUNET_YES, handle, id, key, msg, reset, and set_room_sender_id().

Here is the call graph for this function:

◆ check_recv_message()

static enum GNUNET_GenericReturnValue check_recv_message	(	void *	cls,
		const struct GNUNET_MESSENGER_RecvMessage *	msg
	)

static

Definition at line 306 of file messenger_api.c.

{
  struct GNUNET_MESSENGER_Message message;
  uint16_t full_length, length;
  const char *buffer;
 
  GNUNET_assert (msg);
 
  full_length = ntohs (msg->header.size);
 
  if (full_length < sizeof(*msg))
  {
    GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                "Receiving failed: Message invalid!\n");
    return GNUNET_NO;
  }
 
  length = full_length - sizeof(*msg);
  buffer = ((const char*) msg) + sizeof(*msg);
 
  if (length < get_message_kind_size (GNUNET_MESSENGER_KIND_UNKNOWN,
                                      GNUNET_YES))
  {
    GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                "Receiving failed: Message too short!\n");
    return GNUNET_NO;
  }
 
  if (GNUNET_YES != decode_message (&message, length, buffer, GNUNET_YES, NULL))
  {
    GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                "Receiving failed: Message decoding failed!\n");
    return GNUNET_NO;
  }
 
  cleanup_message (&message);
  return GNUNET_OK;
}

References cleanup_message(), decode_message(), get_message_kind_size(), GNUNET_assert, GNUNET_ERROR_TYPE_ERROR, GNUNET_log, GNUNET_MESSENGER_KIND_UNKNOWN, GNUNET_NO, GNUNET_OK, GNUNET_YES, msg, and GNUNET_MessageHeader::size.

Here is the call graph for this function:

◆ handle_recv_message()

static void handle_recv_message	(	void *	cls,
		const struct GNUNET_MESSENGER_RecvMessage *	msg
	)

static

Definition at line 348 of file messenger_api.c.

{
  struct GNUNET_MESSENGER_Handle *handle;
  const struct GNUNET_HashCode *key;
  const struct GNUNET_HashCode *sender;
  const struct GNUNET_HashCode *context;
  const struct GNUNET_HashCode *hash;
  const struct GNUNET_HashCode *epoch;
  enum GNUNET_MESSENGER_MessageFlags flags;
  struct GNUNET_MESSENGER_Message message;
  struct GNUNET_MESSENGER_Room *room;
  uint16_t length;
  const char *buffer;
 
  GNUNET_assert ((cls) && (msg));
 
  handle = cls;
 
  key = &(msg->key);
  sender = &(msg->sender);
  context = &(msg->context);
  hash = &(msg->hash);
  epoch = &(msg->epoch);
 
  flags = (enum GNUNET_MESSENGER_MessageFlags) (msg->flags);
 
  length = ntohs (msg->header.size) - sizeof(*msg);
  buffer = ((const char*) msg) + sizeof(*msg);
 
  decode_message (&message, length, buffer, GNUNET_YES, NULL);
 
  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
              "Receiving message: %s during epoch '%s'\n",
              GNUNET_MESSENGER_name_of_kind (message.header.kind),
              GNUNET_h2s (epoch));
 
  room = get_handle_room (handle, key);
  if (! room)
  {
    GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Unknown room for this client: %s\n",
                GNUNET_h2s (key));
 
    goto skip_message;
  }
 
  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
              "Raw contact from sender and context: (%s : %s)\n",
              GNUNET_h2s (sender), GNUNET_h2s_full (context));
 
  process_message_control (room->control,
                           sender,
                           context,
                           hash,
                           epoch,
                           &message,
                           flags);
 
skip_message:
  cleanup_message (&message);
}

References cleanup_message(), context, GNUNET_MESSENGER_Room::control, decode_message(), get_handle_room(), GNUNET_assert, GNUNET_ERROR_TYPE_DEBUG, GNUNET_h2s(), GNUNET_h2s_full(), GNUNET_log, GNUNET_MESSENGER_name_of_kind(), GNUNET_YES, handle, GNUNET_MESSENGER_Message::header, key, GNUNET_MESSENGER_MessageHeader::kind, msg, process_message_control(), and GNUNET_MessageHeader::size.

Here is the call graph for this function:

◆ handle_miss_message()

static void handle_miss_message	(	void *	cls,
		const struct GNUNET_MESSENGER_GetMessage *	msg
	)

static

Definition at line 412 of file messenger_api.c.

{
  struct GNUNET_MESSENGER_Handle *handle;
  const struct GNUNET_HashCode *key;
  const struct GNUNET_HashCode *hash;
  struct GNUNET_MESSENGER_Room *room;
 
  GNUNET_assert ((cls) && (msg));
 
  handle = cls;
 
  key = &(msg->key);
  hash = &(msg->hash);
 
  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Missing message in room: %s\n",
              GNUNET_h2s (hash));
 
  room = get_handle_room (handle, key);
  if (! room)
  {
    GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
                "Miss in unknown room for this client: %s\n", GNUNET_h2s (key));
    return;
  }
 
  if (! get_room_sender_id (room))
    return;
 
  {
    struct GNUNET_MESSENGER_Message *message;
 
    message = create_message_request (hash);
    if (! message)
      return;
 
    enqueue_message_to_room (room, NULL, message, NULL, GNUNET_NO);
  }
}

References create_message_request(), enqueue_message_to_room(), get_handle_room(), get_room_sender_id(), GNUNET_assert, GNUNET_ERROR_TYPE_DEBUG, GNUNET_h2s(), GNUNET_log, GNUNET_NO, handle, key, and msg.

Here is the call graph for this function:

◆ reconnect()

static void reconnect ( struct GNUNET_MESSENGER_Handle * handle )

static

Definition at line 675 of file messenger_api.c.

{
  GNUNET_assert (handle);
 
  {
    const struct GNUNET_MQ_MessageHandler handlers[] = {
      GNUNET_MQ_hd_fixed_size (
        member_id,
        GNUNET_MESSAGE_TYPE_MESSENGER_CONNECTION_MEMBER_ID,
        struct GNUNET_MESSENGER_MemberMessage, handle
        ),
      GNUNET_MQ_hd_fixed_size (
        room_open,
        GNUNET_MESSAGE_TYPE_MESSENGER_ROOM_OPEN,
        struct GNUNET_MESSENGER_RoomMessage, handle
        ),
      GNUNET_MQ_hd_fixed_size (
        room_entry,
        GNUNET_MESSAGE_TYPE_MESSENGER_ROOM_ENTRY,
        struct GNUNET_MESSENGER_RoomMessage, handle
        ),
      GNUNET_MQ_hd_fixed_size (
        room_close,
        GNUNET_MESSAGE_TYPE_MESSENGER_ROOM_CLOSE,
        struct GNUNET_MESSENGER_RoomMessage, handle
        ),
      GNUNET_MQ_hd_var_size (
        recv_message,
        GNUNET_MESSAGE_TYPE_MESSENGER_ROOM_RECV_MESSAGE,
        struct GNUNET_MESSENGER_RecvMessage, handle
        ),
      GNUNET_MQ_hd_fixed_size (
        miss_message,
        GNUNET_MESSAGE_TYPE_MESSENGER_ROOM_GET_MESSAGE,
        struct GNUNET_MESSENGER_GetMessage, handle
        ),
      GNUNET_MQ_hd_fixed_size (
        room_sync,
        GNUNET_MESSAGE_TYPE_MESSENGER_ROOM_SYNC,
        struct GNUNET_MESSENGER_RoomMessage, handle
        ),
      GNUNET_MQ_handler_end ()
    };
 
    handle->mq = GNUNET_CLIENT_connect (handle->config,
                                        GNUNET_MESSENGER_SERVICE_NAME,
                                        handlers, &callback_mq_error,
                                        handle);
  }
}

References callback_mq_error(), GNUNET_assert, GNUNET_CLIENT_connect(), GNUNET_MESSAGE_TYPE_MESSENGER_CONNECTION_MEMBER_ID, GNUNET_MESSAGE_TYPE_MESSENGER_ROOM_CLOSE, GNUNET_MESSAGE_TYPE_MESSENGER_ROOM_ENTRY, GNUNET_MESSAGE_TYPE_MESSENGER_ROOM_GET_MESSAGE, GNUNET_MESSAGE_TYPE_MESSENGER_ROOM_OPEN, GNUNET_MESSAGE_TYPE_MESSENGER_ROOM_RECV_MESSAGE, GNUNET_MESSAGE_TYPE_MESSENGER_ROOM_SYNC, GNUNET_MESSENGER_SERVICE_NAME, GNUNET_MQ_handler_end, GNUNET_MQ_hd_fixed_size, GNUNET_MQ_hd_var_size, handle, handlers, GNUNET_VPN_Handle::mq, and recv_message().

Here is the call graph for this function:

◆ send_open_room()

static void send_open_room	(	struct GNUNET_MESSENGER_Handle *	handle,
		struct GNUNET_MESSENGER_Room *	room
	)

static

Definition at line 457 of file messenger_api.c.

{
  const struct GNUNET_CRYPTO_PublicKey *key;
  struct GNUNET_MESSENGER_RoomMessage *msg;
  struct GNUNET_MQ_Envelope *env;
  char *msg_buffer;
  ssize_t len;
 
  GNUNET_assert ((handle) && (handle->mq) && (room));
 
  key = get_handle_pubkey (handle);
 
  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
              "Open room (%s) by member using key: %s\n",
              GNUNET_h2s (get_room_key (room)),
              GNUNET_CRYPTO_public_key_to_string (key));
 
  len = GNUNET_CRYPTO_public_key_get_length (key);
 
  env = GNUNET_MQ_msg_extra (msg, len > 0 ? len : 0,
                             GNUNET_MESSAGE_TYPE_MESSENGER_ROOM_OPEN);
  GNUNET_memcpy (&(msg->key), get_room_key (room), sizeof(msg->key));
  copy_room_last_message (room, &(msg->previous));
 
  msg_buffer = ((char*) msg) + sizeof(*msg);
 
  if (len > 0)
    GNUNET_CRYPTO_write_public_key_to_buffer (key, msg_buffer, len);
 
  GNUNET_MQ_send (handle->mq, env);
}

References copy_room_last_message(), env, get_handle_pubkey(), get_room_key(), GNUNET_assert, GNUNET_CRYPTO_public_key_get_length(), GNUNET_CRYPTO_public_key_to_string(), GNUNET_CRYPTO_write_public_key_to_buffer(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_h2s(), GNUNET_log, GNUNET_memcpy, GNUNET_MESSAGE_TYPE_MESSENGER_ROOM_OPEN, GNUNET_MQ_msg_extra, GNUNET_MQ_send(), handle, key, GNUNET_VPN_Handle::mq, and msg.

Referenced by GNUNET_MESSENGER_open_room(), and iterate_reset_room().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ send_enter_room()

static void send_enter_room	(	struct GNUNET_MESSENGER_Handle *	handle,
		struct GNUNET_MESSENGER_Room *	room,
		const struct GNUNET_PeerIdentity *	door
	)

static

Definition at line 492 of file messenger_api.c.

{
  const struct GNUNET_CRYPTO_PublicKey *key;
  struct GNUNET_MESSENGER_RoomMessage *msg;
  struct GNUNET_MQ_Envelope *env;
  char *msg_buffer;
  ssize_t len;
 
  GNUNET_assert ((handle) && (handle->mq) && (room) && (door));
 
  key = get_handle_pubkey (handle);
 
  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Enter room (%s) via door: %s (%s)\n",
              GNUNET_h2s (get_room_key (room)),
              GNUNET_i2s (door),
              GNUNET_CRYPTO_public_key_to_string (key));
 
  len = GNUNET_CRYPTO_public_key_get_length (key);
 
  env = GNUNET_MQ_msg_extra (msg, len > 0 ? len : 0,
                             GNUNET_MESSAGE_TYPE_MESSENGER_ROOM_ENTRY);
  GNUNET_memcpy (&(msg->door), door, sizeof(*door));
  GNUNET_memcpy (&(msg->key), get_room_key (room), sizeof(msg->key));
  copy_room_last_message (room, &(msg->previous));
 
  msg_buffer = ((char*) msg) + sizeof(*msg);
 
  if (len > 0)
    GNUNET_CRYPTO_write_public_key_to_buffer (key, msg_buffer, len);
 
  GNUNET_MQ_send (handle->mq, env);
}

References copy_room_last_message(), env, get_handle_pubkey(), get_room_key(), GNUNET_assert, GNUNET_CRYPTO_public_key_get_length(), GNUNET_CRYPTO_public_key_to_string(), GNUNET_CRYPTO_write_public_key_to_buffer(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_h2s(), GNUNET_i2s(), GNUNET_log, GNUNET_memcpy, GNUNET_MESSAGE_TYPE_MESSENGER_ROOM_ENTRY, GNUNET_MQ_msg_extra, GNUNET_MQ_send(), handle, key, GNUNET_VPN_Handle::mq, and msg.

Referenced by GNUNET_MESSENGER_enter_room(), and iterate_reset_room().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ send_close_room()

static void send_close_room	(	struct GNUNET_MESSENGER_Handle *	handle,
		struct GNUNET_MESSENGER_Room *	room
	)

static

Definition at line 529 of file messenger_api.c.

{
  struct GNUNET_MESSENGER_RoomMessage *msg;
  struct GNUNET_MQ_Envelope *env;
 
  GNUNET_assert ((handle) && (handle->mq) && (room));
 
  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Close room (%s)!\n",
              GNUNET_h2s (get_room_key (room)));
 
  env = GNUNET_MQ_msg (msg, GNUNET_MESSAGE_TYPE_MESSENGER_ROOM_CLOSE);
 
  GNUNET_memcpy (&(msg->key), get_room_key (room), sizeof(msg->key));
  copy_room_last_message (room, &(msg->previous));
 
  GNUNET_MQ_send (handle->mq, env);
}

References copy_room_last_message(), env, get_room_key(), GNUNET_assert, GNUNET_ERROR_TYPE_DEBUG, GNUNET_h2s(), GNUNET_log, GNUNET_memcpy, GNUNET_MESSAGE_TYPE_MESSENGER_ROOM_CLOSE, GNUNET_MQ_msg, GNUNET_MQ_send(), handle, GNUNET_VPN_Handle::mq, and msg.

Referenced by callback_leave_message_sent(), and iterate_close_room().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ send_sync_room()

static void send_sync_room	(	struct GNUNET_MESSENGER_Handle *	handle,
		struct GNUNET_MESSENGER_Room *	room
	)

static

Definition at line 550 of file messenger_api.c.

{
  struct GNUNET_MESSENGER_RoomMessage *msg;
  struct GNUNET_MQ_Envelope *env;
 
  GNUNET_assert ((handle) && (handle->mq) && (room));
 
  if (GNUNET_YES == room->wait_for_sync)
    return;
 
  room->wait_for_sync = GNUNET_YES;
 
  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Sync room (%s)!\n",
              GNUNET_h2s (get_room_key (room)));
 
  env = GNUNET_MQ_msg (msg, GNUNET_MESSAGE_TYPE_MESSENGER_ROOM_SYNC);
 
  GNUNET_memcpy (&(msg->key), get_room_key (room), sizeof(msg->key));
  copy_room_last_message (room, &(msg->previous));
 
  GNUNET_MQ_send (handle->mq, env);
}

References copy_room_last_message(), env, get_room_key(), GNUNET_assert, GNUNET_ERROR_TYPE_DEBUG, GNUNET_h2s(), GNUNET_log, GNUNET_memcpy, GNUNET_MESSAGE_TYPE_MESSENGER_ROOM_SYNC, GNUNET_MQ_msg, GNUNET_MQ_send(), GNUNET_YES, handle, GNUNET_VPN_Handle::mq, msg, and GNUNET_MESSENGER_Room::wait_for_sync.

Referenced by enqueue_message_to_room().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ iterate_reset_room()

static enum GNUNET_GenericReturnValue iterate_reset_room	(	void *	cls,
		const struct GNUNET_HashCode *	key,
		void *	value
	)

static

Definition at line 576 of file messenger_api.c.

{
  struct GNUNET_MESSENGER_Handle *handle;
  struct GNUNET_MESSENGER_Room *room;
  struct GNUNET_MESSENGER_ListTunnel *entry;
 
  GNUNET_assert ((cls) && (value));
 
  handle = cls;
  room = value;
 
  if (GNUNET_YES == room->opened)
    send_open_room (handle, room);
 
  entry = room->entries.head;
  while (entry)
  {
    struct GNUNET_PeerIdentity door;
 
    GNUNET_PEER_resolve (entry->peer, &door);
    send_enter_room (handle, room, &door);
 
    entry = entry->next;
  }
 
  return GNUNET_YES;
}

References GNUNET_MESSENGER_Room::entries, GNUNET_assert, GNUNET_PEER_resolve(), GNUNET_YES, handle, GNUNET_MESSENGER_ListTunnels::head, GNUNET_MESSENGER_ListTunnel::next, GNUNET_MESSENGER_Room::opened, GNUNET_MESSENGER_ListTunnel::peer, send_enter_room(), send_open_room(), and value.

Referenced by callback_reconnect().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ callback_reconnect()

static void callback_reconnect ( void * cls )

static

Definition at line 608 of file messenger_api.c.

{
  struct GNUNET_MESSENGER_Handle *handle;
 
  GNUNET_assert (cls);
 
  handle = cls;
 
  handle->reconnect_task = NULL;
  handle->reconnect_time = GNUNET_TIME_STD_BACKOFF (handle->reconnect_time);
 
  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Reconnect messenger!\n");
 
  reconnect (handle);
 
  GNUNET_CONTAINER_multihashmap_iterate (handle->rooms, iterate_reset_room,
                                         handle);
}

References GNUNET_assert, GNUNET_CONTAINER_multihashmap_iterate(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_log, GNUNET_TIME_STD_BACKOFF, handle, iterate_reset_room(), and reconnect().

Referenced by callback_mq_error().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ iterate_close_room()

static enum GNUNET_GenericReturnValue iterate_close_room	(	void *	cls,
		const struct GNUNET_HashCode *	key,
		void *	value
	)

static

Definition at line 629 of file messenger_api.c.

{
  struct GNUNET_MESSENGER_Handle *handle;
  struct GNUNET_MESSENGER_Room *room;
 
  GNUNET_assert ((cls) && (value));
 
  handle = cls;
  room = value;
 
  send_close_room (handle, room);
 
  return GNUNET_YES;
}

References GNUNET_assert, GNUNET_YES, handle, send_close_room(), and value.

Referenced by callback_mq_error().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ callback_mq_error()

static void callback_mq_error	(	void *	cls,
		enum GNUNET_MQ_Error	error
	)

static

Definition at line 648 of file messenger_api.c.

{
  struct GNUNET_MESSENGER_Handle *handle;
 
  GNUNET_assert (cls);
 
  handle = cls;
 
  GNUNET_log (GNUNET_ERROR_TYPE_ERROR, "MQ_Error: %u\n", error);
 
  GNUNET_CONTAINER_multihashmap_iterate (handle->rooms, iterate_close_room,
                                         handle);
 
  if (handle->mq)
  {
    GNUNET_MQ_destroy (handle->mq);
    handle->mq = NULL;
  }
 
  handle->reconnect_task = GNUNET_SCHEDULER_add_delayed (handle->reconnect_time,
                                                         &callback_reconnect,
                                                         handle);
}

References callback_reconnect(), GNUNET_assert, GNUNET_CONTAINER_multihashmap_iterate(), GNUNET_ERROR_TYPE_ERROR, GNUNET_log, GNUNET_MQ_destroy(), GNUNET_SCHEDULER_add_delayed(), handle, iterate_close_room(), and GNUNET_VPN_Handle::mq.

Referenced by reconnect().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ callback_leave_message_sent()

static void callback_leave_message_sent ( void * cls )

static

Definition at line 785 of file messenger_api.c.

{
  struct GNUNET_MESSENGER_Room *room;
 
  GNUNET_assert (cls);
 
  room = cls;
 
  room->opened = GNUNET_NO;
  clear_list_tunnels (&(room->entries));
 
  send_close_room (room->handle, room);
}

References clear_list_tunnels(), GNUNET_MESSENGER_Room::entries, GNUNET_assert, GNUNET_NO, GNUNET_MESSENGER_Room::handle, GNUNET_MESSENGER_Room::opened, and send_close_room().

Referenced by send_message_to_room().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ keep_subscription_alive()

static void keep_subscription_alive ( void * cls )

static

Definition at line 801 of file messenger_api.c.

{
  struct GNUNET_MESSENGER_RoomSubscription *subscription;
  struct GNUNET_MESSENGER_Room *room;
  struct GNUNET_MESSENGER_Message *message;
  const struct GNUNET_ShortHashCode *discourse;
 
  GNUNET_assert (cls);
 
  subscription = cls;
  subscription->task = NULL;
 
  room = subscription->room;
  message = subscription->message;
 
  subscription->message = NULL;
 
  discourse = &(message->body.subscribtion.discourse);
 
  if (GNUNET_YES != GNUNET_CONTAINER_multishortmap_remove (room->subscriptions,
                                                           discourse,
                                                           subscription))
  {
    destroy_message (message);
    return;
  }
 
  GNUNET_free (subscription);
 
  enqueue_message_to_room (room, NULL, message, NULL, GNUNET_NO);
}

References GNUNET_MESSENGER_Message::body, destroy_message(), GNUNET_MESSENGER_MessageSubscribtion::discourse, enqueue_message_to_room(), GNUNET_assert, GNUNET_CONTAINER_multishortmap_remove(), GNUNET_free, GNUNET_NO, GNUNET_YES, GNUNET_MESSENGER_RoomSubscription::message, GNUNET_MESSENGER_RoomSubscription::room, GNUNET_MESSENGER_MessageBody::subscribtion, GNUNET_MESSENGER_Room::subscriptions, and GNUNET_MESSENGER_RoomSubscription::task.

Referenced by handle_discourse_subscription().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ handle_discourse_subscription()

static void handle_discourse_subscription	(	struct GNUNET_MESSENGER_Room *	room,
		struct GNUNET_MESSENGER_Message *	message
	)

static

Definition at line 835 of file messenger_api.c.

{
  const struct GNUNET_ShortHashCode *discourse;
  struct GNUNET_MESSENGER_RoomSubscription *subscription;
  struct GNUNET_TIME_Relative time;
  uint32_t flags;
 
  GNUNET_assert ((room) && (message));
 
  flags = message->body.subscribtion.flags;
 
  discourse = &(message->body.subscribtion.discourse);
 
  subscription = GNUNET_CONTAINER_multishortmap_get (room->subscriptions,
                                                     discourse);
 
  if (0 == (flags & GNUNET_MESSENGER_FLAG_SUBSCRIPTION_UNSUBSCRIBE))
    goto active_subscription;
 
  if (! subscription)
    return;
 
  if (subscription->task)
    GNUNET_SCHEDULER_cancel (subscription->task);
 
  if (subscription->message)
    destroy_message (subscription->message);
 
  if (GNUNET_YES != GNUNET_CONTAINER_multishortmap_remove (room->subscriptions,
                                                           discourse,
                                                           subscription))
  {
    subscription->task = NULL;
    subscription->message = NULL;
    return;
  }
 
  GNUNET_free (subscription);
  return;
 
active_subscription:
  if (0 == (flags & GNUNET_MESSENGER_FLAG_SUBSCRIPTION_KEEP_ALIVE))
    return;
 
  time = GNUNET_TIME_relative_ntoh (message->body.subscribtion.time);
 
  if (! subscription)
  {
    subscription = GNUNET_new (struct GNUNET_MESSENGER_RoomSubscription);
 
    if (GNUNET_OK != GNUNET_CONTAINER_multishortmap_put (
          room->subscriptions, discourse, subscription,
          GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_FAST))
    {
      GNUNET_free (subscription);
      return;
    }
 
    subscription->room = room;
  }
  else
  {
    if (subscription->task)
      GNUNET_SCHEDULER_cancel (subscription->task);
 
    if (subscription->message)
      destroy_message (subscription->message);
  }
 
  subscription->message = create_message_subscribtion (discourse, time,
                                                       flags);
 
  if (! subscription->message)
  {
    subscription->task = NULL;
    return;
  }
 
  {
    struct GNUNET_TIME_Relative delay;
    delay = GNUNET_TIME_relative_multiply_double (time, 0.9);
 
    subscription->task = GNUNET_SCHEDULER_add_delayed_with_priority (
      delay, GNUNET_SCHEDULER_PRIORITY_HIGH,
      keep_subscription_alive, subscription);
  }
}

References GNUNET_MESSENGER_Message::body, create_message_subscribtion(), destroy_message(), GNUNET_MESSENGER_MessageSubscribtion::discourse, GNUNET_MESSENGER_MessageSubscribtion::flags, GNUNET_assert, GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_FAST, GNUNET_CONTAINER_multishortmap_get(), GNUNET_CONTAINER_multishortmap_put(), GNUNET_CONTAINER_multishortmap_remove(), GNUNET_free, GNUNET_MESSENGER_FLAG_SUBSCRIPTION_KEEP_ALIVE, GNUNET_MESSENGER_FLAG_SUBSCRIPTION_UNSUBSCRIBE, GNUNET_new, GNUNET_OK, GNUNET_SCHEDULER_add_delayed_with_priority(), GNUNET_SCHEDULER_cancel(), GNUNET_SCHEDULER_PRIORITY_HIGH, GNUNET_TIME_relative_multiply_double(), GNUNET_TIME_relative_ntoh(), GNUNET_YES, keep_subscription_alive(), GNUNET_MESSENGER_RoomSubscription::message, GNUNET_MESSENGER_RoomSubscription::room, GNUNET_MESSENGER_MessageBody::subscribtion, GNUNET_MESSENGER_Room::subscriptions, GNUNET_MESSENGER_RoomSubscription::task, and GNUNET_MESSENGER_MessageSubscribtion::time.

Referenced by send_message_to_room().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ send_message_to_room()

static void send_message_to_room	(	struct GNUNET_MESSENGER_Room *	room,
		struct GNUNET_MESSENGER_Message *	message,
		const struct GNUNET_CRYPTO_PrivateKey *	key,
		const struct GNUNET_HashCode *	epoch,
		struct GNUNET_HashCode *	hash
	)

static

Definition at line 926 of file messenger_api.c.

{
  const struct GNUNET_ShortHashCode *sender_id;
  struct GNUNET_MESSENGER_SendMessage *msg;
  struct GNUNET_MQ_Envelope *env;
  uint16_t msg_length;
  char *msg_buffer;
 
  GNUNET_assert ((room) && (message) && (key) && (hash));
 
  sender_id = get_room_sender_id (room);
 
  if (GNUNET_NO == is_service_message (message))
  {
    struct GNUNET_MESSENGER_Epoch *last_epoch;
    struct GNUNET_MESSENGER_EpochAnnouncement *announcement;
    const struct GNUNET_CRYPTO_SymmetricSessionKey *epoch_key;
 
    last_epoch = get_room_epoch (room, epoch, GNUNET_YES);
 
    if (! last_epoch)
      goto send_message;
 
    announcement = get_epoch_announcement (last_epoch, NULL, GNUNET_YES);
 
    if ((! announcement) && (GNUNET_YES != is_room_public (room)))
      generate_room_epoch_announcement (room, last_epoch, &announcement);
 
    if (announcement)
      epoch_key = get_epoch_announcement_key (announcement);
    else
      epoch_key = NULL;
 
    if (! epoch_key)
      goto send_message;
 
    if (GNUNET_YES != encrypt_secret_message (message, &(announcement->
                                                         identifier), epoch_key)
        )
    {
      GNUNET_log (GNUNET_ERROR_TYPE_ERROR, "Encrypting message (%s) failed!\n",
                  GNUNET_h2s (hash));
      return;
    }
  }
 
send_message:
  if (GNUNET_YES == is_epoch_message (message))
    message->header.timestamp = GNUNET_TIME_absolute_hton (
      GNUNET_TIME_absolute_get_zero_ ());
  else
    message->header.timestamp = GNUNET_TIME_absolute_hton (
      GNUNET_TIME_absolute_get ());
 
  GNUNET_memcpy (&(message->header.sender_id), sender_id,
                 sizeof(message->header.sender_id));
 
  if (0 == GNUNET_CRYPTO_hash_cmp (epoch, &(room->last_epoch)))
    copy_room_last_message (room, &(message->header.previous));
  else
    GNUNET_memcpy (&(message->header.previous), epoch,
                   sizeof(message->header.previous));
 
  switch (message->header.kind)
  {
  case GNUNET_MESSENGER_KIND_JOIN:
    {
      GNUNET_memcpy (&(message->body.join.epoch), epoch,
                     sizeof(message->body.join.epoch));
      break;
    }
  case GNUNET_MESSENGER_KIND_LEAVE:
    {
      GNUNET_memcpy (&(message->body.leave.epoch), epoch,
                     sizeof(message->body.leave.epoch));
      break;
    }
  default:
    break;
  }
 
  message->header.signature.type = key->type;
 
  msg_length = get_message_size (message, GNUNET_YES);
 
  env = GNUNET_MQ_msg_extra (
    msg, msg_length,
    GNUNET_MESSAGE_TYPE_MESSENGER_ROOM_SEND_MESSAGE);
 
  GNUNET_memcpy (&(msg->key), get_room_key (room), sizeof(msg->key));
 
  msg_buffer = ((char*) msg) + sizeof(*msg);
  encode_message (message, msg_length, msg_buffer, GNUNET_YES);
 
  hash_message (message, msg_length, msg_buffer, hash);
  sign_message (message, msg_length, msg_buffer, hash, key);
 
  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Send message (%s)!\n",
              GNUNET_h2s (hash));
 
  if (! get_message_discourse (message))
  {
    const struct GNUNET_HashCode *epoch;
 
    switch (message->header.kind)
    {
    case GNUNET_MESSENGER_KIND_JOIN:
    case GNUNET_MESSENGER_KIND_LEAVE:
      epoch = hash;
      break;
    default:
      epoch = &(room->last_epoch);
      break;
    }
 
    update_room_last_message (room, hash, epoch);
  }
 
  switch (message->header.kind)
  {
  case GNUNET_MESSENGER_KIND_LEAVE:
    GNUNET_MQ_notify_sent (env, callback_leave_message_sent, room);
    break;
  case GNUNET_MESSENGER_KIND_SUBSCRIBTION:
    handle_discourse_subscription (room, message);
    break;
  default:
    break;
  }
 
  GNUNET_MQ_send (room->handle->mq, env);
}

Referenced by dequeue_message_from_room().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ enqueue_message_to_room()

void enqueue_message_to_room	(	struct GNUNET_MESSENGER_Room *	room,
		const struct GNUNET_HashCode *	epoch,
		struct GNUNET_MESSENGER_Message *	message,
		struct GNUNET_MESSENGER_Message *	transcript,
		enum GNUNET_GenericReturnValue	sync
	)

Enqueus a message and its optional transcript for sending it to a given room and epoch.

Parameters

[in,out]	room	Room
[in]	epoch	Hash of epoch
[in]	message	Message
[in]	transcript	Transcript of message or NULL
[in]	sync	GNUNET_YES to enforce syncing, otherwise GNUNET_NO

Definition at line 1065 of file messenger_api.c.

{
  const struct GNUNET_CRYPTO_PrivateKey *key;
 
  GNUNET_assert ((room) && (message));
 
  key = get_handle_key (room->handle);
 
  if (! epoch)
    epoch = &(room->last_epoch);
 
  enqueue_to_messages (&(room->queue),
                       key,
                       epoch,
                       message,
                       transcript);
 
  if (GNUNET_YES != is_room_available (room))
    return;
 
  if ((GNUNET_YES == sync) ||
      (GNUNET_YES == is_message_session_bound (message)))
    send_sync_room (room->handle, room);
  else if (GNUNET_YES != room->wait_for_sync)
    dequeue_messages_from_room (room);
}

References dequeue_messages_from_room(), enqueue_to_messages(), get_handle_key(), GNUNET_assert, GNUNET_YES, GNUNET_MESSENGER_Room::handle, is_message_session_bound(), is_room_available(), key, GNUNET_MESSENGER_Room::last_epoch, GNUNET_MESSENGER_Room::queue, send_sync_room(), and GNUNET_MESSENGER_Room::wait_for_sync.

Referenced by delete_room_message(), GNUNET_MESSENGER_close_room(), handle_member_id(), handle_miss_message(), iterate_send_key_to_room(), iterate_send_name_to_room(), keep_subscription_alive(), send_epoch_message(), and send_message_to_room_with_key().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ dequeue_message_from_room()

static void dequeue_message_from_room ( void * cls )

static

Definition at line 1098 of file messenger_api.c.

{
  struct GNUNET_MESSENGER_Room *room;
  struct GNUNET_MESSENGER_Message *message;
  struct GNUNET_MESSENGER_Message *transcript;
  struct GNUNET_CRYPTO_PrivateKey key;
  struct GNUNET_HashCode epoch;
  struct GNUNET_HashCode hash;
  struct GNUNET_CRYPTO_PublicKey pubkey;
 
  GNUNET_assert (cls);
 
  room = cls;
 
  GNUNET_assert (room->handle);
 
  room->queue_task = NULL;
 
  if ((GNUNET_YES != is_room_available (room)) || (! (room->handle->mq)))
    goto next_message;
 
  message = NULL;
  transcript = NULL;
  memset (&key, 0, sizeof(key));
 
  message = dequeue_from_messages (&(room->queue),
                                   &key,
                                   &epoch,
                                   &transcript);
 
  if (! message)
  {
    if (transcript)
      destroy_message (transcript);
 
    return;
  }
 
  send_message_to_room (room, message, &key, &epoch, &hash);
  destroy_message (message);
 
  if (! transcript)
  {
    GNUNET_CRYPTO_private_key_clear (&key);
    goto next_message;
  }
 
  GNUNET_memcpy (&(transcript->body.transcript.hash), &hash, sizeof(hash));
 
  memset (&pubkey, 0, sizeof(pubkey));
  GNUNET_CRYPTO_key_get_public (&key, &pubkey);
 
  if (GNUNET_YES == encrypt_message (transcript, &pubkey))
  {
    struct GNUNET_HashCode other;
    send_message_to_room (room, transcript, &key, &epoch, &other);
 
    GNUNET_CRYPTO_private_key_clear (&key);
 
    link_room_message (room, &hash, &other);
    link_room_message (room, &other, &hash);
  }
  else
  {
    GNUNET_CRYPTO_private_key_clear (&key);
 
    GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                "Sending transcript aborted: Encryption failed!\n");
  }
 
  destroy_message (transcript);
 
next_message:
  if (! room->queue.head)
    return;
 
  room->queue_task = GNUNET_SCHEDULER_add_with_priority (
    GNUNET_SCHEDULER_PRIORITY_HIGH, dequeue_message_from_room, room);
}

References GNUNET_MESSENGER_Message::body, dequeue_from_messages(), dequeue_message_from_room(), destroy_message(), encrypt_message(), GNUNET_assert, GNUNET_CRYPTO_key_get_public(), GNUNET_CRYPTO_private_key_clear(), GNUNET_ERROR_TYPE_ERROR, GNUNET_log, GNUNET_memcpy, GNUNET_SCHEDULER_add_with_priority(), GNUNET_SCHEDULER_PRIORITY_HIGH, GNUNET_YES, GNUNET_MESSENGER_Room::handle, GNUNET_MESSENGER_MessageTranscript::hash, GNUNET_MESSENGER_QueueMessages::head, is_room_available(), key, link_room_message(), GNUNET_MESSENGER_Handle::mq, next_message, pubkey, GNUNET_MESSENGER_Room::queue, GNUNET_MESSENGER_Room::queue_task, send_message_to_room(), and GNUNET_MESSENGER_MessageBody::transcript.

Referenced by dequeue_message_from_room(), and dequeue_messages_from_room().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ iterate_send_name_to_room()

static enum GNUNET_GenericReturnValue iterate_send_name_to_room	(	void *	cls,
		struct GNUNET_MESSENGER_Room *	room,
		const struct GNUNET_MESSENGER_Contact *	contact
	)

static

Definition at line 1204 of file messenger_api.c.

{
  const struct GNUNET_MESSENGER_Handle *handle;
  struct GNUNET_MESSENGER_Message *message;
  const char *name;
 
  GNUNET_assert ((cls) && (room));
 
  handle = cls;
 
  if (GNUNET_YES != room->use_handle_name)
    return GNUNET_YES;
 
  name = get_handle_name (handle);
  if (! name)
    return GNUNET_YES;
 
  message = create_message_name (name);
  if (! message)
    return GNUNET_NO;
 
  enqueue_message_to_room (room, NULL, message, NULL, GNUNET_NO);
  return GNUNET_YES;
}

References create_message_name(), enqueue_message_to_room(), get_handle_name(), GNUNET_assert, GNUNET_NO, GNUNET_YES, handle, name, and GNUNET_MESSENGER_Room::use_handle_name.

Referenced by GNUNET_MESSENGER_set_name().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ get_non_anonymous_key()

static const struct GNUNET_CRYPTO_PublicKey * get_non_anonymous_key ( const struct GNUNET_CRYPTO_PublicKey * public_key )

static

Definition at line 1246 of file messenger_api.c.

{
  if (0 == GNUNET_memcmp (public_key, get_anonymous_public_key ()))
    return NULL;
 
  return public_key;
}

References get_anonymous_public_key(), and GNUNET_memcmp.

Referenced by GNUNET_MESSENGER_contact_get_key(), GNUNET_MESSENGER_get_key(), and GNUNET_MESSENGER_send_message().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ iterate_send_key_to_room()

static enum GNUNET_GenericReturnValue iterate_send_key_to_room	(	void *	cls,
		struct GNUNET_MESSENGER_Room *	room,
		const struct GNUNET_MESSENGER_Contact *	contact
	)

static

Definition at line 1266 of file messenger_api.c.

{
  const struct GNUNET_CRYPTO_PrivateKey *key;
  struct GNUNET_MESSENGER_Message *message;
 
  GNUNET_assert ((cls) && (room));
 
  key = cls;
 
  message = create_message_key (key);
  if (! message)
    return GNUNET_NO;
 
  enqueue_message_to_room (room, NULL, message, NULL, GNUNET_NO);
  return GNUNET_YES;
}

References create_message_key(), enqueue_message_to_room(), GNUNET_assert, GNUNET_NO, GNUNET_YES, and key.

Referenced by GNUNET_MESSENGER_set_key().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ iterate_find_room()

static enum GNUNET_GenericReturnValue iterate_find_room	(	void *	cls,
		const struct GNUNET_HashCode *	key,
		void *	value
	)

static

Definition at line 1407 of file messenger_api.c.

{
  struct GNUNET_MESSENGER_RoomFind *find;
  struct GNUNET_MESSENGER_Room *room;
  enum GNUNET_GenericReturnValue result;
 
  GNUNET_assert ((cls) && (value));
 
  find = cls;
  room = value;
  result = GNUNET_YES;
 
  if ((! find->contact) ||
      (GNUNET_YES == find_room_member (room, find->contact)))
    find->counter--;
 
  if (find->callback)
    result = find->callback (find->cls, room, find->contact);
 
  if (find->counter <= 0)
    result = GNUNET_NO;
 
  return result;
}

References GNUNET_MESSENGER_RoomFind::callback, GNUNET_MESSENGER_RoomFind::cls, GNUNET_MESSENGER_RoomFind::contact, GNUNET_MESSENGER_RoomFind::counter, find_room_member(), GNUNET_assert, GNUNET_NO, GNUNET_YES, result, and value.

Referenced by GNUNET_MESSENGER_find_rooms().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ send_message_to_room_with_key()

static void send_message_to_room_with_key	(	struct GNUNET_MESSENGER_Room *	room,
		struct GNUNET_MESSENGER_Message *	message,
		const struct GNUNET_CRYPTO_PublicKey *	public_key
	)

static

Definition at line 1525 of file messenger_api.c.

{
  struct GNUNET_MESSENGER_Message *transcript;
  const struct GNUNET_CRYPTO_PublicKey *pubkey;
  const char *handle_name;
  char *original_name;
 
  transcript = NULL;
 
  if (GNUNET_MESSENGER_KIND_NAME != message->header.kind)
    goto skip_naming;
 
  original_name = message->body.name.name;
  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
              "Apply rule for using handle name in room: %s\n", GNUNET_h2s (
                get_room_key (room)));
 
  handle_name = get_handle_name (room->handle);
 
  if ((handle_name) && (GNUNET_YES == room->use_handle_name) &&
      ((! original_name) || (0 == strlen (original_name))))
  {
    if (original_name)
      GNUNET_free (original_name);
 
    message->body.name.name = GNUNET_strdup (handle_name);
  }
 
skip_naming:
  if (! public_key)
    goto skip_encryption;
 
  pubkey = get_handle_pubkey (room->handle);
 
  if (0 != GNUNET_memcmp (pubkey, public_key))
    transcript = transcribe_message (message, public_key);
 
  if (GNUNET_YES != encrypt_message (message, public_key))
  {
    GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                "Sending message aborted: Encryption failed!\n");
 
    if (transcript)
      destroy_message (transcript);
 
    destroy_message (message);
    return;
  }
 
skip_encryption:
  enqueue_message_to_room (room, NULL, message, transcript, GNUNET_NO);
}

References GNUNET_MESSENGER_Message::body, destroy_message(), encrypt_message(), enqueue_message_to_room(), get_handle_name(), get_handle_pubkey(), get_room_key(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_ERROR_TYPE_ERROR, GNUNET_free, GNUNET_h2s(), GNUNET_log, GNUNET_memcmp, GNUNET_MESSENGER_KIND_NAME, GNUNET_NO, GNUNET_strdup, GNUNET_YES, GNUNET_MESSENGER_Room::handle, GNUNET_MESSENGER_Message::header, GNUNET_MESSENGER_MessageHeader::kind, GNUNET_MESSENGER_MessageName::name, GNUNET_MESSENGER_MessageBody::name, pubkey, transcribe_message(), and GNUNET_MESSENGER_Room::use_handle_name.

Referenced by GNUNET_MESSENGER_send_message().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ request_message_from_room()

void request_message_from_room	(	const struct GNUNET_MESSENGER_Room *	room,
		const struct GNUNET_HashCode *	hash
	)

Requests a specific message from a given room which can be identified by its hash.

Parameters

[in]	room	Room
[in]	hash	Hash of message

Definition at line 1648 of file messenger_api.c.

{
  struct GNUNET_MESSENGER_GetMessage *msg;
  struct GNUNET_MQ_Envelope *env;
 
  GNUNET_assert ((room) && (hash));
 
  if (GNUNET_is_zero (hash))
    return;
 
  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Request message (%s)!\n",
              GNUNET_h2s (hash));
 
  env = GNUNET_MQ_msg (msg, GNUNET_MESSAGE_TYPE_MESSENGER_ROOM_GET_MESSAGE);
  GNUNET_memcpy (&(msg->key), get_room_key (room), sizeof(msg->key));
  GNUNET_memcpy (&(msg->hash), hash, sizeof(*hash));
  GNUNET_MQ_send (room->handle->mq, env);
}

References env, get_room_key(), GNUNET_assert, GNUNET_ERROR_TYPE_DEBUG, GNUNET_h2s(), GNUNET_is_zero, GNUNET_log, GNUNET_memcpy, GNUNET_MESSAGE_TYPE_MESSENGER_ROOM_GET_MESSAGE, GNUNET_MQ_msg, GNUNET_MQ_send(), GNUNET_MESSENGER_Room::handle, GNUNET_MESSENGER_Handle::mq, and msg.

Referenced by GNUNET_MESSENGER_get_message(), and iterate_room_request().

Here is the call graph for this function:

Here is the caller graph for this function:

Data Structures

Functions

Function Documentation

◆ dequeue_messages_from_room()

◆ handle_room_open()

◆ handle_room_entry()

◆ handle_room_close()

◆ handle_room_sync()

◆ handle_member_id()

◆ check_recv_message()

◆ handle_recv_message()

◆ handle_miss_message()

◆ reconnect()

◆ send_open_room()

◆ send_enter_room()

◆ send_close_room()

◆ send_sync_room()

◆ iterate_reset_room()

◆ callback_reconnect()

◆ iterate_close_room()

◆ callback_mq_error()

◆ callback_leave_message_sent()

◆ keep_subscription_alive()

◆ handle_discourse_subscription()

◆ send_message_to_room()

◆ enqueue_message_to_room()

◆ dequeue_message_from_room()

◆ iterate_send_name_to_room()

◆ get_non_anonymous_key()

◆ iterate_send_key_to_room()

◆ iterate_find_room()

◆ send_message_to_room_with_key()

◆ request_message_from_room()