GNUnet 0.21.1
gnunet-service-cadet_dht.c File Reference

Information we track per peer. More...

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

Go to the source code of this file.

Data Structures

struct  GCD_search_handle
 

Macros

#define STARTUP_DELAY
 How long do we wait before first announcing our presence to the DHT. More...
 
#define CHANGE_DELAY
 How long do we wait after we get an updated HELLO before publishing? Allows for the HELLO to be updated again quickly, for example in case multiple addresses changed and we got a partial update. More...
 
#define LOG(level, ...)   GNUNET_log_from (level, "cadet-dht", __VA_ARGS__)
 

Functions

static void dht_get_id_handler (void *cls, struct GNUNET_TIME_Absolute exp, const struct GNUNET_HashCode *key, const struct GNUNET_PeerIdentity *trunc_peer, const struct GNUNET_DHT_PathElement *get_path, unsigned int get_path_length, const struct GNUNET_DHT_PathElement *put_path, unsigned int put_path_length, enum GNUNET_BLOCK_Type type, size_t size, const void *data)
 Function to process paths received for a new peer addition. More...
 
static void announce_id (void *cls)
 Periodically announce self id in the DHT. More...
 
void GCD_hello_update ()
 Function called by the HELLO subsystem whenever OUR hello changes. More...
 
void GCD_init (const struct GNUNET_CONFIGURATION_Handle *c)
 Initialize the DHT subsystem. More...
 
void GCD_shutdown (void)
 Shut down the DHT subsystem. More...
 
struct GCD_search_handleGCD_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...
 

Variables

static struct GNUNET_DHT_Handledht_handle
 Handle to use DHT. More...
 
static struct GNUNET_TIME_Relative id_announce_time
 How often to PUT own ID in the DHT. More...
 
static unsigned long long dht_replication_level
 DHT replication level, see DHT API: GNUNET_DHT_get_start(), GNUNET_DHT_put(). More...
 
static struct GNUNET_SCHEDULER_Taskannounce_id_task
 Task to periodically announce itself in the network. More...
 
static struct GNUNET_TIME_Relative announce_delay
 Delay for the next ID announce. More...
 

Detailed Description

Information we track per peer.

Author
Bartlomiej Polot
Christian Grothoff

Definition in file gnunet-service-cadet_dht.c.

Macro Definition Documentation

◆ STARTUP_DELAY

#define STARTUP_DELAY
Value:
#define GNUNET_TIME_UNIT_MILLISECONDS
One millisecond.
struct GNUNET_TIME_Relative GNUNET_TIME_relative_multiply(struct GNUNET_TIME_Relative rel, unsigned long long factor)
Multiply relative time by a given factor.
Definition: time.c:484

How long do we wait before first announcing our presence to the DHT.

Used to wait for our HELLO to be available. Note that we also get notifications when our HELLO is ready, so this is just the maximum we wait for the first notification.

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

◆ CHANGE_DELAY

#define CHANGE_DELAY
Value:

How long do we wait after we get an updated HELLO before publishing? Allows for the HELLO to be updated again quickly, for example in case multiple addresses changed and we got a partial update.

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

◆ LOG

#define LOG (   level,
  ... 
)    GNUNET_log_from (level, "cadet-dht", __VA_ARGS__)

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

Function Documentation

◆ dht_get_id_handler()

static void dht_get_id_handler ( void *  cls,
struct GNUNET_TIME_Absolute  exp,
const struct GNUNET_HashCode key,
const struct GNUNET_PeerIdentity trunc_peer,
const struct GNUNET_DHT_PathElement get_path,
unsigned int  get_path_length,
const struct GNUNET_DHT_PathElement put_path,
unsigned int  put_path_length,
enum GNUNET_BLOCK_Type  type,
size_t  size,
const void *  data 
)
static

Function to process paths received for a new peer addition.

The recorded paths form the initial tunnel, which can be optimized later. Called on each result obtained for the DHT search.

Parameters
clsclosure
expwhen will this value expire
keykey of the result
trunc_peerpeer preceeding with invalid signature, or NULL
get_pathpath of the get request
get_path_lengthlength of get_path
put_pathpath of the put request
put_path_lengthlength of the put_path
typetype of the result
sizenumber of bytes in data
datapointer to the result data

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

121{
122 const struct GNUNET_MessageHeader *hello = data;
124
125 GNUNET_assert (NULL != builder);
126 (void) trunc_peer;
127 GCPP_try_path_from_dht (get_path,
128 get_path_length,
129 put_path,
130 put_path_length);
131
132 struct CadetPeer *peer;
133
134 peer = GCP_get (&put_path[0].pred,
135 GNUNET_YES);
137 "Got HELLO for %s\n",
138 GCP_2s (peer));
139 GCP_set_hello (peer,
140 hello);
142}
static struct HostSet * builder
NULL if we are not currently iterating over peer information.
static char * data
The data to insert into the dht.
#define LOG(level,...)
void GCPP_try_path_from_dht(const struct GNUNET_DHT_PathElement *get_path, unsigned int get_path_length, const struct GNUNET_DHT_PathElement *put_path, unsigned int put_path_length)
Create a peer path based on the result of a DHT lookup.
struct CadetPeer * GCP_get(const struct GNUNET_PeerIdentity *peer_id, int create)
Retrieve the CadetPeer structure associated with the peer.
void GCP_set_hello(struct CadetPeer *cp, const struct GNUNET_MessageHeader *hello)
We got a HELLO for a cp, remember it, and possibly trigger adequate actions (like trying to connect).
const char * GCP_2s(const struct CadetPeer *cp)
Get the static string for a peer ID.
void GNUNET_HELLO_builder_free(struct GNUNET_HELLO_Builder *builder)
Release resources of a builder.
Definition: hello-uri.c:373
struct GNUNET_HELLO_Builder * GNUNET_HELLO_builder_from_msg(const struct GNUNET_MessageHeader *msg)
Parse msg into builder.
Definition: hello-uri.c:391
@ GNUNET_YES
#define GNUNET_assert(cond)
Use this for fatal errors that cannot be handled.
@ GNUNET_ERROR_TYPE_DEBUG
Struct containing all information regarding a given peer.
struct GNUNET_MessageHeader * hello
Hello message of the peer.
Context for building (or parsing) HELLO URIs.
Definition: hello-uri.c:205
Header for all communications.

References builder, data, GCP_2s(), GCP_get(), GCP_set_hello(), GCPP_try_path_from_dht(), GNUNET_assert, GNUNET_ERROR_TYPE_DEBUG, GNUNET_HELLO_builder_free(), GNUNET_HELLO_builder_from_msg(), GNUNET_YES, CadetPeer::hello, and LOG.

Referenced by GCD_search().

Here is the call graph for this function:
Here is the caller graph for this function:

◆ announce_id()

static void announce_id ( void *  cls)
static

Periodically announce self id in the DHT.

Parameters
clsclosure

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

152{
153 struct GNUNET_HashCode phash;
154 const struct GNUNET_MessageHeader *hello;
155 size_t size;
156 size_t block_size;
157 void *block;
159 struct GNUNET_TIME_Relative next_put;
160
161 hello = GCH_get_mine ();
162 size = (NULL != hello) ? ntohs(hello->size) : 0;
163 if (0 == size)
164 {
168 }
169 else
170 {
173 }
174
175 /* Call again in id_announce_time, unless HELLO expires first,
176 * but wait at least 1s. */
177 next_put
179 next_put
180 = GNUNET_TIME_relative_min (next_put,
182 next_put
183 = GNUNET_TIME_relative_max (next_put,
188 cls);
190 "# DHT announce",
191 1,
192 GNUNET_NO);
193 memset (&phash,
194 0,
195 sizeof(phash));
196 GNUNET_memcpy (&phash,
197 &my_full_id,
198 sizeof(my_full_id));
200 &my_full_id,
201 &block,
202 &block_size,
203 &expiration))
204 return;
205
207 "Announcing my HELLO (%lu bytes) in the DHT\n",
208 (unsigned long) block_size);
209 GNUNET_DHT_put (dht_handle, /* DHT handle */
210 &phash, /* Key to use */
211 dht_replication_level, /* Replication level */
213 | GNUNET_DHT_RO_DEMULTIPLEX_EVERYWHERE, /* DHT options */
214 GNUNET_BLOCK_TYPE_DHT_HELLO, /* Block type */
215 block_size, /* Size of the data */
216 (const char *) block, /* Data itself */
217 expiration, /* Data expiration */
218 NULL, /* Continuation */
219 NULL); /* Continuation closure */
220 GNUNET_free (block);
221}
static struct GNUNET_TIME_Relative expiration
User supplied expiration value.
struct GNUNET_PeerIdentity my_full_id
Local peer own ID.
Definition: gnunet-hello.c:101
static struct GNUNET_SCHEDULER_Task * announce_id_task
Task to periodically announce itself in the network.
static struct GNUNET_TIME_Relative id_announce_time
How often to PUT own ID in the DHT.
static unsigned long long dht_replication_level
DHT replication level, see DHT API: GNUNET_DHT_get_start(), GNUNET_DHT_put().
static struct GNUNET_TIME_Relative announce_delay
Delay for the next ID announce.
static void announce_id(void *cls)
Periodically announce self id in the DHT.
static struct GNUNET_DHT_Handle * dht_handle
Handle to use DHT.
const struct GNUNET_MessageHeader * GCH_get_mine(void)
Get own hello message.
static struct GNUNET_STATISTICS_Handle * stats
Handle to the statistics service.
struct GNUNET_DHT_PutHandle * GNUNET_DHT_put(struct GNUNET_DHT_Handle *handle, const struct GNUNET_HashCode *key, uint32_t desired_replication_level, enum GNUNET_DHT_RouteOption options, enum GNUNET_BLOCK_Type type, size_t size, const void *data, struct GNUNET_TIME_Absolute exp, GNUNET_SCHEDULER_TaskCallback cont, void *cont_cls)
Perform a PUT operation storing data in the DHT.
Definition: dht_api.c:1088
@ GNUNET_DHT_RO_RECORD_ROUTE
We should keep track of the route that the message took in the P2P network.
@ GNUNET_DHT_RO_DEMULTIPLEX_EVERYWHERE
Each peer along the way should process the request (otherwise only peers locally closest to the key w...
enum GNUNET_GenericReturnValue GNUNET_HELLO_dht_msg_to_block(const struct GNUNET_MessageHeader *hello, const struct GNUNET_PeerIdentity *pid, void **block, size_t *block_size, struct GNUNET_TIME_Absolute *block_expiration)
Convert a DHT hello message to a HELLO block.
Definition: hello-uri.c:931
struct GNUNET_TIME_Absolute GNUNET_HELLO_builder_get_expiration_time(const struct GNUNET_MessageHeader *msg)
Get the expiration time for this HELLO.
Definition: hello-uri.c:470
#define GNUNET_memcpy(dst, src, n)
Call memcpy() but check for n being 0 first.
uint16_t size
The length of the struct (in bytes, including the length field itself), in big-endian format.
@ GNUNET_OK
@ GNUNET_NO
#define GNUNET_free(ptr)
Wrapper around free.
struct GNUNET_SCHEDULER_Task * GNUNET_SCHEDULER_add_delayed(struct GNUNET_TIME_Relative delay, GNUNET_SCHEDULER_TaskCallback task, void *task_cls)
Schedule a new task to be run with a specified delay.
Definition: scheduler.c:1278
void GNUNET_STATISTICS_update(struct GNUNET_STATISTICS_Handle *handle, const char *name, int64_t delta, int make_persistent)
Set statistic value for the peer.
struct GNUNET_TIME_Relative GNUNET_TIME_relative_min(struct GNUNET_TIME_Relative t1, struct GNUNET_TIME_Relative t2)
Return the minimum of two relative time values.
Definition: time.c:343
struct GNUNET_TIME_Relative GNUNET_TIME_relative_max(struct GNUNET_TIME_Relative t1, struct GNUNET_TIME_Relative t2)
Return the maximum of two relative time values.
Definition: time.c:351
#define GNUNET_TIME_UNIT_SECONDS
One second.
struct GNUNET_TIME_Relative GNUNET_TIME_absolute_get_remaining(struct GNUNET_TIME_Absolute future)
Given a timestamp in the future, how much time remains until then?
Definition: time.c:405
struct GNUNET_TIME_Absolute GNUNET_TIME_absolute_get(void)
Get the current time.
Definition: time.c:111
struct GNUNET_TIME_Absolute GNUNET_TIME_absolute_add(struct GNUNET_TIME_Absolute start, struct GNUNET_TIME_Relative duration)
Add a given relative duration to the given start time.
Definition: time.c:450
#define GNUNET_TIME_STD_BACKOFF(r)
Perform our standard exponential back-off calculation, starting at 1 ms and then going by a factor of...
static unsigned int size
Size of the "table".
Definition: peer.c:68
@ GNUNET_BLOCK_TYPE_DHT_HELLO
Type of a block that contains a DHT-NG HELLO for a peer.
A 512-bit hashcode.
Time for absolute times used by GNUnet, in microseconds.
Time for relative time used by GNUnet, in microseconds.

References announce_delay, announce_id(), announce_id_task, dht_handle, dht_replication_level, expiration, GCH_get_mine(), GNUNET_BLOCK_TYPE_DHT_HELLO, GNUNET_DHT_put(), GNUNET_DHT_RO_DEMULTIPLEX_EVERYWHERE, GNUNET_DHT_RO_RECORD_ROUTE, GNUNET_ERROR_TYPE_DEBUG, GNUNET_free, GNUNET_HELLO_builder_get_expiration_time(), GNUNET_HELLO_dht_msg_to_block(), GNUNET_memcpy, GNUNET_NO, GNUNET_OK, GNUNET_SCHEDULER_add_delayed(), GNUNET_STATISTICS_update(), GNUNET_TIME_absolute_add(), GNUNET_TIME_absolute_get(), GNUNET_TIME_absolute_get_remaining(), GNUNET_TIME_relative_max(), GNUNET_TIME_relative_min(), GNUNET_TIME_STD_BACKOFF, GNUNET_TIME_UNIT_SECONDS, id_announce_time, LOG, my_full_id, GNUNET_MessageHeader::size, size, and stats.

Referenced by announce_id(), GCD_hello_update(), and GCD_init().

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 225 of file gnunet-service-cadet_dht.c.

226{
227 if (NULL == announce_id_task)
228 return; /* too early */
233 NULL);
234}
#define CHANGE_DELAY
How long do we wait after we get an updated HELLO before publishing? Allows for the HELLO to be updat...
void * GNUNET_SCHEDULER_cancel(struct GNUNET_SCHEDULER_Task *task)
Cancel the task with the specified identifier.
Definition: scheduler.c:981

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_init()

void GCD_init ( const struct GNUNET_CONFIGURATION_Handle c)

Initialize the DHT subsystem.

Parameters
cConfiguration.

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

239{
240 if (GNUNET_OK !=
242 "CADET",
243 "DHT_REPLICATION_LEVEL",
245 {
247 "CADET",
248 "DHT_REPLICATION_LEVEL",
249 "USING DEFAULT");
251 }
252
253 if (GNUNET_OK !=
255 "CADET",
256 "ID_ANNOUNCE_TIME",
258 {
260 "CADET",
261 "ID_ANNOUNCE_TIME",
262 "MISSING");
264 return;
265 }
266
268 64);
269 GNUNET_break (NULL != dht_handle);
273 NULL);
274}
#define STARTUP_DELAY
How long do we wait before first announcing our presence to the DHT.
enum GNUNET_GenericReturnValue GNUNET_CONFIGURATION_get_value_number(const struct GNUNET_CONFIGURATION_Handle *cfg, const char *section, const char *option, unsigned long long *number)
Get a configuration value that should be a number.
enum GNUNET_GenericReturnValue GNUNET_CONFIGURATION_get_value_time(const struct GNUNET_CONFIGURATION_Handle *cfg, const char *section, const char *option, struct GNUNET_TIME_Relative *time)
Get a configuration value that should be a relative time.
struct GNUNET_DHT_Handle * GNUNET_DHT_connect(const struct GNUNET_CONFIGURATION_Handle *cfg, unsigned int ht_len)
Initialize the connection with the DHT service.
Definition: dht_api.c:1037
#define GNUNET_break(cond)
Use this for internal assertion violations that are not fatal (can be handled) but should not occur.
void GNUNET_log_config_invalid(enum GNUNET_ErrorType kind, const char *section, const char *option, const char *required)
Log error message about invalid configuration option value.
@ GNUNET_ERROR_TYPE_WARNING
@ GNUNET_ERROR_TYPE_ERROR
void GNUNET_SCHEDULER_shutdown(void)
Request the shutdown of a scheduler.
Definition: scheduler.c:567

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 278 of file gnunet-service-cadet_dht.c.

279{
280 if (NULL != dht_handle)
281 {
283 dht_handle = NULL;
284 }
285 if (NULL != announce_id_task)
286 {
288 announce_id_task = NULL;
289 }
290}
void GNUNET_DHT_disconnect(struct GNUNET_DHT_Handle *handle)
Shutdown connection with the DHT service.
Definition: dht_api.c:1060

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_search()

struct GCD_search_handle * GCD_search ( const struct GNUNET_PeerIdentity peer_id)

Search DHT for paths to peeR_id.

Parameters
peer_idpeer to search for
Returns
handle to abort search

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

295{
296 struct GNUNET_HashCode phash;
297 struct GCD_search_handle *h;
298
300 "# DHT search",
301 1,
302 GNUNET_NO);
303 memset (&phash,
304 0,
305 sizeof(phash));
306 GNUNET_memcpy (&phash,
307 peer_id,
308 sizeof(*peer_id));
309
310 h = GNUNET_new (struct GCD_search_handle);
311 h->dhtget = GNUNET_DHT_get_start (dht_handle, /* handle */
313 &phash, /* key to search */
314 dht_replication_level, /* replication level */
317 NULL, /* xquery */
318 0, /* xquery bits */
320 h);
322 "Starting DHT GET for peer %s (%p)\n",
324 h);
325 return h;
326}
static struct GNUNET_ARM_Handle * h
Connection with ARM.
Definition: gnunet-arm.c:99
static char * peer_id
Option –peer.
Definition: gnunet-cadet.c:42
static void dht_get_id_handler(void *cls, struct GNUNET_TIME_Absolute exp, const struct GNUNET_HashCode *key, const struct GNUNET_PeerIdentity *trunc_peer, const struct GNUNET_DHT_PathElement *get_path, unsigned int get_path_length, const struct GNUNET_DHT_PathElement *put_path, unsigned int put_path_length, enum GNUNET_BLOCK_Type type, size_t size, const void *data)
Function to process paths received for a new peer addition.
struct GNUNET_DHT_GetHandle * GNUNET_DHT_get_start(struct GNUNET_DHT_Handle *handle, enum GNUNET_BLOCK_Type type, const struct GNUNET_HashCode *key, uint32_t desired_replication_level, enum GNUNET_DHT_RouteOption options, const void *xquery, size_t xquery_size, GNUNET_DHT_GetIterator iter, void *iter_cls)
Perform an asynchronous GET operation on the DHT identified.
Definition: dht_api.c:1162
const char * GNUNET_i2s(const struct GNUNET_PeerIdentity *pid)
Convert a peer identity to a string (for printing debug messages).
#define GNUNET_new(type)
Allocate a struct or union of the given type.

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
hhandle to search to stop

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

331{
333 "Stopping DHT GET %p\n",
334 h);
335 GNUNET_DHT_get_stop (h->dhtget);
336 GNUNET_free (h);
337}
void GNUNET_DHT_get_stop(struct GNUNET_DHT_GetHandle *get_handle)
Stop async DHT-get.
Definition: dht_api.c:1235

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:

Variable Documentation

◆ dht_handle

struct GNUNET_DHT_Handle* dht_handle
static

Handle to use DHT.

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

Referenced by announce_id(), GCD_init(), GCD_search(), and GCD_shutdown().

◆ id_announce_time

struct GNUNET_TIME_Relative id_announce_time
static

How often to PUT own ID in the DHT.

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

Referenced by announce_id(), and GCD_init().

◆ dht_replication_level

unsigned long long dht_replication_level
static

DHT replication level, see DHT API: GNUNET_DHT_get_start(), GNUNET_DHT_put().

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

Referenced by announce_id(), GCD_init(), and GCD_search().

◆ announce_id_task

struct GNUNET_SCHEDULER_Task* announce_id_task
static

Task to periodically announce itself in the network.

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

Referenced by announce_id(), GCD_hello_update(), GCD_init(), and GCD_shutdown().

◆ announce_delay

struct GNUNET_TIME_Relative announce_delay
static

Delay for the next ID announce.

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

Referenced by announce_id(), and GCD_init().