gnunet-namestore-zonefile.c File Reference

#include "platform.h"
#include <gnunet_util_lib.h>
#include <gnunet_namestore_plugin.h>

Include dependency graph for gnunet-namestore-zonefile.c:

Go to the source code of this file.

Macros
#define	MAX_RECORDS_PER_NAME   50
#define	MAX_ZONEFILE_LINE_LEN   4096
	Maximum length of a zonefile line.
#define	MAX_ZONEFILE_RECORD_DATA_LEN   2048
	FIXME: Soft limit this?

Enumerations
enum	ZonefileImportState { ZS_READY , ZS_ORIGIN_SET , ZS_ORIGIN_CHANGED , ZS_NAME_CHANGED }

Functions
static void	do_shutdown (void *cls)
	Task run on shutdown.
static void	parse (void *cls)
	Main function that will be run.
static char *	trim (char *line)
static char *	next_token (char *token)
static int	parse_ttl (char *token, struct GNUNET_TIME_Relative *pttl)
static int	parse_origin (char *token, char *porigin)
static void	origin_create_cb (void *cls, const struct GNUNET_CRYPTO_PrivateKey *pk, enum GNUNET_ErrorCode ec)
static void	origin_lookup_cb (void *cls, struct GNUNET_IDENTITY_Ego *ego)
static void	add_continuation (void *cls, enum GNUNET_ErrorCode ec)
static void	identity_cb (void *cls, struct GNUNET_IDENTITY_Ego *ego)
static void	run (void *cls, char *const *args, const char *cfgfile, const struct GNUNET_CONFIGURATION_Handle *_cfg)
int	main (int argc, char *const *argv)
	The main function for gnunet-namestore-dbtool.

Variables
static struct GNUNET_GNSRECORD_Data	rd [50]
	The record data under a single label.
static struct GNUNET_TIME_Relative	ttl
	Current record $TTL to use.
static char	origin [GNUNET_DNSPARSER_MAX_NAME_LENGTH]
	Current origin.
static unsigned int	rd_count = 0
	Number of records for currently parsed set.
static int	ret = 0
	Return code.
static char *	ego_name = NULL
	Name of the ego.
static char *	res
	Currently read line or NULL on EOF.
static unsigned int	published_sets = 0
	Statistics, how many published record sets.
static unsigned int	published_records = 0
	Statistics, how many records published in aggregate.
static struct GNUNET_IDENTITY_EgoLookup *	el
	Handle to identity lookup.
static struct GNUNET_CRYPTO_PrivateKey	zone_pkey
	Private key for the our zone.
static struct GNUNET_NAMESTORE_QueueEntry *	ns_qe
	Queue entry for the 'add' operation.
static struct GNUNET_NAMESTORE_Handle *	ns
	Handle to the namestore.
static struct GNUNET_IDENTITY_Operation *	id_op
	Origin create operations.
static struct GNUNET_IDENTITY_Handle *	id
	Handle to IDENTITY.
static const struct GNUNET_CONFIGURATION_Handle *	cfg
	Current configurataion.
static struct GNUNET_SCHEDULER_Task *	parse_task
	Scheduled parse task.
static int	state
	The current state of the parser.

Macro Definition Documentation

MAX_RECORDS_PER_NAME

#define MAX_RECORDS_PER_NAME   50

Definition at line 30 of file gnunet-namestore-zonefile.c.

MAX_ZONEFILE_LINE_LEN

#define MAX_ZONEFILE_LINE_LEN   4096

Maximum length of a zonefile line.

Definition at line 35 of file gnunet-namestore-zonefile.c.

MAX_ZONEFILE_RECORD_DATA_LEN

#define MAX_ZONEFILE_RECORD_DATA_LEN   2048

FIXME: Soft limit this?

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

Enumeration Type Documentation

ZonefileImportState

enum ZonefileImportState

Enumerator
ZS_READY
ZS_ORIGIN_SET
ZS_ORIGIN_CHANGED
ZS_NAME_CHANGED

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

{
 
  /* Uninitialized */
  ZS_READY,
 
  /* The initial state */
  ZS_ORIGIN_SET,
 
  /* The $ORIGIN has changed */
  ZS_ORIGIN_CHANGED,
 
  /* The record name/label has changed */
  ZS_NAME_CHANGED
 
};

Function Documentation

do_shutdown()

static void do_shutdown ( void *  cls )

static

Task run on shutdown.

Cleans up everything.

Parameters

cls

unused

Definition at line 158 of file gnunet-namestore-zonefile.c.

{
  (void) cls;
  if (NULL != ego_name)
    GNUNET_free (ego_name);
  if (NULL != el)
  {
    GNUNET_IDENTITY_ego_lookup_cancel (el);
    el = NULL;
  }
  if (NULL != ns_qe)
    GNUNET_NAMESTORE_cancel (ns_qe);
  if (NULL != id_op)
    GNUNET_IDENTITY_cancel (id_op);
  if (NULL != ns)
    GNUNET_NAMESTORE_disconnect (ns);
  if (NULL != id)
    GNUNET_IDENTITY_disconnect (id);
  for (int i = 0; i < rd_count; i++)
  {
    void *rd_ptr = (void*) rd[i].data;
    GNUNET_free (rd_ptr);
  }
  if (NULL != parse_task)
    GNUNET_SCHEDULER_cancel (parse_task);
}

References data, ego_name, el, GNUNET_free, GNUNET_IDENTITY_cancel(), GNUNET_IDENTITY_disconnect(), GNUNET_IDENTITY_ego_lookup_cancel(), GNUNET_NAMESTORE_cancel(), GNUNET_NAMESTORE_disconnect(), GNUNET_SCHEDULER_cancel(), id_op, ns, ns_qe, parse_task, rd, and rd_count.

Here is the call graph for this function:

parse()

static void parse ( void *  cls )

static

Main function that will be run.

TODO:

• We must assume that names are not repeated later in the zonefile because our _store APIs are replacing. No sure if that is common in zonefiles.
• We must only actually store a record set when the name to store changes or the end of the file is reached. that way we can group them and add (see above).
• We need to hope our string formats are compatible, but seems ok.

Parameters

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

Definition at line 358 of file gnunet-namestore-zonefile.c.

{
  char buf[MAX_ZONEFILE_LINE_LEN];
  char payload[MAX_ZONEFILE_RECORD_DATA_LEN];
  char *next;
  char *token;
  char *payload_pos;
  static char lastname[GNUNET_DNSPARSER_MAX_LABEL_LENGTH];
  char newname[GNUNET_DNSPARSER_MAX_LABEL_LENGTH];
  void *data;
  size_t data_size;
  int ttl_line = 0;
  int type;
  int bracket_unclosed = 0;
  int quoted = 0;
  int ln = 0;
 
  parse_task = NULL;
  /* use filename provided as 1st argument (stdin by default) */
  while ((res = fgets (buf, sizeof(buf), stdin)))                     /* read each line of input */
  {
    ln++;
    ttl_line = 0;
    token = trim (buf);
    GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
                "Trimmed line (bracket %s): `%s'\n",
                (bracket_unclosed > 0) ? "unclosed" : "closed",
                token);
    if ((0 == strlen (token)) ||
        ((1 == strlen (token)) && (' ' == *token)))
      continue; // I guess we can safely ignore blank lines
    if (bracket_unclosed == 0)
    {
      /* Payload is already parsed */
      payload_pos = payload;
      /* Find space */
      next = strchr (token, ' ');
      if (NULL == next)
      {
        fprintf (stderr, "Error at line %u: %s\n", ln, token);
        ret = 1;
        GNUNET_SCHEDULER_shutdown ();
        return;
      }
      next[0] = '\0';
      next++;
      if (0 == (strcmp (token, "$ORIGIN")))
      {
        state = ZS_ORIGIN_CHANGED;
        token = next_token (next);
      }
      else if (0 == (strcmp (token, "$TTL")))
      {
        ttl_line = 1;
        token = next_token (next);
      }
      else
      {
        if (0 == strcmp (token, "IN")) // Inherit name from before
        {
          GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
                      "Old name: %s\n", lastname);
          strcpy (newname, lastname);
          token[strlen (token)] = ' ';
        }
        else if (token[strlen (token) - 1] != '.') // no fqdn
        {
          GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "New name: %s\n", token);
          if (GNUNET_DNSPARSER_MAX_LABEL_LENGTH < strlen (token))
          {
            fprintf (stderr,
                     _ ("Name `%s' is too long\n"),
                     token);
            ret = 1;
            GNUNET_SCHEDULER_shutdown ();
            return;
          }
          strcpy (newname, token);
          token = next_token (next);
        }
        else if (0 == strcmp (token, origin))
        {
          GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "New name: @\n");
          strcpy (newname, "@");
          token = next_token (next);
        }
        else
        {
          if (strlen (token) < strlen (origin))
          {
            fprintf (stderr, "Wrong origin: %s (expected %s)\n", token, origin);
            break; // FIXME error?
          }
          if (0 != strcmp (token + (strlen (token) - strlen (origin)), origin))
          {
            fprintf (stderr, "Wrong origin: %s (expected %s)\n", token, origin);
            break;
          }
          token[strlen (token) - strlen (origin) - 1] = '\0';
          GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "New name: %s\n", token);
          if (GNUNET_DNSPARSER_MAX_LABEL_LENGTH < strlen (token))
          {
            fprintf (stderr,
                     _ ("Name `%s' is too long\n"),
                     token);
            ret = 1;
            GNUNET_SCHEDULER_shutdown ();
            return;
          }
          strcpy (newname, token);
          token = next_token (next);
        }
        if (0 != strcmp (newname, lastname) &&
            (0 < rd_count))
        {
          GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
                      "Name changed %s->%s, storing record set of %u elements\n",
                      lastname, newname,
                      rd_count);
          state = ZS_NAME_CHANGED;
        }
        else
        {
          strcpy (lastname, newname);
        }
      }
 
      if (ttl_line)
      {
        if (GNUNET_SYSERR == parse_ttl (token, &ttl))
        {
          fprintf (stderr, _ ("Failed to parse $TTL\n"));
          ret = 1;
          GNUNET_SCHEDULER_shutdown ();
          return;
        }
        continue;
      }
      if (ZS_ORIGIN_CHANGED == state)
      {
        if (GNUNET_SYSERR == parse_origin (token, origin))
        {
          fprintf (stderr, _ ("Failed to parse $ORIGIN from %s\n"), token);
          ret = 1;
          GNUNET_SCHEDULER_shutdown ();
          return;
        }
        break;
      }
      if (ZS_READY == state)
      {
        fprintf (stderr,
                 _ (
                   "You must provide $ORIGIN in your zonefile or via arguments (--zone)!\n"));
        ret = 1;
        GNUNET_SCHEDULER_shutdown ();
        return;
      }
      // This is a record, let's go
      if (MAX_RECORDS_PER_NAME == rd_count)
      {
        fprintf (stderr,
                 _ ("Only %u records per unique name supported.\n"),
                 MAX_RECORDS_PER_NAME);
        ret = 1;
        GNUNET_SCHEDULER_shutdown ();
        return;
      }
      rd[rd_count].flags = GNUNET_GNSRECORD_RF_RELATIVE_EXPIRATION;
      rd[rd_count].expiration_time = ttl.rel_value_us;
      next = strchr (token, ' ');
      if (NULL == next)
      {
        fprintf (stderr, "Error, last token: %s\n", token);
        ret = 1;
        GNUNET_SCHEDULER_shutdown ();
        break;
      }
      next[0] = '\0';
      next++;
      GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "class is: %s\n", token);
      while (*next == ' ')
        next++;
      token = next;
      next = strchr (token, ' ');
      if (NULL == next)
      {
        fprintf (stderr, "Error\n");
        break;
      }
      next[0] = '\0';
      next++;
      GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "type is: %s\n", token);
      type = GNUNET_GNSRECORD_typename_to_number (token);
      rd[rd_count].record_type = type;
      while (*next == ' ')
        next++;
      token = next;
    }
    for (int i = 0; i < strlen (token); i++)
    {
      if (token[i] == '"')
        quoted = ! quoted;
      if ((token[i] == '(') && ! quoted)
        bracket_unclosed++;
      if ((token[i] == ')') && ! quoted)
        bracket_unclosed--;
    }
    memcpy (payload_pos, token, strlen (token));
    payload_pos += strlen (token);
    if (bracket_unclosed > 0)
    {
      *payload_pos = ' ';
      payload_pos++;
      continue;
    }
    *payload_pos = '\0';
    GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "data is: %s\n\n", payload);
    if (GNUNET_OK !=
        GNUNET_GNSRECORD_string_to_value (type, payload,
                                          &data,
                                          &data_size))
    {
      fprintf (stderr,
               _ ("Data `%s' invalid\n"),
               payload);
      ret = 1;
      GNUNET_SCHEDULER_shutdown ();
      return;
    }
    rd[rd_count].data = data;
    rd[rd_count].data_size = data_size;
    if (ZS_NAME_CHANGED == state)
      break;
    rd_count++;
  }
  if (rd_count > 0)
  {
    ns_qe = GNUNET_NAMESTORE_record_set_store (ns,
                                               &zone_pkey,
                                               lastname,
                                               rd_count,
                                               rd,
                                               &add_continuation,
                                               NULL);
    published_sets++;
    published_records += rd_count;
    for (int i = 0; i < rd_count; i++)
    {
      data = (void*) rd[i].data;
      GNUNET_free (data);
    }
    if (ZS_NAME_CHANGED == state)
    {
      rd[0] = rd[rd_count]; // recover last rd parsed.
      rd_count = 1;
      strcpy (lastname, newname);
      state = ZS_ORIGIN_SET;
    }
    else
      rd_count = 0;
    return;
  }
  if (ZS_ORIGIN_CHANGED == state)
  {
    if (NULL != ego_name)
      GNUNET_free (ego_name);
    ego_name = GNUNET_strdup (origin);
    if (ego_name[strlen (ego_name) - 1] == '.')
      ego_name[strlen (ego_name) - 1] = '\0';
    GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
                "Changing origin to %s\n", ego_name);
    el = GNUNET_IDENTITY_ego_lookup (cfg, ego_name,
                                     &origin_lookup_cb, NULL);
    return;
  }
  printf ("Published %u records sets with total %u records\n",
          published_sets, published_records);
  GNUNET_SCHEDULER_shutdown ();
}

References _, add_continuation(), cfg, data, GNUNET_GNSRECORD_Data::data, data_size, GNUNET_GNSRECORD_Data::data_size, ego_name, el, GNUNET_GNSRECORD_Data::expiration_time, GNUNET_GNSRECORD_Data::flags, GNUNET_DNSPARSER_MAX_LABEL_LENGTH, GNUNET_ERROR_TYPE_DEBUG, GNUNET_free, GNUNET_GNSRECORD_RF_RELATIVE_EXPIRATION, GNUNET_GNSRECORD_string_to_value(), GNUNET_GNSRECORD_typename_to_number(), GNUNET_IDENTITY_ego_lookup(), GNUNET_log, GNUNET_NAMESTORE_record_set_store(), GNUNET_OK, GNUNET_SCHEDULER_shutdown(), GNUNET_strdup, GNUNET_SYSERR, MAX_RECORDS_PER_NAME, MAX_ZONEFILE_LINE_LEN, MAX_ZONEFILE_RECORD_DATA_LEN, GNUNET_SCHEDULER_Task::next, next_token(), ns, ns_qe, origin, origin_lookup_cb(), parse_origin(), parse_task, parse_ttl(), payload, published_records, published_sets, rd, rd_count, GNUNET_GNSRECORD_Data::record_type, GNUNET_TIME_Relative::rel_value_us, res, ret, state, trim(), ttl, type, zone_pkey, ZS_NAME_CHANGED, ZS_ORIGIN_CHANGED, ZS_ORIGIN_SET, and ZS_READY.

Referenced by add_continuation(), identity_cb(), origin_create_cb(), origin_lookup_cb(), and run().

Here is the call graph for this function:

Here is the caller graph for this function:

trim()

static char * trim ( char *  line )

static

Definition at line 190 of file gnunet-namestore-zonefile.c.

{
  char *ltrimmed = line;
  int ltrimmed_len;
  int quoted = 0;
 
  // Trim all whitespace to the left
  while (*ltrimmed == ' ')
    ltrimmed++;
  ltrimmed_len = strlen (ltrimmed);
  // Find the first occurrence of an unqoted ';', which is our comment
  for (int i = 0; i < ltrimmed_len; i++)
  {
    if (ltrimmed[i] == '"')
      quoted = ! quoted;
    if ((ltrimmed[i] != ';') || quoted)
      continue;
    ltrimmed[i] = '\0';
  }
  ltrimmed_len = strlen (ltrimmed);
  // Remove trailing whitespace
  for (int i = ltrimmed_len; i > 0; i--)
  {
    if (ltrimmed[i - 1] != ' ')
      break;
    ltrimmed[i - 1] = '\0';
  }
  ltrimmed_len = strlen (ltrimmed);
  if (ltrimmed[ltrimmed_len - 1] == '\n')
    ltrimmed[ltrimmed_len - 1] = ' ';
  return ltrimmed;
}

References line.

Referenced by parse().

Here is the caller graph for this function:

next_token()

static char * next_token ( char *  token )

static

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

{
  char *next = token;
  while (*next == ' ')
    next++;
  return next;
}

References GNUNET_SCHEDULER_Task::next.

Referenced by parse().

Here is the caller graph for this function:

parse_ttl()

static int parse_ttl ( char *  token, struct GNUNET_TIME_Relative *  pttl  )

static

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

{
  char *next;
  unsigned int ttl_tmp;
 
  next = strchr (token, ';');
  if (NULL != next)
    next[0] = '\0';
  next = strchr (token, ' ');
  if (NULL != next)
    next[0] = '\0';
  if (1 != sscanf (token, "%u", &ttl_tmp))
  {
    fprintf (stderr, "Unable to parse TTL `%s'\n", token);
    return GNUNET_SYSERR;
  }
  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "TTL is: %u\n", ttl_tmp);
  pttl->rel_value_us = ttl_tmp * 1000 * 1000;
  return GNUNET_OK;
}

References GNUNET_ERROR_TYPE_DEBUG, GNUNET_log, GNUNET_OK, GNUNET_SYSERR, GNUNET_SCHEDULER_Task::next, and GNUNET_TIME_Relative::rel_value_us.

Referenced by parse().

Here is the caller graph for this function:

parse_origin()

static int parse_origin ( char *  token, char *  porigin  )

static

Definition at line 258 of file gnunet-namestore-zonefile.c.

{
  char *next;
  next = strchr (token, ';');
  if (NULL != next)
    next[0] = '\0';
  next = strchr (token, ' ');
  if (NULL != next)
    next[0] = '\0';
  strcpy (porigin, token);
  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Origin is: %s\n", porigin);
  return GNUNET_OK;
}

References GNUNET_ERROR_TYPE_DEBUG, GNUNET_log, GNUNET_OK, and GNUNET_SCHEDULER_Task::next.

Referenced by parse().

Here is the caller graph for this function:

origin_create_cb()

static void origin_create_cb ( void *  cls, const struct GNUNET_CRYPTO_PrivateKey *  pk, enum GNUNET_ErrorCode  ec  )

static

Definition at line 274 of file gnunet-namestore-zonefile.c.

{
  id_op = NULL;
  if (GNUNET_EC_NONE != ec)
  {
    fprintf (stderr, "Error: %s\n", GNUNET_ErrorCode_get_hint (ec));
    ret = 1;
    GNUNET_SCHEDULER_shutdown ();
    return;
  }
  state = ZS_ORIGIN_SET;
  zone_pkey = *pk;
  parse_task = GNUNET_SCHEDULER_add_now (&parse, NULL);
}

References GNUNET_EC_NONE, GNUNET_ErrorCode_get_hint(), GNUNET_SCHEDULER_add_now(), GNUNET_SCHEDULER_shutdown(), id_op, parse(), parse_task, pk, ret, state, zone_pkey, and ZS_ORIGIN_SET.

Referenced by origin_lookup_cb().

Here is the call graph for this function:

Here is the caller graph for this function:

origin_lookup_cb()

static void origin_lookup_cb ( void *  cls, struct GNUNET_IDENTITY_Ego *  ego  )

static

Definition at line 292 of file gnunet-namestore-zonefile.c.

{
 
  el = NULL;
 
  if (NULL == ego)
  {
    GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
                "$ORIGIN %s does not exist, creating...\n", ego_name);
    id_op = GNUNET_IDENTITY_create (id, ego_name, NULL,
                                    GNUNET_PUBLIC_KEY_TYPE_ECDSA, // FIXME make configurable
                                    origin_create_cb,
                                    NULL);
    return;
  }
  state = ZS_ORIGIN_SET;
  zone_pkey = *GNUNET_IDENTITY_ego_get_private_key (ego);
  parse_task = GNUNET_SCHEDULER_add_now (&parse, NULL);
}

References ego_name, el, GNUNET_ERROR_TYPE_DEBUG, GNUNET_IDENTITY_create(), GNUNET_IDENTITY_ego_get_private_key(), GNUNET_log, GNUNET_PUBLIC_KEY_TYPE_ECDSA, GNUNET_SCHEDULER_add_now(), id_op, origin_create_cb(), parse(), parse_task, state, zone_pkey, and ZS_ORIGIN_SET.

Referenced by add_continuation(), and parse().

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 314 of file gnunet-namestore-zonefile.c.

{
  ns_qe = NULL;
  if (GNUNET_EC_NONE != ec)
  {
    fprintf (stderr,
             _ ("Failed to store records...\n"));
    GNUNET_SCHEDULER_shutdown ();
    ret = -1;
  }
  if (ZS_ORIGIN_CHANGED == state)
  {
    if (NULL != ego_name)
      GNUNET_free (ego_name);
    ego_name = GNUNET_strdup (origin);
    if (ego_name[strlen (ego_name) - 1] == '.')
      ego_name[strlen (ego_name) - 1] = '\0';
    GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
                "Changing origin to %s\n", ego_name);
    el = GNUNET_IDENTITY_ego_lookup (cfg, ego_name,
                                     &origin_lookup_cb, NULL);
    return;
  }
  parse_task = GNUNET_SCHEDULER_add_now (&parse, NULL);
}

References _, cfg, ego_name, el, GNUNET_EC_NONE, GNUNET_ERROR_TYPE_DEBUG, GNUNET_free, GNUNET_IDENTITY_ego_lookup(), GNUNET_log, GNUNET_SCHEDULER_add_now(), GNUNET_SCHEDULER_shutdown(), GNUNET_strdup, ns_qe, origin, origin_lookup_cb(), parse(), parse_task, ret, state, and ZS_ORIGIN_CHANGED.

Referenced by parse().

Here is the call graph for this function:

Here is the caller graph for this function:

identity_cb()

static void identity_cb ( void *  cls, struct GNUNET_IDENTITY_Ego *  ego  )

static

Definition at line 641 of file gnunet-namestore-zonefile.c.

{
 
  el = NULL;
  if (NULL == ego)
  {
    if (NULL != ego_name)
    {
      fprintf (stderr,
               _ ("Ego `%s' not known to identity service\n"),
               ego_name);
 
    }
    GNUNET_SCHEDULER_shutdown ();
    ret = -1;
    return;
  }
  zone_pkey = *GNUNET_IDENTITY_ego_get_private_key (ego);
  sprintf (origin, "%s.", ego_name);
  state = ZS_ORIGIN_SET;
  parse_task = GNUNET_SCHEDULER_add_now (&parse, NULL);
}

References _, ego_name, el, GNUNET_IDENTITY_ego_get_private_key(), GNUNET_SCHEDULER_add_now(), GNUNET_SCHEDULER_shutdown(), origin, parse(), parse_task, ret, state, zone_pkey, and ZS_ORIGIN_SET.

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

Definition at line 666 of file gnunet-namestore-zonefile.c.

{
  cfg = _cfg;
  ns = GNUNET_NAMESTORE_connect (cfg);
  GNUNET_SCHEDULER_add_shutdown (&do_shutdown, (void *) cfg);
  if (NULL == ns)
  {
    fprintf (stderr,
             _ ("Failed to connect to NAMESTORE\n"));
    return;
  }
  id = GNUNET_IDENTITY_connect (cfg, NULL, NULL);
  if (NULL == id)
  {
    fprintf (stderr,
             _ ("Failed to connect to IDENTITY\n"));
    return;
  }
  if (NULL != ego_name)
    el = GNUNET_IDENTITY_ego_lookup (cfg, ego_name, &identity_cb, (void *) cfg);
  else
    parse_task = GNUNET_SCHEDULER_add_now (&parse, NULL);
  state = ZS_READY;
}

References _, cfg, do_shutdown, ego_name, el, GNUNET_IDENTITY_connect(), GNUNET_IDENTITY_ego_lookup(), GNUNET_NAMESTORE_connect(), GNUNET_SCHEDULER_add_now(), GNUNET_SCHEDULER_add_shutdown(), identity_cb(), ns, parse(), parse_task, state, and ZS_READY.

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-dbtool.

Parameters

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

Returns

0 ok, 1 on error

Definition at line 703 of file gnunet-namestore-zonefile.c.

{
  struct GNUNET_GETOPT_CommandLineOption options[] = {
    GNUNET_GETOPT_option_string ('z',
                                 "zone",
                                 "EGO",
                                 gettext_noop (
                                   "name of the ego controlling the zone"),
                                 &ego_name),
    GNUNET_GETOPT_OPTION_END
  };
  int lret;
 
  GNUNET_log_setup ("gnunet-namestore-dbtool", "WARNING", NULL);
  if (GNUNET_OK !=
      (lret = GNUNET_PROGRAM_run (GNUNET_OS_project_data_gnunet (),
                                  argc,
                                  argv,
                                  "gnunet-namestore-zonefile",
                                  _ (
                                    "GNUnet namestore database manipulation tool"),
                                  options,
                                  &run,
                                  NULL)))
  {
    return lret;
  }
  return ret;
}

References _, ego_name, gettext_noop, GNUNET_GETOPT_OPTION_END, GNUNET_GETOPT_option_string(), GNUNET_log_setup(), GNUNET_OK, GNUNET_OS_project_data_gnunet(), GNUNET_PROGRAM_run(), options, ret, and run().

Here is the call graph for this function:

Variable Documentation

rd

struct GNUNET_GNSRECORD_Data rd[50]

static

The record data under a single label.

Reused. Hard limit.

Definition at line 46 of file gnunet-namestore-zonefile.c.

Referenced by array_cleanup(), attr_iter_cb(), attr_store_task(), backward_resolution(), block_create2(), block_create_ecdsa(), block_create_eddsa(), block_decrypt_ecdsa(), block_decrypt_eddsa(), block_get_size_ecdsa(), block_get_size_eddsa(), bulk_tx_start(), cb_key_monitor(), check_pkey(), check_rd(), check_result(), check_result(), clean_blind_sign_priv(), clean_blind_sign_pub(), clean_blinded_sig(), clean_rsa_public_key(), clean_rsa_signature(), clean_string(), clean_unblinded_sig(), clean_varsize_blob(), collect_tickets_cb(), consistency_iter(), continue_store_activity(), cred_iter_cb(), del_monitor(), DID_resolve_gns_lookup_cb(), dispatch_job(), dispatch_job_monitor(), display_record(), display_record_iterator(), display_record_lookup(), display_record_monitor(), display_records_from_block(), dns_result_parser(), do_shutdown(), filter_tickets_cb(), forward_resolution(), get_existing_rd_exp(), get_existing_record(), get_existing_record(), get_records_and_call_iterator(), GNUNET_CONVERSATION_phone_get_record(), GNUNET_GNSRECORD_block_calculate_size(), GNUNET_GNSRECORD_block_create(), GNUNET_GNSRECORD_block_create2(), GNUNET_GNSRECORD_block_create_unsigned(), GNUNET_GNSRECORD_is_expired(), GNUNET_GNSRECORD_JSON_from_gnsrecord(), GNUNET_GNSRECORD_JSON_spec_gnsrecord(), GNUNET_GNSRECORD_normalize_record_set(), GNUNET_GNSRECORD_record_get_expiration_time(), GNUNET_GNSRECORD_records_get_size(), GNUNET_GNSRECORD_records_serialize(), GNUNET_NAMESTORE_record_set_store(), GNUNET_NAMESTORE_records_store(), handle_delegate_collection_cb(), handle_edit_record_set_response(), handle_gns2dns_result(), handle_gns_namecache_resolution_result(), handle_gns_resolution_result(), handle_gns_response(), handle_gns_response(), handle_gns_result(), handle_lookup_result(), handle_monitor_event(), handle_record(), handle_record_result(), handle_result(), handle_result(), handle_reverse_lookup(), handle_zone_to_name_it(), handle_zone_to_name_response(), lookup_authz_cb(), lookup_it(), lookup_nick_it(), lookup_redirect_uri_result(), monitor_iterate_cb(), namestore_flat_store_records(), namestore_list_iteration(), namestore_postgres_store_records(), namestore_sqlite_store_records(), ns_get_lookup_cb(), ns_lookup_cb(), ns_lookup_result_cb(), parse(), parse_record(), parse_result_call_iterator(), print_record(), process_lookup_result(), process_lookup_result(), process_parallel_lookup_result(), process_result(), process_result(), process_tickets(), purge_orphans_iterator(), purge_zone_iterator(), recursive_cname_resolution(), recursive_gns2dns_resolution(), recursive_pkey_resolution(), recursive_redirect_resolution(), reply_to_dns(), result_processor(), revoke_attrs_cb(), run(), run_edkey(), run_pkey(), run_with_zone_pkey(), rvk_move_attr_cb(), rvk_ticket_update(), send_lookup_response(), send_lookup_response_with_filter(), start_phone(), start_resolver_lookup(), store_record_set(), transmit_lookup_dns_result(), update_tickets(), vpn_allocation_cb(), zone_iterate_proc(), and zone_iterator().

ttl

struct GNUNET_TIME_Relative ttl

static

Current record $TTL to use.

Definition at line 51 of file gnunet-namestore-zonefile.c.

Referenced by GNUNET_GNSRECORD_check_pow(), GNUNET_GNSRECORD_pow_start(), GSF_pending_request_create_(), GSF_pending_request_get_message_(), merge_pr(), and parse().

origin

char origin[GNUNET_DNSPARSER_MAX_NAME_LENGTH]

static

Current origin.

Definition at line 56 of file gnunet-namestore-zonefile.c.

Referenced by add_continuation(), copy_list_messages(), create_response(), handle_connection_create(), handle_core_message(), handle_p2p_estimate(), identity_cb(), and parse().

rd_count

unsigned int rd_count = 0

static

Number of records for currently parsed set.

Definition at line 61 of file gnunet-namestore-zonefile.c.

Referenced by attr_iter_cb(), backward_resolution(), block_create2(), block_create_ecdsa(), block_create_eddsa(), block_decrypt_ecdsa(), block_decrypt_eddsa(), block_get_size_ecdsa(), block_get_size_eddsa(), cb_key_monitor(), check_rd(), check_result(), check_result(), collect_tickets_cb(), consistency_iter(), continue_store_activity(), cred_iter_cb(), del_monitor(), DID_create_namestore_lookup_cb(), DID_resolve_gns_lookup_cb(), dispatch_job(), dispatch_job_monitor(), dns_result_parser(), do_shutdown(), filter_tickets_cb(), forward_resolution(), get_existing_rd_exp(), get_existing_record(), get_existing_record(), GNUNET_GNSRECORD_block_calculate_size(), GNUNET_GNSRECORD_block_create(), GNUNET_GNSRECORD_block_create2(), GNUNET_GNSRECORD_block_create_unsigned(), GNUNET_GNSRECORD_JSON_from_gnsrecord(), GNUNET_GNSRECORD_JSON_spec_gnsrecord(), GNUNET_GNSRECORD_normalize_record_set(), GNUNET_GNSRECORD_record_get_expiration_time(), GNUNET_GNSRECORD_records_deserialize(), GNUNET_GNSRECORD_records_deserialize_get_size(), GNUNET_GNSRECORD_records_get_size(), GNUNET_GNSRECORD_records_serialize(), GNUNET_NAMESTORE_record_set_store(), GNUNET_NAMESTORE_records_store(), handle_delegate_collection_cb(), handle_edit_record_set_response(), handle_gns2dns_result(), handle_gns_namecache_resolution_result(), handle_gns_resolution_result(), handle_gns_response(), handle_gns_response(), handle_gns_result(), handle_lookup_result(), handle_monitor_event(), handle_record(), handle_record_result(), handle_result(), handle_result(), handle_reverse_lookup(), handle_zone_to_name_it(), handle_zone_to_name_response(), lookup_authz_cb(), lookup_it(), lookup_nick_it(), lookup_redirect_uri_result(), monitor_iterate_cb(), namestore_flat_store_records(), namestore_postgres_store_records(), namestore_sqlite_store_records(), ns_lookup_cb(), ns_lookup_result_cb(), parse(), process_command_stdin(), process_lookup_result(), process_lookup_result(), process_parallel_lookup_result(), process_result(), process_result(), process_tickets(), recursive_gns2dns_resolution(), reply_to_dns(), result_processor(), revoke_attrs_cb(), run_edkey(), run_pkey(), run_with_zone_pkey(), rvk_move_attr_cb(), rvk_ticket_update(), send_lookup_response(), send_lookup_response_with_filter(), store_record_set(), update_tickets(), vpn_allocation_cb(), and zone_iterate_proc().

ret

int ret = 0

static

Return code.

Definition at line 66 of file gnunet-namestore-zonefile.c.

Referenced by add_continuation(), identity_cb(), main(), origin_create_cb(), and parse().

ego_name

char* ego_name = NULL

static

Name of the ego.

Definition at line 71 of file gnunet-namestore-zonefile.c.

Referenced by add_continuation(), do_shutdown(), identity_cb(), main(), origin_lookup_cb(), parse(), and run().

res

char* res

static

Currently read line or NULL on EOF.

Definition at line 76 of file gnunet-namestore-zonefile.c.

Referenced by add_dns_result(), add_services(), block_create2(), client_disconnect_cb(), decode_and_send(), decode_and_send(), delete_old_block(), extract_abs_time(), extract_blind_sign_priv(), extract_blind_sign_pub(), extract_blinded_sig(), extract_bool(), extract_filename(), extract_fixed_blob(), extract_int64(), extract_rel_time(), extract_rsa_public_key(), extract_rsa_signature(), extract_string(), extract_timestamp(), extract_uint16(), extract_uint32(), extract_uint64(), extract_unblinded_sig(), extract_varsize_blob(), file_hash_finish(), file_hash_task(), get_nick_record(), get_server_addresses(), get_server_addresses(), get_url_parameter_copy(), GNUNET_buffer_reap(), GNUNET_buffer_reap_str(), GNUNET_buffer_write_vfstr(), GNUNET_CONFIGURATION_get_data(), GNUNET_CONTAINER_bloomfilter_load(), GNUNET_CONTAINER_bloomfilter_test(), GNUNET_CRYPTO_ecc_dlog(), GNUNET_CRYPTO_ecdsa_sign_derived(), GNUNET_CRYPTO_eddsa_sign_(), GNUNET_CRYPTO_eddsa_sign_raw(), GNUNET_CRYPTO_eddsa_verify_(), GNUNET_CRYPTO_edx25519_verify_(), GNUNET_CRYPTO_hash_context_finish(), GNUNET_DISK_directory_create_for_file(), GNUNET_GNSRECORD_block_calculate_size(), GNUNET_GNSRECORD_block_create(), GNUNET_GNSRECORD_block_decrypt(), GNUNET_GNSRECORD_block_sign(), GNUNET_GNSRECORD_block_verify(), GNUNET_hton_double(), GNUNET_NT_scanner_get_type(), GNUNET_ntoh_double(), GNUNET_PQ_exec_prepared(), GNUNET_PQ_query_param_absolute_time(), GNUNET_PQ_query_param_blind_sign_priv(), GNUNET_PQ_query_param_blind_sign_pub(), GNUNET_PQ_query_param_blinded_sig(), GNUNET_PQ_query_param_fixed_size(), GNUNET_PQ_query_param_int16(), GNUNET_PQ_query_param_int64(), GNUNET_PQ_query_param_null(), GNUNET_PQ_query_param_relative_time(), GNUNET_PQ_query_param_rsa_public_key(), GNUNET_PQ_query_param_rsa_signature(), GNUNET_PQ_query_param_uint16(), GNUNET_PQ_query_param_uint32(), GNUNET_PQ_query_param_uint64(), GNUNET_PQ_query_param_unblinded_sig(), GNUNET_PQ_reconnect(), GNUNET_PQ_result_spec_absolute_time(), GNUNET_PQ_result_spec_absolute_time_nbo(), GNUNET_PQ_result_spec_array_abs_time(), GNUNET_PQ_result_spec_array_bool(), GNUNET_PQ_result_spec_array_fixed_size(), GNUNET_PQ_result_spec_array_rel_time(), GNUNET_PQ_result_spec_array_string(), GNUNET_PQ_result_spec_array_timestamp(), GNUNET_PQ_result_spec_array_uint16(), GNUNET_PQ_result_spec_array_uint32(), GNUNET_PQ_result_spec_array_uint64(), GNUNET_PQ_result_spec_array_variable_size(), GNUNET_PQ_result_spec_blind_sign_priv(), GNUNET_PQ_result_spec_blind_sign_pub(), GNUNET_PQ_result_spec_blinded_sig(), GNUNET_PQ_result_spec_bool(), GNUNET_PQ_result_spec_fixed_size(), GNUNET_PQ_result_spec_int64(), GNUNET_PQ_result_spec_relative_time(), GNUNET_PQ_result_spec_rsa_public_key(), GNUNET_PQ_result_spec_rsa_signature(), GNUNET_PQ_result_spec_string(), GNUNET_PQ_result_spec_timestamp(), GNUNET_PQ_result_spec_timestamp_nbo(), GNUNET_PQ_result_spec_uint16(), GNUNET_PQ_result_spec_uint32(), GNUNET_PQ_result_spec_uint64(), GNUNET_PQ_result_spec_unblinded_sig(), GNUNET_PQ_result_spec_variable_size(), GNUNET_SECRETSHARING_plaintext_generate_i(), GNUNET_STRINGS_string_to_data_alloc(), GNUNET_xstrdup_(), GNUNET_xstrndup_(), handle_arm_result(), handle_auto_result(), handle_block_cache(), handle_block_cache_response(), handle_edit_record_set(), handle_edit_record_set_cancel(), handle_generic_response(), handle_gns_redirect_result(), handle_monitor_notify(), handle_query_message(), handle_record_lookup(), handle_record_store(), handle_success_response(), handle_zone_to_name_response(), hash_for_index_cb(), hash_for_index_val(), list_count(), lookup_nick_it(), main(), namecache_postgres_cache_block(), namecache_postgres_expire_blocks(), namecache_postgres_lookup_block(), namestore_postgres_clear_editor_hint(), namestore_postgres_edit_records(), namestore_postgres_iterate_records(), namestore_postgres_lookup_records(), namestore_postgres_store_records(), namestore_postgres_zone_to_name(), open_static_resource(), pabc_get_issuer(), parse(), parse_result_call_iterator(), parse_rsa_signature(), postgres_plugin_del(), postgres_plugin_get(), postgres_plugin_get_closest(), postgres_plugin_get_key(), postgres_plugin_get_replication(), postgres_plugin_get_zero_anonymity(), pq_notice_receiver_cb(), prepare_check_patch(), prepare_get_oid_by_name(), process_peer_string(), process_result(), query_param_array_generic(), REGEX_BLOCK_check(), return_agpl(), return_agpl(), route_control_message_without_fc(), run(), run(), send_client_reply(), send_lookup_response_with_filter(), send_remaining_elements(), send_remaining_elements(), sign_cb(), store_record_set(), try_old_ax_keys(), and verify_fair().

published_sets

unsigned int published_sets = 0

static

Statistics, how many published record sets.

Definition at line 81 of file gnunet-namestore-zonefile.c.

Referenced by parse().

published_records

unsigned int published_records = 0

static

Statistics, how many records published in aggregate.

Definition at line 86 of file gnunet-namestore-zonefile.c.

Referenced by parse().

el

struct GNUNET_IDENTITY_EgoLookup* el

static

Handle to identity lookup.

Definition at line 92 of file gnunet-namestore-zonefile.c.

Referenced by add_continuation(), do_shutdown(), execute_add(), execute_remove(), GNUNET_IDENTITY_ego_lookup(), GNUNET_IDENTITY_ego_lookup_by_suffix(), GNUNET_IDENTITY_ego_lookup_by_suffix_cancel(), GNUNET_IDENTITY_ego_lookup_cancel(), handle_client_set_add(), handle_client_set_add(), handle_identity_result_code(), handle_identity_result_code(), handle_identity_update(), handle_identity_update(), identity_cb(), mq_error_handler(), mq_error_handler(), origin_lookup_cb(), parse(), run(), send_full_element_iterator(), and send_full_element_iterator().

zone_pkey

struct GNUNET_CRYPTO_PrivateKey zone_pkey

static

Private key for the our zone.

Definition at line 97 of file gnunet-namestore-zonefile.c.

Referenced by identity_cb(), origin_create_cb(), origin_lookup_cb(), and parse().

ns_qe

struct GNUNET_NAMESTORE_QueueEntry* ns_qe

static

Queue entry for the 'add' operation.

Definition at line 102 of file gnunet-namestore-zonefile.c.

Referenced by add_continuation(), do_shutdown(), and parse().

ns

struct GNUNET_NAMESTORE_Handle* ns

static

Handle to the namestore.

Definition at line 107 of file gnunet-namestore-zonefile.c.

Referenced by do_shutdown(), parse(), and run().

id_op

struct GNUNET_IDENTITY_Operation* id_op

static

Origin create operations.

Definition at line 112 of file gnunet-namestore-zonefile.c.

Referenced by do_shutdown(), origin_create_cb(), and origin_lookup_cb().

id

struct GNUNET_IDENTITY_Handle* id

static

Handle to IDENTITY.

Definition at line 117 of file gnunet-namestore-zonefile.c.

Referenced by add_file(), close_service_room(), cred_iter_cb(), delete_attribute_cont(), delete_credential_cont(), do_read(), find_member_session_in_room(), get_handle_member_session(), GNUNET_CADET_get_path(), GNUNET_MQ_assoc_add(), GNUNET_PEER_change_rc(), GNUNET_PEER_decrement_rcs(), GNUNET_PEER_resolve(), GNUNET_PEER_resolve2(), GSF_plan_add_(), GSF_plan_notify_peer_disconnect_(), handle_arm_list_result(), handle_arm_result(), handle_ego_delete(), handle_ego_rename(), handle_identity_update(), handle_identity_update(), handle_member_id(), handle_search_result(), iter_cb(), load_member(), load_state(), mq_send_impl(), notify_srv_handle_message(), path_info_iterator(), process_attrs(), process_message_control(), process_sblock(), run(), run(), score_content(), send_srv_handle_message(), showcomp(), showlevel(), showpeer(), and write_cb().

cfg

const struct GNUNET_CONFIGURATION_Handle* cfg

static

Current configurataion.

Definition at line 122 of file gnunet-namestore-zonefile.c.

Referenced by add_continuation(), parse(), and run().

parse_task

struct GNUNET_SCHEDULER_Task* parse_task

static

Scheduled parse task.

Definition at line 127 of file gnunet-namestore-zonefile.c.

Referenced by add_continuation(), do_shutdown(), identity_cb(), origin_create_cb(), origin_lookup_cb(), parse(), and run().

state

int state

static

The current state of the parser.

Definition at line 132 of file gnunet-namestore-zonefile.c.

Referenced by add_continuation(), check_icmp_remote(), check_icmp_service(), check_tcp_data(), check_tcp_remote(), check_tcp_service(), check_udp_remote(), check_udp_service(), cleanup_s5r(), clear_message_state(), deserialize_unindex_file(), GCT_change_estate(), get_message_state_chain_hash(), get_message_state_merge_hash(), get_redirect_state(), handle_icmp_remote(), handle_icmp_service(), handle_tcp_data(), handle_tcp_remote(), handle_tcp_service(), handle_udp_remote(), handle_udp_service(), icmp_from_helper(), identity_cb(), init_message_state(), intersection_accept(), intersection_evaluate(), iterate_initial_edge(), iterate_reachables(), load_message_state(), make_up_icmp_service_payload(), make_up_icmpv4_payload(), make_up_icmpv6_payload(), mark_as_reachable(), monitor_cb(), origin_create_cb(), origin_lookup_cb(), parse(), parse_definitions(), print_info(), print_plugin_event_info(), process_peer_iteration_cb(), process_peer_monitoring_cb(), reachability_iterator(), resolve_peer_address(), run(), save_message_state(), setup_state_record(), state_remove_transition(), state_set_append(), tcp_from_helper(), udp_from_helper(), union_accept(), union_copy_state(), union_evaluate(), and update_message_state().