Index: src/libchcore/TWriteBufferQueueWrapper.cpp
===================================================================
diff -u -N -r10d42e85d810f6da082cb2ce4415dcb72903410e -rb051cbac8dac8c448507aa7c64753af9cf793af5
--- src/libchcore/TWriteBufferQueueWrapper.cpp	(.../TWriteBufferQueueWrapper.cpp)	(revision 10d42e85d810f6da082cb2ce4415dcb72903410e)
+++ src/libchcore/TWriteBufferQueueWrapper.cpp	(.../TWriteBufferQueueWrapper.cpp)	(revision b051cbac8dac8c448507aa7c64753af9cf793af5)
@@ -87,6 +87,12 @@
 		return m_eventHasBuffers.Handle();
 	}
 
+	void TWriteBufferQueueWrapper::ClearBuffers(const TBufferListPtr& spEmptyBuffers)
+	{
+		m_spDataQueue->ClearBuffers(spEmptyBuffers);
+		m_tRetryBuffers.ClearBuffers(spEmptyBuffers);
+	}
+
 	void TWriteBufferQueueWrapper::UpdateHasBuffers(bool bDataQueueHasPoppableBuffer)
 	{
 		bool bIsReady = bDataQueueHasPoppableBuffer || !m_tRetryBuffers.empty();