SharedEvtQueueProvider.h

Go to the documentation of this file.

/*
  Copyright (C) 2002-2024 CERN for the benefit of the ATLAS collaboration
*/
 
#ifndef ATHENAMPTOOLS_SHAREDEVTQUEUEPROVIDER_H
#define ATHENAMPTOOLS_SHAREDEVTQUEUEPROVIDER_H
 
#include "AthenaMPToolBase.h"
#include "GaudiKernel/IIncidentListener.h"
#include "AthenaInterprocess/SharedQueue.h"
 
class IEventShare;
 
class SharedEvtQueueProvider final : public AthenaMPToolBase
  , public IIncidentListener
{
 public:
  SharedEvtQueueProvider(const std::string& type
             , const std::string& name
             , const IInterface* parent);
 
  virtual ~SharedEvtQueueProvider() override;
  
  // _________IAthenaMPTool_________   
  virtual int makePool ATLAS_NOT_THREAD_SAFE (int maxevt, int nprocs, const std::string& topdir) override;
  virtual StatusCode exec ATLAS_NOT_THREAD_SAFE() override;
 
  virtual void subProcessLogs(std::vector<std::string>&) override;
  virtual AthenaMP::AllWorkerOutputs_ptr generateOutputReport() override;
 
  // _________IIncidentListener___________
  virtual void handle(const Incident& inc) override;
 
  // _____ Actual working horses ________
  virtual std::unique_ptr<AthenaInterprocess::ScheduledWork> bootstrap_func() override;
  virtual std::unique_ptr<AthenaInterprocess::ScheduledWork> exec_func() override;
  virtual std::unique_ptr<AthenaInterprocess::ScheduledWork> fin_func() override;
 
 private:
  SharedEvtQueueProvider();
  SharedEvtQueueProvider(const SharedEvtQueueProvider&);
  SharedEvtQueueProvider& operator= (const SharedEvtQueueProvider&);
 
  // Properties
  int  m_nprocesses;      // We use this data member for adding negative numbers at the end of the event queue
                          // We cannot use m_nprocs for this purpose in order to avoid generating Output File Reports by Shared Queue Providers
  bool m_useSharedReader; // Are we doing the reading?
  int  m_nEventsBeforeFork;
  int  m_nChunkSize;
  int  m_nChunkStart;      // The beginning of the current chunk
  int  m_nPositionInChunk; // Position within the current chunk
  
 
  int  m_nEvtRequested;    // Max event received from AppMgr
  int  m_nEvtCounted;      // The number of events this tool has counted itself in the input files 
  
  AthenaInterprocess::SharedQueue*  m_sharedEventQueue;          
  SmartIF<IEventShare>              m_evtShare;
 
  // Add next event chunk to the queue
  void addEventsToQueue(); 
 
};
 
#endif