]> granicus.if.org Git - icinga2/commitdiff
cluster: Speed up log replays.
authorGunnar Beutner <gunnar.beutner@netways.de>
Fri, 6 Sep 2013 07:59:16 +0000 (09:59 +0200)
committerGunnar Beutner <gunnar.beutner@netways.de>
Fri, 6 Sep 2013 07:59:16 +0000 (09:59 +0200)
components/cluster/clustercomponent.cpp

index 8f6d0779af5d2093f21733bad5ecd5de0ebdef4b..b3c5e4ecb42290e4bad49b29bc63b4149d5a3949 100644 (file)
@@ -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++;
                }