Index: src/libchcore/TOrderedBufferQueue.h =================================================================== diff -u -N -racd7bcfa7355db4a0d9af99a1bb99d685810d790 -ra1f5b3d99f2f175b102d81379698ea1f08e42cce --- src/libchcore/TOrderedBufferQueue.h (.../TOrderedBufferQueue.h) (revision acd7bcfa7355db4a0d9af99a1bb99d685810d790) +++ src/libchcore/TOrderedBufferQueue.h (.../TOrderedBufferQueue.h) (revision a1f5b3d99f2f175b102d81379698ea1f08e42cce) @@ -54,7 +54,7 @@ void ReleaseBuffers(const TBufferListPtr& spBuffers); - boost::signals2::signal& GetNotifier(); + boost::signals2::signal& GetNotifier(); private: void UpdateHasBuffers(); @@ -72,7 +72,7 @@ unsigned long long m_ullExpectedBufferPosition = 0; - boost::signals2::signal m_notifier; + boost::signals2::signal m_notifier; }; template @@ -97,15 +97,15 @@ { // if there is no ptr set then it is being processed somewhere and will be handled separately m_pFirstErrorBuffer->SetErrorCode(ERROR_SUCCESS); - rRetryQueue.Push(m_pFirstErrorBuffer, true); + rRetryQueue.Push(m_pFirstErrorBuffer); } m_pFirstErrorBuffer = pBuffer; m_ullErrorPosition = pBuffer->GetFilePosition(); } else if(pBuffer->GetFilePosition() > m_ullErrorPosition) { pBuffer->SetErrorCode(ERROR_SUCCESS); - rRetryQueue.Push(pBuffer, true); + rRetryQueue.Push(pBuffer); } else if(!m_pFirstErrorBuffer) m_pFirstErrorBuffer = pBuffer; // restore the buffer