Index: src/libchcore/TReadBufferQueueWrapper.cpp
===================================================================
diff -u -N -ra1f5b3d99f2f175b102d81379698ea1f08e42cce -rf1d25f23712f5de7459f690ab51b2640d0f81b91
--- src/libchcore/TReadBufferQueueWrapper.cpp	(.../TReadBufferQueueWrapper.cpp)	(revision a1f5b3d99f2f175b102d81379698ea1f08e42cce)
+++ src/libchcore/TReadBufferQueueWrapper.cpp	(.../TReadBufferQueueWrapper.cpp)	(revision f1d25f23712f5de7459f690ab51b2640d0f81b91)
@@ -165,4 +165,11 @@
 	{
 		m_tRetryBuffers.ReleaseBuffers(m_spEmptyBuffers);
 	}
+
+	void TReadBufferQueueWrapper::UpdateProcessingRange(unsigned long long ullNewPosition)
+	{
+		if(!m_tRetryBuffers.empty())
+			throw TCoreException(eErr_InvalidData, L"Cannot update processing range when processing already started", LOCATION);
+		m_ullNextReadPosition = ullNewPosition;
+	}
 }