salsa
0.3.0
|
TaskExecutorForkZmq class. More...
#include <TaskExecutorForkZmq.hh>
Public Member Functions | |
TaskExecutorForkZmq (zactor_t *pActor=nullptr) | |
virtual | ~TaskExecutorForkZmq () |
virtual bool | run (std::string worker, std::string upstream) |
Run task. More... | |
virtual void * | pipe () const |
virtual bool | handlePipe (std::vector< std::string > &extra) |
Handle pipe. More... | |
void | taskState (TaskState *pTS) |
TaskState * | taskState () const |
Static Public Member Functions | |
static std::shared_ptr < spdlog::logger > | getConsoleOutput () |
Get console output. | |
static void | setConsoleLevel (spdlog::level::level_enum level) |
Sets console log level. | |
Protected Attributes | |
zactor_t * | mpZActor = nullptr |
ZMQ Actor pointer. | |
TaskState * | mpTaskState = nullptr |
Task state. | |
TaskExecutorForkZmq class.
Definition at line 16 of file TaskExecutorForkZmq.hh.
Salsa::TaskExecutorForkZmq::TaskExecutorForkZmq | ( | zactor_t * | pActor = nullptr | ) |
Constructor
Definition at line 4 of file TaskExecutorForkZmq.cc.
|
virtual |
|
virtual |
Handle pipe.
Handle pipe
Implements Salsa::TaskExecutor.
Definition at line 52 of file TaskExecutorForkZmq.cc.
References Salsa::TaskExecutor::mpTaskState, Salsa::TaskState::pid(), pipe(), Salsa::TaskState::state(), and Salsa::TaskState::task().
|
virtual |
Returns pipe
Reimplemented from Salsa::TaskExecutor.
Definition at line 44 of file TaskExecutorForkZmq.cc.
References mpZActor.
Referenced by handlePipe(), and run().
|
virtual |
Run task.
Run
Implements Salsa::TaskExecutor.
Definition at line 19 of file TaskExecutorForkZmq.cc.
References Salsa::TaskExecutor::mpTaskState, pipe(), and Salsa::TaskState::task().
|
inherited |
Sets task state
Definition at line 22 of file TaskExecutor.cc.
References Salsa::TaskExecutor::mpTaskState.
Referenced by Salsa::NodeManagerZyre::addTaskSlot().
|
inherited |
Returns task state
Definition at line 30 of file TaskExecutor.cc.
References Salsa::TaskExecutor::mpTaskState.