mirror of
https://github.com/Icinga/icinga2.git
synced 2025-07-12 00:04:29 +02:00
2acf3a6941
- success: clear the last failed attribute - failed: populate it with the output and current timestamp This can be used to highlight this in the 'icinga' check task. Since 2.9 we don't have problems with circular library dependencies with just one linked binary, therefore it is safe to include libremote in libmethods here.
191 lines
8.7 KiB
C++
191 lines
8.7 KiB
C++
/* Icinga 2 | (c) 2012 Icinga GmbH | GPLv2+ */
|
|
|
|
#include "methods/icingachecktask.hpp"
|
|
#include "icinga/cib.hpp"
|
|
#include "icinga/service.hpp"
|
|
#include "icinga/checkcommand.hpp"
|
|
#include "icinga/macroprocessor.hpp"
|
|
#include "icinga/icingaapplication.hpp"
|
|
#include "icinga/clusterevents.hpp"
|
|
#include "icinga/checkable.hpp"
|
|
#include "remote/apilistener.hpp"
|
|
#include "base/application.hpp"
|
|
#include "base/objectlock.hpp"
|
|
#include "base/utility.hpp"
|
|
#include "base/perfdatavalue.hpp"
|
|
#include "base/function.hpp"
|
|
#include "base/configtype.hpp"
|
|
|
|
using namespace icinga;
|
|
|
|
REGISTER_FUNCTION_NONCONST(Internal, IcingaCheck, &IcingaCheckTask::ScriptFunc, "checkable:cr:resolvedMacros:useResolvedMacros");
|
|
|
|
void IcingaCheckTask::ScriptFunc(const Checkable::Ptr& checkable, const CheckResult::Ptr& cr,
|
|
const Dictionary::Ptr& resolvedMacros, bool useResolvedMacros)
|
|
{
|
|
REQUIRE_NOT_NULL(checkable);
|
|
REQUIRE_NOT_NULL(cr);
|
|
|
|
CheckCommand::Ptr commandObj = checkable->GetCheckCommand();
|
|
|
|
Host::Ptr host;
|
|
Service::Ptr service;
|
|
tie(host, service) = GetHostService(checkable);
|
|
|
|
MacroProcessor::ResolverList resolvers;
|
|
if (service)
|
|
resolvers.emplace_back("service", service);
|
|
resolvers.emplace_back("host", host);
|
|
resolvers.emplace_back("command", commandObj);
|
|
resolvers.emplace_back("icinga", IcingaApplication::GetInstance());
|
|
|
|
String missingIcingaMinVersion;
|
|
|
|
String icingaMinVersion = MacroProcessor::ResolveMacros("$icinga_min_version$", resolvers, checkable->GetLastCheckResult(),
|
|
&missingIcingaMinVersion, MacroProcessor::EscapeCallback(), resolvedMacros, useResolvedMacros);
|
|
|
|
if (resolvedMacros && !useResolvedMacros)
|
|
return;
|
|
|
|
double interval = Utility::GetTime() - Application::GetStartTime();
|
|
|
|
if (interval > 60)
|
|
interval = 60;
|
|
|
|
/* use feature stats perfdata */
|
|
std::pair<Dictionary::Ptr, Array::Ptr> feature_stats = CIB::GetFeatureStats();
|
|
|
|
Array::Ptr perfdata = feature_stats.second;
|
|
|
|
perfdata->Add(new PerfdataValue("active_host_checks", CIB::GetActiveHostChecksStatistics(interval) / interval));
|
|
perfdata->Add(new PerfdataValue("passive_host_checks", CIB::GetPassiveHostChecksStatistics(interval) / interval));
|
|
perfdata->Add(new PerfdataValue("active_host_checks_1min", CIB::GetActiveHostChecksStatistics(60)));
|
|
perfdata->Add(new PerfdataValue("passive_host_checks_1min", CIB::GetPassiveHostChecksStatistics(60)));
|
|
perfdata->Add(new PerfdataValue("active_host_checks_5min", CIB::GetActiveHostChecksStatistics(60 * 5)));
|
|
perfdata->Add(new PerfdataValue("passive_host_checks_5min", CIB::GetPassiveHostChecksStatistics(60 * 5)));
|
|
perfdata->Add(new PerfdataValue("active_host_checks_15min", CIB::GetActiveHostChecksStatistics(60 * 15)));
|
|
perfdata->Add(new PerfdataValue("passive_host_checks_15min", CIB::GetPassiveHostChecksStatistics(60 * 15)));
|
|
|
|
perfdata->Add(new PerfdataValue("active_service_checks", CIB::GetActiveServiceChecksStatistics(interval) / interval));
|
|
perfdata->Add(new PerfdataValue("passive_service_checks", CIB::GetPassiveServiceChecksStatistics(interval) / interval));
|
|
perfdata->Add(new PerfdataValue("active_service_checks_1min", CIB::GetActiveServiceChecksStatistics(60)));
|
|
perfdata->Add(new PerfdataValue("passive_service_checks_1min", CIB::GetPassiveServiceChecksStatistics(60)));
|
|
perfdata->Add(new PerfdataValue("active_service_checks_5min", CIB::GetActiveServiceChecksStatistics(60 * 5)));
|
|
perfdata->Add(new PerfdataValue("passive_service_checks_5min", CIB::GetPassiveServiceChecksStatistics(60 * 5)));
|
|
perfdata->Add(new PerfdataValue("active_service_checks_15min", CIB::GetActiveServiceChecksStatistics(60 * 15)));
|
|
perfdata->Add(new PerfdataValue("passive_service_checks_15min", CIB::GetPassiveServiceChecksStatistics(60 * 15)));
|
|
|
|
perfdata->Add(new PerfdataValue("current_concurrent_checks", Checkable::GetPendingChecks()));
|
|
perfdata->Add(new PerfdataValue("remote_check_queue", ClusterEvents::GetCheckRequestQueueSize()));
|
|
|
|
CheckableCheckStatistics scs = CIB::CalculateServiceCheckStats();
|
|
|
|
perfdata->Add(new PerfdataValue("min_latency", scs.min_latency));
|
|
perfdata->Add(new PerfdataValue("max_latency", scs.max_latency));
|
|
perfdata->Add(new PerfdataValue("avg_latency", scs.avg_latency));
|
|
perfdata->Add(new PerfdataValue("min_execution_time", scs.min_execution_time));
|
|
perfdata->Add(new PerfdataValue("max_execution_time", scs.max_execution_time));
|
|
perfdata->Add(new PerfdataValue("avg_execution_time", scs.avg_execution_time));
|
|
|
|
ServiceStatistics ss = CIB::CalculateServiceStats();
|
|
|
|
perfdata->Add(new PerfdataValue("num_services_ok", ss.services_ok));
|
|
perfdata->Add(new PerfdataValue("num_services_warning", ss.services_warning));
|
|
perfdata->Add(new PerfdataValue("num_services_critical", ss.services_critical));
|
|
perfdata->Add(new PerfdataValue("num_services_unknown", ss.services_unknown));
|
|
perfdata->Add(new PerfdataValue("num_services_pending", ss.services_pending));
|
|
perfdata->Add(new PerfdataValue("num_services_unreachable", ss.services_unreachable));
|
|
perfdata->Add(new PerfdataValue("num_services_flapping", ss.services_flapping));
|
|
perfdata->Add(new PerfdataValue("num_services_in_downtime", ss.services_in_downtime));
|
|
perfdata->Add(new PerfdataValue("num_services_acknowledged", ss.services_acknowledged));
|
|
|
|
double uptime = Utility::GetTime() - Application::GetStartTime();
|
|
perfdata->Add(new PerfdataValue("uptime", uptime));
|
|
|
|
HostStatistics hs = CIB::CalculateHostStats();
|
|
|
|
perfdata->Add(new PerfdataValue("num_hosts_up", hs.hosts_up));
|
|
perfdata->Add(new PerfdataValue("num_hosts_down", hs.hosts_down));
|
|
perfdata->Add(new PerfdataValue("num_hosts_pending", hs.hosts_pending));
|
|
perfdata->Add(new PerfdataValue("num_hosts_unreachable", hs.hosts_unreachable));
|
|
perfdata->Add(new PerfdataValue("num_hosts_flapping", hs.hosts_flapping));
|
|
perfdata->Add(new PerfdataValue("num_hosts_in_downtime", hs.hosts_in_downtime));
|
|
perfdata->Add(new PerfdataValue("num_hosts_acknowledged", hs.hosts_acknowledged));
|
|
|
|
std::vector<Endpoint::Ptr> endpoints = ConfigType::GetObjectsByType<Endpoint>();
|
|
|
|
double lastMessageSent = 0;
|
|
double lastMessageReceived = 0;
|
|
double messagesSentPerSecond = 0;
|
|
double messagesReceivedPerSecond = 0;
|
|
double bytesSentPerSecond = 0;
|
|
double bytesReceivedPerSecond = 0;
|
|
|
|
for (const Endpoint::Ptr& endpoint : endpoints)
|
|
{
|
|
if (endpoint->GetLastMessageSent() > lastMessageSent)
|
|
lastMessageSent = endpoint->GetLastMessageSent();
|
|
|
|
if (endpoint->GetLastMessageReceived() > lastMessageReceived)
|
|
lastMessageReceived = endpoint->GetLastMessageReceived();
|
|
|
|
messagesSentPerSecond += endpoint->GetMessagesSentPerSecond();
|
|
messagesReceivedPerSecond += endpoint->GetMessagesReceivedPerSecond();
|
|
bytesSentPerSecond += endpoint->GetBytesSentPerSecond();
|
|
bytesReceivedPerSecond += endpoint->GetBytesReceivedPerSecond();
|
|
}
|
|
|
|
perfdata->Add(new PerfdataValue("last_messages_sent", lastMessageSent));
|
|
perfdata->Add(new PerfdataValue("last_messages_received", lastMessageReceived));
|
|
perfdata->Add(new PerfdataValue("sum_messages_sent_per_second", messagesSentPerSecond));
|
|
perfdata->Add(new PerfdataValue("sum_messages_received_per_second", messagesReceivedPerSecond));
|
|
perfdata->Add(new PerfdataValue("sum_bytes_sent_per_second", bytesSentPerSecond));
|
|
perfdata->Add(new PerfdataValue("sum_bytes_received_per_second", bytesReceivedPerSecond));
|
|
|
|
cr->SetPerformanceData(perfdata);
|
|
cr->SetState(ServiceOK);
|
|
|
|
String appVersion = Application::GetAppVersion();
|
|
|
|
String output = "Icinga 2 has been running for " + Utility::FormatDuration(uptime) +
|
|
". Version: " + appVersion;
|
|
|
|
/* Indicate a warning if the last reload failed. */
|
|
double lastReloadFailed = Application::GetLastReloadFailed();
|
|
|
|
if (lastReloadFailed > 0) {
|
|
output += "; Last reload attempt failed at " + Utility::FormatDateTime("%Y-%m-%d %H:%M:%S %z", lastReloadFailed);
|
|
cr->SetState(ServiceWarning);
|
|
}
|
|
|
|
/* Indicate a warning when the last synced config caused a stage validation error. */
|
|
ApiListener::Ptr listener = ApiListener::GetInstance();
|
|
|
|
if (listener) {
|
|
Dictionary::Ptr validationResult = listener->GetLastFailedZonesStageValidation();
|
|
|
|
if (validationResult) {
|
|
output += "; Last zone sync stage validation failed at "
|
|
+ Utility::FormatDateTime("%Y-%m-%d %H:%M:%S %z", validationResult->Get("ts"));
|
|
|
|
cr->SetState(ServiceWarning);
|
|
}
|
|
}
|
|
|
|
/* Extract the version number of the running Icinga2 instance.
|
|
* We assume that appVersion will allways be something like 'v2.10.1-8-gaebe6da' and we want to extract '2.10.1'.
|
|
*/
|
|
int endOfVersionNumber = appVersion.FindFirstOf("-") - 1;
|
|
String parsedAppVersion = appVersion.SubStr(1, endOfVersionNumber);
|
|
|
|
/* Return an error if the version is less than specified (optional). */
|
|
if (missingIcingaMinVersion.IsEmpty() && !icingaMinVersion.IsEmpty() && Utility::CompareVersion(icingaMinVersion, parsedAppVersion) < 0) {
|
|
output += "; Minimum version " + icingaMinVersion + " is not installed.";
|
|
cr->SetState(ServiceCritical);
|
|
}
|
|
|
|
cr->SetOutput(output);
|
|
|
|
checkable->ProcessCheckResult(cr);
|
|
}
|