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::Pause(); } +void InfluxdbWriter::Stop(bool runtimeDeleted) +{ + FlushTimeout(); + m_WorkQueue.Join(); + + ObjectImpl::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};