ProcessRunUtils.cpp

Go to the documentation of this file.

// Copyright CERN 2012 - Developed in collaboration with GSI

#include <fesa-core/Utilities/ProcessRunUtils.h>

#include <fesa-core/Core/FesaDefs.h>
#include <fesa-core/Exception/FesaException.h>

#include <cmw-log/Logger.h>

#include <cerrno>
#include <csignal>
#include <cstring>
#include <iostream>
#include <sstream>
#include <unistd.h>


namespace
{

CMW::Log::Logger& logger = CMW::Log::LoggerFactory::getLogger("FESA.FWK.fesa-core.Core.ProcessRunUtils");

} // namespace


namespace fesa
{

namespace ProcessRunUtils
{

void
maskSignals()
{
    sigset_t sigset;
    int rc = sigemptyset(&sigset);
    if (rc == -1)
    {
        std::ostringstream errorStringStream;
        errorStringStream << "sigemptyset(): " << std::strerror(errno);
        throw FesaException(__FILE__, __LINE__, errorStringStream.str());
    }
    // Add fatal signals to the set of masked signals in order to run the shutdown procedure in a specific thread
    rc = sigaddset(&sigset, SIGHUP);
    if (rc == -1)
    {
        std::ostringstream errorStringStream;
        errorStringStream << "sigaddset(): " << std::strerror(errno);
        throw FesaException(__FILE__, __LINE__, errorStringStream.str());
    }
    rc = sigaddset(&sigset, SIGINT);
    if (rc == -1)
    {
        std::ostringstream errorStringStream;
        errorStringStream << "sigaddset(): " << std::strerror(errno);
        throw FesaException(__FILE__, __LINE__, errorStringStream.str());
    }
    rc = sigaddset(&sigset, SIGQUIT);
    if (rc == -1)
    {
        std::ostringstream errorStringStream;
        errorStringStream << "sigaddset(): " << std::strerror(errno);
        throw FesaException(__FILE__, __LINE__, errorStringStream.str());
    }
    rc = sigaddset(&sigset, SIGILL);
    if (rc == -1)
    {
        std::ostringstream errorStringStream;
        errorStringStream << "sigaddset(): " << std::strerror(errno);
        throw FesaException(__FILE__, __LINE__, errorStringStream.str());
    }
    rc = sigaddset(&sigset, SIGTRAP);
    if (rc == -1)
    {
        std::ostringstream errorStringStream;
        errorStringStream << "sigaddset(): " << std::strerror(errno);
        throw FesaException(__FILE__, __LINE__, errorStringStream.str());
    }
    rc = sigaddset(&sigset, SIGABRT);
    if (rc == -1)
    {
        std::ostringstream errorStringStream;
        errorStringStream << "sigaddset(): " << std::strerror(errno);
        throw FesaException(__FILE__, __LINE__, errorStringStream.str());
    }
    rc = sigaddset(&sigset, SIGBUS);
    if (rc == -1)
    {
        std::ostringstream errorStringStream;
        errorStringStream << "sigaddset(): " << std::strerror(errno);
        throw FesaException(__FILE__, __LINE__, errorStringStream.str());
    }
    rc = sigaddset(&sigset, SIGFPE);
    if (rc == -1)
    {
        std::ostringstream errorStringStream;
        errorStringStream << "sigaddset(): " << std::strerror(errno);
        throw FesaException(__FILE__, __LINE__, errorStringStream.str());
    }
    rc = sigaddset(&sigset, SIGSEGV);
    if (rc == -1)
    {
        std::ostringstream errorStringStream;
        errorStringStream << "sigaddset(): " << std::strerror(errno);
        throw FesaException(__FILE__, __LINE__, errorStringStream.str());
    }
    rc = sigaddset(&sigset, SIGTERM);
    if (rc == -1)
    {
        std::ostringstream errorStringStream;
        errorStringStream << "sigaddset(): " << std::strerror(errno);
        throw FesaException(__FILE__, __LINE__, errorStringStream.str());
    }
    rc = sigaddset(&sigset, SIGSTKFLT);
    if (rc == -1)
    {
        std::ostringstream errorStringStream;
        errorStringStream << "sigaddset(): " << std::strerror(errno);
        throw FesaException(__FILE__, __LINE__, errorStringStream.str());
    }
    rc = sigaddset(&sigset, SIGSTOP);
    if (rc == -1)
    {
        std::ostringstream errorStringStream;
        errorStringStream << "sigaddset(): " << std::strerror(errno);
        throw FesaException(__FILE__, __LINE__, errorStringStream.str());
    }
    rc = sigaddset(&sigset, SIGTSTP);
    if (rc == -1)
    {
        std::ostringstream errorStringStream;
        errorStringStream << "sigaddset(): " << std::strerror(errno);
        throw FesaException(__FILE__, __LINE__, errorStringStream.str());
    }
    rc = sigaddset(&sigset, SIGTTIN);
    if (rc == -1)
    {
        std::ostringstream errorStringStream;
        errorStringStream << "sigaddset(): " << std::strerror(errno);
        throw FesaException(__FILE__, __LINE__, errorStringStream.str());
    }
    rc = sigaddset(&sigset, SIGTTOU);
    if (rc == -1)
    {
        std::ostringstream errorStringStream;
        errorStringStream << "sigaddset(): " << std::strerror(errno);
        throw FesaException(__FILE__, __LINE__, errorStringStream.str());
    }
    // Add FESA signals to the set of masked signals in order to run the treatment under a specific thread
    rc = sigaddset(&sigset, fesa::SIGFESA_RT_DOWN);
    if (rc == -1)
    {
        std::ostringstream errorStringStream;
        errorStringStream << "sigaddset(): " << std::strerror(errno);
        throw FesaException(__FILE__, __LINE__, errorStringStream.str());
    }
    rc = sigaddset(&sigset, fesa::SIGFESA_NOTIFICATION_FAILURE);
    if (rc == -1)
    {
        std::ostringstream errorStringStream;
        errorStringStream << "sigaddset(): " << std::strerror(errno);
        throw FesaException(__FILE__, __LINE__, errorStringStream.str());
    }
    rc = sigaddset(&sigset, fesa::SIGFESA_CHECK_PROCESS_ALIVE);
    if (rc == -1)
    {
        std::ostringstream errorStringStream;
        errorStringStream << "sigaddset(): " << std::strerror(errno);
        throw FesaException(__FILE__, __LINE__, errorStringStream.str());
    }
    // Mask the set of signals
    rc = pthread_sigmask(SIG_BLOCK, &sigset, NULL);
    if (rc == -1)
    {
        std::ostringstream errorStringStream;
        errorStringStream << "pthread_sigmask(): " << std::strerror(errno);
        throw FesaException(__FILE__, __LINE__, errorStringStream.str());
    }
}


void
shutDown()
{
    LOG_WARNING_IF(logger, "Reacting to incoming signal. Shutting down the framework");
    std::exit(0);
}


void
detachFromTerminal()
{
    int rc = setsid();
    if (rc == -1)
    {
        std::ostringstream errorStringStream;
        errorStringStream << "setsid(): " << std::strerror(errno);
        std::cerr << "WARNING: Detaching from terminal not successful. " << errorStringStream.str() << std::endl; // Logging is not initialized yet
    }
}

} // ProcessRunUtils

} // fesa