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