Logo ROOT  
Reference Guide
 
Loading...
Searching...
No Matches
TMPWorkerTreeSel Class Reference

Templated derivation of TMPWorkerTree handlign selector tree processing.

Definition at line 105 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.
 
 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.
 
TMPWorkeroperator= (const TMPWorker &)=delete
 
void Run ()
 

Private Member Functions

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

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.
 

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)
 Execute instructions received from a MP client.
 
void Init (int fd, UInt_t workerN)
 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.
 
TFileOpenFile (const std::string &fileName)
 Handle file opening.
 
TTreeRetrieveTree (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
TEntryListfEntryList
 entrylist
 
TFilefFile
 last open file
 
std::vector< std::string > fFileNames
 the files to be processed by all workers
 
ULong64_t fFirstEntry
 first entry to br processed
 
TTreefTree
 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 107 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 113 of file TMPWorkerTree.h.

◆ ~TMPWorkerTreeSel()

virtual TMPWorkerTreeSel::~TMPWorkerTreeSel ( )
inlinevirtual

Definition at line 118 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 239 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 125 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 124 of file TMPWorkerTree.h.

Libraries for TMPWorkerTreeSel:

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