common_logging.c

Go to the documentation of this file.

/*
     This file is part of GNUnet.
     Copyright (C) 2006-2013 GNUnet e.V.
 
     GNUnet is free software: you can redistribute it and/or modify it
     under the terms of the GNU Affero General Public License as published
     by the Free Software Foundation, either version 3 of the License,
     or (at your option) any later version.
 
     GNUnet is distributed in the hope that it will be useful, but
     WITHOUT ANY WARRANTY; without even the implied warranty of
     MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
     Affero General Public License for more details.
 
     You should have received a copy of the GNU Affero General Public License
     along with this program.  If not, see <http://www.gnu.org/licenses/>.
 
     SPDX-License-Identifier: AGPL3.0-or-later
 */
 
#include "platform.h"
#include "gnunet_util_lib.h"
#include <regex.h>
 
 
#define BULK_DELAY_THRESHOLD (12 * 60 * 60 * 1000LL * 1000LL)
 
#define BULK_REPEAT_THRESHOLD 1000
 
#define BULK_TRACK_SIZE 256
 
#define COMP_TRACK_SIZE 32
 
#define DATE_STR_SIZE 64
 
#define ROTATION_KEEP 3
 
#ifndef PATH_MAX
#define PATH_MAX 4096
#endif
 
 
struct CustomLogger
{
  struct CustomLogger *next;
 
  GNUNET_Logger logger;
 
  void *logger_cls;
};
 
 
static GNUNET_THREAD_LOCAL struct GNUNET_AsyncScopeSave current_async_scope;
 
static GNUNET_THREAD_LOCAL char last_bulk[BULK_TRACK_SIZE] __nonstring;
 
static GNUNET_THREAD_LOCAL enum GNUNET_ErrorType last_bulk_kind;
 
static GNUNET_THREAD_LOCAL struct GNUNET_TIME_Absolute last_bulk_time;
 
static GNUNET_THREAD_LOCAL unsigned int last_bulk_repeat;
 
static GNUNET_THREAD_LOCAL char last_bulk_comp[COMP_TRACK_SIZE + 1];
 
static char *component;
 
static char *component_nopid;
 
static char *log_file_name;
 
static enum GNUNET_ErrorType min_level;
 
static struct CustomLogger *loggers;
 
static GNUNET_THREAD_LOCAL int skip_log = 0;
 
static FILE *GNUNET_stderr;
 
struct LogDef
{
  regex_t component_regex;
 
  regex_t file_regex;
 
  regex_t function_regex;
 
  int from_line;
 
  int to_line;
 
  int level;
 
  int force;
};
 
 
#if ! defined(GNUNET_CULL_LOGGING)
static struct LogDef *logdefs;
 
static int logdefs_size;
 
static int logdefs_len;
 
static int gnunet_log_parsed;
 
static int gnunet_force_log_parsed;
 
static int gnunet_force_log_present;
#endif
 
 
static enum GNUNET_ErrorType
get_type (const char *log)
{
  if (NULL == log)
    return GNUNET_ERROR_TYPE_UNSPECIFIED;
  if (0 == strcasecmp (log, "DEBUG"))
    return GNUNET_ERROR_TYPE_DEBUG;
  if (0 == strcasecmp (log, "INFO"))
    return GNUNET_ERROR_TYPE_INFO;
  if (0 == strcasecmp (log, "MESSAGE"))
    return GNUNET_ERROR_TYPE_MESSAGE;
  if (0 == strcasecmp (log, "WARNING"))
    return GNUNET_ERROR_TYPE_WARNING;
  if (0 == strcasecmp (log, "ERROR"))
    return GNUNET_ERROR_TYPE_ERROR;
  if (0 == strcasecmp (log, "NONE"))
    return GNUNET_ERROR_TYPE_NONE;
  return GNUNET_ERROR_TYPE_INVALID;
}
 
 
void
GNUNET_abort_ ()
{
  abort ();
}
 
 
#if ! defined(GNUNET_CULL_LOGGING)
static void
resize_logdefs (void)
{
  logdefs_size = (logdefs_size + 1) * 2;
  logdefs = GNUNET_realloc (logdefs, logdefs_size * sizeof(struct LogDef));
}
 
 
static void
log_rotate (const char *new_name)
{
  static char *rotation[ROTATION_KEEP];
  static unsigned int rotation_off;
  char *discard;
 
  if ('\0' == *new_name)
    return; /* not a real log file name */
  discard = rotation[rotation_off % ROTATION_KEEP];
  if (NULL != discard)
  {
    /* Note: can't log errors during logging (recursion!), so this
       operation MUST silently fail... */
    (void) unlink (discard);
    GNUNET_free (discard);
  }
  rotation[rotation_off % ROTATION_KEEP] = GNUNET_strdup (new_name);
  rotation_off++;
}
 
 
const char *
GNUNET_b2s (const void *buf,
            size_t buf_size)
{
  static GNUNET_THREAD_LOCAL char ret[9];
  struct GNUNET_HashCode hc;
  char *tmp;
 
  GNUNET_CRYPTO_hash (buf,
                      buf_size,
                      &hc);
  tmp = GNUNET_STRINGS_data_to_string_alloc (&hc,
                                             sizeof (hc));
  memcpy (ret,
          tmp,
          8);
  GNUNET_free (tmp);
  ret[8] = '\0';
  return ret;
}
 
 
static enum GNUNET_GenericReturnValue
setup_log_file (const struct tm *tm)
{
  static char last_fn[PATH_MAX + 1];
  char fn[PATH_MAX + 1];
  int altlog_fd;
  int dup_return;
  FILE *altlog;
  char *leftsquare;
 
  if (NULL == log_file_name)
    return GNUNET_SYSERR;
  if (0 == strftime (fn, sizeof(fn), log_file_name, tm))
    return GNUNET_SYSERR;
  leftsquare = strrchr (fn, '[');
  if ((NULL != leftsquare) && (']' == leftsquare[1]))
  {
    char *logfile_copy = GNUNET_strdup (fn);
 
    logfile_copy[leftsquare - fn] = '\0';
    logfile_copy[leftsquare - fn + 1] = '\0';
    snprintf (fn,
              PATH_MAX,
              "%s%d%s",
              logfile_copy,
              getpid (),
              &logfile_copy[leftsquare - fn + 2]);
    GNUNET_free (logfile_copy);
  }
  if (0 == strcmp (fn, last_fn))
    return GNUNET_OK; /* no change */
  log_rotate (last_fn);
  strcpy (last_fn, fn);
  if (GNUNET_SYSERR == GNUNET_DISK_directory_create_for_file (fn))
  {
    fprintf (stderr,
             "Failed to create directory for `%s': %s\n",
             fn,
             strerror (errno));
    return GNUNET_SYSERR;
  }
  altlog_fd = open (fn,
                    O_APPEND | O_WRONLY | O_CREAT,
                    S_IRUSR | S_IWUSR | S_IRGRP | S_IROTH);
 
  if (-1 != altlog_fd)
  {
    if (NULL != GNUNET_stderr)
      fclose (GNUNET_stderr);
    dup_return = dup2 (altlog_fd, 2);
    (void) close (altlog_fd);
    if (-1 != dup_return)
    {
      altlog = fdopen (2, "ab");
      if (NULL == altlog)
      {
        (void) close (2);
        altlog_fd = -1;
      }
    }
    else
    {
      altlog_fd = -1;
    }
  }
  if (-1 == altlog_fd)
  {
    GNUNET_log_strerror_file (GNUNET_ERROR_TYPE_ERROR, "open", fn);
    return GNUNET_SYSERR;
  }
  GNUNET_stderr = altlog;
  return GNUNET_OK;
}
 
 
static int
add_definition (const char *lcomponent,
                const char *file,
                const char *function,
                int from_line,
                int to_line,
                int level,
                int force)
{
  struct LogDef n;
  int r;
 
  if (logdefs_size == logdefs_len)
    resize_logdefs ();
  memset (&n, 0, sizeof(n));
  if (0 == strlen (lcomponent))
    lcomponent = (char *) ".*";
  r = regcomp (&n.component_regex, (const char *) lcomponent, REG_NOSUB);
  if (0 != r)
  {
    return r;
  }
  if (0 == strlen (file))
    file = (char *) ".*";
  r = regcomp (&n.file_regex, (const char *) file, REG_NOSUB);
  if (0 != r)
  {
    regfree (&n.component_regex);
    return r;
  }
  if ((NULL == function) || (0 == strlen (function)))
    function = (char *) ".*";
  r = regcomp (&n.function_regex, (const char *) function, REG_NOSUB);
  if (0 != r)
  {
    regfree (&n.component_regex);
    regfree (&n.file_regex);
    return r;
  }
  n.from_line = from_line;
  n.to_line = to_line;
  n.level = level;
  n.force = force;
  logdefs[logdefs_len++] = n;
  return 0;
}
 
 
int
GNUNET_get_log_call_status (int caller_level,
                            const char *comp,
                            const char *file,
                            const char *function,
                            int line)
{
  struct LogDef *ld;
  int i;
  int force_only;
 
  if (NULL == comp)
    /* Use default component */
    comp = component_nopid;
 
  /* We have no definitions to override globally configured log level,
   * so just use it right away.
   */
  if ((min_level >= 0) && (GNUNET_NO == gnunet_force_log_present))
    return caller_level <= min_level;
 
  /* Only look for forced definitions? */
  force_only = min_level >= 0;
  for (i = 0; i < logdefs_len; i++)
  {
    ld = &logdefs[i];
    if (((! force_only) || ld->force) &&
        ((line >= ld->from_line) && (line <= ld->to_line) ) &&
        (0 == regexec (&ld->component_regex, comp, 0, NULL, 0)) &&
        (0 == regexec (&ld->file_regex, file, 0, NULL, 0)) &&
        (0 == regexec (&ld->function_regex, function, 0, NULL, 0)))
    {
      /* We're finished */
      return caller_level <= ld->level;
    }
  }
  /* No matches - use global level, if defined */
  if (min_level >= 0)
    return caller_level <= min_level;
  /* All programs/services previously defaulted to WARNING.
   * Now *we* default to WARNING, and THEY default to NULL.
   * Or rather we default to MESSAGE, since things aren't always bad.
   */
  return caller_level <= GNUNET_ERROR_TYPE_MESSAGE;
}
 
 
static int
parse_definitions (const char *constname, int force)
{
  char *def;
  const char *tmp;
  char *comp = NULL;
  char *file = NULL;
  char *function = NULL;
  char *p;
  char *start;
  char *t;
  short state;
  int level;
  int from_line, to_line;
  int counter = 0;
  int keep_looking = 1;
 
  tmp = getenv (constname);
  if (NULL == tmp)
    return 0;
  def = GNUNET_strdup (tmp);
  from_line = 0;
  to_line = INT_MAX;
  for (p = def, state = 0, start = def; keep_looking; p++)
  {
    switch (p[0])
    {
    case ';':     /* found a field separator */
      p[0] = '\0';
      switch (state)
      {
      case 0:       /* within a component name */
        comp = start;
        break;
 
      case 1:       /* within a file name */
        file = start;
        break;
 
      case 2:       /* within a function name */
        /* after a file name there must be a function name */
        function = start;
        break;
 
      case 3:       /* within a from-to line range */
        if (strlen (start) > 0)
        {
          errno = 0;
          from_line = strtol (start, &t, 10);
          if ((0 != errno) || (from_line < 0))
          {
            GNUNET_free (def);
            return counter;
          }
          if ((t < p) && ('-' == t[0]))
          {
            errno = 0;
            start = t + 1;
            to_line = strtol (start, &t, 10);
            if ((0 != errno) || (to_line < 0) || (t != p))
            {
              GNUNET_free (def);
              return counter;
            }
          }
          else         /* one number means "match this line only" */
            to_line = from_line;
        }
        else       /* default to 0-max */
        {
          from_line = 0;
          to_line = INT_MAX;
        }
        break;
 
      default:
        fprintf (
          stderr,
          _ ("ERROR: Unable to parse log definition: Syntax error at `%s'.\n"),
          p);
        break;
      }
      start = p + 1;
      state++;
      break;
 
    case '\0':     /* found EOL */
      keep_looking = 0;
 
    /* fall through to '/' */
    case '/':     /* found a definition separator */
      switch (state)
      {
      case 4:       /* within a log level */
        p[0] = '\0';
        state = 0;
        level = get_type ((const char *) start);
        if ((GNUNET_ERROR_TYPE_INVALID == level) ||
            (GNUNET_ERROR_TYPE_UNSPECIFIED == level) ||
            (0 != add_definition (comp,
                                  file,
                                  function,
                                  from_line,
                                  to_line,
                                  level,
                                  force)))
        {
          GNUNET_free (def);
          return counter;
        }
        counter++;
        start = p + 1;
        break;
 
      default:
        fprintf (
          stderr,
          _ ("ERROR: Unable to parse log definition: Syntax error at `%s'.\n"),
          p);
        break;
      }
 
    default:
      break;
    }
  }
  GNUNET_free (def);
  return counter;
}
 
 
static void
parse_all_definitions ()
{
  if (GNUNET_NO == gnunet_force_log_parsed)
    gnunet_force_log_present =
      parse_definitions ("GNUNET_FORCE_LOG", 1) > 0 ? GNUNET_YES : GNUNET_NO;
  gnunet_force_log_parsed = GNUNET_YES;
 
  if (GNUNET_NO == gnunet_log_parsed)
    parse_definitions ("GNUNET_LOG", 0);
  gnunet_log_parsed = GNUNET_YES;
}
 
 
#endif
 
 
enum GNUNET_GenericReturnValue
GNUNET_log_setup (const char *comp,
                  const char *loglevel,
                  const char *logfile)
{
  const char *env_logfile;
 
  min_level = get_type (loglevel);
#if ! defined(GNUNET_CULL_LOGGING)
  parse_all_definitions ();
#endif
  GNUNET_free (component);
  GNUNET_asprintf (&component,
                   "%s-%d",
                   comp,
                   getpid ());
  GNUNET_free (component_nopid);
  component_nopid = GNUNET_strdup (comp);
 
  env_logfile = getenv ("GNUNET_FORCE_LOGFILE");
  if ((NULL != env_logfile) && (strlen (env_logfile) > 0))
    logfile = env_logfile;
  if (NULL == logfile)
    return GNUNET_OK;
  GNUNET_free (log_file_name);
  log_file_name = GNUNET_STRINGS_filename_expand (logfile);
  if (NULL == log_file_name)
    return GNUNET_SYSERR;
#if defined(GNUNET_CULL_LOGGING)
  /* log file option not allowed for wallet logic */
  GNUNET_assert (NULL == logfile);
  return GNUNET_OK;
#else
  {
    time_t t;
    const struct tm *tm;
 
    t = time (NULL);
    tm = gmtime (&t);
    return setup_log_file (tm);
  }
#endif
}
 
 
void
GNUNET_logger_add (GNUNET_Logger logger,
                   void *logger_cls)
{
  struct CustomLogger *entry;
 
  entry = GNUNET_new (struct CustomLogger);
  entry->logger = logger;
  entry->logger_cls = logger_cls;
  entry->next = loggers;
  loggers = entry;
}
 
 
void
GNUNET_logger_remove (GNUNET_Logger logger,
                      void *logger_cls)
{
  struct CustomLogger *pos;
  struct CustomLogger *prev;
 
  prev = NULL;
  pos = loggers;
  while ( (NULL != pos) &&
          ( (pos->logger != logger) ||
            (pos->logger_cls != logger_cls) ) )
  {
    prev = pos;
    pos = pos->next;
  }
  GNUNET_assert (NULL != pos);
  if (NULL == prev)
    loggers = pos->next;
  else
    prev->next = pos->next;
  GNUNET_free (pos);
}
 
 
static void
output_message (enum GNUNET_ErrorType kind,
                const char *comp,
                const char *datestr,
                const char *msg)
{
  static int have_journald = -1;
  struct CustomLogger *pos;
  const char *optional_newline = "\n";
 
  if ((strlen (msg) > 0) &&
      ('\n' == msg[strlen (msg) - 1]))
    optional_newline = "";
 
  if (-1 == have_journald)
  {
    /* systemd after version 231 sets this environment
       variable if we are logging to journald. In this
       case, skip outputting our component name, PID
       and timestamp as journald already adds those. (#8032) */
    if (NULL != getenv ("JOURNAL_STREAM"))
      have_journald = 1;
    else
      have_journald = 0;
  }
 
  /* only use the standard logger if no custom loggers are present */
  if ((NULL != GNUNET_stderr) && (NULL == loggers))
  {
    if (kind == GNUNET_ERROR_TYPE_MESSAGE)
    {
      /* The idea here is to produce "normal" output messages
       * for end users while still having the power of the
       * logging engine for developer needs. So ideally this
       * is what it should look like when CLI tools are used
       * interactively, yet the same message shouldn't look
       * this way if the output is going to logfiles or robots
       * instead.
       */
      fprintf (GNUNET_stderr, "* %s%s", msg, optional_newline);
    }
    else if (GNUNET_YES == current_async_scope.have_scope)
    {
      static GNUNET_THREAD_LOCAL char id_buf[27];
      char *end;
 
      /* We're logging, so skip_log must be currently 0. */
      skip_log = 100;
      end = GNUNET_STRINGS_data_to_string (&current_async_scope.scope_id,
                                           sizeof(struct GNUNET_AsyncScopeId),
                                           id_buf,
                                           sizeof(id_buf) - 1);
      GNUNET_assert (NULL != end);
      *end = '\0';
      skip_log = 0;
      if (have_journald)
        fprintf (GNUNET_stderr,
                 "(%s) %s %s%s",
                 id_buf,
                 GNUNET_error_type_to_string (kind),
                 msg,
                 optional_newline);
      else
        fprintf (GNUNET_stderr,
                 "%s %s(%s) %s %s%s",
                 datestr,
                 comp,
                 id_buf,
                 GNUNET_error_type_to_string (kind),
                 msg,
                 optional_newline);
    }
    else
    {
      if (have_journald)
        fprintf (GNUNET_stderr,
                 "%s %s%s",
                 GNUNET_error_type_to_string (kind),
                 msg,
                 optional_newline);
      else
        fprintf (GNUNET_stderr,
                 "%s %s %s %s%s",
                 datestr,
                 comp,
                 GNUNET_error_type_to_string (kind),
                 msg,
                 optional_newline);
    }
    fflush (GNUNET_stderr);
  }
  pos = loggers;
  while (NULL != pos)
  {
    pos->logger (pos->logger_cls,
                 kind,
                 comp,
                 datestr,
                 msg);
    pos = pos->next;
  }
}
 
 
static void
flush_bulk (const char *datestr)
{
  char msg[DATE_STR_SIZE + BULK_TRACK_SIZE + 256];
  int rev;
  char *last;
  const char *ft;
 
  if ((0 == last_bulk_time.abs_value_us) || (0 == last_bulk_repeat))
    return;
  rev = 0;
  last = memchr (last_bulk, '\0', BULK_TRACK_SIZE);
  if (last == NULL)
    last = &last_bulk[BULK_TRACK_SIZE - 1];
  else if (last != last_bulk)
    last--;
  if (last[0] == '\n')
  {
    rev = 1;
    last[0] = '\0';
  }
  ft =
    GNUNET_STRINGS_relative_time_to_string (GNUNET_TIME_absolute_get_duration (
                                              last_bulk_time),
                                            GNUNET_YES);
  snprintf (msg,
            sizeof(msg),
            _ ("Message `%.*s' repeated %u times in the last %s\n"),
            BULK_TRACK_SIZE,
            last_bulk,
            last_bulk_repeat,
            ft);
  if (rev == 1)
    last[0] = '\n';
  output_message (last_bulk_kind,
                  last_bulk_comp,
                  datestr,
                  msg);
  last_bulk_time = GNUNET_TIME_absolute_get ();
  last_bulk_repeat = 0;
}
 
 
void
GNUNET_log_skip (int n, int check_reset)
{
  int ok;
 
  if (0 == n)
  {
    ok = (0 == skip_log);
    skip_log = 0;
    if (check_reset)
      GNUNET_break (ok);
  }
  else
  {
    skip_log += n;
  }
}
 
 
int
GNUNET_get_log_skip ()
{
  return skip_log;
}
 
 
static void
mylog (enum GNUNET_ErrorType kind,
       const char *comp,
       const char *message,
       va_list va)
{
  char date[DATE_STR_SIZE];
  char date2[DATE_STR_SIZE];
  struct tm *tmptr;
  size_t size;
  va_list vacp;
  int eno = errno;
 
  va_copy (vacp, va);
  size = vsnprintf (NULL,
                    0,
                    message,
                    vacp) + 1;
  GNUNET_assert (0 != size);
  va_end (vacp);
  memset (date, 0, DATE_STR_SIZE);
  {
    char buf[size];
    long long offset;
 
    struct timeval timeofday;
 
    gettimeofday (&timeofday,
                  NULL);
    offset = GNUNET_TIME_get_offset ();
    if (offset > 0)
    {
      timeofday.tv_sec += offset / 1000LL / 1000LL;
      timeofday.tv_usec += (offset % 1000000LL) * 1000000LL;
      if (timeofday.tv_usec > 1000000LL)
      {
        timeofday.tv_usec -= 1000000LL;
        timeofday.tv_sec++;
      }
    }
    else
    {
      timeofday.tv_sec += offset / 1000LL / 1000LL;
      if (timeofday.tv_usec > -(offset % 1000000LL) * 1000000LL)
      {
        timeofday.tv_usec += (offset % 1000000LL) * 1000000LL;
      }
      else
      {
        timeofday.tv_usec += 1000000LL + (offset % 1000000LL) * 1000000LL;
        timeofday.tv_sec--;
      }
    }
    tmptr = localtime (&timeofday.tv_sec);
    if (NULL == tmptr)
    {
      strcpy (date, "localtime error");
    }
    else
    {
      /* RFC 3339 timestamp, with snprintf placeholder for microseconds */
      if (0 == strftime (date2,
                         DATE_STR_SIZE,
                         "%Y-%m-%dT%H:%M:%S.%%06u%z",
                         tmptr))
        abort ();
      /* Fill in microseconds */
      if (0 > snprintf (date,
                        sizeof(date),
                        date2,
                        timeofday.tv_usec))
        abort ();
    }
 
    vsnprintf (buf, size, message, va);
#if ! defined(GNUNET_CULL_LOGGING)
    if (NULL != tmptr)
      (void) setup_log_file (tmptr);
#endif
    if ((0 != (kind & GNUNET_ERROR_TYPE_BULK)) &&
        (0 != last_bulk_time.abs_value_us) &&
        (0 == strncmp (buf, last_bulk, sizeof(last_bulk))))
    {
      last_bulk_repeat++;
      if ((GNUNET_TIME_absolute_get_duration (last_bulk_time).rel_value_us >
           BULK_DELAY_THRESHOLD) ||
          (last_bulk_repeat > BULK_REPEAT_THRESHOLD))
        flush_bulk (date);
      return;
    }
    flush_bulk (date);
    GNUNET_strlcpy (last_bulk,
                    buf,
                    sizeof(last_bulk));
    last_bulk_repeat = 0;
    last_bulk_kind = kind;
    last_bulk_time = GNUNET_TIME_absolute_get ();
    GNUNET_strlcpy (last_bulk_comp,
                    comp,
                    sizeof(last_bulk_comp));
    output_message (kind,
                    comp,
                    date,
                    buf);
  }
  errno = eno;
}
 
 
void
GNUNET_log_nocheck (enum GNUNET_ErrorType kind,
                    const char *message,
                    ...)
{
  va_list va;
 
  va_start (va,
            message);
  mylog (kind,
         component,
         message, va);
  va_end (va);
}
 
 
void
GNUNET_log_from_nocheck (enum GNUNET_ErrorType kind,
                         const char *comp,
                         const char *message,
                         ...)
{
  va_list va;
  char comp_w_pid[128];
  int eno = errno;
 
  if (NULL == comp)
    comp = component_nopid;
 
  va_start (va, message);
  GNUNET_snprintf (comp_w_pid,
                   sizeof(comp_w_pid),
                   "%s-%d",
                   comp,
                   getpid ());
  mylog (kind,
         comp_w_pid,
         message,
         va);
  va_end (va);
  errno = eno;
}
 
 
const char *
GNUNET_error_type_to_string (enum GNUNET_ErrorType kind)
{
  if ((kind & GNUNET_ERROR_TYPE_ERROR) > 0)
    return _ ("ERROR");
  if ((kind & GNUNET_ERROR_TYPE_WARNING) > 0)
    return _ ("WARNING");
  if ((kind & GNUNET_ERROR_TYPE_MESSAGE) > 0)
    return _ ("MESSAGE");
  if ((kind & GNUNET_ERROR_TYPE_INFO) > 0)
    return _ ("INFO");
  if ((kind & GNUNET_ERROR_TYPE_DEBUG) > 0)
    return _ ("DEBUG");
  if ((kind & ~GNUNET_ERROR_TYPE_BULK) == 0)
    return _ ("NONE");
  return _ ("INVALID");
}
 
 
const char *
GNUNET_h2s (const struct GNUNET_HashCode *hc)
{
  static GNUNET_THREAD_LOCAL struct GNUNET_CRYPTO_HashAsciiEncoded ret;
 
  GNUNET_CRYPTO_hash_to_enc (hc,
                             &ret);
  ret.encoding[8] = '\0';
  return (const char *) ret.encoding;
}
 
 
const char *
GNUNET_h2s2 (const struct GNUNET_HashCode *hc)
{
  static GNUNET_THREAD_LOCAL struct GNUNET_CRYPTO_HashAsciiEncoded ret;
 
  GNUNET_CRYPTO_hash_to_enc (hc,
                             &ret);
  ret.encoding[8] = '\0';
  return (const char *) ret.encoding;
}
 
 
const char *
GNUNET_p2s (const struct GNUNET_CRYPTO_EddsaPublicKey *p)
{
  static GNUNET_THREAD_LOCAL struct GNUNET_CRYPTO_HashAsciiEncoded ret;
  struct GNUNET_HashCode hc;
 
  GNUNET_CRYPTO_hash (p,
                      sizeof(*p),
                      &hc);
  GNUNET_CRYPTO_hash_to_enc (&hc,
                             &ret);
  ret.encoding[6] = '\0';
  return (const char *) ret.encoding;
}
 
 
const char *
GNUNET_p2s2 (const struct GNUNET_CRYPTO_EddsaPublicKey *p)
{
  static GNUNET_THREAD_LOCAL struct GNUNET_CRYPTO_HashAsciiEncoded ret;
  struct GNUNET_HashCode hc;
 
  GNUNET_CRYPTO_hash (p,
                      sizeof(*p),
                      &hc);
  GNUNET_CRYPTO_hash_to_enc (&hc,
                             &ret);
  ret.encoding[6] = '\0';
  return (const char *) ret.encoding;
}
 
 
const char *
GNUNET_e2s (const struct GNUNET_CRYPTO_EcdhePublicKey *p)
{
  static GNUNET_THREAD_LOCAL struct GNUNET_CRYPTO_HashAsciiEncoded ret;
  struct GNUNET_HashCode hc;
 
  GNUNET_CRYPTO_hash (p,
                      sizeof(*p),
                      &hc);
  GNUNET_CRYPTO_hash_to_enc (&hc,
                             &ret);
  ret.encoding[6] = '\0';
  return (const char *) ret.encoding;
}
 
 
const char *
GNUNET_e2s2 (const struct GNUNET_CRYPTO_EcdhePublicKey *p)
{
  static GNUNET_THREAD_LOCAL struct GNUNET_CRYPTO_HashAsciiEncoded ret;
  struct GNUNET_HashCode hc;
 
  GNUNET_CRYPTO_hash (p,
                      sizeof(*p),
                      &hc);
  GNUNET_CRYPTO_hash_to_enc (&hc,
                             &ret);
  ret.encoding[6] = '\0';
  return (const char *) ret.encoding;
}
 
 
const char *
GNUNET_sh2s (const struct GNUNET_ShortHashCode *shc)
{
  static GNUNET_THREAD_LOCAL char buf[64];
 
  GNUNET_STRINGS_data_to_string (shc,
                                 sizeof(*shc),
                                 buf,
                                 sizeof(buf));
  buf[6] = '\0';
  return (const char *) buf;
}
 
 
const char *
GNUNET_uuid2s (const struct GNUNET_Uuid *uuid)
{
  static GNUNET_THREAD_LOCAL char buf[32];
 
  GNUNET_STRINGS_data_to_string (uuid, sizeof(*uuid), buf, sizeof(buf));
  buf[6] = '\0';
  return (const char *) buf;
}
 
 
const char *
GNUNET_h2s_full (const struct GNUNET_HashCode *hc)
{
  static GNUNET_THREAD_LOCAL struct GNUNET_CRYPTO_HashAsciiEncoded ret;
 
  GNUNET_CRYPTO_hash_to_enc (hc, &ret);
  ret.encoding[sizeof(ret) - 1] = '\0';
  return (const char *) ret.encoding;
}
 
 
const char *
GNUNET_i2s (const struct GNUNET_PeerIdentity *pid)
{
  static GNUNET_THREAD_LOCAL char buf[5];
  char *ret;
 
  if (NULL == pid)
    return "NULL";
  ret = GNUNET_CRYPTO_eddsa_public_key_to_string (&pid->public_key);
  GNUNET_strlcpy (buf, ret, sizeof(buf));
  GNUNET_free (ret);
  return buf;
}
 
 
const char *
GNUNET_i2s2 (const struct GNUNET_PeerIdentity *pid)
{
  static GNUNET_THREAD_LOCAL char buf[5];
  char *ret;
 
  if (NULL == pid)
    return "NULL";
  ret = GNUNET_CRYPTO_eddsa_public_key_to_string (&pid->public_key);
  GNUNET_strlcpy (buf, ret, sizeof(buf));
  GNUNET_free (ret);
  return buf;
}
 
 
const char *
GNUNET_i2s_full (const struct GNUNET_PeerIdentity *pid)
{
  static GNUNET_THREAD_LOCAL char buf[256];
  char *ret;
 
  ret = GNUNET_CRYPTO_eddsa_public_key_to_string (&pid->public_key);
  strcpy (buf, ret);
  GNUNET_free (ret);
  return buf;
}
 
 
const char *
GNUNET_a2s (const struct sockaddr *addr,
            socklen_t addrlen)
{
#define LEN                           \
        GNUNET_MAX ((INET6_ADDRSTRLEN + 8), \
                    (1 + sizeof(struct sockaddr_un) - sizeof(sa_family_t)))
  static GNUNET_THREAD_LOCAL char buf[LEN];
#undef LEN
  static GNUNET_THREAD_LOCAL char b2[6];
  const struct sockaddr_in *v4;
  const struct sockaddr_un *un;
  const struct sockaddr_in6 *v6;
  unsigned int off;
 
  if (addr == NULL)
    return _ ("unknown address");
  switch (addr->sa_family)
  {
  case AF_INET:
    if (addrlen != sizeof(struct sockaddr_in))
      return "<invalid v4 address>";
    v4 = (const struct sockaddr_in *) addr;
    inet_ntop (AF_INET, &v4->sin_addr, buf, INET_ADDRSTRLEN);
    if (0 == ntohs (v4->sin_port))
      return buf;
    strcat (buf, ":");
    GNUNET_snprintf (b2, sizeof(b2), "%u", ntohs (v4->sin_port));
    strcat (buf, b2);
    return buf;
 
  case AF_INET6:
    if (addrlen != sizeof(struct sockaddr_in6))
      return "<invalid v6 address>";
    v6 = (const struct sockaddr_in6 *) addr;
    buf[0] = '[';
    inet_ntop (AF_INET6, &v6->sin6_addr, &buf[1], INET6_ADDRSTRLEN);
    if (0 == ntohs (v6->sin6_port))
      return &buf[1];
    strcat (buf, "]:");
    GNUNET_snprintf (b2, sizeof(b2), "%u", ntohs (v6->sin6_port));
    strcat (buf, b2);
    return buf;
 
  case AF_UNIX:
    if (addrlen <= sizeof(sa_family_t))
      return "<unbound UNIX client>";
    un = (const struct sockaddr_un *) addr;
    off = 0;
    if ('\0' == un->sun_path[0])
      off++;
    memset (buf, 0, sizeof(buf));
    GNUNET_snprintf (buf,
                     sizeof(buf),
                     "%s%.*s",
                     (1 == off) ? "@" : "",
                     (int) (addrlen - sizeof(sa_family_t) - off),
                     &un->sun_path[off]);
    return buf;
 
  default:
    return _ ("invalid address");
  }
}
 
 
void
GNUNET_log_config_missing (enum GNUNET_ErrorType kind,
                           const char *section,
                           const char *option)
{
  GNUNET_log (kind,
              _ (
                "Configuration fails to specify option `%s' in section `%s'!\n")
              ,
              option,
              section);
}
 
 
void
GNUNET_log_config_invalid (enum GNUNET_ErrorType kind,
                           const char *section,
                           const char *option,
                           const char *required)
{
  GNUNET_log (
    kind,
    _ (
      "Configuration specifies invalid value for option `%s' in section `%s': %s\n"),
    option,
    section,
    required);
}
 
 
void
GNUNET_async_scope_enter (const struct GNUNET_AsyncScopeId *aid,
                          struct GNUNET_AsyncScopeSave *old_scope)
{
  *old_scope = current_async_scope;
  current_async_scope.have_scope = GNUNET_YES;
  current_async_scope.scope_id = *aid;
}
 
 
void
GNUNET_async_scope_restore (struct GNUNET_AsyncScopeSave *old_scope)
{
  current_async_scope = *old_scope;
}
 
 
void
GNUNET_async_scope_fresh (struct GNUNET_AsyncScopeId *aid_ret)
{
  GNUNET_CRYPTO_random_block (GNUNET_CRYPTO_QUALITY_WEAK,
                              aid_ret,
                              sizeof(struct GNUNET_AsyncScopeId));
}
 
 
void
GNUNET_async_scope_get (struct GNUNET_AsyncScopeSave *scope_ret)
{
  *scope_ret = current_async_scope;
}
 
 
size_t
GNUNET_hex2b (const char *src,
              void *dst,
              size_t dstlen,
              int invert)
{
  const char *line = src;
  const char *data = line;
  uint8_t *buf = dst;
  int off;
  int read_byte;
  int data_len = 0;
 
  while ((data_len < dstlen) &&
         (sscanf (data, " %02x%n", &read_byte, &off) == 1))
  {
    if (invert)
      buf[dstlen - 1 - data_len++] = read_byte;
    else
      buf[data_len++] = read_byte;
    data += off;
  }
  return data_len;
}
 
 
void
GNUNET_print_bytes (const void *buf,
                    size_t buf_len,
                    int fold,
                    int in_be)
{
  int i;
 
  for (i = 0; i < buf_len; i++)
  {
    if (0 != i)
    {
      if ((0 != fold) && (i % fold == 0))
        printf ("\n");
    }
    if (in_be)
      printf ("%02x", ((unsigned char*) buf)[buf_len - 1 - i]);
    else
      printf ("%02x", ((unsigned char*) buf)[i]);
  }
  printf ("\n");
}
 
 
void
GNUNET_util_cl_init (void);
 
void __attribute__ ((constructor))
GNUNET_util_cl_init (void)
{
  GNUNET_stderr = stderr;
}
 
 
/* end of common_logging.c */