mirror of
https://github.com/ClickHouse/ClickHouse.git
synced 2024-12-15 10:52:30 +00:00
b7ba0b64dc
stack trace:
(gdb) bt
0 0x00007ffff7dda355 in raise () from /usr/lib/libc.so.6
1 0x00007ffff7dc3853 in abort () from /usr/lib/libc.so.6
2 0x0000000013a78180 in abort_message (format=format@entry=0x5781e10 "terminate_handler unexpectedly threw an exception") at abort_message.cpp:76
3 0x0000000013a899ff in std::__terminate (func=<optimized out>) at cxa_handlers.cpp:67
4 0x0000000013a771a1 in __cxxabiv1::call_terminate (native_exception=native_exception@entry=true, unwind_exception=unwind_exception@entry=0x7ffff70e9060) at cxa_personality.cpp:323
5 0x0000000013a77669 in __cxxabiv1::scan_eh_tab (results=..., actions=<optimized out>, native_exception=native_exception@entry=true, unwind_exception=0x7ffff70e9060, context=context@entry=0x7fffffffc3a0) at cxa_personality.cpp:887
6 0x0000000013a77bde in __cxxabiv1::__gxx_personality_v0 (version=<optimized out>, actions=<optimized out>, exceptionClass=<optimized out>, unwind_exception=0x7ffff70e9060, context=0x7fffffffc3a0) at cxa_personality.cpp:969
7 0x0000000013a962d7 in unwind_phase1 (exception_object=0x7ffff70e9060, cursor=0x7fffffffc3a0, uc=0x7fffffffc2f0) at UnwindLevel1.c:98
8 _Unwind_RaiseException (exception_object=exception_object@entry=0x7ffff70e9060) at UnwindLevel1.c:363
9 0x0000000013a8929b in __cxxabiv1::__cxa_rethrow () at cxa_exception.cpp:607
10 0x000000000f170ad2 in DB::WriteBuffer::next (this=0x7fffffffc510) at WriteBuffer.h:52
11 writeSignalIDtoSignalPipe (sig=<optimized out>) at BaseDaemon.cpp:111
12 <signal handler called>
13 0x00007ffff7e9895b in munmap () from /usr/lib/libc.so.6
14 0x00007ffff7f7e255 in free_stacks () from /usr/lib/libpthread.so.0
15 0x00007ffff7f7e6aa in __deallocate_stack () from /usr/lib/libpthread.so.0
16 0x00007ffff7f80898 in __pthread_clockjoin_ex () from /usr/lib/libpthread.so.0
17 0x0000000013a759f7 in std::__1::__libcpp_thread_join (__t=0x7fff0aa2b090) at __threading_support:409
18 std::__1:🧵:join (this=this@entry=0x7fff0aa2b090) at thread.cpp:56
19 0x000000000a4c9399 in ThreadPoolImpl<std::__1::thread>::finalize (this=this@entry=0x7ffff7053900) at list:355
20 0x000000000a4c9426 in ThreadPoolImpl<std::__1::thread>::~ThreadPoolImpl (this=0x7ffff7053900, __in_chrg=<optimized out>) at ThreadPool.cpp:172
21 0x000000000a4c8a9c in GlobalThreadPool::~GlobalThreadPool (this=0x7ffff7053900, __in_chrg=<optimized out>) at ThreadPool.h:132
22 std::__1::default_delete<GlobalThreadPool>::operator() (__ptr=0x7ffff7053900, this=<optimized out>) at memory:2363
23 std::__1::unique_ptr<GlobalThreadPool, std::__1::default_delete<GlobalThreadPool> >::reset (__p=0x0, this=<optimized out>) at memory:2618
24 std::__1::unique_ptr<GlobalThreadPool, std::__1::default_delete<GlobalThreadPool> >::~unique_ptr (this=<optimized out>, __in_chrg=<optimized out>) at memory:2572
25 0x00007ffff7ddcc57 in __run_exit_handlers () from /usr/lib/libc.so.6
26 0x00007ffff7ddcdfe in exit () from /usr/lib/libc.so.6
27 0x00007ffff7dc5009 in __libc_start_main () from /usr/lib/libc.so.6
28 0x000000000a48702e in _start () at new:340
218 lines
7.8 KiB
C++
218 lines
7.8 KiB
C++
#pragma once
|
||
|
||
#include <sys/types.h>
|
||
#include <unistd.h>
|
||
#include <iostream>
|
||
#include <memory>
|
||
#include <functional>
|
||
#include <optional>
|
||
#include <mutex>
|
||
#include <condition_variable>
|
||
#include <atomic>
|
||
#include <chrono>
|
||
#include <Poco/Process.h>
|
||
#include <Poco/ThreadPool.h>
|
||
#include <Poco/TaskNotification.h>
|
||
#include <Poco/Util/Application.h>
|
||
#include <Poco/Util/ServerApplication.h>
|
||
#include <Poco/Net/SocketAddress.h>
|
||
#include <Poco/Version.h>
|
||
#include <common/types.h>
|
||
#include <common/logger_useful.h>
|
||
#include <common/getThreadId.h>
|
||
#include <daemon/GraphiteWriter.h>
|
||
#include <Common/Config/ConfigProcessor.h>
|
||
#include <Common/StatusFile.h>
|
||
#include <loggers/Loggers.h>
|
||
|
||
|
||
namespace Poco { class TaskManager; }
|
||
|
||
|
||
/// \brief Base class for applications that can run as daemons.
|
||
///
|
||
/// \code
|
||
/// # Some possible command line options:
|
||
/// # --config-file, -C or --config - path to configuration file. By default - config.xml in the current directory.
|
||
/// # --log-file
|
||
/// # --errorlog-file
|
||
/// # --daemon - run as daemon; without this option, the program will be attached to the terminal and also output logs to stderr.
|
||
/// <daemon_name> --daemon --config-file=localfile.xml --log-file=log.log --errorlog-file=error.log
|
||
/// \endcode
|
||
///
|
||
/// You can configure different log options for different loggers used inside program
|
||
/// by providing subsections to "logger" in configuration file.
|
||
class BaseDaemon : public Poco::Util::ServerApplication, public Loggers
|
||
{
|
||
friend class SignalListener;
|
||
|
||
public:
|
||
static inline constexpr char DEFAULT_GRAPHITE_CONFIG_NAME[] = "graphite";
|
||
|
||
BaseDaemon();
|
||
~BaseDaemon() override;
|
||
|
||
/// Загружает конфигурацию и "строит" логгеры на запись в файлы
|
||
void initialize(Poco::Util::Application &) override;
|
||
|
||
/// Читает конфигурацию
|
||
void reloadConfiguration();
|
||
|
||
/// Определяет параметр командной строки
|
||
void defineOptions(Poco::Util::OptionSet & new_options) override;
|
||
|
||
/// Заставляет демон завершаться, если хотя бы одна задача завершилась неудачно
|
||
void exitOnTaskError();
|
||
|
||
/// Завершение демона ("мягкое")
|
||
void terminate();
|
||
|
||
/// Завершение демона ("жёсткое")
|
||
void kill();
|
||
|
||
/// Получен ли сигнал на завершение?
|
||
bool isCancelled() const
|
||
{
|
||
return is_cancelled;
|
||
}
|
||
|
||
/// Получение ссылки на экземпляр демона
|
||
static BaseDaemon & instance()
|
||
{
|
||
return dynamic_cast<BaseDaemon &>(Poco::Util::Application::instance());
|
||
}
|
||
|
||
/// return none if daemon doesn't exist, reference to the daemon otherwise
|
||
static std::optional<std::reference_wrapper<BaseDaemon>> tryGetInstance() { return tryGetInstance<BaseDaemon>(); }
|
||
|
||
/// Спит заданное количество секунд или до события wakeup
|
||
void sleep(double seconds);
|
||
|
||
/// Разбудить
|
||
void wakeup();
|
||
|
||
/// В Graphite компоненты пути(папки) разделяются точкой.
|
||
/// У нас принят путь формата root_path.hostname_yandex_ru.key
|
||
/// root_path по умолчанию one_min
|
||
/// key - лучше группировать по смыслу. Например "meminfo.cached" или "meminfo.free", "meminfo.total"
|
||
template <class T>
|
||
void writeToGraphite(const std::string & key, const T & value, const std::string & config_name = DEFAULT_GRAPHITE_CONFIG_NAME, time_t timestamp = 0, const std::string & custom_root_path = "")
|
||
{
|
||
auto writer = getGraphiteWriter(config_name);
|
||
if (writer)
|
||
writer->write(key, value, timestamp, custom_root_path);
|
||
}
|
||
|
||
template <class T>
|
||
void writeToGraphite(const GraphiteWriter::KeyValueVector<T> & key_vals, const std::string & config_name = DEFAULT_GRAPHITE_CONFIG_NAME, time_t timestamp = 0, const std::string & custom_root_path = "")
|
||
{
|
||
auto writer = getGraphiteWriter(config_name);
|
||
if (writer)
|
||
writer->write(key_vals, timestamp, custom_root_path);
|
||
}
|
||
|
||
template <class T>
|
||
void writeToGraphite(const GraphiteWriter::KeyValueVector<T> & key_vals, const std::chrono::system_clock::time_point & current_time, const std::string & custom_root_path)
|
||
{
|
||
auto writer = getGraphiteWriter();
|
||
if (writer)
|
||
writer->write(key_vals, std::chrono::system_clock::to_time_t(current_time), custom_root_path);
|
||
}
|
||
|
||
GraphiteWriter * getGraphiteWriter(const std::string & config_name = DEFAULT_GRAPHITE_CONFIG_NAME)
|
||
{
|
||
if (graphite_writers.count(config_name))
|
||
return graphite_writers[config_name].get();
|
||
return nullptr;
|
||
}
|
||
|
||
/// close all process FDs except
|
||
/// 0-2 -- stdin, stdout, stderr
|
||
/// also doesn't close global internal pipes for signal handling
|
||
static void closeFDs();
|
||
|
||
protected:
|
||
/// Возвращает TaskManager приложения
|
||
/// все методы task_manager следует вызывать из одного потока
|
||
/// иначе возможен deadlock, т.к. joinAll выполняется под локом, а любой метод тоже берет лок
|
||
Poco::TaskManager & getTaskManager() { return *task_manager; }
|
||
|
||
virtual void logRevision() const;
|
||
|
||
/// Используется при exitOnTaskError()
|
||
void handleNotification(Poco::TaskFailedNotification *);
|
||
|
||
/// thread safe
|
||
virtual void handleSignal(int signal_id);
|
||
|
||
/// initialize termination process and signal handlers
|
||
virtual void initializeTerminationAndSignalProcessing();
|
||
|
||
/// реализация обработки сигналов завершения через pipe не требует блокировки сигнала с помощью sigprocmask во всех потоках
|
||
void waitForTerminationRequest()
|
||
#if defined(POCO_CLICKHOUSE_PATCH) || POCO_VERSION >= 0x02000000 // in old upstream poco not vitrual
|
||
override
|
||
#endif
|
||
;
|
||
/// thread safe
|
||
virtual void onInterruptSignals(int signal_id);
|
||
|
||
template <class Daemon>
|
||
static std::optional<std::reference_wrapper<Daemon>> tryGetInstance();
|
||
|
||
virtual std::string getDefaultCorePath() const;
|
||
|
||
std::unique_ptr<Poco::TaskManager> task_manager;
|
||
|
||
std::optional<DB::StatusFile> pid;
|
||
|
||
std::atomic_bool is_cancelled{false};
|
||
|
||
/// Флаг устанавливается по сообщению из Task (при аварийном завершении).
|
||
bool task_failed = false;
|
||
|
||
bool log_to_console = false;
|
||
|
||
/// Событие, чтобы проснуться во время ожидания
|
||
Poco::Event wakeup_event;
|
||
|
||
/// Поток, в котором принимается сигнал HUP/USR1 для закрытия логов.
|
||
Poco::Thread signal_listener_thread;
|
||
std::unique_ptr<Poco::Runnable> signal_listener;
|
||
|
||
std::map<std::string, std::unique_ptr<GraphiteWriter>> graphite_writers;
|
||
|
||
std::mutex signal_handler_mutex;
|
||
std::condition_variable signal_event;
|
||
std::atomic_size_t terminate_signals_counter{0};
|
||
std::atomic_size_t sigint_signals_counter{0};
|
||
|
||
std::string config_path;
|
||
DB::ConfigProcessor::LoadedConfig loaded_config;
|
||
Poco::Util::AbstractConfiguration * last_configuration = nullptr;
|
||
|
||
String build_id_info;
|
||
|
||
std::vector<int> handled_signals;
|
||
};
|
||
|
||
|
||
template <class Daemon>
|
||
std::optional<std::reference_wrapper<Daemon>> BaseDaemon::tryGetInstance()
|
||
{
|
||
Daemon * ptr = nullptr;
|
||
try
|
||
{
|
||
ptr = dynamic_cast<Daemon *>(&Poco::Util::Application::instance());
|
||
}
|
||
catch (const Poco::NullPointerException &)
|
||
{
|
||
/// if daemon doesn't exist than instance() throw NullPointerException
|
||
}
|
||
|
||
if (ptr)
|
||
return std::optional<std::reference_wrapper<Daemon>>(*ptr);
|
||
else
|
||
return {};
|
||
}
|