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

Public Member Functions inherited from TMPWorkerTree
	TMPWorkerTree ()
	Class constructors.

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

	TMPWorkerTree (const TMPWorkerTree &)=delete

	TMPWorkerTree (TTree tree, TEntryList entries, UInt_t nWorkers, ULong64_t maxEntries, ULong64_t firstEntry)

	~TMPWorkerTree () override

TMPWorkerTree &	operator= (const TMPWorkerTree &)=delete

Public Member Functions inherited from TMPWorker
	TMPWorker ()

	TMPWorker (const TMPWorker &)=delete

	TMPWorker (unsigned nWorkers, ULong64_t maxEntries)

virtual	~TMPWorker ()

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.

TMPWorker &	operator= (const TMPWorker &)=delete

void	Run ()

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

void	SendResult () override
	Selector processing SendResult and Process overload.

Private Attributes
bool	fCallBegin = true

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

Additional Inherited Members
Protected Member Functions inherited from TMPWorkerTree
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	Setup ()
	Auxiliary method for common initialization.

void	SetupTreeCache (TTree *tree)
	Tree cache handling.

Protected Member Functions inherited from TMPWorker
void	SendError (const std::string &errmsg, unsigned int code=MPCode::kError)
	Error sender.

Protected Attributes inherited from TMPWorkerTree
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

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

Protected Attributes inherited from TMPWorker
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

#include <TMPWorkerTree.h>

Inheritance diagram for TMPWorkerTreeSel:

[legend]

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

◆ Process()

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

overrideprivatevirtual

Selector specialization.

Reimplemented from TMPWorkerTree.

Definition at line 239 of file TMPWorkerTree.cxx.

◆ SendResult()

void TMPWorkerTreeSel::SendResult ( )

overrideprivatevirtual

Selector processing SendResult and Process overload.

Reimplemented from TMPWorkerTree.

Definition at line 229 of file TMPWorkerTree.cxx.

Member Data Documentation

◆ fCallBegin

bool TMPWorkerTreeSel::fCallBegin = true

private

Definition at line 126 of file TMPWorkerTree.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.

Libraries for TMPWorkerTreeSel:

[legend]

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

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

Public Member Functions

Private Member Functions

Private Attributes

Additional Inherited Members