GNUnet  0.19.2
gnunet-namestore.c File Reference

command line tool to manipulate the local zone More...

#include "platform.h"
#include <gnunet_util_lib.h>
#include <gnunet_identity_service.h>
#include <gnunet_gnsrecord_lib.h>
#include <gnunet_gns_service.h>
#include <gnunet_namestore_service.h>
#include <inttypes.h>
Include dependency graph for gnunet-namestore.c:

Go to the source code of this file.

Data Structures

struct  RecordSetEntry
 Entry in record set for bulk processing. More...
 
struct  MarkedRecord
 The record marked for deletion. More...
 
struct  EgoEntry
 The ego list. More...
 

Macros

#define WARN_RELATIVE_EXPIRATION_LIMIT
 The upper bound for the zone iteration interval (per record). More...
 
#define MAX_LINE_LEN   4086
 
#define MAX_ARGS   20
 

Functions

static int parse_expiration (const char *expirationstring, int *etime_is_rel, uint64_t *etime)
 Parse expiration time. More...
 
static int parse_recordline (const char *line)
 
static void reset_handles (void)
 
static void do_shutdown (void *cls)
 Task run on shutdown. More...
 
static void commit_cb (void *cls, enum GNUNET_ErrorCode ec)
 
static void process_command_stdin ()
 
static void finish_command (void)
 
static void add_continuation (void *cls, enum GNUNET_ErrorCode ec)
 
static void del_continuation (void *cls, enum GNUNET_ErrorCode ec)
 
static void purge_next_record (void *cls)
 
static void marked_deleted (void *cls, enum GNUNET_ErrorCode ec)
 
static void zone_iteration_finished (void *cls)
 Function called when we are done with a zone iteration. More...
 
static void zone_iteration_error_cb (void *cls)
 Function called when we encountered an error in a zone iteration. More...
 
static void collect_zone_records_to_purge (const struct GNUNET_IDENTITY_PrivateKey *zone_key, const char *rname, unsigned int rd_len, const struct GNUNET_GNSRECORD_Data *rd)
 
static void collect_orphans (const struct GNUNET_IDENTITY_PrivateKey *zone_key, const char *rname, unsigned int rd_len, const struct GNUNET_GNSRECORD_Data *rd)
 
static void display_record (const struct GNUNET_IDENTITY_PrivateKey *zone_key, const char *rname, unsigned int rd_len, const struct GNUNET_GNSRECORD_Data *rd)
 Process a record that was stored in the namestore. More...
 
static void purge_zone_iterator (void *cls, const struct GNUNET_IDENTITY_PrivateKey *zone_key, const char *rname, unsigned int rd_len, const struct GNUNET_GNSRECORD_Data *rd, struct GNUNET_TIME_Absolute expiry)
 
static void purge_orphans_iterator (void *cls, const struct GNUNET_IDENTITY_PrivateKey *zone_key, const char *rname, unsigned int rd_len, const struct GNUNET_GNSRECORD_Data *rd, struct GNUNET_TIME_Absolute expiry)
 
static void display_record_iterator (void *cls, const struct GNUNET_IDENTITY_PrivateKey *zone_key, const char *rname, unsigned int rd_len, const struct GNUNET_GNSRECORD_Data *rd, struct GNUNET_TIME_Absolute expiry)
 Process a record that was stored in the namestore. More...
 
static void display_record_monitor (void *cls, const struct GNUNET_IDENTITY_PrivateKey *zone_key, const char *rname, unsigned int rd_len, const struct GNUNET_GNSRECORD_Data *rd, struct GNUNET_TIME_Absolute expiry)
 Process a record that was stored in the namestore. More...
 
static void display_record_lookup (void *cls, const struct GNUNET_IDENTITY_PrivateKey *zone_key, const char *rname, unsigned int rd_len, const struct GNUNET_GNSRECORD_Data *rd)
 Process a record that was stored in the namestore. More...
 
static void sync_cb (void *cls)
 Function called once we are in sync in monitor mode. More...
 
static void monitor_error_cb (void *cls)
 Function called on errors while monitoring. More...
 
static void lookup_error_cb (void *cls)
 Function called on errors while monitoring. More...
 
static void add_error_cb (void *cls)
 Function called if lookup fails. More...
 
static void get_existing_record (void *cls, const struct GNUNET_IDENTITY_PrivateKey *zone_key, const char *rec_name, unsigned int rd_count, const struct GNUNET_GNSRECORD_Data *rd)
 We're storing a record; this function is given the existing record so that we can merge the information. More...
 
static void reverse_error_cb (void *cls)
 Function called if we encountered an error in zone-to-name. More...
 
static void handle_reverse_lookup (void *cls, const struct GNUNET_IDENTITY_PrivateKey *zone, const char *label, unsigned int rd_count, const struct GNUNET_GNSRECORD_Data *rd)
 Function called with the result of our attempt to obtain a name for a given public key. More...
 
static void del_lookup_error_cb (void *cls)
 Function called if lookup for deletion fails. More...
 
static void del_monitor (void *cls, const struct GNUNET_IDENTITY_PrivateKey *zone, const char *label, unsigned int rd_count, const struct GNUNET_GNSRECORD_Data *rd)
 We were asked to delete something; this function is called with the existing records. More...
 
static void replace_cont (void *cls, enum GNUNET_ErrorCode ec)
 
static void run_with_zone_pkey (const struct GNUNET_CONFIGURATION_Handle *cfg)
 We have obtained the zone's private key, so now process the main commands using it. More...
 
static int get_identity_for_string (const char *str, struct GNUNET_IDENTITY_PrivateKey *zk)
 
static void begin_cb (void *cls, enum GNUNET_ErrorCode ec)
 
static void id_connect_cb (void *cls, struct GNUNET_IDENTITY_Ego *ego, void **ctx, const char *name)
 Function called with ALL of the egos known to the identity service, used on startup if the user did not specify a zone on the command-line. More...
 
static void run (void *cls, char *const *args, const char *cfgfile, const struct GNUNET_CONFIGURATION_Handle *_cfg)
 Main function that will be run. More...
 
int main (int argc, char *const *argv)
 The main function for gnunet-namestore. More...
 

Variables

static struct GNUNET_NAMESTORE_Handlens
 Handle to the namestore. More...
 
static struct GNUNET_IDENTITY_PrivateKey zone_pkey
 Private key for the our zone. More...
 
static struct GNUNET_IDENTITY_Handleidh
 Identity service handle. More...
 
static char * ego_name
 Name of the ego controlling the zone. More...
 
static struct GNUNET_NAMESTORE_QueueEntryadd_qe_uri
 Queue entry for the 'add-uri' operation. More...
 
static struct GNUNET_NAMESTORE_QueueEntryadd_qe
 Queue entry for the 'add' operation. More...
 
static struct GNUNET_NAMESTORE_QueueEntryget_qe
 Queue entry for the 'lookup' operation. More...
 
static struct GNUNET_NAMESTORE_QueueEntryreverse_qe
 Queue entry for the 'reverse lookup' operation (in combination with a name). More...
 
static struct MarkedRecordmarked_head
 Marked record list. More...
 
static struct MarkedRecordmarked_tail
 Marked record list. More...
 
const struct GNUNET_CONFIGURATION_Handlecfg
 Configuration handle. More...
 
static struct EgoEntryego_head
 Ego list. More...
 
static struct EgoEntryego_tail
 Ego list. More...
 
static struct GNUNET_NAMESTORE_ZoneIteratorlist_it
 List iterator for the 'list' operation. More...
 
static int read_from_stdin
 Run in read from stdin mode. More...
 
static int list
 Desired action is to list records. More...
 
static int add
 Desired action is to add a record. More...
 
static int del
 Desired action is to remove a record. More...
 
static int is_public
 Is record public (opposite of GNUNET_GNSRECORD_RF_PRIVATE) More...
 
static int is_shadow
 Is record a shadow record (GNUNET_GNSRECORD_RF_SHADOW) More...
 
static int omit_private
 Filter private records. More...
 
static int output_recordline
 Output in recordline format. More...
 
static int purge_zone
 Purge zone contents. More...
 
static int include_maintenance
 Do not filter maintenance records. More...
 
static int purge_orphaned
 Purge orphaned records. More...
 
static int list_orphaned
 List records and zone keys of orphaned records. More...
 
static struct GNUNET_NAMESTORE_QueueEntrydel_qe
 Queue entry for the 'del' operation. More...
 
static struct GNUNET_NAMESTORE_QueueEntryset_qe
 Queue entry for the 'set/replace' operation. More...
 
static struct GNUNET_NAMESTORE_QueueEntryns_qe
 Queue entry for begin/commit. More...
 
static char * name
 Name of the records to add/list/remove. More...
 
static char * value
 Value of the record to add/remove. More...
 
static char * uri
 URI to import. More...
 
static char * reverse_pkey
 Reverse lookup to perform. More...
 
static char * typestring
 Type of the record to add/remove, NULL to remove all. More...
 
static char * expirationstring
 Desired expiration time. More...
 
static char * nickstring
 Desired nick name. More...
 
static int ret
 Global return value. More...
 
static uint32_t type
 Type string converted to DNS type value. More...
 
static void * data
 Value in binary format. More...
 
static size_t data_size
 Number of bytes in data. More...
 
static uint64_t etime
 Expiration string converted to numeric value. More...
 
static int etime_is_rel = GNUNET_SYSERR
 Is expiration time relative or absolute time? More...
 
static struct GNUNET_NAMESTORE_ZoneMonitorzm
 Monitor handle. More...
 
static int monitor
 Enables monitor mode. More...
 
static struct RecordSetEntryrecordset
 Entry in record set for processing records in bulk. More...
 
static struct GNUNET_SCHEDULER_Taskpurge_task
 Purge task. More...
 

Detailed Description

command line tool to manipulate the local zone

Author
Christian Grothoff

TODO:

  • test

Definition in file gnunet-namestore.c.

Macro Definition Documentation

◆ WARN_RELATIVE_EXPIRATION_LIMIT

#define WARN_RELATIVE_EXPIRATION_LIMIT
Value:
#define GNUNET_TIME_UNIT_MINUTES
One minute.
struct GNUNET_TIME_Relative GNUNET_TIME_relative_multiply(struct GNUNET_TIME_Relative rel, unsigned long long factor)
Multiply relative time by a given factor.
Definition: time.c:484

The upper bound for the zone iteration interval (per record).

Definition at line 40 of file gnunet-namestore.c.

◆ MAX_LINE_LEN

#define MAX_LINE_LEN   4086

Definition at line 1732 of file gnunet-namestore.c.

◆ MAX_ARGS

#define MAX_ARGS   20

Definition at line 1734 of file gnunet-namestore.c.

Function Documentation

◆ parse_expiration()

static int parse_expiration ( const char *  expirationstring,
int *  etime_is_rel,
uint64_t *  etime 
)
static

Parse expiration time.

Parameters
expirationstringtext to parse
[out]etime_is_relset to GNUNET_YES if time is relative
[out]etimeset to expiration time (abs or rel)
Returns
GNUNET_OK on success

Definition at line 351 of file gnunet-namestore.c.

354 {
355  struct GNUNET_TIME_Relative etime_rel;
356  struct GNUNET_TIME_Absolute etime_abs;
357 
358  if (0 == strcmp (expirationstring, "never"))
359  {
360  *etime = GNUNET_TIME_UNIT_FOREVER_ABS.abs_value_us;
362  return GNUNET_OK;
363  }
364  if (GNUNET_OK ==
366  {
368  *etime = etime_rel.rel_value_us;
370  {
372  "Relative expiration times of less than %s are not recommended. To improve availability, consider increasing this value.\n",
375  }
377  "Storing record with relative expiration time of %s\n",
379  return GNUNET_OK;
380  }
381  if (GNUNET_OK ==
383  {
385  *etime = etime_abs.abs_value_us;
387  "Storing record with absolute expiration time of %s\n",
389  return GNUNET_OK;
390  }
391  return GNUNET_SYSERR;
392 }
#define WARN_RELATIVE_EXPIRATION_LIMIT
The upper bound for the zone iteration interval (per record).
static int etime_is_rel
Is expiration time relative or absolute time?
static char * expirationstring
Desired expiration time.
static uint64_t etime
Expiration string converted to numeric value.
#define GNUNET_log(kind,...)
@ GNUNET_OK
@ GNUNET_YES
@ GNUNET_NO
@ GNUNET_SYSERR
@ GNUNET_ERROR_TYPE_WARNING
@ GNUNET_ERROR_TYPE_DEBUG
enum GNUNET_GenericReturnValue GNUNET_STRINGS_fancy_time_to_relative(const char *fancy_time, struct GNUNET_TIME_Relative *rtime)
Convert a given fancy human-readable time to our internal representation.
Definition: strings.c:260
#define GNUNET_TIME_relative_cmp(t1, op, t2)
Compare two relative times.
const char * GNUNET_STRINGS_absolute_time_to_string(struct GNUNET_TIME_Absolute t)
Like asctime, except for GNUnet time.
Definition: strings.c:616
const char * GNUNET_STRINGS_relative_time_to_string(struct GNUNET_TIME_Relative delta, int do_round)
Give relative time in human-readable fancy format.
Definition: strings.c:569
#define GNUNET_TIME_UNIT_FOREVER_ABS
Constant used to specify "forever".
enum GNUNET_GenericReturnValue GNUNET_STRINGS_fancy_time_to_absolute(const char *fancy_time, struct GNUNET_TIME_Absolute *atime)
Convert a given fancy human-readable time to our internal representation.
Definition: strings.c:302
Time for absolute times used by GNUnet, in microseconds.
Time for relative time used by GNUnet, in microseconds.

References GNUNET_TIME_Absolute::abs_value_us, etime, etime_is_rel, expirationstring, GNUNET_ERROR_TYPE_DEBUG, GNUNET_ERROR_TYPE_WARNING, GNUNET_log, GNUNET_NO, GNUNET_OK, GNUNET_STRINGS_absolute_time_to_string(), GNUNET_STRINGS_fancy_time_to_absolute(), GNUNET_STRINGS_fancy_time_to_relative(), GNUNET_STRINGS_relative_time_to_string(), GNUNET_SYSERR, GNUNET_TIME_relative_cmp, GNUNET_TIME_UNIT_FOREVER_ABS, GNUNET_YES, GNUNET_TIME_Relative::rel_value_us, and WARN_RELATIVE_EXPIRATION_LIMIT.

Referenced by run_with_zone_pkey().

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

◆ parse_recordline()

static int parse_recordline ( const char *  line)
static

Definition at line 396 of file gnunet-namestore.c.

397 {
398  struct RecordSetEntry **head = &recordset;
399  struct RecordSetEntry *r;
401  char *cp;
402  char *tok;
403  char *saveptr;
404  void *raw_data;
405 
406  cp = GNUNET_strdup (line);
407  tok = strtok_r (cp, " ", &saveptr);
408  if (NULL == tok)
409  {
411  _ ("Missing entries in record line `%s'.\n"),
412  line);
413  GNUNET_free (cp);
414  return GNUNET_SYSERR;
415  }
416  record.record_type = GNUNET_GNSRECORD_typename_to_number (tok);
417  if (UINT32_MAX == record.record_type)
418  {
419  GNUNET_log (GNUNET_ERROR_TYPE_ERROR, _ ("Unknown record type `%s'\n"), tok);
420  GNUNET_free (cp);
421  return GNUNET_SYSERR;
422  }
423  tok = strtok_r (NULL, " ", &saveptr);
424  if (NULL == tok)
425  {
427  _ ("Empty record line argument is not allowed.\n"));
428  GNUNET_free (cp);
429  return GNUNET_SYSERR;
430  }
431  if (1 != sscanf (tok, "%" SCNu64, &record.expiration_time))
432  {
433  fprintf (stderr,
434  _ ("Error parsing expiration time %s.\n"), tok);
435  GNUNET_free (cp);
436  return GNUNET_SYSERR;
437  }
438  tok = strtok_r (NULL, " ", &saveptr);
439  if (NULL == tok)
440  {
442  _ ("Empty record line argument is not allowed.\n"));
443  GNUNET_free (cp);
444  return GNUNET_SYSERR;
445  }
447  if (NULL != strchr (tok, (unsigned char) 'r'))
449  if (NULL == strchr (tok, (unsigned char) 'p')) /* p = public */
451  if (NULL != strchr (tok, (unsigned char) 'S'))
453  if (NULL != strchr (tok, (unsigned char) 's'))
455  if (NULL != strchr (tok, (unsigned char) 'C'))
457  tok += strlen (tok) + 1;
459  tok,
460  &raw_data,
461  &record.data_size))
462  {
464  _ ("Invalid record data for type %s: `%s'.\n"),
466  tok);
467  return GNUNET_SYSERR;
468  }
469 
470  r = GNUNET_malloc (sizeof(struct RecordSetEntry) + record.data_size);
471  r->next = *head;
472  record.data = &r[1];
473  memcpy (&r[1], raw_data, record.data_size);
474  GNUNET_free (raw_data);
475  r->record = record;
476  *head = r;
477  return GNUNET_OK;
478 }
static struct PendingResolutions * head
Head of list of pending resolution requests.
Definition: gnunet-ats.c:230
static void record(void *cls, size_t data_size, const void *data)
Process recorded audio data.
static char * line
Desired phone line (string to be converted to a hash).
static struct RecordSetEntry * recordset
Entry in record set for processing records in bulk.
const char * GNUNET_GNSRECORD_number_to_typename(uint32_t type)
Convert a type number to the corresponding type string (e.g.
Definition: gnsrecord.c:227
@ GNUNET_GNSRECORD_RF_RELATIVE_EXPIRATION
This expiration time of the record is a relative time (not an absolute time).
@ GNUNET_GNSRECORD_RF_CRITICAL
This record is critical.
@ GNUNET_GNSRECORD_RF_SUPPLEMENTAL
This is a supplemental record.
@ GNUNET_GNSRECORD_RF_SHADOW
This record should not be used unless all (other) records in the set with an absolute expiration time...
@ GNUNET_GNSRECORD_RF_PRIVATE
This is a private record of this peer and it should thus not be published.
@ GNUNET_GNSRECORD_RF_NONE
Entry for no flags / cleared flags.
uint32_t GNUNET_GNSRECORD_typename_to_number(const char *dns_typename)
Convert a type name (e.g.
Definition: gnsrecord.c:200
int GNUNET_GNSRECORD_string_to_value(uint32_t type, const char *s, void **data, size_t *data_size)
Convert human-readable version of the value s of a record of type type to the respective binary repre...
Definition: gnsrecord.c:177
@ GNUNET_ERROR_TYPE_ERROR
#define GNUNET_strdup(a)
Wrapper around GNUNET_xstrdup_.
#define GNUNET_malloc(size)
Wrapper around malloc.
#define GNUNET_free(ptr)
Wrapper around free.
#define _(String)
GNU gettext support macro.
Definition: platform.h:177
Entry in record set for bulk processing.
struct GNUNET_GNSRECORD_Data record
The record to add/remove.
struct RecordSetEntry * next
Kept in a linked list.

References _, GNUNET_ERROR_TYPE_ERROR, GNUNET_free, GNUNET_GNSRECORD_number_to_typename(), GNUNET_GNSRECORD_RF_CRITICAL, GNUNET_GNSRECORD_RF_NONE, GNUNET_GNSRECORD_RF_PRIVATE, GNUNET_GNSRECORD_RF_RELATIVE_EXPIRATION, GNUNET_GNSRECORD_RF_SHADOW, GNUNET_GNSRECORD_RF_SUPPLEMENTAL, GNUNET_GNSRECORD_string_to_value(), GNUNET_GNSRECORD_typename_to_number(), GNUNET_log, GNUNET_malloc, GNUNET_OK, GNUNET_strdup, GNUNET_SYSERR, head, line, RecordSetEntry::next, record(), RecordSetEntry::record, and recordset.

Referenced by process_command_stdin().

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

◆ reset_handles()

static void reset_handles ( void  )
static

Definition at line 481 of file gnunet-namestore.c.

482 {
483  struct MarkedRecord *mrec;
484  struct MarkedRecord *mrec_tmp;
485  struct RecordSetEntry *rs_entry;
486 
487  rs_entry = recordset;
488  while (NULL != (rs_entry = recordset))
489  {
491  GNUNET_free (rs_entry);
492  }
493  recordset = NULL;
494  if (NULL != ego_name)
495  {
497  ego_name = NULL;
498  }
499  if (NULL != name)
500  {
501  GNUNET_free (name);
502  name = NULL;
503  }
504  if (NULL != value)
505  {
506  GNUNET_free (value);
507  value = NULL;
508  }
509  if (NULL != uri)
510  {
511  GNUNET_free (uri);
512  uri = NULL;
513  }
514  if (NULL != expirationstring)
515  {
517  expirationstring = NULL;
518  }
519  if (NULL != purge_task)
520  {
522  purge_task = NULL;
523  }
524  for (mrec = marked_head; NULL != mrec;)
525  {
526  mrec_tmp = mrec;
527  mrec = mrec->next;
528  GNUNET_free (mrec_tmp->name);
529  GNUNET_free (mrec_tmp);
530  }
531  if (NULL != list_it)
532  {
534  list_it = NULL;
535  }
536  if (NULL != add_qe)
537  {
539  add_qe = NULL;
540  }
541  if (NULL != set_qe)
542  {
544  set_qe = NULL;
545  }
546  if (NULL != add_qe_uri)
547  {
549  add_qe_uri = NULL;
550  }
551  if (NULL != get_qe)
552  {
554  get_qe = NULL;
555  }
556  if (NULL != del_qe)
557  {
559  del_qe = NULL;
560  }
561  if (NULL != reverse_qe)
562  {
564  reverse_qe = NULL;
565  }
566  memset (&zone_pkey, 0, sizeof(zone_pkey));
567  if (NULL != zm)
568  {
570  zm = NULL;
571  }
572  if (NULL != data)
573  {
574  GNUNET_free (data);
575  data = NULL;
576  }
577  if (NULL != typestring)
578  {
580  typestring = NULL;
581  }
582  list = 0;
583  is_public = 0;
584  is_shadow = 0;
585  purge_zone = 0;
586 }
static struct GNUNET_NAMESTORE_QueueEntry * get_qe
Queue entry for the 'lookup' operation.
static struct GNUNET_NAMESTORE_ZoneMonitor * zm
Monitor handle.
static struct GNUNET_IDENTITY_PrivateKey zone_pkey
Private key for the our zone.
static struct GNUNET_NAMESTORE_QueueEntry * add_qe
Queue entry for the 'add' operation.
static char * value
Value of the record to add/remove.
static int list
Desired action is to list records.
static struct GNUNET_NAMESTORE_QueueEntry * del_qe
Queue entry for the 'del' operation.
static int purge_zone
Purge zone contents.
static char * name
Name of the records to add/list/remove.
static struct GNUNET_NAMESTORE_QueueEntry * set_qe
Queue entry for the 'set/replace' operation.
static void * data
Value in binary format.
static char * ego_name
Name of the ego controlling the zone.
static struct MarkedRecord * marked_head
Marked record list.
static int is_shadow
Is record a shadow record (GNUNET_GNSRECORD_RF_SHADOW)
static struct GNUNET_SCHEDULER_Task * purge_task
Purge task.
static struct GNUNET_NAMESTORE_ZoneIterator * list_it
List iterator for the 'list' operation.
static struct GNUNET_NAMESTORE_QueueEntry * add_qe_uri
Queue entry for the 'add-uri' operation.
static struct GNUNET_NAMESTORE_QueueEntry * reverse_qe
Queue entry for the 'reverse lookup' operation (in combination with a name).
static char * typestring
Type of the record to add/remove, NULL to remove all.
static char * uri
URI to import.
static int is_public
Is record public (opposite of GNUNET_GNSRECORD_RF_PRIVATE)
void GNUNET_NAMESTORE_cancel(struct GNUNET_NAMESTORE_QueueEntry *qe)
Cancel a namestore operation.
void GNUNET_NAMESTORE_zone_monitor_stop(struct GNUNET_NAMESTORE_ZoneMonitor *zm)
Stop monitoring a zone for changes.
void GNUNET_NAMESTORE_zone_iteration_stop(struct GNUNET_NAMESTORE_ZoneIterator *it)
Stops iteration and releases the namestore handle for further calls.
void * GNUNET_SCHEDULER_cancel(struct GNUNET_SCHEDULER_Task *task)
Cancel the task with the specified identifier.
Definition: scheduler.c:944
The record marked for deletion.
struct MarkedRecord * next
DLL.
char * name
Ego Identifier.

References add_qe, add_qe_uri, data, del_qe, ego_name, expirationstring, get_qe, GNUNET_free, GNUNET_NAMESTORE_cancel(), GNUNET_NAMESTORE_zone_iteration_stop(), GNUNET_NAMESTORE_zone_monitor_stop(), GNUNET_SCHEDULER_cancel(), is_public, is_shadow, list, list_it, marked_head, MarkedRecord::name, name, RecordSetEntry::next, MarkedRecord::next, purge_task, purge_zone, recordset, reverse_qe, set_qe, typestring, uri, value, zm, and zone_pkey.

Referenced by do_shutdown(), and finish_command().

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

◆ do_shutdown()

static void do_shutdown ( void *  cls)
static

Task run on shutdown.

Cleans up everything.

Parameters
clsunused

Definition at line 596 of file gnunet-namestore.c.

597 {
598  struct EgoEntry *ego_entry;
599  struct EgoEntry *ego_tmp;
600  (void) cls;
601 
602  reset_handles ();
603  if (NULL != ns_qe)
604  {
606  ns_qe = NULL;
607  }
608  if (NULL != ns)
609  {
611  ns = NULL;
612  }
613  if (NULL != idh)
614  {
616  idh = NULL;
617  }
618  for (ego_entry = ego_head; NULL != ego_entry;)
619  {
620  ego_tmp = ego_entry;
621  ego_entry = ego_entry->next;
622  GNUNET_free (ego_tmp->identifier);
623  GNUNET_free (ego_tmp);
624  }
625 }
static struct GNUNET_NAMESTORE_QueueEntry * ns_qe
Queue entry for begin/commit.
static void reset_handles(void)
static struct GNUNET_IDENTITY_Handle * idh
Identity service handle.
static struct EgoEntry * ego_head
Ego list.
static struct GNUNET_NAMESTORE_Handle * ns
Handle to the namestore.
void GNUNET_IDENTITY_disconnect(struct GNUNET_IDENTITY_Handle *h)
Disconnect from identity service.
Definition: identity_api.c:757
void GNUNET_NAMESTORE_disconnect(struct GNUNET_NAMESTORE_Handle *h)
Disconnect from the namestore service (and free associated resources).
The ego list.
char * identifier
Ego Identifier.
struct EgoEntry * next
DLL.

References ego_head, GNUNET_free, GNUNET_IDENTITY_disconnect(), GNUNET_NAMESTORE_cancel(), GNUNET_NAMESTORE_disconnect(), EgoEntry::identifier, idh, EgoEntry::next, ns, ns_qe, and reset_handles().

Referenced by run().

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

◆ commit_cb()

static void commit_cb ( void *  cls,
enum GNUNET_ErrorCode  ec 
)
static

Definition at line 628 of file gnunet-namestore.c.

629 {
630  ns_qe = NULL;
631  if (GNUNET_EC_NONE != ec)
632  {
633  fprintf (stderr, "Failed to commit to namestore: `%s'\n",
635  ret = 1;
636  }
638 }
const char * GNUNET_ErrorCode_get_hint(enum GNUNET_ErrorCode ec)
Returns a hint for a given error code.
@ GNUNET_EC_NONE
No error (success).
static int ret
Global return value.
void GNUNET_SCHEDULER_shutdown(void)
Request the shutdown of a scheduler.
Definition: scheduler.c:534

References GNUNET_EC_NONE, GNUNET_ErrorCode_get_hint(), GNUNET_SCHEDULER_shutdown(), ns_qe, and ret.

Referenced by finish_command(), and process_command_stdin().

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

◆ process_command_stdin()

static void process_command_stdin ( )
static

Check if this is a new name. If yes, and we have records, store them.

one last time

Definition at line 1775 of file gnunet-namestore.c.

1776 {
1777  char buf[MAX_LINE_LEN];
1778  static struct GNUNET_IDENTITY_PrivateKey next_zone_key;
1779  static char next_name[GNUNET_DNSPARSER_MAX_NAME_LENGTH];
1780  static int finished = GNUNET_NO;
1781  static int have_next_zonekey = GNUNET_NO;
1782  int zonekey_set = GNUNET_NO;
1783  char *tmp;
1784 
1785 
1786  if (GNUNET_YES == have_next_zonekey)
1787  {
1788  zone_pkey = next_zone_key;
1789  if (NULL != name)
1790  GNUNET_free (name);
1791  name = GNUNET_strdup (next_name);
1792  zonekey_set = GNUNET_YES;
1793  }
1794  while (NULL != fgets (buf, sizeof (buf), stdin))
1795  {
1796  if (1 >= strlen (buf))
1797  continue;
1798  if (buf[strlen (buf) - 1] == '\n')
1799  buf[strlen (buf) - 1] = '\0';
1803  if (buf[strlen (buf) - 1] == ':')
1804  {
1805  memset (next_name, 0, sizeof (next_name));
1806  strncpy (next_name, buf, strlen (buf) - 1);
1807  tmp = strchr (next_name, '.');
1808  if (NULL == tmp)
1809  {
1810  fprintf (stderr, "Error parsing name `%s'\n", next_name);
1812  ret = 1;
1813  return;
1814  }
1815  if (GNUNET_OK != get_identity_for_string (tmp + 1, &next_zone_key))
1816  {
1817  fprintf (stderr, "Error parsing zone name `%s'\n", tmp + 1);
1818  ret = 1;
1820  return;
1821  }
1822  *tmp = '\0';
1823  have_next_zonekey = GNUNET_YES;
1824  /* Run a command for the previous record set */
1825  if (NULL != recordset)
1826  {
1828  return;
1829  }
1830  zone_pkey = next_zone_key;
1831  if (NULL != name)
1832  GNUNET_free (name);
1833  name = GNUNET_strdup (next_name);
1834  zonekey_set = GNUNET_YES;
1835  continue;
1836  }
1837  if (GNUNET_NO == zonekey_set)
1838  {
1839  fprintf (stderr, "Warning, encountered recordline without zone\n");
1840  continue;
1841  }
1843  }
1844  if (GNUNET_NO == finished)
1845  {
1846  if (NULL != recordset)
1847  {
1848  if (GNUNET_YES == zonekey_set)
1849  {
1851  finished = GNUNET_YES;
1852  return;
1853  }
1854  fprintf (stderr, "Warning, encountered recordline without zone\n");
1855  }
1856  }
1858  return;
1859 }
#define MAX_LINE_LEN
static int parse_recordline(const char *line)
static void commit_cb(void *cls, enum GNUNET_ErrorCode ec)
const struct GNUNET_CONFIGURATION_Handle * cfg
Configuration handle.
static int get_identity_for_string(const char *str, struct GNUNET_IDENTITY_PrivateKey *zk)
static void run_with_zone_pkey(const struct GNUNET_CONFIGURATION_Handle *cfg)
We have obtained the zone's private key, so now process the main commands using it.
static char buf[2048]
#define GNUNET_DNSPARSER_MAX_NAME_LENGTH
Maximum length of a name in DNS.
struct GNUNET_NAMESTORE_QueueEntry * GNUNET_NAMESTORE_transaction_commit(struct GNUNET_NAMESTORE_Handle *h, GNUNET_NAMESTORE_ContinuationWithStatus cont, void *cont_cls)
Commit a namestore transaction.
A private key for an identity as per LSD0001.

References buf, cfg, commit_cb(), get_identity_for_string(), GNUNET_DNSPARSER_MAX_NAME_LENGTH, GNUNET_free, GNUNET_NAMESTORE_transaction_commit(), GNUNET_NO, GNUNET_OK, GNUNET_SCHEDULER_shutdown(), GNUNET_strdup, GNUNET_YES, MAX_LINE_LEN, name, ns, ns_qe, parse_recordline(), recordset, ret, run_with_zone_pkey(), and zone_pkey.

Referenced by begin_cb(), and finish_command().

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

◆ finish_command()

static void finish_command ( void  )
static

Definition at line 645 of file gnunet-namestore.c.

646 {
647  reset_handles ();
648  if (read_from_stdin)
649  {
651  return;
652  }
654 }
static int read_from_stdin
Run in read from stdin mode.
static void process_command_stdin()

References commit_cb(), GNUNET_NAMESTORE_transaction_commit(), ns, ns_qe, process_command_stdin(), read_from_stdin, and reset_handles().

Referenced by add_continuation(), add_error_cb(), del_continuation(), del_lookup_error_cb(), del_monitor(), display_record_lookup(), get_existing_record(), handle_reverse_lookup(), lookup_error_cb(), purge_next_record(), replace_cont(), run_with_zone_pkey(), zone_iteration_error_cb(), and zone_iteration_finished().

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

◆ add_continuation()

static void add_continuation ( void *  cls,
enum GNUNET_ErrorCode  ec 
)
static

Definition at line 658 of file gnunet-namestore.c.

659 {
660  struct GNUNET_NAMESTORE_QueueEntry **qe = cls;
661 
662  *qe = NULL;
663  if (GNUNET_EC_NONE != ec)
664  {
665  fprintf (stderr,
666  _ ("Adding record failed: %s\n"),
669  ret = 1;
670  }
671  ret = 0;
672  finish_command ();
673 }
@ GNUNET_EC_NAMESTORE_RECORD_EXISTS
Record already exists.
static struct GNUNET_DATASTORE_QueueEntry * qe
Current operation.
static void finish_command(void)
An QueueEntry used to store information for a pending NAMESTORE record operation.
Definition: namestore_api.c:53

References _, finish_command(), GNUNET_EC_NAMESTORE_RECORD_EXISTS, GNUNET_EC_NONE, GNUNET_ErrorCode_get_hint(), qe, and ret.

Referenced by get_existing_record(), and run_with_zone_pkey().

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

◆ del_continuation()

static void del_continuation ( void *  cls,
enum GNUNET_ErrorCode  ec 
)
static

Definition at line 677 of file gnunet-namestore.c.

678 {
679  (void) cls;
680  del_qe = NULL;
682  {
683  fprintf (stderr,
684  _ ("Deleting record failed: %s\n"), GNUNET_ErrorCode_get_hint (
685  ec));
686  }
687  finish_command ();
688 }
@ GNUNET_EC_NAMESTORE_RECORD_NOT_FOUND
Record not found.

References _, del_qe, finish_command(), GNUNET_EC_NAMESTORE_RECORD_NOT_FOUND, and GNUNET_ErrorCode_get_hint().

Referenced by del_monitor().

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

◆ purge_next_record()

static void purge_next_record ( void *  cls)
static

Definition at line 708 of file gnunet-namestore.c.

709 {
710  struct MarkedRecord *mrec;
711  purge_task = NULL;
712 
713  if (NULL == marked_head)
714  {
715  ret = 0;
716  finish_command ();
717  return;
718  }
719  mrec = marked_head;
721  marked_tail,
722  mrec);
724  &mrec->key,
725  mrec->name,
726  0, NULL,
728  NULL);
729  GNUNET_free (mrec->name);
730  GNUNET_free (mrec);
731 }
static void marked_deleted(void *cls, enum GNUNET_ErrorCode ec)
static struct MarkedRecord * marked_tail
Marked record list.
#define GNUNET_CONTAINER_DLL_remove(head, tail, element)
Remove an element from a DLL.
struct GNUNET_NAMESTORE_QueueEntry * GNUNET_NAMESTORE_records_store(struct GNUNET_NAMESTORE_Handle *h, const struct GNUNET_IDENTITY_PrivateKey *pkey, const char *label, unsigned int rd_count, const struct GNUNET_GNSRECORD_Data *rd, GNUNET_NAMESTORE_ContinuationWithStatus cont, void *cont_cls)
Store an item in the namestore.
struct GNUNET_IDENTITY_PrivateKey key
The zone key.

References del_qe, finish_command(), GNUNET_CONTAINER_DLL_remove, GNUNET_free, GNUNET_NAMESTORE_records_store(), MarkedRecord::key, marked_deleted(), marked_head, marked_tail, MarkedRecord::name, ns, purge_task, and ret.

Referenced by marked_deleted(), and zone_iteration_finished().

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

◆ marked_deleted()

static void marked_deleted ( void *  cls,
enum GNUNET_ErrorCode  ec 
)
static

Definition at line 694 of file gnunet-namestore.c.

695 {
696  del_qe = NULL;
697  if (GNUNET_EC_NONE != ec)
698  {
699  fprintf (stderr,
700  _ ("Deleting record failed: %s\n"),
702  }
704 }
static void purge_next_record(void *cls)
struct GNUNET_SCHEDULER_Task * GNUNET_SCHEDULER_add_now(GNUNET_SCHEDULER_TaskCallback task, void *task_cls)
Schedule a new task to be run as soon as possible.
Definition: scheduler.c:1268

References _, del_qe, GNUNET_EC_NONE, GNUNET_ErrorCode_get_hint(), GNUNET_SCHEDULER_add_now(), purge_next_record(), and purge_task.

Referenced by purge_next_record().

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

◆ zone_iteration_finished()

static void zone_iteration_finished ( void *  cls)
static

Function called when we are done with a zone iteration.

Definition at line 737 of file gnunet-namestore.c.

738 {
739  (void) cls;
740  list_it = NULL;
741  if (purge_orphaned || purge_zone)
742  {
744  return;
745  }
746  ret = 0;
747  finish_command ();
748 }
static int purge_orphaned
Purge orphaned records.

References finish_command(), GNUNET_SCHEDULER_add_now(), list_it, purge_next_record(), purge_orphaned, purge_task, purge_zone, and ret.

Referenced by run_with_zone_pkey().

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

◆ zone_iteration_error_cb()

static void zone_iteration_error_cb ( void *  cls)
static

Function called when we encountered an error in a zone iteration.

Definition at line 755 of file gnunet-namestore.c.

756 {
757  (void) cls;
758  list_it = NULL;
759  fprintf (stderr, "Error iterating over zone\n");
760  ret = 1;
761  finish_command ();
762 }

References finish_command(), list_it, and ret.

Referenced by run_with_zone_pkey().

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

◆ collect_zone_records_to_purge()

static void collect_zone_records_to_purge ( const struct GNUNET_IDENTITY_PrivateKey zone_key,
const char *  rname,
unsigned int  rd_len,
const struct GNUNET_GNSRECORD_Data rd 
)
static

Definition at line 765 of file gnunet-namestore.c.

770 {
771  struct MarkedRecord *mrec;
772 
773  mrec = GNUNET_new (struct MarkedRecord);
774  mrec->key = *zone_key;
775  mrec->name = GNUNET_strdup (rname);
777  marked_tail,
778  mrec);
779 }
static const struct GNUNET_IDENTITY_PrivateKey * zone_key
Private key of the zone.
#define GNUNET_CONTAINER_DLL_insert(head, tail, element)
Insert an element at the head of a DLL.
#define GNUNET_new(type)
Allocate a struct or union of the given type.

References GNUNET_CONTAINER_DLL_insert, GNUNET_new, GNUNET_strdup, MarkedRecord::key, marked_head, marked_tail, MarkedRecord::name, and zone_key.

Referenced by purge_zone_iterator().

Here is the caller graph for this function:

◆ collect_orphans()

static void collect_orphans ( const struct GNUNET_IDENTITY_PrivateKey zone_key,
const char *  rname,
unsigned int  rd_len,
const struct GNUNET_GNSRECORD_Data rd 
)
static

Definition at line 783 of file gnunet-namestore.c.

787 {
788  struct EgoEntry *ego;
789  struct MarkedRecord *orphan;
790  int is_orphaned = 1;
791 
792  for (ego = ego_head; NULL != ego; ego = ego->next)
793  {
794  if (0 == memcmp (GNUNET_IDENTITY_ego_get_private_key (ego->ego),
795  zone_key,
796  sizeof (*zone_key)))
797  {
798  is_orphaned = 0;
799  break;
800  }
801  }
802  if (is_orphaned)
803  {
804  orphan = GNUNET_new (struct MarkedRecord);
805  orphan->key = *zone_key;
806  orphan->name = GNUNET_strdup (rname);
808  marked_tail,
809  orphan);
810  }
811 }
const struct GNUNET_IDENTITY_PrivateKey * GNUNET_IDENTITY_ego_get_private_key(const struct GNUNET_IDENTITY_Ego *ego)
Obtain the ECC key associated with a ego.
Definition: identity_api.c:560
struct GNUNET_IDENTITY_Ego * ego
The Ego.

References EgoEntry::ego, ego_head, GNUNET_CONTAINER_DLL_insert, GNUNET_IDENTITY_ego_get_private_key(), GNUNET_new, GNUNET_strdup, MarkedRecord::key, marked_head, marked_tail, MarkedRecord::name, EgoEntry::next, and zone_key.

Referenced by purge_orphans_iterator().

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

◆ display_record()

static void display_record ( const struct GNUNET_IDENTITY_PrivateKey zone_key,
const char *  rname,
unsigned int  rd_len,
const struct GNUNET_GNSRECORD_Data rd 
)
static

Process a record that was stored in the namestore.

Parameters
rnamename that is being mapped (at most 255 characters long)
rd_lennumber of entries in rd array
rdarray of records with data to store

Definition at line 821 of file gnunet-namestore.c.

825 {
826  const char *typestr;
827  char *s;
828  const char *ets;
829  struct GNUNET_TIME_Absolute at;
830  struct GNUNET_TIME_Relative rt;
831  struct EgoEntry *ego;
832  int have_record;
833  int is_orphaned = 1;
834  char *orphaned_str;
835 
836  if ((NULL != name) && (0 != strcmp (name, rname)))
837  return;
838  have_record = GNUNET_NO;
839  for (unsigned int i = 0; i < rd_len; i++)
840  {
841  if ((GNUNET_GNSRECORD_TYPE_NICK == rd[i].record_type) &&
842  (0 != strcmp (rname, GNUNET_GNS_EMPTY_LABEL_AT)))
843  continue;
844  if ((type != rd[i].record_type) && (GNUNET_GNSRECORD_TYPE_ANY != type))
845  continue;
846  have_record = GNUNET_YES;
847  break;
848  }
849  if (GNUNET_NO == have_record)
850  return;
851  for (ego = ego_head; NULL != ego; ego = ego->next)
852  {
853  if (0 == memcmp (GNUNET_IDENTITY_ego_get_private_key (ego->ego),
854  zone_key,
855  sizeof (*zone_key)))
856  {
857  is_orphaned = 0;
858  break;
859  }
860  }
861  if (list_orphaned && ! is_orphaned)
862  return;
863  if (! list_orphaned && is_orphaned)
864  return;
866  fprintf (stdout, "%s.%s:\n", rname, is_orphaned ? orphaned_str :
867  ego->identifier);
868  GNUNET_free (orphaned_str);
869  if (NULL != typestring)
871  else
873  for (unsigned int i = 0; i < rd_len; i++)
874  {
875  if ((GNUNET_GNSRECORD_TYPE_NICK == rd[i].record_type) &&
876  (0 != strcmp (rname, GNUNET_GNS_EMPTY_LABEL_AT)))
877  continue;
878  if ((type != rd[i].record_type) && (GNUNET_GNSRECORD_TYPE_ANY != type))
879  continue;
880  typestr = GNUNET_GNSRECORD_number_to_typename (rd[i].record_type);
881  s = GNUNET_GNSRECORD_value_to_string (rd[i].record_type,
882  rd[i].data,
883  rd[i].data_size);
884  if (NULL == s)
885  {
886  fprintf (stdout,
887  _ ("\tCorrupt or unsupported record of type %u\n"),
888  (unsigned int) rd[i].record_type);
889  continue;
890  }
891  if (0 != (rd[i].flags & GNUNET_GNSRECORD_RF_RELATIVE_EXPIRATION))
892  {
893  rt.rel_value_us = rd[i].expiration_time;
895  }
896  else
897  {
898  at.abs_value_us = rd[i].expiration_time;
900  }
901  char flgstr[16];
902  sprintf (flgstr, "[%s%s%s%s%s]",
903  (rd[i].flags & GNUNET_GNSRECORD_RF_PRIVATE) ? "" : "p",
904  (rd[i].flags & GNUNET_GNSRECORD_RF_SUPPLEMENTAL) ? "S" : "",
905  (rd[i].flags & GNUNET_GNSRECORD_RF_RELATIVE_EXPIRATION) ? "r" : "",
906  (rd[i].flags & GNUNET_GNSRECORD_RF_SHADOW) ? "S" : "",
907  (rd[i].flags & GNUNET_GNSRECORD_RF_CRITICAL) ? "C" : "");
908  if (output_recordline)
909  fprintf (stdout,
910  " %s %" PRIu64 " %s %s\n",
911  typestr,
912  rd[i].expiration_time,
913  flgstr,
914  s);
915  else
916  fprintf (stdout,
917  "\t%s: %s (%s)\t%s\t%s\n",
918  typestr,
919  s,
920  ets,
921  (0 != (rd[i].flags & GNUNET_GNSRECORD_RF_PRIVATE)) ? "PRIVATE"
922  : "PUBLIC",
923  (0 != (rd[i].flags & GNUNET_GNSRECORD_RF_SHADOW)) ? "SHADOW"
924  : "");
925  GNUNET_free (s);
926  }
927  // fprintf (stdout, "%s", "\n");
928 }
#define GNUNET_GNSRECORD_TYPE_NICK
GNS nick names.
static struct GNUNET_GNSRECORD_Data rd[50]
The record data under a single label.
static int output_recordline
Output in recordline format.
static int list_orphaned
List records and zone keys of orphaned records.
static uint32_t type
Type string converted to DNS type value.
static size_t data_size
Number of bytes in data.
char * GNUNET_GNSRECORD_value_to_string(uint32_t type, const void *data, size_t data_size)
Convert the 'value' of a record to a string.
Definition: gnsrecord.c:155
#define GNUNET_GNS_EMPTY_LABEL_AT
String we use to indicate an empty label (top-level entry in the zone).
#define GNUNET_GNSRECORD_TYPE_ANY
Record type indicating any record/'*'.
char * GNUNET_IDENTITY_private_key_to_string(const struct GNUNET_IDENTITY_PrivateKey *key)
Creates a (Base32) string representation of the private key.
uint64_t expiration_time
Expiration time for the DNS record.

References _, GNUNET_TIME_Absolute::abs_value_us, data, data_size, EgoEntry::ego, ego_head, GNUNET_GNSRECORD_Data::expiration_time, GNUNET_free, GNUNET_GNS_EMPTY_LABEL_AT, GNUNET_GNSRECORD_number_to_typename(), GNUNET_GNSRECORD_RF_CRITICAL, GNUNET_GNSRECORD_RF_PRIVATE, GNUNET_GNSRECORD_RF_RELATIVE_EXPIRATION, GNUNET_GNSRECORD_RF_SHADOW, GNUNET_GNSRECORD_RF_SUPPLEMENTAL, GNUNET_GNSRECORD_TYPE_ANY, GNUNET_GNSRECORD_TYPE_NICK, GNUNET_GNSRECORD_typename_to_number(), GNUNET_GNSRECORD_value_to_string(), GNUNET_IDENTITY_ego_get_private_key(), GNUNET_IDENTITY_private_key_to_string(), GNUNET_NO, GNUNET_STRINGS_absolute_time_to_string(), GNUNET_STRINGS_relative_time_to_string(), GNUNET_YES, list_orphaned, name, output_recordline, rd, GNUNET_TIME_Relative::rel_value_us, type, typestring, and zone_key.

Referenced by display_record_iterator(), display_record_lookup(), and display_record_monitor().

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

◆ purge_zone_iterator()

static void purge_zone_iterator ( void *  cls,
const struct GNUNET_IDENTITY_PrivateKey zone_key,
const char *  rname,
unsigned int  rd_len,
const struct GNUNET_GNSRECORD_Data rd,
struct GNUNET_TIME_Absolute  expiry 
)
static

Definition at line 931 of file gnunet-namestore.c.

937 {
938  (void) cls;
939  (void) zone_key;
940  (void) expiry;
941  collect_zone_records_to_purge (zone_key, rname, rd_len, rd);
943 }
static void collect_zone_records_to_purge(const struct GNUNET_IDENTITY_PrivateKey *zone_key, const char *rname, unsigned int rd_len, const struct GNUNET_GNSRECORD_Data *rd)
void GNUNET_NAMESTORE_zone_iterator_next(struct GNUNET_NAMESTORE_ZoneIterator *it, uint64_t limit)
Calls the record processor specified in GNUNET_NAMESTORE_zone_iteration_start for the next record.

References collect_zone_records_to_purge(), GNUNET_NAMESTORE_zone_iterator_next(), list_it, rd, and zone_key.

Referenced by run_with_zone_pkey().

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

◆ purge_orphans_iterator()

static void purge_orphans_iterator ( void *  cls,
const struct GNUNET_IDENTITY_PrivateKey zone_key,
const char *  rname,
unsigned int  rd_len,
const struct GNUNET_GNSRECORD_Data rd,
struct GNUNET_TIME_Absolute  expiry 
)
static

Definition at line 947 of file gnunet-namestore.c.

953 {
954  (void) cls;
955  (void) zone_key;
956  (void) expiry;
957  collect_orphans (zone_key, rname, rd_len, rd);
959 }
static void collect_orphans(const struct GNUNET_IDENTITY_PrivateKey *zone_key, const char *rname, unsigned int rd_len, const struct GNUNET_GNSRECORD_Data *rd)

References collect_orphans(), GNUNET_NAMESTORE_zone_iterator_next(), list_it, rd, and zone_key.

Referenced by run_with_zone_pkey().

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

◆ display_record_iterator()

static void display_record_iterator ( void *  cls,
const struct GNUNET_IDENTITY_PrivateKey zone_key,
const char *  rname,
unsigned int  rd_len,
const struct GNUNET_GNSRECORD_Data rd,
struct GNUNET_TIME_Absolute  expiry 
)
static

Process a record that was stored in the namestore.

Parameters
clsclosure
zone_keyprivate key of the zone
rnamename that is being mapped (at most 255 characters long)
rd_lennumber of entries in rd array
rdarray of records with data to store

Definition at line 972 of file gnunet-namestore.c.

978 {
979  (void) cls;
980  (void) zone_key;
981  (void) expiry;
982  display_record (zone_key, rname, rd_len, rd);
984 }
static void display_record(const struct GNUNET_IDENTITY_PrivateKey *zone_key, const char *rname, unsigned int rd_len, const struct GNUNET_GNSRECORD_Data *rd)
Process a record that was stored in the namestore.

References display_record(), GNUNET_NAMESTORE_zone_iterator_next(), list_it, rd, and zone_key.

Referenced by run_with_zone_pkey().

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

◆ display_record_monitor()

static void display_record_monitor ( void *  cls,
const struct GNUNET_IDENTITY_PrivateKey zone_key,
const char *  rname,
unsigned int  rd_len,
const struct GNUNET_GNSRECORD_Data rd,
struct GNUNET_TIME_Absolute  expiry 
)
static

Process a record that was stored in the namestore.

Parameters
clsclosure
zone_keyprivate key of the zone
rnamename that is being mapped (at most 255 characters long)
rd_lennumber of entries in rd array
rdarray of records with data to store

Definition at line 997 of file gnunet-namestore.c.

1003 {
1004  (void) cls;
1005  (void) zone_key;
1006  (void) expiry;
1007  display_record (zone_key, rname, rd_len, rd);
1009 }
void GNUNET_NAMESTORE_zone_monitor_next(struct GNUNET_NAMESTORE_ZoneMonitor *zm, uint64_t limit)
Calls the monitor processor specified in GNUNET_NAMESTORE_zone_monitor_start for the next record(s).

References display_record(), GNUNET_NAMESTORE_zone_monitor_next(), rd, zm, and zone_key.

Referenced by run_with_zone_pkey().

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

◆ display_record_lookup()

static void display_record_lookup ( void *  cls,
const struct GNUNET_IDENTITY_PrivateKey zone_key,
const char *  rname,
unsigned int  rd_len,
const struct GNUNET_GNSRECORD_Data rd 
)
static

Process a record that was stored in the namestore.

Parameters
clsclosure
zone_keyprivate key of the zone
rnamename that is being mapped (at most 255 characters long)
rd_lennumber of entries in rd array
rdarray of records with data to store

Definition at line 1022 of file gnunet-namestore.c.

1027 {
1028  (void) cls;
1029  (void) zone_key;
1030  get_qe = NULL;
1031  display_record (zone_key, rname, rd_len, rd);
1032  finish_command ();
1033 }

References display_record(), finish_command(), get_qe, rd, and zone_key.

Referenced by run_with_zone_pkey().

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

◆ sync_cb()

static void sync_cb ( void *  cls)
static

Function called once we are in sync in monitor mode.

Parameters
clsNULL

Definition at line 1042 of file gnunet-namestore.c.

1043 {
1044  (void) cls;
1045  fprintf (stdout, "%s", "Monitor is now in sync.\n");
1046 }

Referenced by GNUNET_NAMESTORE_zone_monitor_start(), GNUNET_NAMESTORE_zone_monitor_start2(), and run_with_zone_pkey().

Here is the caller graph for this function:

◆ monitor_error_cb()

static void monitor_error_cb ( void *  cls)
static

Function called on errors while monitoring.

Parameters
clsNULL

Definition at line 1055 of file gnunet-namestore.c.

1056 {
1057  (void) cls;
1058  fprintf (stderr, "%s", "Monitor disconnected and out of sync.\n");
1059 }

Referenced by run_with_zone_pkey().

Here is the caller graph for this function:

◆ lookup_error_cb()

static void lookup_error_cb ( void *  cls)
static

Function called on errors while monitoring.

Parameters
clsNULL

Definition at line 1068 of file gnunet-namestore.c.

1069 {
1070  (void) cls;
1071  get_qe = NULL;
1072  fprintf (stderr, "%s", "Failed to lookup record.\n");
1073  finish_command ();
1074 }

References finish_command(), and get_qe.

Referenced by run_with_zone_pkey().

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

◆ add_error_cb()

static void add_error_cb ( void *  cls)
static

Function called if lookup fails.

Definition at line 1081 of file gnunet-namestore.c.

1082 {
1083  (void) cls;
1084  add_qe = NULL;
1085  GNUNET_break (0);
1086  ret = 1;
1087  finish_command ();
1088 }
#define GNUNET_break(cond)
Use this for internal assertion violations that are not fatal (can be handled) but should not occur.

References add_qe, finish_command(), GNUNET_break, and ret.

Referenced by run_with_zone_pkey().

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

◆ get_existing_record()

static void get_existing_record ( void *  cls,
const struct GNUNET_IDENTITY_PrivateKey zone_key,
const char *  rec_name,
unsigned int  rd_count,
const struct GNUNET_GNSRECORD_Data rd 
)
static

We're storing a record; this function is given the existing record so that we can merge the information.

Parameters
clsclosure, unused
zone_keyprivate key of the zone
rec_namename that is being mapped (at most 255 characters long)
rd_countnumber of entries in rd array
rdarray of records with data to store

Definition at line 1102 of file gnunet-namestore.c.

1107 {
1108  struct GNUNET_GNSRECORD_Data rdn[rd_count + 1];
1109  struct GNUNET_GNSRECORD_Data *rde;
1110 
1111  (void) cls;
1112  (void) zone_key;
1113  add_qe = NULL;
1114  if (0 != strcmp (rec_name, name))
1115  {
1116  GNUNET_break (0);
1117  ret = 1;
1118  finish_command ();
1119  return;
1120  }
1121 
1123  "Received %u records for name `%s'\n",
1124  rd_count,
1125  rec_name);
1126  for (unsigned int i = 0; i < rd_count; i++)
1127  {
1128  switch (rd[i].record_type)
1129  {
1132  {
1133  fprintf (
1134  stderr,
1135  _ (
1136  "A SOA record exists already under `%s', cannot add a second SOA to the same zone.\n"),
1137  rec_name);
1138  ret = 1;
1139  finish_command ();
1140  return;
1141  }
1142  break;
1143  }
1144  }
1145  memset (rdn, 0, sizeof(struct GNUNET_GNSRECORD_Data));
1146  GNUNET_memcpy (&rdn[1], rd, rd_count * sizeof(struct GNUNET_GNSRECORD_Data));
1147  rde = &rdn[0];
1148  rde->data = data;
1149  rde->data_size = data_size;
1150  rde->record_type = type;
1151  if (1 == is_shadow)
1153  if (1 != is_public)
1155  rde->expiration_time = etime;
1156  if (GNUNET_YES == etime_is_rel)
1158  else if (GNUNET_NO != etime_is_rel)
1159  rde->expiration_time = GNUNET_TIME_UNIT_FOREVER_ABS.abs_value_us;
1160  GNUNET_assert (NULL != name);
1162  &zone_pkey,
1163  name,
1164  rd_count + 1,
1165  rde,
1167  &add_qe);
1168 }
static unsigned int rd_count
Number of records for currently parsed set.
static void add_continuation(void *cls, enum GNUNET_ErrorCode ec)
#define GNUNET_DNSPARSER_TYPE_SOA
#define GNUNET_memcpy(dst, src, n)
Call memcpy() but check for n being 0 first.
#define GNUNET_assert(cond)
Use this for fatal errors that cannot be handled.
uint32_t record_type
Type of the GNS/DNS record.
const void * data
Binary value stored in the DNS record.
size_t data_size
Number of bytes in data.
enum GNUNET_GNSRECORD_Flags flags
Flags for the record.

References _, add_continuation(), add_qe, GNUNET_GNSRECORD_Data::data, data, GNUNET_GNSRECORD_Data::data_size, data_size, etime, etime_is_rel, GNUNET_GNSRECORD_Data::expiration_time, finish_command(), GNUNET_GNSRECORD_Data::flags, GNUNET_assert, GNUNET_break, GNUNET_DNSPARSER_TYPE_SOA, GNUNET_ERROR_TYPE_DEBUG, GNUNET_GNSRECORD_RF_PRIVATE, GNUNET_GNSRECORD_RF_RELATIVE_EXPIRATION, GNUNET_GNSRECORD_RF_SHADOW, GNUNET_log, GNUNET_memcpy, GNUNET_NAMESTORE_records_store(), GNUNET_NO, GNUNET_TIME_UNIT_FOREVER_ABS, GNUNET_YES, is_public, is_shadow, name, ns, rd, rd_count, GNUNET_GNSRECORD_Data::record_type, ret, type, zone_key, and zone_pkey.

Referenced by run_with_zone_pkey().

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

◆ reverse_error_cb()

static void reverse_error_cb ( void *  cls)
static

Function called if we encountered an error in zone-to-name.

Definition at line 1175 of file gnunet-namestore.c.

1176 {
1177  (void) cls;
1178  reverse_qe = NULL;
1179  fprintf (stdout, "%s.zkey\n", reverse_pkey);
1180 }
static char * reverse_pkey
Reverse lookup to perform.

References reverse_pkey, and reverse_qe.

Referenced by run_with_zone_pkey().

Here is the caller graph for this function:

◆ handle_reverse_lookup()

static void handle_reverse_lookup ( void *  cls,
const struct GNUNET_IDENTITY_PrivateKey zone,
const char *  label,
unsigned int  rd_count,
const struct GNUNET_GNSRECORD_Data rd 
)
static

Function called with the result of our attempt to obtain a name for a given public key.

Parameters
clsNULL
zoneprivate key of the zone; NULL on disconnect
labellabel of the records; NULL on disconnect
rd_countnumber of entries in rd array, 0 if label was deleted
rdarray of records with data to store

Definition at line 1194 of file gnunet-namestore.c.

1199 {
1200  (void) cls;
1201  (void) zone;
1202  (void) rd_count;
1203  (void) rd;
1204  reverse_qe = NULL;
1205  if (NULL == label)
1206  fprintf (stdout, "%s\n", reverse_pkey);
1207  else
1208  fprintf (stdout, "%s.%s\n", label, ego_name);
1209  finish_command ();
1210 }
static char * zone
Name of the zone being managed.

References ego_name, finish_command(), rd, rd_count, reverse_pkey, reverse_qe, and zone.

Referenced by run_with_zone_pkey().

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

◆ del_lookup_error_cb()

static void del_lookup_error_cb ( void *  cls)
static

Function called if lookup for deletion fails.

Definition at line 1217 of file gnunet-namestore.c.

1218 {
1219  (void) cls;
1220  del_qe = NULL;
1221  GNUNET_break (0);
1222  ret = 1;
1223  finish_command ();
1224 }

References del_qe, finish_command(), GNUNET_break, and ret.

Referenced by run_with_zone_pkey().

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

◆ del_monitor()

static void del_monitor ( void *  cls,
const struct GNUNET_IDENTITY_PrivateKey zone,
const char *  label,
unsigned int  rd_count,
const struct GNUNET_GNSRECORD_Data rd 
)
static

We were asked to delete something; this function is called with the existing records.

Now we should determine what should be deleted and then issue the deletion operation.

Parameters
clsNULL
zoneprivate key of the zone we are deleting from
labelname of the records we are editing
rd_countsize of the rd array
rdexisting records

Definition at line 1239 of file gnunet-namestore.c.

1244 {
1245  struct GNUNET_GNSRECORD_Data rdx[rd_count];
1246  unsigned int rd_left;
1247  uint32_t type;
1248  char *vs;
1249 
1250  (void) cls;
1251  (void) zone;
1252  del_qe = NULL;
1253  if (0 == rd_count)
1254  {
1255  fprintf (stderr,
1256  _ (
1257  "There are no records under label `%s' that could be deleted.\n"),
1258  label);
1259  ret = 1;
1260  finish_command ();
1261  return;
1262  }
1263  if ((NULL == value) && (NULL == typestring))
1264  {
1265  /* delete everything */
1267  &zone_pkey,
1268  name,
1269  0,
1270  NULL,
1272  NULL);
1273  return;
1274  }
1275  rd_left = 0;
1276  if (NULL != typestring)
1278  else
1280  for (unsigned int i = 0; i < rd_count; i++)
1281  {
1282  vs = NULL;
1283  if (! (((GNUNET_GNSRECORD_TYPE_ANY == type) ||
1284  (rd[i].record_type == type)) &&
1285  ((NULL == value) ||
1286  (NULL ==
1288  rd[i].data,
1289  rd[i].data_size)))) ||
1290  (0 == strcmp (vs, value)))))
1291  rdx[rd_left++] = rd[i];
1292  GNUNET_free (vs);
1293  }
1294  if (rd_count == rd_left)
1295  {
1296  /* nothing got deleted */
1297  fprintf (
1298  stderr,
1299  _ (
1300  "There are no records under label `%s' that match the request for deletion.\n"),
1301  label);
1302  finish_command ();
1303  return;
1304  }
1305  /* delete everything but what we copied to 'rdx' */
1307  &zone_pkey,
1308  name,
1309  rd_left,
1310  rdx,
1312  NULL);
1313 }
static void del_continuation(void *cls, enum GNUNET_ErrorCode ec)

References _, data, data_size, del_continuation(), del_qe, finish_command(), GNUNET_free, GNUNET_GNSRECORD_TYPE_ANY, GNUNET_GNSRECORD_typename_to_number(), GNUNET_GNSRECORD_value_to_string(), GNUNET_NAMESTORE_records_store(), name, ns, rd, rd_count, GNUNET_GNSRECORD_Data::record_type, ret, type, typestring, value, zone, and zone_pkey.

Referenced by run_with_zone_pkey().

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

◆ replace_cont()

static void replace_cont ( void *  cls,
enum GNUNET_ErrorCode  ec 
)
static

Definition at line 1317 of file gnunet-namestore.c.

1318 {
1319  (void) cls;
1320 
1321  set_qe = NULL;
1322  if (GNUNET_EC_NONE != ec)
1323  {
1325  _ ("%s\n"),
1327  ret = 1; /* fail from 'main' */
1328  }
1329  finish_command ();
1330 }
@ GNUNET_ERROR_TYPE_MESSAGE

References _, finish_command(), GNUNET_EC_NONE, GNUNET_ERROR_TYPE_MESSAGE, GNUNET_ErrorCode_get_hint(), GNUNET_log, ret, and set_qe.

Referenced by run_with_zone_pkey().

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

◆ run_with_zone_pkey()

static void run_with_zone_pkey ( const struct GNUNET_CONFIGURATION_Handle cfg)
static

We have obtained the zone's private key, so now process the main commands using it.

Parameters
cfgconfiguration to use

Definition at line 1340 of file gnunet-namestore.c.

1341 {
1342  struct GNUNET_GNSRECORD_Data rd;
1344 
1345  if (omit_private)
1346  filter_flags |= GNUNET_GNSRECORD_FILTER_OMIT_PRIVATE;
1347  if (include_maintenance)
1349  if (! (add | del | list | (NULL != nickstring) | (NULL != uri)
1350  | (NULL != reverse_pkey) | (NULL != recordset) | (monitor)
1351  | (purge_orphaned) | (list_orphaned) | (purge_zone)) )
1352  {
1353  /* nothing more to be done */
1354  fprintf (stderr, _ ("No options given\n"));
1355  finish_command ();
1356  return;
1357  }
1358 
1359  if (NULL != recordset)
1360  {
1361  /* replace entire record set */
1362  unsigned int rd_count;
1363  struct GNUNET_GNSRECORD_Data *rd;
1364 
1365  /* FIXME: We could easily support append and delete with this as well */
1366  if (! add)
1367  {
1368  fprintf (stderr, _ ("Recordlines only work with option `%s'\n"),
1369  "-a");
1370  ret = 1;
1371  finish_command ();
1372  return;
1373  }
1374  if (NULL == name)
1375  {
1376  fprintf (stderr,
1377  _ ("Missing option `%s' for operation `%s'\n"),
1378  "-n",
1379  _ ("name"));
1380  ret = 1;
1381  finish_command ();
1382  return;
1383  }
1384  rd_count = 0;
1385  for (struct RecordSetEntry *e = recordset; NULL != e; e = e->next)
1386  rd_count++;
1388  rd_count = 0;
1389  for (struct RecordSetEntry *e = recordset; NULL != e; e = e->next)
1390  {
1391  rd[rd_count] = e->record;
1392  rd_count++;
1393  }
1395  &zone_pkey,
1396  name,
1397  rd_count,
1398  rd,
1399  &replace_cont,
1400  NULL);
1401  GNUNET_free (rd);
1402  return;
1403  }
1404  if (NULL != nickstring)
1405  {
1406  if (0 == strlen (nickstring))
1407  {
1408  fprintf (stderr, _ ("Invalid nick `%s'\n"), nickstring);
1409  ret = 1;
1410  finish_command ();
1411  return;
1412  }
1413  add = 1;
1418  is_public = 0;
1419  expirationstring = GNUNET_strdup ("never");
1421  nickstring = NULL;
1422  }
1423 
1424  if (add)
1425  {
1426  if (NULL == ego_name)
1427  {
1428  fprintf (stderr,
1429  _ ("Missing option `%s' for operation `%s'\n"),
1430  "-z",
1431  _ ("add"));
1432  ret = 1;
1433  finish_command ();
1434  return;
1435  }
1436  if (NULL == name)
1437  {
1438  fprintf (stderr,
1439  _ ("Missing option `%s' for operation `%s'\n"),
1440  "-n",
1441  _ ("add"));
1442  ret = 1;
1443  finish_command ();
1444  return;
1445  }
1446  if (NULL == typestring)
1447  {
1448  fprintf (stderr,
1449  _ ("Missing option `%s' for operation `%s'\n"),
1450  "-t",
1451  _ ("add"));
1452  ret = 1;
1453  finish_command ();
1454  return;
1455  }
1457  if (UINT32_MAX == type)
1458  {
1459  fprintf (stderr, _ ("Unsupported type `%s'\n"), typestring);
1460  ret = 1;
1461  finish_command ();
1462  return;
1463  }
1464  if ((GNUNET_DNSPARSER_TYPE_SRV == type) ||
1467  {
1468  fprintf (stderr,
1469  _ ("For DNS record types `SRV', `TLSA' and `OPENPGPKEY'"));
1470  fprintf (stderr, ", please use a `BOX' record instead\n");
1471  ret = 1;
1472  finish_command ();
1473  return;
1474  }
1475  if (NULL == value)
1476  {
1477  fprintf (stderr,
1478  _ ("Missing option `%s' for operation `%s'\n"),
1479  "-V",
1480  _ ("add"));
1481  ret = 1;
1482  finish_command ();
1483  return;
1484  }
1485  if (GNUNET_OK !=
1487  {
1488  fprintf (stderr,
1489  _ ("Value `%s' invalid for record type `%s'\n"),
1490  value,
1491  typestring);
1492  ret = 1;
1493  finish_command ();
1494  return;
1495  }
1496  if (NULL == expirationstring)
1497  {
1498  fprintf (stderr,
1499  _ ("Missing option `%s' for operation `%s'\n"),
1500  "-e",
1501  _ ("add"));
1502  ret = 1;
1503  finish_command ();
1504  return;
1505  }
1507  {
1508  fprintf (stderr, _ ("Invalid time format `%s'\n"), expirationstring);
1509  ret = 1;
1510  finish_command ();
1511  return;
1512  }
1514  &zone_pkey,
1515  name,
1516  &add_error_cb,
1517  NULL,
1519  NULL);
1520  }
1521  if (del)
1522  {
1523  if (NULL == ego_name)
1524  {
1525  fprintf (stderr,
1526  _ ("Missing option `%s' for operation `%s'\n"),
1527  "-z",
1528  _ ("del"));
1529  ret = 1;
1530  finish_command ();
1531  return;
1532  }
1533  if (NULL == name)
1534  {
1535  fprintf (stderr,
1536  _ ("Missing option `%s' for operation `%s'\n"),
1537  "-n",
1538  _ ("del"));
1539  ret = 1;
1540  finish_command ();
1541  return;
1542  }
1544  &zone_pkey,
1545  name,
1547  NULL,
1548  &del_monitor,
1549  NULL);
1550  }
1551  if (purge_orphaned)
1552  {
1554  NULL,
1556  NULL,
1558  NULL,
1560  NULL,
1561  filter_flags);
1562 
1563  }
1564  else if (purge_zone)
1565  {
1566  if (NULL == ego_name)
1567  {
1568  fprintf (stderr,
1569  _ ("Missing option `%s' for operation `%s'\n"),
1570  "-z",
1571  _ ("purge-zone"));
1572  ret = 1;
1573  finish_command ();
1574  return;
1575  }
1577  &zone_pkey,
1579  NULL,
1581  NULL,
1583  NULL,
1584  filter_flags);
1585 
1586  }
1587  else if (list || list_orphaned)
1588  {
1589  if (NULL != name)
1590  {
1591  if (NULL == ego_name)
1592  {
1593  fprintf (stderr,
1594  _ ("Missing option `%s' for operation `%s'\n"),
1595  "-z",
1596  _ ("list"));
1597  ret = 1;
1598  finish_command ();
1599  return;
1600  }
1602  &zone_pkey,
1603  name,
1604  &lookup_error_cb,
1605  NULL,
1607  NULL);
1608  }
1609  else
1611  (NULL == ego_name) ?
1612  NULL : &zone_pkey,
1614  NULL,
1616  NULL,
1618  NULL,
1619  filter_flags);
1620  }
1621  if (NULL != reverse_pkey)
1622  {
1624 
1625  if (NULL == ego_name)
1626  {
1627  fprintf (stderr,
1628  _ ("Missing option `%s' for operation `%s'\n"),
1629  "-z",
1630  _ ("reverse-pkey"));
1631  ret = 1;
1632  finish_command ();
1633  return;
1634  }
1635  if (GNUNET_OK !=
1637  &pubkey))
1638  {
1639  fprintf (stderr,
1640  _ ("Invalid public key for reverse lookup `%s'\n"),
1641  reverse_pkey);
1642  ret = 1;
1643  finish_command ();
1644  return;
1645  }
1647  &zone_pkey,
1648  &pubkey,
1650  NULL,
1652  NULL);
1653  }
1654  if (NULL != uri)
1655  {
1656  char sh[105];
1657  char sname[64];
1659  if (NULL == ego_name)
1660  {
1661  fprintf (stderr,
1662  _ ("Missing option `%s' for operation `%s'\n"),
1663  "-z",
1664  _ ("uri"));
1665  ret = 1;
1666  finish_command ();
1667  return;
1668  }
1669 
1670  memset (sh, 0, 105);
1671  memset (sname, 0, 64);
1672 
1673  if ((2 != (sscanf (uri, "gnunet://gns/%58s/%63s", sh, sname))) ||
1674  (GNUNET_OK !=
1676  {
1677  fprintf (stderr, _ ("Invalid URI `%s'\n"), uri);
1678  ret = 1;
1679  finish_command ();
1680  return;
1681  }
1682  if (NULL == expirationstring)
1683  {
1684  fprintf (stderr,
1685  _ ("Missing option `%s' for operation `%s'\n"),
1686  "-e",
1687  _ ("add"));
1688  ret = 1;
1689  finish_command ();
1690  return;
1691  }
1693  {
1694  fprintf (stderr, _ ("Invalid time format `%s'\n"), expirationstring);
1695  ret = 1;
1696  finish_command ();
1697  return;
1698  }
1699  memset (&rd, 0, sizeof(rd));
1700  rd.data = &pkey;
1702  rd.record_type = ntohl (pkey.type);
1704  if (GNUNET_YES == etime_is_rel)
1706  if (1 == is_shadow)
1709  &zone_pkey,
1710  sname,
1711  1,
1712  &rd,
1714  &add_qe_uri);
1715  }
1716  if (monitor)
1717  {
1719  (NULL != ego_name) ?
1720  &zone_pkey : NULL,
1721  GNUNET_YES,
1723  NULL,
1725  NULL,
1726  &sync_cb,
1727  NULL,
1728  filter_flags);
1729  }
1730 }
static struct Experiment * e
static struct SolverHandle * sh
static char * pkey
Public key of the zone to look in, in ASCII.
static struct GNUNET_IDENTITY_PublicKey pubkey
Public key of the zone to look in.
static int omit_private
Filter private records.
static void zone_iteration_finished(void *cls)
Function called when we are done with a zone iteration.
static void replace_cont(void *cls, enum GNUNET_ErrorCode ec)
static void sync_cb(void *cls)
Function called once we are in sync in monitor mode.
static void display_record_iterator(void *cls, const struct GNUNET_IDENTITY_PrivateKey *zone_key, const char *rname, unsigned int rd_len, const struct GNUNET_GNSRECORD_Data *rd, struct GNUNET_TIME_Absolute expiry)
Process a record that was stored in the namestore.
static void del_lookup_error_cb(void *cls)
Function called if lookup for deletion fails.
static void display_record_monitor(void *cls, const struct GNUNET_IDENTITY_PrivateKey *zone_key, const char *rname, unsigned int rd_len, const struct GNUNET_GNSRECORD_Data *rd, struct GNUNET_TIME_Absolute expiry)
Process a record that was stored in the namestore.
static char * nickstring
Desired nick name.
static int monitor
Enables monitor mode.
static int include_maintenance
Do not filter maintenance records.
static void purge_orphans_iterator(void *cls, const struct GNUNET_IDENTITY_PrivateKey *zone_key, const char *rname, unsigned int rd_len, const struct GNUNET_GNSRECORD_Data *rd, struct GNUNET_TIME_Absolute expiry)
static void lookup_error_cb(void *cls)
Function called on errors while monitoring.
static void reverse_error_cb(void *cls)
Function called if we encountered an error in zone-to-name.
static void handle_reverse_lookup(void *cls, const struct GNUNET_IDENTITY_PrivateKey *zone, const char *label, unsigned int rd_count, const struct GNUNET_GNSRECORD_Data *rd)
Function called with the result of our attempt to obtain a name for a given public key.
static void get_existing_record(void *cls, const struct GNUNET_IDENTITY_PrivateKey *zone_key, const char *rec_name, unsigned int rd_count, const struct GNUNET_GNSRECORD_Data *rd)
We're storing a record; this function is given the existing record so that we can merge the informati...
static int del
Desired action is to remove a record.
static void add_error_cb(void *cls)
Function called if lookup fails.
static int parse_expiration(const char *expirationstring, int *etime_is_rel, uint64_t *etime)
Parse expiration time.
static void monitor_error_cb(void *cls)
Function called on errors while monitoring.
static void purge_zone_iterator(void *cls, const struct GNUNET_IDENTITY_PrivateKey *zone_key, const char *rname, unsigned int rd_len, const struct GNUNET_GNSRECORD_Data *rd, struct GNUNET_TIME_Absolute expiry)
static void del_monitor(void *cls, const struct GNUNET_IDENTITY_PrivateKey *zone, const char *label, unsigned int rd_count, const struct GNUNET_GNSRECORD_Data *rd)
We were asked to delete something; this function is called with the existing records.
static void display_record_lookup(void *cls, const struct GNUNET_IDENTITY_PrivateKey *zone_key, const char *rname, unsigned int rd_len, const struct GNUNET_GNSRECORD_Data *rd)
Process a record that was stored in the namestore.
static int add
Desired action is to add a record.
static void zone_iteration_error_cb(void *cls)
Function called when we encountered an error in a zone iteration.
#define GNUNET_DNSPARSER_TYPE_OPENPGPKEY
#define GNUNET_DNSPARSER_TYPE_TLSA
#define GNUNET_DNSPARSER_TYPE_SRV
GNUNET_GNSRECORD_Filter
Filter for GNUNET_GNSRECORD_normalize_record_set().
@ GNUNET_GNSRECORD_FILTER_NONE
No filter flags set.
@ GNUNET_GNSRECORD_FILTER_INCLUDE_MAINTENANCE
Include maintenance records (TOMBSTONE etc).
@ GNUNET_GNSRECORD_FILTER_OMIT_PRIVATE
Filter private records.
enum GNUNET_GenericReturnValue GNUNET_IDENTITY_public_key_from_string(const char *str, struct GNUNET_IDENTITY_PublicKey *key)
Parses a (Base32) string representation of the public key.
ssize_t GNUNET_IDENTITY_public_key_get_length(const struct GNUNET_IDENTITY_PublicKey *key)
Get the compacted length of a GNUNET_IDENTITY_PublicKey.
Definition: identity_api.c:830
#define GNUNET_new_array(n, type)
Allocate a size n array with structs or unions of the given type.
struct GNUNET_NAMESTORE_QueueEntry * GNUNET_NAMESTORE_records_lookup(struct GNUNET_NAMESTORE_Handle *h, const struct GNUNET_IDENTITY_PrivateKey *pkey, const char *label, GNUNET_SCHEDULER_TaskCallback error_cb, void *error_cb_cls, GNUNET_NAMESTORE_RecordMonitor rm, void *rm_cls)
Lookup an item in the namestore.
struct GNUNET_NAMESTORE_ZoneIterator * GNUNET_NAMESTORE_zone_iteration_start2(struct GNUNET_NAMESTORE_Handle *h, const struct GNUNET_IDENTITY_PrivateKey *zone, GNUNET_SCHEDULER_TaskCallback error_cb, void *error_cb_cls, GNUNET_NAMESTORE_RecordSetMonitor proc, void *proc_cls, GNUNET_SCHEDULER_TaskCallback finish_cb, void *finish_cb_cls, enum GNUNET_GNSRECORD_Filter filter)
Starts a new zone iteration (used to periodically PUT all of our records into our DHT).
struct GNUNET_NAMESTORE_ZoneMonitor * GNUNET_NAMESTORE_zone_monitor_start2(const struct GNUNET_CONFIGURATION_Handle *cfg, const struct GNUNET_IDENTITY_PrivateKey *zone, int iterate_first, GNUNET_SCHEDULER_TaskCallback error_cb, void *error_cb_cls, GNUNET_NAMESTORE_RecordSetMonitor monitor, void *monitor_cls, GNUNET_SCHEDULER_TaskCallback sync_cb, void *sync_cb_cls, enum GNUNET_GNSRECORD_Filter filter)
Begin monitoring a zone for changes.
struct GNUNET_NAMESTORE_QueueEntry * GNUNET_NAMESTORE_zone_to_name(struct GNUNET_NAMESTORE_Handle *h, const struct GNUNET_IDENTITY_PrivateKey *zone, const struct GNUNET_IDENTITY_PublicKey *value_zone, GNUNET_SCHEDULER_TaskCallback error_cb, void *error_cb_cls, GNUNET_NAMESTORE_RecordMonitor proc, void *proc_cls)
Look for an existing PKEY delegation record for a given public key.
An identity key as per LSD0001.

References _, add, add_continuation(), add_error_cb(), add_qe, add_qe_uri, cfg, GNUNET_GNSRECORD_Data::data, data, GNUNET_GNSRECORD_Data::data_size, data_size, del, del_lookup_error_cb(), del_monitor(), del_qe, display_record_iterator(), display_record_lookup(), display_record_monitor(), e, ego_name, etime, etime_is_rel, GNUNET_GNSRECORD_Data::expiration_time, expirationstring, finish_command(), GNUNET_GNSRECORD_Data::flags, get_existing_record(), get_qe, GNUNET_DNSPARSER_TYPE_OPENPGPKEY, GNUNET_DNSPARSER_TYPE_SRV, GNUNET_DNSPARSER_TYPE_TLSA, GNUNET_free, GNUNET_GNS_EMPTY_LABEL_AT, GNUNET_GNSRECORD_FILTER_INCLUDE_MAINTENANCE, GNUNET_GNSRECORD_FILTER_NONE, GNUNET_GNSRECORD_FILTER_OMIT_PRIVATE, GNUNET_GNSRECORD_number_to_typename(), GNUNET_GNSRECORD_RF_RELATIVE_EXPIRATION, GNUNET_GNSRECORD_RF_SHADOW, GNUNET_GNSRECORD_string_to_value(), GNUNET_GNSRECORD_TYPE_NICK, GNUNET_GNSRECORD_typename_to_number(), GNUNET_IDENTITY_public_key_from_string(), GNUNET_IDENTITY_public_key_get_length(), GNUNET_NAMESTORE_records_lookup(), GNUNET_NAMESTORE_records_store(), GNUNET_NAMESTORE_zone_iteration_start2(), GNUNET_NAMESTORE_zone_monitor_start2(), GNUNET_NAMESTORE_zone_to_name(), GNUNET_new_array, GNUNET_OK, GNUNET_strdup, GNUNET_YES, handle_reverse_lookup(), include_maintenance, is_public, is_shadow, list, list_it, list_orphaned, lookup_error_cb(), monitor, monitor_error_cb(), name, nickstring, ns, omit_private, parse_expiration(), pkey, pubkey, purge_orphaned, purge_orphans_iterator(), purge_zone, purge_zone_iterator(), rd, rd_count, GNUNET_GNSRECORD_Data::record_type, recordset, replace_cont(), ret, reverse_error_cb(), reverse_pkey, reverse_qe, set_qe, sh, sync_cb(), type, typestring, uri, value, zm, zone_iteration_error_cb(), zone_iteration_finished(), and zone_pkey.

Referenced by begin_cb(), and process_command_stdin().

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

◆ get_identity_for_string()

static int get_identity_for_string ( const char *  str,
struct GNUNET_IDENTITY_PrivateKey zk 
)
static

FIXME: Check for zTLD?

Definition at line 1737 of file gnunet-namestore.c.

1739 {
1740  const struct GNUNET_IDENTITY_PrivateKey *privkey;
1742  struct GNUNET_IDENTITY_PublicKey ego_pubkey;
1743  struct EgoEntry *ego_entry;
1744 
1746  &pubkey))
1747  {
1748  for (ego_entry = ego_head;
1749  NULL != ego_entry; ego_entry = ego_entry->next)
1750  {
1751  privkey = GNUNET_IDENTITY_ego_get_private_key (ego_entry->ego);
1752  GNUNET_IDENTITY_ego_get_public_key (ego_entry->ego, &ego_pubkey);
1753  if (0 == memcmp (&ego_pubkey, &pubkey, sizeof (pubkey)))
1754  {
1755  *zk = *privkey;
1756  return GNUNET_OK;
1757  }
1758  }
1759  }
1760  else
1761  {
1762  for (ego_entry = ego_head; NULL != ego_entry; ego_entry = ego_entry->next)
1763  {
1765  if (0 != strcmp (str, ego_entry->identifier))
1766  continue;
1767  *zk = *GNUNET_IDENTITY_ego_get_private_key (ego_entry->ego);
1768  return GNUNET_OK;
1769  }
1770  }
1771  return GNUNET_NO;
1772 }
void GNUNET_IDENTITY_ego_get_public_key(struct GNUNET_IDENTITY_Ego *ego, struct GNUNET_IDENTITY_PublicKey *pk)
Get the identifier (public key) of an ego.
Definition: identity_api.c:573

References EgoEntry::ego, ego_head, GNUNET_IDENTITY_ego_get_private_key(), GNUNET_IDENTITY_ego_get_public_key(), GNUNET_IDENTITY_public_key_from_string(), GNUNET_NO, GNUNET_OK, EgoEntry::identifier, EgoEntry::next, and pubkey.

Referenced by process_command_stdin().

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

◆ begin_cb()

static void begin_cb ( void *  cls,
enum GNUNET_ErrorCode  ec 
)
static

Definition at line 1863 of file gnunet-namestore.c.

1864 {
1865  ns_qe = NULL;
1866  if (GNUNET_EC_NONE != ec)
1867  {
1869  "Failed to start transaction: %s\n",
1872  return;
1873  }
1874  if (read_from_stdin)
1875  {
1877  return;
1878  }
1880 }

References cfg, GNUNET_EC_NONE, GNUNET_ERROR_TYPE_ERROR, GNUNET_ErrorCode_get_hint(), GNUNET_log, GNUNET_SCHEDULER_shutdown(), ns_qe, process_command_stdin(), read_from_stdin, and run_with_zone_pkey().

Referenced by id_connect_cb().

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

◆ id_connect_cb()

static void id_connect_cb ( void *  cls,
struct GNUNET_IDENTITY_Ego ego,
void **  ctx,
const char *  name 
)
static

Function called with ALL of the egos known to the identity service, used on startup if the user did not specify a zone on the command-line.

Once the iteration is done (ego is NULL), we ask for the default ego for "namestore".

Parameters
clsa struct GNUNET_CONFIGURATION_Handle
egoan ego, NULL for end of iteration
ctxNULL
namename associated with ego

Definition at line 1896 of file gnunet-namestore.c.

1900 {
1902  struct EgoEntry *ego_entry;
1903 
1904  (void) ctx;
1905  (void) name;
1906  if ((NULL != name) && (NULL != ego))
1907  {
1908  ego_entry = GNUNET_new (struct EgoEntry);
1910  ego_entry->ego = ego;
1911  ego_entry->identifier = GNUNET_strdup (name);
1913  ego_tail,
1914  ego_entry);
1915  if ((NULL != ego_name) &&
1916  (0 == strcmp (name, ego_name)))
1918  return;
1919  }
1920  if (NULL != ego)
1921  return;
1923 }
struct GNUNET_IDENTITY_PrivateKey pk
Private key from command line option, or NULL.
static struct EgoEntry * ego_tail
Ego list.
static void begin_cb(void *cls, enum GNUNET_ErrorCode ec)
static struct GNUNET_DNSSTUB_Context * ctx
Context for DNS resolution.
#define GNUNET_CONTAINER_DLL_insert_tail(head, tail, element)
Insert an element at the tail of a DLL.
struct GNUNET_NAMESTORE_QueueEntry * GNUNET_NAMESTORE_transaction_begin(struct GNUNET_NAMESTORE_Handle *h, GNUNET_NAMESTORE_ContinuationWithStatus cont, void *cont_cls)
New API draft.

References begin_cb(), cfg, ctx, EgoEntry::ego, ego_head, ego_name, ego_tail, GNUNET_CONTAINER_DLL_insert_tail, GNUNET_IDENTITY_ego_get_private_key(), GNUNET_IDENTITY_ego_get_public_key(), GNUNET_NAMESTORE_transaction_begin(), GNUNET_new, GNUNET_strdup, EgoEntry::identifier, name, ns, ns_qe, pk, and zone_pkey.

Referenced by run().

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 _cfg 
)
static

Main function that will be run.

Parameters
clsclosure
argsremaining command-line arguments
cfgfilename of the configuration file used (for saving, can be NULL!)
cfgconfiguration

Definition at line 1938 of file gnunet-namestore.c.

1942 {
1943  (void) cls;
1944  (void) args;
1945  (void) cfgfile;
1946  cfg = _cfg;
1947  if (NULL != args[0])
1948  GNUNET_log (
1950  _ ("Superfluous command line arguments (starting with `%s') ignored\n"),
1951  args[0]);
1952 
1955  if (NULL == ns)
1956  {
1957  fprintf (stderr, _ ("Failed to connect to namestore\n"));
1959  return;
1960  }
1962  if (NULL == idh)
1963  {
1964  ret = -1;
1965  fprintf (stderr, _ ("Cannot connect to identity service\n"));
1967  }
1968 }
static void do_shutdown(void *cls)
Task run on shutdown.
static void id_connect_cb(void *cls, struct GNUNET_IDENTITY_Ego *ego, void **ctx, const char *name)
Function called with ALL of the egos known to the identity service, used on startup if the user did n...
struct GNUNET_IDENTITY_Handle * GNUNET_IDENTITY_connect(const struct GNUNET_CONFIGURATION_Handle *cfg, GNUNET_IDENTITY_Callback cb, void *cb_cls)
Connect to the identity service.
Definition: identity_api.c:531
struct GNUNET_NAMESTORE_Handle * GNUNET_NAMESTORE_connect(const struct GNUNET_CONFIGURATION_Handle *cfg)
Connect to the namestore service.
struct GNUNET_SCHEDULER_Task * GNUNET_SCHEDULER_add_shutdown(GNUNET_SCHEDULER_TaskCallback task, void *task_cls)
Schedule a new task to be run on shutdown, that is when a CTRL-C signal is received,...
Definition: scheduler.c:1303

References _, consensus-simulation::args, cfg, do_shutdown(), GNUNET_ERROR_TYPE_WARNING, GNUNET_IDENTITY_connect(), GNUNET_log, GNUNET_NAMESTORE_connect(), GNUNET_SCHEDULER_add_shutdown(), GNUNET_SCHEDULER_shutdown(), id_connect_cb(), idh, ns, and ret.

Referenced by main().

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

◆ main()

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

The main function for gnunet-namestore.

Parameters
argcnumber of arguments from the command line
argvcommand line arguments
Returns
0 ok, 1 on error

Definition at line 1980 of file gnunet-namestore.c.

1981 {
1982  int lret;
1984  { GNUNET_GETOPT_option_flag ('a', "add", gettext_noop ("add record"), &add),
1986  "delete",
1987  gettext_noop ("delete record"),
1988  &del),
1990  "display",
1991  gettext_noop ("display records"),
1992  &list),
1994  "from-stdin",
1995  gettext_noop ("read commands from stdin"),
1996  &read_from_stdin),
1998  'e',
1999  "expiration",
2000  "TIME",
2001  gettext_noop (
2002  "expiration time for record to use (for adding only), \"never\" is possible"),
2003  &expirationstring),
2005  "nick",
2006  "NICKNAME",
2007  gettext_noop (
2008  "set the desired nick name for the zone"),
2009  &nickstring),
2011  "monitor",
2012  gettext_noop (
2013  "monitor changes in the namestore"),
2014  &monitor),
2016  "name",
2017  "NAME",
2018  gettext_noop (
2019  "name of the record to add/delete/display"),
2020  &name),
2022  "recordline",
2023  gettext_noop ("Output in recordline format"),
2026  "zone-to-name",
2027  "KEY",
2028  gettext_noop (
2029  "determine our name for the given KEY"),
2030  &reverse_pkey),
2032  "type",
2033  "TYPE",
2034  gettext_noop (
2035  "type of the record to add/delete/display"),
2036  &typestring),
2038  "uri",
2039  "URI",
2040  gettext_noop ("URI to import into our zone"),
2041  &uri),
2043  "value",
2044  "VALUE",
2045  gettext_noop (
2046  "value of the record to add/delete"),
2047  &value),
2049  "public",
2050  gettext_noop ("create or list public record"),
2051  &is_public),
2053  "omit-private",
2054  gettext_noop ("omit private records"),
2055  &omit_private),
2057  "include-maintenance",
2058  gettext_noop (
2059  "do not filter maintenance records"),
2062  "purge-orphans",
2063  gettext_noop (
2064  "purge namestore of all orphans"),
2065  &purge_orphaned),
2067  "list-orphans",
2068  gettext_noop (
2069  "show private key for orphaned records for recovery using `gnunet-identity -C -P <key>'. Use in combination with --display"),
2070  &list_orphaned),
2072  "purge-zone-records",
2073  gettext_noop (
2074  "delete all records in specified zone"),
2075  &purge_zone),
2077  's',
2078  "shadow",
2079  gettext_noop (
2080  "create shadow record (only valid if all other records of the same type have expired"),
2081  &is_shadow),
2083  "zone",
2084  "EGO",
2085  gettext_noop (
2086  "name of the ego controlling the zone"),
2087  &ego_name),
2089 
2090 
2091  if (GNUNET_OK != GNUNET_STRINGS_get_utf8_args (argc, argv, &argc, &argv))
2092  return 2;
2093 
2094  is_public = -1;
2095  is_shadow = -1;
2096  GNUNET_log_setup ("gnunet-namestore", "WARNING", NULL);
2097  if (GNUNET_OK !=
2098  (lret = GNUNET_PROGRAM_run (argc,
2099  argv,
2100  "gnunet-namestore",
2101  _ ("GNUnet zone manipulation tool"),
2102  options,
2103  &run,
2104  NULL)))
2105  {
2106  GNUNET_free_nz ((void *) argv);
2107  // FIXME
2108  // GNUNET_CRYPTO_ecdsa_key_clear (&zone_pkey);
2109  return lret;
2110  }
2111  GNUNET_free_nz ((void *) argv);
2112  // FIXME
2113  // GNUNET_CRYPTO_ecdsa_key_clear (&zone_pkey);
2114  return ret;
2115 }
struct GNUNET_GETOPT_CommandLineOption GNUNET_GETOPT_OPTION_END
Definition: 002.c:13
struct GNUNET_GETOPT_CommandLineOption options[]
Definition: 002.c:5
#define gettext_noop(String)
Definition: gettext.h:70
static void run(void *cls, char *const *args, const char *cfgfile, const struct GNUNET_CONFIGURATION_Handle *_cfg)
Main function that will be run.
struct GNUNET_GETOPT_CommandLineOption GNUNET_GETOPT_option_flag(char shortName, const char *name, const char *description, int *val)
Allow user to specify a flag (which internally means setting an integer to 1/GNUNET_YES/GNUNET_OK.
struct GNUNET_GETOPT_CommandLineOption GNUNET_GETOPT_option_string(char shortName, const char *name, const char *argumentHelp, const char *description, char **str)
Allow user to specify a string.
int GNUNET_log_setup(const char *comp, const char *loglevel, const char *logfile)
Setup logging.
#define GNUNET_free_nz(ptr)
Wrapper around free.
enum GNUNET_GenericReturnValue GNUNET_PROGRAM_run(int argc, char *const *argv, const char *binaryName, const char *binaryHelp, const struct GNUNET_GETOPT_CommandLineOption *options, GNUNET_PROGRAM_Main task, void *task_cls)
Run a standard GNUnet command startup sequence (initialize loggers and configuration,...
Definition: program.c:400
enum GNUNET_GenericReturnValue GNUNET_STRINGS_get_utf8_args(int argc, char *const *argv, int *u8argc, char *const **u8argv)
Returns utf-8 encoded arguments.
Definition: strings.c:1222
Definition of a command line option.

References _, add, del, ego_name, expirationstring, gettext_noop, GNUNET_free_nz, GNUNET_GETOPT_OPTION_END, GNUNET_GETOPT_option_flag(), GNUNET_GETOPT_option_string(), GNUNET_log_setup(), GNUNET_OK, GNUNET_PROGRAM_run(), GNUNET_STRINGS_get_utf8_args(), include_maintenance, is_public, is_shadow, list, list_orphaned, monitor, name, nickstring, omit_private, options, output_recordline, purge_orphaned, purge_zone, read_from_stdin, ret, reverse_pkey, run(), typestring, uri, and value.

Here is the call graph for this function:

Variable Documentation

◆ ns

◆ zone_pkey

struct GNUNET_IDENTITY_PrivateKey zone_pkey
static

Private key for the our zone.

Definition at line 114 of file gnunet-namestore.c.

Referenced by del_monitor(), get_existing_record(), id_connect_cb(), process_command_stdin(), reset_handles(), and run_with_zone_pkey().

◆ idh

struct GNUNET_IDENTITY_Handle* idh
static

Identity service handle.

Definition at line 124 of file gnunet-namestore.c.

Referenced by do_shutdown(), and run().

◆ ego_name

char* ego_name
static

Name of the ego controlling the zone.

Definition at line 129 of file gnunet-namestore.c.

Referenced by handle_reverse_lookup(), id_connect_cb(), main(), reset_handles(), and run_with_zone_pkey().

◆ add_qe_uri

struct GNUNET_NAMESTORE_QueueEntry* add_qe_uri
static

Queue entry for the 'add-uri' operation.

Definition at line 134 of file gnunet-namestore.c.

Referenced by reset_handles(), and run_with_zone_pkey().

◆ add_qe

struct GNUNET_NAMESTORE_QueueEntry* add_qe
static

Queue entry for the 'add' operation.

Definition at line 139 of file gnunet-namestore.c.

Referenced by add_error_cb(), get_existing_record(), reset_handles(), and run_with_zone_pkey().

◆ get_qe

struct GNUNET_NAMESTORE_QueueEntry* get_qe
static

Queue entry for the 'lookup' operation.

Definition at line 144 of file gnunet-namestore.c.

Referenced by display_record_lookup(), lookup_error_cb(), reset_handles(), and run_with_zone_pkey().

◆ reverse_qe

struct GNUNET_NAMESTORE_QueueEntry* reverse_qe
static

Queue entry for the 'reverse lookup' operation (in combination with a name).

Definition at line 149 of file gnunet-namestore.c.

Referenced by handle_reverse_lookup(), reset_handles(), reverse_error_cb(), and run_with_zone_pkey().

◆ marked_head

struct MarkedRecord* marked_head
static

Marked record list.

Definition at line 154 of file gnunet-namestore.c.

Referenced by collect_orphans(), collect_zone_records_to_purge(), purge_next_record(), and reset_handles().

◆ marked_tail

struct MarkedRecord* marked_tail
static

Marked record list.

Definition at line 159 of file gnunet-namestore.c.

Referenced by collect_orphans(), collect_zone_records_to_purge(), and purge_next_record().

◆ cfg

const struct GNUNET_CONFIGURATION_Handle* cfg

Configuration handle.

Handle to our configuration.

Definition at line 164 of file gnunet-namestore.c.

Referenced by begin_cb(), id_connect_cb(), process_command_stdin(), run(), and run_with_zone_pkey().

◆ ego_head

struct EgoEntry* ego_head
static

◆ ego_tail

struct EgoEntry* ego_tail
static

Ego list.

Definition at line 174 of file gnunet-namestore.c.

Referenced by id_connect_cb().

◆ list_it

◆ read_from_stdin

int read_from_stdin
static

Run in read from stdin mode.

Definition at line 184 of file gnunet-namestore.c.

Referenced by begin_cb(), finish_command(), and main().

◆ list

int list
static

Desired action is to list records.

Definition at line 189 of file gnunet-namestore.c.

Referenced by main(), reset_handles(), and run_with_zone_pkey().

◆ add

◆ del

int del
static

Desired action is to remove a record.

Definition at line 199 of file gnunet-namestore.c.

Referenced by forward_resolution(), GNUNET_ABD_delegate_issue(), main(), run_with_zone_pkey(), and send_lookup_response().

◆ is_public

int is_public
static

Is record public (opposite of GNUNET_GNSRECORD_RF_PRIVATE)

Definition at line 204 of file gnunet-namestore.c.

Referenced by get_existing_record(), main(), reset_handles(), and run_with_zone_pkey().

◆ is_shadow

int is_shadow
static

Is record a shadow record (GNUNET_GNSRECORD_RF_SHADOW)

Definition at line 209 of file gnunet-namestore.c.

Referenced by get_existing_record(), main(), reset_handles(), and run_with_zone_pkey().

◆ omit_private

int omit_private
static

Filter private records.

Definition at line 214 of file gnunet-namestore.c.

Referenced by main(), and run_with_zone_pkey().

◆ output_recordline

int output_recordline
static

Output in recordline format.

Definition at line 219 of file gnunet-namestore.c.

Referenced by display_record(), and main().

◆ purge_zone

int purge_zone
static

Purge zone contents.

Definition at line 225 of file gnunet-namestore.c.

Referenced by main(), reset_handles(), run_with_zone_pkey(), and zone_iteration_finished().

◆ include_maintenance

int include_maintenance
static

Do not filter maintenance records.

Definition at line 230 of file gnunet-namestore.c.

Referenced by main(), and run_with_zone_pkey().

◆ purge_orphaned

int purge_orphaned
static

Purge orphaned records.

Definition at line 235 of file gnunet-namestore.c.

Referenced by main(), run_with_zone_pkey(), and zone_iteration_finished().

◆ list_orphaned

int list_orphaned
static

List records and zone keys of orphaned records.

Definition at line 240 of file gnunet-namestore.c.

Referenced by display_record(), main(), and run_with_zone_pkey().

◆ del_qe

struct GNUNET_NAMESTORE_QueueEntry* del_qe
static

◆ set_qe

struct GNUNET_NAMESTORE_QueueEntry* set_qe
static

Queue entry for the 'set/replace' operation.

Definition at line 250 of file gnunet-namestore.c.

Referenced by replace_cont(), reset_handles(), and run_with_zone_pkey().

◆ ns_qe

struct GNUNET_NAMESTORE_QueueEntry* ns_qe
static

Queue entry for begin/commit.

Definition at line 255 of file gnunet-namestore.c.

Referenced by begin_cb(), commit_cb(), do_shutdown(), finish_command(), id_connect_cb(), and process_command_stdin().

◆ name

char* name
static

Name of the records to add/list/remove.

Definition at line 260 of file gnunet-namestore.c.

Referenced by del_monitor(), display_record(), get_existing_record(), id_connect_cb(), main(), process_command_stdin(), reset_handles(), and run_with_zone_pkey().

◆ value

char* value
static

Value of the record to add/remove.

Definition at line 265 of file gnunet-namestore.c.

Referenced by add_section_contents(), add_sections(), add_setter_action(), add_to_tc(), age_values(), attr_in_claims_request(), auto_conf_iter(), bandwidth_stats_iterator(), barrier_destroy_iterator(), bind_loose_channel(), blacklist_cfg_iter(), build_result_set(), bulk_tx_start(), cache_clear_iterator(), call_iterator(), cancel_pending_request(), cfg_copy_iterator(), change_peer_respect(), channel_destroy_iterator(), check_connection_quality(), check_known_address(), check_known_challenge(), check_validation_request_pending(), check_vectors(), clean_local_client(), clean_request(), cleanup_channel(), cleanup_destination(), cleanup_hashmap(), cleanup_iterator(), cleanup_url_map(), cleanup_validation_entry(), client_disconnect_it(), client_release_ports(), close_files_iter(), collector(), compare_entries(), compute_service_response(), compute_square_sum_mpi_elements(), con_val_iter(), consume_cont(), cookie_identity_interpretation(), copy_element_cb(), copy_entry(), create_randomized_element_iterator(), create_response(), database_setup(), debug_channel(), del_monitor(), delete_entries(), delete_value(), destroy_active_client_request(), destroy_ai_cb(), destroy_all_address_it(), destroy_channel_cb(), destroy_elements_iterator(), destroy_it(), destroy_iterator_cb(), destroy_key_to_element_iter(), destroy_paths_now(), destroy_port_cb(), destroy_remaining_channels(), destroy_session_cb(), destroy_session_shutdown_cb(), destroy_tunnels_now(), destroy_watch(), determinate_avg_element_size_iterator(), determinate_done_message_iterator(), disconnect_all_neighbours(), disconnect_and_free_it(), disconnect_and_free_peer_entry(), dns_string_to_value(), dns_value_to_string(), do_notify(), do_restart_typemap_message(), drop_client_entries(), dv_neighbour_selection(), dv_neighbour_transmission(), execute_get(), execute_select(), expire_blocks(), expire_entries(), filter_all(), filtered_map_initialization(), find_address_cb(), find_address_it(), find_advertisable_hello(), find_ai_cb(), find_ai_no_session_cb(), find_best_address_it(), find_by_message_uuid(), find_result_set(), find_sender_by_address(), find_trees(), flush_respect(), free_ack_cummulator_cb(), free_addr_it(), free_all_it(), free_backtalker_cb(), free_barrier_node_cb(), free_barriers_cb(), free_blacklist_entry(), free_dv_routes_cb(), free_ego(), free_element_cb(), free_entry(), free_host_entry(), free_item(), free_iterate(), free_matching_requests(), free_namespaces_cb(), free_neighbour_cb(), free_nodes_cb(), free_peer(), free_pending_ack_cb(), free_preference(), free_reassembly_cb(), free_request(), free_request_it(), free_result(), free_service_record(), free_sug_handle(), free_tmps(), free_tracker(), free_validation_state_cb(), free_value(), free_waiting_entry(), full_sync_plausibility_check(), get_active_address_it(), get_all_peers_iterator(), get_all_tunnels_iterator(), get_iterator(), get_lt_delete_it(), get_queue_delete_it(), get_rand_peer_iterator(), get_receiver_delete_it(), get_result_present(), get_sender_delete_it(), get_session_delete_it(), get_url_parameter_copy(), GNUNET_CONFIGURATION_append_value_filename(), GNUNET_CONFIGURATION_config_tool_run(), GNUNET_CONFIGURATION_set_value_string(), GNUNET_CONTAINER_multihashmap32_contains_value(), GNUNET_CONTAINER_multihashmap32_iterator_next(), GNUNET_CONTAINER_multihashmap32_put(), GNUNET_CONTAINER_multihashmap32_remove(), GNUNET_CONTAINER_multihashmap_contains_value(), GNUNET_CONTAINER_multihashmap_iterator_next(), GNUNET_CONTAINER_multihashmap_put(), GNUNET_CONTAINER_multihashmap_remove(), GNUNET_CONTAINER_multipeermap_contains_value(), GNUNET_CONTAINER_multipeermap_iterator_next(), GNUNET_CONTAINER_multipeermap_put(), GNUNET_CONTAINER_multipeermap_remove(), GNUNET_CONTAINER_multishortmap_contains_value(), GNUNET_CONTAINER_multishortmap_iterator_next(), GNUNET_CONTAINER_multishortmap_put(), GNUNET_CONTAINER_multishortmap_remove(), GNUNET_CONTAINER_multiuuidmap_contains_value(), GNUNET_CONTAINER_multiuuidmap_iterator_next(), GNUNET_CONTAINER_multiuuidmap_put(), GNUNET_CONTAINER_multiuuidmap_remove(), GNUNET_FS_GETOPT_KEYWORDS(), GNUNET_FS_GETOPT_METADATA(), GNUNET_NETWORK_socket_disable_corking(), GNUNET_PEERSTORE_store(), GNUNET_STATISTICS_set(), GNUNET_TESTING_get_topo_from_string(), GSF_cadet_release_clients(), handle_ack(), handle_alice_client_message(), handle_bob_client_message(), handle_set(), hash_hosts(), header_iterator(), heap_plugin_get_expiration(), heap_plugin_get_replication(), heap_plugin_get_zero_anonymity(), heap_plugin_put(), incrementBit(), init_key_to_element_iterator(), initialize_map_unfiltered(), inspect_attrs(), iterate_addresses(), iterate_channels_cb(), iterate_close_room(), iterate_copy_history(), iterate_create_ego(), iterate_destroy_contacts(), iterate_destroy_egos(), iterate_destroy_entries(), iterate_destroy_links(), iterate_destroy_members(), iterate_destroy_message(), iterate_destroy_messages(), iterate_destroy_operations(), iterate_destroy_room(), iterate_destroy_rooms(), iterate_destroy_session(), iterate_destroy_tunnels(), iterate_entries(), iterate_find_member(), iterate_find_room(), iterate_free_member_ids(), iterate_load_next_member_sessions(), iterate_load_next_session(), iterate_local_members(), iterate_member_sessions_it(), iterate_reachables(), iterate_reset_room(), iterate_save_entries(), iterate_save_links(), iterate_save_member_session_history_hentries(), iterate_save_members(), iterate_save_messages(), iterate_save_operations(), iterate_save_rooms(), iterate_save_session(), iterate_search_session(), iterate_send_room_message(), iterate_store_members_it(), iterate_sync_member_contacts(), iterate_sync_session_contact(), iterate_zones(), iterator(), iterator_bf_create(), iterator_bf_reduce(), iterator_cb(), jwt_parse_attributes(), locate_by_id(), log_namespaces(), log_nodes(), lookup_queue_it(), lookup_session_it(), main(), make_json(), mark_match_down(), mark_peer_down(), migrate_and_drop_keywords(), migrate_and_drop_metadata(), move_to_pending(), move_to_queue(), mpi_to_sexp(), neighbour_delete(), neighbours_iterate(), nibble_to_regex(), node_connections(), normalize_address(), notify_change(), notify_client_about_session(), notify_client_connect_info(), notify_client_queues(), notify_tunnel_up_cb(), num_to_regex(), op_get_element_iterator(), opc_free_iterator(), opc_search_iterator(), open_port_cb(), parse_jwt(), parse_record(), parse_record_data(), peerinfo_it(), peermap_clear_iterator(), PEERSTORE_create_record_mq_envelope(), peerstore_flat_store_record(), peerstore_sqlite_store_record(), pending_reversals_delete_it(), prepare_ibf_iterator(), print_option(), printer(), printer_watch(), process_reply(), process_result_with_request(), process_stat(), process_stat_in(), process_stats(), process_update_node(), rcop_cleanup_iterator(), reachability_iterator(), read_service_conf(), regex_cancel_dht_get(), regex_free_result(), regex_result_iterator(), reghost_free_iterator(), remove_all(), remove_iterator(), reschedule_hellos(), reset_handles(), rewatch_it(), rsa_sign_mpi(), run(), run_with_zone_pkey(), schedule_current_round(), search_iterator(), search_result_free(), search_result_freeze_probes(), search_result_resume_probes(), search_result_stop(), search_result_suspend(), send_full_element_iterator(), send_missing_full_elements_iter(), send_offers_iterator(), send_session_info_iter(), send_simple_cb(), send_utilization_data(), session_cmp_it(), session_disconnect_it(), session_lookup_client_by_address(), session_lookup_it(), session_tag_it(), set_cont(), set_insert_iterator(), set_value(), signal_result_resume(), socket_set_nodelay(), stat_iterator(), statistics_cb(), statistics_result(), stats_iterator(), stop_peer_request(), store_and_free_entries(), store_peer_presistently_iterator(), stun_attr2str(), stun_msg2str(), sum_relative_preferences(), test_blacklisted(), test_exist_cb(), test_result_present(), ticket_collect(), tld_iter(), transmit_client_response(), transmit_suggestion(), try_add_peers(), update_abs_sum(), update_config(), update_flood_times(), update_iterator(), update_rel_sum(), update_sre_result_maps(), url_iterator(), valid_peer_iterator(), validation_entry_match(), watch_notifier_it(), write_item(), and zone_to_name().

◆ uri

char* uri
static

URI to import.

Definition at line 270 of file gnunet-namestore.c.

Referenced by main(), reset_handles(), and run_with_zone_pkey().

◆ reverse_pkey

char* reverse_pkey
static

Reverse lookup to perform.

Definition at line 275 of file gnunet-namestore.c.

Referenced by handle_reverse_lookup(), main(), reverse_error_cb(), and run_with_zone_pkey().

◆ typestring

char* typestring
static

Type of the record to add/remove, NULL to remove all.

Definition at line 280 of file gnunet-namestore.c.

Referenced by del_monitor(), display_record(), main(), reset_handles(), and run_with_zone_pkey().

◆ expirationstring

char* expirationstring
static

Desired expiration time.

Definition at line 285 of file gnunet-namestore.c.

Referenced by main(), parse_expiration(), reset_handles(), and run_with_zone_pkey().

◆ nickstring

char* nickstring
static

Desired nick name.

Definition at line 290 of file gnunet-namestore.c.

Referenced by main(), and run_with_zone_pkey().

◆ ret

◆ type

uint32_t type
static

Type string converted to DNS type value.

Definition at line 300 of file gnunet-namestore.c.

Referenced by del_monitor(), display_record(), get_existing_record(), and run_with_zone_pkey().

◆ data

void* data
static

Value in binary format.

Definition at line 305 of file gnunet-namestore.c.

Referenced by del_monitor(), display_record(), get_existing_record(), reset_handles(), and run_with_zone_pkey().

◆ data_size

size_t data_size
static

Number of bytes in data.

Definition at line 310 of file gnunet-namestore.c.

Referenced by del_monitor(), display_record(), get_existing_record(), and run_with_zone_pkey().

◆ etime

uint64_t etime
static

Expiration string converted to numeric value.

Definition at line 315 of file gnunet-namestore.c.

Referenced by get_existing_record(), parse_expiration(), and run_with_zone_pkey().

◆ etime_is_rel

int etime_is_rel = GNUNET_SYSERR
static

Is expiration time relative or absolute time?

Definition at line 320 of file gnunet-namestore.c.

Referenced by get_existing_record(), parse_expiration(), and run_with_zone_pkey().

◆ zm

◆ monitor

int monitor
static

Enables monitor mode.

Definition at line 330 of file gnunet-namestore.c.

Referenced by main(), and run_with_zone_pkey().

◆ recordset

struct RecordSetEntry* recordset
static

Entry in record set for processing records in bulk.

Definition at line 335 of file gnunet-namestore.c.

Referenced by parse_recordline(), process_command_stdin(), reset_handles(), and run_with_zone_pkey().

◆ purge_task

struct GNUNET_SCHEDULER_Task* purge_task
static

Purge task.

Definition at line 340 of file gnunet-namestore.c.

Referenced by marked_deleted(), purge_next_record(), reset_handles(), and zone_iteration_finished().