granicus.if.org Git - icinga2/blob - lib/livestatus/statustable.cpp

   1 /******************************************************************************
   2  * Icinga 2                                                                   *
   3  * Copyright (C) 2012-2015 Icinga Development Team (http://www.icinga.org)    *
   4  *                                                                            *
   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.                     *
   9  *                                                                            *
  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.                               *
  14  *                                                                            *
  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  ******************************************************************************/
  19
  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"
  29 #include <boost/foreach.hpp>
  30
  31 using namespace icinga;
  32
  33 StatusTable::StatusTable(void)
  34 {
  35         AddColumns(this);
  36 }
  37
  38 void StatusTable::AddColumns(Table *table, const String& prefix,
  39     const Column::ObjectAccessor& objectAccessor)
  40 {
  41         table->AddColumn(prefix + "neb_callbacks", Column(&Table::ZeroAccessor, objectAccessor));
  42         table->AddColumn(prefix + "neb_callbacks_rate", Column(&Table::ZeroAccessor, objectAccessor));
  43
  44         table->AddColumn(prefix + "requests", Column(&Table::ZeroAccessor, objectAccessor));
  45         table->AddColumn(prefix + "requests_rate", Column(&Table::ZeroAccessor, objectAccessor));
  46
  47         table->AddColumn(prefix + "connections", Column(&StatusTable::ConnectionsAccessor, objectAccessor));
  48         table->AddColumn(prefix + "connections_rate", Column(&StatusTable::ConnectionsRateAccessor, objectAccessor));
  49
  50         table->AddColumn(prefix + "service_checks", Column(&StatusTable::ServiceChecksAccessor, objectAccessor));
  51         table->AddColumn(prefix + "service_checks_rate", Column(&StatusTable::ServiceChecksRateAccessor, objectAccessor));
  52
  53         table->AddColumn(prefix + "host_checks", Column(&StatusTable::HostChecksAccessor, objectAccessor));
  54         table->AddColumn(prefix + "host_checks_rate", Column(&StatusTable::HostChecksRateAccessor, objectAccessor));
  55
  56         table->AddColumn(prefix + "forks", Column(&Table::ZeroAccessor, objectAccessor));
  57         table->AddColumn(prefix + "forks_rate", Column(&Table::ZeroAccessor, objectAccessor));
  58
  59         table->AddColumn(prefix + "log_messages", Column(&Table::ZeroAccessor, objectAccessor));
  60         table->AddColumn(prefix + "log_messages_rate", Column(&Table::ZeroAccessor, objectAccessor));
  61
  62         table->AddColumn(prefix + "external_commands", Column(&StatusTable::ExternalCommandsAccessor, objectAccessor));
  63         table->AddColumn(prefix + "external_commands_rate", Column(&StatusTable::ExternalCommandsRateAccessor, objectAccessor));
  64
  65         table->AddColumn(prefix + "livechecks", Column(&Table::ZeroAccessor, objectAccessor));
  66         table->AddColumn(prefix + "livechecks_rate", Column(&Table::ZeroAccessor, objectAccessor));
  67
  68         table->AddColumn(prefix + "livecheck_overflows", Column(&Table::ZeroAccessor, objectAccessor));
  69         table->AddColumn(prefix + "livecheck_overflows_rate", Column(&Table::ZeroAccessor, objectAccessor));
  70
  71         table->AddColumn(prefix + "nagios_pid", Column(&StatusTable::NagiosPidAccessor, objectAccessor));
  72         table->AddColumn(prefix + "enable_notifications", Column(&StatusTable::EnableNotificationsAccessor, objectAccessor));
  73         table->AddColumn(prefix + "execute_service_checks", Column(&StatusTable::ExecuteServiceChecksAccessor, objectAccessor));
  74         table->AddColumn(prefix + "accept_passive_service_checks", Column(&Table::OneAccessor, objectAccessor));
  75         table->AddColumn(prefix + "execute_host_checks", Column(&StatusTable::ExecuteHostChecksAccessor, objectAccessor));
  76         table->AddColumn(prefix + "accept_passive_host_checks", Column(&Table::OneAccessor, objectAccessor));
  77         table->AddColumn(prefix + "enable_event_handlers", Column(&StatusTable::EnableEventHandlersAccessor, objectAccessor));
  78         table->AddColumn(prefix + "obsess_over_services", Column(&Table::ZeroAccessor, objectAccessor));
  79         table->AddColumn(prefix + "obsess_over_hosts", Column(&Table::ZeroAccessor, objectAccessor));
  80         table->AddColumn(prefix + "check_service_freshness", Column(&Table::OneAccessor, objectAccessor));
  81         table->AddColumn(prefix + "check_host_freshness", Column(&Table::OneAccessor, objectAccessor));
  82         table->AddColumn(prefix + "enable_flap_detection", Column(&StatusTable::EnableFlapDetectionAccessor, objectAccessor));
  83         table->AddColumn(prefix + "process_performance_data", Column(&StatusTable::ProcessPerformanceDataAccessor, objectAccessor));
  84         table->AddColumn(prefix + "check_external_commands", Column(&Table::OneAccessor, objectAccessor));
  85         table->AddColumn(prefix + "program_start", Column(&StatusTable::ProgramStartAccessor, objectAccessor));
  86         table->AddColumn(prefix + "last_command_check", Column(&Table::ZeroAccessor, objectAccessor));
  87         table->AddColumn(prefix + "last_log_rotation", Column(&Table::ZeroAccessor, objectAccessor));
  88         table->AddColumn(prefix + "interval_length", Column(&Table::ZeroAccessor, objectAccessor));
  89         table->AddColumn(prefix + "num_hosts", Column(&StatusTable::NumHostsAccessor, objectAccessor));
  90         table->AddColumn(prefix + "num_services", Column(&StatusTable::NumServicesAccessor, objectAccessor));
  91         table->AddColumn(prefix + "program_version", Column(&StatusTable::ProgramVersionAccessor, objectAccessor));
  92         table->AddColumn(prefix + "external_command_buffer_slots", Column(&Table::ZeroAccessor, objectAccessor));
  93         table->AddColumn(prefix + "external_command_buffer_usage", Column(&Table::ZeroAccessor, objectAccessor));
  94         table->AddColumn(prefix + "external_command_buffer_max", Column(&Table::ZeroAccessor, objectAccessor));
  95         table->AddColumn(prefix + "cached_log_messages", Column(&Table::ZeroAccessor, objectAccessor));
  96         table->AddColumn(prefix + "livestatus_version", Column(&StatusTable::LivestatusVersionAccessor, objectAccessor));
  97         table->AddColumn(prefix + "livestatus_active_connections", Column(&Table::ZeroAccessor, objectAccessor));
  98         table->AddColumn(prefix + "livestatus_queued_connections", Column(&Table::ZeroAccessor, objectAccessor));
  99         table->AddColumn(prefix + "livestatus_threads", Column(&Table::ZeroAccessor, objectAccessor));
 100
 101         table->AddColumn(prefix + "custom_variable_names", Column(&StatusTable::CustomVariableNamesAccessor, objectAccessor));
 102         table->AddColumn(prefix + "custom_variable_values", Column(&StatusTable::CustomVariableValuesAccessor, objectAccessor));
 103         table->AddColumn(prefix + "custom_variables", Column(&StatusTable::CustomVariablesAccessor, objectAccessor));
 104 }
 105
 106 String StatusTable::GetName(void) const
 107 {
 108         return "status";
 109 }
 110
 111 String StatusTable::GetPrefix(void) const
 112 {
 113         return "status";
 114 }
 115
 116 void StatusTable::FetchRows(const AddRowFunction& addRowFn)
 117 {
 118         Object::Ptr obj = new Object();
 119
 120         /* Return a fake row. */
 121         addRowFn(obj, LivestatusGroupByNone, Empty);
 122 }
 123
 124 Value StatusTable::ConnectionsAccessor(const Value&)
 125 {
 126         return LivestatusListener::GetConnections();
 127 }
 128
 129 Value StatusTable::ConnectionsRateAccessor(const Value&)
 130 {
 131         return (LivestatusListener::GetConnections() / (Utility::GetTime() - Application::GetStartTime()));
 132 }
 133
 134 Value StatusTable::HostChecksAccessor(const Value&)
 135 {
 136         long timespan = static_cast<long>(Utility::GetTime() - Application::GetStartTime());
 137         return CIB::GetActiveHostChecksStatistics(timespan);
 138 }
 139
 140 Value StatusTable::HostChecksRateAccessor(const Value&)
 141 {
 142         long timespan = static_cast<long>(Utility::GetTime() - Application::GetStartTime());
 143         return (CIB::GetActiveHostChecksStatistics(timespan) / (Utility::GetTime() - Application::GetStartTime()));
 144 }
 145
 146 Value StatusTable::ServiceChecksAccessor(const Value&)
 147 {
 148         long timespan = static_cast<long>(Utility::GetTime() - Application::GetStartTime());
 149         return CIB::GetActiveServiceChecksStatistics(timespan);
 150 }
 151
 152 Value StatusTable::ServiceChecksRateAccessor(const Value&)
 153 {
 154         long timespan = static_cast<long>(Utility::GetTime() - Application::GetStartTime());
 155         return (CIB::GetActiveServiceChecksStatistics(timespan) / (Utility::GetTime() - Application::GetStartTime()));
 156 }
 157
 158 Value StatusTable::ExternalCommandsAccessor(const Value&)
 159 {
 160         return LivestatusQuery::GetExternalCommands();
 161 }
 162
 163 Value StatusTable::ExternalCommandsRateAccessor(const Value&)
 164 {
 165         return (LivestatusQuery::GetExternalCommands() / (Utility::GetTime() - Application::GetStartTime()));
 166 }
 167
 168 Value StatusTable::NagiosPidAccessor(const Value&)
 169 {
 170         return Utility::GetPid();
 171 }
 172
 173 Value StatusTable::EnableNotificationsAccessor(const Value&)
 174 {
 175         return (IcingaApplication::GetInstance()->GetEnableNotifications() ? 1 : 0);
 176 }
 177
 178 Value StatusTable::ExecuteServiceChecksAccessor(const Value&)
 179 {
 180         return (IcingaApplication::GetInstance()->GetEnableServiceChecks() ? 1 : 0);
 181 }
 182
 183 Value StatusTable::ExecuteHostChecksAccessor(const Value&)
 184 {
 185         return (IcingaApplication::GetInstance()->GetEnableHostChecks() ? 1 : 0);
 186 }
 187
 188 Value StatusTable::EnableEventHandlersAccessor(const Value&)
 189 {
 190         return (IcingaApplication::GetInstance()->GetEnableEventHandlers() ? 1 : 0);
 191 }
 192
 193 Value StatusTable::EnableFlapDetectionAccessor(const Value&)
 194 {
 195         return (IcingaApplication::GetInstance()->GetEnableFlapping() ? 1 : 0);
 196 }
 197
 198 Value StatusTable::ProcessPerformanceDataAccessor(const Value&)
 199 {
 200         return (IcingaApplication::GetInstance()->GetEnablePerfdata() ? 1 : 0);
 201 }
 202
 203 Value StatusTable::ProgramStartAccessor(const Value&)
 204 {
 205         return static_cast<long>(Application::GetStartTime());
 206 }
 207
 208 Value StatusTable::NumHostsAccessor(const Value&)
 209 {
 210         return std::distance(ConfigType::GetObjectsByType<Host>().first, ConfigType::GetObjectsByType<Host>().second);
 211 }
 212
 213 Value StatusTable::NumServicesAccessor(const Value&)
 214 {
 215         return std::distance(ConfigType::GetObjectsByType<Service>().first, ConfigType::GetObjectsByType<Service>().second);
 216 }
 217
 218 Value StatusTable::ProgramVersionAccessor(const Value&)
 219 {
 220         return Application::GetAppVersion();
 221 }
 222
 223 Value StatusTable::LivestatusVersionAccessor(const Value&)
 224 {
 225         return Application::GetAppVersion();
 226 }
 227
 228 Value StatusTable::LivestatusActiveConnectionsAccessor(const Value&)
 229 {
 230         return LivestatusListener::GetClientsConnected();
 231 }
 232
 233 Value StatusTable::CustomVariableNamesAccessor(const Value&)
 234 {
 235         Dictionary::Ptr vars = IcingaApplication::GetInstance()->GetVars();
 236
 237         if (!vars)
 238                 return Empty;
 239
 240         Array::Ptr cv = new Array();
 241
 242         String key;
 243         Value value;
 244         BOOST_FOREACH(tie(key, value), vars) {
 245                 cv->Add(key);
 246         }
 247
 248         return cv;
 249 }
 250
 251 Value StatusTable::CustomVariableValuesAccessor(const Value&)
 252 {
 253         Dictionary::Ptr vars = IcingaApplication::GetInstance()->GetVars();
 254
 255         if (!vars)
 256                 return Empty;
 257
 258         Array::Ptr cv = new Array();
 259
 260         String key;
 261         Value value;
 262         BOOST_FOREACH(tie(key, value), vars) {
 263                 cv->Add(value);
 264         }
 265
 266         return cv;
 267 }
 268
 269 Value StatusTable::CustomVariablesAccessor(const Value&)
 270 {
 271         Dictionary::Ptr vars = IcingaApplication::GetInstance()->GetVars();
 272
 273         if (!vars)
 274                 return Empty;
 275
 276         Array::Ptr cv = new Array();
 277
 278         String key;
 279         Value value;
 280         BOOST_FOREACH(tie(key, value), vars) {
 281                 Array::Ptr key_val = new Array();
 282                 key_val->Add(key);
 283                 key_val->Add(value);
 284                 cv->Add(key_val);
 285         }
 286
 287         return cv;
 288 }