gnunet-service-cadet_dht.h File Reference

cadet service; dealing with DHT requests and results More...

#include "platform.h"
#include "gnunet_util_lib.h"

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

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

Go to the source code of this file.

Functions
void	GCD_init (const struct GNUNET_CONFIGURATION_Handle *c)
	Initialize the DHT subsystem. More...
void	GCD_shutdown (void)
	Shut down the DHT subsystem. More...
void	GCD_hello_update (void)
	Function called by the HELLO subsystem whenever OUR hello changes. More...
struct GCD_search_handle *	GCD_search (const struct GNUNET_PeerIdentity *peer_id)
	Search DHT for paths to peeR_id. More...
void	GCD_search_stop (struct GCD_search_handle *h)
	Stop DHT search started with GCD_search(). More...

Detailed Description

cadet service; dealing with DHT requests and results

Author

Bartlomiej Polot

Christian Grothoff

All functions in this file should use the prefix GCD (Gnunet Cadet Dht)

Definition in file gnunet-service-cadet_dht.h.

Function Documentation

GCD_init()

void GCD_init

(

const struct GNUNET_CONFIGURATION_Handle *

c

)

Initialize the DHT subsystem.

Parameters

c	Configuration.

Definition at line 235 of file gnunet-service-cadet_dht.c.

{
  if (GNUNET_OK !=
      GNUNET_CONFIGURATION_get_value_number (c,
                                             "CADET",
                                             "DHT_REPLICATION_LEVEL",
                                             &dht_replication_level))
  {
    GNUNET_log_config_invalid (GNUNET_ERROR_TYPE_WARNING,
                               "CADET",
                               "DHT_REPLICATION_LEVEL",
                               "USING DEFAULT");
    dht_replication_level = 3;
  }
 
  if (GNUNET_OK !=
      GNUNET_CONFIGURATION_get_value_time (c,
                                           "CADET",
                                           "ID_ANNOUNCE_TIME",
                                           &id_announce_time))
  {
    GNUNET_log_config_invalid (GNUNET_ERROR_TYPE_ERROR,
                               "CADET",
                               "ID_ANNOUNCE_TIME",
                               "MISSING");
    GNUNET_SCHEDULER_shutdown ();
    return;
  }
 
  dht_handle = GNUNET_DHT_connect (c,
                                   64);
  GNUNET_break (NULL != dht_handle);
  announce_delay = GNUNET_TIME_UNIT_SECONDS;
  announce_id_task = GNUNET_SCHEDULER_add_delayed (STARTUP_DELAY,
                                                   &announce_id,
                                                   NULL);
}

References announce_delay, announce_id(), announce_id_task, dht_handle, dht_replication_level, GNUNET_break, GNUNET_CONFIGURATION_get_value_number(), GNUNET_CONFIGURATION_get_value_time(), GNUNET_DHT_connect(), GNUNET_ERROR_TYPE_ERROR, GNUNET_ERROR_TYPE_WARNING, GNUNET_log_config_invalid(), GNUNET_OK, GNUNET_SCHEDULER_add_delayed(), GNUNET_SCHEDULER_shutdown(), GNUNET_TIME_UNIT_SECONDS, id_announce_time, and STARTUP_DELAY.

Referenced by run().

Here is the call graph for this function:

Here is the caller graph for this function:

GCD_shutdown()

void GCD_shutdown

(

void

)

Shut down the DHT subsystem.

Definition at line 275 of file gnunet-service-cadet_dht.c.

{
  if (NULL != dht_handle)
  {
    GNUNET_DHT_disconnect (dht_handle);
    dht_handle = NULL;
  }
  if (NULL != announce_id_task)
  {
    GNUNET_SCHEDULER_cancel (announce_id_task);
    announce_id_task = NULL;
  }
}

References announce_id_task, dht_handle, GNUNET_DHT_disconnect(), and GNUNET_SCHEDULER_cancel().

Referenced by shutdown_rest().

Here is the call graph for this function:

Here is the caller graph for this function:

GCD_hello_update()

void GCD_hello_update

(

void

)

Function called by the HELLO subsystem whenever OUR hello changes.

Re-triggers the DHT PUT immediately.

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

{
  if (NULL == announce_id_task)
    return; /* too early */
  GNUNET_SCHEDULER_cancel (announce_id_task);
  announce_id_task
    = GNUNET_SCHEDULER_add_delayed (CHANGE_DELAY,
                                    &announce_id,
                                    NULL);
}

References announce_id(), announce_id_task, CHANGE_DELAY, GNUNET_SCHEDULER_add_delayed(), and GNUNET_SCHEDULER_cancel().

Referenced by got_hello().

Here is the call graph for this function:

Here is the caller graph for this function:

GCD_search()

struct GCD_search_handle * GCD_search

(

const struct GNUNET_PeerIdentity *

peer_id

)

Search DHT for paths to peeR_id.

Parameters

peer_id

peer to search for

Returns

handle to abort search

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

{
  struct GNUNET_HashCode phash;
  struct GCD_search_handle *h;
 
  GNUNET_STATISTICS_update (stats,
                            "# DHT search",
                            1,
                            GNUNET_NO);
  memset (&phash,
          0,
          sizeof(phash));
  GNUNET_memcpy (&phash,
                 peer_id,
                 sizeof(*peer_id));
 
  h = GNUNET_new (struct GCD_search_handle);
  h->dhtget = GNUNET_DHT_get_start (dht_handle,     /* handle */
                                    GNUNET_BLOCK_TYPE_DHT_HELLO, /* type */
                                    &phash,     /* key to search */
                                    dht_replication_level, /* replication level */
                                    GNUNET_DHT_RO_RECORD_ROUTE
                                    | GNUNET_DHT_RO_DEMULTIPLEX_EVERYWHERE,
                                    NULL,       /* xquery */
                                    0,     /* xquery bits */
                                    &dht_get_id_handler,
                                    h);
  LOG (GNUNET_ERROR_TYPE_DEBUG,
       "Starting DHT GET for peer %s (%p)\n",
       GNUNET_i2s (peer_id),
       h);
  return h;
}

References dht_get_id_handler(), dht_handle, dht_replication_level, GNUNET_BLOCK_TYPE_DHT_HELLO, GNUNET_DHT_get_start(), GNUNET_DHT_RO_DEMULTIPLEX_EVERYWHERE, GNUNET_DHT_RO_RECORD_ROUTE, GNUNET_ERROR_TYPE_DEBUG, GNUNET_i2s(), GNUNET_memcpy, GNUNET_new, GNUNET_NO, GNUNET_STATISTICS_update(), h, LOG, peer_id, and stats.

Referenced by consider_peer_activate(), and GCP_path_entry_remove().

Here is the call graph for this function:

Here is the caller graph for this function:

GCD_search_stop()

void GCD_search_stop

(

struct GCD_search_handle *

h

)

Stop DHT search started with GCD_search().

Parameters

h	handle to search to stop

Definition at line 327 of file gnunet-service-cadet_dht.c.

{
  LOG (GNUNET_ERROR_TYPE_DEBUG,
       "Stopping DHT GET %p\n",
       h);
  GNUNET_DHT_get_stop (h->dhtget);
  GNUNET_free (h);
}

References GNUNET_DHT_get_stop(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_free, h, and LOG.

Referenced by consider_peer_activate(), destroy_peer(), and GCP_path_entry_add().

Here is the call graph for this function:

Here is the caller graph for this function: