![]() |
ROOT
6.07/01
Reference Guide
|
Definition at line 71 of file TPoolProcessor.h.
Public Member Functions | |
TPoolProcessor (F procFunc, const std::vector< std::string > &fileNames, const std::string &treeName, unsigned nWorkers, ULong64_t maxEntries) | |
TPoolProcessor (F procFunc, TTree *tree, unsigned nWorkers, ULong64_t maxEntries) | |
~TPoolProcessor () | |
void | HandleInput (MPCodeBufPair &msg) |
Execute instructions received from a TPool client. More... | |
void | Init (int fd, unsigned workerN) |
This method is called by children processes right after forking. More... | |
![]() | |
TMPWorker () | |
Class constructor. More... | |
virtual | ~TMPWorker () |
TMPWorker (const TMPWorker &)=delete | |
TMPWorker & | operator= (const TMPWorker &)=delete |
void | Run () |
TSocket * | GetSocket () |
pid_t | GetPid () |
unsigned | GetNWorker () const |
Private Member Functions | |
void | Process (unsigned code, MPCodeBufPair &msg) |
TFile * | OpenFile (const std::string &fileName) |
TTree * | RetrieveTree (TFile *fp) |
ULong64_t | EvalMaxEntries (ULong64_t maxEntries) |
Private Attributes | |
F | fProcFunc |
the function to be executed More... | |
std::vector< std::string > | fFileNames |
the files to be processed by all workers More... | |
std::string | fTreeName |
the name of the tree to be processed More... | |
TTree * | fTree |
pointer to the tree to be processed. It is only used if the tree is directly passed to TProcPool::Process as argument More... | |
unsigned | fNWorkers |
the number of workers spawned More... | |
ULong64_t | fMaxNEntries |
the maximum number of entries to be processed by this worker More... | |
ULong64_t | fProcessedEntries |
the number of entries processed by this worker so far More... | |
std::result_of< F(std::reference_wrapper < TTreeReader >)>::type | fReducedResult |
the results of the executions of fProcFunc merged together More... | |
bool | fCanReduce |
true if fReducedResult can be reduced with a new result, false until we have produced one result More... | |
#include <TPoolProcessor.h>
TPoolProcessor< F >::TPoolProcessor | ( | F | procFunc, |
const std::vector< std::string > & | fileNames, | ||
const std::string & | treeName, | ||
unsigned | nWorkers, | ||
ULong64_t | maxEntries | ||
) |
Definition at line 99 of file TPoolProcessor.h.
TPoolProcessor< F >::TPoolProcessor | ( | F | procFunc, |
TTree * | tree, | ||
unsigned | nWorkers, | ||
ULong64_t | maxEntries | ||
) |
Definition at line 107 of file TPoolProcessor.h.
|
inline |
Definition at line 75 of file TPoolProcessor.h.
|
private |
Definition at line 306 of file TPoolProcessor.h.
|
virtual |
Execute instructions received from a TPool client.
Reimplemented from TMPWorker.
Definition at line 116 of file TPoolProcessor.h.
|
virtual |
This method is called by children processes right after forking.
Initialization of worker properties that must be delayed until after forking must be done here.
For example, Init saves the pid into fPid, and adds the TMPWorker to the main eventloop (as a TFileHandler).
Make sure this operations are performed also by overriding implementations, e.g. by calling TMPWorker::Init explicitly.
Reimplemented from TMPWorker.
Definition at line 138 of file TPoolProcessor.h.
|
private |
Definition at line 257 of file TPoolProcessor.h.
|
private |
Definition at line 146 of file TPoolProcessor.h.
|
private |
Definition at line 274 of file TPoolProcessor.h.
|
private |
true if fReducedResult can be reduced with a new result, false until we have produced one result
Definition at line 94 of file TPoolProcessor.h.
|
private |
the files to be processed by all workers
Definition at line 87 of file TPoolProcessor.h.
|
private |
the maximum number of entries to be processed by this worker
Definition at line 91 of file TPoolProcessor.h.
|
private |
the number of workers spawned
Definition at line 90 of file TPoolProcessor.h.
|
private |
the number of entries processed by this worker so far
Definition at line 92 of file TPoolProcessor.h.
|
private |
the function to be executed
Definition at line 86 of file TPoolProcessor.h.
|
private |
the results of the executions of fProcFunc merged together
Definition at line 93 of file TPoolProcessor.h.
|
private |
pointer to the tree to be processed. It is only used if the tree is directly passed to TProcPool::Process as argument
Definition at line 89 of file TPoolProcessor.h.
|
private |
the name of the tree to be processed
Definition at line 88 of file TPoolProcessor.h.