tyler.durden/icinga2
1
0
Fork 0
mirror of https://github.com/Icinga/icinga2.git synced 2025-04-08 17:05:25 +02:00
Code Issues Packages Projects Releases Wiki Activity

ElasticsearchWriter#Pause(): lock m_DataBufferMutex during Flush()

Browse Source 
just to be sure regarding race conditions.
This commit is contained in:
Alexander Aleksandrovič Klimov 2023-06-30 14:57:18 +02:00 committed by Alexander A. Klimov
parent 73f8c4473e
commit 8dca4d7121
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
lib/perfdata/elasticsearchwriter.cpp
View File

@ -118,7 +118,11 @@ void ElasticsearchWriter::Pause()
m_HandleNotifications.disconnect();
m_WorkQueue.Join();
Flush();
{
std::unique_lock<std::mutex> lock (m_DataBufferMutex);
Flush();
}
Log(LogInformation, "ElasticsearchWriter")
<< "'" << GetName() << "' paused.";