1 /******************************************************************************
3 * Copyright (C) 2012-2016 Icinga Development Team (https://www.icinga.org/) *
5 * This program is free software; you can redistribute it and/or *
6 * modify it under the terms of the GNU General Public License *
7 * as published by the Free Software Foundation; either version 2 *
8 * of the License, or (at your option) any later version. *
10 * This program is distributed in the hope that it will be useful, *
11 * but WITHOUT ANY WARRANTY; without even the implied warranty of *
12 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the *
13 * GNU General Public License for more details. *
15 * You should have received a copy of the GNU General Public License *
16 * along with this program; if not, write to the Free Software Foundation *
17 * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301, USA. *
18 ******************************************************************************/
20 #include "livestatus/statustable.hpp"
21 #include "livestatus/livestatuslistener.hpp"
22 #include "icinga/icingaapplication.hpp"
23 #include "icinga/cib.hpp"
24 #include "icinga/host.hpp"
25 #include "icinga/service.hpp"
26 #include "base/configtype.hpp"
27 #include "base/utility.hpp"
28 #include "base/application.hpp"
30 using namespace icinga;
32 StatusTable::StatusTable(void)
37 void StatusTable::AddColumns(Table *table, const String& prefix,
38 const Column::ObjectAccessor& objectAccessor)
40 table->AddColumn(prefix + "neb_callbacks", Column(&Table::ZeroAccessor, objectAccessor));
41 table->AddColumn(prefix + "neb_callbacks_rate", Column(&Table::ZeroAccessor, objectAccessor));
43 table->AddColumn(prefix + "requests", Column(&Table::ZeroAccessor, objectAccessor));
44 table->AddColumn(prefix + "requests_rate", Column(&Table::ZeroAccessor, objectAccessor));
46 table->AddColumn(prefix + "connections", Column(&StatusTable::ConnectionsAccessor, objectAccessor));
47 table->AddColumn(prefix + "connections_rate", Column(&StatusTable::ConnectionsRateAccessor, objectAccessor));
49 table->AddColumn(prefix + "service_checks", Column(&StatusTable::ServiceChecksAccessor, objectAccessor));
50 table->AddColumn(prefix + "service_checks_rate", Column(&StatusTable::ServiceChecksRateAccessor, objectAccessor));
52 table->AddColumn(prefix + "host_checks", Column(&StatusTable::HostChecksAccessor, objectAccessor));
53 table->AddColumn(prefix + "host_checks_rate", Column(&StatusTable::HostChecksRateAccessor, objectAccessor));
55 table->AddColumn(prefix + "forks", Column(&Table::ZeroAccessor, objectAccessor));
56 table->AddColumn(prefix + "forks_rate", Column(&Table::ZeroAccessor, objectAccessor));
58 table->AddColumn(prefix + "log_messages", Column(&Table::ZeroAccessor, objectAccessor));
59 table->AddColumn(prefix + "log_messages_rate", Column(&Table::ZeroAccessor, objectAccessor));
61 table->AddColumn(prefix + "external_commands", Column(&StatusTable::ExternalCommandsAccessor, objectAccessor));
62 table->AddColumn(prefix + "external_commands_rate", Column(&StatusTable::ExternalCommandsRateAccessor, objectAccessor));
64 table->AddColumn(prefix + "livechecks", Column(&Table::ZeroAccessor, objectAccessor));
65 table->AddColumn(prefix + "livechecks_rate", Column(&Table::ZeroAccessor, objectAccessor));
67 table->AddColumn(prefix + "livecheck_overflows", Column(&Table::ZeroAccessor, objectAccessor));
68 table->AddColumn(prefix + "livecheck_overflows_rate", Column(&Table::ZeroAccessor, objectAccessor));
70 table->AddColumn(prefix + "nagios_pid", Column(&StatusTable::NagiosPidAccessor, objectAccessor));
71 table->AddColumn(prefix + "enable_notifications", Column(&StatusTable::EnableNotificationsAccessor, objectAccessor));
72 table->AddColumn(prefix + "execute_service_checks", Column(&StatusTable::ExecuteServiceChecksAccessor, objectAccessor));
73 table->AddColumn(prefix + "accept_passive_service_checks", Column(&Table::OneAccessor, objectAccessor));
74 table->AddColumn(prefix + "execute_host_checks", Column(&StatusTable::ExecuteHostChecksAccessor, objectAccessor));
75 table->AddColumn(prefix + "accept_passive_host_checks", Column(&Table::OneAccessor, objectAccessor));
76 table->AddColumn(prefix + "enable_event_handlers", Column(&StatusTable::EnableEventHandlersAccessor, objectAccessor));
77 table->AddColumn(prefix + "obsess_over_services", Column(&Table::ZeroAccessor, objectAccessor));
78 table->AddColumn(prefix + "obsess_over_hosts", Column(&Table::ZeroAccessor, objectAccessor));
79 table->AddColumn(prefix + "check_service_freshness", Column(&Table::OneAccessor, objectAccessor));
80 table->AddColumn(prefix + "check_host_freshness", Column(&Table::OneAccessor, objectAccessor));
81 table->AddColumn(prefix + "enable_flap_detection", Column(&StatusTable::EnableFlapDetectionAccessor, objectAccessor));
82 table->AddColumn(prefix + "process_performance_data", Column(&StatusTable::ProcessPerformanceDataAccessor, objectAccessor));
83 table->AddColumn(prefix + "check_external_commands", Column(&Table::OneAccessor, objectAccessor));
84 table->AddColumn(prefix + "program_start", Column(&StatusTable::ProgramStartAccessor, objectAccessor));
85 table->AddColumn(prefix + "last_command_check", Column(&Table::ZeroAccessor, objectAccessor));
86 table->AddColumn(prefix + "last_log_rotation", Column(&Table::ZeroAccessor, objectAccessor));
87 table->AddColumn(prefix + "interval_length", Column(&Table::ZeroAccessor, objectAccessor));
88 table->AddColumn(prefix + "num_hosts", Column(&StatusTable::NumHostsAccessor, objectAccessor));
89 table->AddColumn(prefix + "num_services", Column(&StatusTable::NumServicesAccessor, objectAccessor));
90 table->AddColumn(prefix + "program_version", Column(&StatusTable::ProgramVersionAccessor, objectAccessor));
91 table->AddColumn(prefix + "external_command_buffer_slots", Column(&Table::ZeroAccessor, objectAccessor));
92 table->AddColumn(prefix + "external_command_buffer_usage", Column(&Table::ZeroAccessor, objectAccessor));
93 table->AddColumn(prefix + "external_command_buffer_max", Column(&Table::ZeroAccessor, objectAccessor));
94 table->AddColumn(prefix + "cached_log_messages", Column(&Table::ZeroAccessor, objectAccessor));
95 table->AddColumn(prefix + "livestatus_version", Column(&StatusTable::LivestatusVersionAccessor, objectAccessor));
96 table->AddColumn(prefix + "livestatus_active_connections", Column(&Table::ZeroAccessor, objectAccessor));
97 table->AddColumn(prefix + "livestatus_queued_connections", Column(&Table::ZeroAccessor, objectAccessor));
98 table->AddColumn(prefix + "livestatus_threads", Column(&Table::ZeroAccessor, objectAccessor));
100 table->AddColumn(prefix + "custom_variable_names", Column(&StatusTable::CustomVariableNamesAccessor, objectAccessor));
101 table->AddColumn(prefix + "custom_variable_values", Column(&StatusTable::CustomVariableValuesAccessor, objectAccessor));
102 table->AddColumn(prefix + "custom_variables", Column(&StatusTable::CustomVariablesAccessor, objectAccessor));
105 String StatusTable::GetName(void) const
110 String StatusTable::GetPrefix(void) const
115 void StatusTable::FetchRows(const AddRowFunction& addRowFn)
117 Object::Ptr obj = new Object();
119 /* Return a fake row. */
120 addRowFn(obj, LivestatusGroupByNone, Empty);
123 Value StatusTable::ConnectionsAccessor(const Value&)
125 return LivestatusListener::GetConnections();
128 Value StatusTable::ConnectionsRateAccessor(const Value&)
130 return (LivestatusListener::GetConnections() / (Utility::GetTime() - Application::GetStartTime()));
133 Value StatusTable::HostChecksAccessor(const Value&)
135 long timespan = static_cast<long>(Utility::GetTime() - Application::GetStartTime());
136 return CIB::GetActiveHostChecksStatistics(timespan);
139 Value StatusTable::HostChecksRateAccessor(const Value&)
141 long timespan = static_cast<long>(Utility::GetTime() - Application::GetStartTime());
142 return (CIB::GetActiveHostChecksStatistics(timespan) / (Utility::GetTime() - Application::GetStartTime()));
145 Value StatusTable::ServiceChecksAccessor(const Value&)
147 long timespan = static_cast<long>(Utility::GetTime() - Application::GetStartTime());
148 return CIB::GetActiveServiceChecksStatistics(timespan);
151 Value StatusTable::ServiceChecksRateAccessor(const Value&)
153 long timespan = static_cast<long>(Utility::GetTime() - Application::GetStartTime());
154 return (CIB::GetActiveServiceChecksStatistics(timespan) / (Utility::GetTime() - Application::GetStartTime()));
157 Value StatusTable::ExternalCommandsAccessor(const Value&)
159 return LivestatusQuery::GetExternalCommands();
162 Value StatusTable::ExternalCommandsRateAccessor(const Value&)
164 return (LivestatusQuery::GetExternalCommands() / (Utility::GetTime() - Application::GetStartTime()));
167 Value StatusTable::NagiosPidAccessor(const Value&)
169 return Utility::GetPid();
172 Value StatusTable::EnableNotificationsAccessor(const Value&)
174 return (IcingaApplication::GetInstance()->GetEnableNotifications() ? 1 : 0);
177 Value StatusTable::ExecuteServiceChecksAccessor(const Value&)
179 return (IcingaApplication::GetInstance()->GetEnableServiceChecks() ? 1 : 0);
182 Value StatusTable::ExecuteHostChecksAccessor(const Value&)
184 return (IcingaApplication::GetInstance()->GetEnableHostChecks() ? 1 : 0);
187 Value StatusTable::EnableEventHandlersAccessor(const Value&)
189 return (IcingaApplication::GetInstance()->GetEnableEventHandlers() ? 1 : 0);
192 Value StatusTable::EnableFlapDetectionAccessor(const Value&)
194 return (IcingaApplication::GetInstance()->GetEnableFlapping() ? 1 : 0);
197 Value StatusTable::ProcessPerformanceDataAccessor(const Value&)
199 return (IcingaApplication::GetInstance()->GetEnablePerfdata() ? 1 : 0);
202 Value StatusTable::ProgramStartAccessor(const Value&)
204 return static_cast<long>(Application::GetStartTime());
207 Value StatusTable::NumHostsAccessor(const Value&)
209 return ConfigType::Get<Host>()->GetObjectCount();
212 Value StatusTable::NumServicesAccessor(const Value&)
214 return ConfigType::Get<Service>()->GetObjectCount();
217 Value StatusTable::ProgramVersionAccessor(const Value&)
219 return Application::GetAppVersion();
222 Value StatusTable::LivestatusVersionAccessor(const Value&)
224 return Application::GetAppVersion();
227 Value StatusTable::LivestatusActiveConnectionsAccessor(const Value&)
229 return LivestatusListener::GetClientsConnected();
232 Value StatusTable::CustomVariableNamesAccessor(const Value&)
234 Dictionary::Ptr vars = IcingaApplication::GetInstance()->GetVars();
239 Array::Ptr cv = new Array();
242 ObjectLock olock(vars);
243 for (const auto& kv : vars) {
251 Value StatusTable::CustomVariableValuesAccessor(const Value&)
253 Dictionary::Ptr vars = IcingaApplication::GetInstance()->GetVars();
258 Array::Ptr cv = new Array();
261 ObjectLock olock(vars);
262 for (const auto& kv : vars) {
270 Value StatusTable::CustomVariablesAccessor(const Value&)
272 Dictionary::Ptr vars = IcingaApplication::GetInstance()->GetVars();
277 Array::Ptr cv = new Array();
280 ObjectLock olock(vars);
281 for (const auto& kv : vars) {
282 Array::Ptr key_val = new Array();
283 key_val->Add(kv.first);
284 key_val->Add(kv.second);