Templated derivation of TMPWorkerTree handlign generic function tree processing.
Definition at line 79 of file TMPWorkerTree.h.
Private Member Functions | |
void | Process (UInt_t code, MPCodeBufPair &msg) override |
void | SendResult () override |
Generic function processing SendResult and Process overload. | |
Private Attributes | |
bool | fCanReduce |
true if fReducedResult can be reduced with a new result, false until we have produced one result | |
F | fProcFunc |
copy the function to be executed | |
ROOT::TypeTraits::InvokeResult_t< F, std::reference_wrapper< TTreeReader > > | fReducedResult |
the results of the executions of fProcFunc merged together | |
Additional Inherited Members | |
![]() | |
void | CloseFile () |
Handle file closing. | |
ULong64_t | EvalMaxEntries (ULong64_t maxEntries) |
Max entries evaluation. | |
void | HandleInput (MPCodeBufPair &msg) override |
Execute instructions received from a MP client. | |
void | Init (int fd, UInt_t workerN) override |
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. | |
TFile * | OpenFile (const std::string &fileName) |
Handle file opening. | |
TTree * | RetrieveTree (TFile *fp) |
Retrieve a tree from an open file. | |
void | Setup () |
Auxiliary method for common initialization. | |
void | SetupTreeCache (TTree *tree) |
Tree cache handling. | |
![]() | |
void | SendError (const std::string &errmsg, unsigned int code=MPCode::kError) |
Error sender. | |
![]() | |
TEntryList * | fEntryList |
entrylist | |
TFile * | fFile |
last open file | |
std::vector< std::string > | fFileNames |
the files to be processed by all workers | |
ULong64_t | fFirstEntry |
first entry to br processed | |
TTree * | fTree |
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 | |
![]() | |
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>
|
inline |
Definition at line 81 of file TMPWorkerTree.h.
|
inline |
Definition at line 87 of file TMPWorkerTree.h.
|
inlineoverride |
Definition at line 93 of file TMPWorkerTree.h.
|
overrideprivatevirtual |
Reimplemented from TMPWorkerTree.
Definition at line 189 of file TMPWorkerTree.h.
|
overrideprivatevirtual |
Generic function processing SendResult and Process overload.
Reimplemented from TMPWorkerTree.
Definition at line 182 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 103 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 101 of file TMPWorkerTree.h.