+++ /dev/null
-// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
-// vim: ts=8 sw=2 smarttab
-//
-#include <syslog.h>
-#include <boost/algorithm/string/predicate.hpp>
-
-#include "LogEntry.h"
-#include "Formatter.h"
-#include "include/stringify.h"
-
-// ----
-// LogEntryKey
-
-void LogEntryKey::encode(bufferlist& bl, uint64_t features) const
-{
- ::encode(who, bl, features);
- ::encode(stamp, bl);
- ::encode(seq, bl);
-}
-
-void LogEntryKey::decode(bufferlist::iterator& bl)
-{
- ::decode(who, bl);
- ::decode(stamp, bl);
- ::decode(seq, bl);
- _calc_hash();
-}
-
-void LogEntryKey::dump(Formatter *f) const
-{
- f->dump_stream("who") << who;
- f->dump_stream("stamp") << stamp;
- f->dump_unsigned("seq", seq);
-}
-
-void LogEntryKey::generate_test_instances(list<LogEntryKey*>& o)
-{
- o.push_back(new LogEntryKey);
- o.push_back(new LogEntryKey(entity_inst_t(), utime_t(1,2), 34));
-}
-
-clog_type LogEntry::str_to_level(std::string const &str)
-{
- std::string level_str = str;
- std::transform(level_str.begin(), level_str.end(), level_str.begin(),
- [](char c) {return std::tolower(c);});
-
- if (level_str == "debug") {
- return CLOG_DEBUG;
- } else if (level_str == "info") {
- return CLOG_INFO;
- } else if (level_str == "sec") {
- return CLOG_SEC;
- } else if (level_str == "warn" || level_str == "warning") {
- return CLOG_WARN;
- } else if (level_str == "error" || level_str == "err") {
- return CLOG_ERROR;
- } else {
- return CLOG_UNKNOWN;
- }
-}
-
-// ----
-
-int clog_type_to_syslog_level(clog_type t)
-{
- switch (t) {
- case CLOG_DEBUG:
- return LOG_DEBUG;
- case CLOG_INFO:
- return LOG_INFO;
- case CLOG_WARN:
- return LOG_WARNING;
- case CLOG_ERROR:
- return LOG_ERR;
- case CLOG_SEC:
- return LOG_CRIT;
- default:
- ceph_abort();
- return 0;
- }
-}
-
-clog_type string_to_clog_type(const string& s)
-{
- if (boost::iequals(s, "debug") ||
- boost::iequals(s, "dbg"))
- return CLOG_DEBUG;
- if (boost::iequals(s, "info") ||
- boost::iequals(s, "inf"))
- return CLOG_INFO;
- if (boost::iequals(s, "warning") ||
- boost::iequals(s, "warn") ||
- boost::iequals(s, "wrn"))
- return CLOG_WARN;
- if (boost::iequals(s, "error") ||
- boost::iequals(s, "err"))
- return CLOG_ERROR;
- if (boost::iequals(s, "security") ||
- boost::iequals(s, "sec"))
- return CLOG_SEC;
-
- return CLOG_UNKNOWN;
-}
-
-int string_to_syslog_level(string s)
-{
- if (boost::iequals(s, "debug"))
- return LOG_DEBUG;
- if (boost::iequals(s, "info") ||
- boost::iequals(s, "notice"))
- return LOG_INFO;
- if (boost::iequals(s, "warning") ||
- boost::iequals(s, "warn"))
- return LOG_WARNING;
- if (boost::iequals(s, "error") ||
- boost::iequals(s, "err"))
- return LOG_ERR;
- if (boost::iequals(s, "crit") ||
- boost::iequals(s, "critical") ||
- boost::iequals(s, "emerg"))
- return LOG_CRIT;
-
- // err on the side of noise!
- return LOG_DEBUG;
-}
-
-int string_to_syslog_facility(string s)
-{
- if (boost::iequals(s, "auth"))
- return LOG_AUTH;
- if (boost::iequals(s, "authpriv"))
- return LOG_AUTHPRIV;
- if (boost::iequals(s, "cron"))
- return LOG_CRON;
- if (boost::iequals(s, "daemon"))
- return LOG_DAEMON;
- if (boost::iequals(s, "ftp"))
- return LOG_FTP;
- if (boost::iequals(s, "kern"))
- return LOG_KERN;
- if (boost::iequals(s, "local0"))
- return LOG_LOCAL0;
- if (boost::iequals(s, "local1"))
- return LOG_LOCAL1;
- if (boost::iequals(s, "local2"))
- return LOG_LOCAL2;
- if (boost::iequals(s, "local3"))
- return LOG_LOCAL3;
- if (boost::iequals(s, "local4"))
- return LOG_LOCAL4;
- if (boost::iequals(s, "local5"))
- return LOG_LOCAL5;
- if (boost::iequals(s, "local6"))
- return LOG_LOCAL6;
- if (boost::iequals(s, "local7"))
- return LOG_LOCAL7;
- if (boost::iequals(s, "lpr"))
- return LOG_LPR;
- if (boost::iequals(s, "mail"))
- return LOG_MAIL;
- if (boost::iequals(s, "news"))
- return LOG_NEWS;
- if (boost::iequals(s, "syslog"))
- return LOG_SYSLOG;
- if (boost::iequals(s, "user"))
- return LOG_USER;
- if (boost::iequals(s, "uucp"))
- return LOG_UUCP;
-
- // default to USER
- return LOG_USER;
-}
-
-string clog_type_to_string(clog_type t)
-{
- switch (t) {
- case CLOG_DEBUG:
- return "debug";
- case CLOG_INFO:
- return "info";
- case CLOG_WARN:
- return "warn";
- case CLOG_ERROR:
- return "err";
- case CLOG_SEC:
- return "crit";
- default:
- ceph_abort();
- return 0;
- }
-}
-
-void LogEntry::log_to_syslog(string level, string facility)
-{
- int min = string_to_syslog_level(level);
- int l = clog_type_to_syslog_level(prio);
- if (l <= min) {
- int f = string_to_syslog_facility(facility);
- syslog(l | f, "%s %llu : %s",
- stringify(who).c_str(),
- (long long unsigned)seq,
- msg.c_str());
- }
-}
-
-void LogEntry::encode(bufferlist& bl, uint64_t features) const
-{
- ENCODE_START(4, 2, bl);
- __u16 t = prio;
- ::encode(who, bl, features);
- ::encode(stamp, bl);
- ::encode(seq, bl);
- ::encode(t, bl);
- ::encode(msg, bl);
- ::encode(channel, bl);
- ::encode(name, bl);
- ENCODE_FINISH(bl);
-}
-
-void LogEntry::decode(bufferlist::iterator& bl)
-{
- DECODE_START_LEGACY_COMPAT_LEN(4, 2, 2, bl);
- __u16 t;
- ::decode(who, bl);
- ::decode(stamp, bl);
- ::decode(seq, bl);
- ::decode(t, bl);
- prio = (clog_type)t;
- ::decode(msg, bl);
- if (struct_v >= 3) {
- ::decode(channel, bl);
- } else {
- // prior to having logging channels we only had a cluster log.
- // Ensure we keep that appearance when the other party has no
- // clue of what a 'channel' is.
- channel = CLOG_CHANNEL_CLUSTER;
- }
- if (struct_v >= 4) {
- ::decode(name, bl);
- }
- DECODE_FINISH(bl);
-}
-
-void LogEntry::dump(Formatter *f) const
-{
- f->dump_stream("who") << who;
- f->dump_stream("name") << name;
- f->dump_stream("stamp") << stamp;
- f->dump_unsigned("seq", seq);
- f->dump_string("channel", channel);
- f->dump_stream("priority") << prio;
- f->dump_string("message", msg);
-}
-
-void LogEntry::generate_test_instances(list<LogEntry*>& o)
-{
- o.push_back(new LogEntry);
-}
-
-
-// -----
-
-void LogSummary::encode(bufferlist& bl, uint64_t features) const
-{
- ENCODE_START(2, 2, bl);
- ::encode(version, bl);
- ::encode(tail, bl, features);
- ENCODE_FINISH(bl);
-}
-
-void LogSummary::decode(bufferlist::iterator& bl)
-{
- DECODE_START_LEGACY_COMPAT_LEN(2, 2, 2, bl);
- ::decode(version, bl);
- ::decode(tail, bl);
- DECODE_FINISH(bl);
- keys.clear();
- for (auto& p : tail) {
- keys.insert(p.key());
- }
-}
-
-void LogSummary::dump(Formatter *f) const
-{
- f->dump_unsigned("version", version);
- f->open_array_section("tail");
- for (list<LogEntry>::const_iterator p = tail.begin(); p != tail.end(); ++p) {
- f->open_object_section("entry");
- p->dump(f);
- f->close_section();
- }
- f->close_section();
-}
-
-void LogSummary::generate_test_instances(list<LogSummary*>& o)
-{
- o.push_back(new LogSummary);
- // more!
-}
-
Code Review / stor4nfv.git / blobdiff