Index: src/libchcore/TWriteBufferQueueWrapper.cpp
===================================================================
diff -u -N -rb051cbac8dac8c448507aa7c64753af9cf793af5 -rc719644bb4360fcf7ccf6f1139bcae852bd6effd
--- src/libchcore/TWriteBufferQueueWrapper.cpp	(.../TWriteBufferQueueWrapper.cpp)	(revision b051cbac8dac8c448507aa7c64753af9cf793af5)
+++ src/libchcore/TWriteBufferQueueWrapper.cpp	(.../TWriteBufferQueueWrapper.cpp)	(revision c719644bb4360fcf7ccf6f1139bcae852bd6effd)
@@ -32,12 +32,12 @@
 
 		UpdateHasBuffers();
 
-		m_emptyBuffersQueueConnector = m_spDataQueue->GetNotifier().connect(boost::bind(&TWriteBufferQueueWrapper::UpdateHasBuffers, this, _1));
+		m_dataQueueConnector = m_spDataQueue->GetNotifier().connect(boost::bind(&TWriteBufferQueueWrapper::UpdateHasBuffers, this, _1));
 	}
 
 	TWriteBufferQueueWrapper::~TWriteBufferQueueWrapper()
 	{
-		m_emptyBuffersQueueConnector.disconnect();
+		m_dataQueueConnector.disconnect();
 	}
 
 	void TWriteBufferQueueWrapper::Push(TOverlappedDataBuffer* pBuffer)
@@ -95,7 +95,7 @@
 
 	void TWriteBufferQueueWrapper::UpdateHasBuffers(bool bDataQueueHasPoppableBuffer)
 	{
-		bool bIsReady = bDataQueueHasPoppableBuffer || !m_tRetryBuffers.empty();
+		bool bIsReady = bDataQueueHasPoppableBuffer || !m_tRetryBuffers.IsEmpty();
 		m_eventHasBuffers.SetEvent(bIsReady);
 	}