RCUSvc.h

Go to the documentation of this file.

// This file's extension implies that it's C, but it's really -*- C++ -*-.
 
/*
  Copyright (C) 2002-2022 CERN for the benefit of the ATLAS collaboration
*/

 
 
#ifndef ATHENASERVICES_RCUSVC_H
#define ATHENASERVICES_RCUSVC_H
 
 
#include "AthenaKernel/IRCUSvc.h"
#include "AthenaBaseComps/AthService.h"
#include "GaudiKernel/ServiceHandle.h"
#include "GaudiKernel/IHiveWhiteBoard.h"
#include "GaudiKernel/IIncidentSvc.h"
#include "GaudiKernel/IIncidentListener.h"
#include <unordered_map>
#include <mutex>
 
 
namespace Athena {
 

class RCUSvc
  : public extends<AthService, IRCUSvc, IIncidentListener>
{
public:
  RCUSvc (const std::string& name, ISvcLocator* svc);
 

  virtual StatusCode initialize() override;
 

  virtual size_t getNumSlots() const override;
 

  virtual void add (IRCUObject* obj) override;
 

  virtual StatusCode remove (IRCUObject* obj) override;
 

  virtual void handle (const Incident& inc) override;
 
 
private:
  typedef std::unordered_set<IRCUObject*> set_t;
  set_t m_objs;

  ServiceHandle<IInterface> m_hiveWhiteBoardSvc;

  ServiceHandle<IIncidentSvc> m_incidentSvc;

  // Needs to be recursive since when handle() quiesces objects,
  // it can lead to calls to remove().
  std::recursive_mutex m_mutex;
  typedef std::lock_guard<std::recursive_mutex> lock_t;
};
 
 
} // namespace Athena
 
 
#endif // not ATHENASERVICES_RCUSVC_H