 |
ROOT 6.08/07 Reference Guide |
| |
ROOT 6.08/07 Reference Guide |
Definition at line 127 of file TPoolWorker.h.
Public Member Functions | |
| TPoolWorker (F func, R redfunc) | |
| ~TPoolWorker () | |
| void | HandleInput (MPCodeBufPair &msg) |
| Handle a message with an EMPCode. More... | |
 Public Member Functions inherited from TMPWorker | |
| TMPWorker () | |
| Class constructors. More... | |
| TMPWorker (const std::vector< std::string > &fileNames, const std::string &treeName, unsigned nWorkers, ULong64_t maxEntries) | |
| TMPWorker (TTree *tree, unsigned nWorkers, ULong64_t maxEntries) | |
| TMPWorker (const TMPWorker &)=delete | |
| 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 Attributes | |
| bool | fCanReduce |
| true if fReducedResult can be reduced with a new result, false until we have produced one result More... | |
| F | fFunc |
| the function to be executed More... | |
| R | fRedFunc |
| the reduce function More... | |
| decltype(fFunc()) | fReducedResult |
| the result of the execution More... | |
Additional Inherited Members | |
| Protected Member Functions inherited from TMPWorker | |
| void | CloseFile () |
| Handle file closing. More... | |
| TFile * | OpenFile (const std::string &fileName) |
| Handle file opening. More... | |
| TTree * | RetrieveTree (TFile *fp) |
| Retrieve a tree from an open file. More... | |
| void | SendError (const std::string &errmsg, unsigned int code=MPCode::kError) |
| Error sender. More... | |
| void | Setup () |
| Auxilliary method for common initializations. More... | |
| void | SetupTreeCache (TTree *tree) |
| Tree cache handling. More... | |
| Protected Attributes inherited from TMPWorker | |
| TFile * | fFile |
| last open file More... | |
| std::vector< std::string > | fFileNames |
| the files to be processed by all workers More... | |
| 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... | |
| 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... | |
#include <TPoolWorker.h>
|
inline |
Definition at line 129 of file TPoolWorker.h.
|
inline |
Definition at line 133 of file TPoolWorker.h.
|
inlinevirtual |
Handle a message with an EMPCode.
This method is called upon receiving a message with a code >= 1000 (i.e. EMPCode). It handles the most generic types of messages.
Classes inheriting from TMPWorker should implement their own HandleInput function, that should be able to handle codes specific to that application.
The appropriate version of the HandleInput method (TMPWorker's or the overriding version) is automatically called depending on the message code.
| msg | Execute instructions received from a TProcessExecutor client |
Reimplemented from TMPWorker.
Definition at line 135 of file TPoolWorker.h.
|
private |
true if fReducedResult can be reduced with a new result, false until we have produced one result
Definition at line 164 of file TPoolWorker.h.
|
private |
the function to be executed
Definition at line 161 of file TPoolWorker.h.
|
private |
the reduce function
Definition at line 162 of file TPoolWorker.h.
|
private |
the result of the execution
Definition at line 163 of file TPoolWorker.h.
ROOT 6.08/07 - Reference Guide Generated on Thu May 31 2018 21:47:53 using Doxygen 1.8.13.