gnunet-service-dht_routing.h File Reference

GNUnet DHT tracking of requests for routing replies. More...

#include "gnunet_util_lib.h"
#include "gnunet_block_lib.h"
#include "gnunet_dht_service.h"

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

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

Go to the source code of this file.

Functions
void	GDS_ROUTING_process (enum GNUNET_BLOCK_Type type, struct GNUNET_TIME_Absolute expiration_time, const struct GNUNET_HashCode *key, unsigned int put_path_length, const struct GNUNET_PeerIdentity *put_path, unsigned int get_path_length, const struct GNUNET_PeerIdentity *get_path, const void *data, size_t data_size)
	Handle a reply (route to origin). More...
void	GDS_ROUTING_add (const struct GNUNET_PeerIdentity *sender, enum GNUNET_BLOCK_Type type, struct GNUNET_BLOCK_Group *bg, enum GNUNET_DHT_RouteOption options, const struct GNUNET_HashCode *key, const void *xquery, size_t xquery_size)
	Add a new entry to our routing table. More...
void	GDS_ROUTING_init (void)
	Initialize routing subsystem. More...
void	GDS_ROUTING_done (void)
	Shutdown routing subsystem. More...

Detailed Description

GNUnet DHT tracking of requests for routing replies.

Author

Christian Grothoff

Definition in file gnunet-service-dht_routing.h.

Function Documentation

GDS_ROUTING_process()

void GDS_ROUTING_process	(	enum GNUNET_BLOCK_Type	type,
		struct GNUNET_TIME_Absolute	expiration_time,
		const struct GNUNET_HashCode *	key,
		unsigned int	put_path_length,
		const struct GNUNET_PeerIdentity *	put_path,
		unsigned int	get_path_length,
		const struct GNUNET_PeerIdentity *	get_path,
		const void *	data,
		size_t	data_size
	)

Handle a reply (route to origin).

Only forwards the reply back to other peers waiting for it. Does not do local caching or forwarding to local clients. Essentially calls GDS_NEIGHBOURS_handle_reply() for all peers that sent us a matching request recently.

Parameters

type	type of the block
expiration_time	when does the content expire
key	key for the content
put_path_length	number of entries in put_path
put_path	peers the original PUT traversed (if tracked)
get_path_length	number of entries in get_path
get_path	peers this reply has traversed so far (if tracked)
data	payload of the reply
data_size	number of bytes in data

Only forwards the reply back to other peers waiting for it. Does not do local caching or forwarding to local clients. Essentially calls GDS_NEIGHBOURS_handle_reply for all peers that sent us a matching request recently.

Parameters

type	type of the block
expiration_time	when does the content expire
key	key for the content
put_path_length	number of entries in put_path
put_path	peers the original PUT traversed (if tracked)
get_path_length	number of entries in get_path
get_path	peers this reply has traversed so far (if tracked)
data	payload of the reply
data_size	number of bytes in data

Definition at line 292 of file gnunet-service-dht_routing.c.

References data, ProcessContext::data, ProcessContext::data_size, data_size, ProcessContext::expiration_time, ProcessContext::get_path, ProcessContext::get_path_length, GNUNET_break, GNUNET_CONTAINER_multihashmap_get_multiple(), process(), ProcessContext::put_path, ProcessContext::put_path_length, RecentRequest::type, and ProcessContext::type.

Referenced by process_reply_with_path().

{
  struct ProcessContext pc;

  pc.type = type;
  pc.expiration_time = expiration_time;
  pc.put_path_length = put_path_length;
  pc.put_path = put_path;
  pc.get_path_length = get_path_length;
  pc.get_path = get_path;
  pc.data = data;
  pc.data_size = data_size;
  if (NULL == data)
    {
      /* Some apps might have an 'empty' reply as a valid reply; however,
         'process' will call GNUNET_BLOCK_evaluate' which treats a 'NULL'
         reply as request-validation (but we need response-validation).
         So we set 'data' to a 0-byte non-NULL value just to be sure */
      GNUNET_break(0 == data_size);
      pc.data_size = 0;
      pc.data = ""; /* something not null */
    }
  GNUNET_CONTAINER_multihashmap_get_multiple(recent_map,
                                             key,
                                             &process,
                                             &pc);
}

Here is the call graph for this function:

Here is the caller graph for this function:

GDS_ROUTING_add()

void GDS_ROUTING_add	(	const struct GNUNET_PeerIdentity *	sender,
		enum GNUNET_BLOCK_Type	type,
		struct GNUNET_BLOCK_Group *	bg,
		enum GNUNET_DHT_RouteOption	options,
		const struct GNUNET_HashCode *	key,
		const void *	xquery,
		size_t	xquery_size
	)

Add a new entry to our routing table.

Parameters

sender	peer that originated the request
type	type of the block
bg	block group to evaluate replies, henceforth owned by routing
options	options for processing
key	key for the content
xquery	extended query
xquery_size	number of bytes in xquery
sender	peer that originated the request
type	type of the block
options	options for processing
key	key for the content
xquery	extended query
xquery_size	number of bytes in xquery
reply_bf	bloomfilter to filter duplicates
reply_bf_mutator	mutator for reply_bf

Definition at line 403 of file gnunet-service-dht_routing.c.

References RecentRequest::bg, DHT_MAX_RECENT, expire_oldest_entry(), GDS_stats, gettext_noop, GNUNET_CONTAINER_heap_get_size(), GNUNET_CONTAINER_heap_insert(), GNUNET_CONTAINER_multihashmap_get_multiple(), GNUNET_CONTAINER_multihashmap_put(), GNUNET_CONTAINER_MULTIHASHMAPOPTION_MULTIPLE, GNUNET_malloc, GNUNET_memcpy, GNUNET_NO, GNUNET_STATISTICS_update(), GNUNET_SYSERR, GNUNET_TIME_absolute_get(), RecentRequest::heap_node, RecentRequest::key, RecentRequest::options, RecentRequest::peer, try_combine_recent(), RecentRequest::type, RecentRequest::xquery, and RecentRequest::xquery_size.

Referenced by handle_dht_p2p_get().

{
  struct RecentRequest *recent_req;

  while (GNUNET_CONTAINER_heap_get_size(recent_heap) >= DHT_MAX_RECENT)
    expire_oldest_entry();
  GNUNET_STATISTICS_update(GDS_stats,
                           gettext_noop("# Entries added to routing table"),
                           1,
                           GNUNET_NO);
  recent_req = GNUNET_malloc(sizeof(struct RecentRequest) + xquery_size);
  recent_req->peer = *sender;
  recent_req->key = *key;
  recent_req->bg = bg;
  recent_req->type = type;
  recent_req->options = options;
  recent_req->xquery = &recent_req[1];
  GNUNET_memcpy(&recent_req[1],
                xquery,
                xquery_size);
  recent_req->xquery_size = xquery_size;
  if (GNUNET_SYSERR ==
      GNUNET_CONTAINER_multihashmap_get_multiple(recent_map,
                                                 key,
                                                 &try_combine_recent,
                                                 recent_req))
    {
      GNUNET_STATISTICS_update(GDS_stats,
                               gettext_noop
                                 ("# DHT requests combined"),
                               1, GNUNET_NO);
      return;
    }
  recent_req->heap_node
    = GNUNET_CONTAINER_heap_insert(recent_heap,
                                   recent_req,
                                   GNUNET_TIME_absolute_get().abs_value_us);
  GNUNET_CONTAINER_multihashmap_put(recent_map,
                                    key,
                                    recent_req,
                                    GNUNET_CONTAINER_MULTIHASHMAPOPTION_MULTIPLE);
}

Here is the call graph for this function:

Here is the caller graph for this function:

GDS_ROUTING_init()

void GDS_ROUTING_init

(

void

)

Initialize routing subsystem.

Definition at line 457 of file gnunet-service-dht_routing.c.

References DHT_MAX_RECENT, GNUNET_CONTAINER_heap_create(), GNUNET_CONTAINER_HEAP_ORDER_MIN, GNUNET_CONTAINER_multihashmap_create(), and GNUNET_NO.

Referenced by run().

{
  recent_heap = GNUNET_CONTAINER_heap_create(GNUNET_CONTAINER_HEAP_ORDER_MIN);
  recent_map = GNUNET_CONTAINER_multihashmap_create(DHT_MAX_RECENT * 4 / 3, GNUNET_NO);
}

Here is the call graph for this function:

Here is the caller graph for this function:

GDS_ROUTING_done()

void GDS_ROUTING_done

(

void

)

Shutdown routing subsystem.

Definition at line 468 of file gnunet-service-dht_routing.c.

References expire_oldest_entry(), GNUNET_assert, GNUNET_CONTAINER_heap_destroy(), GNUNET_CONTAINER_heap_get_size(), GNUNET_CONTAINER_multihashmap_destroy(), and GNUNET_CONTAINER_multihashmap_size().

Referenced by shutdown_task().

{
  while (GNUNET_CONTAINER_heap_get_size(recent_heap) > 0)
    expire_oldest_entry();
  GNUNET_assert(0 == GNUNET_CONTAINER_heap_get_size(recent_heap));
  GNUNET_CONTAINER_heap_destroy(recent_heap);
  recent_heap = NULL;
  GNUNET_assert(0 == GNUNET_CONTAINER_multihashmap_size(recent_map));
  GNUNET_CONTAINER_multihashmap_destroy(recent_map);
  recent_map = NULL;
}

Here is the call graph for this function:

Here is the caller graph for this function: