Merge pull request #6882 from Icinga/bugfix/influxdb-gaps-6841

InfluxdbWriter#Stop(): flush buffer
This commit is contained in:
Michael Friedrich 2019-02-11 17:32:05 +01:00 committed by GitHub
commit 845c72f656
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 9 additions and 0 deletions

View File

@ -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());

View File

@ -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};