gnunet-service-messenger_message_recv.h File Reference

GNUnet MESSENGER service. More...

#include "platform.h"
#include "gnunet_util_lib.h"
#include "gnunet-service-messenger_message_kind.h"
#include "gnunet-service-messenger_member_session.h"
#include "gnunet-service-messenger_tunnel.h"
#include "messenger_api_message.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
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...
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.h.

Function Documentation

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:

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: