Index: src/libchcore/TWriteBufferQueueWrapper.h =================================================================== diff -u -N -rda7737de7046ba0ecd255240fb36b4a46584ebf2 -rb941384e121190b6107f1c99b3233667e3daf4ce --- src/libchcore/TWriteBufferQueueWrapper.h (.../TWriteBufferQueueWrapper.h) (revision da7737de7046ba0ecd255240fb36b4a46584ebf2) +++ src/libchcore/TWriteBufferQueueWrapper.h (.../TWriteBufferQueueWrapper.h) (revision b941384e121190b6107f1c99b3233667e3daf4ce) @@ -32,6 +32,7 @@ { public: TWriteBufferQueueWrapper(const TOrderedBufferQueuePtr& spQueue); + ~TWriteBufferQueueWrapper(); void Push(TOverlappedDataBuffer* pBuffer, bool /*bKeepPosition*/) { Push(pBuffer); } void Push(TOverlappedDataBuffer* pBuffer); @@ -46,10 +47,13 @@ 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 TEvent m_eventHasBuffers;