cadet service; interaction with CORE service More...

#include "gnunet_util_lib.h"

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

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

Functions
void	GCO_init (const struct GNUNET_CONFIGURATION_Handle *c)
	Initialize the CORE subsystem. More...

void	GCO_shutdown (void)
	Shut down the CORE subsystem. More...

Detailed Description

cadet service; interaction with CORE service

Author: Bartlomiej Polot; Christian Grothoff

All functions in this file should use the prefix GCO (Gnunet Cadet cOre (bottom))

Definition in file gnunet-service-cadet_core.h.

Function Documentation

◆ GCO_init()

void GCO_init ( const struct GNUNET_CONFIGURATION_Handle * c )

Initialize the CORE subsystem.

Parameters

c	Configuration.

Definition at line 1262 of file gnunet-service-cadet_core.c.

 {
   struct GNUNET_MQ_MessageHandler handlers[] =
   { GNUNET_MQ_hd_var_size (connection_create,
                            GNUNET_MESSAGE_TYPE_CADET_CONNECTION_CREATE,
                            struct GNUNET_CADET_ConnectionCreateMessage,
                            NULL),
     GNUNET_MQ_hd_fixed_size (connection_create_ack,
                              GNUNET_MESSAGE_TYPE_CADET_CONNECTION_CREATE_ACK,
                              struct GNUNET_CADET_ConnectionCreateAckMessage,
                              NULL),
     GNUNET_MQ_hd_fixed_size (connection_broken,
                              GNUNET_MESSAGE_TYPE_CADET_CONNECTION_BROKEN,
                              struct GNUNET_CADET_ConnectionBrokenMessage,
                              NULL),
     GNUNET_MQ_hd_fixed_size (connection_destroy,
                              GNUNET_MESSAGE_TYPE_CADET_CONNECTION_DESTROY,
                              struct GNUNET_CADET_ConnectionDestroyMessage,
                              NULL),
     GNUNET_MQ_hd_fixed_size (tunnel_kx,
                              GNUNET_MESSAGE_TYPE_CADET_TUNNEL_KX,
                              struct GNUNET_CADET_TunnelKeyExchangeMessage,
                              NULL),
     GNUNET_MQ_hd_fixed_size (tunnel_kx_auth,
                              GNUNET_MESSAGE_TYPE_CADET_TUNNEL_KX_AUTH,
                              struct GNUNET_CADET_TunnelKeyExchangeAuthMessage,
                              NULL),
     GNUNET_MQ_hd_var_size (tunnel_encrypted,
                            GNUNET_MESSAGE_TYPE_CADET_TUNNEL_ENCRYPTED,
                            struct GNUNET_CADET_TunnelEncryptedMessage,
                            NULL),
     GNUNET_MQ_handler_end () };
  
   if (GNUNET_OK != GNUNET_CONFIGURATION_get_value_number (c,
                                                           "CADET",
                                                           "MAX_ROUTES",
                                                           &max_routes))
     max_routes = 5000;
   if (GNUNET_OK != GNUNET_CONFIGURATION_get_value_number (c,
                                                           "CADET",
                                                           "MAX_MSGS_QUEUE",
                                                           &max_buffers))
     max_buffers = 10000;
   routes = GNUNET_CONTAINER_multishortmap_create (1024, GNUNET_NO);
   route_heap = GNUNET_CONTAINER_heap_create (GNUNET_CONTAINER_HEAP_ORDER_MIN);
   core = GNUNET_CORE_connect (c,
                               NULL,
                               &core_init_cb,
                               &core_connect_cb,
                               &core_disconnect_cb,
                               handlers);
 }

References connection_create(), core, core_connect_cb(), core_disconnect_cb(), core_init_cb(), GNUNET_CONFIGURATION_get_value_number(), GNUNET_CONTAINER_heap_create(), GNUNET_CONTAINER_HEAP_ORDER_MIN, GNUNET_CONTAINER_multishortmap_create(), GNUNET_CORE_connect(), GNUNET_MESSAGE_TYPE_CADET_CONNECTION_BROKEN, GNUNET_MESSAGE_TYPE_CADET_CONNECTION_CREATE, GNUNET_MESSAGE_TYPE_CADET_CONNECTION_CREATE_ACK, GNUNET_MESSAGE_TYPE_CADET_CONNECTION_DESTROY, GNUNET_MESSAGE_TYPE_CADET_TUNNEL_ENCRYPTED, GNUNET_MESSAGE_TYPE_CADET_TUNNEL_KX, GNUNET_MESSAGE_TYPE_CADET_TUNNEL_KX_AUTH, GNUNET_MQ_handler_end, GNUNET_MQ_hd_fixed_size, GNUNET_MQ_hd_var_size, GNUNET_NO, GNUNET_OK, handlers, max_buffers, max_routes, route_heap, and routes.

Referenced by run().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GCO_shutdown()

void GCO_shutdown ( void )

Shut down the CORE subsystem.

Definition at line 1317 of file gnunet-service-cadet_core.c.

 {
   if (NULL != core)
   {
     GNUNET_CORE_disconnect (core);
     core = NULL;
   }
   GNUNET_assert (0 == GNUNET_CONTAINER_multishortmap_size (routes));
   GNUNET_CONTAINER_multishortmap_destroy (routes);
   routes = NULL;
   GNUNET_CONTAINER_heap_destroy (route_heap);
   route_heap = NULL;
   if (NULL != timeout_task)
   {
     GNUNET_SCHEDULER_cancel (timeout_task);
     timeout_task = NULL;
   }
 }

References core, GNUNET_assert, GNUNET_CONTAINER_heap_destroy(), GNUNET_CONTAINER_multishortmap_destroy(), GNUNET_CONTAINER_multishortmap_size(), GNUNET_CORE_disconnect(), GNUNET_SCHEDULER_cancel(), route_heap, routes, and timeout_task.