███████████: addition to prev. revision [#CONV-2546].

dbms/include/DB/IO/CompressedWriteBuffer.h

@@ -71,7 +71,7 @@ public:
 
 		try
 		{
-			nextImpl();
+			next();
 		}
 		catch (...)
 		{

dbms/include/DB/IO/RemoteWriteBuffer.h

@@ -93,7 +93,7 @@ public:
 
 		try
 		{
-			nextImpl();
+			next();
 
 			Poco::Net::HTTPResponse response;
 			std::istream & istr = session.receiveResponse(response);

dbms/include/DB/IO/WriteBuffer.h

@@ -31,11 +31,24 @@ public:
 		if (!offset())
 			return;
 		bytes += offset();
-		nextImpl();
+
+		try
+		{
+			nextImpl();
+		}
+		catch (...)
+		{
+			/** Если вызов nextImpl() был неудачным, то переместим курсор в начало,
+			  * чтобы потом (например, при развёртке стека) не было второй попытки записать данные.
+			  */
+			pos = working_buffer.begin();
+			throw;
+		}
+		
 		pos = working_buffer.begin();
 	}
 
-	/** желательно в наследниках поместить в деструктор вызов nextImpl(),
+	/** желательно в наследниках поместить в деструктор вызов next(),
 	  * чтобы последние данные записались
 	  */
 	virtual ~WriteBuffer() {}

dbms/include/DB/IO/WriteBufferFromFileDescriptor.h

@@ -53,7 +53,7 @@ public:
 
 		try
 		{
-			nextImpl();
+			next();
 		}
 		catch (...)
 		{

dbms/include/DB/IO/WriteBufferFromOStream.h

@@ -39,7 +39,7 @@ public:
 
 		try
 		{
-			nextImpl();
+			next();
 		}
 		catch (...)
 		{