31 typedef struct sigaction handler_t;
42 oldact = signal( signum, sa );
45 sigemptyset( &sa.sa_mask );
47 sigaction( signum, &sa, &oldact );
86 for (
int i = 0; i < NSIG; ++i ) {
118 m_caught[signum] = 1;
121 m_oldActions[signum] != SIG_DFL
123 m_oldActions[signum].sa_handler != SIG_DFL
127 m_oldActions[signum]( signum );
129 m_oldActions[signum].sa_handler( signum );
169 const char* sig_desc(
int signum ) {
170 if ( signum >= NSIG || signum < 0 )
return nullptr;
176 return "Illegal instruction";
178 return "Floating point exception";
180 return "Segmentation fault";
184 return "Trace/breakpoint trap";
191 return sys_siglist[signum];
204 inline const std::string&
name(
int signum )
const {
return m_num2id[signum]; }
206 inline const std::string& desc(
int signum )
const {
return m_num2desc[signum]; }
208 inline int signum(
const std::string& str )
const {
209 auto it = m_name2num.
find( str );
210 return it != m_name2num.end() ? it->second : -1;
217 #define addSignal( id ) i_addSignal( id, #id ); 306 inline void i_addSignal(
int signum,
const char* signame ) {
307 m_num2id[signum] = signame;
308 m_name2num[signame] = signum;
309 const char* desc = sig_desc( signum );
311 m_num2desc[signum] = desc;
312 m_name2num[desc] = signum;
334 using extends::extends;
338 std::string serviceName(
"Gaudi::Utils::SignalMonitorSvc" );
340 if ( !m_signalMonitor ) {
341 error() <<
"Cannot retrieve " << serviceName <<
endmsg;
344 serviceName =
"IncidentSvc";
346 if ( !m_incidentSvc ) {
347 error() <<
"Cannot retrieve " << serviceName <<
endmsg;
352 if ( !m_appProperty ) {
353 warning() <<
"Cannot retrieve IProperty interface of ApplicationMgr, " 354 "the return code will not be changed" 358 for (
const auto& signame : m_usedSignals ) {
359 auto sigid = i_decodeSignal( signame );
360 if ( sigid.first >= 0 ) { m_signals[sigid.first] = sigid.second; }
363 const SigMap& sigmap( SigMap::instance() );
364 for (
const auto&
s : m_signals ) {
365 debug() <<
"\t" << sigmap.name(
s.first ) <<
": " << sigmap.desc(
s.first ) <<
" (" <<
s.first <<
")";
366 if (
s.second )
debug() <<
" propagated";
369 m_signalMonitor->monitorSignal(
s.first,
s.second );
371 m_stopRequested =
false;
372 debug() <<
"Register to the IncidentSvc" <<
endmsg;
373 m_incidentSvc->addListener(
this, IncidentType::BeginEvent );
377 m_incidentSvc->removeListener(
this, IncidentType::BeginEvent );
378 m_incidentSvc.reset();
382 m_signalMonitor->ignoreSignal( s.first );
384 m_signalMonitor.reset();
389 if ( !m_stopRequested ) {
390 const SigMap& sigmap( SigMap::instance() );
391 for (
const auto&
s : m_signals ) {
392 if ( !m_signalMonitor->gotSignal(
s.first ) )
continue;
393 warning() <<
"Received signal '" << sigmap.name(
s.first ) <<
"' (" <<
s.first;
397 m_stopRequested =
true;
404 if ( m_stopRequested ) {
408 ep->stopRun().ignore();
410 warning() <<
"Cannot stop the processing because the IEventProcessor interface cannot be retrieved." 422 {
"SIGINT",
"SIGXCPU"},
423 "List of signal names or numbers to use to schedule a stop. " 424 "If the signal is followed by a '+' the signal is propagated the previously " 425 "registered handler (if any)."};
429 bool m_stopRequested =
false;
438 debug() <<
"Decoding signal declaration '" << sig <<
"'" <<
endmsg;
439 if ( sig.
empty() || sig ==
"+" ) {
443 const SigMap& sigmap( SigMap::instance() );
447 if ( signal[signal.
size() - 1] ==
'+' ) {
448 debug() <<
"Must be propagated to previously registered signal handlers" <<
endmsg;
459 signum = sigmap.signum( signal );
462 warning() <<
"Cannot understand signal identifier '" << sig <<
"', ignored" <<
endmsg;
464 verbose() <<
"Matched signal '" << sigmap.name( signum ) <<
"' (" << signum;
469 return {signum, propagate};
void setSignal(int signum) override
Set the flag for the given signal, as if the signal was received.
StatusCode initialize() override
sig_atomic_t m_caught[NSIG]
Array of flags for received signals.
Small smart pointer class with automatic reference counting for IInterface.
The ISvcLocator is the interface implemented by the Service Factory in the Application Manager to loc...
const std::string & name() const override
Retrieve name of the service.
StatusCode finalize() override
SmartIF< IIncidentSvc > m_incidentSvc
Pointer to the incident service.
Implementation of property with value of concrete type.
Gaudi::Utils::SignalMonitorSvc g_u_sms
~SignalMonitorSvc() override
Stop monitoring signals and clear the instance pointer.
bool gotSignal(int signum) const override
Check if the given signal has been received.
void i_handle(int signum)
void ignoreSignal(int signum) override
Remove the specific signal handler for the requested signal, restoring the previous signal handler...
MsgStream & verbose() const
shortcut for the method msgStream(MSG::VERBOSE)
constexpr static const auto SUCCESS
static void dispatcher(int signum)
Signal handler function.
class MergingTransformer< Out(const vector_of_const_< In > void
void clearSignal(int signum) override
Clear the flag for the given signal, so that a new occurrence can be identified.
StatusCode finalize() override
SmartIF< Gaudi::ISignalMonitor > m_signalMonitor
Pointer to the signal monitor service.
#define DECLARE_COMPONENT(type)
MonitoringMode
Possible monitoring modes.
StatusCode service(const Gaudi::Utils::TypeNameString &name, T *&svc, bool createIf=true)
Templated method to access a service by name.
std::map< int, bool > m_signals
Map of monitored signal numbers to the flag telling if they have to be propagated or not...
static void setInstance(SignalMonitorSvc *i)
MsgStream & error() const
shortcut for the method msgStream(MSG::ERROR)
MsgStream & warning() const
shortcut for the method msgStream(MSG::WARNING)
static SignalMonitorSvc * instance()
Method to get the singleton instance.
Implementation of Gaudi::ISignalMonitor.
This class is used for returning status codes from appropriate routines.
SignalMonitorSvc(const std::string &name, ISvcLocator *svcLoc)
Initialize internal variables of the service and set the instance pointer.
void handle(const Incident &) override
SmartIF< IProperty > m_appProperty
Pointer to the interface to set the return code of the application.
std::pair< int, bool > i_decodeSignal(const std::string &sig)
Function to translate the signal name to the signal number.
Service that stop the processing if a signal is received.
StatusCode setAppReturnCode(SmartIF< IProperty > &appmgr, int value, bool force=false)
Set the application return code.
static SignalMonitorSvc * s_instance
Pointer to the current instance.
void monitorSignal(int signum, bool propagate) override
Declare a signal to be monitored.
MsgStream & debug() const
shortcut for the method msgStream(MSG::DEBUG)
Base class used to extend a class implementing other interfaces.
Base class for all Incidents (computing events).
StatusCode initialize() override
constexpr static const auto FAILURE
The IEventProcessor is the interface to process events.
MonitoringMode m_monitored[NSIG]
Array of flags to keep track of monitored signals.
constexpr int SignalOffset
handler_t m_oldActions[NSIG]
List of replaced signal actions (for the recovery when disable the monitoring).
handler_t m_defaultAction
Helper variable for default signal action.
Gaudi::Utils::StopSignalHandler g_u_ssh
SmartIF< ISvcLocator > & serviceLocator() const override
Retrieve pointer to service locator.
Helper functions to set/get the application return code.
MsgStream & endmsg(MsgStream &s)
MsgStream Modifier: endmsg. Calls the output method of the MsgStream.
struct sigaction handler_t