dd/de7/Fun4AllDstInputManager_8h_source.html

// Tell emacs that this is a C++ source

//  -*- C++ -*-.

#ifndef FUN4ALL_FUN4ALLDSTINPUTMANAGER_H

#define FUN4ALL_FUN4ALLDSTINPUTMANAGER_H


#include "Fun4AllInputManager.h"


#include <map>

#include <string>


class PHCompositeNode;

class PHNodeIOManager;

class SyncObject;


class Fun4AllDstInputManager : public Fun4AllInputManager

{

 public:

  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 *iman);

  void Print(const std::string &what = "ALL") const override;

  int PushBackEvents(const int i) override;

  int HasSyncObject() const override;


 protected:

  int ReadNextEventSyncObject();

  void ReadRunTTree(const int i) { m_ReadRunTTree = i; }

  void IManager(PHNodeIOManager *iman) { m_IManager = iman; }

  PHNodeIOManager *IManager() { return m_IManager; }

  void runNode(PHCompositeNode *node) { m_RunNode = node; }

  PHCompositeNode *runNode() { return m_RunNode; }

  void runNodeCopy(PHCompositeNode *node) { m_RunNodeCopy = node; }

  PHCompositeNode *runNodeCopy() { return m_RunNodeCopy; }

  void runNodeSum(PHCompositeNode *node) { m_RunNodeSum = node; }

  PHCompositeNode *runNodeSum() { return m_RunNodeSum; }

  std::string RunNodeName() const { return RunNode; }

  std::string fullfilename;


 private:

  int m_ReadRunTTree = 1;

  int events_total = 0;

  int events_thisfile = 0;

  int events_skipped_during_sync = 0;

  int m_HaveSyncObject = 0;

  std::map<const std::string, int> branchread;

  std::string syncbranchname;

  PHCompositeNode *dstNode = nullptr;

  PHCompositeNode *m_RunNode = nullptr;

  PHCompositeNode *m_RunNodeCopy = nullptr;

  PHCompositeNode *m_RunNodeSum = nullptr;

  PHNodeIOManager *m_IManager = nullptr;

  SyncObject *syncobject = nullptr;

  std::string RunNode = "RUN";

};


#endif /* __FUN4ALLDSTINPUTMANAGER_H__ */