gnunet-service-messenger_message_recv.c File Reference

#include "gnunet-service-messenger_message_recv.h"
#include "gnunet-service-messenger_basement.h"
#include "gnunet-service-messenger_message_kind.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 enum GNUNET_GenericReturnValue	iterate_forward_members (void *cls, const struct GNUNET_CRYPTO_PublicKey *public_key, struct GNUNET_MESSENGER_MemberSession *session)
enum GNUNET_GenericReturnValue	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...
enum GNUNET_GenericReturnValue	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...
enum GNUNET_GenericReturnValue	recv_message_miss (struct GNUNET_MESSENGER_SrvRoom *room, struct GNUNET_MESSENGER_SrvTunnel *tunnel, const struct GNUNET_MESSENGER_Message *message, const struct GNUNET_HashCode *hash)
	Handles a received miss message to react to activity in the basement of a room. More...
static void	callback_found_message (void *cls, struct GNUNET_MESSENGER_SrvRoom *room, const struct GNUNET_MESSENGER_Message *message, const struct GNUNET_HashCode *hash)
enum GNUNET_GenericReturnValue	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...

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 33 of file gnunet-service-messenger_message_recv.c.

{
  struct GNUNET_MESSENGER_MessageStore *message_store;
  struct GNUNET_MESSENGER_ListMessage *element;
 
  GNUNET_assert ((room) && (tunnel) && (session) && (map));
 
  if (session->prev)
    forward_about_members (room, tunnel, session->prev, map);
 
  message_store = get_srv_room_message_store (room);
 
  for (element = session->messages.head; element; element = element->next)
  {
    const struct GNUNET_MESSENGER_Message *message;
 
    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");
 
    message = get_store_message (message_store, &(element->hash));
 
    if (! message)
      continue;
 
    forward_tunnel_message (tunnel, message, &(element->hash));
  }
}

References forward_about_members(), forward_tunnel_message(), get_srv_room_message_store(), get_store_message(), GNUNET_assert, 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 forward_about_members(), and iterate_forward_members().

Here is the call graph for this function:

Here is the caller graph for this function:

iterate_forward_members()

static enum GNUNET_GenericReturnValue iterate_forward_members ( void *  cls, const struct GNUNET_CRYPTO_PublicKey *  public_key, struct GNUNET_MESSENGER_MemberSession *  session  )

static

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

{
  struct GNUNET_MESSENGER_SrvTunnel *tunnel;
 
  GNUNET_assert ((cls) && (session));
  
  tunnel = cls;
 
  if (GNUNET_YES == is_member_session_completed (session))
    return GNUNET_YES;
 
  {
    struct GNUNET_CONTAINER_MultiHashMap *map;
    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_assert, 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()

enum GNUNET_GenericReturnValue 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 101 of file gnunet-service-messenger_message_recv.c.

{
  uint32_t version;
  struct GNUNET_PeerIdentity peer;
  
  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)
    send_tunnel_message (tunnel, room->host, create_message_info (
                           room->service));
  
  get_tunnel_peer_identity (tunnel, &peer);
 
  if (GNUNET_YES != contains_list_tunnels (&(room->basement), &peer))
  {
    struct GNUNET_MESSENGER_MessageStore *message_store;
    struct GNUNET_MESSENGER_MemberStore *member_store;
    struct GNUNET_MESSENGER_ListTunnel *element;
    
    message_store = get_srv_room_message_store (room);
    member_store = get_srv_room_member_store (room);
    
    for (element = room->basement.head; element; element = element->next)
    {
      const struct GNUNET_MESSENGER_Message *msg;
 
      if (! element->hash)
        continue;
 
      msg = get_store_message (message_store, element->hash);
 
      if (! msg)
        continue;
 
      forward_tunnel_message (tunnel, msg, element->hash);
    }
 
    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(), forward_tunnel_message(), get_srv_room_member_store(), get_srv_room_message_store(), get_store_message(), get_tunnel_messenger_version(), get_tunnel_peer_identity(), GNUNET_NO, GNUNET_OK, GNUNET_YES, GNUNET_MESSENGER_ListTunnel::hash, GNUNET_MESSENGER_ListTunnels::head, GNUNET_MESSENGER_SrvRoom::host, GNUNET_MESSENGER_MessageBody::info, iterate_forward_members(), iterate_store_members(), msg, GNUNET_MESSENGER_ListTunnel::next, send_tunnel_message(), GNUNET_MESSENGER_SrvRoom::service, 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()

enum GNUNET_GenericReturnValue 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 161 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));
  }
 
  update_to_list_tunnels (&(room->basement), &(message->body.peer.peer), hash);
  return GNUNET_YES;
}

References GNUNET_MESSENGER_SrvRoom::basement, 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, GNUNET_MESSENGER_SrvTunnel::peer_message, and update_to_list_tunnels().

Referenced by handle_tunnel_message().

Here is the call graph for this function:

Here is the caller graph for this function:

recv_message_miss()

enum GNUNET_GenericReturnValue recv_message_miss	(	struct GNUNET_MESSENGER_SrvRoom *	room,
		struct GNUNET_MESSENGER_SrvTunnel *	tunnel,
		const struct GNUNET_MESSENGER_Message *	message,
		const struct GNUNET_HashCode *	hash
	)

Handles a received miss message to react to activity in the basement of a room.

(the miss message can cause automatic opening of the room)

Parameters

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

Returns

GNUNET_YES to forward the message

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

{
  struct GNUNET_MESSENGER_Service *service;
  
  service = room->service;
 
  if ((GNUNET_YES == service->auto_routing) &&
      (service->min_routers > count_of_tunnels (&(room->basement))))
    open_srv_room (room, NULL);
 
  return GNUNET_YES;
}

References GNUNET_MESSENGER_SrvRoom::basement, count_of_tunnels(), GNUNET_YES, open_srv_room(), service, and GNUNET_MESSENGER_SrvRoom::service.

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 202 of file gnunet-service-messenger_message_recv.c.

{
  struct GNUNET_MESSENGER_SrvTunnel *tunnel;
 
  GNUNET_assert ((cls) && (room) && (hash));
  
  tunnel = cls;
 
  if (! message)
  {
    struct GNUNET_MESSENGER_OperationStore *operation_store;
    
    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_assert, GNUNET_MESSENGER_OP_REQUEST, GNUNET_MESSENGER_REQUEST_DELAY, GNUNET_MESSENGER_OperationStore::room, GNUNET_MESSENGER_SrvTunnel::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()

enum GNUNET_GenericReturnValue 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 236 of file gnunet-service-messenger_message_recv.c.

{
  struct GNUNET_MESSENGER_MemberStore *member_store;
  struct GNUNET_MESSENGER_Member *member;
  struct GNUNET_MESSENGER_MemberSession *session;
  
  member_store = get_srv_room_member_store (room);
  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;
 
  session = get_member_session_of (member, message, hash);
 
  if ((! session) || (GNUNET_YES != check_member_session_history (session,
                                                                  &(message->
                                                                    body.request
                                                                    .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, and request_srv_room_message().

Referenced by handle_tunnel_message().

Here is the call graph for this function:

Here is the caller graph for this function: