#include "gnunet_cadet_service.h"
#include "gnunet_util_lib.h"
#include "gnunet-service-messenger_room.h"
#include "gnunet-service-messenger_message_state.h"

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

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

Data Structures
struct	GNUNET_MESSENGER_SrvTunnel

Functions
struct GNUNET_MESSENGER_SrvTunnel *	create_tunnel (struct GNUNET_MESSENGER_SrvRoom room, const struct GNUNET_PeerIdentity door)
	Creates and allocates a tunnel of a room to a specific peer identity (called door). More...

void	destroy_tunnel (struct GNUNET_MESSENGER_SrvTunnel *tunnel)
	Destroys a tunnel and frees its memory fully. More...

void	bind_tunnel (struct GNUNET_MESSENGER_SrvTunnel tunnel, struct GNUNET_CADET_Channel channel)
	Binds a CADET channel to a tunnel and replaces its channel the tunnel is currently bound to if necessary. More...

enum GNUNET_GenericReturnValue	connect_tunnel (struct GNUNET_MESSENGER_SrvTunnel *tunnel)
	Tries to connect a tunnel by creating a new CADET channel and binding it. More...

void	disconnect_tunnel (struct GNUNET_MESSENGER_SrvTunnel *tunnel)
	Disconnects and unbinds a channel from a tunnel. More...

enum GNUNET_GenericReturnValue	is_tunnel_connected (const struct GNUNET_MESSENGER_SrvTunnel *tunnel)
	Returns the status of a currently bound channel of a tunnel. More...

void	send_tunnel_envelope (struct GNUNET_MESSENGER_SrvTunnel tunnel, struct GNUNET_MQ_Envelope env, const struct GNUNET_HashCode *hash)
	Sends an envelope containing a message with a given hash through a tunnel. More...

enum GNUNET_GenericReturnValue	send_tunnel_message (struct GNUNET_MESSENGER_SrvTunnel tunnel, void handle, struct GNUNET_MESSENGER_Message *message)
	Sends a message by packing it automatically into an envelope and passing it through the tunnel. More...

void	forward_tunnel_message (struct GNUNET_MESSENGER_SrvTunnel tunnel, const struct GNUNET_MESSENGER_Message message, const struct GNUNET_HashCode *hash)
	Forwards a given message with a known hash through a tunnel. More...

const struct GNUNET_HashCode *	get_tunnel_peer_message (const struct GNUNET_MESSENGER_SrvTunnel *tunnel)
	Returns the hash of the latest peer message published through a given tunnel and matching the tunnels peer identity. More...

void	get_tunnel_peer_identity (const struct GNUNET_MESSENGER_SrvTunnel tunnel, struct GNUNET_PeerIdentity peer)
	Writes the peer identity of the peer connected via tunnel to this peer into the peer parameter. More...

uint32_t	get_tunnel_messenger_version (const struct GNUNET_MESSENGER_SrvTunnel *tunnel)
	Returns the current messenger version the peer connected via a given tunnel has reported to be using if it was compatible during updating. More...

enum GNUNET_GenericReturnValue	update_tunnel_messenger_version (struct GNUNET_MESSENGER_SrvTunnel *tunnel, uint32_t version)
	Updates the messenger version of the tunnel to a given version if it is compatible to the running peer of the service. More...

Function Documentation

◆ create_tunnel()

struct GNUNET_MESSENGER_SrvTunnel * create_tunnel	(	struct GNUNET_MESSENGER_SrvRoom *	room,
		const struct GNUNET_PeerIdentity *	door
	)

Creates and allocates a tunnel of a room to a specific peer identity (called door).

Parameters

[in,out]	room	Room
[in]	door	Peer identity

Returns: New tunnel

Definition at line 37 of file gnunet-service-messenger_tunnel.c.

{
  GNUNET_assert ((room) && (door));
 
  struct GNUNET_MESSENGER_SrvTunnel *tunnel = GNUNET_new (struct
                                                          GNUNET_MESSENGER_SrvTunnel);
 
  tunnel->room = room;
  tunnel->channel = NULL;
 
  tunnel->peer = GNUNET_PEER_intern (door);
 
  tunnel->messenger_version = 0;
 
  tunnel->peer_message = NULL;
 
  init_message_state (&(tunnel->state));
 
  return tunnel;
}

References GNUNET_MESSENGER_SrvTunnel::channel, GNUNET_assert, GNUNET_new, GNUNET_PEER_intern(), init_message_state(), GNUNET_MESSENGER_SrvTunnel::messenger_version, GNUNET_MESSENGER_SrvTunnel::peer, GNUNET_MESSENGER_SrvTunnel::peer_message, GNUNET_MESSENGER_SrvTunnel::room, and GNUNET_MESSENGER_SrvTunnel::state.

Referenced by callback_room_connect(), and enter_srv_room_at().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ destroy_tunnel()

void destroy_tunnel ( struct GNUNET_MESSENGER_SrvTunnel * tunnel )

Destroys a tunnel and frees its memory fully.

Parameters

[in,out] tunnel

Definition at line 61 of file gnunet-service-messenger_tunnel.c.

{
  GNUNET_assert (tunnel);
 
  if (tunnel->channel)
    GNUNET_CADET_channel_destroy (tunnel->channel);
 
  GNUNET_PEER_change_rc (tunnel->peer, -1);
 
  if (tunnel->peer_message)
    GNUNET_free (tunnel->peer_message);
 
  clear_message_state (&(tunnel->state));
 
  GNUNET_free (tunnel);
}

References GNUNET_MESSENGER_SrvTunnel::channel, clear_message_state(), GNUNET_assert, GNUNET_CADET_channel_destroy(), GNUNET_free, GNUNET_PEER_change_rc(), GNUNET_MESSENGER_SrvTunnel::peer, GNUNET_MESSENGER_SrvTunnel::peer_message, and GNUNET_MESSENGER_SrvTunnel::state.

Here is the call graph for this function:

◆ bind_tunnel()

void bind_tunnel	(	struct GNUNET_MESSENGER_SrvTunnel *	tunnel,
		struct GNUNET_CADET_Channel *	channel
	)

Binds a CADET channel to a tunnel and replaces its channel the tunnel is currently bound to if necessary.

Parameters

[in,out]	tunnel	Tunnel
[in,out]	channel	CADET channel

Definition at line 80 of file gnunet-service-messenger_tunnel.c.

{
  GNUNET_assert (tunnel);
 
  if (tunnel->channel)
    delayed_disconnect_channel (tunnel->channel);
 
  tunnel->channel = channel;
}

References GNUNET_MESSENGER_SrvTunnel::channel, delayed_disconnect_channel(), and GNUNET_assert.

Referenced by callback_room_connect().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ connect_tunnel()

enum GNUNET_GenericReturnValue connect_tunnel ( struct GNUNET_MESSENGER_SrvTunnel * tunnel )

Tries to connect a tunnel by creating a new CADET channel and binding it.

The function returns GNUNET_YES on success, otherwise GNUNET_NO.

Parameters

[in,out] tunnel Tunnel

Returns: GNUNET_YES on success, otherwise GNUNET_NO

Definition at line 255 of file gnunet-service-messenger_tunnel.c.

{
  GNUNET_assert (tunnel);
 
  if (tunnel->channel)
    return GNUNET_NO;
 
  const struct GNUNET_PeerIdentity *door = GNUNET_PEER_resolve2 (tunnel->peer);
 
  struct GNUNET_CADET_Handle *cadet = get_srv_room_cadet (tunnel->room);
  const struct GNUNET_HashCode *key = get_srv_room_key (tunnel->room);
 
  struct GNUNET_MQ_MessageHandler handlers[] = { GNUNET_MQ_hd_var_size (
                                                   tunnel_message,
                                                   GNUNET_MESSAGE_TYPE_CADET_CLI,
                                                   struct
                                                   GNUNET_MessageHeader, NULL),
                                                 GNUNET_MQ_handler_end () };
 
  struct GNUNET_HashCode port;
  convert_messenger_key_to_port (key, &port);
  tunnel->channel = GNUNET_CADET_channel_create (cadet, tunnel, door, &port,
                                                 NULL,
                                                 callback_tunnel_disconnect,
                                                 handlers);
 
  return GNUNET_YES;
}

References cadet, callback_tunnel_disconnect(), GNUNET_MESSENGER_SrvTunnel::channel, convert_messenger_key_to_port(), get_srv_room_cadet(), get_srv_room_key(), GNUNET_assert, GNUNET_CADET_channel_create(), GNUNET_MESSAGE_TYPE_CADET_CLI, GNUNET_MQ_handler_end, GNUNET_MQ_hd_var_size, GNUNET_NO, GNUNET_PEER_resolve2(), GNUNET_YES, handlers, key, GNUNET_MESSENGER_SrvTunnel::peer, port, and GNUNET_MESSENGER_SrvTunnel::room.

Referenced by enter_srv_room_at(), and rebuild_srv_room_basement_structure().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ disconnect_tunnel()

void disconnect_tunnel ( struct GNUNET_MESSENGER_SrvTunnel * tunnel )

Disconnects and unbinds a channel from a tunnel.

The actual disconnection will be asynchronous.

Parameters

[in,out] tunnel Tunnel

Definition at line 286 of file gnunet-service-messenger_tunnel.c.

{
  GNUNET_assert (tunnel);
 
  if (tunnel->channel)
  {
    delayed_disconnect_channel (tunnel->channel);
 
    tunnel->channel = NULL;
  }
}

References GNUNET_MESSENGER_SrvTunnel::channel, delayed_disconnect_channel(), and GNUNET_assert.

Referenced by callback_room_connect(), rebuild_srv_room_basement_structure(), and recv_message_info().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ is_tunnel_connected()

enum GNUNET_GenericReturnValue is_tunnel_connected ( const struct GNUNET_MESSENGER_SrvTunnel * tunnel )

Returns the status of a currently bound channel of a tunnel.

Parameters

[in] tunnel Tunnel

Returns: GNUNET_YES or GNUNET_NO

Definition at line 300 of file gnunet-service-messenger_tunnel.c.

{
  GNUNET_assert (tunnel);
 
  return (tunnel->channel ? GNUNET_YES : GNUNET_NO);
}

References GNUNET_MESSENGER_SrvTunnel::channel, GNUNET_assert, GNUNET_NO, and GNUNET_YES.

Referenced by iterate_send_room_message(), and send_room_info().

Here is the caller graph for this function:

◆ send_tunnel_envelope()

void send_tunnel_envelope	(	struct GNUNET_MESSENGER_SrvTunnel *	tunnel,
		struct GNUNET_MQ_Envelope *	env,
		const struct GNUNET_HashCode *	hash
	)

Sends an envelope containing a message with a given hash through a tunnel.

Parameters

[in,out]	tunnel	Tunnel
[in,out]	env	Envelope
[in]	hash	Hash of message

Definition at line 327 of file gnunet-service-messenger_tunnel.c.

{
  GNUNET_assert ((tunnel) && (env) && (hash));
 
  struct GNUNET_MQ_Handle *mq = GNUNET_CADET_get_mq (tunnel->channel);
 
  struct GNUNET_MESSENGER_MessageSent *sent = GNUNET_new (struct
                                                          GNUNET_MESSENGER_MessageSent);
 
  GNUNET_memcpy (&(sent->hash), hash, sizeof(struct GNUNET_HashCode));
 
  sent->tunnel = tunnel;
 
  GNUNET_MQ_notify_sent (env, callback_tunnel_sent, sent);
  GNUNET_MQ_send (mq, env);
}

References callback_tunnel_sent(), GNUNET_MESSENGER_SrvTunnel::channel, env, GNUNET_assert, GNUNET_CADET_get_mq(), GNUNET_memcpy, GNUNET_MQ_notify_sent(), GNUNET_MQ_send(), GNUNET_new, GNUNET_MESSENGER_MessageSent::hash, mq, and GNUNET_MESSENGER_MessageSent::tunnel.

Referenced by forward_tunnel_message(), iterate_send_room_message(), and send_tunnel_message().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ send_tunnel_message()

enum GNUNET_GenericReturnValue send_tunnel_message	(	struct GNUNET_MESSENGER_SrvTunnel *	tunnel,
		void *	handle,
		struct GNUNET_MESSENGER_Message *	message
	)

Sends a message by packing it automatically into an envelope and passing it through the tunnel.

The used handle will sign the message and the hash will be calculated and stored.

Parameters

[in,out]	tunnel	Tunnel
[in,out]	handle	Handle
[in,out]	message	Message

Returns: GNUNET_YES on success, GNUNET_NO otherwise

Definition at line 348 of file gnunet-service-messenger_tunnel.c.

{
  GNUNET_assert ((tunnel) && (handle));
 
  if (! message)
    return GNUNET_NO;
 
  struct GNUNET_HashCode hash;
  struct GNUNET_MQ_Envelope *env = pack_srv_room_message (
    tunnel->room, (struct GNUNET_MESSENGER_SrvHandle*) handle,
    message, &hash, GNUNET_MESSENGER_PACK_MODE_ENVELOPE
    );
 
  destroy_message (message);
 
  if (! env)
    return GNUNET_NO;
 
  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Sending tunnel message: %s\n",
              GNUNET_h2s (&hash));
 
  send_tunnel_envelope (tunnel, env, &hash);
  return GNUNET_YES;
}

References destroy_message(), env, GNUNET_assert, GNUNET_ERROR_TYPE_DEBUG, GNUNET_h2s(), GNUNET_log, GNUNET_MESSENGER_PACK_MODE_ENVELOPE, GNUNET_NO, GNUNET_YES, handle, pack_srv_room_message(), GNUNET_MESSENGER_SrvTunnel::room, send_tunnel_envelope(), and GNUNET_MESSENGER_MessageSent::tunnel.

Referenced by recv_message_info(), and send_room_info().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ forward_tunnel_message()

void forward_tunnel_message	(	struct GNUNET_MESSENGER_SrvTunnel *	tunnel,
		const struct GNUNET_MESSENGER_Message *	message,
		const struct GNUNET_HashCode *	hash
	)

Forwards a given message with a known hash through a tunnel.

Parameters

[in,out]	tunnel	Tunnel
[in]	message	Message
[in]	hash	Hash of message

Definition at line 377 of file gnunet-service-messenger_tunnel.c.

{
  GNUNET_assert ((tunnel) && (message) && (hash));
 
  struct GNUNET_MESSENGER_Message *copy = copy_message (message);
  struct GNUNET_MQ_Envelope *env = pack_message (copy, NULL, NULL,
                                                 GNUNET_MESSENGER_PACK_MODE_ENVELOPE,
                                                 NULL);
 
  destroy_message (copy);
 
  if (! env)
    return;
 
  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Forwarding tunnel message: %s\n",
              GNUNET_h2s (hash));
 
  send_tunnel_envelope (tunnel, env, hash);
}

References copy_message(), destroy_message(), env, GNUNET_assert, GNUNET_ERROR_TYPE_DEBUG, GNUNET_h2s(), GNUNET_log, GNUNET_MESSENGER_PACK_MODE_ENVELOPE, pack_message(), and send_tunnel_envelope().

Referenced by callback_found_message(), check_srv_room_peer_status(), forward_about_members(), and recv_message_info().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ get_tunnel_peer_message()

const struct GNUNET_HashCode * get_tunnel_peer_message ( const struct GNUNET_MESSENGER_SrvTunnel * tunnel )

Returns the hash of the latest peer message published through a given tunnel and matching the tunnels peer identity.

If no peer message has been linked to the tunnel yet, NULL gets returned.

Parameters

[in] tunnel Tunnel

Returns: Hash of peer message or NULL

Definition at line 401 of file gnunet-service-messenger_tunnel.c.

{
  GNUNET_assert (tunnel);
 
  return tunnel->peer_message;
}

References GNUNET_assert, and GNUNET_MESSENGER_SrvTunnel::peer_message.

◆ get_tunnel_peer_identity()

void get_tunnel_peer_identity	(	const struct GNUNET_MESSENGER_SrvTunnel *	tunnel,
		struct GNUNET_PeerIdentity *	peer
	)

Writes the peer identity of the peer connected via tunnel to this peer into the peer parameter.

Parameters

[in]	tunnel	Tunnel
[out]	peer	Peer identity

Definition at line 410 of file gnunet-service-messenger_tunnel.c.

{
  GNUNET_assert (tunnel);
 
  GNUNET_PEER_resolve (tunnel->peer, peer);
}

References GNUNET_assert, GNUNET_PEER_resolve(), and GNUNET_MESSENGER_SrvTunnel::peer.

Referenced by callback_room_disconnect(), and recv_message_info().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ get_tunnel_messenger_version()

uint32_t get_tunnel_messenger_version ( const struct GNUNET_MESSENGER_SrvTunnel * tunnel )

Returns the current messenger version the peer connected via a given tunnel has reported to be using if it was compatible during updating.

See also: update_tunnel_messenger_version

Parameters

[in] tunnel Tunnel

Returns: Version of messenger

Definition at line 420 of file gnunet-service-messenger_tunnel.c.

{
  GNUNET_assert (tunnel);
 
  return tunnel->messenger_version;
}

References GNUNET_assert, and GNUNET_MESSENGER_SrvTunnel::messenger_version.

Referenced by iterate_send_room_message(), and recv_message_info().

Here is the caller graph for this function:

◆ update_tunnel_messenger_version()

enum GNUNET_GenericReturnValue update_tunnel_messenger_version	(	struct GNUNET_MESSENGER_SrvTunnel *	tunnel,
		uint32_t	version
	)

Updates the messenger version of the tunnel to a given version if it is compatible to the running peer of the service.

Depending on success it returns GNUNET_OK or GNUNET_SYSERR on failure.

Parameters

[in,out]	tunnel	Tunnel
[in]	version	Version of messenger

Returns: GNUNET_OK on success, otherwise GNUNET_SYSERR

Definition at line 429 of file gnunet-service-messenger_tunnel.c.

{
  GNUNET_assert (tunnel);
 
  if (version != GNUNET_MESSENGER_VERSION)
    return GNUNET_SYSERR;
 
  if (version > tunnel->messenger_version)
    tunnel->messenger_version = version;
 
  return GNUNET_OK;
}

References GNUNET_assert, GNUNET_MESSENGER_VERSION, GNUNET_OK, GNUNET_SYSERR, and GNUNET_MESSENGER_SrvTunnel::messenger_version.

Referenced by recv_message_info().

Here is the caller graph for this function:

Data Structures

Functions

Function Documentation

◆ create_tunnel()

◆ destroy_tunnel()

◆ bind_tunnel()

◆ connect_tunnel()

◆ disconnect_tunnel()

◆ is_tunnel_connected()

◆ send_tunnel_envelope()

◆ send_tunnel_message()

◆ forward_tunnel_message()

◆ get_tunnel_peer_message()

◆ get_tunnel_peer_identity()

◆ get_tunnel_messenger_version()

◆ update_tunnel_messenger_version()