tyler.durden/icinga2
1
0
Fork 0
mirror of https://github.com/Icinga/icinga2.git synced 2025-09-25 18:48:50 +02:00
Code Issues Packages Projects Releases Wiki Activity

WIP

Browse Source
This commit is contained in:
Noah Hilverling 2020-11-12 11:53:02 +01:00
parent 6535f064fe
commit 60b665c1fc
2 changed files with 13 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
lib/remote/apilistener.cpp
View File

@ -856,13 +856,21 @@ void ApiListener::ApiTimerHandler()
} }
for (const Endpoint::Ptr& endpoint : ConfigType::GetObjectsByType<Endpoint>()) { for (const Endpoint::Ptr& endpoint : ConfigType::GetObjectsByType<Endpoint>()) {
if (!endpoint->GetConnected()) Log(LogCritical, "LOG-POSITION")
<< "Checking endpoint '" << endpoint->GetName() << "'";
if (!endpoint->GetConnected()) {
Log(LogCritical, "LOG-POSITION")
<< "Endpoint '" << endpoint->GetName() << "' is not connected";
continue; continue;
}
double ts = endpoint->GetRemoteLogPosition(); double ts = endpoint->GetRemoteLogPosition();
if (ts == 0) if (ts == 0) {
Log(LogCritical, "LOG-POSITION")
<< "LocalLogPosition is 0 for endpoint '" << endpoint->GetName() << "'";
continue; continue;
}
Dictionary::Ptr lmessage = new Dictionary({ Dictionary::Ptr lmessage = new Dictionary({
{ "jsonrpc", "2.0" }, { "jsonrpc", "2.0" },

4
lib/remote/jsonrpcconnection.cpp
View File

@ -265,6 +265,8 @@ void JsonRpcConnection::MessageHandler(const String& jsonString)
if (ts < m_Endpoint->GetRemoteLogPosition()) if (ts < m_Endpoint->GetRemoteLogPosition())
return; return;
Log(LogCritical, "LOG-POSITION")
<< "SetRemoteLogPosition to '" << ts << "' for endpoint '" << m_Endpoint->GetName() << "'";
m_Endpoint->SetRemoteLogPosition(ts); m_Endpoint->SetRemoteLogPosition(ts);
} }
@ -342,7 +344,7 @@ Value SetLogPositionHandler(const MessageOrigin::Ptr& origin, const Dictionary::
endpoint->SetLocalLogPosition(log_position); endpoint->SetLocalLogPosition(log_position);
Log(LogCritical, "LOG-POSITION") Log(LogCritical, "LOG-POSITION")
<< "Got SetLogPosition with timestamp '" << log_position << "' from endpoint '" << endpoint->GetName() << "'"; << "Got SetLocalLogPosition with timestamp '" << log_position << "' from endpoint '" << endpoint->GetName() << "'";
return Empty; return Empty;
} }