mirror of https://github.com/Icinga/icinga2.git
ElasticsearchWriter#Pause(): call Flush() only once
The first Flush() is redundant and may access m_DataBuffer at the same time as some Flush() in m_WorkQueue (race condition) which isn't joined, yet.
This commit is contained in:
parent
a2926b8604
commit
d5e6ecec8a
|
@ -118,8 +118,6 @@ void ElasticsearchWriter::Pause()
|
||||||
m_HandleNotifications.disconnect();
|
m_HandleNotifications.disconnect();
|
||||||
|
|
||||||
m_FlushTimer->Stop(true);
|
m_FlushTimer->Stop(true);
|
||||||
|
|
||||||
Flush();
|
|
||||||
m_WorkQueue.Join();
|
m_WorkQueue.Join();
|
||||||
Flush();
|
Flush();
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue