gnunet-service-messenger_message_recv.h File Reference

#include "gnunet-service-messenger_tunnel.h"

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

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Functions
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...
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

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:

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: