From 8470facfe2d8437d5db75e4f84434991d30032c7 Mon Sep 17 00:00:00 2001
From: "Alexander A. Klimov" <alexander.klimov@icinga.com>
Date: Tue, 8 Jan 2019 18:15:32 +0100
Subject: [PATCH] InfluxdbWriter#Stop(): flush buffer

refs #6841
---
 lib/perfdata/influxdbwriter.cpp | 8 ++++++++
 lib/perfdata/influxdbwriter.hpp | 1 +
 2 files changed, 9 insertions(+)

diff --git a/lib/perfdata/influxdbwriter.cpp b/lib/perfdata/influxdbwriter.cpp
index 91fb1be10..80d050233 100644
--- a/lib/perfdata/influxdbwriter.cpp
+++ b/lib/perfdata/influxdbwriter.cpp
@@ -140,6 +140,14 @@ void InfluxdbWriter::Pause()
 	ObjectImpl<InfluxdbWriter>::Pause();
 }
 
+void InfluxdbWriter::Stop(bool runtimeDeleted)
+{
+	FlushTimeout();
+	m_WorkQueue.Join();
+
+	ObjectImpl<InfluxdbWriter>::Stop(runtimeDeleted);
+}
+
 void InfluxdbWriter::AssertOnWorkQueue()
 {
 	ASSERT(m_WorkQueue.IsWorkerThread());
diff --git a/lib/perfdata/influxdbwriter.hpp b/lib/perfdata/influxdbwriter.hpp
index face44f69..370ca25c5 100644
--- a/lib/perfdata/influxdbwriter.hpp
+++ b/lib/perfdata/influxdbwriter.hpp
@@ -51,6 +51,7 @@ protected:
 	void OnConfigLoaded() override;
 	void Resume() override;
 	void Pause() override;
+	void Stop(bool runtimeDeleted) override;
 
 private:
 	WorkQueue m_WorkQueue{10000000, 1};
-- 
2.40.0