From a7142252fa375aae2f88f88443e348081fad634f Mon Sep 17 00:00:00 2001
From: Michael Friedrich <michael.friedrich@netways.de>
Date: Thu, 4 Feb 2016 11:30:27 +0100
Subject: [PATCH] Ensure that config sync updates are always sent on reconnect

fixes #11083
---
 lib/remote/apilistener.cpp | 30 ++++++++++++++++++++----------
 lib/remote/apilistener.hpp |  2 +-
 2 files changed, 21 insertions(+), 11 deletions(-)

diff --git a/lib/remote/apilistener.cpp b/lib/remote/apilistener.cpp
index 338d1c869..32c3499bd 100644
--- a/lib/remote/apilistener.cpp
+++ b/lib/remote/apilistener.cpp
@@ -333,11 +333,6 @@ void ApiListener::NewClientHandlerInternal(const Socket::Ptr& client, const Stri
 		    << "New client connection (no client certificate)";
 	}
 
-	bool need_sync = false;
-
-	if (endpoint)
-		need_sync = !endpoint->GetConnected();
-
 	ClientType ctype;
 
 	if (role == RoleClient) {
@@ -371,10 +366,11 @@ void ApiListener::NewClientHandlerInternal(const Socket::Ptr& client, const Stri
 		aclient->Start();
 
 		if (endpoint) {
+			bool needSync = !endpoint->GetConnected();
+
 			endpoint->AddClient(aclient);
 
-			if (need_sync)
-				m_SyncQueue.Enqueue(boost::bind(&ApiListener::SyncClient, this, aclient, endpoint));
+			m_SyncQueue.Enqueue(boost::bind(&ApiListener::SyncClient, this, aclient, endpoint, needSync));
 		} else
 			AddAnonymousClient(aclient);
 	} else {
@@ -386,7 +382,7 @@ void ApiListener::NewClientHandlerInternal(const Socket::Ptr& client, const Stri
 	}
 }
 
-void ApiListener::SyncClient(const JsonRpcConnection::Ptr& aclient, const Endpoint::Ptr& endpoint)
+void ApiListener::SyncClient(const JsonRpcConnection::Ptr& aclient, const Endpoint::Ptr& endpoint, bool needSync)
 {
 	try {
 		{
@@ -395,8 +391,12 @@ void ApiListener::SyncClient(const JsonRpcConnection::Ptr& aclient, const Endpoi
 			endpoint->SetSyncing(true);
 		}
 
+		/* Make sure that the config updates are synced
+		 * before the logs are replayed.
+		 */
+
 		Log(LogInformation, "ApiListener")
-		    << "Sending updates for endpoint '" << endpoint->GetName() << "'.";
+		    << "Sending config updates for endpoint '" << endpoint->GetName() << "'.";
 
 		/* sync zone file config */
 		SendConfigUpdate(aclient);
@@ -404,9 +404,19 @@ void ApiListener::SyncClient(const JsonRpcConnection::Ptr& aclient, const Endpoi
 		SendRuntimeConfigObjects(aclient);
 
 		Log(LogInformation, "ApiListener")
-		    << "Finished sending updates for endpoint '" << endpoint->GetName() << "'.";
+		    << "Finished sending config updates for endpoint '" << endpoint->GetName() << "'.";
+
+		if (!needSync)
+			return;
+
+		Log(LogInformation, "ApiListener")
+		    << "Sending replay log for endpoint '" << endpoint->GetName() << "'.";
 
 		ReplayLog(aclient);
+
+		Log(LogInformation, "ApiListener")
+		    << "Finished sending replay log for endpoint '" << endpoint->GetName() << "'.";
+
 	} catch (const std::exception& ex) {
 		Log(LogCritical, "ApiListener")
 		    << "Error while syncing endpoint '" << endpoint->GetName() << "': " << DiagnosticInformation(ex);
diff --git a/lib/remote/apilistener.hpp b/lib/remote/apilistener.hpp
index bfc2f2d7a..4c860f89b 100644
--- a/lib/remote/apilistener.hpp
+++ b/lib/remote/apilistener.hpp
@@ -156,7 +156,7 @@ private:
 	    const JsonRpcConnection::Ptr& client = JsonRpcConnection::Ptr());
 	void SendRuntimeConfigObjects(const JsonRpcConnection::Ptr& aclient);
 
-	void SyncClient(const JsonRpcConnection::Ptr& aclient, const Endpoint::Ptr& endpoint);
+	void SyncClient(const JsonRpcConnection::Ptr& aclient, const Endpoint::Ptr& endpoint, bool needSync);
 };
 
 }
-- 
2.40.0