ProcBlock.hh

 
#ifndef __RAT_ProcBlock__
#define __RAT_ProcBlock__
 
#include <TStopwatch.h>
 
#include <RAT/Processor.hh>
#include <RAT/ProducerBlock.hh>
#include <vector>
 
namespace RAT {
 
class ProducerBlock;
 
class ProcBlock : public Processor {
 public:
  ProcBlock(ProducerBlock *prodBlock);
 
  virtual ~ProcBlock();
 
  virtual void BeginOfRun(DS::Run *run);
 
  virtual void EndOfRun(DS::Run *run);
 
  virtual void Clear();
 
  virtual void AddProcessor(Processor *proc);
 
  virtual void DeferAppend(Processor *proc);
 
  virtual Processor::Result DSEvent(DS::Root *ds);
 
 protected:
  void FlushDeferredAppends();
 
  std::vector<Processor *> fProcessorList;
 
  std::vector<double> fProcessorTime;
 
  std::vector<int> fProcessorExecutionCount;
 
  bool fSeenFirstEvent;
 
  TStopwatch fSourceTimer;
 
  double fSourceTime;
 
  int fSourceCount;
 
  std::vector<Processor *> fDeferredAppendList;
 
  ProducerBlock *prodBlock;
};
 
}  // namespace RAT
 
#endif