gnunet-service-messenger_message_handle.c File Reference

#include "gnunet-service-messenger_message_handle.h"
#include "gnunet-service-messenger_room.h"

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

Go to the source code of this file.

Functions
static void	handle_member_session_switch (struct GNUNET_MESSENGER_MemberSession *session, const struct GNUNET_MESSENGER_Message *message, const struct GNUNET_HashCode *hash)
void	handle_message_join (struct GNUNET_MESSENGER_SrvRoom *room, struct GNUNET_MESSENGER_SenderSession *session, const struct GNUNET_MESSENGER_Message *message, const struct GNUNET_HashCode *hash)
	Handles a received or sent join message to make changes of current member information. More...
void	handle_message_leave (struct GNUNET_MESSENGER_SrvRoom *room, struct GNUNET_MESSENGER_SenderSession *session, const struct GNUNET_MESSENGER_Message *message, const struct GNUNET_HashCode *hash)
	Handles a received or sent leave message to make changes of current member information. More...
void	handle_message_key (struct GNUNET_MESSENGER_SrvRoom *room, struct GNUNET_MESSENGER_SenderSession *session, const struct GNUNET_MESSENGER_Message *message, const struct GNUNET_HashCode *hash)
	Handles a received or sent key message to change the key of a member and rearrange the contacts accordingly. More...
void	handle_message_peer (struct GNUNET_MESSENGER_SrvRoom *room, struct GNUNET_MESSENGER_SenderSession *session, const struct GNUNET_MESSENGER_Message *message, const struct GNUNET_HashCode *hash)
	Handles a received or sent peer message to make changes of the basement in the room. More...
void	handle_message_id (struct GNUNET_MESSENGER_SrvRoom *room, struct GNUNET_MESSENGER_SenderSession *session, const struct GNUNET_MESSENGER_Message *message, const struct GNUNET_HashCode *hash)
	Handles a received or sent id message to change a members id. More...
void	handle_message_miss (struct GNUNET_MESSENGER_SrvRoom *room, struct GNUNET_MESSENGER_SenderSession *session, const struct GNUNET_MESSENGER_Message *message, const struct GNUNET_HashCode *hash)
	Handles a received or sent miss message to drop a peer from the basement in the room. More...
void	handle_message_delete (struct GNUNET_MESSENGER_SrvRoom *room, struct GNUNET_MESSENGER_SenderSession *session, const struct GNUNET_MESSENGER_Message *message, const struct GNUNET_HashCode *hash)
	Handles a received or sent delete message to delete a specific message from the store. More...
void	handle_message_connection (struct GNUNET_MESSENGER_SrvRoom *room, struct GNUNET_MESSENGER_SenderSession *session, const struct GNUNET_MESSENGER_Message *message, const struct GNUNET_HashCode *hash)
	Handles a received or sent connection message to update connection information about a peer. More...
void	handle_message_subscribe (struct GNUNET_MESSENGER_SrvRoom *room, struct GNUNET_MESSENGER_SenderSession *session, const struct GNUNET_MESSENGER_Message *message, const struct GNUNET_HashCode *hash)
	Handles a received or sent subscribe message to subscribe a member to a discourse. More...

Function Documentation

handle_member_session_switch()

static void handle_member_session_switch ( struct GNUNET_MESSENGER_MemberSession *  session, const struct GNUNET_MESSENGER_Message *  message, const struct GNUNET_HashCode *  hash  )

static

Definition at line 31 of file gnunet-service-messenger_message_handle.c.

{
  struct GNUNET_MESSENGER_MemberSession *next;
 
  GNUNET_assert ((session) && (message) && (hash));
  
  next = switch_member_session (session, message, hash);
 
  if (next != session)
    add_member_session (next->member, next);
}

References add_member_session(), GNUNET_assert, GNUNET_MESSENGER_MemberSession::member, GNUNET_MESSENGER_MemberSession::next, and switch_member_session().

Referenced by handle_message_id(), and handle_message_key().

Here is the call graph for this function:

Here is the caller graph for this function:

handle_message_join()

void handle_message_join	(	struct GNUNET_MESSENGER_SrvRoom *	room,
		struct GNUNET_MESSENGER_SenderSession *	session,
		const struct GNUNET_MESSENGER_Message *	message,
		const struct GNUNET_HashCode *	hash
	)

Handles a received or sent join message to make changes of current member information.

(add matching member and clear member info)

Parameters

[in,out]	room	Room of the message
[in,out]	session	Sender session
[in]	message	JOIN-Message
[in]	hash	Hash of the message

Definition at line 47 of file gnunet-service-messenger_message_handle.c.

{
  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Member (%s) joins room (%s).\n",
              GNUNET_sh2s (&(message->header.sender_id)), GNUNET_h2s (
                get_srv_room_key (room)));
 
  if (GNUNET_OK != reset_member_session (session->member, hash))
    GNUNET_log (GNUNET_ERROR_TYPE_ERROR, "Resetting member session failed!\n");
 
  solve_srv_room_member_collisions (
    room,
    &(message->body.join.key),
    &(message->header.sender_id),
    GNUNET_TIME_absolute_ntoh (message->header.timestamp)
    );
}

References GNUNET_MESSENGER_Message::body, get_srv_room_key(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_ERROR_TYPE_ERROR, GNUNET_h2s(), GNUNET_log, GNUNET_OK, GNUNET_sh2s(), GNUNET_TIME_absolute_ntoh(), GNUNET_MESSENGER_Message::header, GNUNET_MESSENGER_MessageBody::join, GNUNET_MESSENGER_MessageJoin::key, GNUNET_MESSENGER_SenderSession::member, reset_member_session(), GNUNET_MESSENGER_MessageHeader::sender_id, solve_srv_room_member_collisions(), and GNUNET_MESSENGER_MessageHeader::timestamp.

Referenced by callback_room_handle_message().

Here is the call graph for this function:

Here is the caller graph for this function:

handle_message_leave()

void handle_message_leave	(	struct GNUNET_MESSENGER_SrvRoom *	room,
		struct GNUNET_MESSENGER_SenderSession *	session,
		const struct GNUNET_MESSENGER_Message *	message,
		const struct GNUNET_HashCode *	hash
	)

Handles a received or sent leave message to make changes of current member information.

(remove matching member and clear member info)

Parameters

[in,out]	room	Room of the message
[in,out]	session	Sender session
[in]	message	LEAVE-Message
[in]	hash	Hash of the message

Definition at line 69 of file gnunet-service-messenger_message_handle.c.

{
  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Member (%s) leaves room (%s).\n",
              GNUNET_sh2s (&(message->header.sender_id)), GNUNET_h2s (
                get_srv_room_key (room)));
 
  close_member_session (session->member);
}

References close_member_session(), get_srv_room_key(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_h2s(), GNUNET_log, GNUNET_sh2s(), GNUNET_MESSENGER_Message::header, GNUNET_MESSENGER_SenderSession::member, and GNUNET_MESSENGER_MessageHeader::sender_id.

Referenced by callback_room_handle_message().

Here is the call graph for this function:

Here is the caller graph for this function:

handle_message_key()

void handle_message_key	(	struct GNUNET_MESSENGER_SrvRoom *	room,
		struct GNUNET_MESSENGER_SenderSession *	session,
		const struct GNUNET_MESSENGER_Message *	message,
		const struct GNUNET_HashCode *	hash
	)

Handles a received or sent key message to change the key of a member and rearrange the contacts accordingly.

(move the member in the contacts and change its key)

Parameters

[in,out]	room	Room of the message
[in,out]	session	Sender session
[in]	message	KEY-Message
[in]	hash	Hash of the message

Definition at line 83 of file gnunet-service-messenger_message_handle.c.

{
  handle_member_session_switch (session->member, message, hash);
}

References handle_member_session_switch(), and GNUNET_MESSENGER_SenderSession::member.

Referenced by callback_room_handle_message().

Here is the call graph for this function:

Here is the caller graph for this function:

handle_message_peer()

void handle_message_peer	(	struct GNUNET_MESSENGER_SrvRoom *	room,
		struct GNUNET_MESSENGER_SenderSession *	session,
		const struct GNUNET_MESSENGER_Message *	message,
		const struct GNUNET_HashCode *	hash
	)

Handles a received or sent peer message to make changes of the basement in the room.

(add a new peer to the basement and restructure connections based on updated list of peers)

Parameters

[in,out]	room	Room of the message
[in,out]	session	Sender session
[in]	message	PEER-Message
[in]	hash	Hash of the message

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

{
  struct GNUNET_MESSENGER_PeerStore *store;
  
  store = get_srv_room_peer_store (room);
 
  if (0 == GNUNET_memcmp (session->peer, &(message->body.peer.peer)))
    update_store_peer (store, &(message->body.peer.peer), GNUNET_YES);
 
  if (GNUNET_NO == contains_list_tunnels (&(room->basement),
                                          &(message->body.peer.peer)))
    add_to_list_tunnels (&(room->basement), &(message->body.peer.peer), hash);
 
  if (room->peer_message)
    rebuild_srv_room_basement_structure (room);
}

References add_to_list_tunnels(), GNUNET_MESSENGER_SrvRoom::basement, GNUNET_MESSENGER_Message::body, contains_list_tunnels(), get_srv_room_peer_store(), GNUNET_memcmp, GNUNET_NO, GNUNET_YES, GNUNET_MESSENGER_MessagePeer::peer, GNUNET_MESSENGER_MessageBody::peer, GNUNET_MESSENGER_SenderSession::peer, GNUNET_MESSENGER_SrvRoom::peer_message, rebuild_srv_room_basement_structure(), and update_store_peer().

Referenced by callback_room_handle_message().

Here is the call graph for this function:

Here is the caller graph for this function:

handle_message_id()

void handle_message_id	(	struct GNUNET_MESSENGER_SrvRoom *	room,
		struct GNUNET_MESSENGER_SenderSession *	session,
		const struct GNUNET_MESSENGER_Message *	message,
		const struct GNUNET_HashCode *	hash
	)

Handles a received or sent id message to change a members id.

(change id of matching member)

Parameters

[in,out]	room	Room of the message
[in,out]	session	Sender session
[in]	message	ID-Message
[in]	hash	Hash of the message

Definition at line 115 of file gnunet-service-messenger_message_handle.c.

{
  handle_member_session_switch (session->member, message, hash);
 
  solve_srv_room_member_collisions (
    room,
    get_member_session_public_key (session->member),
    &(message->body.id.id),
    GNUNET_TIME_absolute_ntoh (message->header.timestamp)
    );
}

References GNUNET_MESSENGER_Message::body, get_member_session_public_key(), GNUNET_TIME_absolute_ntoh(), handle_member_session_switch(), GNUNET_MESSENGER_Message::header, GNUNET_MESSENGER_MessageId::id, GNUNET_MESSENGER_MessageBody::id, GNUNET_MESSENGER_SenderSession::member, solve_srv_room_member_collisions(), and GNUNET_MESSENGER_MessageHeader::timestamp.

Referenced by callback_room_handle_message().

Here is the call graph for this function:

Here is the caller graph for this function:

handle_message_miss()

void handle_message_miss	(	struct GNUNET_MESSENGER_SrvRoom *	room,
		struct GNUNET_MESSENGER_SenderSession *	session,
		const struct GNUNET_MESSENGER_Message *	message,
		const struct GNUNET_HashCode *	hash
	)

Handles a received or sent miss message to drop a peer from the basement in the room.

(remove a peer from the basement and restructure connections based on updated list of peers)

Parameters

[in,out]	room	Room of the message
[in,out]	session	Sender session
[in]	message	MISS-Message
[in]	hash	Hash of the message

Definition at line 132 of file gnunet-service-messenger_message_handle.c.

{
  struct GNUNET_MESSENGER_PeerStore *store;
  struct GNUNET_MESSENGER_ListTunnel *element;
  
  store = get_srv_room_peer_store (room);
 
  if (0 == GNUNET_memcmp (session->peer, &(message->body.miss.peer)))
    update_store_peer (store, &(message->body.miss.peer), GNUNET_NO);
 
  element = find_list_tunnels (&(room->basement), 
                               &(message->body.miss.peer), NULL);
 
  if (! element)
    return;
 
  remove_from_list_tunnels (&(room->basement), element);
 
  if (room->peer_message)
    rebuild_srv_room_basement_structure (room);
}

References GNUNET_MESSENGER_SrvRoom::basement, GNUNET_MESSENGER_Message::body, find_list_tunnels(), get_srv_room_peer_store(), GNUNET_memcmp, GNUNET_NO, GNUNET_MESSENGER_MessageBody::miss, GNUNET_MESSENGER_MessageMiss::peer, GNUNET_MESSENGER_SenderSession::peer, GNUNET_MESSENGER_SrvRoom::peer_message, rebuild_srv_room_basement_structure(), remove_from_list_tunnels(), and update_store_peer().

Referenced by callback_room_handle_message().

Here is the call graph for this function:

Here is the caller graph for this function:

handle_message_delete()

void handle_message_delete	(	struct GNUNET_MESSENGER_SrvRoom *	room,
		struct GNUNET_MESSENGER_SenderSession *	session,
		const struct GNUNET_MESSENGER_Message *	message,
		const struct GNUNET_HashCode *	hash
	)

Handles a received or sent delete message to delete a specific message from the store.

(remove a message from the store of a room under a given delay)

Parameters

[in,out]	room	Room of the message
[in,out]	session	Sender session
[in]	message	DELETE-Message
[in]	hash	Hash of the message

Definition at line 159 of file gnunet-service-messenger_message_handle.c.

{
  struct GNUNET_TIME_Relative delay;
  struct GNUNET_TIME_Absolute action;
  
  delay = GNUNET_TIME_relative_ntoh (message->body.deletion.delay);
  action = GNUNET_TIME_absolute_ntoh (message->header.timestamp);
 
  action = GNUNET_TIME_absolute_add (action, delay);
  delay = GNUNET_TIME_absolute_get_difference (GNUNET_TIME_absolute_get (),
                                               action);
 
  delete_srv_room_message (room, session->member,
                           &(message->body.deletion.hash), delay);
}

References consensus-simulation::action, GNUNET_MESSENGER_Message::body, GNUNET_MESSENGER_MessageDelete::delay, delete_srv_room_message(), GNUNET_MESSENGER_MessageBody::deletion, GNUNET_TIME_absolute_add(), GNUNET_TIME_absolute_get(), GNUNET_TIME_absolute_get_difference(), GNUNET_TIME_absolute_ntoh(), GNUNET_TIME_relative_ntoh(), GNUNET_MESSENGER_MessageDelete::hash, GNUNET_MESSENGER_Message::header, GNUNET_MESSENGER_SenderSession::member, and GNUNET_MESSENGER_MessageHeader::timestamp.

Referenced by callback_room_handle_message().

Here is the call graph for this function:

Here is the caller graph for this function:

handle_message_connection()

void handle_message_connection	(	struct GNUNET_MESSENGER_SrvRoom *	room,
		struct GNUNET_MESSENGER_SenderSession *	session,
		const struct GNUNET_MESSENGER_Message *	message,
		const struct GNUNET_HashCode *	hash
	)

Handles a received or sent connection message to update connection information about a peer.

(update a peer in the basement)

Parameters

[in,out]	room	Room of the message
[in,out]	session	Sender session
[in]	message	DELETE-Message
[in]	hash	Hash of the message

Definition at line 180 of file gnunet-service-messenger_message_handle.c.

{
  struct GNUNET_MESSENGER_ListTunnel *element;
  
  element = find_list_tunnels (&(room->basement), session->peer, NULL);
 
  if (! element)
    return;
 
  memcpy (&(element->connection), &(message->body.connection),
          sizeof (struct GNUNET_MESSENGER_MessageConnection));
}

References GNUNET_MESSENGER_SrvRoom::basement, GNUNET_MESSENGER_Message::body, GNUNET_MESSENGER_MessageBody::connection, GNUNET_MESSENGER_ListTunnel::connection, find_list_tunnels(), and GNUNET_MESSENGER_SenderSession::peer.

Referenced by callback_room_handle_message().

Here is the call graph for this function:

Here is the caller graph for this function:

handle_message_subscribe()

void handle_message_subscribe	(	struct GNUNET_MESSENGER_SrvRoom *	room,
		struct GNUNET_MESSENGER_SenderSession *	session,
		const struct GNUNET_MESSENGER_Message *	message,
		const struct GNUNET_HashCode *	hash
	)

Handles a received or sent subscribe message to subscribe a member to a discourse.

(subscribe a member to a discourse)

Parameters

[in,out]	room	Room of the message
[in,out]	session	Sender session
[in]	message	SUBSCRIBE-Message
[in]	hash	Hash of the message

Definition at line 198 of file gnunet-service-messenger_message_handle.c.

{
  struct GNUNET_MESSENGER_Member *member;
  const struct GNUNET_ShortHashCode *discourse;
  struct GNUNET_MESSENGER_Subscription *subscription;
  
  member = session->member->member;
 
  discourse = &(message->body.subscribe.discourse);
  subscription = get_member_subscription (member, discourse);
 
  {
    struct GNUNET_TIME_Absolute timestamp;
    struct GNUNET_TIME_Relative duration;
 
    timestamp = GNUNET_TIME_absolute_ntoh (message->header.timestamp);
    duration = GNUNET_TIME_relative_ntoh (message->body.subscribe.time);
 
    if (subscription)
      update_subscription (subscription, 
                          timestamp,
                          duration);
    else
    {
      subscription =
        create_subscription (room, member, discourse, 
                            timestamp,
                            duration);
 
      if (! subscription)
        return;
 
      add_member_subscription (member, subscription);
    }
  }
 
  update_subscription_timing (subscription);
  cleanup_srv_room_discourse_messages (room, discourse);
}

References add_member_subscription(), GNUNET_MESSENGER_Message::body, cleanup_srv_room_discourse_messages(), create_subscription(), GNUNET_MESSENGER_MessageSubscribe::discourse, GNUNET_MESSENGER_Subscription::discourse, duration, get_member_subscription(), GNUNET_TIME_absolute_ntoh(), GNUNET_TIME_relative_ntoh(), GNUNET_MESSENGER_Message::header, GNUNET_MESSENGER_MemberSession::member, GNUNET_MESSENGER_SenderSession::member, GNUNET_MESSENGER_Subscription::member, GNUNET_MESSENGER_MessageBody::subscribe, GNUNET_MESSENGER_MessageSubscribe::time, GNUNET_MESSENGER_MessageHeader::timestamp, timestamp(), update_subscription(), and update_subscription_timing().

Referenced by callback_room_handle_message().

Here is the call graph for this function:

Here is the caller graph for this function: