gnunet-dht-put.c File Reference

search for data in DHT More...

#include "platform.h"
#include "gnunet_dht_service.h"

Include dependency graph for gnunet-dht-put.c:

Go to the source code of this file.

Functions
static void	shutdown_task (void *cls)
static void	message_sent_cont (void *cls)
	Signature of the main function of a task. More...
static void	run (void *cls, char *const *args, const char *cfgfile, const struct GNUNET_CONFIGURATION_Handle *c)
	Main function that will be run by the scheduler. More...
int	main (int argc, char *const *argv)
	Entry point for gnunet-dht-put. More...

Variables
static unsigned int	query_type
	The type of the query. More...
struct GNUNET_HashCode	key
	The key used in the DHT. More...
static char *	query_key
	The key for the query. More...
static struct GNUNET_TIME_Relative	expiration
	User supplied expiration value. More...
static unsigned int	replication = 5
	Desired replication level. More...
static unsigned int	verbose
	Be verbose. More...
static int	demultixplex_everywhere
	Use #GNUNET_DHT_DEMULTIPLEX_EVERYWHERE. More...
static int	record_route
	Use GNUNET_DHT_RO_RECORD_ROUTE. More...
static struct GNUNET_DHT_Handle *	dht_handle
	Handle to the DHT. More...
static const struct GNUNET_CONFIGURATION_Handle *	cfg
	Global handle of the configuration. More...
static int	ret
	Global status value. More...
static char *	data
	The data to insert into the dht. More...

Detailed Description

search for data in DHT

Author

Christian Grothoff

Nathan Evans

Definition in file gnunet-dht-put.c.

Function Documentation

shutdown_task()

static void shutdown_task ( void *  cls )

static

Definition at line 92 of file gnunet-dht-put.c.

References GNUNET_DHT_disconnect().

Referenced by message_sent_cont().

{
  if (NULL != dht_handle)
    {
      GNUNET_DHT_disconnect(dht_handle);
      dht_handle = NULL;
    }
}

Here is the call graph for this function:

Here is the caller graph for this function:

message_sent_cont()

static void message_sent_cont ( void *  cls )

static

Signature of the main function of a task.

Parameters

cls

closure

Definition at line 108 of file gnunet-dht-put.c.

References GNUNET_SCHEDULER_add_now(), and shutdown_task().

Referenced by run().

{
  GNUNET_SCHEDULER_add_now(&shutdown_task, NULL);
}

Here is the call graph for this function:

Here is the caller graph for this function:

run()

static void run ( void *  cls, char *const *  args, const char *  cfgfile, const struct GNUNET_CONFIGURATION_Handle *  c  )

static

Main function that will be run by the scheduler.

Parameters

cls	closure
args	remaining command-line arguments
cfgfile	name of the configuration file used (for saving, can be NULL!)
c	configuration

Definition at line 123 of file gnunet-dht-put.c.

References _, data, demultixplex_everywhere, expiration, GNUNET_BLOCK_TYPE_ANY, GNUNET_BLOCK_TYPE_TEST, GNUNET_CRYPTO_hash(), GNUNET_DHT_connect(), GNUNET_DHT_put(), GNUNET_DHT_RO_DEMULTIPLEX_EVERYWHERE, GNUNET_DHT_RO_NONE, GNUNET_DHT_RO_RECORD_ROUTE, GNUNET_TIME_relative_to_absolute(), key, message_sent_cont(), query_key, query_type, record_route, replication, ret, and verbose.

Referenced by main().

{
  enum GNUNET_DHT_RouteOption ro;

  cfg = c;
  if ((NULL == query_key) || (NULL == data))
    {
      fprintf(stderr, "%s", _("Must provide KEY and DATA for DHT put!\n"));
      ret = 1;
      return;
    }

  if (NULL == (dht_handle = GNUNET_DHT_connect(cfg, 1)))
    {
      fprintf(stderr, _("Could not connect to DHT service!\n"));
      ret = 1;
      return;
    }
  if (GNUNET_BLOCK_TYPE_ANY == query_type) /* Type of data not set */
    query_type = GNUNET_BLOCK_TYPE_TEST;

  GNUNET_CRYPTO_hash(query_key, strlen(query_key), &key);

  if (verbose)
    fprintf(stderr,
            _("Issuing put request for `%s' with data `%s'!\n"),
            query_key,
            data);
  ro = GNUNET_DHT_RO_NONE;
  if (demultixplex_everywhere)
    ro |= GNUNET_DHT_RO_DEMULTIPLEX_EVERYWHERE;
  if (record_route)
    ro |= GNUNET_DHT_RO_RECORD_ROUTE;
  GNUNET_DHT_put(dht_handle,
                 &key,
                 replication,
                 ro,
                 query_type,
                 strlen(data),
                 data,
                 GNUNET_TIME_relative_to_absolute(expiration),
                 &message_sent_cont,
                 NULL);
}

Here is the call graph for this function:

Here is the caller graph for this function:

main()

int main	(	int	argc,
		char *const *	argv
	)

Entry point for gnunet-dht-put.

Parameters

argc	number of arguments from the command line
argv	command line arguments

Returns

0 ok, 1 on error

Definition at line 179 of file gnunet-dht-put.c.

References data, demultixplex_everywhere, expiration, gettext_noop, GNUNET_GETOPT_OPTION_END, GNUNET_GETOPT_option_flag(), GNUNET_GETOPT_option_relative_time(), GNUNET_GETOPT_option_string(), GNUNET_GETOPT_option_uint(), GNUNET_GETOPT_option_verbose(), GNUNET_OK, GNUNET_PROGRAM_run(), GNUNET_STRINGS_get_utf8_args(), GNUNET_TIME_UNIT_HOURS, query_key, query_type, record_route, replication, ret, run(), and verbose.

{
  struct GNUNET_GETOPT_CommandLineOption options[] =
  { GNUNET_GETOPT_option_string('d',
                                "data",
                                "DATA",
                                gettext_noop(
                                  "the data to insert under the key"),
                                &data),
    GNUNET_GETOPT_option_relative_time(
      'e',
      "expiration",
      "EXPIRATION",
      gettext_noop("how long to store this entry in the dht (in seconds)"),
      &expiration),
    GNUNET_GETOPT_option_string('k',
                                "key",
                                "KEY",
                                gettext_noop("the query key"),
                                &query_key),
    GNUNET_GETOPT_option_flag('x',
                              "demultiplex",
                              gettext_noop(
                                "use DHT's demultiplex everywhere option"),
                              &demultixplex_everywhere),
    GNUNET_GETOPT_option_uint('r',
                              "replication",
                              "LEVEL",
                              gettext_noop("how many replicas to create"),
                              &replication),
    GNUNET_GETOPT_option_flag('R',
                              "record",
                              gettext_noop("use DHT's record route option"),
                              &record_route),
    GNUNET_GETOPT_option_uint('t',
                              "type",
                              "TYPE",
                              gettext_noop("the type to insert data as"),
                              &query_type),
    GNUNET_GETOPT_option_verbose(&verbose),
    GNUNET_GETOPT_OPTION_END };


  if (GNUNET_OK != GNUNET_STRINGS_get_utf8_args(argc, argv, &argc, &argv))
    return 2;
  expiration = GNUNET_TIME_UNIT_HOURS;
  return (GNUNET_OK ==
          GNUNET_PROGRAM_run(
            argc,
            argv,
            "gnunet-dht-put",
            gettext_noop(
              "Issue a PUT request to the GNUnet DHT insert DATA under KEY."),
            options,
            &run,
            NULL))
         ? ret
         : 1;
}

Here is the call graph for this function:

Variable Documentation

query_type

unsigned int query_type

static

The type of the query.

Definition at line 32 of file gnunet-dht-put.c.

Referenced by main(), and run().

key

struct GNUNET_HashCode key

The key used in the DHT.

Definition at line 37 of file gnunet-dht-put.c.

Referenced by build_result_set(), collector(), decode_and_send(), dns_string_to_value(), get_ibf_key(), get_iv_key(), get_redirect_state(), get_result_iterator(), GNUNET_ABE_cpabe_create_master_key(), GNUNET_ABE_cpabe_deserialize_key(), GNUNET_ABE_cpabe_deserialize_master_key(), GNUNET_CRYPTO_cpabe_create_master_key(), GNUNET_CRYPTO_cpabe_deserialize_key(), GNUNET_CRYPTO_cpabe_deserialize_master_key(), GNUNET_CRYPTO_rsa_private_key_decode(), GNUNET_CRYPTO_rsa_public_key_decode(), GNUNET_DATASTORE_get_key(), GNUNET_DATASTORE_put(), GNUNET_DATASTORE_remove(), GNUNET_DHT_get_start(), GNUNET_DHT_monitor_start(), GNUNET_DHT_put(), GNUNET_REVOCATION_query(), GNUNET_REVOCATION_revoke(), handle_client_redirect_to_ip(), handle_client_redirect_to_service(), iterateBits(), message_sent_cont(), no_more_local_results(), process_ksk_result(), process_migration_content(), process_sks_result(), regex_edge_iterator(), regex_iterator(), run(), setup_cipher(), setup_state_record(), store_skipped_key(), transmit_item(), try_old_ax_keys(), and update_config_sections().

query_key

char* query_key

static

The key for the query.

Definition at line 42 of file gnunet-dht-put.c.

Referenced by main(), and run().

expiration

struct GNUNET_TIME_Relative expiration

static

User supplied expiration value.

Definition at line 47 of file gnunet-dht-put.c.

Referenced by main(), and run().

replication

unsigned int replication = 5

static

Desired replication level.

Definition at line 52 of file gnunet-dht-put.c.

Referenced by main(), and run().

verbose

unsigned int verbose

static

Be verbose.

Definition at line 57 of file gnunet-dht-put.c.

Referenced by main(), and run().

demultixplex_everywhere

int demultixplex_everywhere

static

Use #GNUNET_DHT_DEMULTIPLEX_EVERYWHERE.

Definition at line 62 of file gnunet-dht-put.c.

Referenced by main(), and run().

record_route

int record_route

static

Use GNUNET_DHT_RO_RECORD_ROUTE.

Definition at line 67 of file gnunet-dht-put.c.

Referenced by main(), and run().

dht_handle

struct GNUNET_DHT_Handle* dht_handle

static

Handle to the DHT.

Definition at line 72 of file gnunet-dht-put.c.

cfg

const struct GNUNET_CONFIGURATION_Handle* cfg

static

Global handle of the configuration.

Definition at line 78 of file gnunet-dht-put.c.

ret

int ret

static

Global status value.

Definition at line 83 of file gnunet-dht-put.c.

Referenced by main(), and run().

data

char* data

static

The data to insert into the dht.

Definition at line 88 of file gnunet-dht-put.c.

Referenced by main(), and run().