Method initializeTerminationAndSignalProcessing

src/Daemon/BaseDaemon.cpp:448–496

extern const char * GIT_HASH;

void BaseDaemon::initializeTerminationAndSignalProcessing()
{
    CrashWriter::initialize(config());
    if (config().getBool("send_crash_reports.enabled", false)
        && config().getBool("send_crash_reports.send_logical_errors", false)
        && CrashWriter::initialized())
    {
        LOG_DEBUG(&logger(), "Sending logical errors is enabled");
        Exception::callback = [](std::string_view format_string, int code, bool remote, const Exception::Trace & trace)
        {
            if (!remote && code == ErrorCodes::LOGICAL_ERROR)
            {
                CrashWriter::FramePointers frame_pointers;
                for (size_t i = 0; i < trace.size(); ++i)
                    frame_pointers[i] = trace[i];
                CrashWriter::onException(code, format_string, frame_pointers, /* offset= */ 0, trace.size());
            }
        };
    }

    /// We want to avoid SIGPIPE when working with sockets and pipes, and just handle return value/errno instead.
    blockSignals({SIGPIPE});

    /// Setup signal handlers.
    HandledSignals::instance().setupTerminateHandler();
    HandledSignals::instance().setupCommonDeadlySignalHandlers();
    HandledSignals::instance().setupCommonTerminateRequestSignalHandlers();
    HandledSignals::instance().addSignalHandler({SIGHUP}, closeLogsSignalHandler, true);
    HandledSignals::instance().addSignalHandler({SIGCHLD}, childSignalHandler, true);

    /// Set up Poco ErrorHandler for Poco Threads.
    static KillingErrorHandler killing_error_handler;
    Poco::ErrorHandler::set(&killing_error_handler);

    signal_listener = std::make_unique<SignalListener>(this, getLogger("BaseDaemon"), [this](int, bool) { onTerminateRequestSignal(); });

#if (defined(__ELF__) && !defined(OS_FREEBSD)) || defined(OS_DARWIN)
    build_id = SymbolIndex::instance().getBuildIDHex();
#endif

    signal_listener_thread.start(*signal_listener);

#if defined(OS_LINUX)
    std::string executable_path = getExecutablePath();

    if (!executable_path.empty())
        stored_binary_hash = Elf(executable_path).getStoredBinaryHash();
#endif
}

void BaseDaemon::logRevision() const
{