granicus.if.org Git - icinga2/blob - lib/methods/icingachecktask.cpp

   1 /* Icinga 2 | (c) 2012 Icinga GmbH | GPLv2+ */
   2
   3 #include "methods/icingachecktask.hpp"
   4 #include "icinga/cib.hpp"
   5 #include "icinga/service.hpp"
   6 #include "icinga/checkcommand.hpp"
   7 #include "icinga/macroprocessor.hpp"
   8 #include "icinga/icingaapplication.hpp"
   9 #include "icinga/clusterevents.hpp"
  10 #include "icinga/checkable.hpp"
  11 #include "base/application.hpp"
  12 #include "base/objectlock.hpp"
  13 #include "base/utility.hpp"
  14 #include "base/perfdatavalue.hpp"
  15 #include "base/function.hpp"
  16 #include "base/configtype.hpp"
  17
  18 using namespace icinga;
  19
  20 REGISTER_FUNCTION_NONCONST(Internal, IcingaCheck, &IcingaCheckTask::ScriptFunc, "checkable:cr:resolvedMacros:useResolvedMacros");
  21
  22 void IcingaCheckTask::ScriptFunc(const Checkable::Ptr& checkable, const CheckResult::Ptr& cr,
  23         const Dictionary::Ptr& resolvedMacros, bool useResolvedMacros)
  24 {
  25         REQUIRE_NOT_NULL(checkable);
  26         REQUIRE_NOT_NULL(cr);
  27
  28         CheckCommand::Ptr commandObj = checkable->GetCheckCommand();
  29
  30         Host::Ptr host;
  31         Service::Ptr service;
  32         tie(host, service) = GetHostService(checkable);
  33
  34         MacroProcessor::ResolverList resolvers;
  35         if (service)
  36                 resolvers.emplace_back("service", service);
  37         resolvers.emplace_back("host", host);
  38         resolvers.emplace_back("command", commandObj);
  39         resolvers.emplace_back("icinga", IcingaApplication::GetInstance());
  40
  41         String missingIcingaMinVersion;
  42
  43         String icingaMinVersion = MacroProcessor::ResolveMacros("$icinga_min_version$", resolvers, checkable->GetLastCheckResult(),
  44                 &missingIcingaMinVersion, MacroProcessor::EscapeCallback(), resolvedMacros, useResolvedMacros);
  45
  46         if (resolvedMacros && !useResolvedMacros)
  47                 return;
  48
  49         double interval = Utility::GetTime() - Application::GetStartTime();
  50
  51         if (interval > 60)
  52                 interval = 60;
  53
  54         /* use feature stats perfdata */
  55         std::pair<Dictionary::Ptr, Array::Ptr> feature_stats = CIB::GetFeatureStats();
  56
  57         Array::Ptr perfdata = feature_stats.second;
  58
  59         perfdata->Add(new PerfdataValue("active_host_checks", CIB::GetActiveHostChecksStatistics(interval) / interval));
  60         perfdata->Add(new PerfdataValue("passive_host_checks", CIB::GetPassiveHostChecksStatistics(interval) / interval));
  61         perfdata->Add(new PerfdataValue("active_host_checks_1min", CIB::GetActiveHostChecksStatistics(60)));
  62         perfdata->Add(new PerfdataValue("passive_host_checks_1min", CIB::GetPassiveHostChecksStatistics(60)));
  63         perfdata->Add(new PerfdataValue("active_host_checks_5min", CIB::GetActiveHostChecksStatistics(60 * 5)));
  64         perfdata->Add(new PerfdataValue("passive_host_checks_5min", CIB::GetPassiveHostChecksStatistics(60 * 5)));
  65         perfdata->Add(new PerfdataValue("active_host_checks_15min", CIB::GetActiveHostChecksStatistics(60 * 15)));
  66         perfdata->Add(new PerfdataValue("passive_host_checks_15min", CIB::GetPassiveHostChecksStatistics(60 * 15)));
  67
  68         perfdata->Add(new PerfdataValue("active_service_checks", CIB::GetActiveServiceChecksStatistics(interval) / interval));
  69         perfdata->Add(new PerfdataValue("passive_service_checks", CIB::GetPassiveServiceChecksStatistics(interval) / interval));
  70         perfdata->Add(new PerfdataValue("active_service_checks_1min", CIB::GetActiveServiceChecksStatistics(60)));
  71         perfdata->Add(new PerfdataValue("passive_service_checks_1min", CIB::GetPassiveServiceChecksStatistics(60)));
  72         perfdata->Add(new PerfdataValue("active_service_checks_5min", CIB::GetActiveServiceChecksStatistics(60 * 5)));
  73         perfdata->Add(new PerfdataValue("passive_service_checks_5min", CIB::GetPassiveServiceChecksStatistics(60 * 5)));
  74         perfdata->Add(new PerfdataValue("active_service_checks_15min", CIB::GetActiveServiceChecksStatistics(60 * 15)));
  75         perfdata->Add(new PerfdataValue("passive_service_checks_15min", CIB::GetPassiveServiceChecksStatistics(60 * 15)));
  76
  77         perfdata->Add(new PerfdataValue("current_concurrent_checks", Checkable::GetPendingChecks()));
  78         perfdata->Add(new PerfdataValue("remote_check_queue", ClusterEvents::GetCheckRequestQueueSize()));
  79
  80         CheckableCheckStatistics scs = CIB::CalculateServiceCheckStats();
  81
  82         perfdata->Add(new PerfdataValue("min_latency", scs.min_latency));
  83         perfdata->Add(new PerfdataValue("max_latency", scs.max_latency));
  84         perfdata->Add(new PerfdataValue("avg_latency", scs.avg_latency));
  85         perfdata->Add(new PerfdataValue("min_execution_time", scs.min_execution_time));
  86         perfdata->Add(new PerfdataValue("max_execution_time", scs.max_execution_time));
  87         perfdata->Add(new PerfdataValue("avg_execution_time", scs.avg_execution_time));
  88
  89         ServiceStatistics ss = CIB::CalculateServiceStats();
  90
  91         perfdata->Add(new PerfdataValue("num_services_ok", ss.services_ok));
  92         perfdata->Add(new PerfdataValue("num_services_warning", ss.services_warning));
  93         perfdata->Add(new PerfdataValue("num_services_critical", ss.services_critical));
  94         perfdata->Add(new PerfdataValue("num_services_unknown", ss.services_unknown));
  95         perfdata->Add(new PerfdataValue("num_services_pending", ss.services_pending));
  96         perfdata->Add(new PerfdataValue("num_services_unreachable", ss.services_unreachable));
  97         perfdata->Add(new PerfdataValue("num_services_flapping", ss.services_flapping));
  98         perfdata->Add(new PerfdataValue("num_services_in_downtime", ss.services_in_downtime));
  99         perfdata->Add(new PerfdataValue("num_services_acknowledged", ss.services_acknowledged));
 100
 101         double uptime = Utility::GetTime() - Application::GetStartTime();
 102         perfdata->Add(new PerfdataValue("uptime", uptime));
 103
 104         HostStatistics hs = CIB::CalculateHostStats();
 105
 106         perfdata->Add(new PerfdataValue("num_hosts_up", hs.hosts_up));
 107         perfdata->Add(new PerfdataValue("num_hosts_down", hs.hosts_down));
 108         perfdata->Add(new PerfdataValue("num_hosts_pending", hs.hosts_pending));
 109         perfdata->Add(new PerfdataValue("num_hosts_unreachable", hs.hosts_unreachable));
 110         perfdata->Add(new PerfdataValue("num_hosts_flapping", hs.hosts_flapping));
 111         perfdata->Add(new PerfdataValue("num_hosts_in_downtime", hs.hosts_in_downtime));
 112         perfdata->Add(new PerfdataValue("num_hosts_acknowledged", hs.hosts_acknowledged));
 113
 114         std::vector<Endpoint::Ptr> endpoints = ConfigType::GetObjectsByType<Endpoint>();
 115
 116         double lastMessageSent = 0;
 117         double lastMessageReceived = 0;
 118         double messagesSentPerSecond = 0;
 119         double messagesReceivedPerSecond = 0;
 120         double bytesSentPerSecond = 0;
 121         double bytesReceivedPerSecond = 0;
 122
 123         for (const Endpoint::Ptr& endpoint : endpoints)
 124         {
 125                 if (endpoint->GetLastMessageSent() > lastMessageSent)
 126                         lastMessageSent = endpoint->GetLastMessageSent();
 127
 128                 if (endpoint->GetLastMessageReceived() > lastMessageReceived)
 129                         lastMessageReceived = endpoint->GetLastMessageReceived();
 130
 131                 messagesSentPerSecond += endpoint->GetMessagesSentPerSecond();
 132                 messagesReceivedPerSecond += endpoint->GetMessagesReceivedPerSecond();
 133                 bytesSentPerSecond += endpoint->GetBytesSentPerSecond();
 134                 bytesReceivedPerSecond += endpoint->GetBytesReceivedPerSecond();
 135         }
 136
 137         perfdata->Add(new PerfdataValue("last_messages_sent", lastMessageSent));
 138         perfdata->Add(new PerfdataValue("last_messages_received", lastMessageReceived));
 139         perfdata->Add(new PerfdataValue("sum_messages_sent_per_second", messagesSentPerSecond));
 140         perfdata->Add(new PerfdataValue("sum_messages_received_per_second", messagesReceivedPerSecond));
 141         perfdata->Add(new PerfdataValue("sum_bytes_sent_per_second", bytesSentPerSecond));
 142         perfdata->Add(new PerfdataValue("sum_bytes_received_per_second", bytesReceivedPerSecond));
 143
 144         cr->SetPerformanceData(perfdata);
 145         cr->SetState(ServiceOK);
 146
 147         String appVersion = Application::GetAppVersion();
 148
 149         String output = "Icinga 2 has been running for " + Utility::FormatDuration(uptime) +
 150                 ". Version: " + appVersion;
 151
 152         /* Indicate a warning if the last reload failed. */
 153         double lastReloadFailed = Application::GetLastReloadFailed();
 154
 155         if (lastReloadFailed > 0) {
 156                 output += "; Last reload attempt failed at " + Utility::FormatDateTime("%Y-%m-%d %H:%M:%S %z", lastReloadFailed);
 157                 cr->SetState(ServiceWarning);
 158         }
 159
 160         /* Extract the version number of the running Icinga2 instance.
 161          * We assume that appVersion will allways be something like 'v2.10.1-8-gaebe6da' and we want to extract '2.10.1'.
 162          */
 163         int endOfVersionNumber = appVersion.FindFirstOf("-") - 1;
 164         String parsedAppVersion = appVersion.SubStr(1, endOfVersionNumber);
 165
 166         /* Return an error if the version is less than specified (optional). */
 167         if (missingIcingaMinVersion.IsEmpty() && !icingaMinVersion.IsEmpty() && Utility::CompareVersion(icingaMinVersion, parsedAppVersion) < 0) {
 168                 output += "; Minimum version " + icingaMinVersion + " is not installed.";
 169                 cr->SetState(ServiceCritical);
 170         }
 171
 172         cr->SetOutput(output);
 173
 174         checkable->ProcessCheckResult(cr);
 175 }