Loading [MathJax]/extensions/MathMenu.js
Logo ROOT  
Reference Guide
All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Properties Friends Macros Modules Pages
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: