Index: src/libchcore/TOverlappedWriterFB.h
===================================================================
diff -u -N -r7892d3d5ca43da7dca4d9e8e0c321c21c3e13ea0 -r3d7d129eda4a42e9f9318ae6b6f3b873dc9290d4
--- src/libchcore/TOverlappedWriterFB.h	(.../TOverlappedWriterFB.h)	(revision 7892d3d5ca43da7dca4d9e8e0c321c21c3e13ea0)
+++ src/libchcore/TOverlappedWriterFB.h	(.../TOverlappedWriterFB.h)	(revision 3d7d129eda4a42e9f9318ae6b6f3b873dc9290d4)
@@ -23,6 +23,7 @@
 #include "TFilesystemFileFeedbackWrapper.h"
 #include "TOverlappedProcessorRange.h"
 #include "TThreadedQueueRunner.h"
+#include "TEventCounter.h"
 
 namespace chcore
 {
@@ -65,6 +66,8 @@
 		HANDLE GetEventWritingFinishedHandle() const;
 		HANDLE GetEventProcessingFinishedHandle() const;
 
+		void QueueProcessedBuffer(TOverlappedDataBuffer* pBuffer);
+
 	private:
 		void AdjustProcessedSize(file_size_t fsWritten);
 		TSubTaskBase::ESubOperationResult AdjustFinalSize();
@@ -81,6 +84,8 @@
 		TEvent m_eventProcessingFinished;
 		TEvent m_eventWritingFinished;
 
+		TEventCounter<unsigned int, EEventCounterMode::eSetIfEqual, 0> m_counterOnTheFly;
+
 		TWorkerThreadController& m_rThreadController;
 		TSubTaskBase::ESubOperationResult m_eThreadResult = TSubTaskBase::eSubResult_Continue;
 	};