Templated derivation of TMPWorkerTree handlign selector tree processing.

Definition at line 104 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)

virtual	~TMPWorkerTreeSel ()

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

	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)

virtual	~TMPWorkerTree ()

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

TMPWorker &	operator= (const TMPWorker &)=delete

void	Run ()

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

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

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

Additional Inherited Members
Protected Member Functions inherited from TMPWorkerTree
void	CloseFile ()
	Handle file closing. More...

ULong64_t	EvalMaxEntries (ULong64_t maxEntries)
	Max entries evaluation. More...

void	HandleInput (MPCodeBufPair &msg)
	Execute instructions received from a MP client. More...

void	Init (int fd, UInt_t workerN)
	Init overload definign max entries. More...

Int_t	LoadTree (UInt_t code, MPCodeBufPair &msg, Long64_t &start, Long64_t &finish, TEntryList **enl, std::string &errmsg)
	Load the requierd tree and evaluate the processing range. More...

TFile *	OpenFile (const std::string &fileName)
	Handle file opening. More...

virtual void	Process (UInt_t, MPCodeBufPair &)

TTree *	RetrieveTree (TFile *fp)
	Retrieve a tree from an open file. More...

virtual void	SendResult ()

void	Setup ()
	Auxilliary method for common initializations. More...

void	SetupTreeCache (TTree *tree)
	Tree cache handling. More...

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

Protected Attributes inherited from TMPWorkerTree
TEntryList *	fEntryList
	entrylist More...

TFile *	fFile
	last open file More...

std::vector< std::string >	fFileNames
	the files to be processed by all workers More...

ULong64_t	fFirstEntry
	first entry to br processed More...

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

std::string	fTreeName
	the name of the tree to be processed More...

Protected Attributes inherited from TMPWorker
std::string	fId
	identifier string in the form W<nwrk>\|P<proc id> More...

ULong64_t	fMaxNEntries
	the maximum number of entries to be processed by this worker More...

unsigned	fNWorkers
	the number of workers spawned More...

ULong64_t	fProcessedEntries
	the number of entries processed by this worker so far More...

#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 106 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 112 of file TMPWorkerTree.h.

◆ ~TMPWorkerTreeSel()

virtual TMPWorkerTreeSel::~TMPWorkerTreeSel ( )

inlinevirtual

Definition at line 117 of file TMPWorkerTree.h.

Member Function Documentation

◆ Process()

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

privatevirtual

Selector specialization.

Reimplemented from TMPWorkerTree.

Definition at line 237 of file TMPWorkerTree.cxx.

◆ SendResult()

void TMPWorkerTreeSel::SendResult ( )

privatevirtual

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 124 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 123 of file TMPWorkerTree.h.

Libraries for TMPWorkerTreeSel: