stream  0.10.0
stream analysis framework
mbs/Processor.h
1 #ifndef MBS_PROCESSOR_H
2 #define MBS_PROCESSOR_H
3 
4 #include "base/StreamProc.h"
5 
6 
7 namespace mbs {
8 
12  class Processor : public base::StreamProc {
13 
14  protected:
15 
17 
18  unsigned fLastSync1;
19  unsigned fLastSync2;
20 
23  virtual bool doTriggerSelection() const { return false; }
24 
27  virtual double MaximumDisorderTm() const { return 1e-6; }
28 
29  public:
30 
31  Processor();
32 
33  virtual ~Processor();
34 
36  virtual bool FirstBufferScan(const base::Buffer& buf);
37 
38  virtual bool SecondBufferScan(const base::Buffer& buf);
39 
40  };
41 }
42 
43 
44 #endif
Memory management class.
Definition: Buffer.h:49
LocalStampConverter class should perform conversion of time stamps to time in seconds.
Definition: TimeStamp.h:35
Abstract processor of data streams.
Definition: StreamProc.h:21
This could be generic processor for data, coming from MBS For the moment it is rather CERN beamtime-s...
Definition: mbs/Processor.h:12
base::LocalStampConverter fConv1
! use converter to emulate local time scale
Definition: mbs/Processor.h:16
virtual bool SecondBufferScan(const base::Buffer &buf)
Second generic scan of buffer Here selection of data for region-of-interest should be performed.
Definition: mbs/Processor.cxx:87
virtual bool FirstBufferScan(const base::Buffer &buf)
Scan all messages, find reference signals.
Definition: mbs/Processor.cxx:40
virtual ~Processor()
destructor
Definition: mbs/Processor.cxx:36
virtual bool doTriggerSelection() const
Returns true when processor used to select trigger signal TRB3 not yet able to perform trigger select...
Definition: mbs/Processor.h:23
unsigned fLastSync1
! last sync id in first scan
Definition: mbs/Processor.h:18
unsigned fLastSync2
! last sync id in second scan
Definition: mbs/Processor.h:19
virtual double MaximumDisorderTm() const
This is maximum disorder time for MBS TODO: derive this value from sub-items.
Definition: mbs/Processor.h:27