Also apply buffer flush fix for Elasticsearch feature

This commit is contained in:
Michael Friedrich 2019-03-27 11:35:41 +01:00
parent cb3729bc6a
commit 06eacd13ab
1 changed files with 4 additions and 0 deletions

View File

@ -398,6 +398,10 @@ void ElasticsearchWriter::FlushTimeout()
void ElasticsearchWriter::Flush()
{
/* Flush can be called from 1) Timeout 2) Threshold 3) on shutdown/reload. */
if (m_DataBuffer.empty())
return;
/* Ensure you hold a lock against m_DataBuffer so that things
* don't go missing after creating the body and clearing the buffer.
*/