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_