thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-09-20 08:40:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

dbms: attempt to fix an error [#METR-19623].

Browse Source
This commit is contained in:
Alexey Milovidov 2016-01-14 06:17:11 +03:00
parent a0a803439b
commit 2ae6e4ba77
2 changed files with 14 additions and 33 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
dbms/src/Server/TCPHandler.cpp
View File

@ -723,34 +723,16 @@ void TCPHandler::run()
LOG_INFO(log, "Done processing connection."); LOG_INFO(log, "Done processing connection.");
} }
catch (Exception & e)
{
LOG_ERROR(log, "Code: " << e.code() << ", e.displayText() = " << e.displayText() << ", e.what() = " << e.what()
<< ", Stack trace:\n\n" << e.getStackTrace().toString());
}
catch (Poco::Exception & e) catch (Poco::Exception & e)
{ {
std::stringstream message;
message << "Poco::Exception. Code: " << ErrorCodes::POCO_EXCEPTION << ", e.code() = " << e.code()
<< ", e.displayText() = " << e.displayText() << ", e.what() = " << e.what();
/// Таймаут - не ошибка. /// Таймаут - не ошибка.
if (!strcmp(e.what(), "Timeout")) if (!strcmp(e.what(), "Timeout"))
{ {
LOG_DEBUG(log, message.rdbuf()); LOG_DEBUG(log, "Poco::Exception. Code: " << ErrorCodes::POCO_EXCEPTION << ", e.code() = " << e.code()
<< ", e.displayText() = " << e.displayText() << ", e.what() = " << e.what());
} }
else else
{ throw;
LOG_ERROR(log, message.rdbuf());
}
}
catch (std::exception & e)
{
LOG_ERROR(log, "std::exception. Code: " << ErrorCodes::STD_EXCEPTION << ". " << e.what());
}
catch (...)
{
LOG_ERROR(log, "Unknown exception. Code: " << ErrorCodes::UNKNOWN_EXCEPTION << ".");
} }
} }

23
libs/libcommon/include/common/ErrorHandlers.h
View File

@ -1,8 +1,8 @@
#pragma once #pragma once
#include <Poco/ErrorHandler.h> #include <Poco/ErrorHandler.h>
#include <Poco/Net/SocketDefs.h>
#include <common/logger_useful.h> #include <common/logger_useful.h>
#include <DB/Common/Exception.h>
/** ErrorHandler для потоков, который в случае неперехваченного исключения, /** ErrorHandler для потоков, который в случае неперехваченного исключения,
@ -17,21 +17,20 @@ public:
}; };
/** То же самое, но не завершает работу в случае эксепшена типа Socket is not connected. /** Выводит информацию об исключении в лог.
* Этот эксепшен возникает внутри реализаций Poco::Net::HTTPServer, Poco::Net::TCPServer,
* и иначе его не удаётся перехватить, и сервер завершает работу.
*/ */
class ServerErrorHandler : public KillingErrorHandler class ServerErrorHandler : public Poco::ErrorHandler
{ {
public: public:
void exception(const Poco::Exception & e) void exception(const Poco::Exception & e) { logException(); }
{ void exception(const std::exception & e) { logException(); }
if (e.code() == POCO_ENOTCONN) void exception() { logException(); }
LOG_WARNING(log, "Client has gone away.");
else
std::terminate();
}
private: private:
Logger * log = &Logger::get("ServerErrorHandler"); Logger * log = &Logger::get("ServerErrorHandler");
void logException()
{
DB::tryLogCurrentException(log);
}
}; };