ROOT 6.16/01 Reference Guide |
Definition at line 168 of file TMPWorkerExecutor.h.
Public Member Functions | |
TMPWorkerExecutor (F func, const std::vector< T > &args) | |
~TMPWorkerExecutor () | |
void | HandleInput (MPCodeBufPair &msg) |
Handle a message with an EMPCode. More... | |
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 Attributes | |
std::vector< T > | fArgs |
a vector containing the arguments that must be passed to fFunc More... | |
F | fFunc |
the function to be executed More... | |
Additional Inherited Members | |
Protected Member Functions inherited from TMPWorker | |
void | SendError (const std::string &errmsg, unsigned int code=MPCode::kError) |
Error sender. 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 <TMPWorkerExecutor.h>
|
inline |
Definition at line 170 of file TMPWorkerExecutor.h.
|
inline |
Definition at line 171 of file TMPWorkerExecutor.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.
Reimplemented from TMPWorker.
Definition at line 172 of file TMPWorkerExecutor.h.
|
private |
a vector containing the arguments that must be passed to fFunc
Definition at line 189 of file TMPWorkerExecutor.h.
|
private |
the function to be executed
Definition at line 188 of file TMPWorkerExecutor.h.