dbms: better [#METR-9194].

dbms/include/DB/Core/Exception.h

@@ -51,6 +51,11 @@ void throwFromErrno(const std::string & s, int code = 0, int the_errno = errno);
   */
 ExceptionPtr cloneCurrentException();
 
+/** Попробовать записать исключение в лог (и забыть про него).
+  * Можно использовать в деструкторах в блоке catch (...).
+  */
+void tryLogCurrentException(const char * log_name);
+
 
 void rethrowFirstException(Exceptions & exceptions);
 

dbms/include/DB/IO/AsynchronousWriteBuffer.h

@@ -73,6 +73,7 @@ public:
 		}
 		catch (...)
 		{
+			tryLogCurrentException(__PRETTY_FUNCTION__);
 		}
 	}
 

dbms/include/DB/IO/CompressedWriteBuffer.h

@@ -126,6 +126,7 @@ public:
 		}
 		catch (...)
 		{
+			tryLogCurrentException(__PRETTY_FUNCTION__);
 		}
 
 		delete qlz_state;

dbms/include/DB/IO/HexWriteBuffer.h

@@ -43,6 +43,7 @@ public:
 		}
 		catch (...)
 		{
+			tryLogCurrentException(__PRETTY_FUNCTION__);
 		}
 	}
 };

dbms/include/DB/IO/RemoteWriteBuffer.h

@@ -162,6 +162,7 @@ public:
 		}
 		catch (...)
 		{
+			tryLogCurrentException(__PRETTY_FUNCTION__);
 		}
 	}
 

dbms/include/DB/IO/WriteBufferFromFile.h

@@ -35,6 +35,7 @@ public:
 		}
 		catch (...)
 		{
+			tryLogCurrentException(__PRETTY_FUNCTION__);
 		}
 
 		close(fd);

dbms/include/DB/IO/WriteBufferFromFileDescriptor.h

@@ -65,6 +65,7 @@ public:
 		}
 		catch (...)
 		{
+			tryLogCurrentException(__PRETTY_FUNCTION__);
 		}
 	}
 

dbms/include/DB/IO/WriteBufferFromHTTPServerResponse.h

@@ -56,6 +56,7 @@ public:
 		}
 		catch (...)
 		{
+			tryLogCurrentException(__PRETTY_FUNCTION__);
 		}
 	}
 };

dbms/include/DB/IO/WriteBufferFromOStream.h

@@ -41,6 +41,7 @@ public:
 		}
 		catch (...)
 		{
+			tryLogCurrentException(__PRETTY_FUNCTION__);
 		}
 	}
 };

dbms/include/DB/IO/WriteBufferFromPocoSocket.h

@@ -62,6 +62,7 @@ public:
 		}
 		catch (...)
 		{
+			tryLogCurrentException(__PRETTY_FUNCTION__);
 		}
 	}
 };

dbms/src/Core/Exception.cpp

@@ -1,6 +1,8 @@
 #include <errno.h>
 #include <string.h>
 
+#include <Yandex/logger_useful.h>
+
 #include <DB/IO/WriteHelpers.h>
 
 #include <DB/Core/Exception.h>
@@ -82,6 +84,49 @@ ExceptionPtr cloneCurrentException()
 }
 
 
+void tryLogCurrentException(const char * log_name)
+{
+	try
+	{
+		throw;
+	}
+	catch (const Exception & e)
+	{
+		try
+		{
+			LOG_ERROR(&Logger::get(log_name), "Code: " << e.code() << ", e.displayText() = " << e.displayText() << ", e.what() = " << e.what()
+				<< ", Stack trace:\n\n" << e.getStackTrace().toString());
+		}
+		catch (...) {}
+	}
+	catch (const Poco::Exception & e)
+	{
+		try
+		{
+			LOG_ERROR(&Logger::get(log_name), "Poco::Exception. Code: " << ErrorCodes::POCO_EXCEPTION << ", e.code() = " << e.code()
+				<< ", e.displayText() = " << e.displayText() << ", e.what() = " << e.what());
+		}
+		catch (...) {}
+	}
+	catch (const std::exception & e)
+	{
+		try
+		{
+			LOG_ERROR(&Logger::get(log_name), "std::exception. Code: " << ErrorCodes::STD_EXCEPTION << ", e.what() = " << e.what());
+		}
+		catch (...) {}
+	}
+	catch (...)
+	{
+		try
+		{
+			LOG_ERROR(&Logger::get(log_name), "Unknown exception. Code: " << ErrorCodes::UNKNOWN_EXCEPTION);
+		}
+		catch (...) {}
+	}
+}
+
+
 void rethrowFirstException(Exceptions & exceptions)
 {
 	for (size_t i = 0, size = exceptions.size(); i < size; ++i)