gnunet-service-dht.c File Reference

GNUnet DHT service. More...

#include "platform.h"
#include "gnunet_block_lib.h"
#include "gnunet_util_lib.h"
#include "gnunet_transport_service.h"
#include "gnunet_transport_hello_service.h"
#include "gnunet_hello_lib.h"
#include "gnunet_dht_service.h"
#include "gnunet_statistics_service.h"
#include "gnunet-service-dht.h"
#include "gnunet-service-dht_datacache.h"
#include "gnunet-service-dht_hello.h"
#include "gnunet-service-dht_neighbours.h"
#include "gnunet-service-dht_nse.h"
#include "gnunet-service-dht_routing.h"
#include "gnunet-service-dht_clients.c"

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

Go to the source code of this file.

Functions
static void	process_hello (void *cls, const struct GNUNET_MessageHeader *message)
	Receive the HELLO from transport service, free current and replace if necessary. More...
static void	shutdown_task (void *cls)
	Task run during shutdown. More...
static void	run (void *cls, const struct GNUNET_CONFIGURATION_Handle *c, struct GNUNET_SERVICE_Handle *service)
	Process dht requests. More...
	GNUNET_SERVICE_MAIN ("dht", GNUNET_SERVICE_OPTION_NONE, &run, &client_connect_cb, &client_disconnect_cb, NULL, GNUNET_MQ_hd_var_size(dht_local_put, GNUNET_MESSAGE_TYPE_DHT_CLIENT_PUT, struct GNUNET_DHT_ClientPutMessage, NULL), GNUNET_MQ_hd_var_size(dht_local_get, GNUNET_MESSAGE_TYPE_DHT_CLIENT_GET, struct GNUNET_DHT_ClientGetMessage, NULL), GNUNET_MQ_hd_fixed_size(dht_local_get_stop, GNUNET_MESSAGE_TYPE_DHT_CLIENT_GET_STOP, struct GNUNET_DHT_ClientGetStopMessage, NULL), GNUNET_MQ_hd_fixed_size(dht_local_monitor, GNUNET_MESSAGE_TYPE_DHT_MONITOR_START, struct GNUNET_DHT_MonitorStartStopMessage, NULL), GNUNET_MQ_hd_fixed_size(dht_local_monitor_stop, GNUNET_MESSAGE_TYPE_DHT_MONITOR_STOP, struct GNUNET_DHT_MonitorStartStopMessage, NULL), GNUNET_MQ_hd_var_size(dht_local_get_result_seen, GNUNET_MESSAGE_TYPE_DHT_CLIENT_GET_RESULTS_KNOWN, struct GNUNET_DHT_ClientGetResultSeenMessage, NULL), GNUNET_MQ_handler_end())

Variables
struct GNUNET_MessageHeader *	GDS_my_hello
	Our HELLO. More...
static struct GNUNET_TRANSPORT_HelloGetHandle *	ghh
	Handle to get our current HELLO. More...
struct GNUNET_TIME_Relative	hello_expiration
	Hello address expiration. More...

Detailed Description

GNUnet DHT service.

Author

Christian Grothoff

Nathan Evans

Definition in file gnunet-service-dht.c.

Function Documentation

process_hello()

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

static

Receive the HELLO from transport service, free current and replace if necessary.

Parameters

cls	NULL
message	HELLO message of peer

Definition at line 69 of file gnunet-service-dht.c.

References GNUNET_free_non_null, GNUNET_malloc, GNUNET_memcpy, and GNUNET_MessageHeader::size.

Referenced by run().

{
  GNUNET_free_non_null(GDS_my_hello);
  GDS_my_hello = GNUNET_malloc(ntohs(message->size));
  GNUNET_memcpy(GDS_my_hello,
                message,
                ntohs(message->size));
}

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 86 of file gnunet-service-dht.c.

References GDS_block_context, GDS_CLIENTS_stop(), GDS_DATACACHE_done(), GDS_HELLO_done(), GDS_NEIGHBOURS_done(), GDS_NSE_done(), GDS_ROUTING_done(), GDS_stats, GNUNET_BLOCK_context_destroy(), GNUNET_free_non_null, GNUNET_STATISTICS_destroy(), GNUNET_TRANSPORT_hello_get_cancel(), and GNUNET_YES.

Referenced by run().

{
  if (NULL != ghh)
    {
      GNUNET_TRANSPORT_hello_get_cancel(ghh);
      ghh = NULL;
    }
  GDS_NEIGHBOURS_done();
  GDS_DATACACHE_done();
  GDS_ROUTING_done();
  GDS_HELLO_done();
  GDS_NSE_done();
  if (NULL != GDS_block_context)
    {
      GNUNET_BLOCK_context_destroy(GDS_block_context);
      GDS_block_context = NULL;
    }
  if (NULL != GDS_stats)
    {
      GNUNET_STATISTICS_destroy(GDS_stats,
                                GNUNET_YES);
      GDS_stats = NULL;
    }
  GNUNET_free_non_null(GDS_my_hello);
  GDS_my_hello = NULL;
  GDS_CLIENTS_stop();
}

Here is the call graph for this function:

Here is the caller graph for this function:

run()

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

static

Process dht requests.

Parameters

cls	closure
c	configuration to use
service	the initialized service

Definition at line 123 of file gnunet-service-dht.c.

References GDS_block_context, GDS_cfg, GDS_CLIENTS_init(), GDS_DATACACHE_init(), GDS_DHT_SERVICE_INIT, GDS_HELLO_init(), GDS_NEIGHBOURS_init(), GDS_NSE_init(), GDS_ROUTING_init(), GDS_service, GDS_stats, GNUNET_BLOCK_context_create(), GNUNET_CONFIGURATION_get_value_time(), GNUNET_CONSTANTS_HELLO_ADDRESS_EXPIRATION, GNUNET_OK, GNUNET_SCHEDULER_add_shutdown(), GNUNET_SERVICE_suspend(), GNUNET_STATISTICS_create(), GNUNET_TRANSPORT_AC_GLOBAL, GNUNET_TRANSPORT_hello_get(), hello_expiration, process_hello(), service, and shutdown_task().

{
  GDS_cfg = c;
  GDS_service = service;
  if (GNUNET_OK !=
      GNUNET_CONFIGURATION_get_value_time(c,
                                          "transport",
                                          "HELLO_EXPIRATION",
                                          &hello_expiration))
    {
      hello_expiration = GNUNET_CONSTANTS_HELLO_ADDRESS_EXPIRATION;
    }
  GDS_block_context = GNUNET_BLOCK_context_create(GDS_cfg);
  GDS_stats = GNUNET_STATISTICS_create("dht",
                                       GDS_cfg);
  GNUNET_SERVICE_suspend(GDS_service);
  GDS_CLIENTS_init();
  GDS_ROUTING_init();
  GDS_NSE_init();
  GDS_DATACACHE_init();
  GDS_HELLO_init();
  if (GNUNET_OK != GDS_NEIGHBOURS_init())
    {
      shutdown_task(NULL);
      return;
    }
  GNUNET_SCHEDULER_add_shutdown(&shutdown_task,
                                NULL);
  ghh = GNUNET_TRANSPORT_hello_get(GDS_cfg,
                                   GNUNET_TRANSPORT_AC_GLOBAL,
                                   &process_hello,
                                   NULL);
}

Here is the call graph for this function:

GNUNET_SERVICE_MAIN()

GNUNET_SERVICE_MAIN	(	"dht"	,
		GNUNET_SERVICE_OPTION_NONE	,
		&	run,
		&	client_connect_cb,
		&	client_disconnect_cb,
		NULL	,
		GNUNET_MQ_hd_var_size(dht_local_put, GNUNET_MESSAGE_TYPE_DHT_CLIENT_PUT, struct GNUNET_DHT_ClientPutMessage, NULL)	,
		GNUNET_MQ_hd_var_size(dht_local_get, GNUNET_MESSAGE_TYPE_DHT_CLIENT_GET, struct GNUNET_DHT_ClientGetMessage, NULL)	,
		GNUNET_MQ_hd_fixed_size(dht_local_get_stop, GNUNET_MESSAGE_TYPE_DHT_CLIENT_GET_STOP, struct GNUNET_DHT_ClientGetStopMessage, NULL)	,
		GNUNET_MQ_hd_fixed_size(dht_local_monitor, GNUNET_MESSAGE_TYPE_DHT_MONITOR_START, struct GNUNET_DHT_MonitorStartStopMessage, NULL)	,
		GNUNET_MQ_hd_fixed_size(dht_local_monitor_stop, GNUNET_MESSAGE_TYPE_DHT_MONITOR_STOP, struct GNUNET_DHT_MonitorStartStopMessage, NULL)	,
		GNUNET_MQ_hd_var_size(dht_local_get_result_seen, GNUNET_MESSAGE_TYPE_DHT_CLIENT_GET_RESULTS_KNOWN, struct GNUNET_DHT_ClientGetResultSeenMessage, NULL)	,
		GNUNET_MQ_handler_end()
	)

Variable Documentation

GDS_my_hello

struct GNUNET_MessageHeader* GDS_my_hello

Our HELLO.

Definition at line 45 of file gnunet-service-dht.c.

Referenced by handle_find_peer().

ghh

struct GNUNET_TRANSPORT_HelloGetHandle* ghh

static

Handle to get our current HELLO.

Definition at line 50 of file gnunet-service-dht.c.

Referenced by GNUNET_TRANSPORT_hello_get(), and handle_hello().

hello_expiration

struct GNUNET_TIME_Relative hello_expiration

Hello address expiration.

Definition at line 55 of file gnunet-service-dht.c.

Referenced by run().