Definition at line 169 of file TMPWorkerExecutor.h.
Public Member Functions | |
TMPWorkerExecutor (F func, const std::vector< T > &args) | |
~TMPWorkerExecutor () | |
void | HandleInput (MPCodeBufPair &msg) override |
< Execute instructions received from a TProcessExecutor client | |
![]() | |
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. | |
TMPWorker & | operator= (const TMPWorker &)=delete |
void | Run () |
Private Attributes | |
std::vector< T > | fArgs |
a vector containing the arguments that must be passed to fFunc | |
F | fFunc |
the function to be executed | |
Additional Inherited Members | |
![]() | |
void | SendError (const std::string &errmsg, unsigned int code=MPCode::kError) |
Error sender. | |
![]() | |
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 <TMPWorkerExecutor.h>
|
inline |
Definition at line 171 of file TMPWorkerExecutor.h.
|
inline |
Definition at line 172 of file TMPWorkerExecutor.h.
|
inlineoverridevirtual |
< Execute instructions received from a TProcessExecutor client
Reimplemented from TMPWorker.
Definition at line 173 of file TMPWorkerExecutor.h.
|
private |
a vector containing the arguments that must be passed to fFunc
Definition at line 189 of file TMPWorkerExecutor.h.
the function to be executed
Definition at line 188 of file TMPWorkerExecutor.h.