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. More...
#define	MAX_ZONEFILE_RECORD_DATA_LEN   2048
	FIXME: Soft limit this? More...

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. More...
static void	tx_end (void *cls, enum GNUNET_ErrorCode ec)
static void	parse (void *cls)
	Main function that will be run. More...
static char *	trim (char *line)
static char *	next_token (char *token)
static int	parse_ttl (char *token, struct GNUNET_TIME_Relative *ttl)
static int	parse_origin (char *token, char *origin)
static void	origin_create_cb (void *cls, const struct GNUNET_IDENTITY_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	tx_start (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. More...

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

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

Referenced by run().

Here is the call graph for this function:

Here is the caller graph for this function:

tx_end()

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

static

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

{
  ns_qe = NULL;
  if (GNUNET_EC_NONE != ec)
  {
    fprintf (stderr,
             _ ("Ego `%s' not known to identity service\n"),
             ego_name);
    GNUNET_SCHEDULER_shutdown ();
    ret = -1;
  }
  GNUNET_SCHEDULER_shutdown ();
}

References _, ego_name, GNUNET_EC_NONE, GNUNET_SCHEDULER_shutdown(), ns_qe, and ret.

Referenced by parse().

Here is the call graph for this function:

Here is the caller 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 368 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;
 
  parse_task = NULL;
  /* use filename provided as 1st argument (stdin by default) */
  int ln = 0;
  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_records_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);
  ns_qe = GNUNET_NAMESTORE_transaction_commit (ns,
                                               &tx_end,
                                               NULL);
}

References _, add_continuation(), buf, cfg, GNUNET_GNSRECORD_Data::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_records_store(), GNUNET_NAMESTORE_transaction_commit(), 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, tx_end(), type, zone_pkey, ZS_NAME_CHANGED, ZS_ORIGIN_CHANGED, ZS_ORIGIN_SET, and ZS_READY.

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

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 205 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 occurence 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 239 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 *  ttl  )

static

Definition at line 248 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);
  ttl->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, GNUNET_TIME_Relative::rel_value_us, and ttl.

Referenced by parse().

Here is the caller graph for this function:

parse_origin()

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

static

Definition at line 270 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 (origin, token);
  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Origin is: %s\n", origin);
  return GNUNET_OK;
}

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

Referenced by parse().

Here is the caller graph for this function:

origin_create_cb()

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

static

Definition at line 285 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 302 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_IDENTITY_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_IDENTITY_TYPE_ECDSA, GNUNET_log, 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 323 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:

tx_start()

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

static

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

{
  ns_qe = NULL;
  if (GNUNET_EC_NONE != ec)
  {
    fprintf (stderr,
             _ ("Ego `%s' not known to identity service\n"),
             ego_name);
    GNUNET_SCHEDULER_shutdown ();
    ret = -1;
    return;
  }
  parse_task = GNUNET_SCHEDULER_add_now (&parse, NULL);
}

References _, ego_name, GNUNET_EC_NONE, GNUNET_SCHEDULER_add_now(), GNUNET_SCHEDULER_shutdown(), ns_qe, parse(), parse_task, and ret.

Referenced by identity_cb().

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 667 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;
  ns_qe = GNUNET_NAMESTORE_transaction_begin (ns,
                                              &tx_start,
                                              NULL);
}

References _, ego_name, el, GNUNET_IDENTITY_ego_get_private_key(), GNUNET_NAMESTORE_transaction_begin(), GNUNET_SCHEDULER_shutdown(), ns, ns_qe, origin, ret, state, tx_start(), 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 694 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 731 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;
 
  if (GNUNET_OK != GNUNET_STRINGS_get_utf8_args (argc, argv, &argc, &argv))
    return 2;
 
  GNUNET_log_setup ("gnunet-namestore-dbtool", "WARNING", NULL);
  if (GNUNET_OK !=
      (lret = GNUNET_PROGRAM_run (argc,
                                  argv,
                                  "gnunet-namestore-zonefile",
                                  _ (
                                    "GNUnet namestore database manipulation tool"),
                                  options,
                                  &run,
                                  NULL)))
  {
    GNUNET_free_nz ((void *) argv);
    return lret;
  }
  GNUNET_free_nz ((void *) argv);
  return ret;
}

References _, ego_name, gettext_noop, GNUNET_free_nz, GNUNET_GETOPT_OPTION_END, GNUNET_GETOPT_option_string(), GNUNET_log_setup(), GNUNET_OK, GNUNET_PROGRAM_run(), GNUNET_STRINGS_get_utf8_args(), 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 1 of file gnunet-namestore-zonefile.c.

Referenced by attr_iter_cb(), attr_store_task(), backward_resolution(), block_create2(), block_create_ecdsa(), block_create_eddsa(), bulk_tx_start(), check_credential_iteration_start(), check_monitor_start(), check_pkey(), check_rd(), check_result(), check_zone_to_name(), clean_rsa_public_key(), clean_rsa_signature(), clean_string(), clean_varsize_blob(), collect_tickets_cb(), completed_cb(), consistency_iter(), continue_store_activity(), create_response(), del_monitor(), DID_resolve(), 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(), GNUNET_CONVERSATION_phone_get_record(), GNUNET_GNSRECORD_is_expired(), GNUNET_GNSRECORD_JSON_from_gnsrecord(), GNUNET_GNSRECORD_records_get_size(), GNUNET_GNSRECORD_records_serialize(), GNUNET_NAMESTORE_records_store(), GNUNET_NAMESTORE_records_store2(), handle_delegate_collection_cb(), handle_gns2dns_result(), handle_gns_namecache_resolution_result(), handle_gns_resolution_result(), handle_gns_response(), handle_gns_result(), handle_lookup_result(), handle_monitor_event(), handle_record(), handle_record_result(), handle_result(), handle_reverse_lookup(), handle_zone_to_name_response(), iterate_do_cb(), iterate_done_cb(), iterate_error_cb(), lookup_authz_cb(), lookup_it(), lookup_nick_it(), lookup_records(), lookup_redirect_uri_result(), namestore_flat_store_records(), namestore_list_iteration(), ns_get_lookup_cb(), ns_lookup_cb(), ns_lookup_result_cb(), parse(), parse_record(), print_record(), process_lookup_result(), process_parallel_lookup_result(), process_result(), process_tickets(), purge_orphans_iterator(), purge_zone_iterator(), recursive_cname_resolution(), recursive_gns2dns_resolution(), recursive_pkey_resolution(), recursive_redirect_resolution(), register_do_cb(), register_done_cb(), register_error_cb(), reply_to_dns(), result_processor(), revoke_attrs_cb(), run(), run_edkey(), run_pkey(), run_with_zone_pkey(), rvk_move_attr_cb(), rvk_ticket_update(), search_done_cb(), search_error_cb(), send_lookup_response(), send_lookup_response_with_filter(), start_phone(), start_resolver_lookup(), 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 1 of file gnunet-namestore-zonefile.c.

Referenced by GNUNET_REVOCATION_pow_start(), GSF_pending_request_create_(), GSF_pending_request_get_message_(), merge_pr(), parse(), and parse_ttl().

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(), parse(), and parse_origin().

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(), check_credential_iteration_start(), check_monitor_start(), check_rd(), check_result(), check_zone_to_name(), collect_tickets_cb(), consistency_iter(), continue_store_activity(), del_monitor(), DID_create(), DID_resolve(), dispatch_job(), dispatch_job_monitor(), dns_result_parser(), do_shutdown(), filter_tickets_cb(), forward_resolution(), get_existing_rd_exp(), get_existing_record(), GNUNET_GNSRECORD_JSON_from_gnsrecord(), GNUNET_GNSRECORD_records_deserialize(), GNUNET_GNSRECORD_records_deserialize_get_size(), GNUNET_GNSRECORD_records_get_size(), GNUNET_GNSRECORD_records_serialize(), GNUNET_NAMESTORE_records_store(), GNUNET_NAMESTORE_records_store2(), handle_delegate_collection_cb(), handle_gns2dns_result(), handle_gns_namecache_resolution_result(), handle_gns_resolution_result(), handle_gns_response(), handle_gns_result(), handle_lookup_result(), handle_monitor_event(), handle_record(), handle_record_result(), handle_result(), handle_reverse_lookup(), handle_zone_to_name_response(), lookup_authz_cb(), lookup_it(), lookup_nick_it(), lookup_redirect_uri_result(), namestore_flat_store_records(), ns_lookup_cb(), ns_lookup_result_cb(), parse(), process_lookup_result(), process_parallel_lookup_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(), 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(), parse(), tx_end(), and tx_start().

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(), run(), tx_end(), and tx_start().

res

char* res

static

Currently read line or NULL on EOF.

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

Referenced by parse().

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(), identity_cb(), origin_lookup_cb(), parse(), and run().

zone_pkey

struct GNUNET_IDENTITY_PrivateKey zone_pkey

static

Private key for the our zone.

Definition at line 92 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(), identity_cb(), parse(), tx_end(), and tx_start().

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(), identity_cb(), 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.

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(), origin_create_cb(), origin_lookup_cb(), parse(), run(), and tx_start().

state

int state

static

The current state of the parser.

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

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