![]() |
GRSISort "v4.0.0.5"
An extension of the ROOT analysis Framework
|
![]() |
This loop takes built events and fills histograms using 'histos/MakeAnalysisHistograms.cxx'
Definition at line 26 of file TAnalysisHistLoop.h.
Public Member Functions | |
TAnalysisHistLoop (const TAnalysisHistLoop &)=delete | |
TAnalysisHistLoop (TAnalysisHistLoop &&) noexcept=delete | |
~TAnalysisHistLoop () | |
void | AddCutFile (TFile *cut_file) |
void | ClearHistograms () |
void | ClearQueue () override |
virtual std::string | EndStatus () |
TList * | GetGates () |
size_t | GetItemsCurrent () override |
size_t | GetItemsPopped () override |
size_t | GetItemsPushed () override |
std::string | GetLibraryName () const |
TList * | GetObjects () |
std::string | GetOutputFilename () const |
size_t | GetRate () override |
std::shared_ptr< ThreadsafeQueue< std::shared_ptr< TUnpackedEvent > > > & | InputQueue () |
bool | IsPaused () |
bool | IsRunning () |
void | Join () |
void | LoadLibrary (const std::string &library) |
std::string | Name () const |
virtual void | OnEnd () |
TAnalysisHistLoop & | operator= (const TAnalysisHistLoop &)=delete |
TAnalysisHistLoop & | operator= (TAnalysisHistLoop &&) noexcept=delete |
void | Pause () |
virtual std::string | Progress () |
void | Resume () |
void | SetOutputFilename (const std::string &name) |
virtual std::string | Status () |
void | Stop () |
void | Write () |
Static Public Member Functions | |
static std::string | AllThreadHeader () |
static std::string | AllThreadProgress () |
static std::string | AllThreadStatus () |
static bool | AnyThreadRunning () |
static std::string | AnyThreadStatus () |
static void | ClearAllQueues () |
static size_t | ColumnWidth () |
static void | ColumnWidth (size_t val) |
static StoppableThread * | Get (const std::string &name) |
static TAnalysisHistLoop * | Get (std::string name="") |
static std::vector< StoppableThread * > | GetAll () |
static int | GetNThreads () |
static void | join_status_thread () |
static void | PauseAll () |
static void | Print () |
static void | ResumeAll () |
static void | SendStop () |
static void | start_status_thread () |
static void | status_out () |
static void | status_out_loop () |
static size_t | StatusWidth () |
static void | StatusWidth (size_t val) |
static void | stop_status_thread () |
static void | StopAll () |
Protected Member Functions | |
void | IncrementItemsPopped () |
std::atomic_long & | InputSize () |
void | InputSize (int64_t val) |
std::atomic_size_t & | ItemsPopped () |
void | ItemsPopped (size_t val) |
bool | Iteration () override |
Private Member Functions | |
TAnalysisHistLoop (std::string name) | |
void | CloseFile () |
void | Loop () |
void | OpenFile () |
Private Attributes | |
TCompiledHistograms | fCompiledHistograms |
std::atomic_bool | fForceStop {false} |
std::shared_ptr< ThreadsafeQueue< std::shared_ptr< TUnpackedEvent > > > | fInputQueue |
std::atomic_long | fInputSize {0} |
std::atomic_size_t | fItemsPopped {0} |
std::string | fName |
TFile * | fOutputFile |
std::string | fOutputFilename |
std::atomic_bool | fPaused {false} |
std::condition_variable | fPausedWait |
std::mutex | fPauseMutex |
std::atomic_bool | fRunning {false} |
std::thread | fThread |
Static Private Attributes | |
static size_t | fColumnWidth = 20 |
static std::thread | fStatusThread |
static bool | fStatusThreadOn = false |
static size_t | fStatusWidth = 80 |
static std::map< std::string, StoppableThread * > | fThreadMap |
|
delete |
Referenced by Get().
|
deletenoexcept |
TAnalysisHistLoop::~TAnalysisHistLoop | ( | ) |
Definition at line 32 of file TAnalysisHistLoop.cxx.
References CloseFile().
|
explicitprivate |
Definition at line 25 of file TAnalysisHistLoop.cxx.
References TGRSIOptions::Get(), and LoadLibrary().
void TAnalysisHistLoop::AddCutFile | ( | TFile * | cut_file | ) |
Definition at line 141 of file TAnalysisHistLoop.cxx.
References TCompiledHistograms::AddCutFile(), and fCompiledHistograms.
|
staticinherited |
Definition at line 73 of file StoppableThread.cxx.
References StoppableThread::fColumnWidth, StoppableThread::fStatusWidth, and StoppableThread::fThreadMap.
Referenced by TGRSIint::ApplyOptions().
|
staticinherited |
Definition at line 59 of file StoppableThread.cxx.
References StoppableThread::fColumnWidth, StoppableThread::fStatusWidth, and StoppableThread::fThreadMap.
Referenced by TGRSIint::LoopUntilDone().
|
staticinherited |
Definition at line 83 of file StoppableThread.cxx.
References StoppableThread::fColumnWidth, StoppableThread::fStatusWidth, and StoppableThread::fThreadMap.
Referenced by TGRSIint::LoopUntilDone().
|
staticinherited |
Definition at line 37 of file StoppableThread.cxx.
References StoppableThread::fThreadMap.
Referenced by TChannel::GetChannel(), TGRSIint::LoopUntilDone(), and TGRSIInterruptHandler::Notify().
|
staticinherited |
Definition at line 47 of file StoppableThread.cxx.
References StoppableThread::fThreadMap.
|
staticinherited |
Definition at line 166 of file StoppableThread.cxx.
References StoppableThread::fThreadMap.
Referenced by TGRSIInterruptHandler::Notify().
void TAnalysisHistLoop::ClearHistograms | ( | ) |
Definition at line 66 of file TAnalysisHistLoop.cxx.
References TCompiledHistograms::ClearHistograms(), and fCompiledHistograms.
|
overridevirtual |
Reimplemented from StoppableThread.
Definition at line 37 of file TAnalysisHistLoop.cxx.
References fInputQueue.
|
private |
Definition at line 79 of file TAnalysisHistLoop.cxx.
References fOutputFile, fOutputFilename, and Write().
Referenced by ~TAnalysisHistLoop().
|
inlinestaticinherited |
Definition at line 82 of file StoppableThread.h.
References StoppableThread::fColumnWidth.
Referenced by TGRSIint::SetupPipeline().
|
inlinestaticinherited |
Definition at line 80 of file StoppableThread.h.
References StoppableThread::fColumnWidth.
|
inlinevirtualinherited |
Reimplemented in TAnalysisWriteLoop, TEventBuildingLoop, TFragWriteLoop, and TUnpackingLoop.
Definition at line 62 of file StoppableThread.h.
Referenced by StoppableThread::Join(), and StoppableThread::Stop().
|
staticinherited |
Definition at line 173 of file StoppableThread.cxx.
References StoppableThread::fThreadMap.
Referenced by Get(), TAnalysisWriteLoop::Get(), TDataLoop::Get(), TDetBuildingLoop::Get(), TEventBuildingLoop::Get(), TFragHistLoop::Get(), TFragmentChainLoop::Get(), TFragWriteLoop::Get(), TTerminalLoop< T >::Get(), and TUnpackingLoop::Get().
|
static |
Definition at line 13 of file TAnalysisHistLoop.cxx.
References TAnalysisHistLoop(), and StoppableThread::Get().
Referenced by TGRSIint::SetupPipeline().
|
staticinherited |
Definition at line 315 of file StoppableThread.cxx.
References StoppableThread::fThreadMap.
TList * TAnalysisHistLoop::GetGates | ( | ) |
Definition at line 126 of file TAnalysisHistLoop.cxx.
References fCompiledHistograms, and TCompiledHistograms::GetGates().
|
inlineoverridevirtual |
Implements StoppableThread.
Definition at line 61 of file TAnalysisHistLoop.h.
|
inlineoverridevirtual |
Implements StoppableThread.
Definition at line 59 of file TAnalysisHistLoop.h.
|
inlineoverridevirtual |
Implements StoppableThread.
Definition at line 60 of file TAnalysisHistLoop.h.
std::string TAnalysisHistLoop::GetLibraryName | ( | ) | const |
Definition at line 116 of file TAnalysisHistLoop.cxx.
References fCompiledHistograms, and TCompiledHistograms::GetLibraryName().
|
staticinherited |
Definition at line 21 of file StoppableThread.cxx.
References StoppableThread::fThreadMap.
Referenced by StoppableThread::Print().
TList * TAnalysisHistLoop::GetObjects | ( | ) |
Definition at line 121 of file TAnalysisHistLoop.cxx.
References fCompiledHistograms, and TCompiledHistograms::GetObjects().
std::string TAnalysisHistLoop::GetOutputFilename | ( | ) | const |
Definition at line 136 of file TAnalysisHistLoop.cxx.
References fOutputFilename.
Referenced by Write().
|
inlineoverridevirtual |
Implements StoppableThread.
Definition at line 62 of file TAnalysisHistLoop.h.
|
inlineprotectedinherited |
Definition at line 97 of file StoppableThread.h.
References StoppableThread::fItemsPopped.
Referenced by Iteration(), TAnalysisWriteLoop::Iteration(), TDetBuildingLoop::Iteration(), TEventBuildingLoop::Iteration(), TFragHistLoop::Iteration(), TFragmentChainLoop::Iteration(), TFragWriteLoop::Iteration(), and TUnpackingLoop::Iteration().
|
inline |
Definition at line 37 of file TAnalysisHistLoop.h.
References fInputQueue.
Referenced by TGRSIint::SetupPipeline().
|
inlineprotectedinherited |
Definition at line 96 of file StoppableThread.h.
References StoppableThread::fInputSize.
Referenced by TAnalysisWriteLoop::EndStatus(), TFragWriteLoop::EndStatus(), Iteration(), TAnalysisWriteLoop::Iteration(), TDataLoop::Iteration(), TDetBuildingLoop::Iteration(), TEventBuildingLoop::Iteration(), TFragHistLoop::Iteration(), TFragmentChainLoop::Iteration(), TFragWriteLoop::Iteration(), and TUnpackingLoop::Iteration().
|
inlineprotectedinherited |
Definition at line 94 of file StoppableThread.h.
References StoppableThread::fInputSize.
|
inherited |
Definition at line 224 of file StoppableThread.cxx.
References StoppableThread::fPaused.
|
inherited |
Definition at line 219 of file StoppableThread.cxx.
References StoppableThread::fRunning.
Referenced by StoppableThread::status_out().
|
inlineprotectedinherited |
Definition at line 95 of file StoppableThread.h.
References StoppableThread::fItemsPopped.
Referenced by TAnalysisWriteLoop::EndStatus(), TEventBuildingLoop::EndStatus(), TFragWriteLoop::EndStatus(), TFragmentChainLoop::GetItemsPopped(), TFragWriteLoop::GetItemsPopped(), TAnalysisWriteLoop::GetItemsPushed(), TFragmentChainLoop::GetItemsPushed(), TFragWriteLoop::GetItemsPushed(), TDataLoop::Iteration(), TFragmentChainLoop::Iteration(), TUnpackingLoop::Iteration(), and TFragmentChainLoop::Restart().
|
inlineprotectedinherited |
Definition at line 93 of file StoppableThread.h.
References StoppableThread::fItemsPopped.
|
overrideprotectedvirtual |
Implements StoppableThread.
Definition at line 45 of file TAnalysisHistLoop.cxx.
References fCompiledHistograms, TCompiledHistograms::Fill(), fInputQueue, fOutputFile, StoppableThread::IncrementItemsPopped(), StoppableThread::InputSize(), and OpenFile().
|
inherited |
Definition at line 229 of file StoppableThread.cxx.
References StoppableThread::EndStatus(), and StoppableThread::fThread.
Referenced by StoppableThread::StopAll().
|
staticinherited |
Definition at line 280 of file StoppableThread.cxx.
References StoppableThread::fStatusThread, and StoppableThread::stop_status_thread().
void TAnalysisHistLoop::LoadLibrary | ( | const std::string & | library | ) |
Definition at line 111 of file TAnalysisHistLoop.cxx.
References fCompiledHistograms, and TCompiledHistograms::Load().
Referenced by TAnalysisHistLoop().
|
privateinherited |
Definition at line 237 of file StoppableThread.cxx.
References StoppableThread::fPaused, StoppableThread::fPausedWait, StoppableThread::fPauseMutex, StoppableThread::fRunning, StoppableThread::Iteration(), and StoppableThread::OnEnd().
Referenced by StoppableThread::StoppableThread().
|
inlineinherited |
Definition at line 63 of file StoppableThread.h.
References StoppableThread::fName.
Referenced by TAnalysisWriteLoop::AddBranch(), TAnalysisWriteLoop::EndStatus(), TFragWriteLoop::EndStatus(), TUnpackingLoop::EndStatus(), and StoppableThread::status_out().
|
inlinevirtualinherited |
Reimplemented in TAnalysisWriteLoop, TDataLoop, and TFragmentChainLoop.
Definition at line 59 of file StoppableThread.h.
Referenced by StoppableThread::Loop().
|
private |
Definition at line 71 of file TAnalysisHistLoop.cxx.
References fCompiledHistograms, fOutputFile, fOutputFilename, TGRSIint::instance(), TGRSIint::OpenRootFile(), and TCompiledHistograms::SetDefaultDirectory().
Referenced by Iteration().
|
delete |
|
deletenoexcept |
|
inherited |
Definition at line 202 of file StoppableThread.cxx.
References StoppableThread::fPaused, and StoppableThread::fRunning.
|
staticinherited |
Definition at line 97 of file StoppableThread.cxx.
References StoppableThread::fThreadMap.
|
staticinherited |
Definition at line 254 of file StoppableThread.cxx.
References StoppableThread::fColumnWidth, StoppableThread::fStatusWidth, StoppableThread::fThreadMap, StoppableThread::GetNThreads(), and hex().
|
virtualinherited |
Definition at line 119 of file StoppableThread.cxx.
References StoppableThread::fColumnWidth, StoppableThread::fInputSize, and StoppableThread::fItemsPopped.
|
inherited |
Definition at line 193 of file StoppableThread.cxx.
References StoppableThread::fPaused, StoppableThread::fPausedWait, StoppableThread::fPauseMutex, and StoppableThread::fRunning.
|
staticinherited |
Definition at line 104 of file StoppableThread.cxx.
References StoppableThread::fThreadMap.
Referenced by TGRSIint::SetupPipeline().
|
staticinherited |
Definition at line 135 of file StoppableThread.cxx.
References StoppableThread::fThreadMap.
Referenced by StoppableThread::StopAll(), and TGRSIint::Terminate().
void TAnalysisHistLoop::SetOutputFilename | ( | const std::string & | name | ) |
Definition at line 131 of file TAnalysisHistLoop.cxx.
References fOutputFilename.
Referenced by TGRSIint::SetupPipeline().
|
staticinherited |
Definition at line 265 of file StoppableThread.cxx.
References StoppableThread::fStatusThread, StoppableThread::fStatusThreadOn, and StoppableThread::status_out_loop().
Referenced by StoppableThread::StoppableThread().
|
virtualinherited |
Definition at line 111 of file StoppableThread.cxx.
References StoppableThread::fColumnWidth, StoppableThread::fInputSize, and StoppableThread::fItemsPopped.
|
staticinherited |
Definition at line 297 of file StoppableThread.cxx.
References StoppableThread::fThreadMap, StoppableThread::GetItemsCurrent(), StoppableThread::GetItemsPopped(), StoppableThread::GetItemsPushed(), StoppableThread::GetRate(), StoppableThread::IsRunning(), and StoppableThread::Name().
Referenced by StoppableThread::status_out_loop(), and StoppableThread::StopAll().
|
staticinherited |
Definition at line 286 of file StoppableThread.cxx.
References StoppableThread::fStatusThreadOn, and StoppableThread::status_out().
Referenced by StoppableThread::start_status_thread().
|
inlinestaticinherited |
Definition at line 83 of file StoppableThread.h.
References StoppableThread::fStatusWidth.
Referenced by TGRSIint::SetupPipeline().
|
inlinestaticinherited |
Definition at line 81 of file StoppableThread.h.
References StoppableThread::fStatusWidth.
|
inherited |
Definition at line 209 of file StoppableThread.cxx.
References StoppableThread::EndStatus(), StoppableThread::fPaused, StoppableThread::fPausedWait, StoppableThread::fPauseMutex, and StoppableThread::fRunning.
|
staticinherited |
Definition at line 273 of file StoppableThread.cxx.
References StoppableThread::fStatusThreadOn.
Referenced by StoppableThread::join_status_thread().
|
staticinherited |
Definition at line 147 of file StoppableThread.cxx.
References StoppableThread::fThreadMap, StoppableThread::Join(), StoppableThread::SendStop(), and StoppableThread::status_out().
Referenced by TGRSIint::Terminate().
void TAnalysisHistLoop::Write | ( | ) |
Definition at line 90 of file TAnalysisHistLoop.cxx.
References BLUE, fCompiledHistograms, fOutputFile, GValue::Get(), TChannel::GetDefaultChannel(), TChannel::GetNumberOfChannels(), GetOutputFilename(), RESET_COLOR, GValue::Size(), and TCompiledHistograms::Write().
Referenced by CloseFile().
|
staticprivateinherited |
Definition at line 108 of file StoppableThread.h.
Referenced by StoppableThread::AllThreadHeader(), StoppableThread::AllThreadProgress(), StoppableThread::AllThreadStatus(), StoppableThread::ColumnWidth(), StoppableThread::ColumnWidth(), StoppableThread::Print(), StoppableThread::Progress(), and StoppableThread::Status().
|
private |
Definition at line 70 of file TAnalysisHistLoop.h.
Referenced by AddCutFile(), ClearHistograms(), GetGates(), GetLibraryName(), GetObjects(), Iteration(), LoadLibrary(), OpenFile(), and Write().
|
privateinherited |
Definition at line 120 of file StoppableThread.h.
|
private |
Definition at line 79 of file TAnalysisHistLoop.h.
Referenced by ClearQueue(), InputQueue(), and Iteration().
|
privateinherited |
number of items in the input (queue), only updated within Iteration(), so not always fully up-to-date (signed to hold error from queue::pop)
Definition at line 102 of file StoppableThread.h.
Referenced by StoppableThread::InputSize(), StoppableThread::InputSize(), StoppableThread::Progress(), and StoppableThread::Status().
|
privateinherited |
number of items popped from input queue
Definition at line 101 of file StoppableThread.h.
Referenced by StoppableThread::IncrementItemsPopped(), StoppableThread::ItemsPopped(), StoppableThread::ItemsPopped(), StoppableThread::Progress(), and StoppableThread::Status().
|
privateinherited |
Definition at line 106 of file StoppableThread.h.
Referenced by StoppableThread::StoppableThread(), StoppableThread::~StoppableThread(), and StoppableThread::Name().
|
private |
Definition at line 75 of file TAnalysisHistLoop.h.
Referenced by CloseFile(), Iteration(), OpenFile(), and Write().
|
private |
Definition at line 76 of file TAnalysisHistLoop.h.
Referenced by CloseFile(), GetOutputFilename(), OpenFile(), and SetOutputFilename().
|
privateinherited |
Definition at line 121 of file StoppableThread.h.
Referenced by StoppableThread::IsPaused(), StoppableThread::Loop(), StoppableThread::Pause(), StoppableThread::Resume(), and StoppableThread::Stop().
|
privateinherited |
Definition at line 122 of file StoppableThread.h.
Referenced by StoppableThread::Loop(), StoppableThread::Resume(), and StoppableThread::Stop().
|
privateinherited |
Definition at line 123 of file StoppableThread.h.
Referenced by StoppableThread::Loop(), StoppableThread::Resume(), and StoppableThread::Stop().
|
privateinherited |
Definition at line 119 of file StoppableThread.h.
Referenced by StoppableThread::IsRunning(), StoppableThread::Loop(), StoppableThread::Pause(), StoppableThread::Resume(), and StoppableThread::Stop().
|
staticprivateinherited |
Definition at line 117 of file StoppableThread.h.
Referenced by StoppableThread::~StoppableThread(), StoppableThread::join_status_thread(), and StoppableThread::start_status_thread().
|
staticprivateinherited |
Definition at line 115 of file StoppableThread.h.
Referenced by StoppableThread::StoppableThread(), StoppableThread::~StoppableThread(), StoppableThread::start_status_thread(), StoppableThread::status_out_loop(), and StoppableThread::stop_status_thread().
|
staticprivateinherited |
Definition at line 109 of file StoppableThread.h.
Referenced by StoppableThread::AllThreadHeader(), StoppableThread::AllThreadProgress(), StoppableThread::AllThreadStatus(), StoppableThread::Print(), StoppableThread::StatusWidth(), and StoppableThread::StatusWidth().
|
privateinherited |
Definition at line 118 of file StoppableThread.h.
Referenced by StoppableThread::StoppableThread(), and StoppableThread::Join().
|
staticprivateinherited |
Definition at line 113 of file StoppableThread.h.
Referenced by StoppableThread::StoppableThread(), StoppableThread::~StoppableThread(), StoppableThread::AllThreadHeader(), StoppableThread::AllThreadProgress(), StoppableThread::AllThreadStatus(), StoppableThread::AnyThreadRunning(), StoppableThread::AnyThreadStatus(), StoppableThread::ClearAllQueues(), StoppableThread::Get(), StoppableThread::GetAll(), StoppableThread::GetNThreads(), StoppableThread::PauseAll(), StoppableThread::Print(), StoppableThread::ResumeAll(), StoppableThread::SendStop(), StoppableThread::status_out(), and StoppableThread::StopAll().