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

#include <BmnOnlineDecoder.h>

Inheritance diagram for BmnOnlineDecoder:
Collaboration diagram for BmnOnlineDecoder:

Public Member Functions

 BmnOnlineDecoder ()
virtual ~BmnOnlineDecoder ()
BmnStatus Decode (TString dirname, TString startFile, Bool_t runCurrent)
BmnStatus OpenStream ()
void ProcessStream ()
BmnStatus CloseStream ()
BmnStatus BatchDirectory (TString dirname)
BmnStatus BatchDirectoryToSocket (TString dirname)
void SetBmnSetup (BmnSetup v)
BmnSetup GetBmnSetup () const
void SetPeriodID (uint32_t v)
uint32_t GetPeriodID () const
void SetDetectorSetup (map< DetectorId, bool > setup)
void SetDaqAddress (TString addr)
void SetProcessNormEvents (bool val=true)
void SetProcessStatEvents (bool val=true)
void SetDigiSocket (uint32_t val=RAW_DECODER_SOCKET_PORT)
 BmnOnlineDecoder ()
virtual ~BmnOnlineDecoder ()
BmnStatus Decode (TString dirname, TString startFile, Bool_t runCurrent)
BmnStatus OpenStream ()
void ProcessStream ()
BmnStatus CloseStream ()
BmnStatus BatchDirectory (TString dirname)
BmnStatus BatchDirectoryToSocket (TString dirname)
void SetBmnSetup (BmnSetup v)
BmnSetup GetBmnSetup () const
void SetPeriodID (uint32_t v)
uint32_t GetPeriodID () const
void SetDetectorSetup (map< DetectorId, bool > setup)
void SetDaqAddress (TString addr)
void SetProcessNormEvents (bool val=true)
void SetProcessStatEvents (bool val=true)
void SetDigiSocket (uint32_t val=RAW_DECODER_SOCKET_PORT)
Public Member Functions inherited from TNamed
 TNamed ()
 TNamed (const char *name, const char *title)
 TNamed (const TNamed &named)
 TNamed (const TString &name, const TString &title)
virtual ~TNamed ()
void Clear (Option_t *option="") override
TObject * Clone (const char *newname="") const override
Int_t Compare (const TObject *obj) const override
void Copy (TObject &named) const override
virtual void FillBuffer (char *&buffer)
const char * GetName () const override
const char * GetTitle () const override
ULong_t Hash () const override
TClass * IsA () const override
Bool_t IsSortable () const override
void ls (Option_t *option="") const override
TNamed & operator= (const TNamed &rhs)
void Print (Option_t *option="") const override
virtual void SetName (const char *name)
virtual void SetNameTitle (const char *name, const char *title)
virtual void SetTitle (const char *title="")
virtual Int_t Sizeof () const
void Streamer (TBuffer &) override
void StreamerNVirtual (TBuffer &ClassDef_StreamerNVirtual_b)
Public Member Functions inherited from TObject
 TObject ()
 TObject (const TObject &object)
virtual ~TObject ()
void AbstractMethod (const char *method) const
virtual void AppendPad (Option_t *option="")
virtual void Browse (TBrowser *b)
ULong_t CheckedHash ()
virtual const char * ClassName () const
virtual void Delete (Option_t *option="")
virtual Int_t DistancetoPrimitive (Int_t px, Int_t py)
virtual void Draw (Option_t *option="")
virtual void DrawClass () const
virtual TObject * DrawClone (Option_t *option="") const
virtual void Dump () const
virtual void Error (const char *method, const char *msgfmt,...) const
virtual void Execute (const char *method, const char *params, Int_t *error=nullptr)
virtual void Execute (TMethod *method, TObjArray *params, Int_t *error=nullptr)
virtual void ExecuteEvent (Int_t event, Int_t px, Int_t py)
virtual void Fatal (const char *method, const char *msgfmt,...) const
virtual TObject * FindObject (const char *name) const
virtual TObject * FindObject (const TObject *obj) const
virtual Option_t * GetDrawOption () const
virtual const char * GetIconName () const
virtual char * GetObjectInfo (Int_t px, Int_t py) const
virtual Option_t * GetOption () const
virtual UInt_t GetUniqueID () const
virtual Bool_t HandleTimer (TTimer *timer)
Bool_t HasInconsistentHash () const
virtual void Info (const char *method, const char *msgfmt,...) const
virtual Bool_t InheritsFrom (const char *classname) const
virtual Bool_t InheritsFrom (const TClass *cl) const
virtual void Inspect () const
void InvertBit (UInt_t f)
Bool_t IsDestructed () const
virtual Bool_t IsEqual (const TObject *obj) const
virtual Bool_t IsFolder () const
R__ALWAYS_INLINE Bool_t IsOnHeap () const
R__ALWAYS_INLINE Bool_t IsZombie () const
void MayNotUse (const char *method) const
virtual Bool_t Notify ()
void Obsolete (const char *method, const char *asOfVers, const char *removedFromVers) const
void operator delete (void *ptr)
void operator delete (void *ptr, void *vp)
void operator delete[] (void *ptr)
void operator delete[] (void *ptr, void *vp)
void * operator new (size_t sz)
void * operator new (size_t sz, void *vp)
void * operator new[] (size_t sz)
void * operator new[] (size_t sz, void *vp)
TObject & operator= (const TObject &rhs)
virtual void Paint (Option_t *option="")
virtual void Pop ()
virtual Int_t Read (const char *name)
virtual void RecursiveRemove (TObject *obj)
void ResetBit (UInt_t f)
virtual void SaveAs (const char *filename="", Option_t *option="") const
virtual void SavePrimitive (std::ostream &out, Option_t *option="")
void SetBit (UInt_t f)
void SetBit (UInt_t f, Bool_t set)
virtual void SetDrawOption (Option_t *option="")
virtual void SetUniqueID (UInt_t uid)
void StreamerNVirtual (TBuffer &ClassDef_StreamerNVirtual_b)
virtual void SysError (const char *method, const char *msgfmt,...) const
R__ALWAYS_INLINE Bool_t TestBit (UInt_t f) const
Int_t TestBits (UInt_t f) const
virtual void UseCurrentStyle ()
virtual void Warning (const char *method, const char *msgfmt,...) const
virtual Int_t Write (const char *name=nullptr, Int_t option=0, Int_t bufsize=0)
virtual Int_t Write (const char *name=nullptr, Int_t option=0, Int_t bufsize=0) const

Static Public Member Functions

static void StripView (TString OrigFileName, TString TestFileName, uint32_t periodID=8, uint32_t runID=0, BmnSetup fSetup=kBMNSETUP, bool FillOccupancy=true)
static void StripView (TString OrigFileName, TString TestFileName, uint32_t periodID=8, uint32_t runID=0, BmnSetup fSetup=kBMNSETUP, bool FillOccupancy=true)
Static Public Member Functions inherited from TNamed
static TClass * Class ()
static const char * Class_Name ()
static constexpr Version_t Class_Version ()
static const char * DeclFileName ()
Static Public Member Functions inherited from TObject
static TClass * Class ()
static const char * Class_Name ()
static constexpr Version_t Class_Version ()
static const char * DeclFileName ()
static Longptr_t GetDtorOnly ()
static Bool_t GetObjectStat ()
static void SetDtorOnly (void *obj)
static void SetObjectStat (Bool_t stat)

Private Member Functions

BmnStatus InitDecoder (string)
BmnStatus InitDecoder (TString)
BmnStatus InitDecoder (uint32_t runID)
BmnStatus ConnectDataSocket ()
BmnStatus ConnectDigiSocket ()
BmnStatus StartNewRun (uint32_t runID)
BmnStatus AddRun2DB ()
void ProcessFileRun (TString digiName, UInt_t timeLimit=WAIT_LIMIT)
BmnStatus InitDecoder (string)
BmnStatus InitDecoder (TString)
BmnStatus InitDecoder (uint32_t runID)
BmnStatus ConnectDataSocket ()
BmnStatus ConnectDigiSocket ()
BmnStatus StartNewRun (uint32_t runID)
BmnStatus AddRun2DB ()
void ProcessFileRun (TString digiName, UInt_t timeLimit=WAIT_LIMIT)

Static Private Member Functions

template<typename SST>
static void InitCanvas (TString DetName, unique_ptr< SST > &stationSet, TCanvas *&canStrip, vector< PadInfo * > &canStripPads, vector< vector< vector< TH1F * > > > *histStrip)
template<typename DigiType>
static void FillHists (vector< vector< vector< TH1F * > > > &hist_vec, TClonesArray *digs, bool set_bin_content=false)
static TString WatchNext (TString dirname, TString filename, Int_t cycleWait)
static TString WatchNext (Int_t inotifDir, Int_t cycleWait)
static Int_t GetRunIdFromName (TString name)
template<typename SST>
static void InitCanvas (TString DetName, unique_ptr< SST > &stationSet, TCanvas *&canStrip, vector< PadInfo * > &canStripPads, vector< vector< vector< TH1F * > > > *histStrip)
template<typename DigiType>
static void FillHists (vector< vector< vector< TH1F * > > > &hist_vec, TClonesArray *digs, bool set_bin_content=false)
static TString WatchNext (TString dirname, TString filename, Int_t cycleWait)
static TString WatchNext (Int_t inotifDir, Int_t cycleWait)
static Int_t GetRunIdFromName (TString name)

Private Attributes

void * _ctx
void * _decoSocket
TString fDAQAddr
BmnSetup fBmnSetup
BmnRawDataDecoder * rawDataDecoder
map< DetectorId, bool > fDetectorSetup
TString _curFile
TString _curDir
Int_t fEvents
uint32_t fPeriodID
uint32_t fRunID
BmnDataReceiver * dataReceiver
Int_t _inotifDir
Int_t _inotifDirW
Int_t _inotifFile
Int_t _inotifFileW
Bool_t fKeepWorking
void * _socket_mcast
void * _socket_data
Byte_t buf [MAX_BUF_LEN]
bool _do_process_stat_ev
bool _do_process_norm_ev
uint32_t _digi_socket

Additional Inherited Members

Public Types inherited from TObject
enum  EDeprecatedStatusBits
enum  EStatusBits
Public Attributes inherited from TObject
 kIsOnHeap
 kNotDeleted
 kZombie
 kInconsistent
 kBitMask
 kSingleKey
 kOverwrite
 kWriteDelete
 kObjInCanvas
 kCanDelete
 kMustCleanup
 kIsReferenced
 kHasUUID
 kCannotPick
 kNoContextMenu
 kInvalidObject
Protected Member Functions inherited from TNamed
void SavePrimitiveNameTitle (std::ostream &out, const char *variable_name)
Protected Member Functions inherited from TObject
virtual void DoError (int level, const char *location, const char *fmt, va_list va) const
void MakeZombie ()
Static Protected Member Functions inherited from TObject
static void SavePrimitiveConstructor (std::ostream &out, TClass *cl, const char *variable_name, const char *constructor_agrs="", Bool_t empty_line=kTRUE)
static void SavePrimitiveDraw (std::ostream &out, const char *variable_name, Option_t *option=nullptr)
static TString SavePrimitiveVector (std::ostream &out, const char *prefix, Int_t len, Double_t *arr, Bool_t empty_line=kFALSE)
Protected Attributes inherited from TNamed
TString fName
TString fTitle
Protected Attributes inherited from TObject
 kOnlyPrepStep

Detailed Description

Definition at line 39 of file BmnOnlineDecoder.h.

Constructor & Destructor Documentation

◆ BmnOnlineDecoder() [1/2]

BmnOnlineDecoder::BmnOnlineDecoder ( )

Definition at line 37 of file BmnOnlineDecoder.cxx.

References _ctx, _digi_socket, _do_process_norm_ev, _do_process_stat_ev, fBmnSetup, fKeepWorking, fRunID, kBMNSETUP, RAW_DECODER_SOCKET_PORT, rawDataDecoder, and UNKNOWN_RUNID.

Referenced by GetRunIdFromName().

Here is the caller graph for this function:

◆ ~BmnOnlineDecoder() [1/2]

BmnOnlineDecoder::~BmnOnlineDecoder ( )
virtual

Definition at line 48 of file BmnOnlineDecoder.cxx.

References _ctx, rawDataDecoder, and signal().

Here is the call graph for this function:

◆ BmnOnlineDecoder() [2/2]

BmnOnlineDecoder::BmnOnlineDecoder ( )

◆ ~BmnOnlineDecoder() [2/2]

virtual BmnOnlineDecoder::~BmnOnlineDecoder ( )
virtual

Member Function Documentation

◆ AddRun2DB() [1/2]

BmnStatus BmnOnlineDecoder::AddRun2DB ( )
private

Definition at line 685 of file BmnOnlineDecoder.cxx.

References TDatime::AsString(), UniRun::CreateRun(), fPeriodID, fRunEndTime, fRunID, fRunStartTime, UniRun::GetEndDatetime(), UniRun::GetEventCount(), UniRun::GetRun(), UniRun::GetStartDatetime(), kBMNERROR, kBMNSUCCESS, rawDataDecoder, UniRun::SetEndDatetime(), UniRun::SetEventCount(), UniRun::SetStartDatetime(), and UNKNOWN_RUNID.

Referenced by ProcessStream().

Here is the call graph for this function:
Here is the caller graph for this function:

◆ AddRun2DB() [2/2]

BmnStatus BmnOnlineDecoder::AddRun2DB ( )
private

◆ BatchDirectory() [1/2]

BmnStatus BmnOnlineDecoder::BatchDirectory ( TString dirname)

Definition at line 834 of file BmnOnlineDecoder.cxx.

References _ctx, _curDir, _curFile, _decoSocket, TString::Data(), DBGERR, i, InitDecoder(), kBMNERROR, n, BmnConverterTools::ParseRawFileName(), ProcessFileRun(), RAW_DECODER_SOCKET_PORT, and rawDataDecoder.

Referenced by BatchDirectory().

Here is the call graph for this function:
Here is the caller graph for this function:

◆ BatchDirectory() [2/2]

BmnStatus BmnOnlineDecoder::BatchDirectory ( TString dirname)

◆ BatchDirectoryToSocket() [1/2]

BmnStatus BmnOnlineDecoder::BatchDirectoryToSocket ( TString dirname)

Definition at line 918 of file BmnOnlineDecoder.cxx.

References _curDir, _curFile, i, kBMNERROR, n, BmnConverterTools::ParseRawFileName(), and signal().

Here is the call graph for this function:

◆ BatchDirectoryToSocket() [2/2]

BmnStatus BmnOnlineDecoder::BatchDirectoryToSocket ( TString dirname)

◆ CloseStream() [1/2]

BmnStatus BmnOnlineDecoder::CloseStream ( )

Definition at line 213 of file BmnOnlineDecoder.cxx.

References _ctx, _decoSocket, _socket_data, DBG, and kBMNFINISH.

Referenced by ProcessStream().

Here is the caller graph for this function:

◆ CloseStream() [2/2]

BmnStatus BmnOnlineDecoder::CloseStream ( )

◆ ConnectDataSocket() [1/2]

BmnStatus BmnOnlineDecoder::ConnectDataSocket ( )
private

Definition at line 152 of file BmnOnlineDecoder.cxx.

References _ctx, _socket_data, DBGERR, fDAQAddr, kBMNERROR, kBMNSUCCESS, MAX_ADDR_LEN, and ZMQ_STREAM.

Referenced by OpenStream(), and ProcessStream().

Here is the caller graph for this function:

◆ ConnectDataSocket() [2/2]

BmnStatus BmnOnlineDecoder::ConnectDataSocket ( )
private

◆ ConnectDigiSocket() [1/2]

BmnStatus BmnOnlineDecoder::ConnectDigiSocket ( )
private

Definition at line 174 of file BmnOnlineDecoder.cxx.

References _ctx, _decoSocket, _digi_socket, TString::Data(), DBGERR, kBMNERROR, and kBMNSUCCESS.

Referenced by OpenStream().

Here is the call graph for this function:
Here is the caller graph for this function:

◆ ConnectDigiSocket() [2/2]

BmnStatus BmnOnlineDecoder::ConnectDigiSocket ( )
private

◆ Decode() [1/2]

BmnStatus BmnOnlineDecoder::Decode ( TString dirname,
TString startFile,
Bool_t runCurrent )

Definition at line 225 of file BmnOnlineDecoder.cxx.

References _ctx, _curDir, _curFile, _decoSocket, TString::Data(), DBG, DBGERR, InitDecoder(), kBMNERROR, kBMNSUCCESS, ProcessFileRun(), RAW_DECODER_SOCKET_PORT, rawDataDecoder, RUN_FILE_CHECK_PERIOD, and WatchNext().

Referenced by monDecoder().

Here is the call graph for this function:
Here is the caller graph for this function:

◆ Decode() [2/2]

BmnStatus BmnOnlineDecoder::Decode ( TString dirname,
TString startFile,
Bool_t runCurrent )

◆ FillHists() [1/2]

template<typename DigiType>
void BmnOnlineDecoder::FillHists ( vector< vector< vector< TH1F * > > > & hist_vec,
TClonesArray * digs,
bool set_bin_content = false )
inlinestaticprivate

Definition at line 155 of file BmnOnlineDecoder.h.

References TObjArray::GetEntriesFast(), TObject::TClonesArray, and TObjArray::UncheckedAt().

Referenced by StripView().

Here is the call graph for this function:
Here is the caller graph for this function:

◆ FillHists() [2/2]

template<typename DigiType>
void BmnOnlineDecoder::FillHists ( vector< vector< vector< TH1F * > > > & hist_vec,
TClonesArray * digs,
bool set_bin_content = false )
inlinestaticprivate

Definition at line 155 of file BmnOnlineDecoder.h.

References TObjArray::GetEntriesFast(), TObject::TClonesArray, and TObjArray::UncheckedAt().

Here is the call graph for this function:

◆ GetBmnSetup() [1/2]

BmnSetup BmnOnlineDecoder::GetBmnSetup ( ) const
inline

Definition at line 53 of file BmnOnlineDecoder.h.

References fBmnSetup.

◆ GetBmnSetup() [2/2]

BmnSetup BmnOnlineDecoder::GetBmnSetup ( ) const
inline

Definition at line 53 of file BmnOnlineDecoder.h.

References fBmnSetup.

◆ GetPeriodID() [1/2]

uint32_t BmnOnlineDecoder::GetPeriodID ( ) const
inline

Definition at line 57 of file BmnOnlineDecoder.h.

References fPeriodID.

◆ GetPeriodID() [2/2]

uint32_t BmnOnlineDecoder::GetPeriodID ( ) const
inline

Definition at line 57 of file BmnOnlineDecoder.h.

References fPeriodID.

◆ GetRunIdFromName() [1/2]

Int_t BmnOnlineDecoder::GetRunIdFromName ( TString name)
staticprivate

Definition at line 978 of file BmnOnlineDecoder.cxx.

References TObjArray::At(), TString::Data(), TObjArray::Delete(), TObjArray::GetEntriesFast(), and TPRegexp::MatchS().

Here is the call graph for this function:

◆ GetRunIdFromName() [2/2]

Int_t BmnOnlineDecoder::GetRunIdFromName ( TString name)
staticprivate

References BmnOnlineDecoder(), _ctx, _curDir, _curFile, _decoSocket, _digi_socket, _do_process_norm_ev, _do_process_stat_ev, _inotifDir, _inotifDirW, _inotifFile, _inotifFileW, _socket_data, _socket_mcast, buf, dataReceiver, fBmnSetup, fDAQAddr, fDetectorSetup, fEvents, fKeepWorking, fPeriodID, fRunID, MAX_BUF_LEN, and rawDataDecoder.

Here is the call graph for this function:

◆ InitCanvas() [1/2]

template<typename SST>
void BmnOnlineDecoder::InitCanvas ( TString DetName,
unique_ptr< SST > & stationSet,
TCanvas *& canStrip,
vector< PadInfo * > & canStripPads,
vector< vector< vector< TH1F * > > > * histStrip )
inlinestaticprivate

Definition at line 77 of file BmnOnlineDecoder.h.

References PadInfo::current, TString::Data(), TPad::Divide(), TPad::GetPad(), TH1::GetXaxis(), TH1::GetYaxis(), PadInfo::normalize, PAD_HEIGHT_SIL, PAD_WIDTH_SIL, PadInfo::ref, TVirtualPad::SetGrid(), BmnHist::SetHistStyleTH1(), TAttLine::SetLineColor(), TNamed::SetTitle(), and STRIP_COMP_COLS.

Referenced by StripView().

Here is the call graph for this function:
Here is the caller graph for this function:

◆ InitCanvas() [2/2]

template<typename SST>
void BmnOnlineDecoder::InitCanvas ( TString DetName,
unique_ptr< SST > & stationSet,
TCanvas *& canStrip,
vector< PadInfo * > & canStripPads,
vector< vector< vector< TH1F * > > > * histStrip )
inlinestaticprivate

Definition at line 77 of file BmnOnlineDecoder.h.

References PadInfo::current, TString::Data(), TPad::Divide(), TPad::GetPad(), TH1::GetXaxis(), TH1::GetYaxis(), PadInfo::normalize, PAD_HEIGHT_SIL, PAD_WIDTH_SIL, PadInfo::ref, TVirtualPad::SetGrid(), BmnHist::SetHistStyleTH1(), TAttLine::SetLineColor(), TNamed::SetTitle(), and STRIP_COMP_COLS.

Here is the call graph for this function:

◆ InitDecoder() [1/6]

BmnStatus BmnOnlineDecoder::InitDecoder ( string fRawFileName)
private

Definition at line 62 of file BmnOnlineDecoder.cxx.

References InitDecoder().

Referenced by BatchDirectory(), Decode(), InitDecoder(), InitDecoder(), ProcessStream(), and StartNewRun().

Here is the call graph for this function:
Here is the caller graph for this function:

◆ InitDecoder() [2/6]

BmnStatus BmnOnlineDecoder::InitDecoder ( string )
private

◆ InitDecoder() [3/6]

BmnStatus BmnOnlineDecoder::InitDecoder ( TString RawFileName)
private

Definition at line 67 of file BmnOnlineDecoder.cxx.

References DBG, BmnFileProp::GetRunId(), InitDecoder(), kBMNERROR, kBMNSUCCESS, BmnConverterTools::ParseRawFileName(), and rawDataDecoder.

Here is the call graph for this function:

◆ InitDecoder() [4/6]

BmnStatus BmnOnlineDecoder::InitDecoder ( TString )
private

◆ InitDecoder() [5/6]

BmnStatus BmnOnlineDecoder::InitDecoder ( uint32_t runID)
private

Definition at line 91 of file BmnOnlineDecoder.cxx.

References _curDir, _curFile, fBmnSetup, fDetectorSetup, fPeriodID, BmnDecoder::GetPeriodId(), BmnDecoder::GetRunId(), kBMNSETUP, rawDataDecoder, BmnDecoder::SetCSCMapping(), BmnDecoder::SetFHCalCalibration(), BmnDecoder::SetFHCalMapping(), BmnDecoder::SetGemMapping(), BmnDecoder::SetHodoCalibration(), BmnDecoder::SetHodoMapping(), BmnDecoder::SetMSCMapping(), BmnDecoder::SetNdetCalibration(), BmnDecoder::SetNdetMapping(), BmnDecoder::SetScWallCalibration(), BmnDecoder::SetScWallMapping(), BmnDecoder::SetSiBTMapping(), BmnDecoder::SetSiliconMapping(), BmnDecoder::SetTof400Mapping(), BmnDecoder::SetTof700Geom(), BmnDecoder::SetTof700Mapping(), BmnDecoder::SetTOF700ReferenceRun(), BmnDecoder::SetTof701Mapping(), BmnDecoder::SetTrigChannelMapping(), BmnDecoder::SetTrigPlaceMapping(), BmnDecoder::SetUseCalibFile(), and BmnDecoder::SetVspMapping().

Here is the call graph for this function:

◆ InitDecoder() [6/6]

BmnStatus BmnOnlineDecoder::InitDecoder ( uint32_t runID)
private

◆ OpenStream() [1/2]

BmnStatus BmnOnlineDecoder::OpenStream ( )

Definition at line 202 of file BmnOnlineDecoder.cxx.

References _ctx, ConnectDataSocket(), ConnectDigiSocket(), DBG, kBMNERROR, and kBMNSUCCESS.

Referenced by ProcessStream().

Here is the call graph for this function:
Here is the caller graph for this function:

◆ OpenStream() [2/2]

BmnStatus BmnOnlineDecoder::OpenStream ( )

◆ ProcessFileRun() [1/2]

void BmnOnlineDecoder::ProcessFileRun ( TString digiName,
UInt_t timeLimit = WAIT_LIMIT )
private

Definition at line 730 of file BmnOnlineDecoder.cxx.

References _decoSocket, TBuffer::Buffer(), DBG, fEvents, DigiArrays::header, kBMNERROR, kBMNFINISH, kBMNSUCCESS, kBMNTIMEOUT, TBuffer::kWrite, TBuffer::Length(), rawDataDecoder, TBufferIO::Reset(), and TBufferIO::WriteObject().

Referenced by BatchDirectory(), and Decode().

Here is the call graph for this function:
Here is the caller graph for this function:

◆ ProcessFileRun() [2/2]

void BmnOnlineDecoder::ProcessFileRun ( TString digiName,
UInt_t timeLimit = WAIT_LIMIT )
private

References WAIT_LIMIT.

◆ ProcessStream() [1/2]

void BmnOnlineDecoder::ProcessStream ( )

Definition at line 276 of file BmnOnlineDecoder.cxx.

References _decoSocket, _do_process_norm_ev, _do_process_stat_ev, _socket_data, AddRun2DB(), buf, TBuffer::Buffer(), CloseStream(), ConnectDataSocket(), DBG, fEvents, fKeepWorking, fPeriodID, fRunID, BmnEventHeader::GetEventType(), DigiArrays::header, InitDecoder(), kBMNERROR, kBMNPAYLOAD, kBMNSUCCESS, kNBYTESINWORD, TBuffer::kWrite, TBuffer::Length(), MAX_ADDR_LEN, MAX_BUF_LEN, MPD_EVENT_HEAD_WORDS, MPD_EVENT_HEAD_WORDS_OLD, MSG_TIMEOUT, OpenStream(), BmnConverterTools::ParseComplexTLV(), rawDataDecoder, TBufferIO::Reset(), signal(), StartNewRun(), SYNC_EVENT, SYNC_EVENT_OLD, SYNC_JSON, SYNC_RUN_START, SYNC_RUN_STOP, SYNC_STAT, and TBufferIO::WriteObject().

Referenced by monStreamDecoder(), and monStreamDecoderStat().

Here is the call graph for this function:
Here is the caller graph for this function:

◆ ProcessStream() [2/2]

void BmnOnlineDecoder::ProcessStream ( )

◆ SetBmnSetup() [1/2]

void BmnOnlineDecoder::SetBmnSetup ( BmnSetup v)
inline

Definition at line 51 of file BmnOnlineDecoder.h.

References fBmnSetup, and v.

Referenced by BatchDirectory(), monDecoder(), monStreamDecoder(), and monStreamDecoderStat().

Here is the caller graph for this function:

◆ SetBmnSetup() [2/2]

void BmnOnlineDecoder::SetBmnSetup ( BmnSetup v)
inline

Definition at line 51 of file BmnOnlineDecoder.h.

References fBmnSetup, and v.

◆ SetDaqAddress() [1/2]

void BmnOnlineDecoder::SetDaqAddress ( TString addr)
inline

Definition at line 61 of file BmnOnlineDecoder.h.

References fDAQAddr.

Referenced by monStreamDecoder(), and monStreamDecoderStat().

Here is the caller graph for this function:

◆ SetDaqAddress() [2/2]

void BmnOnlineDecoder::SetDaqAddress ( TString addr)
inline

Definition at line 61 of file BmnOnlineDecoder.h.

References fDAQAddr.

◆ SetDetectorSetup() [1/2]

void BmnOnlineDecoder::SetDetectorSetup ( map< DetectorId, bool > setup)
inline

Definition at line 59 of file BmnOnlineDecoder.h.

References fDetectorSetup.

Referenced by BatchDirectory(), monStreamDecoder(), and monStreamDecoderStat().

Here is the caller graph for this function:

◆ SetDetectorSetup() [2/2]

void BmnOnlineDecoder::SetDetectorSetup ( map< DetectorId, bool > setup)
inline

Definition at line 59 of file BmnOnlineDecoder.h.

References fDetectorSetup.

◆ SetDigiSocket() [1/2]

void BmnOnlineDecoder::SetDigiSocket ( uint32_t val = RAW_DECODER_SOCKET_PORT)
inline

Definition at line 66 of file BmnOnlineDecoder.h.

References _digi_socket, and RAW_DECODER_SOCKET_PORT.

Referenced by monStreamDecoder(), and monStreamDecoderStat().

Here is the caller graph for this function:

◆ SetDigiSocket() [2/2]

void BmnOnlineDecoder::SetDigiSocket ( uint32_t val = RAW_DECODER_SOCKET_PORT)
inline

Definition at line 66 of file BmnOnlineDecoder.h.

References _digi_socket, and RAW_DECODER_SOCKET_PORT.

◆ SetPeriodID() [1/2]

void BmnOnlineDecoder::SetPeriodID ( uint32_t v)
inline

Definition at line 55 of file BmnOnlineDecoder.h.

References fPeriodID, and v.

Referenced by BatchDirectory(), monDecoder(), monStreamDecoder(), and monStreamDecoderStat().

Here is the caller graph for this function:

◆ SetPeriodID() [2/2]

void BmnOnlineDecoder::SetPeriodID ( uint32_t v)
inline

Definition at line 55 of file BmnOnlineDecoder.h.

References fPeriodID, and v.

◆ SetProcessNormEvents() [1/2]

void BmnOnlineDecoder::SetProcessNormEvents ( bool val = true)
inline

Definition at line 63 of file BmnOnlineDecoder.h.

References _do_process_norm_ev.

Referenced by monStreamDecoder(), and monStreamDecoderStat().

Here is the caller graph for this function:

◆ SetProcessNormEvents() [2/2]

void BmnOnlineDecoder::SetProcessNormEvents ( bool val = true)
inline

Definition at line 63 of file BmnOnlineDecoder.h.

References _do_process_norm_ev.

◆ SetProcessStatEvents() [1/2]

void BmnOnlineDecoder::SetProcessStatEvents ( bool val = true)
inline

Definition at line 64 of file BmnOnlineDecoder.h.

References _do_process_stat_ev.

Referenced by monStreamDecoder(), and monStreamDecoderStat().

Here is the caller graph for this function:

◆ SetProcessStatEvents() [2/2]

void BmnOnlineDecoder::SetProcessStatEvents ( bool val = true)
inline

Definition at line 64 of file BmnOnlineDecoder.h.

References _do_process_stat_ev.

◆ StartNewRun() [1/2]

BmnStatus BmnOnlineDecoder::StartNewRun ( uint32_t runID)
private

Definition at line 665 of file BmnOnlineDecoder.cxx.

References fRunID, InitDecoder(), kBMNERROR, kBMNSUCCESS, and rawDataDecoder.

Referenced by ProcessStream().

Here is the call graph for this function:
Here is the caller graph for this function:

◆ StartNewRun() [2/2]

BmnStatus BmnOnlineDecoder::StartNewRun ( uint32_t runID)
private

◆ StripView() [1/2]

void BmnOnlineDecoder::StripView ( TString OrigFileName,
TString TestFileName,
uint32_t periodID = 8,
uint32_t runID = 0,
BmnSetup fSetup = kBMNSETUP,
bool FillOccupancy = true )
static

Definition at line 995 of file BmnOnlineDecoder.cxx.

References BmnCSCStationSet::Create(), BmnGemStripStationSet::Create(), BmnSiBTStationSet::Create(), BmnSiliconStationSet::Create(), BmnVSPStationSet::Create(), BmnHist::DrawRef(), FillHists(), TTree::GetEntries(), TTree::GetEntry(), BmnEventHeader::GetEventId(), i, InitCanvas(), TPad::SaveAs(), TTree::SetBranchAddress(), STRIP_COMP_COLS, and TObject::TClonesArray.

Here is the call graph for this function:

◆ StripView() [2/2]

void BmnOnlineDecoder::StripView ( TString OrigFileName,
TString TestFileName,
uint32_t periodID = 8,
uint32_t runID = 0,
BmnSetup fSetup = kBMNSETUP,
bool FillOccupancy = true )
static

References kBMNSETUP.

◆ WatchNext() [1/4]

TString BmnOnlineDecoder::WatchNext ( Int_t inotifDir,
Int_t cycleWait )
staticprivate

Definition at line 803 of file BmnOnlineDecoder.cxx.

References TString::Data(), DBG, i, and INOTIF_BUF_LEN.

Here is the call graph for this function:

◆ WatchNext() [2/4]

TString BmnOnlineDecoder::WatchNext ( Int_t inotifDir,
Int_t cycleWait )
staticprivate

◆ WatchNext() [3/4]

TString BmnOnlineDecoder::WatchNext ( TString dirname,
TString filename,
Int_t cycleWait )
staticprivate

Definition at line 775 of file BmnOnlineDecoder.cxx.

References TString::Data(), TSubString::Data(), DBG, i, n, and TString::Strip().

Referenced by Decode().

Here is the call graph for this function:
Here is the caller graph for this function:

◆ WatchNext() [4/4]

TString BmnOnlineDecoder::WatchNext ( TString dirname,
TString filename,
Int_t cycleWait )
staticprivate

Member Data Documentation

◆ _ctx

void * BmnOnlineDecoder::_ctx
private

Definition at line 185 of file BmnOnlineDecoder.h.

Referenced by BmnOnlineDecoder(), ~BmnOnlineDecoder(), BatchDirectory(), CloseStream(), ConnectDataSocket(), ConnectDigiSocket(), Decode(), GetRunIdFromName(), and OpenStream().

◆ _curDir

TString BmnOnlineDecoder::_curDir
private

Definition at line 192 of file BmnOnlineDecoder.h.

Referenced by BatchDirectory(), BatchDirectoryToSocket(), Decode(), GetRunIdFromName(), and InitDecoder().

◆ _curFile

TString BmnOnlineDecoder::_curFile
private

Definition at line 191 of file BmnOnlineDecoder.h.

Referenced by BatchDirectory(), BatchDirectoryToSocket(), Decode(), GetRunIdFromName(), and InitDecoder().

◆ _decoSocket

void * BmnOnlineDecoder::_decoSocket
private

Definition at line 186 of file BmnOnlineDecoder.h.

Referenced by BatchDirectory(), CloseStream(), ConnectDigiSocket(), Decode(), GetRunIdFromName(), ProcessFileRun(), and ProcessStream().

◆ _digi_socket

uint32_t BmnOnlineDecoder::_digi_socket
private

Definition at line 211 of file BmnOnlineDecoder.h.

Referenced by BmnOnlineDecoder(), ConnectDigiSocket(), GetRunIdFromName(), and SetDigiSocket().

◆ _do_process_norm_ev

bool BmnOnlineDecoder::_do_process_norm_ev
private

Definition at line 209 of file BmnOnlineDecoder.h.

Referenced by BmnOnlineDecoder(), GetRunIdFromName(), ProcessStream(), and SetProcessNormEvents().

◆ _do_process_stat_ev

bool BmnOnlineDecoder::_do_process_stat_ev
private

Definition at line 208 of file BmnOnlineDecoder.h.

Referenced by BmnOnlineDecoder(), GetRunIdFromName(), ProcessStream(), and SetProcessStatEvents().

◆ _inotifDir

Int_t BmnOnlineDecoder::_inotifDir
private

Definition at line 197 of file BmnOnlineDecoder.h.

Referenced by GetRunIdFromName().

◆ _inotifDirW

Int_t BmnOnlineDecoder::_inotifDirW
private

Definition at line 198 of file BmnOnlineDecoder.h.

Referenced by GetRunIdFromName().

◆ _inotifFile

Int_t BmnOnlineDecoder::_inotifFile
private

Definition at line 199 of file BmnOnlineDecoder.h.

Referenced by GetRunIdFromName().

◆ _inotifFileW

Int_t BmnOnlineDecoder::_inotifFileW
private

Definition at line 200 of file BmnOnlineDecoder.h.

Referenced by GetRunIdFromName().

◆ _socket_data

void * BmnOnlineDecoder::_socket_data
private

Definition at line 205 of file BmnOnlineDecoder.h.

Referenced by CloseStream(), ConnectDataSocket(), GetRunIdFromName(), and ProcessStream().

◆ _socket_mcast

void * BmnOnlineDecoder::_socket_mcast
private

Definition at line 204 of file BmnOnlineDecoder.h.

Referenced by GetRunIdFromName().

◆ buf

Byte_t BmnOnlineDecoder::buf
private

Definition at line 206 of file BmnOnlineDecoder.h.

Referenced by GetRunIdFromName(), and ProcessStream().

◆ dataReceiver

BmnDataReceiver * BmnOnlineDecoder::dataReceiver
private

Definition at line 196 of file BmnOnlineDecoder.h.

Referenced by GetRunIdFromName().

◆ fBmnSetup

BmnSetup BmnOnlineDecoder::fBmnSetup
private

Definition at line 188 of file BmnOnlineDecoder.h.

Referenced by BmnOnlineDecoder(), GetBmnSetup(), GetRunIdFromName(), InitDecoder(), and SetBmnSetup().

◆ fDAQAddr

TString BmnOnlineDecoder::fDAQAddr
private

Definition at line 187 of file BmnOnlineDecoder.h.

Referenced by ConnectDataSocket(), GetRunIdFromName(), and SetDaqAddress().

◆ fDetectorSetup

map< DetectorId, bool > BmnOnlineDecoder::fDetectorSetup
private

Definition at line 190 of file BmnOnlineDecoder.h.

Referenced by GetRunIdFromName(), InitDecoder(), and SetDetectorSetup().

◆ fEvents

Int_t BmnOnlineDecoder::fEvents
private

Definition at line 193 of file BmnOnlineDecoder.h.

Referenced by GetRunIdFromName(), ProcessFileRun(), and ProcessStream().

◆ fKeepWorking

Bool_t BmnOnlineDecoder::fKeepWorking
private

Definition at line 202 of file BmnOnlineDecoder.h.

Referenced by BmnOnlineDecoder(), GetRunIdFromName(), and ProcessStream().

◆ fPeriodID

uint32_t BmnOnlineDecoder::fPeriodID
private

Definition at line 194 of file BmnOnlineDecoder.h.

Referenced by AddRun2DB(), GetPeriodID(), GetRunIdFromName(), InitDecoder(), ProcessStream(), and SetPeriodID().

◆ fRunID

uint32_t BmnOnlineDecoder::fRunID
private

Definition at line 195 of file BmnOnlineDecoder.h.

Referenced by BmnOnlineDecoder(), AddRun2DB(), GetRunIdFromName(), ProcessStream(), and StartNewRun().

◆ rawDataDecoder

BmnRawDataDecoder * BmnOnlineDecoder::rawDataDecoder
private

Definition at line 189 of file BmnOnlineDecoder.h.

Referenced by BmnOnlineDecoder(), ~BmnOnlineDecoder(), AddRun2DB(), BatchDirectory(), Decode(), GetRunIdFromName(), InitDecoder(), InitDecoder(), ProcessFileRun(), ProcessStream(), and StartNewRun().

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