stream
0.10.0
stream analysis framework
|
Handler for first.C in go4. More...
#include <TFirstStepProcessor.h>
Public Member Functions | |
TFirstStepProcessor () | |
constructor | |
TFirstStepProcessor (const char *name) | |
constructor | |
virtual | ~TFirstStepProcessor () |
destructor | |
virtual Bool_t | BuildEvent (TGo4EventElement *) |
build event - main entry point | |
virtual bool | InternalHistFormat () const |
When returns true, indicates that simple histogram format is used. | |
virtual void | SetSortedOrder (bool=true) |
set sorted order for created histogram folders | |
virtual bool | IsSortedOrder () |
is sorted order for created histogram folders | |
virtual base::H1handle | MakeH1 (const char *name, const char *title, int nbins, double left, double right, const char *xtitle=0) |
make H1 see base::ProcMgr::MakeH1 | |
virtual bool | GetH1NBins (base::H1handle h1, int &nbins) |
Get H1 bins numbers. | |
virtual void | FillH1 (base::H1handle h1, double x, double weight=1.) |
fill H1 | |
virtual double | GetH1Content (base::H1handle h1, int nbin) |
get h1 content | |
virtual void | SetH1Content (base::H1handle h1, int bin, double v=0.) |
set h1 content | |
virtual void | ClearH1 (base::H1handle h1) |
clear h1 | |
virtual void | CopyH1 (base::H1handle tgt, base::H1handle src) |
copy h1 | |
virtual void | SetH1Title (base::H1handle h1, const char *title) |
set h1 title | |
virtual base::H2handle | MakeH2 (const char *name, const char *title, int nbins1, double left1, double right1, int nbins2, double left2, double right2, const char *options=0) |
make H2 see base::ProcMgr::MakeH2 | |
virtual bool | GetH2NBins (base::H2handle h2, int &nbins1, int &nbins2) |
get h2 bins number | |
virtual void | FillH2 (base::H2handle h2, double x, double y, double weight=1.) |
fill h2 | |
virtual double | GetH2Content (base::H2handle h2, int bin1, int bin2) |
get h2 content | |
virtual void | SetH2Content (base::H2handle h2, int bin1, int bin2, double v=0.) |
set h2 content | |
virtual void | ClearH2 (base::H2handle h2) |
clear h2 | |
virtual void | SetH2Title (base::H2handle h2, const char *title) |
set h2 title | |
virtual void | ClearAllHistograms () |
clear all histograms | |
virtual base::C1handle | MakeC1 (const char *name, double left, double right, base::H1handle h1=0) |
make condition | |
virtual void | ChangeC1 (base::C1handle c1, double left, double right) |
change condition | |
virtual int | TestC1 (base::C1handle c1, double value, double *dist=0) |
test condition | |
virtual double | GetC1Limit (base::C1handle c1, bool isleft=true) |
get condition limit | |
virtual bool | RegisterObject (TObject *tobj, const char *subfolder=0) |
register object | |
virtual void | UserPreLoop () |
pre loop | |
virtual void | UserPostLoop () |
post loop | |
![]() | |
TRootProcMgr () | |
constructor | |
virtual | ~TRootProcMgr () |
destructor | |
virtual bool | CreateStore (const char *storename) |
create store | |
virtual bool | CloseStore () |
close store | |
virtual bool | CreateBranch (const char *name, const char *class_name, void **obj) |
create branch | |
virtual bool | CreateBranch (const char *name, void *member, const char *kind) |
create branch | |
virtual bool | StoreEvent () |
store event | |
bool | CallFunc (const char *funcname, void *arg) |
call function | |
![]() | |
ProcMgr () | |
constructor | |
virtual | ~ProcMgr () |
destructor | |
ProcMgr * | AddProcessor (Processor *proc) |
add processor | |
void | SetSecondName (const std::string &name="second.C") |
Set name of second macro, which executed after first.C. More... | |
void | ClearSecondName () |
Clear name of second macro, will not be executed at all. | |
const std::string & | GetSecondName () const |
Returns number of second macro. | |
bool | RegisterProc (StreamProc *proc, unsigned kind, unsigned brdid) |
Enter processor for processing data of specified kind. | |
unsigned | NumProc () const |
Get number of registered processors. | |
StreamProc * | GetProc (unsigned n) const |
Get processor by sequence number. | |
StreamProc * | FindProc (const char *name) const |
Find processor by name. More... | |
void | SetHistFilling (int lvl) |
Set histogram fill level for all processors. More... | |
void | SetDebug (int lvl=0) |
Set debug level. | |
int | GetDebug () const |
Returns debug level. | |
virtual void | SetStoreKind (unsigned kind=1) |
Set store kind for all processors. More... | |
virtual void | AddRunLog (const char *msg) |
Add run log. | |
virtual void | AddErrLog (const char *msg) |
Add error log. | |
virtual bool | DoLog () |
Returns true if logging is enabled. | |
virtual void | PrintLog (const char *msg) |
print log message | |
virtual void | TagH1Time (H1handle h1) |
Tag histogram time. | |
virtual void | TagH2Time (H2handle h2) |
Tag histogram time. | |
bool | IsRawAnalysis () const |
Returns true if raw analysis is configured. | |
void | SetRawAnalysis (bool on=true) |
Enable/disable raw analysis. More... | |
bool | IsTriggeredAnalysis () const |
Returns true if triggered analysis is configured. | |
void | SetTriggeredAnalysis (bool on=true) |
Enabled/disable triggered analysis is configured. More... | |
bool | IsStreamAnalysis () const |
Returns true if full timed stream analysis is configured. | |
void | SetTimeSorting (bool on) |
Set sorting flag for all registered processors. More... | |
void | SetTimeMasterIndex (unsigned indx) |
Specify processor index, which is used as time reference for all others. | |
void | ProvideRawData (const Buffer &buf) |
Method to provide raw data on base of data kind to the processor. | |
bool | AnalyzeSyncMarkers () |
Check current sync markers TODO: configure which processor is time master TODO: work with unsynchronized SYNC messages - not always the same id in the front TODO: process not only last sync message. | |
bool | CollectNewTriggers () |
Method to collect triggers. More... | |
bool | ScanDataForNewTriggers () |
Method to produce data for new triggers. More... | |
bool | AnalyzeNewData (base::Event *&evt) |
Analyze new data, if triggered analysis configured - immediately produce new event. | |
bool | HasTrigEvent () const |
Returns true if trigger even exists. | |
bool | AddToTrigEvent (const std::string &name, base::SubEvent *sub) |
add subevent with the name to the trigger event More... | |
bool | ProduceNextEvent (base::Event *&evt) |
Very central method - select if possible data for next event. More... | |
virtual bool | ProcessEvent (base::Event *evt) |
Process event - consequently calls all event processors. | |
void | UserPreLoop (Processor *only_proc=nullptr, bool call_when_running=false) |
pre-loop | |
void | UserPostLoop (Processor *only_proc=nullptr) |
post-loop | |
Protected Attributes | |
long | fTotalDataSize |
processed data size | |
long | fNumInpBufs |
processed number of buffers | |
long | fNumOutEvents |
created number of output events | |
![]() | |
std::string | fSecondName |
! name of second.C script | |
std::vector< StreamProc * > | fProc |
! all stream processors | |
StreamProcMap | fMap |
! map for fast access | |
std::vector< EventProc * > | fEvProc |
! all event processors | |
GlobalMarksQueue | fTriggers |
!< list of current triggers | |
unsigned | fTimeMasterIndex |
! processor index, which time is used for all other subsystems | |
AnalysisKind | fAnalysisKind |
! ignore all events, only single scan, not output events | |
TTree * | fTree {nullptr} |
! abstract tree pointer, will be used in ROOT implementation | |
int | fDfltHistLevel |
! default histogram fill level for any new created processor | |
int | fDfltStoreKind |
! default store kind for any new created processor | |
base::Event * | fTrigEvent {nullptr} |
! current event, filled when performing triggered analysis | |
int | fDebug {0} |
! debug level | |
Additional Inherited Members | |
![]() | |
static ProcMgr * | instance () |
Return global instance of processor manager, provided by framework. | |
static void | ClearInstancePointer (ProcMgr *mgr=nullptr) |
clear instance pointer | |
static ProcMgr * | AddProc (Processor *proc) |
add processor to instance | |
![]() | |
enum | { MaxBrdId = 256 } |
enum | { NoSyncIndex = 0xfffffffe , DummyIndex = 0xffffffff } |
typedef std::map< unsigned, StreamProc * > | StreamProcMap |
map of stream processors | |
![]() | |
virtual unsigned | SyncIdRange () const |
range for sync messages | |
int | SyncIdDiff (unsigned id1, unsigned id2) const |
Method calculated difference id2-id1, used for sync markers identification Sync ID overflow is taken into account. More... | |
void | DeleteAllProcessors () |
Delete all processors. | |
![]() | |
static ProcMgr * | fInstance = 0 |
! instance | |
Handler for first.C in go4.