mirror of
https://github.com/Icinga/icinga2.git
synced 2026-02-03 20:40:17 -05:00
2366df6057
The previous implementation assumed that every version number will have 5 characters. With the release of 2.10.0 this does not work anymore. The new implementation extracts everything from the second character to the first dash. This should work as long as the version string is in a format like 'v2.10.1-8-gaebe6da'. fixes Icinga#6703
191 lines
9.6 KiB
C++
191 lines
9.6 KiB
C++
/******************************************************************************
|
|
* Icinga 2 *
|
|
* Copyright (C) 2012-2018 Icinga Development Team (https://icinga.com/) *
|
|
* *
|
|
* This program is free software; you can redistribute it and/or *
|
|
* modify it under the terms of the GNU General Public License *
|
|
* as published by the Free Software Foundation; either version 2 *
|
|
* of the License, or (at your option) any later version. *
|
|
* *
|
|
* This program is distributed in the hope that it will be useful, *
|
|
* but WITHOUT ANY WARRANTY; without even the implied warranty of *
|
|
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the *
|
|
* GNU General Public License for more details. *
|
|
* *
|
|
* You should have received a copy of the GNU General Public License *
|
|
* along with this program; if not, write to the Free Software Foundation *
|
|
* Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301, USA. *
|
|
******************************************************************************/
|
|
|
|
#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 "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);
|
|
}
|
|
|
|
/* 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);
|
|
}
|