Templated derivation of TMPWorkerTree handlign selector tree processing.

Definition at line 106 of file TMPWorkerTree.h.

Public Member Functions
	TMPWorkerTreeSel (TSelector &selector, const std::vector< std::string > &fileNames, TEntryList *entries, const std::string &treeName, UInt_t nWorkers, ULong64_t maxEntries, ULong64_t firstEntry)
	TMPWorkerTreeSel (TSelector &selector, TTree tree, TEntryList entries, UInt_t nWorkers, ULong64_t maxEntries, ULong64_t firstEntry)
	~TMPWorkerTreeSel () override
unsigned	GetNWorker () const
pid_t	GetPid ()
TSocket *	GetSocket ()
virtual void	Init (int fd, unsigned workerN)
	This method is called by children processes right after forking.
void	Run ()

Protected Member Functions
void	CloseFile ()
	Handle file closing.
ULong64_t	EvalMaxEntries (ULong64_t maxEntries)
	Max entries evaluation.
void	HandleInput (MPCodeBufPair &msg) override
	Execute instructions received from a MP client.
void	Init (int fd, UInt_t workerN) override
	Init overload defining max entries.
Int_t	LoadTree (UInt_t code, MPCodeBufPair &msg, Long64_t &start, Long64_t &finish, TEntryList **enl, std::string &errmsg)
	Load the required tree and evaluate the processing range.
TFile *	OpenFile (const std::string &fileName)
	Handle file opening.
TTree *	RetrieveTree (TFile *fp)
	Retrieve a tree from an open file.
void	SendError (const std::string &errmsg, unsigned int code=MPCode::kError)
	Error sender.
void	Setup ()
	Auxiliary method for common initialization.
void	SetupTreeCache (TTree *tree)
	Tree cache handling.

Protected Attributes
TEntryList *	fEntryList
	entrylist
TFile *	fFile
	last open file
std::vector< std::string >	fFileNames
	the files to be processed by all workers
ULong64_t	fFirstEntry
	first entry to br processed
std::string	fId
	identifier string in the form W<nwrk>\|P<proc id>
ULong64_t	fMaxNEntries
	the maximum number of entries to be processed by this worker
unsigned	fNWorkers
	the number of workers spawned
ULong64_t	fProcessedEntries
	the number of entries processed by this worker so far
TTree *	fTree
	pointer to the tree to be processed. It is only used if the tree is directly passed to TProcessExecutor::Process as argument
std::string	fTreeName
	the name of the tree to be processed

Private Member Functions
void	Process (UInt_t code, MPCodeBufPair &msg) override
	Selector specialization.
void	SendResult () override
	Selector processing SendResult and Process overload.

Private Attributes
Long64_t	fCacheSize
	Cache size.
bool	fCallBegin = true
unsigned	fNWorker
	the ordinal number of this worker (0 to nWorkers-1)
pid_t	fPid
	the PID of the process in which this worker is running
std::unique_ptr< TSocket >	fS
	This worker's socket. The unique_ptr makes sure resources are released.
TSelector &	fSelector
	pointer to the selector to be used to process the tree. It is null if we are not using a TSelector.
TTreeCache *	fTreeCache
	instance of the tree cache for the tree
bool	fTreeCacheIsLearning
	Whether cache is in learning phase.
bool	fUseTreeCache
	Control usage of the tree cache.

#include <TMPWorkerTree.h>

Inheritance diagram for TMPWorkerTreeSel:

Constructor & Destructor Documentation

◆ TMPWorkerTreeSel() [1/2]

TMPWorkerTreeSel::TMPWorkerTreeSel	(	TSelector &	selector,
		const std::vector< std::string > &	fileNames,
		TEntryList *	entries,
		const std::string &	treeName,
		UInt_t	nWorkers,
		ULong64_t	maxEntries,
		ULong64_t	firstEntry )

inline

Definition at line 108 of file TMPWorkerTree.h.

◆ TMPWorkerTreeSel() [2/2]

TMPWorkerTreeSel::TMPWorkerTreeSel	(	TSelector &	selector,
		TTree *	tree,
		TEntryList *	entries,
		UInt_t	nWorkers,
		ULong64_t	maxEntries,
		ULong64_t	firstEntry )

inline

Definition at line 114 of file TMPWorkerTree.h.

◆ ~TMPWorkerTreeSel()

TMPWorkerTreeSel::~TMPWorkerTreeSel ( )

inlineoverride

Definition at line 119 of file TMPWorkerTree.h.

Member Function Documentation

◆ CloseFile()

void TMPWorkerTree::CloseFile ( )

protectedinherited

Handle file closing.

Definition at line 88 of file TMPWorkerTree.cxx.

◆ EvalMaxEntries()

ULong64_t TMPWorkerTree::EvalMaxEntries ( ULong64_t maxEntries )

protectedinherited

Max entries evaluation.

Definition at line 190 of file TMPWorkerTree.cxx.

◆ GetNWorker()

unsigned TMPWorker::GetNWorker ( ) const

inlineinherited

Definition at line 41 of file TMPWorker.h.

◆ GetPid()

pid_t TMPWorker::GetPid ( )

inlineinherited

Definition at line 40 of file TMPWorker.h.

◆ GetSocket()

TSocket * TMPWorker::GetSocket ( )

inlineinherited

Definition at line 39 of file TMPWorker.h.

◆ HandleInput()

void TMPWorkerTree::HandleInput ( MPCodeBufPair & msg )

overrideprotectedvirtualinherited

Execute instructions received from a MP client.

Generic input handling.

Reimplemented from TMPWorker.

Definition at line 204 of file TMPWorkerTree.cxx.

◆ Init() [1/2]

void TMPWorker::Init	(	int	fd,
		unsigned	workerN )

virtualinherited

This method is called by children processes right after forking.

Initialization of worker properties that must be delayed until after forking must be done here.
For example, Init saves the pid into fPid, and adds the TMPWorker to the main eventloop (as a TFileHandler).
Make sure this operations are performed also by overriding implementations, e.g. by calling TMPWorker::Init explicitly.

Definition at line 52 of file TMPWorker.cxx.

◆ Init() [2/2]

void TMPWorkerTree::Init	(	int	fd,
		UInt_t	workerN )

overrideprotectedinherited

Init overload defining max entries.

Definition at line 180 of file TMPWorkerTree.cxx.

◆ LoadTree()

Int_t TMPWorkerTree::LoadTree	(	UInt_t	code,
		MPCodeBufPair &	msg,
		Long64_t &	start,
		Long64_t &	finish,
		TEntryList **	enl,
		std::string &	errmsg )

protectedinherited

Load the required tree and evaluate the processing range.

Definition at line 276 of file TMPWorkerTree.cxx.

◆ OpenFile()

TFile * TMPWorkerTree::OpenFile ( const std::string & fileName )

protectedinherited

Handle file opening.

Definition at line 101 of file TMPWorkerTree.cxx.

◆ Process()

void TMPWorkerTreeSel::Process	(	UInt_t	code,
		MPCodeBufPair &	msg )

overrideprivatevirtual

Selector specialization.

Reimplemented from TMPWorkerTree.

Definition at line 239 of file TMPWorkerTree.cxx.

◆ RetrieveTree()

TTree * TMPWorkerTree::RetrieveTree ( TFile * fp )

protectedinherited

Retrieve a tree from an open file.

Definition at line 119 of file TMPWorkerTree.cxx.

◆ Run()

void TMPWorker::Run ( )

inherited

Definition at line 61 of file TMPWorker.cxx.

◆ SendError()

void TMPWorker::SendError	(	const std::string &	errmsg,
		unsigned int	code = MPCode::kError )

protectedinherited

Error sender.

Definition at line 112 of file TMPWorker.cxx.

◆ SendResult()

void TMPWorkerTreeSel::SendResult ( )

overrideprivatevirtual

Selector processing SendResult and Process overload.

Reimplemented from TMPWorkerTree.

Definition at line 229 of file TMPWorkerTree.cxx.

◆ Setup()

void TMPWorkerTree::Setup ( )

protectedinherited

Auxiliary method for common initialization.

Definition at line 78 of file TMPWorkerTree.cxx.

◆ SetupTreeCache()

void TMPWorkerTree::SetupTreeCache ( TTree * tree )

protectedinherited

Tree cache handling.

Definition at line 151 of file TMPWorkerTree.cxx.

Member Data Documentation

◆ fCacheSize

Long64_t TMPWorkerTree::fCacheSize

privateinherited

Cache size.

Definition at line 75 of file TMPWorkerTree.h.

◆ fCallBegin

bool TMPWorkerTreeSel::fCallBegin = true

private

Definition at line 126 of file TMPWorkerTree.h.

◆ fEntryList

TEntryList* TMPWorkerTree::fEntryList

protectedinherited

entrylist

Definition at line 66 of file TMPWorkerTree.h.

◆ fFile

TFile* TMPWorkerTree::fFile

protectedinherited

last open file

Definition at line 65 of file TMPWorkerTree.h.

◆ fFileNames

std::vector<std::string> TMPWorkerTree::fFileNames

protectedinherited

the files to be processed by all workers

Definition at line 62 of file TMPWorkerTree.h.

◆ fFirstEntry

ULong64_t TMPWorkerTree::fFirstEntry

protectedinherited

first entry to br processed

Definition at line 67 of file TMPWorkerTree.h.

◆ fId

std::string TMPWorker::fId

protectedinherited

identifier string in the form W<nwrk>|P<proc id>

Definition at line 44 of file TMPWorker.h.

◆ fMaxNEntries

ULong64_t TMPWorker::fMaxNEntries

protectedinherited

the maximum number of entries to be processed by this worker

Definition at line 46 of file TMPWorker.h.

◆ fNWorker

unsigned TMPWorker::fNWorker

privateinherited

the ordinal number of this worker (0 to nWorkers-1)

Definition at line 56 of file TMPWorker.h.

◆ fNWorkers

unsigned TMPWorker::fNWorkers

protectedinherited

the number of workers spawned

Definition at line 45 of file TMPWorker.h.

◆ fPid

pid_t TMPWorker::fPid

privateinherited

the PID of the process in which this worker is running

Definition at line 55 of file TMPWorker.h.

◆ fProcessedEntries

ULong64_t TMPWorker::fProcessedEntries

protectedinherited

the number of entries processed by this worker so far

Definition at line 47 of file TMPWorker.h.

◆ fS

std::unique_ptr<TSocket> TMPWorker::fS

privateinherited

This worker's socket. The unique_ptr makes sure resources are released.

Definition at line 54 of file TMPWorker.h.

◆ fSelector

TSelector& TMPWorkerTreeSel::fSelector

private

pointer to the selector to be used to process the tree. It is null if we are not using a TSelector.

Definition at line 125 of file TMPWorkerTree.h.

◆ fTree

TTree* TMPWorkerTree::fTree

protectedinherited

pointer to the tree to be processed. It is only used if the tree is directly passed to TProcessExecutor::Process as argument

Definition at line 64 of file TMPWorkerTree.h.

◆ fTreeCache

TTreeCache* TMPWorkerTree::fTreeCache

privateinherited

instance of the tree cache for the tree

Definition at line 72 of file TMPWorkerTree.h.

◆ fTreeCacheIsLearning

bool TMPWorkerTree::fTreeCacheIsLearning

privateinherited

Whether cache is in learning phase.

Definition at line 73 of file TMPWorkerTree.h.

◆ fTreeName

std::string TMPWorkerTree::fTreeName

protectedinherited

the name of the tree to be processed

Definition at line 63 of file TMPWorkerTree.h.

◆ fUseTreeCache

bool TMPWorkerTree::fUseTreeCache

privateinherited

Control usage of the tree cache.

Definition at line 74 of file TMPWorkerTree.h.

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

tree/treeplayer/inc/TMPWorkerTree.h
tree/treeplayer/src/TMPWorkerTree.cxx

Public Member Functions

Protected Member Functions

Protected Attributes

Private Member Functions

Private Attributes

Constructor & Destructor Documentation

◆ TMPWorkerTreeSel() [1/2]

◆ TMPWorkerTreeSel() [2/2]

◆ ~TMPWorkerTreeSel()

Member Function Documentation

◆ CloseFile()

◆ EvalMaxEntries()

◆ GetNWorker()

◆ GetPid()

◆ GetSocket()

◆ HandleInput()

◆ Init() [1/2]

◆ Init() [2/2]

◆ LoadTree()

◆ OpenFile()

◆ Process()

◆ RetrieveTree()

◆ Run()

◆ SendError()

◆ SendResult()

◆ Setup()

◆ SetupTreeCache()

Member Data Documentation

◆ fCacheSize

◆ fCallBegin

◆ fEntryList

◆ fFile

◆ fFileNames

◆ fFirstEntry

◆ fId

◆ fMaxNEntries

◆ fNWorker

◆ fNWorkers

◆ fPid

◆ fProcessedEntries

◆ fS

◆ fSelector

◆ fTree

◆ fTreeCache

◆ fTreeCacheIsLearning

◆ fTreeName

◆ fUseTreeCache