Updated years in all README's.

[libucw.git] / ucw / log.c

diff --git a/ucw/log.c b/ucw/log.c
index 5c4a006982f863b760e9309d34deb51eaaa05e09..419c5e9fcca30ef741f625b8ee7bf769894ea25f 100644 (file)
--- a/ucw/log.c
+++ b/ucw/log.c
@@ -26,6 +26,8 @@ char *log_title;
 int log_pid;
 void (*log_die_hook)(void);
 
 int log_pid;
 void (*log_die_hook)(void);
 

+static void NONRET do_die(void);
+

 /*** The default log stream, which logs to stderr ***/
 
 static int default_log_handler(struct log_stream *ls UNUSED, struct log_msg *m)
 /*** The default log stream, which logs to stderr ***/
 
 static int default_log_handler(struct log_stream *ls UNUSED, struct log_msg *m)


@@ -40,6 +42,7 @@ struct log_stream log_stream_default = {
   .use_count = 1000000,
   .handler = default_log_handler,
   .levels = ~0U,
   .use_count = 1000000,
   .handler = default_log_handler,
   .levels = ~0U,

+  .types = ~0U,

   .msgfmt = LSFMT_DEFAULT,
   // an empty clist
   .substreams.head.next = (cnode *) &log_stream_default.substreams.head,
   .msgfmt = LSFMT_DEFAULT,
   // an empty clist
   .substreams.head.next = (cnode *) &log_stream_default.substreams.head,


@@ -69,6 +72,21 @@ log_stream_by_flags(uns flags)
   return log_streams.ptr[n];
 }
 
   return log_streams.ptr[n];
 }
 

+/*** Known message types ***/
+
+char **log_type_names;
+
+char *
+log_type_name(uns flags)
+{
+  uns type = LS_GET_TYPE(flags);
+
+  if (!log_type_names || !log_type_names[type])
+    return "default";
+  else
+    return log_type_names[type];
+}
+

 /*** Logging ***/
 
 void
 /*** Logging ***/
 
 void


@@ -82,21 +100,25 @@ vmsg(uns cat, const char *fmt, va_list args)
   char msgbuf[256];
   char *p;
   int len;
   char msgbuf[256];
   char *p;
   int len;

-  struct log_stream *ls = log_stream_by_flags(cat);
+  uns sighandler = cat & L_SIGHANDLER;
+  struct log_stream *ls;

   struct log_msg m = { .flags = cat };
 
   struct log_msg m = { .flags = cat };
 

-  /* Check the stream existence */
-  if (!ls)
+  /* Find the destination stream */
+  if (sighandler)
+    ls = &log_stream_default;
+  else if (!(ls = log_stream_by_flags(cat)))

     {
       msg((LS_CTRL_MASK&cat)|L_WARN, "No log_stream with number %d! Logging to the default log.", LS_GET_STRNUM(cat));
       ls = &log_stream_default;
     }
 
   /* Get the current time */
     {
       msg((LS_CTRL_MASK&cat)|L_WARN, "No log_stream with number %d! Logging to the default log.", LS_GET_STRNUM(cat));
       ls = &log_stream_default;
     }
 
   /* Get the current time */

-  if (!(cat & L_SIGHANDLER))
+  if (!sighandler)

     {
       /* CAVEAT: These calls are not safe in signal handlers. */
       gettimeofday(&tv, NULL);
     {
       /* CAVEAT: These calls are not safe in signal handlers. */
       gettimeofday(&tv, NULL);

+      m.tv = &tv;

       if (localtime_r(&tv.tv_sec, &tm))
        m.tm = &tm;
     }
       if (localtime_r(&tv.tv_sec, &tm))
        m.tm = &tm;
     }


@@ -119,7 +141,7 @@ vmsg(uns cat, const char *fmt, va_list args)
   va_copy(args2, args);
   len = vsnprintf(msgbuf, sizeof(msgbuf), fmt, args2);
   va_end(args2);
   va_copy(args2, args);
   len = vsnprintf(msgbuf, sizeof(msgbuf), fmt, args2);
   va_end(args2);

-  if (len < (int) sizeof(msgbuf))
+  if (len < (int) sizeof(msgbuf) || sighandler)

     m.raw_msg = msgbuf;
   else
     {
     m.raw_msg = msgbuf;
   else
     {


@@ -147,6 +169,35 @@ vmsg(uns cat, const char *fmt, va_list args)
     xfree(m.raw_msg);
 }
 
     xfree(m.raw_msg);
 }
 

+static void
+log_report_err(struct log_stream *ls, struct log_msg *m, int err)
+{
+  if (m->flags & L_LOGGER_ERR)
+    return;
+  if (ls->stream_flags & LSFLAG_ERR_REPORTED)
+    return;
+  ls->stream_flags |= LSFLAG_ERR_REPORTED;
+
+  struct log_msg errm = *m;
+  char errbuf[128];
+  char *name = (ls->name ? : "<unnamed>");
+
+  errm.flags = ((ls->stream_flags & LSFLAG_ERR_IS_FATAL) ? L_FATAL : L_ERROR);
+  errm.flags |= L_LOGGER_ERR | (m->flags & LS_CTRL_MASK);
+  errm.raw_msg = errbuf;
+  if (err == EDEADLK)
+    snprintf(errbuf, sizeof(errbuf), "Error logging to %s: Maximum nesting level of log streams exceeded", name);
+  else
+    {
+      errno = err;
+      snprintf(errbuf, sizeof(errbuf), "Error logging to %s: %m", name);
+    }
+  log_pass_msg(0, &log_stream_default, &errm);
+
+  if (ls->stream_flags & LSFLAG_ERR_IS_FATAL)
+    do_die();
+}
+

 /* Maximal depth of log_pass_msg recursion */
 #define LS_MAX_DEPTH 64
 
 /* Maximal depth of log_pass_msg recursion */
 #define LS_MAX_DEPTH 64
 


@@ -158,16 +209,14 @@ log_pass_msg(int depth, struct log_stream *ls, struct log_msg *m)
   /* Check recursion depth */
   if (depth > LS_MAX_DEPTH)
     {
   /* Check recursion depth */
   if (depth > LS_MAX_DEPTH)
     {

-      struct log_msg errm = *m;
-      errm.flags = L_ERROR | (m->flags & LS_CTRL_MASK);
-      errm.raw_msg = "Loop in the log_stream system detected.";
-      log_pass_msg(0, &log_stream_default, &errm);
+      log_report_err(ls, m, EDEADLK);
+      return 1;

     }
 
     }
 

-  /* Filter by level and hook function */
-  if (!((1 << LS_GET_LEVEL(m->flags)) & ls->levels))
-    return 0;
-  if (ls->filter && ls->filter(ls, m))
+  /* Filter by level, type and hook function */
+  if (!((1 << LS_GET_LEVEL(m->flags)) & ls->levels) ||
+      !((1 << LS_GET_TYPE(m->flags)) & ls->types) ||
+      ls->filter && ls->filter(ls, m))

     return 0;
 
   /* Pass the message to substreams */
     return 0;
 
   /* Pass the message to substreams */


@@ -179,16 +228,23 @@ log_pass_msg(int depth, struct log_stream *ls, struct log_msg *m)
   if (!ls->handler)
     return 0;
 
   if (!ls->handler)
     return 0;
 

+  /* Will print a message type? */
+  char *type = NULL;
+  if ((ls->msgfmt & LSFMT_TYPE) && LS_GET_TYPE(m->flags))
+    type = log_type_name(m->flags);
+

   /* Upper bound on message length */
   int len = strlen(m->raw_msg) + strlen(m->stime) + strlen(m->sutime) + 32;
   if (log_title)
     len += strlen(log_title);
   if (ls->name)
     len += strlen(ls->name);
   /* Upper bound on message length */
   int len = strlen(m->raw_msg) + strlen(m->stime) + strlen(m->sutime) + 32;
   if (log_title)
     len += strlen(log_title);
   if (ls->name)
     len += strlen(ls->name);

+  if (type)
+    len += strlen(type) + 3;

 
   /* Get a buffer and format the message */
   char *free_buf = NULL;
 
   /* Get a buffer and format the message */
   char *free_buf = NULL;

-  if (len <= 256)
+  if (len <= 256 || (m->flags & L_SIGHANDLER))

     m->m = alloca(len);
   else
     m->m = free_buf = xmalloc(len);
     m->m = alloca(len);
   else
     m->m = free_buf = xmalloc(len);


@@ -226,7 +282,7 @@ log_pass_msg(int depth, struct log_stream *ls, struct log_msg *m)
     }
   else
     {
     }
   else
     {

-      if (ls->msgfmt & LSFMT_PID)
+      if ((ls->msgfmt & LSFMT_PID) && log_pid)

        p += sprintf(p, "[%d] ", log_pid);
     }
 
        p += sprintf(p, "[%d] ", log_pid);
     }
 


@@ -239,6 +295,10 @@ log_pass_msg(int depth, struct log_stream *ls, struct log_msg *m)
        p += sprintf(p, "<?> ");
     }
 
        p += sprintf(p, "<?> ");
     }
 

+  /* Message type ( |type| + 3 chars ) */
+  if (type)
+    p += sprintf(p, "{%s} ", type);
+

   /* The message itself ( |m| + 1 chars ) */
     {
       const char *q = m->raw_msg;
   /* The message itself ( |m| + 1 chars ) */
     {
       const char *q = m->raw_msg;


@@ -247,7 +307,9 @@ log_pass_msg(int depth, struct log_stream *ls, struct log_msg *m)
       *p++ = '\n';
       *p = '\0';
       m->m_len = p - m->m;
       *p++ = '\n';
       *p = '\0';
       m->m_len = p - m->m;

-      ls->handler(ls, m);
+      int err = ls->handler(ls, m);
+      if (err)
+       log_report_err(ls, m, err);

     }
 
   if (free_buf)
     }
 
   if (free_buf)


@@ -267,6 +329,16 @@ msg(unsigned int cat, const char *fmt, ...)
   va_end(args);
 }
 
   va_end(args);
 }
 

+static void NONRET
+do_die(void)
+{
+#ifdef DEBUG_DIE_BY_ABORT
+  abort();
+#else
+  exit(1);
+#endif
+}
+

 void
 die(const char *fmt, ...)
 {
 void
 die(const char *fmt, ...)
 {


@@ -277,11 +349,7 @@ die(const char *fmt, ...)
   va_end(args);
   if (log_die_hook)
     log_die_hook();
   va_end(args);
   if (log_die_hook)
     log_die_hook();

-#ifdef DEBUG_DIE_BY_ABORT
-  abort();
-#else
-  exit(1);
-#endif
+  do_die();

 }
 
 void
 }
 
 void


@@ -332,10 +400,18 @@ log_fork(void)
 
 int main(void)
 {
 
 int main(void)
 {

+  int type = log_find_type("foo");
+  ASSERT(type < 0);
+  type = log_register_type("foo");
+

   struct log_stream *ls = log_new_syslog("local3", 0);
   struct log_stream *ls = log_new_syslog("local3", 0);

+#if 0
+  log_add_substream(ls, ls);
+  ls->stream_flags |= LSFLAG_ERR_IS_FATAL;
+#endif

   msg(L_INFO | ls->regnum, "Brum <%300s>", ":-)");
   msg(L_INFO | ls->regnum, "Brum <%300s>", ":-)");

-  log_set_format(log_default_stream(), ~0U, LSFMT_USEC);
-  msg(L_INFO, "Brum <%300s>", ":-)");
+  log_set_format(log_default_stream(), ~0U, LSFMT_USEC | LSFMT_TYPE);
+  msg(L_INFO | type, "Brum <%300s>", ":-)");

   log_close_all();
   return 0;
 }
   log_close_all();
   return 0;
 }