This loop writes fragments to a root-file.

Definition at line 27 of file TFragWriteLoop.h.

Public Member Functions
	~TFragWriteLoop () override

std::shared_ptr< ThreadsafeQueue< std::shared_ptr< const TBadFragment > > > &	BadInputQueue ()

void	ClearQueue () override

std::string	EndStatus () override

size_t	GetItemsCurrent () override

size_t	GetItemsPopped () override

size_t	GetItemsPushed () override

size_t	GetRate () override

std::shared_ptr< ThreadsafeQueue< std::shared_ptr< const TFragment > > > &	InputQueue ()

bool	IsPaused ()

bool	IsRunning ()

void	Join ()

std::string	Name () const

virtual void	OnEnd ()

std::shared_ptr< ThreadsafeQueue< std::shared_ptr< const TFragment > > > &	OutputQueue ()

void	Pause ()

virtual std::string	Progress ()

void	Resume ()

std::shared_ptr< ThreadsafeQueue< std::shared_ptr< TEpicsFrag > > > &	ScalerInputQueue ()

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 void	ColumnWidth (size_t val)

static size_t	ColumnWidth ()

static TFragWriteLoop *	Get (std::string name="", std::string fOutputFilename="")

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
	TFragWriteLoop (std::string name, std::string fOutputFilename)

	ClassDefOverride (TFragWriteLoop, 0)

void	WriteBadEvent (const std::shared_ptr< const TBadFragment > &event)

void	WriteEvent (const std::shared_ptr< const TFragment > &event)

void	WriteScaler (const std::shared_ptr< TEpicsFrag > &scaler)

Private Attributes
TBadFragment *	fBadEventAddress

TTree *	fBadEventTree

std::shared_ptr< ThreadsafeQueue< std::shared_ptr< const TBadFragment > > >	fBadInputQueue

TFragment *	fEventAddress

TTree *	fEventTree

std::shared_ptr< ThreadsafeQueue< std::shared_ptr< const TFragment > > >	fInputQueue

TFile *	fOutputFile

std::shared_ptr< ThreadsafeQueue< std::shared_ptr< const TFragment > > >	fOutputQueue

TEpicsFrag *	fScalerAddress

std::shared_ptr< ThreadsafeQueue< std::shared_ptr< TEpicsFrag > > >	fScalerInputQueue

TTree *	fScalerTree

#include <TFragWriteLoop.h>

Inheritance diagram for TFragWriteLoop:

Collaboration diagram for TFragWriteLoop:

Constructor & Destructor Documentation

◆ ~TFragWriteLoop()

TFragWriteLoop::~TFragWriteLoop ( )

override

Definition at line 68 of file TFragWriteLoop.cxx.

References Write().

◆ TFragWriteLoop()

TFragWriteLoop::TFragWriteLoop	(	std::string	name,
		std::string	fOutputFilename
	)

private

Definition at line 38 of file TFragWriteLoop.cxx.

References fBadEventAddress, fBadEventTree, fEventAddress, fEventTree, fOutputFile, fScalerAddress, and fScalerTree.

Referenced by Get().

Member Function Documentation

◆ 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.

◆ BadInputQueue()

std::shared_ptr<ThreadsafeQueue<std::shared_ptr<const TBadFragment> > >& TFragWriteLoop::BadInputQueue ( )

inline

Definition at line 35 of file TFragWriteLoop.h.

References fBadInputQueue.

Referenced by TGRSIint::SetupPipeline().

◆ ClassDefOverride()

TFragWriteLoop::ClassDefOverride	(	TFragWriteLoop	,
		0
	)

private

◆ ClearAllQueues()

void StoppableThread::ClearAllQueues ( )

staticinherited

Definition at line 166 of file StoppableThread.cxx.

References StoppableThread::fThreadMap.

Referenced by TGRSIInterruptHandler::Notify().

◆ ClearQueue()

void TFragWriteLoop::ClearQueue ( )

overridevirtual

Reimplemented from StoppableThread.

Definition at line 73 of file TFragWriteLoop.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()

std::string TFragWriteLoop::EndStatus ( )

overridevirtual

Reimplemented from StoppableThread.

Definition at line 81 of file TFragWriteLoop.cxx.

References fBadEventTree, fEventTree, StoppableThread::fInputSize, StoppableThread::fItemsPopped, and StoppableThread::Name().

◆ Get() [1/2]

TFragWriteLoop * TFragWriteLoop::Get	(	std::string	name = `""`,
		std::string	fOutputFilename = `""`
	)

static

Definition at line 22 of file TFragWriteLoop.cxx.

References StoppableThread::Get(), and TFragWriteLoop().

Referenced by TGRSIint::SetupPipeline().

◆ Get() [2/2]

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

◆ GetItemsCurrent()

size_t TFragWriteLoop::GetItemsCurrent ( )

inlineoverridevirtual

Implements StoppableThread.

Definition at line 48 of file TFragWriteLoop.h.

◆ GetItemsPopped()

size_t TFragWriteLoop::GetItemsPopped ( )

inlineoverridevirtual

Implements StoppableThread.

Definition at line 47 of file TFragWriteLoop.h.

References StoppableThread::fItemsPopped.

◆ GetItemsPushed()

size_t TFragWriteLoop::GetItemsPushed ( )

inlineoverridevirtual

Implements StoppableThread.

Definition at line 46 of file TFragWriteLoop.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 TFragWriteLoop::GetRate ( )

inlineoverridevirtual

Implements StoppableThread.

Definition at line 49 of file TFragWriteLoop.h.

◆ InputQueue()

std::shared_ptr<ThreadsafeQueue<std::shared_ptr<const TFragment> > >& TFragWriteLoop::InputQueue ( )

inline

Definition at line 34 of file TFragWriteLoop.h.

References fInputQueue.

Referenced by TGRSIint::SetupPipeline().

◆ 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 TFragWriteLoop::Iteration ( )

overrideprotectedvirtual

Implements StoppableThread.

Definition at line 93 of file TFragWriteLoop.cxx.

References fBadInputQueue, fInputQueue, StoppableThread::fInputSize, StoppableThread::fItemsPopped, fScalerInputQueue, WriteBadEvent(), WriteEvent(), and WriteScaler().

◆ 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 TAnalysisWriteLoopClient::AddBranch(), TAnalysisWriteLoop::EndStatus(), EndStatus(), TUnpackingLoop::EndStatus(), and StoppableThread::status_out().

◆ OnEnd()

virtual void StoppableThread::OnEnd ( )

inlinevirtualinherited

Reimplemented in TAnalysisWriteLoopClient, TFragmentChainLoop, TAnalysisWriteLoop, and TDataLoop.

Definition at line 54 of file StoppableThread.h.

Referenced by StoppableThread::Loop().

◆ OutputQueue()

std::shared_ptr<ThreadsafeQueue<std::shared_ptr<const TFragment> > >& TFragWriteLoop::OutputQueue ( )

inline

Definition at line 37 of file TFragWriteLoop.h.

References fOutputQueue.

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

◆ ScalerInputQueue()

std::shared_ptr<ThreadsafeQueue<std::shared_ptr<TEpicsFrag> > >& TFragWriteLoop::ScalerInputQueue ( )

inline

Definition at line 36 of file TFragWriteLoop.h.

References fScalerInputQueue.

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

◆ Write()

void TFragWriteLoop::Write ( )

◆ WriteBadEvent()

void TFragWriteLoop::WriteBadEvent ( const std::shared_ptr< const TBadFragment > & event )

private

Definition at line 184 of file TFragWriteLoop.cxx.

References fBadEventAddress, fBadEventTree, and ttree_fill_mutex.

Referenced by Iteration().

◆ WriteEvent()

void TFragWriteLoop::WriteEvent ( const std::shared_ptr< const TFragment > & event )

private

Definition at line 171 of file TFragWriteLoop.cxx.

References TDetectorHit::ClearTransients(), fEventAddress, fEventTree, and ttree_fill_mutex.

Referenced by Iteration().

◆ WriteScaler()

void TFragWriteLoop::WriteScaler ( const std::shared_ptr< TEpicsFrag > & scaler )

private

Definition at line 193 of file TFragWriteLoop.cxx.

References fScalerAddress, fScalerTree, and ttree_fill_mutex.

Referenced by Iteration().

Member Data Documentation

◆ fBadEventAddress

TBadFragment* TFragWriteLoop::fBadEventAddress

private

Definition at line 71 of file TFragWriteLoop.h.

Referenced by TFragWriteLoop(), and WriteBadEvent().

◆ fBadEventTree

TTree* TFragWriteLoop::fBadEventTree

private

Definition at line 67 of file TFragWriteLoop.h.

Referenced by EndStatus(), TFragWriteLoop(), Write(), and WriteBadEvent().

◆ fBadInputQueue

std::shared_ptr<ThreadsafeQueue<std::shared_ptr<const TBadFragment> > > TFragWriteLoop::fBadInputQueue

private

Definition at line 76 of file TFragWriteLoop.h.

Referenced by BadInputQueue(), and Iteration().

◆ fEventAddress

TFragment* TFragWriteLoop::fEventAddress

private

Definition at line 70 of file TFragWriteLoop.h.

Referenced by TFragWriteLoop(), and WriteEvent().

◆ fEventTree

TTree* TFragWriteLoop::fEventTree

private

Definition at line 66 of file TFragWriteLoop.h.

Referenced by EndStatus(), TFragWriteLoop(), Write(), and WriteEvent().

◆ fInputQueue

std::shared_ptr<ThreadsafeQueue<std::shared_ptr<const TFragment> > > TFragWriteLoop::fInputQueue

private

Definition at line 75 of file TFragWriteLoop.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(), EndStatus(), TAnalysisWriteLoopClient::GetInputSize(), TEventBuildingLoop::Iteration(), TDataLoop::Iteration(), TDetBuildingLoop::Iteration(), TAnalysisWriteLoop::Iteration(), TUnpackingLoop::Iteration(), Iteration(), TFragHistLoop::Iteration(), TAnalysisHistLoop::Iteration(), TFragmentChainLoop::Iteration(), TAnalysisWriteLoopClient::Iteration(), StoppableThread::Progress(), and StoppableThread::Status().

◆ fItemsPopped

std::atomic_size_t StoppableThread::fItemsPopped {0}

protectedinherited

◆ fName

std::string StoppableThread::fName

protectedinherited

Definition at line 99 of file StoppableThread.h.

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

◆ fOutputFile

TFile* TFragWriteLoop::fOutputFile

private

Definition at line 64 of file TFragWriteLoop.h.

Referenced by TFragWriteLoop(), and Write().

◆ fOutputQueue

std::shared_ptr<ThreadsafeQueue<std::shared_ptr<const TFragment> > > TFragWriteLoop::fOutputQueue

private

Definition at line 78 of file TFragWriteLoop.h.

Referenced by OutputQueue().

◆ fScalerAddress

TEpicsFrag* TFragWriteLoop::fScalerAddress

private

Definition at line 72 of file TFragWriteLoop.h.

Referenced by TFragWriteLoop(), and WriteScaler().

◆ fScalerInputQueue

std::shared_ptr<ThreadsafeQueue<std::shared_ptr<TEpicsFrag> > > TFragWriteLoop::fScalerInputQueue

private

Definition at line 77 of file TFragWriteLoop.h.

Referenced by Iteration(), and ScalerInputQueue().

◆ fScalerTree

TTree* TFragWriteLoop::fScalerTree

private

Definition at line 68 of file TFragWriteLoop.h.

Referenced by TFragWriteLoop(), Write(), and WriteScaler().

◆ 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.

Public Member Functions

Static Public Member Functions

Static Public Attributes

Protected Member Functions

Protected Attributes

Static Protected Attributes

Private Member Functions

Private Attributes

Constructor & Destructor Documentation

◆ ~TFragWriteLoop()

◆ TFragWriteLoop()

Member Function Documentation

◆ AllThreadHeader()

◆ AllThreadProgress()

◆ AllThreadStatus()

◆ AnyThreadRunning()

◆ AnyThreadStatus()

◆ BadInputQueue()

◆ ClassDefOverride()

◆ ClearAllQueues()

◆ ClearQueue()

◆ ColumnWidth() [1/2]

◆ ColumnWidth() [2/2]

◆ EndStatus()

◆ Get() [1/2]

◆ Get() [2/2]

◆ GetAll()

◆ GetItemsCurrent()

◆ GetItemsPopped()

◆ GetItemsPushed()

◆ GetNThreads()

◆ GetRate()

◆ InputQueue()

◆ IsPaused()

◆ IsRunning()

◆ Iteration()

◆ Join()

◆ join_status_thread()

◆ Name()

◆ OnEnd()

◆ OutputQueue()

◆ Pause()

◆ PauseAll()

◆ Print()

◆ Progress()

◆ Resume()

◆ ResumeAll()

◆ ScalerInputQueue()

◆ SendStop()

◆ start_status_thread()

◆ Status()

◆ status_out()

◆ status_out_loop()

◆ StatusWidth() [1/2]

◆ StatusWidth() [2/2]

◆ Stop()

◆ stop_status_thread()

◆ StopAll()

◆ Write()

◆ WriteBadEvent()

◆ WriteEvent()

◆ WriteScaler()

Member Data Documentation

◆ fBadEventAddress

◆ fBadEventTree

◆ fBadInputQueue

◆ fEventAddress

◆ fEventTree

◆ fInputQueue

◆ fInputSize

◆ fItemsPopped

◆ fName

◆ fOutputFile

◆ fOutputQueue

◆ fScalerAddress

◆ fScalerInputQueue

◆ fScalerTree

◆ fStatusThread

◆ fStatusThreadOn

◆ fThreadMap