Index: src/libchcore/TOverlappedReaderWriter.cpp =================================================================== diff -u -N -r6e4ac7776b68464371cd8522a2a8d79fbcab3b28 -r6c41e7b3cf7711c6f5027c0c0154013f50f08e7b --- src/libchcore/TOverlappedReaderWriter.cpp (.../TOverlappedReaderWriter.cpp) (revision 6e4ac7776b68464371cd8522a2a8d79fbcab3b28) +++ src/libchcore/TOverlappedReaderWriter.cpp (.../TOverlappedReaderWriter.cpp) (revision 6c41e7b3cf7711c6f5027c0c0154013f50f08e7b) @@ -32,7 +32,6 @@ m_spMemoryPool(spMemoryPool), m_tReader(spLogFileData, spMemoryPool->GetBufferList(), ullFilePos, dwChunkSize), m_tWriter(spLogFileData, m_tReader.GetFinishedQueue(), ullFilePos), - m_bDataWritingFinished(false), m_eventAllBuffersAccountedFor(true, true) { if(!spMemoryPool) @@ -105,9 +104,6 @@ if(pBuffer) { - if (pBuffer->IsLastPart()) - m_bDataWritingFinished = true; - pBuffer->SetParam(this); UpdateAllBuffersAccountedFor(); @@ -206,6 +202,7 @@ m_tWriter.MarkAsFinalized(pBuffer); } + void TOverlappedReaderWriter::UpdateAllBuffersAccountedFor() { size_t stCurrentBuffers = m_spMemoryPool->GetAvailableBufferCount() + m_tReader.GetBufferCount() + m_tWriter.GetBufferCount();