 |
ROOT
Reference Guide |
|
| |
ROOT
Reference Guide |
|
Templated derivation of TMPWorkerTree handlign generic function tree processing.
Definition at line 79 of file TMPWorkerTree.h.
Public Member Functions | |
| TMPWorkerTreeFunc (F procFunc, const std::vector< std::string > &fileNames, TEntryList *entries, const std::string &treeName, UInt_t nWorkers, ULong64_t maxEntries, ULong64_t firstEntry) | |
| TMPWorkerTreeFunc (F procFunc, TTree *tree, TEntryList *entries, UInt_t nWorkers, ULong64_t maxEntries, ULong64_t firstEntry) | |
| virtual | ~TMPWorkerTreeFunc () |
 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) |
| void | SendResult () |
| Generic function processing SendResult and Process overload. More... | |
Private Attributes | |
| bool | fCanReduce |
| true if fReducedResult can be reduced with a new result, false until we have produced one result More... | |
| F | fProcFunc |
| copy the function to be executed More... | |
| std::result_of< F(std::reference_wrapper< TTreeReader >)>::type | fReducedResult |
| the results of the executions of fProcFunc merged together 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>
|
inline |
Definition at line 81 of file TMPWorkerTree.h.
|
inline |
Definition at line 87 of file TMPWorkerTree.h.
|
inlinevirtual |
Definition at line 93 of file TMPWorkerTree.h.
|
privatevirtual |
Reimplemented from TMPWorkerTree.
Definition at line 187 of file TMPWorkerTree.h.
|
privatevirtual |
Generic function processing SendResult and Process overload.
Reimplemented from TMPWorkerTree.
Definition at line 180 of file TMPWorkerTree.h.
|
private |
true if fReducedResult can be reduced with a new result, false until we have produced one result
Definition at line 101 of file TMPWorkerTree.h.
|
private |
copy the function to be executed
Definition at line 99 of file TMPWorkerTree.h.
|
private |
the results of the executions of fProcFunc merged together
Definition at line 100 of file TMPWorkerTree.h.
