tyler.durden/icinga2
1
0
Fork 0
mirror of https://github.com/Icinga/icinga2.git synced 2025-07-25 06:34:42 +02:00
Code Issues Packages Projects Releases Wiki Activity

Show slave lag for the cluster-zone check

Browse Source 
fixes #8515
This commit is contained in:
Gunnar Beutner 2015-02-24 09:14:17 +01:00
parent 5ceb64d649
commit f4c7d945e2
1 changed files with 14 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
lib/methods/clusterzonechecktask.cpp
View File

@ -20,10 +20,12 @@
#include "methods/clusterzonechecktask.hpp" #include "methods/clusterzonechecktask.hpp"
#include "icinga/checkcommand.hpp" #include "icinga/checkcommand.hpp"
#include "icinga/macroprocessor.hpp" #include "icinga/macroprocessor.hpp"
#include "icinga/perfdatavalue.hpp"
#include "remote/apilistener.hpp" #include "remote/apilistener.hpp"
#include "remote/endpoint.hpp" #include "remote/endpoint.hpp"
#include "remote/zone.hpp" #include "remote/zone.hpp"
#include "base/function.hpp" #include "base/function.hpp"
#include "base/convert.hpp"
#include <boost/foreach.hpp> #include <boost/foreach.hpp>
using namespace icinga; using namespace icinga;
@ -79,8 +81,14 @@ void ClusterZoneCheckTask::ScriptFunc(const Checkable::Ptr& checkable, const Che
} }
bool connected = false; bool connected = false;
double lag = 0;
BOOST_FOREACH(const Endpoint::Ptr& endpoint, zone->GetEndpoints()) { BOOST_FOREACH(const Endpoint::Ptr& endpoint, zone->GetEndpoints()) {
double eplag = Utility::GetTime() - endpoint->GetRemoteLogPosition();
if (eplag > lag)
lag = eplag;
if (endpoint->IsConnected()) { if (endpoint->IsConnected()) {
connected = true; connected = true;
break; break;
@ -89,11 +97,15 @@ void ClusterZoneCheckTask::ScriptFunc(const Checkable::Ptr& checkable, const Che
if (!connected) { if (!connected) {
cr->SetState(ServiceCritical); cr->SetState(ServiceCritical);
cr->SetOutput("Zone '" + zoneName + "' is not connected."); cr->SetOutput("Zone '" + zoneName + "' is not connected. Log lag: " + Convert::ToString(lag));
} else { } else {
cr->SetState(ServiceOK); cr->SetState(ServiceOK);
cr->SetOutput("Zone '" + zoneName + "' is connected."); cr->SetOutput("Zone '" + zoneName + "' is connected. Log lag: " + Convert::ToString(lag));
} }
Array::Ptr perfdata = new Array();
perfdata->Add(new PerfdataValue("slave_lag", lag));
cr->SetPerformanceData(perfdata);
checkable->ProcessCheckResult(cr); checkable->ProcessCheckResult(cr);
} }