Information we track per peer. More...

#include "gnunet_util_lib.h"
#include "cadet_protocol.h"

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

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

Data Structures
struct	CadetPeerPathEntry
	Entry in a peer path. More...

struct	CadetTConnection
	Entry in list of connections used by tunnel, with metadata. More...

struct	OpenPort
	Port opened by a client. More...

Functions
void	GSC_send_to_client (struct CadetClient c, struct GNUNET_MQ_Envelope env)
	Send a message to a client. More...

void	GSC_handle_remote_channel_destroy (struct CadetClient c, struct GNUNET_CADET_ClientChannelNumber ccn, struct CadetChannel ch)
	A channel was destroyed by the other peer. More...

void	GSC_drop_loose_channel (const struct GNUNET_HashCode h_port, struct CadetChannel ch)
	A client that created a loose channel that was not bound to a port disconnected, drop it from the loose_channels list. More...

struct GNUNET_CADET_ClientChannelNumber	GSC_bind (struct CadetClient c, struct CadetChannel ch, struct CadetPeer dest, const struct GNUNET_HashCode port, uint32_t options)
	Bind incoming channel to this client, and notify client about incoming connection. More...

const char *	GSC_2s (struct CadetClient *c)
	Return identifier for a client as a string. More...

Variables
const struct GNUNET_CONFIGURATION_Handle *	cfg
	Handle to our configuration. More...

struct GNUNET_STATISTICS_Handle *	stats
	Handle to the statistics service. More...

struct GNUNET_TRANSPORT_ApplicationHandle *	transport
	Handle to Transport service. More...

struct GNUNET_PeerIdentity	my_full_id
	Local peer own ID. More...

struct GNUNET_CRYPTO_EddsaPrivateKey *	my_private_key
	Own private key. More...

struct GNUNET_CONTAINER_MultiHashMap *	open_ports
	All ports clients of this peer have opened. More...

struct GNUNET_CONTAINER_MultiShortmap *	connections
	Map from `struct GNUNET_CADET_ConnectionTunnelIdentifier` hash codes to `struct CadetConnection` objects. More...

struct GNUNET_CONTAINER_MultiHashMap *	loose_channels
	Map from ports to channels where the ports were closed at the time we got the inbound connection. More...

struct GNUNET_CONTAINER_MultiPeerMap *	peers
	Map from PIDs to `struct CadetPeer` entries. More...

unsigned long long	ratchet_messages
	How many messages are needed to trigger an AXOLOTL ratchet advance. More...

struct GNUNET_TIME_Relative	ratchet_time
	How long until we trigger a ratched advance due to time. More...

struct GNUNET_TIME_Relative	keepalive_period
	How frequently do we send KEEPALIVE messages on idle connections? More...

int	shutting_down
	Signal that shutdown is happening: prevent recovery measures. More...

unsigned long long	drop_percent
	Set to non-zero values to create random drops to test retransmissions. More...

Detailed Description

Information we track per peer.

Author: Bartlomiej Polot; Christian Grothoff

Definition in file gnunet-service-cadet.h.

Function Documentation

◆ GSC_send_to_client()

void GSC_send_to_client	(	struct CadetClient *	c,
		struct GNUNET_MQ_Envelope *	env
	)

Send a message to a client.

Parameters

c	client to get the message
env	envelope with the message

Definition at line 207 of file gnunet-service-cadet.c.

{
  GNUNET_MQ_send (c->mq,
                  env);
}

References env, GNUNET_MQ_send(), and CadetClient::mq.

Referenced by GCCH_handle_channel_plaintext_data(), GCCH_handle_local_ack(), GCCH_handle_local_data(), GSC_bind(), GSC_handle_remote_channel_destroy(), and send_ack_to_client().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GSC_handle_remote_channel_destroy()

void GSC_handle_remote_channel_destroy	(	struct CadetClient *	c,
		struct GNUNET_CADET_ClientChannelNumber	ccn,
		struct CadetChannel *	ch
	)

A channel was destroyed by the other peer.

Tell our client.

Parameters

c	client that lost a channel
ccn	channel identification number for the client
ch	the channel object

Definition at line 1082 of file gnunet-service-cadet.c.

{
  struct GNUNET_MQ_Envelope *env;
  struct GNUNET_CADET_LocalChannelDestroyMessage *tdm;
 
  env = GNUNET_MQ_msg (tdm,
                       GNUNET_MESSAGE_TYPE_CADET_LOCAL_CHANNEL_DESTROY);
  tdm->ccn = ccn;
  GSC_send_to_client (c,
                      env);
  GNUNET_assert (GNUNET_YES ==
                 GNUNET_CONTAINER_multihashmap32_remove (c->channels,
                                                         ntohl (
                                                           ccn.channel_of_client),
                                                         ch));
}

References GNUNET_CADET_LocalChannelDestroyMessage::ccn, ch, GNUNET_CADET_ClientChannelNumber::channel_of_client, CadetClient::channels, env, GNUNET_assert, GNUNET_CONTAINER_multihashmap32_remove(), GNUNET_MESSAGE_TYPE_CADET_LOCAL_CHANNEL_DESTROY, GNUNET_MQ_msg, GNUNET_YES, and GSC_send_to_client().

Referenced by GCCH_handle_remote_destroy(), and signal_remote_destroy_cb().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GSC_drop_loose_channel()

void GSC_drop_loose_channel	(	const struct GNUNET_HashCode *	h_port,
		struct CadetChannel *	ch
	)

A client that created a loose channel that was not bound to a port disconnected, drop it from the loose_channels list.

Parameters

h_port	the hashed port the channel was trying to bind to
ch	the channel that was lost

Definition at line 1103 of file gnunet-service-cadet.c.

{
  GNUNET_assert (GNUNET_YES ==
                 GNUNET_CONTAINER_multihashmap_remove (loose_channels,
                                                       h_port,
                                                       ch));
}

References ch, GNUNET_assert, GNUNET_CONTAINER_multihashmap_remove(), GNUNET_YES, and loose_channels.

Referenced by channel_destroy().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GSC_bind()

struct GNUNET_CADET_ClientChannelNumber GSC_bind	(	struct CadetClient *	c,
		struct CadetChannel *	ch,
		struct CadetPeer *	dest,
		const struct GNUNET_HashCode *	port,
		uint32_t	options
	)

Bind incoming channel to this client, and notify client about incoming connection.

Parameters

c	client to bind to
ch	channel to be bound
dest	peer that establishes the connection
port	port number
options	options

Returns: local channel number assigned to the new client

Caller is responsible for notifying the other peer about our acceptance of the channel.

Parameters

c	client to bind to
ch	channel to be bound
dest	peer that establishes the connection
port	port number
options	options

Returns: local channel number assigned to the new client

Definition at line 291 of file gnunet-service-cadet.c.

{
  struct GNUNET_MQ_Envelope *env;
  struct GNUNET_CADET_LocalChannelCreateMessage *cm;
  struct GNUNET_CADET_ClientChannelNumber ccn;
 
  ccn = client_get_next_ccn (c);
  GNUNET_assert (GNUNET_YES ==
                 GNUNET_CONTAINER_multihashmap32_put (c->channels,
                                                      ntohl (
                                                        ccn.channel_of_client),
                                                      ch,
                                                      GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_ONLY));
  LOG (GNUNET_ERROR_TYPE_DEBUG,
       "Accepting incoming %s from %s on open port %s (%u), assigning ccn %X\n",
       GCCH_2s (ch),
       GCP_2s (dest),
       GNUNET_h2s (port),
       (uint32_t) ntohl (options),
       (uint32_t) ntohl (ccn.channel_of_client));
  /* notify local client about incoming connection! */
  env = GNUNET_MQ_msg (cm,
                       GNUNET_MESSAGE_TYPE_CADET_LOCAL_CHANNEL_CREATE);
  cm->ccn = ccn;
  cm->port = *port;
  cm->opt = htonl (options);
  cm->peer = *GCP_get_id (dest);
  GSC_send_to_client (c,
                      env);
  return ccn;
}

References GNUNET_CADET_LocalChannelCreateMessage::ccn, ch, GNUNET_CADET_ClientChannelNumber::channel_of_client, client_get_next_ccn(), warningfilter::dest, env, GCCH_2s(), GCP_2s(), GCP_get_id(), GNUNET_assert, GNUNET_CONTAINER_multihashmap32_put(), GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_ONLY, GNUNET_ERROR_TYPE_DEBUG, GNUNET_h2s(), GNUNET_MESSAGE_TYPE_CADET_LOCAL_CHANNEL_CREATE, GNUNET_MQ_msg, GNUNET_YES, GSC_send_to_client(), LOG, GNUNET_CADET_LocalChannelCreateMessage::opt, options, GNUNET_CADET_LocalChannelCreateMessage::peer, GNUNET_CADET_LocalChannelCreateMessage::port, and port.

Referenced by GCCH_bind().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GSC_2s()

const char * GSC_2s ( struct CadetClient * c )

Return identifier for a client as a string.

Parameters

c	client to identify

Returns: string for debugging

Definition at line 222 of file gnunet-service-cadet.c.

{
  static char buf[32];
 
  GNUNET_snprintf (buf,
                   sizeof(buf),
                   "Client(%u)",
                   c->id);
  return buf;
}