src/lwes_mondemand.c

   1 #include "lwes_mondemand.h"
   2 #include "opt.h"
   3 #include <string.h>
   4
   5 #ifdef HAVE_MONDEMAND
   6
   7 struct mondemand_client *client;
   8 #define mondemand_inc(x) mondemand_increment_key_by_val(client, #x, stats->x)
   9
  10 static void init()
  11 {
  12   if (client==NULL && arg_mondemand_host!=NULL && arg_mondemand_ip!=NULL)
  13     {
  14       struct mondemand_transport *transport = NULL;
  15       client = mondemand_client_create("lwes-journaller");
  16       mondemand_set_context(client,"host",arg_mondemand_host);
  17       transport = mondemand_transport_lwes_create(arg_mondemand_ip,arg_mondemand_port,NULL,0,0);
  18       if (transport)
  19         {
  20           mondemand_add_transport(client, transport);
  21         }
  22       else
  23         {
  24           LOG_WARN("Unable to create mondemand transport to connect to %s:%d",arg_mondemand_ip,arg_mondemand_port);
  25         }
  26     }
  27 }
  28
  29 void mondemand_stats (const struct stats* stats, time_t now)
  30 {
  31   init();
  32   if (client==NULL) return;
  33   mondemand_inc(loss);
  34   mondemand_inc(bytes_total);
  35   mondemand_inc(bytes_since_last_rotate);
  36   mondemand_inc(packets_total);
  37   mondemand_inc(packets_since_last_rotate);
  38   mondemand_inc(bytes_in_burst);
  39   mondemand_inc(packets_in_burst);
  40   mondemand_inc(hiq);
  41   mondemand_inc(hiq_start);
  42   mondemand_inc(hiq_last);
  43   mondemand_inc(hiq_since_last_rotate);
  44   mondemand_inc(bytes_in_burst_since_last_rotate);
  45   mondemand_inc(packets_in_burst_since_last_rotate);
  46   mondemand_inc(start_time);
  47   mondemand_inc(last_rotate);
  48   mondemand_increment_key_by_val(client, "rotate", now);
  49   mondemand_flush_stats(client);
  50 }
  51
  52 static int get_mondemand_level (log_level_t level)
  53 {
  54   switch (level)
  55     {
  56     case LOG_ERROR:
  57       return M_LOG_ERR;
  58     case LOG_WARNING:
  59       return M_LOG_WARNING;
  60     case LOG_INFO:
  61       return M_LOG_INFO;
  62     default:
  63       return M_LOG_DEBUG;
  64     }
  65 }
  66
  67 void mondemand_log_msg (log_level_t level, const char *fname, int lineno, const char *buf)
  68 {
  69   const int mondemand_level = get_mondemand_level(level);
  70   if (mondemand_level_is_enabled(client, mondemand_level))
  71   {
  72     mondemand_log_real(client, fname, lineno, level, MONDEMAND_NULL_TRACE_ID, "%s", buf);
  73   }
  74 }
  75
  76 #else /* HAVE_MONDEMAND */
  77
  78 void mondemand_stats (const struct stats* stats, time_t now)
  79 {
  80   (void)stats;
  81   (void)now;
  82 }
  83
  84 void mondemand_log_msg (log_level_t level, const char *fname, int lineno, const char *buf)
  85 {
  86   (void)level;
  87   (void)fname;
  88   (void)lineno;
  89   (void)buf;
  90 }
  91
  92 #endif /* HAVE_MONDEMAND */