gnunet-service-dht_datacache.h File Reference

GNUnet DHT service's datacache integration. More...

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

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

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

Go to the source code of this file.

Typedefs
typedef void(*	GDS_DATACACHE_GetCallback) (void *cls, const struct GNUNET_DATACACHE_Block *bd)
	Handle a result for a GET operation.

Functions
void	GDS_DATACACHE_handle_put (const struct GNUNET_DATACACHE_Block *bd)
	Handle a datum we've received from another peer.
enum GNUNET_BLOCK_ReplyEvaluationResult	GDS_DATACACHE_handle_get (const struct GNUNET_HashCode *key, enum GNUNET_BLOCK_Type type, const void *xquery, size_t xquery_size, struct GNUNET_BLOCK_Group *bg, GDS_DATACACHE_GetCallback gc, void *gc_cls)
	Handle a GET request we've received from another peer.
enum GNUNET_BLOCK_ReplyEvaluationResult	GDS_DATACACHE_get_closest (const struct GNUNET_HashCode *key, enum GNUNET_BLOCK_Type type, const void *xquery, size_t xquery_size, struct GNUNET_BLOCK_Group *bg, GDS_DATACACHE_GetCallback cb, void *cb_cls)
	Handle a request for data close to a key that we have received from another peer.
void	GDS_DATACACHE_init (void)
	Initialize datacache subsystem.
void	GDS_DATACACHE_done (void)
	Shutdown datacache subsystem.

Detailed Description

GNUnet DHT service's datacache integration.

Author

Christian Grothoff

Nathan Evans

Definition in file gnunet-service-dht_datacache.h.

Typedef Documentation

GDS_DATACACHE_GetCallback

typedef void(* GDS_DATACACHE_GetCallback) (void *cls, const struct GNUNET_DATACACHE_Block *bd)

Handle a result for a GET operation.

Parameters

cls	closure
bd	block details

Definition at line 52 of file gnunet-service-dht_datacache.h.

Function Documentation

GDS_DATACACHE_handle_put()

void GDS_DATACACHE_handle_put

(

const struct GNUNET_DATACACHE_Block *

bd

)

Handle a datum we've received from another peer.

Cache if possible.

Parameters

bd	block data to cache

Definition at line 49 of file gnunet-service-dht_datacache.c.

{
  struct GNUNET_HashCode xor;
  enum GNUNET_GenericReturnValue r;
 
  if (NULL == datacache)
  {
    GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
                "PUT request received, but have no datacache!\n");
    return;
  }
  if (bd->data_size >= GNUNET_MAX_MESSAGE_SIZE)
  {
    GNUNET_break (0);
    return;
  }
  /* Put size is actual data size plus struct overhead plus path length (if any) */
  GNUNET_STATISTICS_update (GDS_stats,
                            "# ITEMS stored in datacache",
                            1,
                            GNUNET_NO);
  GNUNET_CRYPTO_hash_xor (&bd->key,
                          &GDS_my_identity_hash,
                          &xor);
  r = GNUNET_DATACACHE_put (datacache,
                            GNUNET_CRYPTO_hash_count_leading_zeros (&xor),
                            bd);
  LOG (GNUNET_ERROR_TYPE_DEBUG,
       "DATACACHE PUT for key %s [%lu] completed (%d) after %u hops\n",
       GNUNET_h2s (&bd->key),
       (unsigned long) bd->data_size,
       r,
       bd->put_path_length);
}

References GNUNET_DATACACHE_Block::data_size, datacache, GDS_my_identity_hash, GDS_stats, GNUNET_break, GNUNET_CRYPTO_hash_count_leading_zeros(), GNUNET_CRYPTO_hash_xor(), GNUNET_DATACACHE_put(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_ERROR_TYPE_WARNING, GNUNET_h2s(), GNUNET_log, GNUNET_MAX_MESSAGE_SIZE, GNUNET_NO, GNUNET_STATISTICS_update(), GNUNET_DATACACHE_Block::key, LOG, and GNUNET_DATACACHE_Block::put_path_length.

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

Here is the call graph for this function:

Here is the caller graph for this function:

GDS_DATACACHE_handle_get()

enum GNUNET_BLOCK_ReplyEvaluationResult GDS_DATACACHE_handle_get	(	const struct GNUNET_HashCode *	key,
		enum GNUNET_BLOCK_Type	type,
		const void *	xquery,
		size_t	xquery_size,
		struct GNUNET_BLOCK_Group *	bg,
		GDS_DATACACHE_GetCallback	gc,
		void *	gc_cls
	)

Handle a GET request we've received from another peer.

Parameters

key	the query
type	requested data type
xquery	extended query
xquery_size	number of bytes in xquery
bg	block group to use for evaluation of replies
gc	function to call on the results
gc_cls	closure for gc

Returns

evaluation result for the local replies

Definition at line 192 of file gnunet-service-dht_datacache.c.

{
  struct GetRequestContext ctx = {
    .eval = GNUNET_BLOCK_REPLY_TYPE_NOT_SUPPORTED,
    .key = *key,
    .xquery = xquery,
    .xquery_size = xquery_size,
    .bg = bg,
    .gc = gc,
    .gc_cls = gc_cls
  };
  unsigned int r;
 
  if (NULL == datacache)
    return GNUNET_BLOCK_REPLY_TYPE_NOT_SUPPORTED;
  GNUNET_STATISTICS_update (GDS_stats,
                            "# GET requests given to datacache",
                            1,
                            GNUNET_NO);
  r = GNUNET_DATACACHE_get (datacache,
                            key,
                            type,
                            &datacache_get_iterator,
                            &ctx);
  LOG (GNUNET_ERROR_TYPE_DEBUG,
       "DATACACHE GET for key %s completed (%d). %u results found.\n",
       GNUNET_h2s (key),
       ctx.eval,
       r);
  return ctx.eval;
}

References GetRequestContext::bg, ctx, datacache, datacache_get_iterator(), GetRequestContext::gc, GetRequestContext::gc_cls, GDS_stats, GNUNET_BLOCK_REPLY_TYPE_NOT_SUPPORTED, GNUNET_DATACACHE_get(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_h2s(), GNUNET_NO, GNUNET_STATISTICS_update(), key, LOG, type, GetRequestContext::xquery, and GetRequestContext::xquery_size.

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

enum GNUNET_BLOCK_ReplyEvaluationResult GDS_DATACACHE_get_closest	(	const struct GNUNET_HashCode *	key,
		enum GNUNET_BLOCK_Type	type,
		const void *	xquery,
		size_t	xquery_size,
		struct GNUNET_BLOCK_Group *	bg,
		GDS_DATACACHE_GetCallback	cb,
		void *	cb_cls
	)

Handle a request for data close to a key that we have received from another peer.

Parameters

key	the location at which the peer is looking for data that is close
type	requested data type
xquery	extended query
xquery_size	number of bytes in xquery
bg	block group to use for evaluation of replies
cb	function to call with the result
cb_cls	closure for cb

Returns

evaluation result for the local replies

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

{
  struct GetRequestContext ctx = {
    .eval = GNUNET_BLOCK_REPLY_TYPE_NOT_SUPPORTED,
    .key = *key,
    .xquery = xquery,
    .xquery_size = xquery_size,
    .bg = bg,
    .gc = cb,
    .gc_cls = cb_cls
  };
  unsigned int r;
 
  if (NULL == datacache)
    return GNUNET_BLOCK_REPLY_TYPE_NOT_SUPPORTED;
  GNUNET_STATISTICS_update (GDS_stats,
                            "# GET closest requests given to datacache",
                            1,
                            GNUNET_NO);
  r = GNUNET_DATACACHE_get_closest (datacache,
                                    key,
                                    type,
                                    NUM_CLOSEST,
                                    &datacache_get_iterator,
                                    &ctx);
  LOG (GNUNET_ERROR_TYPE_DEBUG,
       "DATACACHE approximate GET for key %s completed (%d). %u results found.\n",
       GNUNET_h2s (key),
       ctx.eval,
       r);
  return ctx.eval;
}

References GetRequestContext::bg, ctx, datacache, datacache_get_iterator(), GDS_stats, GNUNET_BLOCK_REPLY_TYPE_NOT_SUPPORTED, GNUNET_DATACACHE_get_closest(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_h2s(), GNUNET_NO, GNUNET_STATISTICS_update(), key, LOG, NUM_CLOSEST, type, GetRequestContext::xquery, and GetRequestContext::xquery_size.

Referenced by handle_dht_p2p_get().

Here is the call graph for this function:

Here is the caller graph for this function:

GDS_DATACACHE_init()

void GDS_DATACACHE_init

(

void

)

Initialize datacache subsystem.

Definition at line 273 of file gnunet-service-dht_datacache.c.

{
  datacache = GNUNET_DATACACHE_create (GDS_cfg,
                                       "dhtcache");
}

References datacache, GDS_cfg, and GNUNET_DATACACHE_create().

Referenced by run().

Here is the call graph for this function:

Here is the caller graph for this function:

GDS_DATACACHE_done()

void GDS_DATACACHE_done

(

void

)

Shutdown datacache subsystem.

Definition at line 281 of file gnunet-service-dht_datacache.c.

{
  if (NULL != datacache)
  {
    GNUNET_DATACACHE_destroy (datacache);
    datacache = NULL;
  }
}

References datacache, and GNUNET_DATACACHE_destroy().

Referenced by shutdown_task().

Here is the call graph for this function:

Here is the caller graph for this function: