Ensure staging flag is not unset

This commit is contained in:
Martchus 2021-04-28 22:19:10 +02:00
parent a96ba707cd
commit 6101eaa6b6
1 changed files with 2 additions and 1 deletions

View File

@ -179,7 +179,8 @@ void BatchProcessingSession::enableStagingInNextBatch()
m_enableStagingInNextBatch = true;
if (!m_stagingEnabled) {
std::lock_guard<std::mutex> lock(m_mutex);
m_stagingEnabled = m_batchIterator != m_batchEnd && m_batchIterator != m_batchBegin && m_packageIterator == m_batchIterator->begin();
m_stagingEnabled
= m_stagingEnabled || (m_batchIterator != m_batchEnd && m_batchIterator != m_batchBegin && m_packageIterator == m_batchIterator->begin());
}
}