gnunet-service-dht.c File Reference

GNUnet DHT service. More...

#include "platform.h"
#include "gnunet_common.h"
#include "gnunet_block_lib.h"
#include "gnunet_util_lib.h"
#include "gnunet_hello_uri_lib.h"
#include "gnunet_statistics_service.h"
#include "gnunet-service-dht.h"
#include "gnunet-service-dht_datacache.h"
#include "gnunet-service-dht_neighbours.h"
#include "gnunet-service-dht_routing.h"
#include "plugin_dhtu_ip.h"
#include "plugin_dhtu_gnunet.h"
#include "gnunet-service-dht_clients.c"

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

Go to the source code of this file.

Data Structures
struct	GDS_Underlay
	Information we keep per underlay. More...
struct	MyAddress
	An address of this peer. More...

Macros
#define	HELLO_FREQUENCY   GNUNET_TIME_UNIT_HOURS
	How often do we broadcast our HELLO to neighbours if nothing special happens? More...

Functions
static void	update_network_size_estimate (void *cls, struct GNUNET_TIME_Absolute timestamp, double logestimate, double std_dev)
	Callback that is called when network size estimate is updated. More...
double	GDS_NSE_get (void)
	Return the current NSE. More...
static void	broadcast_hello (void *cls)
	Task run periodically to broadcast our HELLO. More...
static void	u_address_add (void *cls, const char *address, struct GNUNET_DHTU_Source *source, void **ctx)
	Function to call with new addresses of this peer. More...
static void	u_address_del (void *ctx)
	Function to call with expired addresses of this peer. More...
void	GDS_u_try_connect (const struct GNUNET_PeerIdentity *pid, const char *address)
	Ask all underlays to connect to peer pid at address. More...
void	GDS_u_send (struct GDS_Underlay *u, struct GNUNET_DHTU_Target *target, const void *msg, size_t msg_size, GNUNET_SCHEDULER_TaskCallback finished_cb, void *finished_cb_cls)
	Send message to some other participant over the network. More...
void	GDS_u_drop (struct GDS_Underlay *u, struct GNUNET_DHTU_PreferenceHandle *ph)
	Drop a hold ph from underlay u. More...
struct GNUNET_DHTU_PreferenceHandle *	GDS_u_hold (struct GDS_Underlay *u, struct GNUNET_DHTU_Target *target)
	Create a hold on target at underlay u. More...
static void	shutdown_task (void *cls)
	Task run during shutdown. More...
static void	load_underlay (void *cls, const char *section)
	Function iterating over all configuration sections. More...
static void	run (void *cls, const struct GNUNET_CONFIGURATION_Handle *c, struct GNUNET_SERVICE_Handle *service)
	Process dht requests. More...
	GNUNET_SERVICE_MAIN (GNUNET_OS_project_data_gnunet(), "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_hd_fixed_size(dht_local_hello_get, GNUNET_MESSAGE_TYPE_DHT_CLIENT_HELLO_GET, struct GNUNET_MessageHeader, NULL), GNUNET_MQ_hd_var_size(dht_local_hello_offer, GNUNET_MESSAGE_TYPE_DHT_CLIENT_HELLO_URL, struct GNUNET_MessageHeader, NULL), GNUNET_MQ_handler_end())

Variables
struct GNUNET_HELLO_Builder *	GDS_my_hello
	Our HELLO. More...
struct GNUNET_PeerIdentity	GDS_my_identity
	Identity of this peer. More...
struct GNUNET_HashCode	GDS_my_identity_hash
	Hash of the identity of this peer. More...
struct GNUNET_CRYPTO_EddsaPrivateKey	GDS_my_private_key
	Our private key. More...
static struct GNUNET_SCHEDULER_Task *	hello_task
	Task broadcasting our HELLO. More...
static struct GDS_Underlay *	u_head
	Handles for the DHT underlays. More...
static struct GDS_Underlay *	u_tail
	Handles for the DHT underlays. More...
static struct MyAddress *	a_head
	Head of addresses of this peer. More...
static struct MyAddress *	a_tail
	Tail of addresses of this peer. More...
static double	log_of_network_size_estimate
	log of the current network size estimate, used as the point where we switch between random and deterministic routing. More...

Detailed Description

GNUnet DHT service.

Author

Christian Grothoff

Nathan Evans

Definition in file gnunet-service-dht.c.

Macro Definition Documentation

HELLO_FREQUENCY

#define HELLO_FREQUENCY   GNUNET_TIME_UNIT_HOURS

How often do we broadcast our HELLO to neighbours if nothing special happens?

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

Function Documentation

update_network_size_estimate()

static void update_network_size_estimate ( void *  cls, struct GNUNET_TIME_Absolute  timestamp, double  logestimate, double  std_dev  )

static

Callback that is called when network size estimate is updated.

Parameters

cls	a struct GDS_Underlay
timestamp	time when the estimate was received from the server (or created by the server)
logestimate	the log(Base 2) value of the current network size estimate
std_dev	standard deviation for the estimate

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

{
  struct GDS_Underlay *u = cls;
  double sum = 0.0;
 
  GNUNET_STATISTICS_update (GDS_stats,
                            "# Network size estimates received",
                            1,
                            GNUNET_NO);
  /* do not allow estimates < 0.5 */
  u->network_size_estimate = pow (2.0,
                                  GNUNET_MAX (0.5,
                                              logestimate));
  for (struct GDS_Underlay *p = u_head; NULL != p; p = p->next)
    sum += p->network_size_estimate;
  if (sum <= 2.0)
    log_of_network_size_estimate = 0.5;
  else
    log_of_network_size_estimate = log2 (sum);
}

References GDS_stats, GNUNET_MAX, GNUNET_NO, GNUNET_STATISTICS_update(), log_of_network_size_estimate, p, u, and u_head.

Referenced by load_underlay().

Here is the call graph for this function:

Here is the caller graph for this function:

GDS_NSE_get()

double GDS_NSE_get

(

void

)

Return the current NSE.

Returns

the current NSE as a logarithm

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

{
  return log_of_network_size_estimate;
}

References log_of_network_size_estimate.

Referenced by get_forward_count(), handle_find_local_hello(), and select_peer().

Here is the caller graph for this function:

broadcast_hello()

static void broadcast_hello ( void *  cls )

static

Task run periodically to broadcast our HELLO.

Parameters

cls

NULL

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

{
  struct GNUNET_MessageHeader *hello;
 
  (void) cls;
  /* TODO: randomize! */
  hello_task = GNUNET_SCHEDULER_add_delayed (HELLO_FREQUENCY,
                                             &broadcast_hello,
                                             NULL);
  hello = GNUNET_HELLO_builder_to_dht_hello_msg (GDS_my_hello,
                                                 &GDS_my_private_key,
                                                 GNUNET_TIME_UNIT_ZERO);
  if (NULL == hello)
  {
    GNUNET_break (0);
    return;
  }
  GDS_NEIGHBOURS_broadcast (hello);
  GNUNET_free (hello);
}

References broadcast_hello(), GDS_my_hello, GDS_my_private_key, GDS_NEIGHBOURS_broadcast(), GNUNET_break, GNUNET_free, GNUNET_HELLO_builder_to_dht_hello_msg(), GNUNET_SCHEDULER_add_delayed(), GNUNET_TIME_UNIT_ZERO, HELLO_FREQUENCY, and hello_task.

Referenced by broadcast_hello(), u_address_add(), and u_address_del().

Here is the call graph for this function:

Here is the caller graph for this function:

u_address_add()

static void u_address_add ( void *  cls, const char *  address, struct GNUNET_DHTU_Source *  source, void **  ctx  )

static

Function to call with new addresses of this peer.

Parameters

	cls	the closure
	address	address under which we are likely reachable, pointer will remain valid until address_del_cb is called; to be used for HELLOs. Example: "ip+udp://$PID/1.1.1.1:2086/"
	source	handle for sending from this address, NULL if we can only receive
[out]	ctx	storage space for DHT to use in association with this address

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

{
  struct GDS_Underlay *u = cls;
  struct MyAddress *a;
  enum GNUNET_GenericReturnValue add_success;
 
  GNUNET_log (GNUNET_ERROR_TYPE_INFO,
              "Underlay adds address %s for this peer\n",
              address);
  if (GNUNET_OK != (add_success = GNUNET_HELLO_builder_add_address (
                      GDS_my_hello,
                      address)))
  {
    GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
                "Adding address `%s' from underlay %s\n",
                address,
                GNUNET_NO == add_success ? "not done" : "failed");
    return;
  }
  a = GNUNET_new (struct MyAddress);
  a->source = source;
  a->url = GNUNET_strdup (address);
  a->u = u;
  GNUNET_CONTAINER_DLL_insert (a_head,
                               a_tail,
                               a);
  *ctx = a;
 
  if (NULL != hello_task)
    GNUNET_SCHEDULER_cancel (hello_task);
  hello_task = GNUNET_SCHEDULER_add_now (&broadcast_hello,
                                         NULL);
}

References a_head, a_tail, address, broadcast_hello(), ctx, GDS_my_hello, GNUNET_CONTAINER_DLL_insert, GNUNET_ERROR_TYPE_INFO, GNUNET_ERROR_TYPE_WARNING, GNUNET_HELLO_builder_add_address(), GNUNET_log, GNUNET_new, GNUNET_NO, GNUNET_OK, GNUNET_SCHEDULER_add_now(), GNUNET_SCHEDULER_cancel(), GNUNET_strdup, hello_task, source, MyAddress::source, u, MyAddress::u, and MyAddress::url.

Referenced by load_underlay().

Here is the call graph for this function:

Here is the caller graph for this function:

u_address_del()

static void u_address_del ( void *  ctx )

static

Function to call with expired addresses of this peer.

Parameters

[in]

ctx

storage space used by the DHT in association with this address

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

{
  struct MyAddress *a = ctx;
 
  GNUNET_log (GNUNET_ERROR_TYPE_INFO,
              "Underlay deletes address %s for this peer\n",
              a->url);
  GNUNET_HELLO_builder_del_address (GDS_my_hello,
                                    a->url);
  GNUNET_CONTAINER_DLL_remove (a_head,
                               a_tail,
                               a);
  GNUNET_free (a->url);
  GNUNET_free (a);
  if (NULL != hello_task)
    GNUNET_SCHEDULER_cancel (hello_task);
  hello_task = GNUNET_SCHEDULER_add_now (&broadcast_hello,
                                         NULL);
}

References a_head, a_tail, broadcast_hello(), ctx, GDS_my_hello, GNUNET_CONTAINER_DLL_remove, GNUNET_ERROR_TYPE_INFO, GNUNET_free, GNUNET_HELLO_builder_del_address(), GNUNET_log, GNUNET_SCHEDULER_add_now(), GNUNET_SCHEDULER_cancel(), hello_task, and MyAddress::url.

Referenced by load_underlay().

Here is the call graph for this function:

Here is the caller graph for this function:

GDS_u_try_connect()

void GDS_u_try_connect	(	const struct GNUNET_PeerIdentity *	pid,
		const char *	address
	)

Ask all underlays to connect to peer pid at address.

Parameters

pid	identity of the peer we would connect to
address	an address of pid

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

{
  for (struct GDS_Underlay *u = u_head;
       NULL != u;
       u = u->next)
    u->dhtu->try_connect (u->dhtu->cls,
                          pid,
                          address);
}

References address, pid, u, and u_head.

Referenced by GDS_try_connect().

Here is the caller graph for this function:

GDS_u_send()

void GDS_u_send	(	struct GDS_Underlay *	u,
		struct GNUNET_DHTU_Target *	target,
		const void *	msg,
		size_t	msg_size,
		GNUNET_SCHEDULER_TaskCallback	finished_cb,
		void *	finished_cb_cls
	)

Send message to some other participant over the network.

Note that sending is not guaranteeing that the other peer actually received the message. For any given target, the DHT must wait for the finished_cb to be called before calling send() again.

Parameters

u	underlay to use for transmission
target	receiver identification
msg	message
msg_size	number of bytes in msg
finished_cb	function called once transmission is done (not called if target disconnects, then only the disconnect_cb is called).
finished_cb_cls	closure for finished_cb

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

{
  u->dhtu->send (u->dhtu->cls,
                 target,
                 msg,
                 msg_size,
                 finished_cb,
                 finished_cb_cls);
}

References finished_cb(), msg, and u.

Referenced by do_send().

Here is the call graph for this function:

Here is the caller graph for this function:

GDS_u_drop()

void GDS_u_drop	(	struct GDS_Underlay *	u,
		struct GNUNET_DHTU_PreferenceHandle *	ph
	)

Drop a hold ph from underlay u.

Parameters

u	the underlay controlling the hold
ph	the preference handle

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

{
  u->dhtu->drop (ph);
}

References u.

Referenced by GDS_u_disconnect().

Here is the caller graph for this function:

GDS_u_hold()

struct GNUNET_DHTU_PreferenceHandle * GDS_u_hold	(	struct GDS_Underlay *	u,
		struct GNUNET_DHTU_Target *	target
	)

Create a hold on target at underlay u.

Parameters

u	the underlay controlling the target
target	the peer to hold the connection to

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

{
  return u->dhtu->hold (u->dhtu->cls,
                        target);
}

References GNUNET_DHTU_PreferenceHandle::target, and u.

Referenced by update_hold().

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

{
  struct GDS_Underlay *u;
 
  while (NULL != (u = u_head))
  {
    GNUNET_CONTAINER_DLL_remove (u_head,
                                 u_tail,
                                 u);
    if (0 == strcmp (u->name, "gnunet"))
    {
      DHTU_gnunet_done (u->dhtu);
    }
#ifdef LINUX
    else if (0 == strcmp (u->name, "ip"))
    {
      DHTU_ip_done (u->dhtu);
    }
#endif
    else
    {
      GNUNET_assert (0);
    }
    GNUNET_free (u->name);
    GNUNET_free (u);
  }
  GDS_NEIGHBOURS_done ();
  GDS_DATACACHE_done ();
  GDS_ROUTING_done ();
  if (NULL != GDS_block_context)
  {
    GNUNET_BLOCK_context_destroy (GDS_block_context);
    GDS_block_context = NULL;
  }
  GDS_CLIENTS_stop ();
  if (NULL != GDS_stats)
  {
    GNUNET_STATISTICS_destroy (GDS_stats,
                               GNUNET_YES);
    GDS_stats = NULL;
  }
  if (NULL != GDS_my_hello)
  {
    GNUNET_HELLO_builder_free (GDS_my_hello);
    GDS_my_hello = NULL;
  }
  if (NULL != hello_task)
  {
    GNUNET_SCHEDULER_cancel (hello_task);
    hello_task = NULL;
  }
}

References DHTU_gnunet_done(), DHTU_ip_done(), GDS_block_context, GDS_CLIENTS_stop(), GDS_DATACACHE_done(), GDS_my_hello, GDS_NEIGHBOURS_done(), GDS_ROUTING_done(), GDS_stats, GNUNET_assert, GNUNET_BLOCK_context_destroy(), GNUNET_CONTAINER_DLL_remove, GNUNET_free, GNUNET_HELLO_builder_free(), GNUNET_SCHEDULER_cancel(), GNUNET_STATISTICS_destroy(), GNUNET_YES, hello_task, u, u_head, and u_tail.

Referenced by run().

Here is the call graph for this function:

Here is the caller graph for this function:

load_underlay()

static void load_underlay ( void *  cls, const char *  section  )

static

Function iterating over all configuration sections.

Loads plugins for enabled DHT underlays.

Parameters

cls	NULL
section	configuration section to inspect

NOTE: This is not pretty, but it allows us to avoid dynamically loading plugins

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

{
  struct GDS_Underlay *u;
 
  (void) cls;
  if (0 != strncasecmp (section,
                        "dhtu-",
                        strlen ("dhtu-")))
    return;
  if (GNUNET_YES !=
      GNUNET_CONFIGURATION_get_value_yesno (GDS_cfg,
                                            section,
                                            "ENABLED"))
    return;
  section += strlen ("dhtu-");
  u = GNUNET_new (struct GDS_Underlay);
  u->env.cls = u;
  u->env.cfg = GDS_cfg;
  u->env.address_add_cb = &u_address_add;
  u->env.address_del_cb = &u_address_del;
  u->env.network_size_cb = &update_network_size_estimate;
  u->env.connect_cb = &GDS_u_connect;
  u->env.disconnect_cb = &GDS_u_disconnect;
  u->env.receive_cb = &GDS_u_receive;
 
  if (0 == strcmp (section, "gnunet"))
  {
    u->dhtu = DHTU_gnunet_init (&u->env);
  }
#ifdef LINUX
  else if (0 == strcmp (section, "ip"))
  {
    u->dhtu = DHTU_ip_init (&u->env);
  }
#endif
  if (NULL == u->dhtu)
  {
    GNUNET_free (u);
    return;
  }
  u->name = GNUNET_strdup (section);
  GNUNET_CONTAINER_DLL_insert (u_head,
                               u_tail,
                               u);
}

References DHTU_gnunet_init(), DHTU_ip_init(), GDS_cfg, GDS_u_connect(), GDS_u_disconnect(), GDS_u_receive(), GNUNET_CONFIGURATION_get_value_yesno(), GNUNET_CONTAINER_DLL_insert, GNUNET_free, GNUNET_new, GNUNET_strdup, GNUNET_YES, u, u_address_add(), u_address_del(), u_head, u_tail, and update_network_size_estimate().

Referenced by run().

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

{
  GDS_cfg = c;
  GDS_service = service;
  {
    char *keyfile;
 
    if (GNUNET_OK !=
        GNUNET_CONFIGURATION_get_value_filename (GDS_cfg,
                                                 "PEER",
                                                 "PRIVATE_KEY",
                                                 &keyfile))
    {
      GNUNET_log_config_missing (GNUNET_ERROR_TYPE_ERROR,
                                 "PEER",
                                 "PRIVATE_KEY");
      GNUNET_SCHEDULER_shutdown ();
      return;
    }
    if (GNUNET_SYSERR ==
        GNUNET_CRYPTO_eddsa_key_from_file (keyfile,
                                           GNUNET_YES,
                                           &GDS_my_private_key))
    {
      GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                  "Failed to setup peer's private key\n");
      GNUNET_free (keyfile);
      GNUNET_SCHEDULER_shutdown ();
      return;
    }
    GNUNET_free (keyfile);
  }
  GNUNET_CRYPTO_eddsa_key_get_public (&GDS_my_private_key,
                                      &GDS_my_identity.public_key);
  GDS_my_hello = GNUNET_HELLO_builder_new (&GDS_my_identity);
  GNUNET_CRYPTO_hash (&GDS_my_identity,
                      sizeof(struct GNUNET_PeerIdentity),
                      &GDS_my_identity_hash);
  GDS_block_context = GNUNET_BLOCK_context_create (GDS_cfg);
  GDS_stats = GNUNET_STATISTICS_create ("dht",
                                        GDS_cfg);
  GDS_CLIENTS_init ();
  GDS_ROUTING_init ();
  GDS_DATACACHE_init ();
  GNUNET_SCHEDULER_add_shutdown (&shutdown_task,
                                 NULL);
  if (GNUNET_OK !=
      GDS_NEIGHBOURS_init ())
  {
    GNUNET_SCHEDULER_shutdown ();
    return;
  }
  GNUNET_CONFIGURATION_iterate_sections (GDS_cfg,
                                         &load_underlay,
                                         NULL);
  if (NULL == u_head)
  {
    GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                "No DHT underlays configured!\n");
    GNUNET_SCHEDULER_shutdown ();
    return;
  }
}

References GDS_block_context, GDS_cfg, GDS_CLIENTS_init(), GDS_DATACACHE_init(), GDS_my_hello, GDS_my_identity, GDS_my_identity_hash, GDS_my_private_key, GDS_NEIGHBOURS_init(), GDS_ROUTING_init(), GDS_service, GDS_stats, GNUNET_BLOCK_context_create(), GNUNET_CONFIGURATION_get_value_filename(), GNUNET_CONFIGURATION_iterate_sections(), GNUNET_CRYPTO_eddsa_key_from_file(), GNUNET_CRYPTO_eddsa_key_get_public(), GNUNET_CRYPTO_hash(), GNUNET_ERROR_TYPE_ERROR, GNUNET_free, GNUNET_HELLO_builder_new(), GNUNET_log, GNUNET_log_config_missing(), GNUNET_OK, GNUNET_SCHEDULER_add_shutdown(), GNUNET_SCHEDULER_shutdown(), GNUNET_STATISTICS_create(), GNUNET_SYSERR, GNUNET_YES, load_underlay(), GNUNET_PeerIdentity::public_key, service, shutdown_task(), and u_head.

Here is the call graph for this function:

GNUNET_SERVICE_MAIN()

GNUNET_SERVICE_MAIN	(	GNUNET_OS_project_data_gnunet()	,
		"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_hd_fixed_size(dht_local_hello_get, GNUNET_MESSAGE_TYPE_DHT_CLIENT_HELLO_GET, struct GNUNET_MessageHeader, NULL)	,
		GNUNET_MQ_hd_var_size(dht_local_hello_offer, GNUNET_MESSAGE_TYPE_DHT_CLIENT_HELLO_URL, struct GNUNET_MessageHeader, NULL)	,
		GNUNET_MQ_handler_end()
	)

Variable Documentation

GDS_my_hello

struct GNUNET_HELLO_Builder* GDS_my_hello

Our HELLO.

Our HELLO builder.

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

Referenced by broadcast_hello(), handle_dht_local_hello_get(), handle_find_my_hello(), run(), shutdown_task(), u_address_add(), and u_address_del().

GDS_my_identity

struct GNUNET_PeerIdentity GDS_my_identity

Identity of this peer.

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

Referenced by forward_reply(), GDS_CLIENTS_handle_reply(), GDS_NEIGHBOURS_get_id(), GDS_NEIGHBOURS_handle_get(), GDS_NEIGHBOURS_handle_put(), GDS_NEIGHBOURS_handle_reply(), GDS_try_connect(), GDS_u_connect(), handle_dht_p2p_get(), handle_dht_p2p_put(), handle_dht_p2p_result(), and run().

GDS_my_identity_hash

struct GNUNET_HashCode GDS_my_identity_hash

Hash of the identity of this peer.

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

Referenced by find_bucket(), GDS_am_closest_peer(), GDS_DATACACHE_handle_put(), GDS_NEIGHBOURS_handle_get(), GDS_NEIGHBOURS_handle_put(), handle_find_my_hello(), run(), select_peer(), and send_find_peer_message().

GDS_my_private_key

struct GNUNET_CRYPTO_EddsaPrivateKey GDS_my_private_key

Our private key.

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

Referenced by broadcast_hello(), GDS_NEIGHBOURS_handle_put(), GDS_NEIGHBOURS_handle_reply(), handle_dht_local_hello_get(), handle_find_my_hello(), and run().

hello_task

struct GNUNET_SCHEDULER_Task* hello_task

static

Task broadcasting our HELLO.

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

Referenced by broadcast_hello(), shutdown_task(), u_address_add(), and u_address_del().

u_head

struct GDS_Underlay* u_head

static

Handles for the DHT underlays.

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

Referenced by GDS_u_try_connect(), load_underlay(), run(), shutdown_task(), and update_network_size_estimate().

u_tail

struct GDS_Underlay* u_tail

static

Handles for the DHT underlays.

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

Referenced by load_underlay(), and shutdown_task().

a_head

struct MyAddress* a_head

static

Head of addresses of this peer.

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

Referenced by hash_addresses(), u_address_add(), and u_address_del().

a_tail

struct MyAddress* a_tail

static

Tail of addresses of this peer.

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

Referenced by u_address_add(), and u_address_del().

log_of_network_size_estimate

double log_of_network_size_estimate

static

log of the current network size estimate, used as the point where we switch between random and deterministic routing.

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

Referenced by GDS_NSE_get(), and update_network_size_estimate().