BmnOnlineSource Class Reference

#include <BmnOnlineSource.h>

Inheritance diagram for BmnOnlineSource:

Collaboration diagram for BmnOnlineSource:

Public Member Functions
	BmnOnlineSource (TString endpoint="tcp://localhost:5555")
virtual	~BmnOnlineSource ()
virtual Bool_t	Init ()
virtual Int_t	ReadEvent (UInt_t=0)
virtual void	Close ()
	BmnOnlineSource (const BmnOnlineSource &)=delete
BmnOnlineSource &	operator= (const BmnOnlineSource &)=delete
	BmnOnlineSource (TString endpoint="tcp://localhost:5555")
virtual	~BmnOnlineSource ()
virtual Bool_t	Init ()
virtual Int_t	ReadEvent (UInt_t=0)
virtual void	Close ()
	BmnOnlineSource (const BmnOnlineSource &)=delete
BmnOnlineSource &	operator= (const BmnOnlineSource &)=delete

Static Public Member Functions
template<typename T >
static void	DeserializeZmqMessage (zmq_msg_t *zmq_message, std::unique_ptr< T > &output)
template<typename T >
static void	DeserializeZmqMessage (zmq_msg_t *zmq_message, std::unique_ptr< T > &output)

Protected Member Functions
void	RegisterBranches (std::unique_ptr< TTree > &tree)
void	UploadDataToRegisteredBranches (std::unique_ptr< TTree > &tree)
void	RegisterBranches (std::unique_ptr< TTree > &tree)
void	UploadDataToRegisteredBranches (std::unique_ptr< TTree > &tree)

Protected Attributes
TString	fEndpoint
std::shared_ptr< void >	fZmqContext
std::shared_ptr< void >	fZmqSubSocket
std::unordered_map< std::string, std::unique_ptr< TClonesArray > >	fRegisteredBranches

Detailed Description

Definition at line 18 of file BmnOnlineSource.h.

Constructor & Destructor Documentation

BmnOnlineSource() [1/4]

BmnOnlineSource::BmnOnlineSource

(

TString

endpoint = "tcp://localhost:5555"

)

Definition at line 6 of file BmnOnlineSource.cxx.

~BmnOnlineSource() [1/2]

BmnOnlineSource::~BmnOnlineSource ( )

virtual

Definition at line 12 of file BmnOnlineSource.cxx.

BmnOnlineSource() [2/4]

BmnOnlineSource::BmnOnlineSource ( const BmnOnlineSource &  )

delete

BmnOnlineSource() [3/4]

BmnOnlineSource::BmnOnlineSource

(

TString

endpoint = "tcp://localhost:5555"

)

~BmnOnlineSource() [2/2]

virtual BmnOnlineSource::~BmnOnlineSource ( )

virtual

BmnOnlineSource() [4/4]

BmnOnlineSource::BmnOnlineSource ( const BmnOnlineSource &  )

delete

Member Function Documentation

Close() [1/2]

void BmnOnlineSource::Close ( )

virtual

Definition at line 65 of file BmnOnlineSource.cxx.

References fRegisteredBranches, fZmqContext, and fZmqSubSocket.

Close() [2/2]

virtual void BmnOnlineSource::Close ( )

virtual

DeserializeZmqMessage() [1/2]

template<typename T >

static void BmnOnlineSource::DeserializeZmqMessage ( zmq_msg_t *  zmq_message, std::unique_ptr< T > &  output  )

inlinestatic

Definition at line 31 of file BmnOnlineSource.h.

Referenced by ReadEvent().

DeserializeZmqMessage() [2/2]

template<typename T >

static void BmnOnlineSource::DeserializeZmqMessage ( zmq_msg_t *  zmq_message, std::unique_ptr< T > &  output  )

inlinestatic

Definition at line 31 of file BmnOnlineSource.h.

Init() [1/2]

Bool_t BmnOnlineSource::Init ( )

virtual

Definition at line 14 of file BmnOnlineSource.cxx.

References fEndpoint, fZmqContext, and fZmqSubSocket.

Init() [2/2]

virtual Bool_t BmnOnlineSource::Init ( )

virtual

operator=() [1/2]

BmnOnlineSource & BmnOnlineSource::operator= ( const BmnOnlineSource &  )

delete

operator=() [2/2]

BmnOnlineSource & BmnOnlineSource::operator= ( const BmnOnlineSource &  )

delete

ReadEvent() [1/2]

Int_t BmnOnlineSource::ReadEvent ( UInt_t  = 0 )

virtual

Definition at line 37 of file BmnOnlineSource.cxx.

References DeserializeZmqMessage(), fZmqSubSocket, RegisterBranches(), and UploadDataToRegisteredBranches().

ReadEvent() [2/2]

virtual Int_t BmnOnlineSource::ReadEvent ( UInt_t  = 0 )

virtual

RegisterBranches() [1/2]

void BmnOnlineSource::RegisterBranches ( std::unique_ptr< TTree > &  tree )

protected

Definition at line 72 of file BmnOnlineSource.cxx.

References fRegisteredBranches.

Referenced by ReadEvent().

RegisterBranches() [2/2]

void BmnOnlineSource::RegisterBranches ( std::unique_ptr< TTree > &  tree )

protected

UploadDataToRegisteredBranches() [1/2]

void BmnOnlineSource::UploadDataToRegisteredBranches ( std::unique_ptr< TTree > &  tree )

protected

Definition at line 103 of file BmnOnlineSource.cxx.

References fRegisteredBranches.

Referenced by ReadEvent().

UploadDataToRegisteredBranches() [2/2]

void BmnOnlineSource::UploadDataToRegisteredBranches ( std::unique_ptr< TTree > &  tree )

protected

Member Data Documentation

fEndpoint

TString BmnOnlineSource::fEndpoint

protected

Definition at line 41 of file BmnOnlineSource.h.

Referenced by Init().

fRegisteredBranches

std::unordered_map< std::string, std::unique_ptr< TClonesArray > > BmnOnlineSource::fRegisteredBranches

protected

Definition at line 47 of file BmnOnlineSource.h.

Referenced by Close(), RegisterBranches(), and UploadDataToRegisteredBranches().

fZmqContext

std::shared_ptr< void > BmnOnlineSource::fZmqContext

protected

Definition at line 43 of file BmnOnlineSource.h.

Referenced by Close(), and Init().

fZmqSubSocket

std::shared_ptr< void > BmnOnlineSource::fZmqSubSocket

protected

Definition at line 44 of file BmnOnlineSource.h.

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

---

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

• base/source/BmnOnlineSource.h
• install/include/BmnOnlineSource.h
• base/source/BmnOnlineSource.cxx