Index: src/libchcore/TOverlappedWriter.h =================================================================== diff -u -N -ra1f5b3d99f2f175b102d81379698ea1f08e42cce -rf1d25f23712f5de7459f690ab51b2640d0f81b91 --- src/libchcore/TOverlappedWriter.h (.../TOverlappedWriter.h) (revision a1f5b3d99f2f175b102d81379698ea1f08e42cce) +++ src/libchcore/TOverlappedWriter.h (.../TOverlappedWriter.h) (revision f1d25f23712f5de7459f690ab51b2640d0f81b91) @@ -24,14 +24,15 @@ #include "TOrderedBufferQueue.h" #include "TWriteBufferQueueWrapper.h" #include "TBufferList.h" +#include "TOverlappedProcessorRange.h" namespace chcore { class TOverlappedWriter { public: explicit TOverlappedWriter(const logger::TLogFileDataPtr& spLogFileData, const TOrderedBufferQueuePtr& spBuffersToWrite, - unsigned long long ullFilePos, const TBufferListPtr& spEmptyBuffers); + const TOverlappedProcessorRangePtr& spRange, const TBufferListPtr& spEmptyBuffers); TOverlappedWriter(const TOverlappedWriter&) = delete; ~TOverlappedWriter(); @@ -57,6 +58,8 @@ HANDLE GetEventWriteFailedHandle() const; HANDLE GetEventWriteFinishedHandle() const; + void UpdateProcessingRange(unsigned long long ullNewPosition); + private: logger::TLoggerPtr m_spLog; @@ -66,6 +69,8 @@ TOrderedBufferQueue m_tFinishedBuffers; TOverlappedDataBuffer* m_pLastPartBuffer = nullptr; + + boost::signals2::connection m_dataRangeChanged; }; using TOverlappedWriterPtr = std::shared_ptr;