BmnRoot 26.10.0-18-g4e3414f9
Software framework of the BM@N experiment
Loading...
Searching...
No Matches
BmnMQSource Class Reference

#include <BmnMQSource.h>

Inheritance diagram for BmnMQSource:
Collaboration diagram for BmnMQSource:

Public Member Functions

 BmnMQSource (std::string addr="tcp://localhost:6666", Bool_t toFile=kFALSE)
virtual ~BmnMQSource ()
Bool_t Init ()
Int_t ReadEvent (UInt_t i=0)
void Close ()
void FillEventHeader (FairEventHeader *feh)
virtual Int_t CheckMaxEventNo (Int_t end_ev)
FairRunAna * GetRunInstance ()
void SetRunInstance (FairRunAna *run)
uint32_t GetPeriodId ()
 BmnMQSource (std::string addr="tcp://localhost:6666", Bool_t toFile=kFALSE)
virtual ~BmnMQSource ()
Bool_t Init ()
Int_t ReadEvent (UInt_t i=0)
void Close ()
void FillEventHeader (FairEventHeader *feh)
virtual Int_t CheckMaxEventNo (Int_t end_ev)
FairRunAna * GetRunInstance ()
void SetRunInstance (FairRunAna *run)
uint32_t GetPeriodId ()

Private Member Functions

TString GetDstNameFromRunId (Int_t runId)
Bool_t InitZMQ ()
TString GetDstNameFromRunId (Int_t runId)
Bool_t InitZMQ ()

Private Attributes

FairRunAna * fRunInst
zmq_msg_t _msg
TBufferFile * _tBuf
void * _ctx
void * _decoSocket
std::string _addrString
std::vector< TNamed * > fNamVec
std::vector< TClonesArray * > fArrVec
const Int_t TimeDelta = 50000
Bool_t fFirstEvent
Bool_t fToFile
uint32_t fPeriodId
Int_t iEventNumber
Int_t iT0BranchIndex
FairEventHeader * fEventHeader

Detailed Description

Definition at line 26 of file BmnMQSource.h.

Constructor & Destructor Documentation

◆ BmnMQSource() [1/2]

BmnMQSource::BmnMQSource ( std::string addr = "tcp://localhost:6666",
Bool_t toFile = kFALSE )

Definition at line 21 of file BmnMQSource.cxx.

References _addrString, _tBuf, fEventHeader, fFirstEvent, fPeriodId, fToFile, and iEventNumber.

Referenced by InitZMQ().

Here is the caller graph for this function:

◆ ~BmnMQSource() [1/2]

BmnMQSource::~BmnMQSource ( )
virtual

Definition at line 32 of file BmnMQSource.cxx.

◆ BmnMQSource() [2/2]

BmnMQSource::BmnMQSource ( std::string addr = "tcp://localhost:6666",
Bool_t toFile = kFALSE )

◆ ~BmnMQSource() [2/2]

virtual BmnMQSource::~BmnMQSource ( )
virtual

Member Function Documentation

◆ CheckMaxEventNo() [1/2]

virtual Int_t BmnMQSource::CheckMaxEventNo ( Int_t end_ev)
inlinevirtual

Definition at line 37 of file BmnMQSource.h.

◆ CheckMaxEventNo() [2/2]

virtual Int_t BmnMQSource::CheckMaxEventNo ( Int_t end_ev)
inlinevirtual

Definition at line 37 of file BmnMQSource.h.

◆ Close() [1/2]

void BmnMQSource::Close ( )

Definition at line 112 of file BmnMQSource.cxx.

References _ctx, _decoSocket, _tBuf, fArrVec, and fNamVec.

◆ Close() [2/2]

void BmnMQSource::Close ( )

◆ FillEventHeader() [1/2]

void BmnMQSource::FillEventHeader ( FairEventHeader * feh)

Definition at line 209 of file BmnMQSource.cxx.

References fEventHeader.

◆ FillEventHeader() [2/2]

void BmnMQSource::FillEventHeader ( FairEventHeader * feh)

◆ GetDstNameFromRunId() [1/2]

TString BmnMQSource::GetDstNameFromRunId ( Int_t runId)
inlineprivate

Definition at line 44 of file BmnMQSource.h.

◆ GetDstNameFromRunId() [2/2]

TString BmnMQSource::GetDstNameFromRunId ( Int_t runId)
inlineprivate

Definition at line 44 of file BmnMQSource.h.

◆ GetPeriodId() [1/2]

uint32_t BmnMQSource::GetPeriodId ( )
inline

Definition at line 41 of file BmnMQSource.h.

References fPeriodId.

◆ GetPeriodId() [2/2]

uint32_t BmnMQSource::GetPeriodId ( )
inline

Definition at line 41 of file BmnMQSource.h.

References fPeriodId.

◆ GetRunInstance() [1/2]

FairRunAna * BmnMQSource::GetRunInstance ( )
inline

Definition at line 38 of file BmnMQSource.h.

References fRunInst.

◆ GetRunInstance() [2/2]

FairRunAna * BmnMQSource::GetRunInstance ( )
inline

Definition at line 38 of file BmnMQSource.h.

References fRunInst.

◆ Init() [1/2]

Bool_t BmnMQSource::Init ( )

Definition at line 34 of file BmnMQSource.cxx.

References _decoSocket, _msg, _tBuf, TObject::Class(), TObject::ClassName(), fArrVec, fNamVec, fPeriodId, fRunId, BmnParts::GetArrays(), TCollection::GetName(), BmnParts::GetObjects(), BmnEventHeader::GetPeriodId(), DstEventHeader::GetPeriodId(), InitZMQ(), TCollection::SetName(), and TimeDelta.

Here is the call graph for this function:

◆ Init() [2/2]

Bool_t BmnMQSource::Init ( )

◆ InitZMQ() [1/2]

Bool_t BmnMQSource::InitZMQ ( )
private

Definition at line 220 of file BmnMQSource.cxx.

References _addrString, _ctx, _decoSocket, _tBuf, DBGERR, and TBuffer::kRead.

Referenced by Init().

Here is the caller graph for this function:

◆ InitZMQ() [2/2]

Bool_t BmnMQSource::InitZMQ ( )
private

References BmnMQSource(), _addrString, _ctx, _decoSocket, _msg, _tBuf, fArrVec, fEventHeader, fFirstEvent, fNamVec, fPeriodId, fRunInst, fToFile, iEventNumber, iT0BranchIndex, and TimeDelta.

Here is the call graph for this function:

◆ ReadEvent() [1/2]

Int_t BmnMQSource::ReadEvent ( UInt_t i = 0)

Definition at line 128 of file BmnMQSource.cxx.

References _decoSocket, _msg, _tBuf, TObject::Class(), fArrVec, fEventHeader, fNamVec, BmnParts::GetArrays(), BmnParts::GetObjects(), i, signal(), and TimeDelta.

Here is the call graph for this function:

◆ ReadEvent() [2/2]

Int_t BmnMQSource::ReadEvent ( UInt_t i = 0)

References i.

◆ SetRunInstance() [1/2]

void BmnMQSource::SetRunInstance ( FairRunAna * run)
inline

Definition at line 39 of file BmnMQSource.h.

References fRunInst.

◆ SetRunInstance() [2/2]

void BmnMQSource::SetRunInstance ( FairRunAna * run)
inline

Definition at line 39 of file BmnMQSource.h.

References fRunInst.

Member Data Documentation

◆ _addrString

std::string BmnMQSource::_addrString
private

Definition at line 55 of file BmnMQSource.h.

Referenced by BmnMQSource(), and InitZMQ().

◆ _ctx

void * BmnMQSource::_ctx
private

Definition at line 53 of file BmnMQSource.h.

Referenced by Close(), and InitZMQ().

◆ _decoSocket

void * BmnMQSource::_decoSocket
private

Definition at line 54 of file BmnMQSource.h.

Referenced by Close(), Init(), InitZMQ(), and ReadEvent().

◆ _msg

zmq_msg_t BmnMQSource::_msg
private

Definition at line 51 of file BmnMQSource.h.

Referenced by Init(), InitZMQ(), and ReadEvent().

◆ _tBuf

TBufferFile * BmnMQSource::_tBuf
private

Definition at line 52 of file BmnMQSource.h.

Referenced by BmnMQSource(), Close(), Init(), InitZMQ(), and ReadEvent().

◆ fArrVec

std::vector< TClonesArray * > BmnMQSource::fArrVec
private

Definition at line 57 of file BmnMQSource.h.

Referenced by Close(), Init(), InitZMQ(), and ReadEvent().

◆ fEventHeader

FairEventHeader * BmnMQSource::fEventHeader
private

Definition at line 68 of file BmnMQSource.h.

Referenced by BmnMQSource(), FillEventHeader(), InitZMQ(), and ReadEvent().

◆ fFirstEvent

Bool_t BmnMQSource::fFirstEvent
private

Definition at line 60 of file BmnMQSource.h.

Referenced by BmnMQSource(), and InitZMQ().

◆ fNamVec

std::vector< TNamed * > BmnMQSource::fNamVec
private

Definition at line 56 of file BmnMQSource.h.

Referenced by Close(), Init(), InitZMQ(), and ReadEvent().

◆ fPeriodId

uint32_t BmnMQSource::fPeriodId
private

Definition at line 64 of file BmnMQSource.h.

Referenced by BmnMQSource(), GetPeriodId(), Init(), and InitZMQ().

◆ fRunInst

FairRunAna * BmnMQSource::fRunInst
private

Definition at line 50 of file BmnMQSource.h.

Referenced by GetRunInstance(), InitZMQ(), and SetRunInstance().

◆ fToFile

Bool_t BmnMQSource::fToFile
private

Definition at line 61 of file BmnMQSource.h.

Referenced by BmnMQSource(), and InitZMQ().

◆ iEventNumber

Int_t BmnMQSource::iEventNumber
private

Definition at line 66 of file BmnMQSource.h.

Referenced by BmnMQSource(), and InitZMQ().

◆ iT0BranchIndex

Int_t BmnMQSource::iT0BranchIndex
private

Definition at line 67 of file BmnMQSource.h.

Referenced by InitZMQ().

◆ TimeDelta

const Int_t BmnMQSource::TimeDelta = 50000
private

Definition at line 59 of file BmnMQSource.h.

Referenced by Init(), InitZMQ(), and ReadEvent().

The documentation for this class was generated from the following files: