#include <ProcMgr.h>

Inheritance diagram for base::ProcMgr:

Collaboration diagram for base::ProcMgr:

Public Member Functions
	ProcMgr ()
virtual	~ProcMgr ()
bool	RegisterProc (StreamProc *proc, unsigned kind, unsigned brdid)
unsigned	NumProc () const
StreamProc *	GetProc (unsigned n) const
virtual H1handle	MakeH1 (const char name, const char title, int nbins, double left, double right, const char *xtitle=0)
virtual void	FillH1 (H1handle h1, double x, double weight=1.)
virtual H2handle	MakeH2 (const char name, const char title, int nbins1, double left1, double right1, int nbins2, double left2, double right2, const char *options=0)
virtual void	FillH2 (H1handle h2, double x, double y, double weight=1.)
virtual C1handle	MakeC1 (const char *name, double left, double right, base::H1handle h1=0)
virtual void	ChangeC1 (C1handle c1, double left, double right)
virtual int	TestC1 (C1handle c1, double value, double *dist=0)
virtual double	GetC1Limit (C1handle c1, bool isleft=true)
bool	IsRawAnalysis () const
void	SetRawAnalysis (bool on)
void	SetTimeSorting (bool on)
void	SetTimeMasterIndex (unsigned indx)
void	ProvideRawData (const Buffer &buf)
void	ScanNewData ()
bool	SkipAllData ()
bool	AnalyzeSyncMarkers ()
bool	CollectNewTriggers ()
bool	ScanDataForNewTriggers ()
bool	ProduceNextEvent (base::Event *&evt)
Static Public Member Functions
static ProcMgr *	instance ()
static ProcMgr *	AddProc (StreamProc *proc)
Protected Types
enum	{ MaxBrdId = 256 }
enum	{ NoSyncIndex = 0xfffffffe, DummyIndex = 0xffffffff }
typedef std::vector< StreamProc * >	ProcessorsVect
typedef std::map< unsigned, StreamProc * >	ProcessorsMap
Protected Member Functions
virtual unsigned	SyncIdRange () const
int	SyncIdDiff (unsigned id1, unsigned id2) const
Protected Attributes
ProcessorsVect	fProc
ProcessorsMap	fMap
GlobalTriggerMarksQueue	fTriggers
	list of current triggers
unsigned	fTimeMasterIndex
	processor index, which time is used for all other subsystems
bool	fRawAnalysisOnly
	ignore all events, only single scan, not ouput events
Static Protected Attributes
static ProcMgr *	fInstance = 0

Detailed Description

Class base::ProcMgr is central manager of processors and interface to any external frameworks like ROOT or Go4 or ... It is singleton - the only instance for whole system

Definition at line 17 of file ProcMgr.h.

Member Typedef Documentation

typedef std::map<unsigned,StreamProc*> base::ProcMgr::ProcessorsMap [protected]

Definition at line 28 of file ProcMgr.h.

typedef std::vector<StreamProc*> base::ProcMgr::ProcessorsVect [protected]

Definition at line 27 of file ProcMgr.h.

Member Enumeration Documentation

anonymous enum [protected]

Enumerator:

MaxBrdId

Definition at line 20 of file ProcMgr.h.

anonymous enum [protected]

Enumerator:

NoSyncIndex
DummyIndex

Definition at line 22 of file ProcMgr.h.

Constructor & Destructor Documentation

base::ProcMgr::ProcMgr ( )

Definition at line 9 of file ProcMgr.cxx.

References fInstance.

base::ProcMgr::~ProcMgr ( ) [virtual]

Definition at line 19 of file ProcMgr.cxx.

References fInstance, and fProc.

Member Function Documentation

base::ProcMgr * base::ProcMgr::AddProc ( StreamProc * proc ) [static]

Definition at line 40 of file ProcMgr.cxx.

References fInstance, and fProc.

Referenced by base::StreamProc::StreamProc().

bool base::ProcMgr::AnalyzeSyncMarkers ( )

Check current sync markers

Definition at line 132 of file ProcMgr.cxx.

References DummyIndex, base::StreamProc::eraseSyncAt(), fProc, base::StreamProc::fSyncFlag, base::StreamProc::fSyncScanIndex, fTimeMasterIndex, base::StreamProc::getSync(), base::SyncMarker::globaltm, base::StreamProc::IsSynchronisationRequired(), base::SyncMarker::localtm, NoSyncIndex, base::StreamProc::numSyncs(), SyncIdDiff(), and base::SyncMarker::uniqueid.

Referenced by TCBMFirstProc::BuildEvent().

virtual void base::ProcMgr::ChangeC1	(	C1handle	c1,
		double	left,
		double	right
	)			`[inline, virtual]`

Reimplemented in TCBMFirstProc.

Definition at line 69 of file ProcMgr.h.

Referenced by base::StreamProc::ChangeC1().

bool base::ProcMgr::CollectNewTriggers ( )

Method to collect triggers

Definition at line 265 of file ProcMgr.cxx.

References fProc, fTimeMasterIndex, and fTriggers.

Referenced by TCBMFirstProc::BuildEvent().

virtual void base::ProcMgr::FillH1	(	H1handle	h1,
		double	x,
		double	weight = `1.`
	)			`[inline, virtual]`

Reimplemented in TCBMFirstProc.

Definition at line 63 of file ProcMgr.h.

Referenced by base::StreamProc::FillH1().

virtual void base::ProcMgr::FillH2	(	H1handle	h2,
		double	x,
		double	y,
		double	weight = `1.`
	)			`[inline, virtual]`

Reimplemented in TCBMFirstProc.

Definition at line 66 of file ProcMgr.h.

Referenced by base::StreamProc::FillH2().

virtual double base::ProcMgr::GetC1Limit	(	C1handle	c1,
		bool	isleft = `true`
	)			`[inline, virtual]`

Reimplemented in TCBMFirstProc.

Definition at line 73 of file ProcMgr.h.

Referenced by base::StreamProc::GetC1Limit().

StreamProc* base::ProcMgr::GetProc ( unsigned n ) const [inline]

Definition at line 60 of file ProcMgr.h.

References fProc, and NumProc().

base::ProcMgr * base::ProcMgr::instance ( ) [static]

Definition at line 34 of file ProcMgr.cxx.

References fInstance.

bool base::ProcMgr::IsRawAnalysis ( ) const [inline]

Definition at line 77 of file ProcMgr.h.

References fRawAnalysisOnly.

Referenced by TCBMFirstProc::BuildEvent(), and ProduceNextEvent().

virtual C1handle base::ProcMgr::MakeC1	(	const char *	name,
		double	left,
		double	right,
		base::H1handle	h1 = `0`
	)			`[inline, virtual]`

Reimplemented in TCBMFirstProc.

Definition at line 68 of file ProcMgr.h.

Referenced by base::StreamProc::MakeC1().

virtual H1handle base::ProcMgr::MakeH1	(	const char *	name,
		const char *	title,
		int	nbins,
		double	left,
		double	right,
		const char *	xtitle = `0`
	)			`[inline, virtual]`

Reimplemented in TCBMFirstProc.

Definition at line 62 of file ProcMgr.h.

Referenced by base::StreamProc::MakeH1(), and base::SysCoreProc::SysCoreProc().

virtual H2handle base::ProcMgr::MakeH2	(	const char *	name,
		const char *	title,
		int	nbins1,
		double	left1,
		double	right1,
		int	nbins2,
		double	left2,
		double	right2,
		const char *	options = `0`
	)			`[inline, virtual]`

Reimplemented in TCBMFirstProc.

Definition at line 65 of file ProcMgr.h.

Referenced by base::StreamProc::MakeH2().

unsigned base::ProcMgr::NumProc ( ) const [inline]

Definition at line 59 of file ProcMgr.h.

References fProc.

Referenced by GetProc().

bool base::ProcMgr::ProduceNextEvent ( base::Event *& evt )

Very central method - select if possible data for next event Only can be done that each processor is agree to deliver data within trigger interval. It may not be a case when messages from future buffers may be required

Definition at line 326 of file ProcMgr.cxx.

References base::Event::DestroyEvents(), fProc, fTriggers, IsRawAnalysis(), and base::Event::SetTriggerTime().

Referenced by TCBMFirstProc::BuildEvent().

void base::ProcMgr::ProvideRawData ( const Buffer & buf )

Method to provide raw data on base of data kind to the processor

Definition at line 78 of file ProcMgr.cxx.

References fMap, MaxBrdId, and base::Buffer::null().

Referenced by TCBMFirstProc::BuildEvent().