]> granicus.if.org Git - icinga2/blob - lib/base/sysloglogger.cpp
Merge pull request #7185 from Icinga/bugfix/gelfwriter-wrong-log-facility
[icinga2] / lib / base / sysloglogger.cpp
1 /* Icinga 2 | (c) 2012 Icinga GmbH | GPLv2+ */
2
3 #ifndef _WIN32
4 #include "base/sysloglogger.hpp"
5 #include "base/sysloglogger-ti.cpp"
6 #include "base/configtype.hpp"
7 #include "base/statsfunction.hpp"
8
9 using namespace icinga;
10
11 REGISTER_TYPE(SyslogLogger);
12
13 REGISTER_STATSFUNCTION(SyslogLogger, &SyslogLogger::StatsFunc);
14
15 INITIALIZE_ONCE(&SyslogLogger::StaticInitialize);
16
17 std::map<String, int> SyslogLogger::m_FacilityMap;
18
19 void SyslogLogger::StaticInitialize()
20 {
21         ScriptGlobal::Set("System.FacilityAuth", "LOG_AUTH", true);
22         ScriptGlobal::Set("System.FacilityAuthPriv", "LOG_AUTHPRIV", true);
23         ScriptGlobal::Set("System.FacilityCron", "LOG_CRON", true);
24         ScriptGlobal::Set("System.FacilityDaemon", "LOG_DAEMON", true);
25         ScriptGlobal::Set("System.FacilityFtp", "LOG_FTP", true);
26         ScriptGlobal::Set("System.FacilityKern", "LOG_KERN", true);
27         ScriptGlobal::Set("System.FacilityLocal0", "LOG_LOCAL0", true);
28         ScriptGlobal::Set("System.FacilityLocal1", "LOG_LOCAL1", true);
29         ScriptGlobal::Set("System.FacilityLocal2", "LOG_LOCAL2", true);
30         ScriptGlobal::Set("System.FacilityLocal3", "LOG_LOCAL3", true);
31         ScriptGlobal::Set("System.FacilityLocal4", "LOG_LOCAL4", true);
32         ScriptGlobal::Set("System.FacilityLocal5", "LOG_LOCAL5", true);
33         ScriptGlobal::Set("System.FacilityLocal6", "LOG_LOCAL6", true);
34         ScriptGlobal::Set("System.FacilityLocal7", "LOG_LOCAL7", true);
35         ScriptGlobal::Set("System.FacilityLpr", "LOG_LPR", true);
36         ScriptGlobal::Set("System.FacilityMail", "LOG_MAIL", true);
37         ScriptGlobal::Set("System.FacilityNews", "LOG_NEWS", true);
38         ScriptGlobal::Set("System.FacilitySyslog", "LOG_SYSLOG", true);
39         ScriptGlobal::Set("System.FacilityUser", "LOG_USER", true);
40         ScriptGlobal::Set("System.FacilityUucp", "LOG_UUCP", true);
41
42         m_FacilityMap["LOG_AUTH"] = LOG_AUTH;
43         m_FacilityMap["LOG_AUTHPRIV"] = LOG_AUTHPRIV;
44         m_FacilityMap["LOG_CRON"] = LOG_CRON;
45         m_FacilityMap["LOG_DAEMON"] = LOG_DAEMON;
46         m_FacilityMap["LOG_FTP"] = LOG_FTP;
47         m_FacilityMap["LOG_KERN"] = LOG_KERN;
48         m_FacilityMap["LOG_LOCAL0"] = LOG_LOCAL0;
49         m_FacilityMap["LOG_LOCAL1"] = LOG_LOCAL1;
50         m_FacilityMap["LOG_LOCAL2"] = LOG_LOCAL2;
51         m_FacilityMap["LOG_LOCAL3"] = LOG_LOCAL3;
52         m_FacilityMap["LOG_LOCAL4"] = LOG_LOCAL4;
53         m_FacilityMap["LOG_LOCAL5"] = LOG_LOCAL5;
54         m_FacilityMap["LOG_LOCAL6"] = LOG_LOCAL6;
55         m_FacilityMap["LOG_LOCAL7"] = LOG_LOCAL7;
56         m_FacilityMap["LOG_LPR"] = LOG_LPR;
57         m_FacilityMap["LOG_MAIL"] = LOG_MAIL;
58         m_FacilityMap["LOG_NEWS"] = LOG_NEWS;
59         m_FacilityMap["LOG_SYSLOG"] = LOG_SYSLOG;
60         m_FacilityMap["LOG_USER"] = LOG_USER;
61         m_FacilityMap["LOG_UUCP"] = LOG_UUCP;
62 }
63
64 void SyslogLogger::StatsFunc(const Dictionary::Ptr& status, const Array::Ptr&)
65 {
66         DictionaryData nodes;
67
68         for (const SyslogLogger::Ptr& sysloglogger : ConfigType::GetObjectsByType<SyslogLogger>()) {
69                 nodes.emplace_back(sysloglogger->GetName(), 1); //add more stats
70         }
71
72         status->Set("sysloglogger", new Dictionary(std::move(nodes)));
73 }
74
75 void SyslogLogger::OnConfigLoaded()
76 {
77         ObjectImpl<SyslogLogger>::OnConfigLoaded();
78
79         String facilityString = GetFacility();
80
81         auto it = m_FacilityMap.find(facilityString);
82
83         if (it != m_FacilityMap.end())
84                 m_Facility = it->second;
85         else
86                 m_Facility = Convert::ToLong(facilityString);
87 }
88
89 void SyslogLogger::ValidateFacility(const Lazy<String>& lvalue, const ValidationUtils& utils)
90 {
91         ObjectImpl<SyslogLogger>::ValidateFacility(lvalue, utils);
92
93         if (m_FacilityMap.find(lvalue()) == m_FacilityMap.end()) {
94                 try {
95                         Convert::ToLong(lvalue());
96                 } catch (const std::exception&) {
97                         BOOST_THROW_EXCEPTION(ValidationError(this, { "facility" }, "Invalid facility specified."));
98                 }
99         }
100 }
101
102 /**
103  * Processes a log entry and outputs it to syslog.
104  *
105  * @param entry The log entry.
106  */
107 void SyslogLogger::ProcessLogEntry(const LogEntry& entry)
108 {
109         int severity;
110         switch (entry.Severity) {
111                 case LogDebug:
112                         severity = LOG_DEBUG;
113                         break;
114                 case LogNotice:
115                         severity = LOG_NOTICE;
116                         break;
117                 case LogWarning:
118                         severity = LOG_WARNING;
119                         break;
120                 case LogCritical:
121                         severity = LOG_CRIT;
122                         break;
123                 case LogInformation:
124                 default:
125                         severity = LOG_INFO;
126                         break;
127         }
128
129         syslog(severity | m_Facility, "%s", entry.Message.CStr());
130 }
131
132 void SyslogLogger::Flush()
133 {
134         /* Nothing to do here. */
135 }
136 #endif /* _WIN32 */