mirror of https://github.com/Icinga/icinga2.git
Revert "InfluxdbWriter#Stop(): flush buffer"
This reverts commit 8470facfe2
.
This commit is contained in:
parent
5da1cbd096
commit
7b2b45b503
|
@ -140,14 +140,6 @@ void InfluxdbWriter::Pause()
|
||||||
ObjectImpl<InfluxdbWriter>::Pause();
|
ObjectImpl<InfluxdbWriter>::Pause();
|
||||||
}
|
}
|
||||||
|
|
||||||
void InfluxdbWriter::Stop(bool runtimeDeleted)
|
|
||||||
{
|
|
||||||
FlushTimeout();
|
|
||||||
m_WorkQueue.Join();
|
|
||||||
|
|
||||||
ObjectImpl<InfluxdbWriter>::Stop(runtimeDeleted);
|
|
||||||
}
|
|
||||||
|
|
||||||
void InfluxdbWriter::AssertOnWorkQueue()
|
void InfluxdbWriter::AssertOnWorkQueue()
|
||||||
{
|
{
|
||||||
ASSERT(m_WorkQueue.IsWorkerThread());
|
ASSERT(m_WorkQueue.IsWorkerThread());
|
||||||
|
|
|
@ -51,7 +51,6 @@ protected:
|
||||||
void OnConfigLoaded() override;
|
void OnConfigLoaded() override;
|
||||||
void Resume() override;
|
void Resume() override;
|
||||||
void Pause() override;
|
void Pause() override;
|
||||||
void Stop(bool runtimeDeleted) override;
|
|
||||||
|
|
||||||
private:
|
private:
|
||||||
WorkQueue m_WorkQueue{10000000, 1};
|
WorkQueue m_WorkQueue{10000000, 1};
|
||||||
|
|
Loading…
Reference in New Issue