framework/fun4all/Fun4AllRunNodeInputManager.h

0001 // Tell emacs that this is a C++ source
0002 //  -*- C++ -*-.
0003 #ifndef FUN4ALL_FUN4ALLRUNNODEINPUTMANAGER_H
0004 #define FUN4ALL_FUN4ALLRUNNODEINPUTMANAGER_H
0005
0006 #include "Fun4AllDstInputManager.h"
0007
0008 #include "Fun4AllReturnCodes.h"
0009
0010 #include <string>  // for string
0011
0012 class PHNodeIOManager;
0013 class SyncObject;
0014
0015 class Fun4AllRunNodeInputManager : public Fun4AllDstInputManager
0016 {
0017  public:
0018   Fun4AllRunNodeInputManager(const std::string& name = "DUMMY", const std::string& nodename = "DST", const std::string& topnodename = "TOP");
0019
0020   ~Fun4AllRunNodeInputManager() override {}
0021
0022   int fileopen(const std::string& filenam) override;
0023   int run(const int /*nevents*/) override;
0024
0025   // Effectivly turn off the synchronization checking
0026   //
0027   int SyncIt(const SyncObject* /*mastersync*/) override { return Fun4AllReturnCodes::SYNC_OK; }
0028   int GetSyncObject(SyncObject** /*mastersync*/) override { return Fun4AllReturnCodes::SYNC_NOOBJECT; }
0029   int NoSyncPushBackEvents(const int nevt) override { return PushBackEvents(nevt); }
0030   /* // no sync object we don't need to enable the sync variables */
0031   int setSyncBranches(PHNodeIOManager* /*IManager*/) override { return 0; }
0032   int PushBackEvents(const int /*i*/) override { return 0; }
0033   int SkipForThisManager(const int nevents) override { return PushBackEvents(nevents); }
0034   int HasSyncObject() const override { return 0; }
0035 };
0036
0037 #endif  // FUN4ALL_FUN4ALLRUNNODEINPUTMANAGER_H