gnunet-service-messenger.c File Reference

#include "gnunet-service-messenger.h"
#include "gnunet-service-messenger_handle.h"
#include "gnunet-service-messenger_room.h"
#include "gnunet-service-messenger_service.h"
#include "gnunet_common.h"
#include "messenger_api_message.h"

Include dependency graph for gnunet-service-messenger.c:

Go to the source code of this file.

Data Structures
struct	GNUNET_MESSENGER_Client

Functions
static void	handle_create (void *cls, const struct GNUNET_MESSENGER_CreateMessage *msg)
static void	handle_destroy (void *cls, const struct GNUNET_MESSENGER_DestroyMessage *msg)
static enum GNUNET_GenericReturnValue	check_room_initial_key (const struct GNUNET_MESSENGER_RoomMessage *msg)
static void	initialize_handle_via_key (struct GNUNET_MESSENGER_SrvHandle *handle, const struct GNUNET_MESSENGER_RoomMessage *msg)
static enum GNUNET_GenericReturnValue	check_room_open (void *cls, const struct GNUNET_MESSENGER_RoomMessage *msg)
static void	handle_room_open (void *cls, const struct GNUNET_MESSENGER_RoomMessage *msg)
static enum GNUNET_GenericReturnValue	check_room_entry (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 enum GNUNET_GenericReturnValue	check_send_message (void *cls, const struct GNUNET_MESSENGER_SendMessage *msg)
static void	handle_send_message (void *cls, const struct GNUNET_MESSENGER_SendMessage *msg)
static void	callback_found_message (void *cls, struct GNUNET_MESSENGER_SrvRoom *room, const struct GNUNET_MESSENGER_Message *message, const struct GNUNET_HashCode *hash)
static void	handle_get_message (void *cls, const struct GNUNET_MESSENGER_GetMessage *msg)
static void *	callback_client_connect (void *cls, struct GNUNET_SERVICE_Client *client, struct GNUNET_MQ_Handle *mq)
static void	callback_client_disconnect (void *cls, struct GNUNET_SERVICE_Client *client, void *internal_cls)
static void	run (void *cls, const struct GNUNET_CONFIGURATION_Handle *config, struct GNUNET_SERVICE_Handle *service)
	Setup MESSENGER internals. More...
	GNUNET_SERVICE_MAIN (GNUNET_MESSENGER_SERVICE_NAME, GNUNET_SERVICE_OPTION_NONE, &run, &callback_client_connect, &callback_client_disconnect, NULL, GNUNET_MQ_hd_fixed_size(create, GNUNET_MESSAGE_TYPE_MESSENGER_CONNECTION_CREATE, struct GNUNET_MESSENGER_CreateMessage, NULL), GNUNET_MQ_hd_fixed_size(destroy, GNUNET_MESSAGE_TYPE_MESSENGER_CONNECTION_DESTROY, struct GNUNET_MESSENGER_DestroyMessage, NULL), GNUNET_MQ_hd_var_size(room_open, GNUNET_MESSAGE_TYPE_MESSENGER_ROOM_OPEN, struct GNUNET_MESSENGER_RoomMessage, NULL), GNUNET_MQ_hd_var_size(room_entry, GNUNET_MESSAGE_TYPE_MESSENGER_ROOM_ENTRY, struct GNUNET_MESSENGER_RoomMessage, NULL), GNUNET_MQ_hd_fixed_size(room_close, GNUNET_MESSAGE_TYPE_MESSENGER_ROOM_CLOSE, struct GNUNET_MESSENGER_RoomMessage, NULL), GNUNET_MQ_hd_var_size(send_message, GNUNET_MESSAGE_TYPE_MESSENGER_ROOM_SEND_MESSAGE, struct GNUNET_MESSENGER_SendMessage, NULL), GNUNET_MQ_hd_fixed_size(get_message, GNUNET_MESSAGE_TYPE_MESSENGER_ROOM_GET_MESSAGE, struct GNUNET_MESSENGER_GetMessage, NULL), GNUNET_MQ_hd_fixed_size(room_sync, GNUNET_MESSAGE_TYPE_MESSENGER_ROOM_SYNC, struct GNUNET_MESSENGER_RoomMessage, NULL), GNUNET_MQ_handler_end())
	Define "main" method using service macro. More...

Variables
struct GNUNET_MESSENGER_Service *	messenger

Function Documentation

handle_create()

static void handle_create ( void *  cls, const struct GNUNET_MESSENGER_CreateMessage *  msg  )

static

Definition at line 43 of file gnunet-service-messenger.c.

{
  struct GNUNET_MESSENGER_Client *msg_client = cls;
 
  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Handle created\n");
 
  GNUNET_SERVICE_client_continue (msg_client->client);
}

References GNUNET_MESSENGER_Client::client, GNUNET_ERROR_TYPE_DEBUG, GNUNET_log, and GNUNET_SERVICE_client_continue().

Here is the call graph for this function:

handle_destroy()

static void handle_destroy ( void *  cls, const struct GNUNET_MESSENGER_DestroyMessage *  msg  )

static

Definition at line 55 of file gnunet-service-messenger.c.

{
  struct GNUNET_MESSENGER_Client *msg_client = cls;
 
  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Handle destroyed\n");
 
  GNUNET_SERVICE_client_drop (msg_client->client);
}

References GNUNET_MESSENGER_Client::client, GNUNET_ERROR_TYPE_DEBUG, GNUNET_log, and GNUNET_SERVICE_client_drop().

Here is the call graph for this function:

check_room_initial_key()

static enum GNUNET_GenericReturnValue check_room_initial_key ( const struct GNUNET_MESSENGER_RoomMessage *  msg )

static

Definition at line 67 of file gnunet-service-messenger.c.

{
  const uint16_t full_length = ntohs (msg->header.size);
 
  if (full_length < sizeof(*msg))
    return GNUNET_NO;
 
  const uint16_t msg_length = full_length - sizeof(*msg);
  const char *msg_buffer = ((const char*) msg) + sizeof(*msg);
 
  if (0 == msg_length)
    return GNUNET_OK;
 
  struct GNUNET_CRYPTO_PublicKey key;
  size_t key_len;
 
  if (GNUNET_OK != GNUNET_CRYPTO_read_public_key_from_buffer (msg_buffer,
                                                              msg_length,
                                                              &key, &key_len))
    return GNUNET_NO;
 
  return key_len == msg_length ? GNUNET_OK : GNUNET_NO;
}

References GNUNET_CRYPTO_read_public_key_from_buffer(), GNUNET_NO, GNUNET_OK, key, msg, and GNUNET_MessageHeader::size.

Referenced by check_room_entry(), and check_room_open().

Here is the call graph for this function:

Here is the caller graph for this function:

initialize_handle_via_key()

static void initialize_handle_via_key ( struct GNUNET_MESSENGER_SrvHandle *  handle, const struct GNUNET_MESSENGER_RoomMessage *  msg  )

static

Definition at line 93 of file gnunet-service-messenger.c.

{
  GNUNET_assert (handle);
 
  const uint16_t full_length = ntohs (msg->header.size);
  const uint16_t msg_length = full_length - sizeof(*msg);
  const char *msg_buffer = ((const char*) msg) + sizeof(*msg);
 
  if (msg_length > 0)
  {
    struct GNUNET_CRYPTO_PublicKey key;
    size_t key_len;
 
    if (GNUNET_OK == GNUNET_CRYPTO_read_public_key_from_buffer (msg_buffer,
                                                                msg_length,
                                                                &key,
                                                                &key_len))
      set_srv_handle_key (handle, &key);
    else
      GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                  "Initialization failed while reading invalid key!\n");
  }
  else
    GNUNET_log (GNUNET_ERROR_TYPE_WARNING, "Initialization is missing key!\n");
}

References GNUNET_assert, GNUNET_CRYPTO_read_public_key_from_buffer(), GNUNET_ERROR_TYPE_ERROR, GNUNET_ERROR_TYPE_WARNING, GNUNET_log, GNUNET_OK, handle, key, msg, set_srv_handle_key(), and GNUNET_MessageHeader::size.

Referenced by handle_room_entry(), and handle_room_open().

Here is the call graph for this function:

Here is the caller graph for this function:

check_room_open()

static enum GNUNET_GenericReturnValue check_room_open ( void *  cls, const struct GNUNET_MESSENGER_RoomMessage *  msg  )

static

Definition at line 122 of file gnunet-service-messenger.c.

{
  return check_room_initial_key (msg);
}

References check_room_initial_key(), and msg.

Here is the call graph for this function:

handle_room_open()

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

static

Definition at line 130 of file gnunet-service-messenger.c.

{
  struct GNUNET_MESSENGER_Client *msg_client = cls;
 
  initialize_handle_via_key (msg_client->handle, msg);
 
  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Opening room: %s\n", GNUNET_h2s (
                &(msg->key)));
 
  if (GNUNET_YES == open_srv_handle_room (msg_client->handle, &(msg->key)))
  {
    struct GNUNET_HashCode prev;
    sync_srv_handle_messages (msg_client->handle, &(msg->key), &(msg->previous),
                              &prev);
 
    const struct GNUNET_ShortHashCode *member_id = get_srv_handle_member_id (
      msg_client->handle, &(msg->key));
 
    GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Opening room with member id: %s\n",
                GNUNET_sh2s (member_id));
 
    struct GNUNET_MESSENGER_RoomMessage *response;
    struct GNUNET_MQ_Envelope *env;
 
    env = GNUNET_MQ_msg (response, GNUNET_MESSAGE_TYPE_MESSENGER_ROOM_OPEN);
    GNUNET_memcpy (&(response->key), &(msg->key), sizeof(response->key));
    GNUNET_memcpy (&(response->previous), &prev, sizeof(response->previous));
    GNUNET_MQ_send (msg_client->handle->mq, env);
  }
  else
    GNUNET_log (GNUNET_ERROR_TYPE_ERROR, "Opening room failed: %s\n",
                GNUNET_h2s (&(msg->key)));
 
  GNUNET_SERVICE_client_continue (msg_client->client);
}

References GNUNET_MESSENGER_Client::client, env, get_srv_handle_member_id(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_ERROR_TYPE_ERROR, GNUNET_h2s(), GNUNET_log, GNUNET_memcpy, GNUNET_MESSAGE_TYPE_MESSENGER_ROOM_OPEN, GNUNET_MQ_msg, GNUNET_MQ_send(), GNUNET_SERVICE_client_continue(), GNUNET_sh2s(), GNUNET_YES, GNUNET_MESSENGER_Client::handle, initialize_handle_via_key(), GNUNET_MESSENGER_SrvHandle::mq, msg, open_srv_handle_room(), GNUNET_MQ_Envelope::prev, response, and sync_srv_handle_messages().

Here is the call graph for this function:

check_room_entry()

static enum GNUNET_GenericReturnValue check_room_entry ( void *  cls, const struct GNUNET_MESSENGER_RoomMessage *  msg  )

static

Definition at line 169 of file gnunet-service-messenger.c.

{
  return check_room_initial_key (msg);
}

References check_room_initial_key(), and msg.

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 177 of file gnunet-service-messenger.c.

{
  struct GNUNET_MESSENGER_Client *msg_client = cls;
 
  initialize_handle_via_key (msg_client->handle, msg);
 
  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Entering room: %s, %s\n", GNUNET_h2s (
                &(msg->key)), GNUNET_i2s (&(msg->door)));
 
  if (GNUNET_YES == entry_srv_handle_room (msg_client->handle, &(msg->door),
                                           &(msg->key)))
  {
    struct GNUNET_HashCode prev;
    sync_srv_handle_messages (msg_client->handle, &(msg->key), &(msg->previous),
                              &prev);
 
    const struct GNUNET_ShortHashCode *member_id = get_srv_handle_member_id (
      msg_client->handle, &(msg->key));
 
    GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Entering room with member id: %s\n",
                GNUNET_sh2s (member_id));
 
    struct GNUNET_MESSENGER_RoomMessage *response;
    struct GNUNET_MQ_Envelope *env;
 
    env = GNUNET_MQ_msg (response, GNUNET_MESSAGE_TYPE_MESSENGER_ROOM_ENTRY);
    GNUNET_memcpy (&(response->door), &(msg->door), sizeof(response->door));
    GNUNET_memcpy (&(response->key), &(msg->key), sizeof(response->key));
    GNUNET_memcpy (&(response->previous), &prev, sizeof(response->previous));
    GNUNET_MQ_send (msg_client->handle->mq, env);
  }
  else
    GNUNET_log (GNUNET_ERROR_TYPE_ERROR, "Entrance into room failed: %s, %s\n",
                GNUNET_h2s (&(msg->key)),
                GNUNET_i2s (&(msg->door)));
 
  GNUNET_SERVICE_client_continue (msg_client->client);
}

References GNUNET_MESSENGER_Client::client, entry_srv_handle_room(), env, get_srv_handle_member_id(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_ERROR_TYPE_ERROR, GNUNET_h2s(), GNUNET_i2s(), GNUNET_log, GNUNET_memcpy, GNUNET_MESSAGE_TYPE_MESSENGER_ROOM_ENTRY, GNUNET_MQ_msg, GNUNET_MQ_send(), GNUNET_SERVICE_client_continue(), GNUNET_sh2s(), GNUNET_YES, GNUNET_MESSENGER_Client::handle, initialize_handle_via_key(), GNUNET_MESSENGER_SrvHandle::mq, msg, GNUNET_MQ_Envelope::prev, response, and sync_srv_handle_messages().

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 219 of file gnunet-service-messenger.c.

{
  struct GNUNET_MESSENGER_Client *msg_client = cls;
 
  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Closing room: %s\n", GNUNET_h2s (
                &(msg->key)));
 
  if (GNUNET_YES == close_srv_handle_room (msg_client->handle, &(msg->key)))
  {
    GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Closing room succeeded: %s\n",
                GNUNET_h2s (&(msg->key)));
 
    struct GNUNET_MESSENGER_RoomMessage *response;
    struct GNUNET_MQ_Envelope *env;
 
    env = GNUNET_MQ_msg (response, GNUNET_MESSAGE_TYPE_MESSENGER_ROOM_CLOSE);
    GNUNET_memcpy (&(response->key), &(msg->key), sizeof(response->key));
    GNUNET_memcpy (&(response->previous), &(msg->previous),
                   sizeof(response->previous));
    GNUNET_MQ_send (msg_client->handle->mq, env);
  }
  else
    GNUNET_log (GNUNET_ERROR_TYPE_ERROR, "Closing room failed: %s\n",
                GNUNET_h2s (&(msg->key)));
 
  GNUNET_SERVICE_client_continue (msg_client->client);
}

References GNUNET_MESSENGER_Client::client, close_srv_handle_room(), env, GNUNET_ERROR_TYPE_DEBUG, GNUNET_ERROR_TYPE_ERROR, GNUNET_h2s(), GNUNET_log, GNUNET_memcpy, GNUNET_MESSAGE_TYPE_MESSENGER_ROOM_CLOSE, GNUNET_MQ_msg, GNUNET_MQ_send(), GNUNET_SERVICE_client_continue(), GNUNET_YES, GNUNET_MESSENGER_Client::handle, GNUNET_MESSENGER_SrvHandle::mq, msg, and response.

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 250 of file gnunet-service-messenger.c.

{
  struct GNUNET_MESSENGER_Client *msg_client = cls;
 
  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Syncing room: %s\n", GNUNET_h2s (
                &(msg->key)));
 
  struct GNUNET_HashCode prev;
  sync_srv_handle_messages (msg_client->handle, &(msg->key), &(msg->previous),
                            &prev);
 
  struct GNUNET_MESSENGER_RoomMessage *response;
  struct GNUNET_MQ_Envelope *env;
 
  env = GNUNET_MQ_msg (response, GNUNET_MESSAGE_TYPE_MESSENGER_ROOM_SYNC);
  GNUNET_memcpy (&(response->key), &(msg->key), sizeof(response->key));
  GNUNET_memcpy (&(response->previous), &prev, sizeof(response->previous));
  GNUNET_MQ_send (msg_client->handle->mq, env);
 
  GNUNET_SERVICE_client_continue (msg_client->client);
}

References GNUNET_MESSENGER_Client::client, env, GNUNET_ERROR_TYPE_DEBUG, GNUNET_h2s(), GNUNET_log, GNUNET_memcpy, GNUNET_MESSAGE_TYPE_MESSENGER_ROOM_SYNC, GNUNET_MQ_msg, GNUNET_MQ_send(), GNUNET_SERVICE_client_continue(), GNUNET_MESSENGER_Client::handle, GNUNET_MESSENGER_SrvHandle::mq, msg, GNUNET_MQ_Envelope::prev, response, and sync_srv_handle_messages().

Here is the call graph for this function:

check_send_message()

static enum GNUNET_GenericReturnValue check_send_message ( void *  cls, const struct GNUNET_MESSENGER_SendMessage *  msg  )

static

Definition at line 275 of file gnunet-service-messenger.c.

{
  const uint16_t full_length = ntohs (msg->header.size);
 
  if (full_length < sizeof(*msg))
    return GNUNET_NO;
 
  const uint16_t msg_length = full_length - sizeof(*msg);
  const char *msg_buffer = ((const char*) msg) + sizeof(*msg);
 
  struct GNUNET_MESSENGER_Message message;
 
  if (msg_length < get_message_kind_size (GNUNET_MESSENGER_KIND_UNKNOWN,
                                          GNUNET_YES))
    return GNUNET_NO;
 
  if (GNUNET_YES != decode_message (&message, msg_length, msg_buffer,
                                    GNUNET_YES,
                                    NULL))
    return GNUNET_NO;
 
  enum GNUNET_GenericReturnValue allowed;
  allowed = filter_message_sending (&message);
 
  cleanup_message (&message);
  return GNUNET_SYSERR != allowed? GNUNET_OK : GNUNET_NO;
}

References cleanup_message(), decode_message(), filter_message_sending(), get_message_kind_size(), GNUNET_MESSENGER_KIND_UNKNOWN, GNUNET_NO, GNUNET_OK, GNUNET_SYSERR, GNUNET_YES, msg, and GNUNET_MessageHeader::size.

Here is the call graph for this function:

handle_send_message()

static void handle_send_message ( void *  cls, const struct GNUNET_MESSENGER_SendMessage *  msg  )

static

Definition at line 306 of file gnunet-service-messenger.c.

{
  struct GNUNET_MESSENGER_Client *msg_client = cls;
 
  const struct GNUNET_HashCode *key = &(msg->key);
  const char *msg_buffer = ((const char*) msg) + sizeof(*msg);
  const uint16_t msg_length = ntohs (msg->header.size) - sizeof(*msg);
 
  struct GNUNET_MESSENGER_Message message;
  decode_message (&message, msg_length, msg_buffer, GNUNET_YES, NULL);
 
  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Sending message: %s to %s (by %s)\n",
              GNUNET_MESSENGER_name_of_kind (message.header.kind),
              GNUNET_h2s (key),
              GNUNET_sh2s (&(message.header.sender_id)));
 
  if (GNUNET_YES != send_srv_handle_message (msg_client->handle, key, &message))
    GNUNET_log (GNUNET_ERROR_TYPE_ERROR, "Sending message failed: %s to %s\n",
                GNUNET_MESSENGER_name_of_kind (message.header.kind),
                GNUNET_h2s (key));
 
  cleanup_message (&message);
 
  GNUNET_SERVICE_client_continue (msg_client->client);
}

References cleanup_message(), GNUNET_MESSENGER_Client::client, decode_message(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_ERROR_TYPE_ERROR, GNUNET_h2s(), GNUNET_log, GNUNET_MESSENGER_name_of_kind(), GNUNET_SERVICE_client_continue(), GNUNET_sh2s(), GNUNET_YES, GNUNET_MESSENGER_Client::handle, GNUNET_MESSENGER_Message::header, key, GNUNET_MESSENGER_MessageHeader::kind, msg, send_srv_handle_message(), GNUNET_MESSENGER_MessageHeader::sender_id, and GNUNET_MessageHeader::size.

Here is the call graph for this function:

callback_found_message()

static void callback_found_message ( void *  cls, struct GNUNET_MESSENGER_SrvRoom *  room, const struct GNUNET_MESSENGER_Message *  message, const struct GNUNET_HashCode *  hash  )

static

Definition at line 335 of file gnunet-service-messenger.c.

{
  struct GNUNET_MESSENGER_Client *msg_client = cls;
 
  if (! message)
  {
    struct GNUNET_MESSENGER_GetMessage *response;
    struct GNUNET_MQ_Envelope *env;
 
    env = GNUNET_MQ_msg (response,
                         GNUNET_MESSAGE_TYPE_MESSENGER_ROOM_GET_MESSAGE);
    GNUNET_memcpy (&(response->key), &(room->key), sizeof(room->key));
    GNUNET_memcpy (&(response->hash), hash, sizeof(*hash));
    GNUNET_MQ_send (msg_client->handle->mq, env);
    return;
  }
 
  struct GNUNET_MESSENGER_SenderSession session;
 
  if (GNUNET_YES == is_peer_message (message))
  {
    struct GNUNET_MESSENGER_PeerStore *store = get_srv_room_peer_store (room);
 
    session.peer = get_store_peer_of (store, message, hash);
 
    if (! session.peer)
    {
      GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                  "Peer session from sender of message (%s) unknown!\n",
                  GNUNET_h2s (hash));
      return;
    }
  }
  else
  {
    struct GNUNET_MESSENGER_MemberStore *store = get_srv_room_member_store (
      room);
    struct GNUNET_MESSENGER_Member *member = get_store_member_of (store,
                                                                  message);
 
    if (! member)
    {
      GNUNET_log (GNUNET_ERROR_TYPE_ERROR, "Sender of message (%s) unknown!\n",
                  GNUNET_h2s (hash));
      return;
    }
 
    session.member = get_member_session_of (member, message, hash);
 
    if (! session.member)
    {
      GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                  "Member session from sender of message (%s) unknown!\n",
                  GNUNET_h2s (hash));
      return;
    }
  }
 
  notify_srv_handle_message (msg_client->handle, room, &session, message,
                             hash, GNUNET_NO);
}

References env, get_member_session_of(), get_srv_room_member_store(), get_srv_room_peer_store(), get_store_member_of(), get_store_peer_of(), GNUNET_ERROR_TYPE_ERROR, GNUNET_h2s(), GNUNET_log, GNUNET_memcpy, GNUNET_MESSAGE_TYPE_MESSENGER_ROOM_GET_MESSAGE, GNUNET_MQ_msg, GNUNET_MQ_send(), GNUNET_NO, GNUNET_YES, GNUNET_MESSENGER_Client::handle, is_peer_message(), GNUNET_MESSENGER_SrvRoom::key, GNUNET_MESSENGER_SenderSession::member, GNUNET_MESSENGER_SrvHandle::mq, notify_srv_handle_message(), GNUNET_MESSENGER_SenderSession::peer, response, GNUNET_MESSENGER_MemberStore::room, and GNUNET_MESSENGER_Member::store.

Referenced by handle_get_message().

Here is the call graph for this function:

Here is the caller graph for this function:

handle_get_message()

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

static

Definition at line 402 of file gnunet-service-messenger.c.

{
  struct GNUNET_MESSENGER_Client *msg_client = cls;
 
  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Requesting message from room: %s\n",
              GNUNET_h2s (&(msg->key)));
  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Requested message: %s\n",
              GNUNET_h2s (&(msg->hash)));
 
  struct GNUNET_MESSENGER_SrvRoom *room = get_service_room (messenger,
                                                            &(msg->key));
 
  if (! room)
  {
    GNUNET_log (GNUNET_ERROR_TYPE_ERROR, "Room not found: %s\n", GNUNET_h2s (
                  &(msg->key)));
    goto end_handling;
  }
 
  struct GNUNET_MESSENGER_MemberStore *member_store =
    get_srv_room_member_store (room);
 
  const struct GNUNET_ShortHashCode *member_id;
  member_id = get_srv_handle_member_id (msg_client->handle,
                                        &(msg->key));
 
  struct GNUNET_MESSENGER_Member *member = get_store_member (member_store,
                                                             member_id);
 
  if (! member)
  {
    GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                "Member not valid to request a message! (%s)\n",
                GNUNET_sh2s (member_id));
    goto end_handling;
  }
 
  const struct GNUNET_CRYPTO_PublicKey *pubkey = get_srv_handle_key (
    msg_client->handle);
 
  if (! pubkey)
  {
    GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                "Handle needs to have a public key to request a message! (%s)\n",
                GNUNET_sh2s (member_id));
    goto end_handling;
  }
 
  struct GNUNET_MESSENGER_MemberSession *session = get_member_session (member,
                                                                       pubkey);
 
  if (! session)
  {
    GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                "Session not valid to request a message! (%s)\n",
                GNUNET_sh2s (member_id));
    goto end_handling;
  }
 
  request_srv_room_message (room, &(msg->hash), session, callback_found_message,
                            msg_client);
 
end_handling:
  GNUNET_SERVICE_client_continue (msg_client->client);
}

References callback_found_message(), GNUNET_MESSENGER_Client::client, get_member_session(), get_service_room(), get_srv_handle_key(), get_srv_handle_member_id(), get_srv_room_member_store(), get_store_member(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_ERROR_TYPE_ERROR, GNUNET_h2s(), GNUNET_log, GNUNET_SERVICE_client_continue(), GNUNET_sh2s(), GNUNET_MESSENGER_Client::handle, GNUNET_MESSENGER_MemberSession::member, messenger, msg, pubkey, request_srv_room_message(), and GNUNET_MESSENGER_MemberStore::room.

Here is the call graph for this function:

callback_client_connect()

static void * callback_client_connect ( void *  cls, struct GNUNET_SERVICE_Client *  client, struct GNUNET_MQ_Handle *  mq  )

static

Definition at line 471 of file gnunet-service-messenger.c.

{
  struct GNUNET_MESSENGER_Client *msg_client = GNUNET_new (struct
                                                           GNUNET_MESSENGER_Client);
 
  msg_client->client = client;
  msg_client->handle = add_service_handle (messenger, mq);
 
  return msg_client;
}

References add_service_handle(), GNUNET_MESSENGER_Client::client, GNUNET_new, GNUNET_MESSENGER_Client::handle, messenger, and mq.

Here is the call graph for this function:

callback_client_disconnect()

static void callback_client_disconnect ( void *  cls, struct GNUNET_SERVICE_Client *  client, void *  internal_cls  )

static

Definition at line 486 of file gnunet-service-messenger.c.

{
  struct GNUNET_MESSENGER_Client *msg_client = internal_cls;
 
  remove_service_handle (messenger, msg_client->handle);
 
  GNUNET_free (msg_client);
}

References GNUNET_free, GNUNET_MESSENGER_Client::handle, messenger, and remove_service_handle().

Here is the call graph for this function:

run()

static void run ( void *  cls, const struct GNUNET_CONFIGURATION_Handle *  config, struct GNUNET_SERVICE_Handle *  service  )

static

Setup MESSENGER internals.

Parameters

	[in/out]	cls closure
[in]	config	configuration to use
	[in/out]	service the initialized service

Definition at line 506 of file gnunet-service-messenger.c.

{
  messenger = create_service (config, service);
 
  if (! messenger)
    GNUNET_SCHEDULER_shutdown ();
}

References config, create_service(), GNUNET_SCHEDULER_shutdown(), messenger, and service.

Here is the call graph for this function:

GNUNET_SERVICE_MAIN()

GNUNET_SERVICE_MAIN	(	GNUNET_MESSENGER_SERVICE_NAME	,
		GNUNET_SERVICE_OPTION_NONE	,
		&	run,
		&	callback_client_connect,
		&	callback_client_disconnect,
		NULL	,
		GNUNET_MQ_hd_fixed_size(create, GNUNET_MESSAGE_TYPE_MESSENGER_CONNECTION_CREATE, struct GNUNET_MESSENGER_CreateMessage, NULL)	,
		GNUNET_MQ_hd_fixed_size(destroy, GNUNET_MESSAGE_TYPE_MESSENGER_CONNECTION_DESTROY, struct GNUNET_MESSENGER_DestroyMessage, NULL)	,
		GNUNET_MQ_hd_var_size(room_open, GNUNET_MESSAGE_TYPE_MESSENGER_ROOM_OPEN, struct GNUNET_MESSENGER_RoomMessage, NULL)	,
		GNUNET_MQ_hd_var_size(room_entry, GNUNET_MESSAGE_TYPE_MESSENGER_ROOM_ENTRY, struct GNUNET_MESSENGER_RoomMessage, NULL)	,
		GNUNET_MQ_hd_fixed_size(room_close, GNUNET_MESSAGE_TYPE_MESSENGER_ROOM_CLOSE, struct GNUNET_MESSENGER_RoomMessage, NULL)	,
		GNUNET_MQ_hd_var_size(send_message, GNUNET_MESSAGE_TYPE_MESSENGER_ROOM_SEND_MESSAGE, struct GNUNET_MESSENGER_SendMessage, NULL)	,
		GNUNET_MQ_hd_fixed_size(get_message, GNUNET_MESSAGE_TYPE_MESSENGER_ROOM_GET_MESSAGE, struct GNUNET_MESSENGER_GetMessage, NULL)	,
		GNUNET_MQ_hd_fixed_size(room_sync, GNUNET_MESSAGE_TYPE_MESSENGER_ROOM_SYNC, struct GNUNET_MESSENGER_RoomMessage, NULL)	,
		GNUNET_MQ_handler_end()
	)

Define "main" method using service macro.

Variable Documentation

messenger

struct GNUNET_MESSENGER_Service* messenger

Definition at line 40 of file gnunet-service-messenger.c.

Referenced by callback_client_connect(), callback_client_disconnect(), handle_get_message(), and run().