BmnRoot
Loading...
Searching...
No Matches
Classes | Public Member Functions | Public Attributes | List of all members
BmnConverterThread Class Reference

#include <BmnConverterThread.h>

Inheritance diagram for BmnConverterThread:
[legend]
Collaboration diagram for BmnConverterThread:
[legend]

Classes

struct  BmnEventData
 

Public Member Functions

 BmnConverterThread (queue< Int_t > *thread_queue, std::mutex *queue_access, std::condition_variable *queue_wait, Int_t id, Bool_t measure_time=kFALSE)
 
 BmnConverterThread (BmnConverterThread const &)=delete
 
BmnConverterThread & operator= (BmnConverterThread const &)=delete
 
virtual ~BmnConverterThread ()
 
void CreateTrees ()
 
void RegisterBranches ()
 
void RegisterSpillBranches ()
 
void ClearRawArrays ()
 
void ClearRawSpillArrays ()
 
void SpillEnd ()
 
void SetTrees (TTree *tree, TTree *treeSpills)
 
void SetPeriod (UInt_t v)
 
void SetData (Int_t taskId, Int_t len=0, UInt_t *data=nullptr, BmnEventType fCurEvType=kBMNEMPTY, UInt_t fRunId=7444, UInt_t fEventId=-1)
 
void SetInitData (vector< pair< int, pair< int, int > > > *vec_tree, vector< pair< int, pair< int, int > > > *vec_tree_spills)
 
void SetMerger (TBufferMerger *m)
 
void Terminate ()
 
void WriteTree ()
 
void WriteTreeSpills ()
 
void FinalizeFile ()
 
void SetExportExternalSpillStat (bool v)
 
 BmnConverterThread (queue< Int_t > *thread_queue, std::mutex *queue_access, std::condition_variable *queue_wait, Int_t id, Bool_t measure_time=kFALSE)
 
 BmnConverterThread (BmnConverterThread const &)=delete
 
BmnConverterThread & operator= (BmnConverterThread const &)=delete
 
virtual ~BmnConverterThread ()
 
void CreateTrees ()
 
void RegisterBranches ()
 
void RegisterSpillBranches ()
 
void ClearRawArrays ()
 
void ClearRawSpillArrays ()
 
void SpillEnd ()
 
void SetTrees (TTree *tree, TTree *treeSpills)
 
void SetPeriod (UInt_t v)
 
void SetData (Int_t taskId, Int_t len=0, UInt_t *data=nullptr, BmnEventType fCurEvType=kBMNEMPTY, UInt_t fRunId=7444, UInt_t fEventId=-1)
 
void SetInitData (vector< pair< int, pair< int, int > > > *vec_tree, vector< pair< int, pair< int, int > > > *vec_tree_spills)
 
void SetMerger (TBufferMerger *m)
 
void Terminate ()
 
void WriteTree ()
 
void WriteTreeSpills ()
 
void FinalizeFile ()
 
void SetExportExternalSpillStat (bool v)
 
- Public Member Functions inherited from BmnAbstractThread
void Run ()
 
int32_t GetRunningThreads ()
 
int32_t GetWaitingThreads ()
 
CDuration GetWaitingCTime ()
 
CDuration GetCalculationCTime ()
 
int32_t GetId ()
 
void Execute ()
 
void CancelReady ()
 
virtual void SetInitData (...)
 
virtual void SetData (...)
 
void Run ()
 
int32_t GetRunningThreads ()
 
int32_t GetWaitingThreads ()
 
CDuration GetWaitingCTime ()
 
CDuration GetCalculationCTime ()
 
int32_t GetId ()
 
void Execute ()
 
void CancelReady ()
 
virtual void SetInitData (...)
 
virtual void SetData (...)
 

Public Attributes

TTree * fRawTree
 
TTree * fRawTreeSpills
 
TBufferMerger * merger
 
std::shared_ptr< TBufferMergerFile > mergerFile
 
UInt_t rawData [10000000]
 
TClonesArray * sync
 
TClonesArray * adc32
 
TClonesArray * adc64
 
TClonesArray * adc128
 
TClonesArray * adc
 
TClonesArray * vsp
 
TClonesArray * hrb
 
TClonesArray * tdc
 
TClonesArray * tqdc_tdc
 
TClonesArray * tqdc_adc
 
TClonesArray * tdc_hgnd
 
TClonesArray * msc
 
TClonesArray * t0raw
 
BmnEventHeader * eventHeaderDAQ
 
std::map< uint8_t, uint32_t * > time_slice_map
 

Additional Inherited Members

- Protected Member Functions inherited from BmnAbstractThread
 BmnAbstractThread (std::queue< int32_t > *threadQueue, std::mutex *queueAccess, std::condition_variable *queueWait, int32_t id, bool measureTime=false)
 
 ~BmnAbstractThread ()
 
 BmnAbstractThread (std::queue< int32_t > *threadQueue, std::mutex *queueAccess, std::condition_variable *queueWait, int32_t id, bool measureTime=false)
 
 ~BmnAbstractThread ()
 
- Protected Attributes inherited from BmnAbstractThread
int32_t threadId
 
int32_t taskId
 

Detailed Description

Definition at line 25 of file BmnConverterThread.h.

Constructor & Destructor Documentation

◆ BmnConverterThread() [1/4]

BmnConverterThread::BmnConverterThread ( queue< Int_t > *  thread_queue,
std::mutex *  queue_access,
std::condition_variable *  queue_wait,
Int_t  id,
Bool_t  measure_time = kFALSE 
)
inline

Definition at line 61 of file BmnConverterThread.h.

◆ BmnConverterThread() [2/4]

BmnConverterThread::BmnConverterThread ( BmnConverterThread const &  )
delete

◆ ~BmnConverterThread() [1/2]

virtual BmnConverterThread::~BmnConverterThread ( )
inlinevirtual

Definition at line 92 of file BmnConverterThread.h.

References fRawTree, and fRawTreeSpills.

◆ BmnConverterThread() [3/4]

BmnConverterThread::BmnConverterThread ( queue< Int_t > *  thread_queue,
std::mutex *  queue_access,
std::condition_variable *  queue_wait,
Int_t  id,
Bool_t  measure_time = kFALSE 
)
inline

Definition at line 61 of file BmnConverterThread.h.

◆ BmnConverterThread() [4/4]

BmnConverterThread::BmnConverterThread ( BmnConverterThread const &  )
delete

◆ ~BmnConverterThread() [2/2]

virtual BmnConverterThread::~BmnConverterThread ( )
inlinevirtual

Definition at line 92 of file BmnConverterThread.h.

References fRawTree, and fRawTreeSpills.

Member Function Documentation

◆ ClearRawArrays() [1/2]

void BmnConverterThread::ClearRawArrays ( )

Definition at line 1360 of file BmnConverterThread.cxx.

References adc, adc128, adc32, adc64, hrb, sync, tdc, tdc_hgnd, tqdc_adc, tqdc_tdc, and vsp.

◆ ClearRawArrays() [2/2]

void BmnConverterThread::ClearRawArrays ( )

◆ ClearRawSpillArrays() [1/2]

void BmnConverterThread::ClearRawSpillArrays ( )

Definition at line 1375 of file BmnConverterThread.cxx.

References msc, and t0raw.

Referenced by SpillEnd().

◆ ClearRawSpillArrays() [2/2]

void BmnConverterThread::ClearRawSpillArrays ( )

◆ CreateTrees() [1/2]

void BmnConverterThread::CreateTrees ( )

Definition at line 48 of file BmnConverterThread.cxx.

References adc, adc128, adc32, adc64, eventHeaderDAQ, fRawTree, fRawTreeSpills, hrb, merger, mergerFile, msc, sync, t0raw, tdc, tdc_hgnd, BmnAbstractThread::threadId, tqdc_adc, tqdc_tdc, and vsp.

Referenced by BmnConverter::BmnConverter().

◆ CreateTrees() [2/2]

void BmnConverterThread::CreateTrees ( )

◆ FinalizeFile() [1/2]

void BmnConverterThread::FinalizeFile ( )

Definition at line 161 of file BmnConverterThread.cxx.

References mergerFile.

Referenced by BmnConverter::OutputTrees().

◆ FinalizeFile() [2/2]

void BmnConverterThread::FinalizeFile ( )

◆ operator=() [1/2]

BmnConverterThread & BmnConverterThread::operator= ( BmnConverterThread const &  )
delete

◆ operator=() [2/2]

BmnConverterThread & BmnConverterThread::operator= ( BmnConverterThread const &  )
delete

◆ RegisterBranches() [1/2]

void BmnConverterThread::RegisterBranches ( )

Definition at line 24 of file BmnConverterThread.cxx.

References adc, adc128, adc32, adc64, eventHeaderDAQ, fRawTree, hrb, sync, tdc, tdc_hgnd, tqdc_adc, tqdc_tdc, and vsp.

Referenced by BmnConverter::BmnConverter(), and BmnConverter::SeparateEventsBySpills().

◆ RegisterBranches() [2/2]

void BmnConverterThread::RegisterBranches ( )

◆ RegisterSpillBranches() [1/2]

void BmnConverterThread::RegisterSpillBranches ( )

Definition at line 42 of file BmnConverterThread.cxx.

References fRawTreeSpills, msc, and t0raw.

Referenced by BmnConverter::BmnConverter(), and BmnConverter::SeparateEventsBySpills().

◆ RegisterSpillBranches() [2/2]

void BmnConverterThread::RegisterSpillBranches ( )

◆ SetData() [1/2]

void BmnConverterThread::SetData ( Int_t  taskId,
Int_t  len = 0,
UInt_t *  data = nullptr,
BmnEventType  fCurEvType = kBMNEMPTY,
UInt_t  fRunId = 7444,
UInt_t  fEventId = -1 
)

Definition at line 173 of file BmnConverterThread.cxx.

References BmnConverterThread::BmnEventData::fCurEvType, BmnConverterThread::BmnEventData::fEventId, BmnConverterThread::BmnEventData::fRunId, rawData, and BmnAbstractThread::taskId.

Referenced by BmnConverter::OutputSpills().

◆ SetData() [2/2]

void BmnConverterThread::SetData ( Int_t  taskId,
Int_t  len = 0,
UInt_t *  data = nullptr,
BmnEventType  fCurEvType = kBMNEMPTY,
UInt_t  fRunId = 7444,
UInt_t  fEventId = -1 
)

◆ SetExportExternalSpillStat() [1/2]

void BmnConverterThread::SetExportExternalSpillStat ( bool  v)
inline

Definition at line 152 of file BmnConverterThread.h.

References v.

◆ SetExportExternalSpillStat() [2/2]

void BmnConverterThread::SetExportExternalSpillStat ( bool  v)
inline

Definition at line 152 of file BmnConverterThread.h.

References v.

◆ SetInitData() [1/2]

void BmnConverterThread::SetInitData ( vector< pair< int, pair< int, int > > > *  vec_tree,
vector< pair< int, pair< int, int > > > *  vec_tree_spills 
)
inline

Definition at line 116 of file BmnConverterThread.h.

Referenced by BmnConverter::FeedFile().

◆ SetInitData() [2/2]

void BmnConverterThread::SetInitData ( vector< pair< int, pair< int, int > > > *  vec_tree,
vector< pair< int, pair< int, int > > > *  vec_tree_spills 
)
inline

Definition at line 116 of file BmnConverterThread.h.

◆ SetMerger() [1/2]

void BmnConverterThread::SetMerger ( TBufferMerger *  m)
inline

Definition at line 124 of file BmnConverterThread.h.

References m, and merger.

Referenced by BmnConverter::BmnConverter(), and BmnConverter::OutputSpills().

◆ SetMerger() [2/2]

void BmnConverterThread::SetMerger ( TBufferMerger *  m)
inline

Definition at line 124 of file BmnConverterThread.h.

References m, and merger.

◆ SetPeriod() [1/2]

void BmnConverterThread::SetPeriod ( UInt_t  v)
inline

Definition at line 107 of file BmnConverterThread.h.

References v.

Referenced by BmnConverter::BmnConverter().

◆ SetPeriod() [2/2]

void BmnConverterThread::SetPeriod ( UInt_t  v)
inline

Definition at line 107 of file BmnConverterThread.h.

References v.

◆ SetTrees() [1/2]

void BmnConverterThread::SetTrees ( TTree *  tree,
TTree *  treeSpills 
)

Definition at line 76 of file BmnConverterThread.cxx.

References adc, adc128, adc32, adc64, eventHeaderDAQ, fRawTree, fRawTreeSpills, hrb, msc, sync, t0raw, tdc, tdc_hgnd, tqdc_adc, tqdc_tdc, and vsp.

Referenced by BmnConverter::OutputSpills().

◆ SetTrees() [2/2]

void BmnConverterThread::SetTrees ( TTree *  tree,
TTree *  treeSpills 
)

◆ SpillEnd() [1/2]

void BmnConverterThread::SpillEnd ( )

Definition at line 192 of file BmnConverterThread.cxx.

References ClearRawSpillArrays(), and fRawTreeSpills.

◆ SpillEnd() [2/2]

void BmnConverterThread::SpillEnd ( )

◆ Terminate() [1/2]

void BmnConverterThread::Terminate ( )
inlinevirtual

Reimplemented from BmnAbstractThread.

Definition at line 125 of file BmnConverterThread.h.

References adc, adc128, adc32, adc64, eventHeaderDAQ, BmnAbstractThread::Execute(), BmnAbstractThread::GetCalculationCTime(), BmnAbstractThread::GetWaitingCTime(), hrb, msc, sync, t0raw, BmnAbstractThread::taskId, tdc, tdc_hgnd, BmnAbstractThread::threadId, tqdc_adc, tqdc_tdc, and vsp.

◆ Terminate() [2/2]

void BmnConverterThread::Terminate ( )
inlinevirtual

Reimplemented from BmnAbstractThread.

Definition at line 125 of file BmnConverterThread.h.

References adc, adc128, adc32, adc64, eventHeaderDAQ, BmnAbstractThread::Execute(), BmnAbstractThread::GetCalculationCTime(), BmnAbstractThread::GetWaitingCTime(), hrb, msc, sync, t0raw, BmnAbstractThread::taskId, tdc, tdc_hgnd, BmnAbstractThread::threadId, tqdc_adc, tqdc_tdc, and vsp.

◆ WriteTree() [1/2]

void BmnConverterThread::WriteTree ( )

Definition at line 151 of file BmnConverterThread.cxx.

References fRawTree.

◆ WriteTree() [2/2]

void BmnConverterThread::WriteTree ( )

◆ WriteTreeSpills() [1/2]

void BmnConverterThread::WriteTreeSpills ( )

Definition at line 156 of file BmnConverterThread.cxx.

References fRawTreeSpills.

◆ WriteTreeSpills() [2/2]

void BmnConverterThread::WriteTreeSpills ( )

Member Data Documentation

◆ adc

TClonesArray * BmnConverterThread::adc

Definition at line 39 of file BmnConverterThread.h.

Referenced by ClearRawArrays(), CreateTrees(), RegisterBranches(), SetTrees(), and Terminate().

◆ adc128

TClonesArray * BmnConverterThread::adc128

Definition at line 38 of file BmnConverterThread.h.

Referenced by ClearRawArrays(), CreateTrees(), RegisterBranches(), SetTrees(), and Terminate().

◆ adc32

TClonesArray * BmnConverterThread::adc32

Definition at line 36 of file BmnConverterThread.h.

Referenced by ClearRawArrays(), CreateTrees(), RegisterBranches(), SetTrees(), and Terminate().

◆ adc64

TClonesArray * BmnConverterThread::adc64

Definition at line 37 of file BmnConverterThread.h.

Referenced by ClearRawArrays(), CreateTrees(), RegisterBranches(), SetTrees(), and Terminate().

◆ eventHeaderDAQ

BmnEventHeader * BmnConverterThread::eventHeaderDAQ

Definition at line 48 of file BmnConverterThread.h.

Referenced by CreateTrees(), RegisterBranches(), BmnConverter::SeparateEventsBySpills(), BmnConverter::SeparateEventsBySpillsTM(), SetTrees(), and Terminate().

◆ fRawTree

TTree * BmnConverterThread::fRawTree

Definition at line 28 of file BmnConverterThread.h.

Referenced by CreateTrees(), RegisterBranches(), BmnConverter::SeparateEventsBySpills(), BmnConverter::SeparateEventsBySpillsTM(), SetTrees(), WriteTree(), and ~BmnConverterThread().

◆ fRawTreeSpills

TTree * BmnConverterThread::fRawTreeSpills

Definition at line 29 of file BmnConverterThread.h.

Referenced by CreateTrees(), RegisterSpillBranches(), BmnConverter::SeparateEventsBySpills(), SetTrees(), SpillEnd(), WriteTreeSpills(), and ~BmnConverterThread().

◆ hrb

TClonesArray * BmnConverterThread::hrb

Definition at line 41 of file BmnConverterThread.h.

Referenced by ClearRawArrays(), CreateTrees(), RegisterBranches(), SetTrees(), and Terminate().

◆ merger

TBufferMerger * BmnConverterThread::merger

Definition at line 30 of file BmnConverterThread.h.

Referenced by CreateTrees(), and SetMerger().

◆ mergerFile

std::shared_ptr< TBufferMergerFile > BmnConverterThread::mergerFile

Definition at line 31 of file BmnConverterThread.h.

Referenced by CreateTrees(), and FinalizeFile().

◆ msc

TClonesArray * BmnConverterThread::msc

Definition at line 46 of file BmnConverterThread.h.

Referenced by ClearRawSpillArrays(), CreateTrees(), RegisterSpillBranches(), BmnConverter::SeparateEventsBySpills(), SetTrees(), and Terminate().

◆ rawData

UInt_t BmnConverterThread::rawData

Definition at line 32 of file BmnConverterThread.h.

Referenced by SetData().

◆ sync

TClonesArray * BmnConverterThread::sync

Definition at line 35 of file BmnConverterThread.h.

Referenced by ClearRawArrays(), CreateTrees(), RegisterBranches(), SetTrees(), and Terminate().

◆ t0raw

TClonesArray * BmnConverterThread::t0raw

Definition at line 47 of file BmnConverterThread.h.

Referenced by ClearRawSpillArrays(), CreateTrees(), RegisterSpillBranches(), BmnConverter::SeparateEventsBySpills(), SetTrees(), and Terminate().

◆ tdc

TClonesArray * BmnConverterThread::tdc

Definition at line 42 of file BmnConverterThread.h.

Referenced by ClearRawArrays(), CreateTrees(), RegisterBranches(), SetTrees(), and Terminate().

◆ tdc_hgnd

TClonesArray * BmnConverterThread::tdc_hgnd

Definition at line 45 of file BmnConverterThread.h.

Referenced by ClearRawArrays(), CreateTrees(), RegisterBranches(), SetTrees(), and Terminate().

◆ time_slice_map

std::map< uint8_t, uint32_t * > BmnConverterThread::time_slice_map

Definition at line 50 of file BmnConverterThread.h.

◆ tqdc_adc

TClonesArray * BmnConverterThread::tqdc_adc

Definition at line 44 of file BmnConverterThread.h.

Referenced by ClearRawArrays(), CreateTrees(), RegisterBranches(), SetTrees(), and Terminate().

◆ tqdc_tdc

TClonesArray * BmnConverterThread::tqdc_tdc

Definition at line 43 of file BmnConverterThread.h.

Referenced by ClearRawArrays(), CreateTrees(), RegisterBranches(), SetTrees(), and Terminate().

◆ vsp

TClonesArray * BmnConverterThread::vsp

Definition at line 40 of file BmnConverterThread.h.

Referenced by ClearRawArrays(), CreateTrees(), RegisterBranches(), SetTrees(), and Terminate().

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