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

cluster: Speed up log replays.

Browse Source
This commit is contained in:
Gunnar Beutner 2013-09-06 09:59:16 +02:00
parent 0755d1b9d1
commit 2daa2cae85
1 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
components/cluster/clustercomponent.cpp
View File

@ -221,7 +221,7 @@ void ClusterComponent::RelayMessage(const Endpoint::Ptr& except, const Dictionar
if (except) if (except)
pmessage->Set("except", except->GetName()); pmessage->Set("except", except->GetName());
pmessage->Set("message", message); pmessage->Set("message", Value(message).Serialize());
ObjectLock olock(this); ObjectLock olock(this);
if (m_LogFile) { if (m_LogFile) {
@ -360,8 +360,7 @@ void ClusterComponent::ReplayLog(const Endpoint::Ptr& endpoint, const Stream::Pt
if (pmessage->Get("except") == endpoint->GetName()) if (pmessage->Get("except") == endpoint->GetName())
continue; continue;
String json = Value(pmessage->Get("message")).Serialize(); NetString::WriteStringToStream(stream, pmessage->Get("message"));
NetString::WriteStringToStream(stream, json);
count++; count++;
} }