EventSelectorAthenaPoolSharedIO.h

Go to the documentation of this file.

/*
  Copyright (C) 2002-2026 CERN for the benefit of the ATLAS collaboration
*/
 
#ifndef EVENTSELECTORATHENAPOOLSHAREDIO_H
#define EVENTSELECTORATHENAPOOLSHAREDIO_H

 
#include "EventSelectorAthenaPool.h"
 
#include "AthenaKernel/IAthenaIPCTool.h"
#include "AthenaKernel/IEventShare.h"

class EventSelectorAthenaPoolSharedIO :
  public extends<EventSelectorAthenaPool, IEventShare>
{
 
public: // Constructor and Destructor
   EventSelectorAthenaPoolSharedIO(const std::string& name, ISvcLocator* pSvcLocator);
   virtual ~EventSelectorAthenaPoolSharedIO() = default;

   virtual StatusCode initialize() override;
   virtual StatusCode start() override;
   virtual StatusCode stop() override;
   virtual StatusCode finalize() override;
 
   //-------------------------------------------------
   // IEventSelector
   virtual StatusCode next(IEvtSelector::Context& ctxt) const override;
   virtual StatusCode next(IEvtSelector::Context& ctxt, int jump) const override;
 
   //-------------------------------------------------
   // IEventShare
   virtual StatusCode makeServer(int num) override;

   virtual StatusCode makeClient(int num) override;

   virtual StatusCode share(int evtnum) override;

   virtual StatusCode readEvent(int maxevt) override;
 
   //-------------------------------------------------
   // IIoComponent
   virtual StatusCode io_reinit() override;
 
protected:
   //-------------------------------------------------
   // ISecondaryEventSelector
   virtual StatusCode recordAttributeList() const override;
 
private: // properties
   ToolHandle<IAthenaIPCTool> m_eventStreamingTool{this, "SharedMemoryTool", "", ""};
   Gaudi::Property<int> m_makeStreamingToolClient{this, "MakeStreamingToolClient", 0};
};
 
#endif