gnunet-service-cadet.c File Reference

GNUnet CADET service with encryption. More...

#include "cadet.h"
#include "gnunet_pils_service.h"
#include "gnunet_util_lib.h"
#include "gnunet_statistics_service.h"
#include "gnunet_transport_application_service.h"
#include "gnunet-service-cadet.h"
#include "gnunet-service-cadet_channel.h"
#include "gnunet-service-cadet_core.h"
#include "gnunet-service-cadet_dht.h"
#include "gnunet-service-cadet_hello.h"
#include "gnunet-service-cadet_tunnels.h"
#include "gnunet-service-cadet_peer.h"
#include "gnunet-service-cadet_paths.h"
#include "gnunet_constants.h"

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

Go to the source code of this file.

Data Structures
struct	CadetClient
	Struct containing information about a client of the service. More...

Macros
#define	LOG(level, ...)   GNUNET_log (level, __VA_ARGS__)

Functions
void	GSC_send_to_client (struct CadetClient *c, struct GNUNET_MQ_Envelope *env)
	Send a message to a client.
const char *	GSC_2s (struct CadetClient *c)
	Return identifier for a client as a string.
static struct CadetChannel *	lookup_channel (struct CadetClient *c, struct GNUNET_CADET_ClientChannelNumber ccn)
	Lookup channel of client c by ccn.
static struct GNUNET_CADET_ClientChannelNumber	client_get_next_ccn (struct CadetClient *c)
	Obtain the next LID to use for incoming connections to the given client.
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.
static int	destroy_tunnels_now (void *cls, const struct GNUNET_PeerIdentity *pid, void *value)
	Callback invoked on all peers to destroy all tunnels that may still exist.
static int	destroy_paths_now (void *cls, const struct GNUNET_PeerIdentity *pid, void *value)
	Callback invoked on all peers to destroy all tunnels that may still exist.
static void	shutdown_rest ()
	Shutdown everything once the clients have disconnected.
static void	shutdown_task (void *cls)
	Task run during shutdown.
static int	bind_loose_channel (void *cls, const struct GNUNET_HashCode *port, void *value)
	We had a remote connection value to port h_port before client cls opened port port.
static void	handle_port_open (void *cls, const struct GNUNET_CADET_PortMessage *pmsg)
	Handle port open request.
static void	handle_port_close (void *cls, const struct GNUNET_CADET_PortMessage *pmsg)
	Handler for port close requests.
static void	handle_channel_create (void *cls, const struct GNUNET_CADET_LocalChannelCreateMessage *tcm)
	Handler for requests for us creating a new channel to another peer and port.
static void	handle_channel_destroy (void *cls, const struct GNUNET_CADET_LocalChannelDestroyMessage *msg)
	Handler for requests of destroying an existing channel.
static int	check_local_data (void *cls, const struct GNUNET_CADET_LocalData *msg)
	Check for client traffic data message is well-formed.
static void	handle_local_data (void *cls, const struct GNUNET_CADET_LocalData *msg)
	Handler for client payload traffic to be send on a channel to another peer.
static void	handle_local_ack (void *cls, const struct GNUNET_CADET_LocalAck *msg)
	Handler for client's ACKs for payload traffic.
static int	get_all_peers_iterator (void *cls, const struct GNUNET_PeerIdentity *peer, void *value)
	Iterator over all peers to send a monitoring client info about each peer.
static void	handle_get_peers (void *cls, const struct GNUNET_MessageHeader *message)
	Handler for client's INFO PEERS request.
static int	path_info_iterator (void *cls, struct CadetPeerPath *path, unsigned int off)
	Iterator over all paths of a peer to build an InfoPeer message.
static void	handle_show_path (void *cls, const struct GNUNET_CADET_RequestPathInfoMessage *msg)
	Handler for client's GNUNET_MESSAGE_TYPE_CADET_LOCAL_REQUEST_INFO_PATH request.
static int	get_all_tunnels_iterator (void *cls, const struct GNUNET_PeerIdentity *peer, void *value)
	Iterator over all tunnels to send a monitoring client info about each tunnel.
static void	handle_info_tunnels (void *cls, const struct GNUNET_MessageHeader *message)
	Handler for client's GNUNET_MESSAGE_TYPE_CADET_LOCAL_REQUEST_INFO_TUNNELS request.
static void	handle_drop_message (void *cls, const struct GNUNET_CADET_RequestDropCadetMessage *message)
	Handler for client's GNUNET_MESSAGE_TYPE_CADET_DROP_CADET_MESSAGE request.
static void *	client_connect_cb (void *cls, struct GNUNET_SERVICE_Client *client, struct GNUNET_MQ_Handle *mq)
	Callback called when a client connects to the service.
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.
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.
static int	channel_destroy_iterator (void *cls, uint32_t key, void *value)
	Iterator for deleting each channel whose client endpoint disconnected.
static int	client_release_ports (void *cls, const struct GNUNET_HashCode *port, void *value)
	Remove client's ports from the global hashmap on disconnect.
static void	client_disconnect_cb (void *cls, struct GNUNET_SERVICE_Client *client, void *internal_cls)
	Callback called when a client disconnected from the service.
static void	run (void *cls, const struct GNUNET_CONFIGURATION_Handle *c, struct GNUNET_SERVICE_Handle *service)
	Setup CADET internals.
	GNUNET_SERVICE_MAIN (GNUNET_OS_project_data_gnunet(), "cadet", GNUNET_SERVICE_OPTION_NONE, &run, &client_connect_cb, &client_disconnect_cb, NULL, GNUNET_MQ_hd_fixed_size(port_open, GNUNET_MESSAGE_TYPE_CADET_LOCAL_PORT_OPEN, struct GNUNET_CADET_PortMessage, NULL), GNUNET_MQ_hd_fixed_size(port_close, GNUNET_MESSAGE_TYPE_CADET_LOCAL_PORT_CLOSE, struct GNUNET_CADET_PortMessage, NULL), GNUNET_MQ_hd_fixed_size(channel_create, GNUNET_MESSAGE_TYPE_CADET_LOCAL_CHANNEL_CREATE, struct GNUNET_CADET_LocalChannelCreateMessage, NULL), GNUNET_MQ_hd_fixed_size(channel_destroy, GNUNET_MESSAGE_TYPE_CADET_LOCAL_CHANNEL_DESTROY, struct GNUNET_CADET_LocalChannelDestroyMessage, NULL), GNUNET_MQ_hd_var_size(local_data, GNUNET_MESSAGE_TYPE_CADET_LOCAL_DATA, struct GNUNET_CADET_LocalData, NULL), GNUNET_MQ_hd_fixed_size(local_ack, GNUNET_MESSAGE_TYPE_CADET_LOCAL_ACK, struct GNUNET_CADET_LocalAck, NULL), GNUNET_MQ_hd_fixed_size(get_peers, GNUNET_MESSAGE_TYPE_CADET_LOCAL_REQUEST_INFO_PEERS, struct GNUNET_MessageHeader, NULL), GNUNET_MQ_hd_fixed_size(show_path, GNUNET_MESSAGE_TYPE_CADET_LOCAL_REQUEST_INFO_PATH, struct GNUNET_CADET_RequestPathInfoMessage, NULL), GNUNET_MQ_hd_fixed_size(info_tunnels, GNUNET_MESSAGE_TYPE_CADET_LOCAL_REQUEST_INFO_TUNNELS, struct GNUNET_MessageHeader, NULL), GNUNET_MQ_hd_fixed_size(drop_message, GNUNET_MESSAGE_TYPE_CADET_DROP_CADET_MESSAGE, struct GNUNET_CADET_RequestDropCadetMessage, NULL), GNUNET_MQ_handler_end())
	Define "main" method using service macro.

Variables
const struct GNUNET_CONFIGURATION_Handle *	cfg
	Handle to our configuration.
struct GNUNET_STATISTICS_Handle *	stats
	Handle to the statistics service.
struct GNUNET_TRANSPORT_ApplicationHandle *	transport
	Handle to Transport service.
struct GNUNET_PILS_Handle *	pils
	Handle to the pils service.
int	shutting_down
	Signal that shutdown is happening: prevent recovery measures.
static struct CadetClient *	clients_head
	DLL with all the clients, head.
static struct CadetClient *	clients_tail
	DLL with all the clients, tail.
static unsigned int	next_client_id
	Next ID to assign to a client.
struct GNUNET_CONTAINER_MultiHashMap *	open_ports
	All ports clients of this peer have opened.
struct GNUNET_CONTAINER_MultiHashMap *	loose_channels
	Map from ports to channels where the ports were closed at the time we got the inbound connection.
struct GNUNET_CONTAINER_MultiPeerMap *	peers
	Map from PIDs to struct CadetPeer entries.
struct GNUNET_CONTAINER_MultiShortmap *	connections
	Map from struct GNUNET_CADET_ConnectionTunnelIdentifier hash codes to struct CadetConnection objects.
unsigned long long	ratchet_messages
	How many messages are needed to trigger an AXOLOTL ratchet advance.
struct GNUNET_TIME_Relative	ratchet_time
	How long until we trigger a ratched advance due to time.
struct GNUNET_TIME_Relative	keepalive_period
	How frequently do we send KEEPALIVE messages on idle connections?
unsigned long long	drop_percent
	Set to non-zero values to create random drops to test retransmissions.

Detailed Description

GNUnet CADET service with encryption.

Author

Bartlomiej Polot

Christian Grothoff

Dictionary:

• peer: other cadet instance. If there is direct connection it's a neighbor.
• path: series of directly connected peer from one peer to another.
• connection: path which is being used in a tunnel.
• tunnel: encrypted connection to a peer, neighbor or not.
• channel: logical link between two clients, on the same or different peers. have properties like reliability.

Definition in file gnunet-service-cadet.c.

Macro Definition Documentation

LOG

#define LOG	(		level,
			...
	)		GNUNET_log (level, __VA_ARGS__)

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

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 203 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_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 218 of file gnunet-service-cadet.c.

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

References GNUNET_snprintf(), and CadetClient::id.

Referenced by channel_destroy_iterator(), client_connect_cb(), client_disconnect_cb(), client_release_ports(), GCCH_bind(), GCCH_channel_local_destroy(), GCCH_channel_local_new(), GCCH_debug(), GCCH_handle_channel_plaintext_data(), GCCH_handle_local_ack(), handle_channel_create(), handle_channel_destroy(), handle_local_ack(), handle_local_data(), handle_port_close(), handle_port_open(), and send_ack_to_client().

Here is the call graph for this function:

Here is the caller graph for this function:

lookup_channel()

static struct CadetChannel * lookup_channel ( struct CadetClient *  c, struct GNUNET_CADET_ClientChannelNumber  ccn  )

static

Lookup channel of client c by ccn.

Parameters

c	client to look in
ccn	channel ID to look up

Returns

NULL if no such channel exists

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

{
  return GNUNET_CONTAINER_multihashmap32_get (c->channels,
                                              ntohl (ccn.channel_of_client));
}

References GNUNET_CADET_ClientChannelNumber::channel_of_client, CadetClient::channels, and GNUNET_CONTAINER_multihashmap32_get().

Referenced by client_get_next_ccn(), handle_channel_create(), handle_channel_destroy(), handle_drop_message(), handle_local_ack(), and handle_local_data().

Here is the call graph for this function:

Here is the caller graph for this function:

client_get_next_ccn()

static struct GNUNET_CADET_ClientChannelNumber client_get_next_ccn ( struct CadetClient *  c )

static

Obtain the next LID to use for incoming connections to the given client.

Parameters

c	client handle

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

{
  struct GNUNET_CADET_ClientChannelNumber ccn = c->next_ccn;
 
  /* increment until we have a free one... */
  while (NULL !=
         lookup_channel (c,
                         ccn))
  {
    ccn.channel_of_client
      = htonl (1 + (ntohl (ccn.channel_of_client)));
    if (ntohl (ccn.channel_of_client) >=
        GNUNET_CADET_LOCAL_CHANNEL_ID_CLI)
      ccn.channel_of_client = htonl (0);
  }
  c->next_ccn.channel_of_client
    = htonl (1 + (ntohl (ccn.channel_of_client)));
  return ccn;
}

References GNUNET_CADET_ClientChannelNumber::channel_of_client, GNUNET_CADET_LOCAL_CHANNEL_ID_CLI, and lookup_channel().

Referenced by GSC_bind().

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.

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 287 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(), 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:

destroy_tunnels_now()

static int destroy_tunnels_now ( void *  cls, const struct GNUNET_PeerIdentity *  pid, void *  value  )

static

Callback invoked on all peers to destroy all tunnels that may still exist.

Parameters

cls	NULL
pid	identify of a peer
value	a struct CadetPeer that may still have a tunnel

Returns

GNUNET_OK (iterate over all entries)

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

{
  struct CadetPeer *cp = value;
  struct CadetTunnel *t = GCP_get_tunnel (cp,
                                          GNUNET_NO);
 
  if (NULL != t)
    GCT_destroy_tunnel_now (t);
  return GNUNET_OK;
}

References GCP_get_tunnel(), GCT_destroy_tunnel_now(), GNUNET_NO, GNUNET_OK, t, and value.

Referenced by shutdown_rest().

Here is the call graph for this function:

Here is the caller graph for this function:

destroy_paths_now()

static int destroy_paths_now ( void *  cls, const struct GNUNET_PeerIdentity *  pid, void *  value  )

static

Callback invoked on all peers to destroy all tunnels that may still exist.

Parameters

cls	NULL
pid	identify of a peer
value	a struct CadetPeer that may still have a tunnel

Returns

GNUNET_OK (iterate over all entries)

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

{
  struct CadetPeer *cp = value;
 
  GCP_drop_owned_paths (cp);
  return GNUNET_OK;
}

References GCP_drop_owned_paths(), GNUNET_OK, and value.

Referenced by shutdown_rest().

Here is the call graph for this function:

Here is the caller graph for this function:

shutdown_rest()

static void shutdown_rest ( )

static

Shutdown everything once the clients have disconnected.

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

{
  if (NULL != stats)
  {
    GNUNET_STATISTICS_destroy (stats,
                               GNUNET_NO);
    stats = NULL;
  }
  /* Destroy tunnels.  Note that all channels must be destroyed first! */
  GCP_iterate_all (&destroy_tunnels_now,
                   NULL);
  /* All tunnels, channels, connections and CORE must be down before this point. */
  GCP_iterate_all (&destroy_paths_now,
                   NULL);
  /* All paths, tunnels, channels, connections and CORE must be down before this point. */
  GCP_destroy_all_peers ();
  if (NULL != open_ports)
  {
    GNUNET_CONTAINER_multihashmap_destroy (open_ports);
    open_ports = NULL;
  }
  if (NULL != loose_channels)
  {
    GNUNET_CONTAINER_multihashmap_destroy (loose_channels);
    loose_channels = NULL;
  }
  if (NULL != peers)
  {
    GNUNET_CONTAINER_multipeermap_destroy (peers);
    peers = NULL;
  }
  if (NULL != connections)
  {
    GNUNET_CONTAINER_multishortmap_destroy (connections);
    connections = NULL;
  }
  if (NULL != transport)
  {
    GNUNET_TRANSPORT_application_done (transport);
    transport = NULL;
  }
  GCD_shutdown ();
  GCH_shutdown ();
}

References connections, destroy_paths_now(), destroy_tunnels_now(), GCD_shutdown(), GCH_shutdown(), GCP_destroy_all_peers(), GCP_iterate_all(), GNUNET_CONTAINER_multihashmap_destroy(), GNUNET_CONTAINER_multipeermap_destroy(), GNUNET_CONTAINER_multishortmap_destroy(), GNUNET_NO, GNUNET_STATISTICS_destroy(), GNUNET_TRANSPORT_application_done(), loose_channels, open_ports, peers, stats, and transport.

Referenced by client_disconnect_cb(), and shutdown_task().

Here is the call graph for this function:

Here is the caller graph for this function:

shutdown_task()

static void shutdown_task ( void *  cls )

static

Task run during shutdown.

Parameters

cls

unused

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

{
  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
              "Shutting down\n");
  shutting_down = GNUNET_YES;
  GCO_shutdown ();
  if (NULL == clients_head)
    shutdown_rest ();
}

References clients_head, GCO_shutdown(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_log, GNUNET_YES, shutdown_rest(), and shutting_down.

Here is the call graph for this function:

bind_loose_channel()

static int bind_loose_channel ( void *  cls, const struct GNUNET_HashCode *  port, void *  value  )

static

We had a remote connection value to port h_port before client cls opened port port.

Bind them now.

Parameters

cls	the struct CadetClient
port	the hashed port
value	the struct CadetChannel

Returns

GNUNET_YES (iterate over all such channels)

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

{
  struct OpenPort *op = cls;
  struct CadetChannel *ch = value;
 
  GCCH_bind (ch,
             op->c,
             &op->port);
  GNUNET_assert (GNUNET_YES ==
                 GNUNET_CONTAINER_multihashmap_remove (loose_channels,
                                                       &op->h_port,
                                                       ch));
  return GNUNET_YES;
}

References ch, GCCH_bind(), GNUNET_assert, GNUNET_CONTAINER_multihashmap_remove(), GNUNET_YES, loose_channels, op, and value.

Referenced by handle_port_open().

Here is the call graph for this function:

Here is the caller graph for this function:

handle_port_open()

static void handle_port_open ( void *  cls, const struct GNUNET_CADET_PortMessage *  pmsg  )

static

Handle port open request.

Creates a mapping from the port to the respective client and checks whether we have loose channels trying to bind to the port. If so, those are bound.

Parameters

cls	Identification of the client.
pmsg	The actual message.

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

{
  const struct GNUNET_PeerIdentity *my_identity;
  struct CadetClient *c = cls;
  struct OpenPort *op;
 
  LOG (GNUNET_ERROR_TYPE_DEBUG,
       "Open port %s requested by %s\n",
       GNUNET_h2s (&pmsg->port),
       GSC_2s (c));
 
  my_identity = GNUNET_PILS_get_identity (pils);
  if (! my_identity)
  {
    /* PILS has not delivered our peer identity yet -- #GCH_init() only
       *starts* the connection, so there is a window right after startup in
       which we are already accepting clients but cannot compute @e h_port.
 
       This used to `return' here, which called neither
       #GNUNET_SERVICE_client_continue() nor #GNUNET_SERVICE_client_drop().
       The service framework then never reads another message from that
       client, for the lifetime of the process: it just logs "Processing code
       for message of type 1022 did not call `GNUNET_SERVICE_client_continue'"
       once a minute, forever.  The port was silently never opened either, so
       the application waits for incoming channels that cannot arrive, and a
       later #GNUNET_MESSAGE_TYPE_CADET_LOCAL_PORT_CLOSE for it trips the
       GNUNET_break(0) in #handle_port_close().
 
       Dropping the client is recoverable and honest: the port really was not
       opened, and #reconnect_cbk() in cadet_api.c re-opens every port the
       client holds after a GNUNET_TIME_STD_BACKOFF delay, by which time PILS
       will have answered. */
    GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
                "Cannot open port for %s yet: no peer identity from PILS. "
                "Dropping the client so that it retries.\n",
                GSC_2s (c));
    GNUNET_SERVICE_client_drop (c->client);
    return;
  }
 
  if (NULL == c->ports)
    c->ports = GNUNET_CONTAINER_multihashmap_create (4,
                                                     GNUNET_NO);
  op = GNUNET_new (struct OpenPort);
  op->c = c;
  op->port = pmsg->port;
  GCCH_hash_port (&op->h_port,
                  &pmsg->port,
                  my_identity);
  if (GNUNET_OK !=
      GNUNET_CONTAINER_multihashmap_put (c->ports,
                                         &op->port,
                                         op,
                                         GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_ONLY))
  {
    GNUNET_break (0);
    GNUNET_SERVICE_client_drop (c->client);
    return;
  }
  (void) GNUNET_CONTAINER_multihashmap_put (open_ports,
                                            &op->h_port,
                                            op,
                                            GNUNET_CONTAINER_MULTIHASHMAPOPTION_MULTIPLE);
  GNUNET_CONTAINER_multihashmap_get_multiple (loose_channels,
                                              &op->h_port,
                                              &bind_loose_channel,
                                              op);
  GNUNET_SERVICE_client_continue (c->client);
}

References bind_loose_channel(), OpenPort::c, CadetClient::client, GCCH_hash_port(), GNUNET_break, GNUNET_CONTAINER_multihashmap_create(), GNUNET_CONTAINER_multihashmap_get_multiple(), GNUNET_CONTAINER_multihashmap_put(), GNUNET_CONTAINER_MULTIHASHMAPOPTION_MULTIPLE, GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_ONLY, GNUNET_ERROR_TYPE_DEBUG, GNUNET_ERROR_TYPE_WARNING, GNUNET_h2s(), GNUNET_log, GNUNET_new, GNUNET_NO, GNUNET_OK, GNUNET_PILS_get_identity(), GNUNET_SERVICE_client_continue(), GNUNET_SERVICE_client_drop(), GSC_2s(), LOG, loose_channels, my_identity, op, open_ports, pils, GNUNET_CADET_PortMessage::port, and CadetClient::ports.

Here is the call graph for this function:

handle_port_close()

static void handle_port_close ( void *  cls, const struct GNUNET_CADET_PortMessage *  pmsg  )

static

Handler for port close requests.

Marks this port as closed (unless of course we have another client with the same port open). Note that existing channels accepted on the port are not affected.

Parameters

cls	Identification of the client.
pmsg	The actual message.

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

{
  struct CadetClient *c = cls;
  struct OpenPort *op;
 
  LOG (GNUNET_ERROR_TYPE_DEBUG,
       "Closing port %s as requested by %s\n",
       GNUNET_h2s (&pmsg->port),
       GSC_2s (c));
  if (NULL == c->ports)
  {
    /* Client closed a port despite _never_ having opened one? */
    GNUNET_break (0);
    GNUNET_SERVICE_client_drop (c->client);
    return;
  }
  op = GNUNET_CONTAINER_multihashmap_get (c->ports,
                                          &pmsg->port);
  if (NULL == op)
  {
    GNUNET_break (0);
    GNUNET_SERVICE_client_drop (c->client);
    return;
  }
  GNUNET_assert (GNUNET_YES ==
                 GNUNET_CONTAINER_multihashmap_remove (c->ports,
                                                       &op->port,
                                                       op));
  GNUNET_assert (GNUNET_YES ==
                 GNUNET_CONTAINER_multihashmap_remove (open_ports,
                                                       &op->h_port,
                                                       op));
  GNUNET_free (op);
  GNUNET_SERVICE_client_continue (c->client);
}

References OpenPort::c, CadetClient::client, GNUNET_assert, GNUNET_break, GNUNET_CONTAINER_multihashmap_get(), GNUNET_CONTAINER_multihashmap_remove(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_free, GNUNET_h2s(), GNUNET_SERVICE_client_continue(), GNUNET_SERVICE_client_drop(), GNUNET_YES, GSC_2s(), LOG, op, open_ports, GNUNET_CADET_PortMessage::port, and CadetClient::ports.

Here is the call graph for this function:

handle_channel_create()

static void handle_channel_create ( void *  cls, const struct GNUNET_CADET_LocalChannelCreateMessage *  tcm  )

static

Handler for requests for us creating a new channel to another peer and port.

Parameters

cls	Identification of the client.
tcm	The actual message.

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

{
  struct CadetClient *c = cls;
  struct CadetChannel *ch;
 
  if (ntohl (tcm->ccn.channel_of_client) < GNUNET_CADET_LOCAL_CHANNEL_ID_CLI)
  {
    /* Channel ID not in allowed range. */
    LOG (GNUNET_ERROR_TYPE_DEBUG,"Channel ID not in allowed range.");
    GNUNET_break (0);
    GNUNET_SERVICE_client_drop (c->client);
    return;
  }
  ch = lookup_channel (c,
                       tcm->ccn);
  if (NULL != ch)
  {
    /* Channel ID already in use. Not allowed. */
    LOG (GNUNET_ERROR_TYPE_DEBUG,"Channel ID already in use. Not allowed.");
    GNUNET_break (0);
    GNUNET_SERVICE_client_drop (c->client);
    return;
  }
  LOG (GNUNET_ERROR_TYPE_DEBUG,
       "New channel to %s at port %s requested by %s\n",
       GNUNET_i2s (&tcm->peer),
       GNUNET_h2s (&tcm->port),
       GSC_2s (c));
 
  /* Create channel */
  ch = GCCH_channel_local_new (c,
                               tcm->ccn,
                               GCP_get (&tcm->peer,
                                        GNUNET_YES),
                               &tcm->port,
                               ntohl (tcm->opt));
  if (NULL == ch)
  {
    GNUNET_break (0);
    GNUNET_SERVICE_client_drop (c->client);
    return;
  }
  GNUNET_assert (GNUNET_YES ==
                 GNUNET_CONTAINER_multihashmap32_put (c->channels,
                                                      ntohl (
                                                        tcm->ccn.
                                                        channel_of_client),
                                                      ch,
                                                      GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_ONLY));
 
  GNUNET_SERVICE_client_continue (c->client);
}

References GNUNET_CADET_LocalChannelCreateMessage::ccn, ch, GNUNET_CADET_ClientChannelNumber::channel_of_client, CadetClient::channels, CadetClient::client, GCCH_channel_local_new(), GCP_get(), GNUNET_assert, GNUNET_break, GNUNET_CADET_LOCAL_CHANNEL_ID_CLI, GNUNET_CONTAINER_multihashmap32_put(), GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_ONLY, GNUNET_ERROR_TYPE_DEBUG, GNUNET_h2s(), GNUNET_i2s(), GNUNET_SERVICE_client_continue(), GNUNET_SERVICE_client_drop(), GNUNET_YES, GSC_2s(), LOG, lookup_channel(), GNUNET_CADET_LocalChannelCreateMessage::opt, GNUNET_CADET_LocalChannelCreateMessage::peer, and GNUNET_CADET_LocalChannelCreateMessage::port.

Here is the call graph for this function:

handle_channel_destroy()

static void handle_channel_destroy ( void *  cls, const struct GNUNET_CADET_LocalChannelDestroyMessage *  msg  )

static

Handler for requests of destroying an existing channel.

Parameters

cls	client identification of the client
msg	the actual message

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

{
  struct CadetClient *c = cls;
  struct CadetChannel *ch;
 
  ch = lookup_channel (c,
                       msg->ccn);
  if (NULL == ch)
  {
    /* Client attempted to destroy unknown channel.
       Can happen if the other side went down at the same time.*/
    LOG (GNUNET_ERROR_TYPE_DEBUG,
         "%s tried to destroy unknown channel %X\n",
         GSC_2s (c),
         (uint32_t) ntohl (msg->ccn.channel_of_client));
    GNUNET_SERVICE_client_continue (c->client);
    return;
  }
  LOG (GNUNET_ERROR_TYPE_DEBUG,
       "%s is destroying %s\n",
       GSC_2s (c),
       GCCH_2s (ch));
  GNUNET_assert (GNUNET_YES ==
                 GNUNET_CONTAINER_multihashmap32_remove (c->channels,
                                                         ntohl (
                                                           msg->ccn.
                                                           channel_of_client),
                                                         ch));
  GCCH_channel_local_destroy (ch,
                              c,
                              msg->ccn);
  GNUNET_SERVICE_client_continue (c->client);
}

References ch, CadetClient::channels, CadetClient::client, GCCH_2s(), GCCH_channel_local_destroy(), GNUNET_assert, GNUNET_CONTAINER_multihashmap32_remove(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_SERVICE_client_continue(), GNUNET_YES, GSC_2s(), LOG, lookup_channel(), and msg.

Here is the call graph for this function:

check_local_data()

static int check_local_data ( void *  cls, const struct GNUNET_CADET_LocalData *  msg  )

static

Check for client traffic data message is well-formed.

Parameters

cls	identification of the client
msg	the actual message

Returns

GNUNET_OK if msg is OK, GNUNET_SYSERR if not

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

{
  size_t payload_size;
  size_t payload_claimed_size;
  const char *buf;
  struct GNUNET_MessageHeader pa;
 
  /* FIXME: what is the format we shall allow for @a msg?
     ONE payload item or multiple? Seems current cadet_api
     at least in theory allows more than one. Next-gen
     cadet_api will likely no more, so we could then
     simplify this mess again. *//* Sanity check for message size */payload_size = ntohs (msg->header.size) - sizeof(*msg);
  buf = (const char *) &msg[1];
  while (payload_size >= sizeof(struct GNUNET_MessageHeader))
  {
    /* need to memcpy() for alignment */
    GNUNET_memcpy (&pa,
                   buf,
                   sizeof(pa));
    payload_claimed_size = ntohs (pa.size);
    if ((payload_size < payload_claimed_size) ||
        (payload_claimed_size < sizeof(struct GNUNET_MessageHeader)) ||
        (GNUNET_CONSTANTS_MAX_CADET_MESSAGE_SIZE < payload_claimed_size))
    {
      GNUNET_break (0);
      LOG (GNUNET_ERROR_TYPE_DEBUG,
           "Local data of %u total size had sub-message %u at %u with %u bytes\n",
           ntohs (msg->header.size),
           ntohs (pa.type),
           (unsigned int) (buf - (const char *) &msg[1]),
           (unsigned int) payload_claimed_size);
      return GNUNET_SYSERR;
    }
    payload_size -= payload_claimed_size;
    buf += payload_claimed_size;
  }
  if (0 != payload_size)
  {
    GNUNET_break_op (0);
    return GNUNET_SYSERR;
  }
  return GNUNET_OK;
}

References GNUNET_break, GNUNET_break_op, GNUNET_CONSTANTS_MAX_CADET_MESSAGE_SIZE, GNUNET_ERROR_TYPE_DEBUG, GNUNET_memcpy, GNUNET_OK, GNUNET_SYSERR, LOG, msg, GNUNET_MessageHeader::size, and GNUNET_MessageHeader::type.

handle_local_data()

static void handle_local_data ( void *  cls, const struct GNUNET_CADET_LocalData *  msg  )

static

Handler for client payload traffic to be send on a channel to another peer.

Parameters

cls	identification of the client
msg	the actual message

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

{
  struct CadetClient *c = cls;
  struct CadetChannel *ch;
  size_t payload_size;
  const char *buf;
 
  ch = lookup_channel (c,
                       msg->ccn);
  if (NULL == ch)
  {
    /* Channel does not exist (anymore) */
    LOG (GNUNET_ERROR_TYPE_WARNING,
         "Dropping payload for channel %u from client (channel unknown, other endpoint may have disconnected)\n",
         (unsigned int) ntohl (msg->ccn.channel_of_client));
    GNUNET_SERVICE_client_continue (c->client);
    return;
  }
  payload_size = ntohs (msg->header.size) - sizeof(*msg);
  GNUNET_STATISTICS_update (stats,
                            "# payload received from clients",
                            payload_size,
                            GNUNET_NO);
  buf = (const char *) &msg[1];
  LOG (GNUNET_ERROR_TYPE_DEBUG,
       "Received %u bytes payload from %s for %s\n",
       (unsigned int) payload_size,
       GSC_2s (c),
       GCCH_2s (ch));
  if (GNUNET_OK !=
      GCCH_handle_local_data (ch,
                              msg->ccn,
                              buf,
                              payload_size))
  {
    GNUNET_break (0);
    GNUNET_SERVICE_client_drop (c->client);
    return;
  }
  GNUNET_SERVICE_client_continue (c->client);
}

References ch, CadetClient::client, GCCH_2s(), GCCH_handle_local_data(), GNUNET_break, GNUNET_ERROR_TYPE_DEBUG, GNUNET_ERROR_TYPE_WARNING, GNUNET_NO, GNUNET_OK, GNUNET_SERVICE_client_continue(), GNUNET_SERVICE_client_drop(), GNUNET_STATISTICS_update(), GSC_2s(), LOG, lookup_channel(), msg, GNUNET_MessageHeader::size, and stats.

Here is the call graph for this function:

handle_local_ack()

static void handle_local_ack ( void *  cls, const struct GNUNET_CADET_LocalAck *  msg  )

static

Handler for client's ACKs for payload traffic.

Parameters

cls	identification of the client.
msg	The actual message.

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

{
  struct CadetClient *c = cls;
  struct CadetChannel *ch;
 
  ch = lookup_channel (c,
                       msg->ccn);
  if (NULL == ch)
  {
    /* Channel does not exist (anymore) */
    LOG (GNUNET_ERROR_TYPE_WARNING,
         "Ignoring local ACK for channel %u from client (channel unknown, other endpoint may have disconnected)\n",
         (unsigned int) ntohl (msg->ccn.channel_of_client));
    GNUNET_SERVICE_client_continue (c->client);
    return;
  }
  LOG (GNUNET_ERROR_TYPE_DEBUG,
       "Got a local ACK from %s for %s\n",
       GSC_2s (c),
       GCCH_2s (ch));
  GCCH_handle_local_ack (ch,
                         msg->ccn);
  GNUNET_SERVICE_client_continue (c->client);
}

References ch, CadetClient::client, GCCH_2s(), GCCH_handle_local_ack(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_ERROR_TYPE_WARNING, GNUNET_SERVICE_client_continue(), GSC_2s(), LOG, lookup_channel(), and msg.

Here is the call graph for this function:

get_all_peers_iterator()

static int get_all_peers_iterator ( void *  cls, const struct GNUNET_PeerIdentity *  peer, void *  value  )

static

Iterator over all peers to send a monitoring client info about each peer.

Parameters

cls	Closure ().
peer	Peer ID (tunnel remote peer).
value	Peer info.

Returns

GNUNET_YES, to keep iterating.

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

{
  struct CadetClient *c = cls;
  struct CadetPeer *p = value;
  struct GNUNET_MQ_Envelope *env;
  struct GNUNET_CADET_LocalInfoPeers *msg;
 
  env = GNUNET_MQ_msg (msg,
                       GNUNET_MESSAGE_TYPE_CADET_LOCAL_INFO_PEERS);
  msg->destination = *peer;
  msg->paths = htons (GCP_count_paths (p));
  msg->tunnel = htons (NULL != GCP_get_tunnel (p,
                                               GNUNET_NO));
  msg->best_path_length = htonl (0);  // FIXME: get length of shortest known path!
  GNUNET_MQ_send (c->mq,
                  env);
  return GNUNET_YES;
}

References env, GCP_count_paths(), GCP_get_tunnel(), GNUNET_MESSAGE_TYPE_CADET_LOCAL_INFO_PEERS, GNUNET_MQ_msg, GNUNET_MQ_send(), GNUNET_NO, GNUNET_YES, CadetClient::mq, msg, p, and value.

Referenced by handle_get_peers().

Here is the call graph for this function:

Here is the caller graph for this function:

handle_get_peers()

static void handle_get_peers ( void *  cls, const struct GNUNET_MessageHeader *  message  )

static

Handler for client's INFO PEERS request.

Parameters

cls	Identification of the client.
message	The actual message.

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

{
  struct CadetClient *c = cls;
  struct GNUNET_MQ_Envelope *env;
  struct GNUNET_MessageHeader *reply;
 
  GCP_iterate_all (&get_all_peers_iterator,
                   c);
  env = GNUNET_MQ_msg (reply,
                       GNUNET_MESSAGE_TYPE_CADET_LOCAL_INFO_PEERS_END);
  GNUNET_MQ_send (c->mq,
                  env);
  GNUNET_SERVICE_client_continue (c->client);
}

References CadetClient::client, env, GCP_iterate_all(), get_all_peers_iterator(), GNUNET_MESSAGE_TYPE_CADET_LOCAL_INFO_PEERS_END, GNUNET_MQ_msg, GNUNET_MQ_send(), GNUNET_SERVICE_client_continue(), and CadetClient::mq.

Here is the call graph for this function:

path_info_iterator()

static int path_info_iterator ( void *  cls, struct CadetPeerPath *  path, unsigned int  off  )

static

Iterator over all paths of a peer to build an InfoPeer message.

Message contains blocks of peers, first not included.

Parameters

cls	message queue for transmission
path	Path itself
off	offset of the peer on path

Returns

GNUNET_YES if should keep iterating. GNUNET_NO otherwise.

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

{
  struct GNUNET_MQ_Handle *mq = cls;
  struct GNUNET_MQ_Envelope *env;
  struct GNUNET_CADET_LocalInfoPath *resp;
  struct GNUNET_PeerIdentity *id;
  size_t path_size;
  unsigned int path_length;
 
  path_length = GCPP_get_length (path);
  path_size = sizeof(struct GNUNET_PeerIdentity) * path_length;
  if (sizeof(*resp) + path_size > UINT16_MAX)
  {
    /* try just giving the relevant path */
    path_length = GNUNET_MIN ((UINT16_MAX - sizeof(*resp)) / sizeof(struct
                                                                    GNUNET_PeerIdentity),
                              off);
    path_size = sizeof(struct GNUNET_PeerIdentity) * path_length;
  }
  if (sizeof(*resp) + path_size > UINT16_MAX)
  {
    LOG (GNUNET_ERROR_TYPE_WARNING,
         "Path of %u entries is too long for info message\n",
         path_length);
    return GNUNET_YES;
  }
  env = GNUNET_MQ_msg_extra (resp,
                             path_size,
                             GNUNET_MESSAGE_TYPE_CADET_LOCAL_INFO_PATH);
  id = (struct GNUNET_PeerIdentity *) &resp[1];
 
  /* Don't copy first peer.  First peer is always the local one.  Last
   * peer is always the destination (leave as 0, EOL).
   */
  for (unsigned int i = 0; i < path_length; i++)
    id[i] = *GCP_get_id (GCPP_get_peer_at_offset (path,
                                                  i));
  resp->off = htonl (off);
  GNUNET_MQ_send (mq,
                  env);
  return GNUNET_YES;
}

References env, GCP_get_id(), GCPP_get_length(), GCPP_get_peer_at_offset(), GNUNET_ERROR_TYPE_WARNING, GNUNET_MESSAGE_TYPE_CADET_LOCAL_INFO_PATH, GNUNET_MIN, GNUNET_MQ_msg_extra, GNUNET_MQ_send(), GNUNET_YES, id, LOG, mq, and GNUNET_CADET_LocalInfoPath::off.

Referenced by handle_show_path().

Here is the call graph for this function:

Here is the caller graph for this function:

handle_show_path()

static void handle_show_path ( void *  cls, const struct GNUNET_CADET_RequestPathInfoMessage *  msg  )

static

Handler for client's GNUNET_MESSAGE_TYPE_CADET_LOCAL_REQUEST_INFO_PATH request.

Parameters

cls	Identification of the client.
msg	The actual message.

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

{
  struct CadetClient *c = cls;
  struct CadetPeer *p;
  struct GNUNET_MQ_Envelope *env;
  struct GNUNET_MessageHeader *resp;
 
  p = GCP_get (&msg->peer,
               GNUNET_NO);
  if (NULL != p)
    GCP_iterate_indirect_paths (p,
                                &path_info_iterator,
                                c->mq);
  env = GNUNET_MQ_msg (resp,
                       GNUNET_MESSAGE_TYPE_CADET_LOCAL_INFO_PATH_END);
  GNUNET_MQ_send (c->mq,
                  env);
  GNUNET_SERVICE_client_continue (c->client);
}

References CadetClient::client, env, GCP_get(), GCP_iterate_indirect_paths(), GNUNET_MESSAGE_TYPE_CADET_LOCAL_INFO_PATH_END, GNUNET_MQ_msg, GNUNET_MQ_send(), GNUNET_NO, GNUNET_SERVICE_client_continue(), CadetClient::mq, msg, p, and path_info_iterator().

Here is the call graph for this function:

get_all_tunnels_iterator()

static int get_all_tunnels_iterator ( void *  cls, const struct GNUNET_PeerIdentity *  peer, void *  value  )

static

Iterator over all tunnels to send a monitoring client info about each tunnel.

Parameters

cls	Closure ().
peer	Peer ID (tunnel remote peer).
value	a struct CadetPeer

Returns

GNUNET_YES, to keep iterating.

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

{
  struct CadetClient *c = cls;
  struct CadetPeer *p = value;
  struct GNUNET_MQ_Envelope *env;
  struct GNUNET_CADET_LocalInfoTunnel *msg;
  struct CadetTunnel *t;
 
  t = GCP_get_tunnel (p,
                      GNUNET_NO);
  if (NULL == t)
    return GNUNET_YES;
  env = GNUNET_MQ_msg (msg,
                       GNUNET_MESSAGE_TYPE_CADET_LOCAL_INFO_TUNNELS);
  msg->destination = *peer;
  msg->channels = htonl (GCT_count_channels (t));
  msg->connections = htonl (GCT_count_any_connections (t));
  msg->cstate = htons (0);
  msg->estate = htons (GCT_get_estate (t));
  GNUNET_MQ_send (c->mq,
                  env);
  return GNUNET_YES;
}

References env, GCP_get_tunnel(), GCT_count_any_connections(), GCT_count_channels(), GCT_get_estate(), GNUNET_MESSAGE_TYPE_CADET_LOCAL_INFO_TUNNELS, GNUNET_MQ_msg, GNUNET_MQ_send(), GNUNET_NO, GNUNET_YES, CadetClient::mq, msg, p, t, and value.

Referenced by handle_info_tunnels().

Here is the call graph for this function:

Here is the caller graph for this function:

handle_info_tunnels()

static void handle_info_tunnels ( void *  cls, const struct GNUNET_MessageHeader *  message  )

static

Handler for client's GNUNET_MESSAGE_TYPE_CADET_LOCAL_REQUEST_INFO_TUNNELS request.

Parameters

cls	client Identification of the client.
message	The actual message.

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

{
  struct CadetClient *c = cls;
  struct GNUNET_MQ_Envelope *env;
  struct GNUNET_MessageHeader *reply;
 
  GCP_iterate_all (&get_all_tunnels_iterator,
                   c);
  env = GNUNET_MQ_msg (reply,
                       GNUNET_MESSAGE_TYPE_CADET_LOCAL_INFO_TUNNELS_END);
  GNUNET_MQ_send (c->mq,
                  env);
  GNUNET_SERVICE_client_continue (c->client);
}

References CadetClient::client, env, GCP_iterate_all(), get_all_tunnels_iterator(), GNUNET_MESSAGE_TYPE_CADET_LOCAL_INFO_TUNNELS_END, GNUNET_MQ_msg, GNUNET_MQ_send(), GNUNET_SERVICE_client_continue(), and CadetClient::mq.

Here is the call graph for this function:

handle_drop_message()

static void handle_drop_message ( void *  cls, const struct GNUNET_CADET_RequestDropCadetMessage *  message  )

static

Handler for client's GNUNET_MESSAGE_TYPE_CADET_DROP_CADET_MESSAGE request.

Parameters

cls	client Identification of the client.
message	The actual message.

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

{
  struct CadetClient *c = cls;
  struct CadetChannel *ch;
 
  ch = lookup_channel (c,
                       message->ccn);
 
  if (NULL != ch)
    GCCH_assign_type_to_drop (ch, message);
 
  GNUNET_SERVICE_client_continue (c->client);
}

References GNUNET_CADET_RequestDropCadetMessage::ccn, ch, CadetClient::client, GCCH_assign_type_to_drop(), GNUNET_SERVICE_client_continue(), and lookup_channel().

Here is the call graph for this function:

client_connect_cb()

static void * client_connect_cb ( void *  cls, struct GNUNET_SERVICE_Client *  client, struct GNUNET_MQ_Handle *  mq  )

static

Callback called when a client connects to the service.

Parameters

cls	closure for the service
client	the new client that connected to the service
mq	the message queue used to send messages to the client

Returns

c

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

{
  struct CadetClient *c;
 
  c = GNUNET_new (struct CadetClient);
  c->client = client;
  c->mq = mq;
  c->id = next_client_id++; /* overflow not important: just for debug */
  c->channels
    = GNUNET_CONTAINER_multihashmap32_create (32);
  GNUNET_CONTAINER_DLL_insert (clients_head,
                               clients_tail,
                               c);
  GNUNET_STATISTICS_update (stats,
                            "# clients",
                            +1,
                            GNUNET_NO);
  LOG (GNUNET_ERROR_TYPE_DEBUG,
       "%s connected\n",
       GSC_2s (c));
  return c;
}

References CadetClient::channels, CadetClient::client, clients_head, clients_tail, GNUNET_CONTAINER_DLL_insert, GNUNET_CONTAINER_multihashmap32_create(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_new, GNUNET_NO, GNUNET_STATISTICS_update(), GSC_2s(), CadetClient::id, LOG, mq, CadetClient::mq, next_client_id, and stats.

Here is the call 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 1107 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 1129 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:

channel_destroy_iterator()

static int channel_destroy_iterator ( void *  cls, uint32_t  key, void *  value  )

static

Iterator for deleting each channel whose client endpoint disconnected.

Parameters

cls	Closure (client that has disconnected).
key	The local channel id in host byte order
value	The value stored at the key (channel to destroy).

Returns

GNUNET_OK, keep iterating.

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

{
  struct CadetClient *c = cls;
  struct GNUNET_CADET_ClientChannelNumber ccn;
  struct CadetChannel *ch = value;
 
  LOG (GNUNET_ERROR_TYPE_DEBUG,
       "Destroying %s, due to %s disconnecting.\n",
       GCCH_2s (ch),
       GSC_2s (c));
  ccn.channel_of_client = htonl (key);
  GNUNET_assert (GNUNET_YES ==
                 GNUNET_CONTAINER_multihashmap32_remove (c->channels,
                                                         key,
                                                         ch));
  GCCH_channel_local_destroy (ch,
                              c,
                              ccn);
  return GNUNET_OK;
}

References ch, GNUNET_CADET_ClientChannelNumber::channel_of_client, CadetClient::channels, GCCH_2s(), GCCH_channel_local_destroy(), GNUNET_assert, GNUNET_CONTAINER_multihashmap32_remove(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_OK, GNUNET_YES, GSC_2s(), key, LOG, and value.

Referenced by client_disconnect_cb().

Here is the call graph for this function:

Here is the caller graph for this function:

client_release_ports()

static int client_release_ports ( void *  cls, const struct GNUNET_HashCode *  port, void *  value  )

static

Remove client's ports from the global hashmap on disconnect.

Parameters

cls	the struct CadetClient
port	the port.
value	the struct OpenPort to remove

Returns

GNUNET_OK, keep iterating.

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

{
  struct CadetClient *c = cls;
  struct OpenPort *op = value;
 
  GNUNET_assert (c == op->c);
  LOG (GNUNET_ERROR_TYPE_DEBUG,
       "Closing port %s due to %s disconnect.\n",
       GNUNET_h2s (port),
       GSC_2s (c));
  GNUNET_assert (GNUNET_YES ==
                 GNUNET_CONTAINER_multihashmap_remove (open_ports,
                                                       &op->h_port,
                                                       op));
  GNUNET_assert (GNUNET_YES ==
                 GNUNET_CONTAINER_multihashmap_remove (c->ports,
                                                       port,
                                                       op));
  GNUNET_free (op);
  return GNUNET_OK;
}

References OpenPort::c, GNUNET_assert, GNUNET_CONTAINER_multihashmap_remove(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_free, GNUNET_h2s(), GNUNET_OK, GNUNET_YES, GSC_2s(), LOG, op, open_ports, port, CadetClient::ports, and value.

Referenced by client_disconnect_cb().

Here is the call graph for this function:

Here is the caller graph for this function:

client_disconnect_cb()

static void client_disconnect_cb ( void *  cls, struct GNUNET_SERVICE_Client *  client, void *  internal_cls  )

static

Callback called when a client disconnected from the service.

Parameters

cls	closure for the service
client	the client that disconnected
internal_cls	should be equal to c

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

{
  struct CadetClient *c = internal_cls;
 
  GNUNET_assert (c->client == client);
  LOG (GNUNET_ERROR_TYPE_DEBUG,
       "%s is disconnecting.\n",
       GSC_2s (c));
  if (NULL != c->channels)
  {
    GNUNET_CONTAINER_multihashmap32_iterate (c->channels,
                                             &channel_destroy_iterator,
                                             c);
    GNUNET_assert (0 == GNUNET_CONTAINER_multihashmap32_size (c->channels));
    GNUNET_CONTAINER_multihashmap32_destroy (c->channels);
  }
  if (NULL != c->ports)
  {
    GNUNET_CONTAINER_multihashmap_iterate (c->ports,
                                           &client_release_ports,
                                           c);
    GNUNET_CONTAINER_multihashmap_destroy (c->ports);
  }
  GNUNET_CONTAINER_DLL_remove (clients_head,
                               clients_tail,
                               c);
  GNUNET_STATISTICS_update (stats,
                            "# clients",
                            -1,
                            GNUNET_NO);
  GNUNET_free (c);
  if ((NULL == clients_head) &&
      (GNUNET_YES == shutting_down))
    shutdown_rest ();
}

References channel_destroy_iterator(), CadetClient::channels, CadetClient::client, client_release_ports(), clients_head, clients_tail, GNUNET_assert, GNUNET_CONTAINER_DLL_remove, GNUNET_CONTAINER_multihashmap32_destroy(), GNUNET_CONTAINER_multihashmap32_iterate(), GNUNET_CONTAINER_multihashmap32_size(), GNUNET_CONTAINER_multihashmap_destroy(), GNUNET_CONTAINER_multihashmap_iterate(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_free, GNUNET_NO, GNUNET_STATISTICS_update(), GNUNET_YES, GSC_2s(), LOG, CadetClient::ports, shutdown_rest(), shutting_down, and stats.

Here is the call graph for this function:

run()

static void run ( void *  cls, const struct GNUNET_CONFIGURATION_Handle *  c, struct GNUNET_SERVICE_Handle *  service  )

static

Setup CADET internals.

Parameters

cls	closure
c	configuration to use

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

{
  cfg = c;
  if (GNUNET_OK !=
      GNUNET_CONFIGURATION_get_value_number (c,
                                             "CADET",
                                             "RATCHET_MESSAGES",
                                             &ratchet_messages))
  {
    GNUNET_log_config_invalid (GNUNET_ERROR_TYPE_WARNING,
                               "CADET",
                               "RATCHET_MESSAGES",
                               "needs to be a number");
    ratchet_messages = 64;
  }
  if (GNUNET_OK !=
      GNUNET_CONFIGURATION_get_value_time (c,
                                           "CADET",
                                           "RATCHET_TIME",
                                           &ratchet_time))
  {
    GNUNET_log_config_invalid (GNUNET_ERROR_TYPE_WARNING,
                               "CADET",
                               "RATCHET_TIME",
                               "need delay value");
    ratchet_time = GNUNET_TIME_UNIT_HOURS;
  }
  if (GNUNET_OK !=
      GNUNET_CONFIGURATION_get_value_time (c,
                                           "CADET",
                                           "REFRESH_CONNECTION_TIME",
                                           &keepalive_period))
  {
    GNUNET_log_config_invalid (GNUNET_ERROR_TYPE_WARNING,
                               "CADET",
                               "REFRESH_CONNECTION_TIME",
                               "need delay value");
    keepalive_period = GNUNET_TIME_UNIT_MINUTES;
  }
  if (GNUNET_OK !=
      GNUNET_CONFIGURATION_get_value_number (c,
                                             "CADET",
                                             "DROP_PERCENT",
                                             &drop_percent))
  {
    drop_percent = 0;
  }
  else
  {
    LOG (GNUNET_ERROR_TYPE_WARNING, "**************************************\n");
    LOG (GNUNET_ERROR_TYPE_WARNING, "Cadet is running with DROP enabled.\n");
    LOG (GNUNET_ERROR_TYPE_WARNING, "This is NOT a good idea!\n");
    LOG (GNUNET_ERROR_TYPE_WARNING, "Remove DROP_PERCENT from config file.\n");
    LOG (GNUNET_ERROR_TYPE_WARNING, "**************************************\n");
  }
  stats = GNUNET_STATISTICS_create ("cadet",
                                    c);
  GNUNET_SCHEDULER_add_shutdown (&shutdown_task,
                                 NULL);
  transport = GNUNET_TRANSPORT_application_init (c);
  /* FIXME: optimize code to allow GNUNET_YES here! */
  open_ports = GNUNET_CONTAINER_multihashmap_create (16,
                                                     GNUNET_NO);
  loose_channels = GNUNET_CONTAINER_multihashmap_create (16,
                                                         GNUNET_NO);
  peers = GNUNET_CONTAINER_multipeermap_create (16,
                                                GNUNET_YES);
  connections = GNUNET_CONTAINER_multishortmap_create (256,
                                                       GNUNET_YES);
  GCH_init (c);
  GCD_init (c);
  GCO_init (c);
  GNUNET_log (GNUNET_ERROR_TYPE_INFO,
              "CADET started for peer %s\n",
              GNUNET_i2s (GNUNET_PILS_get_identity (pils)));
}

References cfg, connections, drop_percent, GCD_init(), GCH_init(), GCO_init(), GNUNET_CONFIGURATION_get_value_number(), GNUNET_CONFIGURATION_get_value_time(), GNUNET_CONTAINER_multihashmap_create(), GNUNET_CONTAINER_multipeermap_create(), GNUNET_CONTAINER_multishortmap_create(), GNUNET_ERROR_TYPE_INFO, GNUNET_ERROR_TYPE_WARNING, GNUNET_i2s(), GNUNET_log, GNUNET_log_config_invalid(), GNUNET_NO, GNUNET_OK, GNUNET_PILS_get_identity(), GNUNET_SCHEDULER_add_shutdown(), GNUNET_STATISTICS_create(), GNUNET_TIME_UNIT_HOURS, GNUNET_TIME_UNIT_MINUTES, GNUNET_TRANSPORT_application_init(), GNUNET_YES, keepalive_period, LOG, loose_channels, open_ports, peers, pils, ratchet_messages, ratchet_time, shutdown_task, stats, and transport.

Here is the call graph for this function:

GNUNET_SERVICE_MAIN()

GNUNET_SERVICE_MAIN	(	GNUNET_OS_project_data_gnunet()	,
		"cadet"	,
		GNUNET_SERVICE_OPTION_NONE	,
		&	run,
		&	client_connect_cb,
		&	client_disconnect_cb,
		NULL	,
		GNUNET_MQ_hd_fixed_size(port_open, GNUNET_MESSAGE_TYPE_CADET_LOCAL_PORT_OPEN, struct GNUNET_CADET_PortMessage, NULL)	,
		GNUNET_MQ_hd_fixed_size(port_close, GNUNET_MESSAGE_TYPE_CADET_LOCAL_PORT_CLOSE, struct GNUNET_CADET_PortMessage, NULL)	,
		GNUNET_MQ_hd_fixed_size(channel_create, GNUNET_MESSAGE_TYPE_CADET_LOCAL_CHANNEL_CREATE, struct GNUNET_CADET_LocalChannelCreateMessage, NULL)	,
		GNUNET_MQ_hd_fixed_size(channel_destroy, GNUNET_MESSAGE_TYPE_CADET_LOCAL_CHANNEL_DESTROY, struct GNUNET_CADET_LocalChannelDestroyMessage, NULL)	,
		GNUNET_MQ_hd_var_size(local_data, GNUNET_MESSAGE_TYPE_CADET_LOCAL_DATA, struct GNUNET_CADET_LocalData, NULL)	,
		GNUNET_MQ_hd_fixed_size(local_ack, GNUNET_MESSAGE_TYPE_CADET_LOCAL_ACK, struct GNUNET_CADET_LocalAck, NULL)	,
		GNUNET_MQ_hd_fixed_size(get_peers, GNUNET_MESSAGE_TYPE_CADET_LOCAL_REQUEST_INFO_PEERS, struct GNUNET_MessageHeader, NULL)	,
		GNUNET_MQ_hd_fixed_size(show_path, GNUNET_MESSAGE_TYPE_CADET_LOCAL_REQUEST_INFO_PATH, struct GNUNET_CADET_RequestPathInfoMessage, NULL)	,
		GNUNET_MQ_hd_fixed_size(info_tunnels, GNUNET_MESSAGE_TYPE_CADET_LOCAL_REQUEST_INFO_TUNNELS, struct GNUNET_MessageHeader, NULL)	,
		GNUNET_MQ_hd_fixed_size(drop_message, GNUNET_MESSAGE_TYPE_CADET_DROP_CADET_MESSAGE, struct GNUNET_CADET_RequestDropCadetMessage, NULL)	,
		GNUNET_MQ_handler_end()
	)

Define "main" method using service macro.

Variable Documentation

cfg

const struct GNUNET_CONFIGURATION_Handle* cfg

Handle to our configuration.

Handle to our configuration.

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

Referenced by run().

stats

struct GNUNET_STATISTICS_Handle* stats

Handle to the statistics service.

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

Referenced by client_connect_cb(), client_disconnect_cb(), handle_local_data(), run(), and shutdown_rest().

transport

struct GNUNET_TRANSPORT_ApplicationHandle* transport

Handle to Transport service.

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

Referenced by consider_peer_activate(), GCP_set_hello(), run(), and shutdown_rest().

pils

struct GNUNET_PILS_Handle* pils

Handle to the pils service.

Handle to Pils service.

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

Referenced by handle_port_open(), and run().

shutting_down

int shutting_down

Signal that shutdown is happening: prevent recovery measures.

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

Referenced by client_disconnect_cb(), GCT_destroy_tunnel_now(), and shutdown_task().

clients_head

struct CadetClient* clients_head

static

DLL with all the clients, head.

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

Referenced by client_connect_cb(), client_disconnect_cb(), and shutdown_task().

clients_tail

struct CadetClient* clients_tail

static

DLL with all the clients, tail.

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

Referenced by client_connect_cb(), and client_disconnect_cb().

next_client_id

unsigned int next_client_id

static

Next ID to assign to a client.

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

Referenced by client_connect_cb().

open_ports

struct GNUNET_CONTAINER_MultiHashMap* open_ports

All ports clients of this peer have opened.

Maps from a hashed port to a struct OpenPort.

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

Referenced by client_release_ports(), GCCH_channel_incoming_new(), GCCH_channel_local_new(), handle_port_close(), handle_port_open(), run(), and shutdown_rest().

loose_channels

struct GNUNET_CONTAINER_MultiHashMap* loose_channels

Map from ports to channels where the ports were closed at the time we got the inbound connection.

Indexed by h_port, contains struct CadetChannel.

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

Referenced by bind_loose_channel(), GCCH_channel_incoming_new(), GCCH_channel_local_new(), GSC_drop_loose_channel(), handle_port_open(), run(), and shutdown_rest().

peers

struct GNUNET_CONTAINER_MultiPeerMap* peers

Map from PIDs to struct CadetPeer entries.

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

Referenced by cb_print_put_message(), check_n_peers_ready(), clients_notify_stream_peer(), collect_peers_cb(), collect_peers_info_cb(), destroy_peer(), GCP_destroy_all_peers(), GCP_get(), GCP_iterate_all(), GNUNET_CONSENSUS_create(), GNUNET_SECRETSHARING_create_session(), handle_client_seed(), handle_peer_pull_reply(), handle_view_update(), load_debug(), peer_info_ready_cb(), peers_ready_cb(), print_put_message(), run(), run(), send_stream_peers(), shutdown_rest(), test_master(), and test_run().

connections

struct GNUNET_CONTAINER_MultiShortmap* connections

Map from struct GNUNET_CADET_ConnectionTunnelIdentifier hash codes to struct CadetConnection objects.

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

Referenced by connection_create(), GCC_destroy(), GCC_lookup(), run(), and shutdown_rest().

ratchet_messages

unsigned long long ratchet_messages

How many messages are needed to trigger an AXOLOTL ratchet advance.

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

Referenced by run().

ratchet_time

struct GNUNET_TIME_Relative ratchet_time

How long until we trigger a ratched advance due to time.

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

Referenced by run(), t_ax_encrypt(), and update_ax_by_kx().

keepalive_period

struct GNUNET_TIME_Relative keepalive_period

How frequently do we send KEEPALIVE messages on idle connections?

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

Referenced by GCC_handle_connection_create_ack(), handle_connection_create(), keepalive_done(), manage_first_hop_mq(), run(), send_create_ack(), send_keepalive(), and timeout_cb().

drop_percent

unsigned long long drop_percent

Set to non-zero values to create random drops to test retransmissions.

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

Referenced by get_channel_weight(), run(), and should_I_drop().