Logo ROOT  
Reference Guide
TMPWorkerTreeSel Class Reference

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 ()
 
TMPWorkerTreeoperator= (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 ()
 
TSocketGetSocket ()
 
virtual void Init (int fd, unsigned workerN)
 This method is called by children processes right after forking. More...
 
TMPWorkeroperator= (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
 
TSelectorfSelector
 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...
 
TFileOpenFile (const std::string &fileName)
 Handle file opening. More...
 
virtual void Process (UInt_t, MPCodeBufPair &)
 
TTreeRetrieveTree (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
TEntryListfEntryList
 entrylist More...
 
TFilefFile
 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...
 
TTreefTree
 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:
[legend]

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