gnunet-service-messenger_message_recv.c File Reference

GNUnet MESSENGER service. More...

#include "platform.h"
#include "gnunet-service-messenger_message_recv.h"
#include "gnunet-service-messenger_operation.h"

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

Go to the source code of this file.

Functions
static void	forward_about_members (struct GNUNET_MESSENGER_SrvRoom *room, struct GNUNET_MESSENGER_SrvTunnel *tunnel, struct GNUNET_MESSENGER_MemberSession *session, struct GNUNET_CONTAINER_MultiHashMap *map)
static int	iterate_forward_members (void *cls, const struct GNUNET_IDENTITY_PublicKey *public_key, struct GNUNET_MESSENGER_MemberSession *session)
int	recv_message_info (struct GNUNET_MESSENGER_SrvRoom *room, struct GNUNET_MESSENGER_SrvTunnel *tunnel, const struct GNUNET_MESSENGER_Message *message, const struct GNUNET_HashCode *hash)
	Handles a received info message to change the current member id to the one generated by the host connected to. More...
int	recv_message_peer (struct GNUNET_MESSENGER_SrvRoom *room, struct GNUNET_MESSENGER_SrvTunnel *tunnel, const struct GNUNET_MESSENGER_Message *message, const struct GNUNET_HashCode *hash)
	Handles a received peer message to link it to its origin tunnel if the peer identity matches. More...
static void	callback_found_message (void *cls, struct GNUNET_MESSENGER_SrvRoom *room, const struct GNUNET_MESSENGER_Message *message, const struct GNUNET_HashCode *hash)
int	recv_message_request (struct GNUNET_MESSENGER_SrvRoom *room, struct GNUNET_MESSENGER_SrvTunnel *tunnel, const struct GNUNET_MESSENGER_Message *message, const struct GNUNET_HashCode *hash)
	Handles a received request message by checking for the requested message and forwarding it back if the message was found. More...

Detailed Description

GNUnet MESSENGER service.

Author

Tobias Frisch

Definition in file gnunet-service-messenger_message_recv.c.

Function Documentation

forward_about_members()

static void forward_about_members ( struct GNUNET_MESSENGER_SrvRoom *  room, struct GNUNET_MESSENGER_SrvTunnel *  tunnel, struct GNUNET_MESSENGER_MemberSession *  session, struct GNUNET_CONTAINER_MultiHashMap *  map  )

static

Definition at line 32 of file gnunet-service-messenger_message_recv.c.

{
  if (session->prev)
    forward_about_members (room, tunnel, session->prev, map);
 
  struct GNUNET_MESSENGER_MessageStore *message_store = get_srv_room_message_store(room);
  struct GNUNET_MESSENGER_ListMessage *element;
 
  for (element = session->messages.head; element; element = element->next)
  {
    if (GNUNET_YES == GNUNET_CONTAINER_multihashmap_contains(map, &(element->hash)))
      continue;
 
    if (GNUNET_OK != GNUNET_CONTAINER_multihashmap_put(map, &(element->hash), NULL,
                                                       GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_FAST))
      GNUNET_log(GNUNET_ERROR_TYPE_WARNING, "Forwarding of session message could be duplicated!\n");
 
    const struct GNUNET_MESSENGER_Message *message = get_store_message(message_store, &(element->hash));
 
    if (message)
      forward_tunnel_message(tunnel, message, &(element->hash));
  }
}

References forward_tunnel_message(), get_srv_room_message_store(), get_store_message(), GNUNET_CONTAINER_multihashmap_contains(), GNUNET_CONTAINER_multihashmap_put(), GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_FAST, GNUNET_ERROR_TYPE_WARNING, GNUNET_log, GNUNET_OK, GNUNET_YES, GNUNET_MESSENGER_ListMessage::hash, GNUNET_MESSENGER_ListMessages::head, map, GNUNET_MESSENGER_MemberSession::messages, GNUNET_MESSENGER_ListMessage::next, and GNUNET_MESSENGER_MemberSession::prev.

Referenced by iterate_forward_members().

Here is the call graph for this function:

Here is the caller graph for this function:

iterate_forward_members()

static int iterate_forward_members ( void *  cls, const struct GNUNET_IDENTITY_PublicKey *  public_key, struct GNUNET_MESSENGER_MemberSession *  session  )

static

Definition at line 60 of file gnunet-service-messenger_message_recv.c.

{
  struct GNUNET_MESSENGER_SrvTunnel *tunnel = cls;
 
  if (GNUNET_YES == is_member_session_completed(session))
    return GNUNET_YES;
 
  struct GNUNET_CONTAINER_MultiHashMap *map = GNUNET_CONTAINER_multihashmap_create(4, GNUNET_NO);
 
  forward_about_members (tunnel->room, tunnel, session, map);
 
  GNUNET_CONTAINER_multihashmap_destroy(map);
  return GNUNET_YES;
}

References forward_about_members(), GNUNET_CONTAINER_multihashmap_create(), GNUNET_CONTAINER_multihashmap_destroy(), GNUNET_NO, GNUNET_YES, is_member_session_completed(), map, and GNUNET_MESSENGER_SrvTunnel::room.

Referenced by recv_message_info().

Here is the call graph for this function:

Here is the caller graph for this function:

recv_message_info()

int recv_message_info	(	struct GNUNET_MESSENGER_SrvRoom *	room,
		struct GNUNET_MESSENGER_SrvTunnel *	tunnel,
		const struct GNUNET_MESSENGER_Message *	message,
		const struct GNUNET_HashCode *	hash
	)

Handles a received info message to change the current member id to the one generated by the host connected to.

(all current tunnels will be informed about the id change)

Parameters

[in,out]	room	Room of the message
[in,out]	tunnel	Receiving connection
[in]	message	INFO-Message
[in]	hash	Hash of the message

Returns

GNUNET_NO to not forward the message

Definition at line 78 of file gnunet-service-messenger_message_recv.c.

{
  const uint32_t version = get_tunnel_messenger_version(tunnel);
 
  if (GNUNET_OK != update_tunnel_messenger_version(tunnel, message->body.info.messenger_version))
  {
    disconnect_tunnel(tunnel);
    return GNUNET_NO;
  }
 
  if (version == get_tunnel_messenger_version(tunnel))
    return GNUNET_NO;
 
  if (room->host)
  {
    const struct GNUNET_MESSENGER_Ego *ego = get_srv_handle_ego(room->host);
 
    send_tunnel_message (tunnel, room->host, create_message_info(ego));
  }
 
  struct GNUNET_PeerIdentity peer;
  get_tunnel_peer_identity(tunnel, &peer);
 
  if (GNUNET_YES != contains_list_tunnels(&(room->basement), &peer))
  {
    struct GNUNET_MESSENGER_MemberStore *member_store = get_srv_room_member_store(room);
 
    iterate_store_members(member_store, iterate_forward_members, tunnel);
  }
 
  check_srv_room_peer_status(room, tunnel);
 
  return GNUNET_NO;
}

References GNUNET_MESSENGER_SrvRoom::basement, GNUNET_MESSENGER_Message::body, check_srv_room_peer_status(), contains_list_tunnels(), create_message_info(), disconnect_tunnel(), get_srv_handle_ego(), get_srv_room_member_store(), get_tunnel_messenger_version(), get_tunnel_peer_identity(), GNUNET_NO, GNUNET_OK, GNUNET_YES, GNUNET_MESSENGER_SrvRoom::host, GNUNET_MESSENGER_MessageBody::info, iterate_forward_members(), iterate_store_members(), GNUNET_MESSENGER_MessageInfo::messenger_version, peer, GNUNET_MESSENGER_MemberStore::room, send_tunnel_message(), and update_tunnel_messenger_version().

Referenced by handle_tunnel_message().

Here is the call graph for this function:

Here is the caller graph for this function:

recv_message_peer()

int recv_message_peer	(	struct GNUNET_MESSENGER_SrvRoom *	room,
		struct GNUNET_MESSENGER_SrvTunnel *	tunnel,
		const struct GNUNET_MESSENGER_Message *	message,
		const struct GNUNET_HashCode *	hash
	)

Handles a received peer message to link it to its origin tunnel if the peer identity matches.

(the peer message and the member id can potentially be linked to the tunnel)

Parameters

[in,out]	room	Room of the message
[in,out]	tunnel	Receiving connection
[in]	message	PEER-Message
[in]	hash	Hash of the message

Returns

GNUNET_YES to forward the message

Definition at line 117 of file gnunet-service-messenger_message_recv.c.

{
  struct GNUNET_PeerIdentity peer;
  GNUNET_PEER_resolve (tunnel->peer, &peer);
 
  if (0 == GNUNET_memcmp(&peer, &(message->body.peer.peer)))
  {
    if (!tunnel->peer_message)
      tunnel->peer_message = GNUNET_new(struct GNUNET_HashCode);
 
    GNUNET_memcpy(tunnel->peer_message, &hash, sizeof(hash));
  }
 
  return GNUNET_YES;
}

References GNUNET_MESSENGER_Message::body, GNUNET_memcmp, GNUNET_memcpy, GNUNET_new, GNUNET_PEER_resolve(), GNUNET_YES, GNUNET_MESSENGER_MessagePeer::peer, GNUNET_MESSENGER_MessageBody::peer, GNUNET_MESSENGER_SrvTunnel::peer, peer, and GNUNET_MESSENGER_SrvTunnel::peer_message.

Referenced by handle_tunnel_message().

Here is the call graph for this function:

Here is the caller 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 137 of file gnunet-service-messenger_message_recv.c.

{
  struct GNUNET_MESSENGER_SrvTunnel *tunnel = tunnel;
 
  if (!message)
  {
    struct GNUNET_MESSENGER_OperationStore *operation_store = get_srv_room_operation_store(room);
 
    use_store_operation(
        operation_store,
        hash,
        GNUNET_MESSENGER_OP_REQUEST,
        GNUNET_MESSENGER_REQUEST_DELAY
    );
  }
  else
    forward_tunnel_message (tunnel, message, hash);
}

References forward_tunnel_message(), get_srv_room_operation_store(), GNUNET_MESSENGER_OP_REQUEST, GNUNET_MESSENGER_REQUEST_DELAY, GNUNET_MESSENGER_OperationStore::room, and use_store_operation().

Referenced by recv_message_request().

Here is the call graph for this function:

Here is the caller graph for this function:

recv_message_request()

int recv_message_request	(	struct GNUNET_MESSENGER_SrvRoom *	room,
		struct GNUNET_MESSENGER_SrvTunnel *	tunnel,
		const struct GNUNET_MESSENGER_Message *	message,
		const struct GNUNET_HashCode *	hash
	)

Handles a received request message by checking for the requested message and forwarding it back if the message was found.

(this can also cause this peer to send a new request instead of only forwarding the received one)

Parameters

[in,out]	room	Room of the message
[in,out]	tunnel	Receiving connection
[in]	message	REQUEST-Message
[in]	hash	Hash of the message

Returns

GNUNET_YES or GNUNET_NO depending on required forwarding

Definition at line 164 of file gnunet-service-messenger_message_recv.c.

{
  struct GNUNET_MESSENGER_MemberStore *member_store = get_srv_room_member_store(room);
  struct GNUNET_MESSENGER_Member *member = get_store_member_of(member_store, message);
 
  GNUNET_log(GNUNET_ERROR_TYPE_DEBUG, "Request for message (%s)\n", GNUNET_h2s (hash));
 
  if (!member)
    return GNUNET_NO;
 
  struct GNUNET_MESSENGER_MemberSession *session = get_member_session_of(member, message, hash);
 
  if ((!session) || (GNUNET_YES != check_member_session_history(session, hash, GNUNET_NO)))
    return GNUNET_NO;
 
  if (GNUNET_NO == request_srv_room_message(room, &(message->body.request.hash), session, callback_found_message, tunnel))
    return GNUNET_YES;
 
  return GNUNET_NO;
}

References GNUNET_MESSENGER_Message::body, callback_found_message(), check_member_session_history(), get_member_session_of(), get_srv_room_member_store(), get_store_member_of(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_h2s(), GNUNET_log, GNUNET_NO, GNUNET_YES, GNUNET_MESSENGER_MessageRequest::hash, GNUNET_MESSENGER_MemberSession::member, GNUNET_MESSENGER_MessageBody::request, request_srv_room_message(), and GNUNET_MESSENGER_MemberStore::room.

Referenced by handle_tunnel_message().

Here is the call graph for this function:

Here is the caller graph for this function: