GNUnet 0.22.1
gnunet-service-dht.h File Reference

GNUnet DHT globals. More...

Include dependency graph for gnunet-service-dht.h:
This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Macros

#define DEBUG_DHT   GNUNET_EXTRA_LOGGING
 

Functions

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_PreferenceHandleGDS_u_hold (struct GDS_Underlay *u, struct GNUNET_DHTU_Target *target)
 Create a hold on target at underlay u. More...
 
bool GDS_CLIENTS_handle_reply (const struct GNUNET_DATACACHE_Block *bd, const struct GNUNET_HashCode *query_hash, unsigned int get_path_length, const struct GNUNET_DHT_PathElement *get_path)
 Handle a reply we've received from another peer. More...
 
void GDS_CLIENTS_process_get (enum GNUNET_DHT_RouteOption options, enum GNUNET_BLOCK_Type type, uint32_t hop_count, uint32_t desired_replication_level, const struct GNUNET_HashCode *key)
 Check if some client is monitoring GET messages and notify them in that case. More...
 
void GDS_CLIENTS_process_get_resp (const struct GNUNET_DATACACHE_Block *bd, const struct GNUNET_DHT_PathElement *get_path, unsigned int get_path_length)
 Check if some client is monitoring GET RESP messages and notify them in that case. More...
 
void GDS_CLIENTS_process_put (const struct GNUNET_DATACACHE_Block *bd, uint32_t hop_count, uint32_t desired_replication_level)
 Check if some client is monitoring PUT messages and notify them in that case. More...
 
double GDS_NSE_get (void)
 Return the current NSE. More...
 

Variables

const struct GNUNET_CONFIGURATION_HandleGDS_cfg
 Configuration we use. More...
 
struct GNUNET_SERVICE_HandleGDS_service
 Handle for the service. More...
 
struct GNUNET_BLOCK_ContextGDS_block_context
 Our handle to the BLOCK library. More...
 
struct GNUNET_STATISTICS_HandleGDS_stats
 Handle for the statistics service. More...
 
struct GNUNET_HELLO_BuilderGDS_my_hello
 Our HELLO builder. 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...
 

Detailed Description

GNUnet DHT globals.

Author
Christian Grothoff

Definition in file gnunet-service-dht.h.

Macro Definition Documentation

◆ DEBUG_DHT

#define DEBUG_DHT   GNUNET_EXTRA_LOGGING

Definition at line 34 of file gnunet-service-dht.h.

Function Documentation

◆ 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
pididentity of the peer we would connect to
addressan address of pid

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

325{
326 for (struct GDS_Underlay *u = u_head;
327 NULL != u;
328 u = u->next)
329 u->dhtu->try_connect (u->dhtu->cls,
330 pid,
331 address);
332}
static mp_limb_t u[(((256)+GMP_NUMB_BITS - 1)/GMP_NUMB_BITS)]
static char * address
GNS address for this phone.
static struct GDS_Underlay * u_head
Handles for the DHT underlays.
static struct GNUNET_PeerIdentity pid
Identity of the peer we transmit to / connect to.
Information we keep per underlay.

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
uunderlay to use for transmission
targetreceiver identification
msgmessage
msg_sizenumber of bytes in msg
finished_cbfunction called once transmission is done (not called if target disconnects, then only the disconnect_cb is called).
finished_cb_clsclosure for finished_cb

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

342{
343 u->dhtu->send (u->dhtu->cls,
344 target,
345 msg,
346 msg_size,
348 finished_cb_cls);
349}
struct GNUNET_MessageHeader * msg
Definition: 005.c:2
static void finished_cb(void *cls, enum GNUNET_GenericReturnValue rv)

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
uthe underlay controlling the hold
phthe preference handle

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

355{
356 u->dhtu->drop (ph);
357}

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
uthe underlay controlling the target
targetthe peer to hold the connection to

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

363{
364 return u->dhtu->hold (u->dhtu->cls,
365 target);
366}

References GNUNET_DHTU_PreferenceHandle::target, and u.

Referenced by update_hold().

Here is the caller graph for this function:

◆ GDS_CLIENTS_handle_reply()

bool GDS_CLIENTS_handle_reply ( const struct GNUNET_DATACACHE_Block bd,
const struct GNUNET_HashCode query_hash,
unsigned int  get_path_length,
const struct GNUNET_DHT_PathElement get_path 
)

Handle a reply we've received from another peer.

If the reply matches any of our pending queries, forward it to the respective client(s).

Parameters
bdblock details
query_hashhash of the original query, might not match key in bd
get_path_lengthnumber of entries in get_path
get_pathpath the reply has taken
Returns
true on success, false on failures

Definition at line 1061 of file gnunet-service-dht_clients.c.

1065{
1066 struct ForwardReplyContext frc;
1067 size_t msize = sizeof (struct GNUNET_DHT_ClientResultMessage)
1068 + bd->data_size
1070 * sizeof(struct GNUNET_DHT_PathElement);
1071#if SANITY_CHECKS > 1
1072 bool truncated = (0 != (bd->ro & GNUNET_DHT_RO_TRUNCATED));
1073#endif
1074
1075 if (msize >= GNUNET_MAX_MESSAGE_SIZE)
1076 {
1077 GNUNET_break (0);
1078 return false;
1079 }
1080#if SANITY_CHECKS > 1
1081 if (0 !=
1083 bd->data_size,
1084 bd->expiration_time,
1085 truncated
1086 ? &bd->trunc_peer
1087 : NULL,
1088 bd->put_path,
1089 bd->put_path_length,
1090 get_path,
1091 get_path_length,
1093 {
1094 GNUNET_break (0);
1095 return false;
1096 }
1097#endif
1098 frc.bd = bd;
1099 frc.get_path = get_path;
1100 frc.get_path_length = get_path_length;
1102 "Forwarding reply for query hash %s with GPL %u and PPL %u to client\n",
1103 GNUNET_h2s (query_hash),
1104 get_path_length,
1105 bd->put_path_length);
1106 if (0 ==
1108 query_hash,
1110 &frc))
1111 {
1113 "No matching client for reply for query %s\n",
1114 GNUNET_h2s (query_hash));
1116 "# REPLIES ignored for CLIENTS (no match)",
1117 1,
1118 GNUNET_NO);
1119 }
1120 return true;
1121}
static size_t data_size
Number of bytes in data.
struct GNUNET_PeerIdentity GDS_my_identity
Identity of this peer.
static enum GNUNET_GenericReturnValue forward_reply(void *cls, const struct GNUNET_HashCode *query_hash, void *value)
Iterator over hash map entries that send a given reply to each of the matching clients.
struct GNUNET_STATISTICS_Handle * GDS_stats
Handle for the statistics service.
static struct GNUNET_CONTAINER_MultiHashMap * forward_map
Hashmap for fast key based lookup, maps keys to struct ClientQueryRecord entries.
#define LOG(kind,...)
#define GNUNET_MAX_MESSAGE_SIZE
Largest supported message (to be precise, one byte more than the largest possible message,...
unsigned int GNUNET_DHT_verify_path(const void *data, size_t data_size, struct GNUNET_TIME_Absolute exp_time, const struct GNUNET_PeerIdentity *trunc_peer, const struct GNUNET_DHT_PathElement *put_path, unsigned int put_path_len, const struct GNUNET_DHT_PathElement *get_path, unsigned int get_path_len, const struct GNUNET_PeerIdentity *me)
Verify signatures on a path consisting of put_path and get_path in reverse order (starting at the las...
Definition: dht_api.c:1344
@ GNUNET_DHT_RO_TRUNCATED
Flag set if the path was truncated.
enum GNUNET_GenericReturnValue GNUNET_CONTAINER_multihashmap_get_multiple(struct GNUNET_CONTAINER_MultiHashMap *map, const struct GNUNET_HashCode *key, GNUNET_CONTAINER_MultiHashMapIteratorCallback it, void *it_cls)
Iterate over all entries in the map that match a particular key.
@ GNUNET_NO
#define GNUNET_break(cond)
Use this for internal assertion violations that are not fatal (can be handled) but should not occur.
const char * GNUNET_h2s(const struct GNUNET_HashCode *hc)
Convert a hash value to a string (for printing debug messages).
@ GNUNET_ERROR_TYPE_DEBUG
void GNUNET_STATISTICS_update(struct GNUNET_STATISTICS_Handle *handle, const char *name, int64_t delta, int make_persistent)
Set statistic value for the peer.
Closure for forward_reply()
const struct GNUNET_DHT_PathElement * put_path
PUT path taken by the block, array of peer identities.
const void * data
Actual block data.
enum GNUNET_DHT_RouteOption ro
Options for routing for the block.
struct GNUNET_PeerIdentity trunc_peer
If the path was truncated, this is the peer ID at which the path was truncated.
size_t data_size
Number of bytes in data.
unsigned int put_path_length
Length of the put_path array.
struct GNUNET_TIME_Absolute expiration_time
When does the block expire?
Reply to a GET send from the service to a client.
Definition: dht.h:144
uint32_t put_path_length
Number of peers recorded in the outgoing path from source to the storgage location of this message.
Definition: dht.h:169
uint32_t get_path_length
The number of peer identities recorded from the storage location to this peer.
Definition: dht.h:175
A (signed) path tracking a block's flow through the DHT is represented by an array of path elements,...

References ForwardReplyContext::bd, GNUNET_DATACACHE_Block::data, data_size, GNUNET_DATACACHE_Block::data_size, GNUNET_DATACACHE_Block::expiration_time, forward_map, forward_reply(), GDS_my_identity, GDS_stats, ForwardReplyContext::get_path, GNUNET_DHT_ClientResultMessage::get_path_length, ForwardReplyContext::get_path_length, GNUNET_break, GNUNET_CONTAINER_multihashmap_get_multiple(), GNUNET_DHT_RO_TRUNCATED, GNUNET_DHT_verify_path(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_h2s(), GNUNET_MAX_MESSAGE_SIZE, GNUNET_NO, GNUNET_STATISTICS_update(), LOG, GNUNET_DATACACHE_Block::put_path, GNUNET_DATACACHE_Block::put_path_length, GNUNET_DHT_ClientResultMessage::put_path_length, GNUNET_DATACACHE_Block::ro, and GNUNET_DATACACHE_Block::trunc_peer.

Referenced by handle_dht_local_put(), handle_dht_p2p_put(), handle_local_result(), and process_reply_with_path().

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

◆ GDS_CLIENTS_process_get()

void GDS_CLIENTS_process_get ( enum GNUNET_DHT_RouteOption  options,
enum GNUNET_BLOCK_Type  type,
uint32_t  hop_count,
uint32_t  desired_replication_level,
const struct GNUNET_HashCode key 
)

Check if some client is monitoring GET messages and notify them in that case.

If tracked, path should include the local peer.

Parameters
optionsOptions, for instance RecordRoute, DemultiplexEverywhere.
typeThe type of data in the request.
hop_countHop count so far.
desired_replication_levelDesired replication level.
keyKey of the requested data.

Definition at line 1396 of file gnunet-service-dht_clients.c.

1401{
1402 struct GetActionContext gac = {
1403 .options = options,
1404 .type = type,
1405 .hop_count = hop_count,
1406 .desired_replication_level = desired_replication_level,
1407 .key = key
1408 };
1409
1411 key,
1412 &get_action,
1413 &gac);
1414}
struct GNUNET_GETOPT_CommandLineOption options[]
Definition: 002.c:5
struct GNUNET_HashCode key
The key used in the DHT.
static uint32_t type
Type string converted to DNS type value.
static void for_matching_monitors(enum GNUNET_BLOCK_Type type, const struct GNUNET_HashCode *key, MonitorAction cb, void *cb_cls)
Call cb on all monitors that watch for blocks of type and key key.
static void get_action(void *cls, struct ClientMonitorRecord *m)
Function called on monitors that match a GET.
Closure for get_action();.
enum GNUNET_DHT_RouteOption options

References GetActionContext::desired_replication_level, for_matching_monitors(), get_action(), GetActionContext::hop_count, key, options, GetActionContext::options, and type.

Referenced by handle_dht_local_get(), and handle_dht_p2p_get().

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

◆ GDS_CLIENTS_process_get_resp()

void GDS_CLIENTS_process_get_resp ( const struct GNUNET_DATACACHE_Block bd,
const struct GNUNET_DHT_PathElement get_path,
unsigned int  get_path_length 
)

Check if some client is monitoring GET RESP messages and notify them in that case.

Parameters
bdblock details
get_pathPeers on GET path (or NULL if not recorded).
get_path_lengthnumber of entries in get_path.

Definition at line 1490 of file gnunet-service-dht_clients.c.

1493{
1494 struct ResponseActionContext rac = {
1495 .bd = bd,
1496 .get_path = get_path,
1497 .get_path_length = get_path_length
1498 };
1499
1501 &bd->key,
1503 &rac);
1504}
static void response_action(void *cls, struct ClientMonitorRecord *m)
Function called on monitors that match a response.
enum GNUNET_BLOCK_Type type
Type of the block.
struct GNUNET_HashCode key
Key of the block.
Closure for response_action().
const struct GNUNET_DHT_PathElement * get_path
const struct GNUNET_DATACACHE_Block * bd

References ResponseActionContext::bd, for_matching_monitors(), ResponseActionContext::get_path, ResponseActionContext::get_path_length, GNUNET_DATACACHE_Block::key, response_action(), and GNUNET_DATACACHE_Block::type.

Referenced by process_reply_with_path().

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

◆ GDS_CLIENTS_process_put()

void GDS_CLIENTS_process_put ( const struct GNUNET_DATACACHE_Block bd,
uint32_t  hop_count,
uint32_t  desired_replication_level 
)

Check if some client is monitoring PUT messages and notify them in that case.

The path should include our own peer ID (if recorded).

Parameters
bddetails about the block
hop_countHop count so far.
desired_replication_levelDesired replication level.

Definition at line 1578 of file gnunet-service-dht_clients.c.

1581{
1582 struct PutActionContext put_ctx = {
1583 .bd = bd,
1584 .hop_count = hop_count,
1585 .desired_replication_level = desired_replication_level
1586 };
1587
1589 &bd->key,
1590 &put_action,
1591 &put_ctx);
1592}
static void put_action(void *cls, struct ClientMonitorRecord *m)
Function called on monitors that match a PUT.
Closure for put_action().
const struct GNUNET_DATACACHE_Block * bd

References PutActionContext::bd, PutActionContext::desired_replication_level, for_matching_monitors(), PutActionContext::hop_count, GNUNET_DATACACHE_Block::key, put_action(), and GNUNET_DATACACHE_Block::type.

Referenced by handle_dht_local_put(), and handle_dht_p2p_put().

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.

211{
213}
static double log_of_network_size_estimate
log of the current network size estimate, used as the point where we switch between random and determ...

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:

Variable Documentation

◆ GDS_cfg

const struct GNUNET_CONFIGURATION_Handle* GDS_cfg
extern

Configuration we use.

Configuration we use.

Definition at line 232 of file gnunet-service-dht_clients.c.

Referenced by GDS_DATACACHE_init(), GDS_NEIGHBOURS_init(), load_underlay(), and run().

◆ GDS_service

struct GNUNET_SERVICE_Handle* GDS_service
extern

Handle for the service.

Definition at line 227 of file gnunet-service-dht_clients.c.

Referenced by run().

◆ GDS_block_context

◆ GDS_stats

◆ GDS_my_hello

struct GNUNET_HELLO_Builder* GDS_my_hello
extern

Our HELLO builder.

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

◆ GDS_my_identity_hash

◆ GDS_my_private_key