TAnalysisWriteLoopClient Class Reference

The client(s) for the TAnalysisWriteLoop. Each gets a subset of event to write to file.

Definition at line 36 of file TAnalysisWriteLoopClient.h.

Public Member Functions
	TAnalysisWriteLoopClient (std::string name, std::string outputFilename, Int_t localPort)
	~TAnalysisWriteLoopClient () override
void	ClearQueue () override
virtual std::string	EndStatus ()
size_t	GetInputSize ()
size_t	GetItemsCurrent () override
size_t	GetItemsPopped () override
size_t	GetItemsPushed () override
size_t	GetRate () override
std::shared_ptr< ThreadsafeQueue< std::shared_ptr< TUnpackedEvent > > >	InputQueue ()
bool	IsPaused ()
bool	IsRunning ()
void	Join ()
std::string	Name () const
void	OnEnd () override
void	OutOfOrderFragment (std::shared_ptr< const TFragment > frag)
std::shared_ptr< ThreadsafeQueue< std::shared_ptr< const TFragment > > >	OutOfOrderQueue ()
void	Pause ()
virtual std::string	Progress ()
void	Resume ()
virtual std::string	Status ()
void	Stop ()

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 void	ColumnWidth (size_t val)
static size_t	ColumnWidth ()
static StoppableThread *	Get (const 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 void	StatusWidth (size_t val)
static size_t	StatusWidth ()
static void	stop_status_thread ()
static void	StopAll ()

Static Public Attributes
static std::thread	fStatusThread
static bool	fStatusThreadOn = false

Protected Member Functions
bool	Iteration () override

Protected Attributes
std::atomic_long	fInputSize {0}
std::atomic_size_t	fItemsPopped {0}
std::string	fName

Static Protected Attributes
static std::map< std::string, StoppableThread * >	fThreadMap

Private Member Functions
void	AddBranch (TClass *cls)
void	WriteEvent (std::shared_ptr< TUnpackedEvent > &event)

Private Attributes
std::map< TClass *, TDetector * >	fDefaultDets
std::map< TClass *, TDetector ** >	fDetMap
TTree *	fEventTree
bool	fFirstClient
std::shared_ptr< ThreadsafeQueue< std::shared_ptr< TUnpackedEvent > > >	fInputQueue
bool	fOutOfOrder
TFragment *	fOutOfOrderFrag
std::shared_ptr< ThreadsafeQueue< std::shared_ptr< const TFragment > > >	fOutOfOrderQueue
TTree *	fOutOfOrderTree
TParallelMergingFile *	fOutputFile

Static Private Attributes
static std::map< TClass *, TDetector ** >	fGlobalDetMap

#include <TAnalysisWriteLoopClient.h>

Inheritance diagram for TAnalysisWriteLoopClient:

Collaboration diagram for TAnalysisWriteLoopClient:

Constructor & Destructor Documentation

TAnalysisWriteLoopClient()

TAnalysisWriteLoopClient::TAnalysisWriteLoopClient	(	std::string	name,
		std::string	outputFilename,
		Int_t	localPort
	)

Definition at line 10 of file TAnalysisWriteLoopClient.cxx.

References fEventTree, fFirstClient, fOutOfOrder, fOutOfOrderFrag, fOutOfOrderTree, fOutputFile, and TGRSIOptions::Get().

~TAnalysisWriteLoopClient()

TAnalysisWriteLoopClient::~TAnalysisWriteLoopClient ( )

override

Definition at line 34 of file TAnalysisWriteLoopClient.cxx.

References fDetMap.

Member Function Documentation

AddBranch()

void TAnalysisWriteLoopClient::AddBranch ( TClass *  cls )

private

Definition at line 87 of file TAnalysisWriteLoopClient.cxx.

References fDefaultDets, fDetMap, fEventTree, fFirstClient, fGlobalDetMap, StoppableThread::Name(), and ttree_fill_mutex.

AllThreadHeader()

std::string StoppableThread::AllThreadHeader ( )

staticinherited

Definition at line 73 of file StoppableThread.cxx.

References StoppableThread::fColumnWidth, StoppableThread::fStatusWidth, and StoppableThread::fThreadMap.

Referenced by TGRSIint::ApplyOptions().

AllThreadProgress()

std::string StoppableThread::AllThreadProgress ( )

staticinherited

Definition at line 59 of file StoppableThread.cxx.

References StoppableThread::fColumnWidth, StoppableThread::fStatusWidth, and StoppableThread::fThreadMap.

Referenced by TGRSIint::LoopUntilDone().

AllThreadStatus()

std::string StoppableThread::AllThreadStatus ( )

staticinherited

Definition at line 83 of file StoppableThread.cxx.

References StoppableThread::fColumnWidth, StoppableThread::fStatusWidth, and StoppableThread::fThreadMap.

Referenced by TGRSIint::LoopUntilDone().

AnyThreadRunning()

bool StoppableThread::AnyThreadRunning ( )

staticinherited

Definition at line 37 of file StoppableThread.cxx.

References StoppableThread::fThreadMap.

Referenced by TChannel::GetChannel(), TGRSIint::LoopUntilDone(), and TGRSIInterruptHandler::Notify().

AnyThreadStatus()

std::string StoppableThread::AnyThreadStatus ( )

staticinherited

Definition at line 47 of file StoppableThread.cxx.

References StoppableThread::fThreadMap.

ClearAllQueues()

void StoppableThread::ClearAllQueues ( )

staticinherited

Definition at line 166 of file StoppableThread.cxx.

References StoppableThread::fThreadMap.

Referenced by TGRSIInterruptHandler::Notify().

ClearQueue()

void TAnalysisWriteLoopClient::ClearQueue ( )

overridevirtual

Reimplemented from StoppableThread.

Definition at line 41 of file TAnalysisWriteLoopClient.cxx.

References fInputQueue.

ColumnWidth() [1/2]

static void StoppableThread::ColumnWidth ( size_t  val )

inlinestaticinherited

Definition at line 75 of file StoppableThread.h.

References StoppableThread::fColumnWidth.

ColumnWidth() [2/2]

static size_t StoppableThread::ColumnWidth ( )

inlinestaticinherited

Definition at line 77 of file StoppableThread.h.

References StoppableThread::fColumnWidth.

Referenced by TGRSIint::SetupPipeline().

EndStatus()

virtual std::string StoppableThread::EndStatus ( )

inlinevirtualinherited

Reimplemented in TUnpackingLoop, TEventBuildingLoop, TFragWriteLoop, and TAnalysisWriteLoop.

Definition at line 57 of file StoppableThread.h.

Referenced by StoppableThread::Join(), and StoppableThread::Stop().

Get()

StoppableThread * StoppableThread::Get ( const std::string &  name )

staticinherited

Definition at line 173 of file StoppableThread.cxx.

References StoppableThread::fThreadMap.

Referenced by ClassImp(), TTerminalLoop< T >::Get(), TFragHistLoop::Get(), TAnalysisHistLoop::Get(), TAnalysisWriteLoop::Get(), TFragWriteLoop::Get(), TUnpackingLoop::Get(), TFragmentChainLoop::Get(), and TDataLoop::Get().

GetAll()

std::vector< StoppableThread * > StoppableThread::GetAll ( )

staticinherited

Definition at line 315 of file StoppableThread.cxx.

References StoppableThread::fThreadMap.

GetInputSize()

size_t TAnalysisWriteLoopClient::GetInputSize ( )

inline

Definition at line 53 of file TAnalysisWriteLoopClient.h.

References StoppableThread::fInputSize.

GetItemsCurrent()

size_t TAnalysisWriteLoopClient::GetItemsCurrent ( )

inlineoverridevirtual

Implements StoppableThread.

Definition at line 51 of file TAnalysisWriteLoopClient.h.

GetItemsPopped()

size_t TAnalysisWriteLoopClient::GetItemsPopped ( )

inlineoverridevirtual

Implements StoppableThread.

Definition at line 50 of file TAnalysisWriteLoopClient.h.

GetItemsPushed()

size_t TAnalysisWriteLoopClient::GetItemsPushed ( )

inlineoverridevirtual

Implements StoppableThread.

Definition at line 49 of file TAnalysisWriteLoopClient.h.

References StoppableThread::fItemsPopped.

GetNThreads()

int StoppableThread::GetNThreads ( )

staticinherited

Definition at line 21 of file StoppableThread.cxx.

References StoppableThread::fThreadMap.

Referenced by StoppableThread::Print().

GetRate()

size_t TAnalysisWriteLoopClient::GetRate ( )

inlineoverridevirtual

Implements StoppableThread.

Definition at line 52 of file TAnalysisWriteLoopClient.h.

InputQueue()

std::shared_ptr<ThreadsafeQueue<std::shared_ptr<TUnpackedEvent> > > TAnalysisWriteLoopClient::InputQueue ( )

inline

Definition at line 42 of file TAnalysisWriteLoopClient.h.

References fInputQueue.

IsPaused()

bool StoppableThread::IsPaused ( )

inherited

Definition at line 224 of file StoppableThread.cxx.

References StoppableThread::fPaused.

IsRunning()

bool StoppableThread::IsRunning ( )

inherited

Definition at line 219 of file StoppableThread.cxx.

References StoppableThread::fRunning.

Referenced by StoppableThread::status_out().

Iteration()

bool TAnalysisWriteLoopClient::Iteration ( )

overrideprotectedvirtual

Implements StoppableThread.

Definition at line 49 of file TAnalysisWriteLoopClient.cxx.

References TDetectorHit::ClearTransients(), fInputQueue, StoppableThread::fInputSize, StoppableThread::fItemsPopped, fOutOfOrder, fOutOfOrderFrag, fOutOfOrderQueue, fOutOfOrderTree, ttree_fill_mutex, and WriteEvent().

Join()

void StoppableThread::Join ( )

inherited

Definition at line 229 of file StoppableThread.cxx.

References StoppableThread::EndStatus(), and StoppableThread::fThread.

Referenced by StoppableThread::StopAll().

join_status_thread()

void StoppableThread::join_status_thread ( )

staticinherited

Definition at line 280 of file StoppableThread.cxx.

References StoppableThread::fStatusThread, and StoppableThread::stop_status_thread().

Name()

std::string StoppableThread::Name ( ) const

inlineinherited

Definition at line 58 of file StoppableThread.h.

References StoppableThread::fName.

Referenced by AddBranch(), TAnalysisWriteLoop::EndStatus(), TFragWriteLoop::EndStatus(), TUnpackingLoop::EndStatus(), and StoppableThread::status_out().

OnEnd()

void TAnalysisWriteLoopClient::OnEnd ( )

overridevirtual

Reimplemented from StoppableThread.

Definition at line 81 of file TAnalysisWriteLoopClient.cxx.

References fOutputFile.

OutOfOrderFragment()

void TAnalysisWriteLoopClient::OutOfOrderFragment

(

std::shared_ptr< const TFragment >

frag

)

OutOfOrderQueue()

std::shared_ptr<ThreadsafeQueue<std::shared_ptr<const TFragment> > > TAnalysisWriteLoopClient::OutOfOrderQueue ( )

inline

Definition at line 43 of file TAnalysisWriteLoopClient.h.

References fOutOfOrderQueue.

Pause()

void StoppableThread::Pause ( )

inherited

Definition at line 202 of file StoppableThread.cxx.

References StoppableThread::fPaused, and StoppableThread::fRunning.

PauseAll()

void StoppableThread::PauseAll ( )

staticinherited

Definition at line 97 of file StoppableThread.cxx.

References StoppableThread::fThreadMap.

Print()

void StoppableThread::Print ( )

staticinherited

Definition at line 254 of file StoppableThread.cxx.

References StoppableThread::fColumnWidth, StoppableThread::fStatusWidth, StoppableThread::fThreadMap, StoppableThread::GetNThreads(), and hex().

Progress()

std::string StoppableThread::Progress ( )

virtualinherited

Definition at line 119 of file StoppableThread.cxx.

References StoppableThread::fColumnWidth, StoppableThread::fInputSize, and StoppableThread::fItemsPopped.

Resume()

void StoppableThread::Resume ( )

inherited

Definition at line 193 of file StoppableThread.cxx.

References StoppableThread::fPaused, StoppableThread::fPausedWait, StoppableThread::fPauseMutex, and StoppableThread::fRunning.

ResumeAll()

void StoppableThread::ResumeAll ( )

staticinherited

Definition at line 104 of file StoppableThread.cxx.

References StoppableThread::fThreadMap.

Referenced by TGRSIint::SetupPipeline().

SendStop()

void StoppableThread::SendStop ( )

staticinherited

Definition at line 135 of file StoppableThread.cxx.

References StoppableThread::fThreadMap, and StoppableThread::Stop().

Referenced by StoppableThread::StopAll(), and TGRSIint::Terminate().

start_status_thread()

void StoppableThread::start_status_thread ( )

staticinherited

Definition at line 265 of file StoppableThread.cxx.

References StoppableThread::fStatusThread, StoppableThread::fStatusThreadOn, and StoppableThread::status_out_loop().

Referenced by StoppableThread::StoppableThread().

Status()

std::string StoppableThread::Status ( )

virtualinherited

Definition at line 111 of file StoppableThread.cxx.

References StoppableThread::fColumnWidth, StoppableThread::fInputSize, and StoppableThread::fItemsPopped.

status_out()

void StoppableThread::status_out ( )

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().

status_out_loop()

void StoppableThread::status_out_loop ( )

staticinherited

Definition at line 286 of file StoppableThread.cxx.

References StoppableThread::fStatusThreadOn, and StoppableThread::status_out().

Referenced by StoppableThread::start_status_thread().

StatusWidth() [1/2]

static void StoppableThread::StatusWidth ( size_t  val )

inlinestaticinherited

Definition at line 76 of file StoppableThread.h.

References StoppableThread::fStatusWidth.

StatusWidth() [2/2]

static size_t StoppableThread::StatusWidth ( )

inlinestaticinherited

Definition at line 78 of file StoppableThread.h.

References StoppableThread::fStatusWidth.

Referenced by TGRSIint::SetupPipeline().

Stop()

void StoppableThread::Stop ( )

inherited

Definition at line 209 of file StoppableThread.cxx.

References StoppableThread::EndStatus(), StoppableThread::fPaused, StoppableThread::fPausedWait, StoppableThread::fPauseMutex, and StoppableThread::fRunning.

Referenced by StoppableThread::SendStop().

stop_status_thread()

void StoppableThread::stop_status_thread ( )

staticinherited

Definition at line 273 of file StoppableThread.cxx.

References StoppableThread::fStatusThreadOn.

Referenced by StoppableThread::join_status_thread().

StopAll()

void StoppableThread::StopAll ( )

staticinherited

Definition at line 147 of file StoppableThread.cxx.

References StoppableThread::fThreadMap, StoppableThread::Join(), StoppableThread::SendStop(), and StoppableThread::status_out().

Referenced by TGRSIint::Terminate().

WriteEvent()

void TAnalysisWriteLoopClient::WriteEvent ( std::shared_ptr< TUnpackedEvent > &  event )

private

Referenced by Iteration().

Member Data Documentation

fDefaultDets

std::map<TClass*, TDetector*> TAnalysisWriteLoopClient::fDefaultDets

private

Definition at line 74 of file TAnalysisWriteLoopClient.h.

Referenced by AddBranch().

fDetMap

std::map<TClass*, TDetector**> TAnalysisWriteLoopClient::fDetMap

private

Definition at line 73 of file TAnalysisWriteLoopClient.h.

Referenced by AddBranch(), and ~TAnalysisWriteLoopClient().

fEventTree

TTree* TAnalysisWriteLoopClient::fEventTree

private

Definition at line 65 of file TAnalysisWriteLoopClient.h.

Referenced by AddBranch(), and TAnalysisWriteLoopClient().

fFirstClient

bool TAnalysisWriteLoopClient::fFirstClient

private

Definition at line 69 of file TAnalysisWriteLoopClient.h.

Referenced by AddBranch(), and TAnalysisWriteLoopClient().

fGlobalDetMap

std::map< TClass *, TDetector ** > TAnalysisWriteLoopClient::fGlobalDetMap

staticprivate

Definition at line 72 of file TAnalysisWriteLoopClient.h.

Referenced by AddBranch().

fInputQueue

std::shared_ptr<ThreadsafeQueue<std::shared_ptr<TUnpackedEvent> > > TAnalysisWriteLoopClient::fInputQueue

private

Definition at line 75 of file TAnalysisWriteLoopClient.h.

Referenced by ClearQueue(), InputQueue(), and Iteration().

fInputSize

std::atomic_long StoppableThread::fInputSize {0}

protectedinherited

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 95 of file StoppableThread.h.

Referenced by TAnalysisWriteLoop::EndStatus(), TFragWriteLoop::EndStatus(), GetInputSize(), TEventBuildingLoop::Iteration(), TDataLoop::Iteration(), TDetBuildingLoop::Iteration(), TAnalysisWriteLoop::Iteration(), TUnpackingLoop::Iteration(), TFragWriteLoop::Iteration(), TFragHistLoop::Iteration(), TAnalysisHistLoop::Iteration(), TFragmentChainLoop::Iteration(), Iteration(), StoppableThread::Progress(), and StoppableThread::Status().

fItemsPopped

std::atomic_size_t StoppableThread::fItemsPopped {0}

protectedinherited

number of items popped from input queue

Definition at line 94 of file StoppableThread.h.

Referenced by TAnalysisWriteLoop::EndStatus(), TFragWriteLoop::EndStatus(), TEventBuildingLoop::EndStatus(), TFragmentChainLoop::GetItemsPopped(), TFragWriteLoop::GetItemsPopped(), TAnalysisWriteLoop::GetItemsPushed(), TFragmentChainLoop::GetItemsPushed(), TFragWriteLoop::GetItemsPushed(), GetItemsPushed(), TEventBuildingLoop::Iteration(), TDataLoop::Iteration(), TDetBuildingLoop::Iteration(), TAnalysisWriteLoop::Iteration(), TUnpackingLoop::Iteration(), TFragWriteLoop::Iteration(), TFragHistLoop::Iteration(), TFragmentChainLoop::Iteration(), TAnalysisHistLoop::Iteration(), Iteration(), StoppableThread::Progress(), TFragmentChainLoop::Restart(), and StoppableThread::Status().

fName

std::string StoppableThread::fName

protectedinherited

Definition at line 99 of file StoppableThread.h.

Referenced by StoppableThread::Name(), StoppableThread::StoppableThread(), and StoppableThread::~StoppableThread().

fOutOfOrder

bool TAnalysisWriteLoopClient::fOutOfOrder

private

Definition at line 68 of file TAnalysisWriteLoopClient.h.

Referenced by Iteration(), and TAnalysisWriteLoopClient().

fOutOfOrderFrag

TFragment* TAnalysisWriteLoopClient::fOutOfOrderFrag

private

Definition at line 67 of file TAnalysisWriteLoopClient.h.

Referenced by Iteration(), and TAnalysisWriteLoopClient().

fOutOfOrderQueue

std::shared_ptr<ThreadsafeQueue<std::shared_ptr<const TFragment> > > TAnalysisWriteLoopClient::fOutOfOrderQueue

private

Definition at line 76 of file TAnalysisWriteLoopClient.h.

Referenced by Iteration(), and OutOfOrderQueue().

fOutOfOrderTree

TTree* TAnalysisWriteLoopClient::fOutOfOrderTree

private

Definition at line 66 of file TAnalysisWriteLoopClient.h.

Referenced by Iteration(), and TAnalysisWriteLoopClient().

fOutputFile

TParallelMergingFile* TAnalysisWriteLoopClient::fOutputFile

private

Definition at line 64 of file TAnalysisWriteLoopClient.h.

Referenced by OnEnd(), and TAnalysisWriteLoopClient().

fStatusThread

std::thread StoppableThread::fStatusThread

staticinherited

Definition at line 81 of file StoppableThread.h.

Referenced by StoppableThread::join_status_thread(), StoppableThread::start_status_thread(), and StoppableThread::~StoppableThread().

fStatusThreadOn

bool StoppableThread::fStatusThreadOn = false

staticinherited

Definition at line 83 of file StoppableThread.h.

Referenced by StoppableThread::start_status_thread(), StoppableThread::status_out_loop(), StoppableThread::stop_status_thread(), StoppableThread::StoppableThread(), and StoppableThread::~StoppableThread().

fThreadMap

std::map< std::string, StoppableThread * > StoppableThread::fThreadMap

staticprotectedinherited

Definition at line 91 of file StoppableThread.h.

Referenced by 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(), StoppableThread::StopAll(), StoppableThread::StoppableThread(), and StoppableThread::~StoppableThread().