From 1b31ced475080a1a4e1651b8a8c1739271b245d0 Mon Sep 17 00:00:00 2001 From: Gunnar Beutner Date: Tue, 3 Sep 2013 11:00:57 +0200 Subject: [PATCH] cluster: Fix crash bug. --- components/cluster/clustercomponent.cpp | 18 ++++++++++-------- 1 file changed, 10 insertions(+), 8 deletions(-) diff --git a/components/cluster/clustercomponent.cpp b/components/cluster/clustercomponent.cpp index 7edc099b8..31efc8d17 100644 --- a/components/cluster/clustercomponent.cpp +++ b/components/cluster/clustercomponent.cpp @@ -215,14 +215,16 @@ void ClusterComponent::RelayMessage(const Endpoint::Ptr& except, const Dictionar pmessage->Set("message", message); ObjectLock olock(this); - String json = Value(pmessage).Serialize(); - NetString::WriteStringToStream(m_LogFile, json); - m_LogMessageCount++; - m_LogMessageTimestamp = ts; - - if (m_LogMessageCount > 250000) { - CloseLogFile(); - OpenLogFile(); + if (m_LogFile) { + String json = Value(pmessage).Serialize(); + NetString::WriteStringToStream(m_LogFile, json); + m_LogMessageCount++; + m_LogMessageTimestamp = ts; + + if (m_LogMessageCount > 250000) { + CloseLogFile(); + OpenLogFile(); + } } } -- 2.40.0