GNUnet DHT globals. More...
#include "gnunet-service-dht_datacache.h"
#include "gnunet-service-dht_neighbours.h"
#include "gnunet_statistics_service.h"
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_PreferenceHandle * | GDS_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_Handle * | GDS_cfg |
Configuration we use. More... | |
struct GNUNET_SERVICE_Handle * | GDS_service |
Handle for the service. More... | |
struct GNUNET_BLOCK_Context * | GDS_block_context |
Our handle to the BLOCK library. More... | |
struct GNUNET_STATISTICS_Handle * | GDS_stats |
Handle for the statistics service. More... | |
struct GNUNET_PILS_Handle * | GDS_pils |
Handle for the pils service. More... | |
struct GNUNET_MessageHeader * | GDS_my_hello |
Our HELLO parser. 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... | |
GNUnet DHT globals.
Definition in file gnunet-service-dht.h.
#define DEBUG_DHT GNUNET_EXTRA_LOGGING |
Definition at line 34 of file gnunet-service-dht.h.
void GDS_u_try_connect | ( | const struct GNUNET_PeerIdentity * | pid, |
const char * | address | ||
) |
Ask all underlays to connect to peer pid at address.
pid | identity of the peer we would connect to |
address | an address of pid |
Definition at line 301 of file gnunet-service-dht.c.
References address, pid, u, and u_head.
Referenced by GDS_try_connect().
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.
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 314 of file gnunet-service-dht.c.
References finished_cb(), msg, and u.
Referenced by do_send().
void GDS_u_drop | ( | struct GDS_Underlay * | u, |
struct GNUNET_DHTU_PreferenceHandle * | ph | ||
) |
Drop a hold ph from underlay u.
u | the underlay controlling the hold |
ph | the preference handle |
Definition at line 331 of file gnunet-service-dht.c.
References u.
Referenced by GDS_u_disconnect().
struct GNUNET_DHTU_PreferenceHandle * GDS_u_hold | ( | struct GDS_Underlay * | u, |
struct GNUNET_DHTU_Target * | target | ||
) |
Create a hold on target at underlay u.
u | the underlay controlling the target |
target | the peer to hold the connection to |
Definition at line 339 of file gnunet-service-dht.c.
References GNUNET_DHTU_PreferenceHandle::target, and u.
Referenced by update_hold().
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).
bd | block details |
query_hash | hash of the original query, might not match key in bd |
get_path_length | number of entries in get_path |
get_path | path the reply has taken |
Definition at line 1066 of file gnunet-service-dht_clients.c.
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().
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.
options | Options, for instance RecordRoute, DemultiplexEverywhere. |
type | The type of data in the request. |
hop_count | Hop count so far. |
desired_replication_level | Desired replication level. |
key | Key of the requested data. |
Definition at line 1407 of file gnunet-service-dht_clients.c.
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().
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.
bd | block details |
get_path | Peers on GET path (or NULL if not recorded). |
get_path_length | number of entries in get_path. |
Definition at line 1501 of file gnunet-service-dht_clients.c.
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().
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).
bd | details about the block |
hop_count | Hop count so far. |
desired_replication_level | Desired replication level. |
Definition at line 1589 of file gnunet-service-dht_clients.c.
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().
double GDS_NSE_get | ( | void | ) |
Return the current NSE.
Definition at line 237 of file gnunet-service-dht.c.
References log_of_network_size_estimate.
Referenced by get_forward_count(), handle_find_local_hello(), and select_peer().
|
extern |
Configuration we use.
Configuration we use.
Definition at line 237 of file gnunet-service-dht_clients.c.
Referenced by GDS_DATACACHE_init(), GDS_NEIGHBOURS_init(), load_underlay(), and run().
|
extern |
Handle for the service.
Definition at line 232 of file gnunet-service-dht_clients.c.
Referenced by run().
|
extern |
Our handle to the BLOCK library.
Definition at line 217 of file gnunet-service-dht_clients.c.
Referenced by datacache_get_iterator(), forward_reply(), handle_dht_local_put(), handle_dht_p2p_get(), handle_dht_p2p_put(), handle_dht_p2p_result(), handle_find_local_hello(), handle_find_my_hello(), process(), run(), send_find_peer_message(), shutdown_task(), and transmit_request().
|
extern |
Handle for the statistics service.
Definition at line 222 of file gnunet-service-dht_clients.c.
Referenced by datacache_get_iterator(), do_send(), expire_oldest_entry(), forward_reply(), GDS_CLIENTS_handle_reply(), GDS_DATACACHE_get_closest(), GDS_DATACACHE_handle_get(), GDS_DATACACHE_handle_put(), GDS_NEIGHBOURS_handle_get(), GDS_NEIGHBOURS_handle_put(), GDS_NEIGHBOURS_handle_reply(), GDS_ROUTING_add(), GDS_u_connect(), GDS_u_disconnect(), get_forward_count(), handle_dht_local_get(), handle_dht_local_get_stop(), handle_dht_local_put(), handle_dht_p2p_get(), handle_dht_p2p_put(), handle_dht_p2p_result(), handle_find_my_hello(), process(), run(), select_peer(), send_find_peer_message(), shutdown_task(), transmit_request(), and update_network_size_estimate().
|
extern |
Handle for the pils service.
Definition at line 227 of file gnunet-service-dht_clients.c.
Referenced by run(), and shutdown_task().
|
extern |
Our HELLO parser.
Our HELLO parser.
Definition at line 152 of file gnunet-service-dht.c.
Referenced by handle_dht_local_hello_get(), handle_find_my_hello(), pid_change_cb(), and shutdown_task().
|
extern |
Identity of this peer.
Definition at line 157 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(), pid_change_cb(), and run().
|
extern |
Hash of the identity of this peer.
Definition at line 162 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(), pid_change_cb(), run(), select_peer(), and send_find_peer_message().
|
extern |
Our private key.
Definition at line 167 of file gnunet-service-dht.c.
Referenced by GDS_NEIGHBOURS_handle_put(), GDS_NEIGHBOURS_handle_reply(), and run().