Index: src/libchcore/TOverlappedReaderFB.h =================================================================== diff -u -N -r7892d3d5ca43da7dca4d9e8e0c321c21c3e13ea0 -r3d7d129eda4a42e9f9318ae6b6f3b873dc9290d4 --- src/libchcore/TOverlappedReaderFB.h (.../TOverlappedReaderFB.h) (revision 7892d3d5ca43da7dca4d9e8e0c321c21c3e13ea0) +++ src/libchcore/TOverlappedReaderFB.h (.../TOverlappedReaderFB.h) (revision 3d7d129eda4a42e9f9318ae6b6f3b873dc9290d4) @@ -22,8 +22,8 @@ #include "TOverlappedReader.h" #include "TFilesystemFileFeedbackWrapper.h" #include "TOverlappedProcessorRange.h" -#include #include "TThreadedQueueRunner.h" +#include "TEventCounter.h" namespace chcore { @@ -60,6 +60,8 @@ HANDLE GetEventReadingFinishedHandle() const; HANDLE GetEventProcessingFinishedHandle() const; + void QueueProcessedBuffer(TOverlappedDataBuffer* pBuffer); + private: TSubTaskBase::ESubOperationResult UpdateFileStats(); @@ -73,10 +75,12 @@ TEvent m_eventReadingFinished; TEvent m_eventProcessingFinished; + TEventCounter m_counterOnTheFly; + IFilesystemPtr m_spFilesystem; + TFileInfoPtr m_spSrcFileInfo; TFilesystemFileFeedbackWrapperPtr m_spSrcFile; TSubTaskStatsInfoPtr m_spStats; - TFileInfoPtr m_spSrcFileInfo; TWorkerThreadController& m_rThreadController; TSubTaskBase::ESubOperationResult m_eThreadResult = TSubTaskBase::eSubResult_Continue;