Index: src/libchcore/TWriteBufferQueueWrapper.h =================================================================== diff -u -N -racd7bcfa7355db4a0d9af99a1bb99d685810d790 -ra1f5b3d99f2f175b102d81379698ea1f08e42cce --- src/libchcore/TWriteBufferQueueWrapper.h (.../TWriteBufferQueueWrapper.h) (revision acd7bcfa7355db4a0d9af99a1bb99d685810d790) +++ src/libchcore/TWriteBufferQueueWrapper.h (.../TWriteBufferQueueWrapper.h) (revision a1f5b3d99f2f175b102d81379698ea1f08e42cce) @@ -34,26 +34,23 @@ explicit TWriteBufferQueueWrapper(const TOrderedBufferQueuePtr& spQueue); ~TWriteBufferQueueWrapper(); - void Push(TOverlappedDataBuffer* pBuffer, bool /*bKeepPosition*/) { Push(pBuffer); } void Push(TOverlappedDataBuffer* pBuffer); TOverlappedDataBuffer* Pop(); size_t GetCount() const; HANDLE GetHasBuffersEvent() const; - void ReleaseBuffers(const TBufferListPtr& spBuffers); private: bool IsBufferReady() const; void UpdateHasBuffers(); - void UpdateHasBuffers(bool /*bAdded*/) { UpdateHasBuffers(); } TOverlappedDataBuffer* InternalPop(); private: TOrderedBufferQueuePtr m_spDataQueue; // external queue of buffers to use boost::signals2::connection m_emptyBuffersQueueConnector; - TSimpleOrderedBufferQueue m_tClaimedQueue; // internal queue of claimed buffers + TSimpleOrderedBufferQueue m_tRetryBuffers; // internal queue of claimed buffers TEvent m_eventHasBuffers; };