root/src/noit_check_log.c

/*
 * Copyright (c) 2007, OmniTI Computer Consulting, Inc.
 * All rights reserved.
 */

#include "noit_defines.h"

#include <uuid/uuid.h>
#include <netinet/in.h>

#include "noit_check.h"
#include "utils/noit_log.h"
#include "jlog/jlog.h"

/* Log format is tab delimited:
 *
 * CHECK:
 *  'C' TIMESTAMP UUID TARGET MODULE NAME
 *
 * STATUS:
 *  'S' TIMESTAMP UUID STATE AVAILABILITY DURATION STATUS_MESSAGE
 *
 * METRICS:
 *  'M' TIMESTAMP UUID NAME TYPE VALUE
 */

static noit_log_stream_t check_log = NULL;
static noit_log_stream_t status_log = NULL;
static noit_log_stream_t metrics_log = NULL;
#define SETUP_LOG(a) do { if(!a##_log) a##_log = noit_log_stream_find(#a); \
                          if(!a##_log) return; } while(0)
#define SECPART(a) ((unsigned long)(a)->tv_sec)
#define MSECPART(a) ((unsigned long)((a)->tv_usec / 1000))
void
noit_check_log_check(noit_check_t *check) {
  struct timeval __now;
  char uuid_str[37];
  SETUP_LOG(check);

  gettimeofday(&__now, NULL);
  uuid_unparse_lower(check->checkid, uuid_str);
  noitL(check_log, "C\t%lu.%03lu\t%s\t%s\t%s\t%s\n",
        SECPART(&__now), MSECPART(&__now), uuid_str,
        check->target, check->module, check->name);
}
void
noit_check_log_status(noit_check_t *check) {
  char uuid_str[37];
  stats_t *c;
  SETUP_LOG(status);

  uuid_unparse_lower(check->checkid, uuid_str);
  c = &check->stats.current;
  noitL(status_log, "S\t%lu.%03lu\t%s\t%c\t%c\t%d\t%s\n",
        SECPART(&c->whence), MSECPART(&c->whence), uuid_str,
        (char)c->state, (char)c->available, c->duration, c->status);
}
void
noit_check_log_metrics(noit_check_t *check) {
  char uuid_str[37];
  noit_hash_iter iter = NOIT_HASH_ITER_ZERO;
  const char *key;
  int klen;
  metric_t *m;
  stats_t *c;
  SETUP_LOG(metrics);

  uuid_unparse_lower(check->checkid, uuid_str);
  c = &check->stats.current;
  while(noit_hash_next(&c->metrics, &iter, &key, &klen, (void **)&m)) {
    if(!m->metric_value.s) { /* they are all null */
      noitL(metrics_log, "M\t%lu.%03lu\t%s\t%s\t%c\t[[null]]\n",
            SECPART(&c->whence), MSECPART(&c->whence), uuid_str,
            m->metric_name, m->metric_type);
    }
    else {
      switch(m->metric_type) {
        case METRIC_INT32:
          noitL(metrics_log, "M\t%lu.%03lu\t%s\t%s\t%c\t%d\n",
                SECPART(&c->whence), MSECPART(&c->whence), uuid_str,
                m->metric_name, m->metric_type, *(m->metric_value.i));
          break;
        case METRIC_UINT32:
          noitL(metrics_log, "M\t%lu.%03lu\t%s\t%s\t%c\t%u\n",
                SECPART(&c->whence), MSECPART(&c->whence), uuid_str,
                m->metric_name, m->metric_type, *(m->metric_value.I));
          break;
        case METRIC_INT64:
          noitL(metrics_log, "M\t%lu.%03lu\t%s\t%s\t%c\t%lld\n",
                SECPART(&c->whence), MSECPART(&c->whence), uuid_str,
                m->metric_name, m->metric_type, *(m->metric_value.l));
          break;
        case METRIC_UINT64:
          noitL(metrics_log, "M\t%lu.%03lu\t%s\t%s\t%c\t%llu\n",
                SECPART(&c->whence), MSECPART(&c->whence), uuid_str,
                m->metric_name, m->metric_type, *(m->metric_value.L));
          break;
        case METRIC_DOUBLE:
          noitL(metrics_log, "M\t%lu.%03lu\t%s\t%s\t%c\t%.12e\n",
                SECPART(&c->whence), MSECPART(&c->whence), uuid_str,
                m->metric_name, m->metric_type, *(m->metric_value.n));
          break;
        case METRIC_STRING:
          noitL(metrics_log, "M\t%lu.%03lu\t%s\t%s\t%c\t%s\n",
                SECPART(&c->whence), MSECPART(&c->whence), uuid_str,
                m->metric_name, m->metric_type, m->metric_value.s);
          break;
        default:
          noitL(noit_error, "Unknown metric type '%c' 0x%x\n",
                m->metric_type, m->metric_type);
      }
    }
  }
}