Syslog.cpp

Go to the documentation of this file.

/*

$Header$

*/

#include <ctype.h>

#include "Error.h"
#include "Config.h"

#include "Syslog.h"

// Public methods.

int Syslog::log(const Severity severity, const String &msg)
{
  char message[SYSLOG_LIMIT_MSG_SIZE_MAX];
  char timestamp[SYSLOG_LIMIT_TIMESTAMP_SIZE_MAX];
  time_t t = time(NULL);
  int res;

  strftime(timestamp, sizeof(timestamp), "%b %e %T", localtime(&t));

  snprintf(message, sizeof(message), "<%03u> %s %s %s[%u]: %s",
    _facility + severity, timestamp, _connection->localIp().c_str(), _tag.c_str(), getpid(), msg.c_str());

  if (FAILED(res = _connection->writeStr(String(message).replaceCtrlChars())))
    return ERROR_BACKTRACE(res);

  return OK;
}

int Syslog::log(const Severity &severity, const String &timestamp, const String &fileName,
                const unsigned int lineNum, const String &functionName, const String &msg)
{
  char message[SYSLOG_LIMIT_MSG_SIZE_MAX];
  int res;


  snprintf(message, sizeof(message), "<%03u> %s %s %s[%u]: [file: %s, line: %u, function: %s] %s",
    _facility + severity, CSTRING(timestamp), CSTRING(_connection->localIp()), CSTRING(_tag), getpid(),
    CSTRING(fileName), lineNum, CSTRING(functionName), CSTRING(msg));

  if (FAILED(res = _connection->writeStr(String(message).replaceCtrlChars())))
    return ERROR_BACKTRACE(res);

  return OK;
}

Facility Syslog::facilityId(const String &facility)
{
  if (strcasecmp(facility.c_str(), "kernel") == 0)
    return FACILITY_KERNEL;
  if (strcasecmp(facility.c_str(), "user") == 0)
    return FACILITY_USER;
  if (strcasecmp(facility.c_str(), "mail") == 0)
    return FACILITY_MAIL;
  if (strcasecmp(facility.c_str(), "daemon") == 0)
    return FACILITY_DAEMON;
  if (strcasecmp(facility.c_str(), "security") == 0)
    return FACILITY_SECURITY;
  if (strcasecmp(facility.c_str(), "syslog") == 0)
    return FACILITY_SYSLOG;
  if (strcasecmp(facility.c_str(), "printer") == 0)
    return FACILITY_PRINTER;
  if (strcasecmp(facility.c_str(), "news") == 0)
    return FACILITY_NEWS;
  if (strcasecmp(facility.c_str(), "uucp") == 0)
    return FACILITY_UUCP;
  if (strcasecmp(facility.c_str(), "clock") == 0)
    return FACILITY_CLOCK;
  if (strcasecmp(facility.c_str(), "security2") == 0)
    return FACILITY_SECURITY2;
  if (strcasecmp(facility.c_str(), "ftp") == 0)
    return FACILITY_FTP;
  if (strcasecmp(facility.c_str(), "ntp") == 0)
    return FACILITY_NTP;
  if (strcasecmp(facility.c_str(), "log_audit") == 0)
    return FACILITY_LOG_AUDIT;
  if (strcasecmp(facility.c_str(), "log_alert") == 0)
    return FACILITY_LOG_ALERT;
  if (strcasecmp(facility.c_str(), "clock2") == 0)
    return FACILITY_CLOCK2;
  if (strcasecmp(facility.c_str(), "local0") == 0)
    return FACILITY_LOCAL0;
  if (strcasecmp(facility.c_str(), "local1") == 0)
    return FACILITY_LOCAL1;
  if (strcasecmp(facility.c_str(), "local2") == 0)
    return FACILITY_LOCAL2;
  if (strcasecmp(facility.c_str(), "local3") == 0)
    return FACILITY_LOCAL3;
  if (strcasecmp(facility.c_str(), "local4") == 0)
    return FACILITY_LOCAL4;
  if (strcasecmp(facility.c_str(), "local5") == 0)
    return FACILITY_LOCAL5;
  if (strcasecmp(facility.c_str(), "local6") == 0)
    return FACILITY_LOCAL6;
  if (strcasecmp(facility.c_str(), "local7") == 0)
    return FACILITY_LOCAL7;

  return FACILITY_LOCAL5;
}

String Syslog::facilityName(const Facility facility)
{
  switch (facility) {
    case FACILITY_KERNEL:
      return "kernel";
      break;
    case FACILITY_USER:
      return "user";
      break;
    case FACILITY_MAIL:
      return "mail";
      break;
    case FACILITY_DAEMON:
      return "daemon";
      break;
    case FACILITY_SECURITY:
      return "security";
      break;
    case FACILITY_SYSLOG:
      return "syslog";
      break;
    case FACILITY_PRINTER:
      return "printer";
      break;
    case FACILITY_NEWS:
      return "news";
      break;
    case FACILITY_UUCP:
      return "uucp";
      break;
    case FACILITY_CLOCK:
      return "clock";
      break;
    case FACILITY_SECURITY2:
      return "security2";
      break;
    case FACILITY_FTP:
      return "ftp";
      break;
    case FACILITY_NTP:
      return "ntp";
      break;
    case FACILITY_LOG_AUDIT:
      return "log_audit";
      break;
    case FACILITY_LOG_ALERT:
      return "log_alert";
      break;
    case FACILITY_CLOCK2:
      return "clock2";
      break;
    case FACILITY_LOCAL0:
      return "local0";
      break;
    case FACILITY_LOCAL1:
      return "local1";
      break;
    case FACILITY_LOCAL2:
      return "local2";
      break;
    case FACILITY_LOCAL3:
      return "local3";
      break;
    case FACILITY_LOCAL4:
      return "local4";
      break;
    case FACILITY_LOCAL5:
      return "local5";
      break;
    case FACILITY_LOCAL6:
      return "local6";
      break;
    case FACILITY_LOCAL7:
      return "local7";
      break;
    default:
      return "local5";
      break;
  }
  return "local5";
}

String Syslog::severityName(const Severity severity)
{
  switch (severity) {
    case SEVERITY_EMERGENCY:
      return "Emergency";
      break;
    case SEVERITY_ALERT:
      return "Alert";
      break;
    case SEVERITY_CRITICAL:
      return "Critical";
      break;
    case SEVERITY_ERROR:
      return "Error";
      break;
    case SEVERITY_WARNING:
      return "Warning";
      break;
    case SEVERITY_NOTICE:
      return "Notice";
      break;
    case SEVERITY_INFO:
      return "Info";
      break;
    case SEVERITY_DEBUG:
      return "Debug";
      break;
    default:
      return "Unknown";
      break;
  }
  return "Unknown";
}

int Syslog::setTag(const String &newTag)
{
  _tag = newTag;
  return OK;
}

// Private methods.

Syslog::Syslog() : Object(), Singleton<Syslog>()
{
  BIND(tag);
  BIND(collector);
  BIND(facility);

  String collectorHost;
  int res;

  if (FAILED(res = REGISTRY_GET(Syslog, collector, collectorHost))) {
    failure(ERROR_BACKTRACE(res));
    return;
  }

  if (FAILED(res = REGISTRY_GET(Syslog, tag, _tag))) {
    failure(ERROR_BACKTRACE(res));
    return;
  }

  String facility;
  if (FAILED(res = REGISTRY_GET(Syslog, facility, facility))) {
    failure(ERROR_BACKTRACE(res));
    return;
  }
  _facility = facilityId(facility) << 3;

  if (!(_connection = new UdpConnection(CSTRING(collectorHost), SYSLOG_PORT))) {
    failure(ERROR(MSG_OBJECT_CANNOT_CREATE, "UdpConnection"));
    return;
  }
  if (FAILED(res = _connection->failureCode())) {
    failure(ERROR_BACKTRACE(res));
    return;
  }
  if (collectorHost == "255.255.255.255")
    if (FAILED(res = _connection->setBroadcast())) {
      failure(ERROR_BACKTRACE(res));
      return;
    }

  if (FAILED(res = CONNECT(tag(), set, this, Syslog, setTag))) {
    failure(ERROR_BACKTRACE(res));
    return;
  }

}

Syslog::~Syslog()
{
  if (_connection)
    delete _connection;
}

---