InfluxdbWriter#Stop(): flush buffer

refs #6841

diff --git a/lib/perfdata/influxdbwriter.cpp b/lib/perfdata/influxdbwriter.cpp
index 91fb1be10ae8f6d432a21dbcaed9ddd04a7bd85a..80d05023364891b0eac245b99c31128a0373ac97 100644 (file)
--- 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 face44f69a32012907b99f19801e0790e730f947..370ca25c5e110a56f26104b3619988116c8d6bad 100644 (file)
--- 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};