From: Gunnar Beutner <gunnar.beutner@netways.de>
Date: Fri, 6 Sep 2013 07:59:16 +0000 (+0200)
Subject: cluster: Speed up log replays.
X-Git-Tag: v0.0.3~597
X-Git-Url: https://granicus.if.org/sourcecode?a=commitdiff_plain;h=2daa2cae854d3f298be59af24acef2fe97468224;p=icinga2

cluster: Speed up log replays.
---

diff --git a/components/cluster/clustercomponent.cpp b/components/cluster/clustercomponent.cpp
index 8f6d0779a..b3c5e4ecb 100644
--- a/components/cluster/clustercomponent.cpp
+++ b/components/cluster/clustercomponent.cpp
@@ -221,7 +221,7 @@ void ClusterComponent::RelayMessage(const Endpoint::Ptr& except, const Dictionar
 		if (except)
 			pmessage->Set("except", except->GetName());
 
-		pmessage->Set("message", message);
+		pmessage->Set("message", Value(message).Serialize());
 
 		ObjectLock olock(this);
 		if (m_LogFile) {
@@ -360,8 +360,7 @@ void ClusterComponent::ReplayLog(const Endpoint::Ptr& endpoint, const Stream::Pt
 			if (pmessage->Get("except") == endpoint->GetName())
 				continue;
 
-			String json = Value(pmessage->Get("message")).Serialize();
-			NetString::WriteStringToStream(stream, json);
+			NetString::WriteStringToStream(stream, pmessage->Get("message"));
 			count++;
 		}