StalledEventMonitor.h

Go to the documentation of this file.

/***********************************************************************************\
* (c) Copyright 1998-2019 CERN for the benefit of the LHCb and ATLAS collaborations *
*                                                                                   *
* This software is distributed under the terms of the Apache version 2 licence,     *
* copied verbatim in the file "LICENSE".                                            *
*                                                                                   *
* In applying this licence, CERN does not waive the privileges and immunities       *
* granted to it by virtue of its status as an Intergovernmental Organization        *
* or submit itself to any jurisdiction.                                             *
\***********************************************************************************/
/*
 * StalledEventMonitor.h
 *
 *  Created on: Apr 19, 2010
 *      Author: Marco Clemencic
 */
 
#ifndef STALLEDEVENTMONITOR_H_
#define STALLEDEVENTMONITOR_H_
 
// Include files
#include "GaudiKernel/IIncidentListener.h"
#include "GaudiKernel/Service.h"
#include <memory>
 
// Forward declarations
class WatchdogThread;
class IIncidentSvc;
 
class StalledEventMonitor : public extends<Service, IIncidentListener> {
public:
  using extends::extends;
 
  StatusCode initialize() override;
 
  StatusCode start() override;
 
  void handle( const Incident& /* incident */ ) override;
 
  StatusCode stop() override;
 
  StatusCode finalize() override;
 
private:
  Gaudi::Property<unsigned int> m_eventTimeout{
      this, "EventTimeout", 600, "Number of seconds allowed to process a single event (0 to disable the check)."};
  Gaudi::Property<int>  m_maxTimeoutCount{this, "MaxTimeoutCount", 0,
                                         "Number timeouts before aborting the execution (0 means never abort)."};
  Gaudi::Property<bool> m_stackTrace{this, "StackTrace", false, "Whether to print the stack-trace on timeout."};
 
  std::unique_ptr<WatchdogThread> m_watchdog;
 
  SmartIF<IIncidentSvc> m_incidentSvc;
};
 
#endif // STALLEDEVENTMONITOR_H_