ECCE @ EIC Software
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Groups Pages
Fun4AllDstInputManager Class Reference

#include <coresoftware/blob/master/offline/framework/fun4all/Fun4AllDstInputManager.h>

+ Inheritance diagram for Fun4AllDstInputManager:
+ Collaboration diagram for Fun4AllDstInputManager:

Public Member Functions

 Fun4AllDstInputManager (const std::string &name="DUMMY", const std::string &nodename="DST", const std::string &topnodename="TOP")
 
 ~Fun4AllDstInputManager () override
 
int fileopen (const std::string &filenam) override
 
int fileclose () override
 
int run (const int nevents=0) override
 
int GetSyncObject (SyncObject **mastersync) override
 
int SyncIt (const SyncObject *mastersync) override
 
int BranchSelect (const std::string &branch, const int iflag) override
 
int setBranches () override
 
virtual int setSyncBranches (PHNodeIOManager *IManager)
 
void Print (const std::string &what="ALL") const override
 
int PushBackEvents (const int i) override
 
int HasSyncObject () const override
 
- Public Member Functions inherited from Fun4AllInputManager
 ~Fun4AllInputManager () override
 
virtual int ReadInRunNode (PHCompositeNode *)
 
std::string FileName () const
 
void FileName (const std::string &fn)
 
void Print (const std::string &what="ALL") const override
 
virtual int skip (const int nevt)
 
virtual int NoSyncPushBackEvents (const int)
 
int AddFile (const std::string &filename)
 
int AddListFile (const std::string &filename, const int do_it=0)
 
int registerSubsystem (SubsysReco *subsystem)
 
virtual int RejectEvent ()
 
void Repeat (const int i=-1)
 
virtual void setSyncManager (Fun4AllSyncManager *master)
 
virtual int ResetFileList ()
 
virtual int ResetEvent ()
 
virtual void SetRunNumber (const int runno)
 
virtual int RunNumber () const
 
void AddToFileOpened (const std::string &filename)
 
std::pair< std::list
< std::string >
::const_iterator, std::list
< std::string >
::const_iterator > 
FileOpenListBeginEnd ()
 
std::string InputNode ()
 
void InputNode (const std::string &innode)
 
std::string TopNodeName () const
 
bool FileListEmpty () const
 
virtual int IsOpen () const
 
virtual int SkipForThisManager (const int)
 
- Public Member Functions inherited from Fun4AllBase
virtual ~Fun4AllBase ()
 
virtual const std::string Name () const
 Returns the name of this module.
 
virtual void Name (const std::string &name)
 Sets the name of this module.
 
virtual void Verbosity (const int ival)
 Sets the verbosity of this module (0 by default=quiet).
 
virtual void Verbosity (enu_Verbosity ival)
 Sets the verbosity of this module (0 by default=quiet).
 
virtual int Verbosity () const
 Gets the verbosity of this module.
 

Protected Member Functions

int ReadNextEventSyncObject ()
 
void ReadRunTTree (const int i)
 
- Protected Member Functions inherited from Fun4AllInputManager
 Fun4AllInputManager (const std::string &name="DUMMY", const std::string &nodename="DST", const std::string &topnodename="TOP")
 
void UpdateFileList ()
 
int OpenNextFile ()
 
void IsOpen (const int i)
 
Fun4AllSyncManagerMySyncManager ()
 
- Protected Member Functions inherited from Fun4AllBase
 Fun4AllBase (const std::string &name="NONAME")
 

Private Attributes

int m_ReadRunTTree = 1
 
int events_total = 0
 
int events_thisfile = 0
 
int events_skipped_during_sync = 0
 
int m_HaveSyncObject = 0
 
std::string fullfilename
 
std::string RunNode = "RUN"
 
std::map< const std::string, intbranchread
 
std::string syncbranchname
 
PHCompositeNodedstNode = nullptr
 
PHCompositeNoderunNode = nullptr
 
PHCompositeNoderunNodeCopy = nullptr
 
PHCompositeNoderunNodeSum = nullptr
 
PHNodeIOManagerIManager = nullptr
 
SyncObjectsyncobject = nullptr
 

Additional Inherited Members

- Public Types inherited from Fun4AllBase
enum  enu_Verbosity {
  VERBOSITY_QUIET = 0, VERBOSITY_SOME = 1, VERBOSITY_MORE = 2, VERBOSITY_EVEN_MORE = 3,
  VERBOSITY_A_LOT = 4, VERBOSITY_MAX = INT_MAX - 10
}
 

Detailed Description

Definition at line 15 of file Fun4AllDstInputManager.h.

View newest version in sPHENIX GitHub at line 15 of file Fun4AllDstInputManager.h

Constructor & Destructor Documentation

Fun4AllDstInputManager::Fun4AllDstInputManager ( const std::string &  name = "DUMMY",
const std::string &  nodename = "DST",
const std::string &  topnodename = "TOP" 
)

Definition at line 35 of file Fun4AllDstInputManager.cc.

View newest version in sPHENIX GitHub at line 35 of file Fun4AllDstInputManager.cc

Fun4AllDstInputManager::~Fun4AllDstInputManager ( )
override

Definition at line 41 of file Fun4AllDstInputManager.cc.

View newest version in sPHENIX GitHub at line 41 of file Fun4AllDstInputManager.cc

References IManager, and runNodeSum.

Member Function Documentation

int Fun4AllDstInputManager::BranchSelect ( const std::string &  branch,
const int  iflag 
)
overridevirtual

Reimplemented from Fun4AllInputManager.

Definition at line 506 of file Fun4AllDstInputManager.cc.

View newest version in sPHENIX GitHub at line 506 of file Fun4AllDstInputManager.cc

References branchread, Fun4AllInputManager::IsOpen(), and Fun4AllBase::Verbosity().

+ Here is the call graph for this function:

int Fun4AllDstInputManager::fileclose ( )
overridevirtual

Reimplemented from Fun4AllInputManager.

Definition at line 217 of file Fun4AllDstInputManager.cc.

View newest version in sPHENIX GitHub at line 217 of file Fun4AllDstInputManager.cc

References IManager, Fun4AllInputManager::IsOpen(), m_HaveSyncObject, Fun4AllBase::Name(), and Fun4AllInputManager::UpdateFileList().

Referenced by fileopen(), ReadNextEventSyncObject(), run(), and SyncIt().

+ Here is the call graph for this function:

+ Here is the caller graph for this function:

int Fun4AllDstInputManager::GetSyncObject ( SyncObject **  mastersync)
overridevirtual

Reimplemented from Fun4AllInputManager.

Reimplemented in Fun4AllNoSyncDstInputManager.

Definition at line 232 of file Fun4AllDstInputManager.cc.

View newest version in sPHENIX GitHub at line 232 of file Fun4AllDstInputManager.cc

References SyncObject::CloneMe(), Fun4AllReturnCodes::SYNC_OK, and syncobject.

+ Here is the call graph for this function:

int Fun4AllDstInputManager::HasSyncObject ( ) const
overridevirtual

Reimplemented from Fun4AllInputManager.

Reimplemented in Fun4AllNoSyncDstInputManager.

Definition at line 637 of file Fun4AllDstInputManager.cc.

View newest version in sPHENIX GitHub at line 637 of file Fun4AllDstInputManager.cc

References g4zmq::exit(), Fun4AllInputManager::IsOpen(), m_HaveSyncObject, and PHWHERE.

+ Here is the call graph for this function:

void Fun4AllDstInputManager::Print ( const std::string &  what = "ALL") const
overridevirtual

Print out some info about this module.

Parameters
whatcan be used to specify what to print exactly.

Reimplemented from Fun4AllBase.

Definition at line 587 of file Fun4AllDstInputManager.cc.

View newest version in sPHENIX GitHub at line 587 of file Fun4AllDstInputManager.cc

References branchread, IManager, Fun4AllBase::Name(), PHNodeIOManager::print(), and Fun4AllInputManager::Print().

+ Here is the call graph for this function:

int Fun4AllDstInputManager::PushBackEvents ( const int  i)
overridevirtual

Reimplemented from Fun4AllInputManager.

Definition at line 623 of file Fun4AllDstInputManager.cc.

View newest version in sPHENIX GitHub at line 623 of file Fun4AllDstInputManager.cc

References PHIOManager::getEventNumber(), IManager, Fun4AllBase::Name(), PHWHERE, and PHIOManager::setEventNumber().

Referenced by Fun4AllNoSyncDstInputManager::NoSyncPushBackEvents(), Fun4AllNoSyncDstInputManager::SkipForThisManager(), and SyncIt().

+ Here is the call graph for this function:

+ Here is the caller graph for this function:

int Fun4AllDstInputManager::ReadNextEventSyncObject ( )
protected

Definition at line 403 of file Fun4AllDstInputManager.cc.

View newest version in sPHENIX GitHub at line 403 of file Fun4AllDstInputManager.cc

References phooldefs::branchpathdelim, dstNode, fileclose(), PHNodeIOManager::GetBranchMap(), PHIOManager::getEventNumber(), IManager, itest, Fun4AllBase::Name(), Fun4AllInputManager::OpenNextFile(), PHWHERE, PHNodeIOManager::read(), PHNodeIOManager::readSpecific(), PHIOManager::setEventNumber(), split(), Fun4AllReturnCodes::SYNC_FAIL, syncbranchname, and Fun4AllBase::Verbosity().

Referenced by SyncIt().

+ Here is the call graph for this function:

+ Here is the caller graph for this function:

void Fun4AllDstInputManager::ReadRunTTree ( const int  i)
inlineprotected

Definition at line 34 of file Fun4AllDstInputManager.h.

View newest version in sPHENIX GitHub at line 34 of file Fun4AllDstInputManager.h

References m_ReadRunTTree.

Referenced by Fun4AllNoSyncDstInputManager::NoRunTTree().

+ Here is the caller graph for this function:

int Fun4AllDstInputManager::run ( const int  nevents = 0)
overridevirtual

Reimplemented from Fun4AllInputManager.

Definition at line 159 of file Fun4AllDstInputManager.cc.

View newest version in sPHENIX GitHub at line 159 of file Fun4AllDstInputManager.cc

References dstNode, Fun4AllReturnCodes::EVENT_OK, events_thisfile, events_total, fileclose(), Fun4AllInputManager::FileListEmpty(), IManager, Fun4AllInputManager::IsOpen(), Fun4AllBase::Name(), Fun4AllInputManager::OpenNextFile(), PHNodeIOManager::read(), Fun4AllInputManager::RejectEvent(), syncobject, and Fun4AllBase::Verbosity().

+ Here is the call graph for this function:

int Fun4AllDstInputManager::setBranches ( )
overridevirtual

Reimplemented from Fun4AllInputManager.

Definition at line 548 of file Fun4AllDstInputManager.cc.

View newest version in sPHENIX GitHub at line 548 of file Fun4AllDstInputManager.cc

References branchread, IManager, Fun4AllBase::Name(), PHWHERE, PHNodeIOManager::selectObjectToRead(), setSyncBranches(), and Fun4AllBase::Verbosity().

Referenced by fileopen().

+ Here is the call graph for this function:

+ Here is the caller graph for this function:

int Fun4AllDstInputManager::setSyncBranches ( PHNodeIOManager IManager)
virtual

Reimplemented in Fun4AllNoSyncDstInputManager.

Definition at line 577 of file Fun4AllDstInputManager.cc.

View newest version in sPHENIX GitHub at line 577 of file Fun4AllDstInputManager.cc

References PHNodeIOManager::selectObjectToRead().

Referenced by setBranches().

+ Here is the call graph for this function:

+ Here is the caller graph for this function:

int Fun4AllDstInputManager::SyncIt ( const SyncObject mastersync)
overridevirtual

Reimplemented from Fun4AllInputManager.

Reimplemented in Fun4AllNoSyncDstInputManager.

Definition at line 253 of file Fun4AllDstInputManager.cc.

View newest version in sPHENIX GitHub at line 253 of file Fun4AllDstInputManager.cc

References SyncObject::Different(), dstNode, SyncObject::EventCounter(), SyncObject::EventNumber(), events_skipped_during_sync, fileclose(), SyncObject::identify(), IManager, Fun4AllBase::Name(), PHWHERE, PushBackEvents(), PHNodeIOManager::read(), ReadNextEventSyncObject(), SyncObject::RunNumber(), SyncObject::SegmentNumber(), Fun4AllReturnCodes::SYNC_FAIL, Fun4AllReturnCodes::SYNC_OK, syncobject, and Fun4AllBase::Verbosity().

+ Here is the call graph for this function:

Member Data Documentation

std::map<const std::string, int> Fun4AllDstInputManager::branchread
private

Definition at line 44 of file Fun4AllDstInputManager.h.

View newest version in sPHENIX GitHub at line 44 of file Fun4AllDstInputManager.h

Referenced by BranchSelect(), Print(), and setBranches().

PHCompositeNode* Fun4AllDstInputManager::dstNode = nullptr
private

Definition at line 46 of file Fun4AllDstInputManager.h.

View newest version in sPHENIX GitHub at line 46 of file Fun4AllDstInputManager.h

Referenced by fileopen(), ReadNextEventSyncObject(), run(), and SyncIt().

int Fun4AllDstInputManager::events_skipped_during_sync = 0
private

Definition at line 40 of file Fun4AllDstInputManager.h.

View newest version in sPHENIX GitHub at line 40 of file Fun4AllDstInputManager.h

Referenced by SyncIt().

int Fun4AllDstInputManager::events_thisfile = 0
private

Definition at line 39 of file Fun4AllDstInputManager.h.

View newest version in sPHENIX GitHub at line 39 of file Fun4AllDstInputManager.h

Referenced by fileopen(), and run().

int Fun4AllDstInputManager::events_total = 0
private

Definition at line 38 of file Fun4AllDstInputManager.h.

View newest version in sPHENIX GitHub at line 38 of file Fun4AllDstInputManager.h

Referenced by run().

std::string Fun4AllDstInputManager::fullfilename
private

Definition at line 42 of file Fun4AllDstInputManager.h.

View newest version in sPHENIX GitHub at line 42 of file Fun4AllDstInputManager.h

Referenced by fileopen().

PHNodeIOManager* Fun4AllDstInputManager::IManager = nullptr
private

Definition at line 50 of file Fun4AllDstInputManager.h.

View newest version in sPHENIX GitHub at line 50 of file Fun4AllDstInputManager.h

Referenced by fileclose(), fileopen(), Print(), PushBackEvents(), ReadNextEventSyncObject(), run(), setBranches(), SyncIt(), and ~Fun4AllDstInputManager().

int Fun4AllDstInputManager::m_HaveSyncObject = 0
private

Definition at line 41 of file Fun4AllDstInputManager.h.

View newest version in sPHENIX GitHub at line 41 of file Fun4AllDstInputManager.h

Referenced by fileclose(), fileopen(), and HasSyncObject().

int Fun4AllDstInputManager::m_ReadRunTTree = 1
private

Definition at line 37 of file Fun4AllDstInputManager.h.

View newest version in sPHENIX GitHub at line 37 of file Fun4AllDstInputManager.h

Referenced by fileopen(), and ReadRunTTree().

std::string Fun4AllDstInputManager::RunNode = "RUN"
private

Definition at line 43 of file Fun4AllDstInputManager.h.

View newest version in sPHENIX GitHub at line 43 of file Fun4AllDstInputManager.h

Referenced by fileopen().

PHCompositeNode* Fun4AllDstInputManager::runNode = nullptr
private

Definition at line 47 of file Fun4AllDstInputManager.h.

View newest version in sPHENIX GitHub at line 47 of file Fun4AllDstInputManager.h

Referenced by fileopen().

PHCompositeNode* Fun4AllDstInputManager::runNodeCopy = nullptr
private

Definition at line 48 of file Fun4AllDstInputManager.h.

View newest version in sPHENIX GitHub at line 48 of file Fun4AllDstInputManager.h

Referenced by fileopen().

PHCompositeNode* Fun4AllDstInputManager::runNodeSum = nullptr
private

Definition at line 49 of file Fun4AllDstInputManager.h.

View newest version in sPHENIX GitHub at line 49 of file Fun4AllDstInputManager.h

Referenced by fileopen(), and ~Fun4AllDstInputManager().

std::string Fun4AllDstInputManager::syncbranchname
private

Definition at line 45 of file Fun4AllDstInputManager.h.

View newest version in sPHENIX GitHub at line 45 of file Fun4AllDstInputManager.h

Referenced by ReadNextEventSyncObject().

SyncObject* Fun4AllDstInputManager::syncobject = nullptr
private

Definition at line 51 of file Fun4AllDstInputManager.h.

View newest version in sPHENIX GitHub at line 51 of file Fun4AllDstInputManager.h

Referenced by GetSyncObject(), run(), and SyncIt().


The documentation for this class was generated from the following files: