salsa  0.4.15
Salsa::TaskExecutorForkZmq Class Reference

TaskExecutorForkZmq class. More...

#include <TaskExecutorForkZmq.hh>

Inheritance diagram for Salsa::TaskExecutorForkZmq:
Salsa::TaskExecutor Salsa::Object

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)
 
TaskStatetaskState () 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.
 
TaskStatempTaskState = nullptr
 Task state.
 

Static Private Attributes

static std::shared_ptr< spdlog::logger > mspConsoleLogger = spdlog::stdout_color_mt("salsa")
 Pointer to spd logger.
 

Detailed Description

Constructor & Destructor Documentation

◆ TaskExecutorForkZmq()

Salsa::TaskExecutorForkZmq::TaskExecutorForkZmq ( zactor_t *  pActor = nullptr)

Constructor

Definition at line 4 of file TaskExecutorForkZmq.cc.

◆ ~TaskExecutorForkZmq()

Salsa::TaskExecutorForkZmq::~TaskExecutorForkZmq ( )
virtual

Destructor

Definition at line 10 of file TaskExecutorForkZmq.cc.

References mpZActor.

Member Function Documentation

◆ handlePipe()

bool Salsa::TaskExecutorForkZmq::handlePipe ( std::vector< std::string > &  )
virtual

◆ pipe()

void * Salsa::TaskExecutorForkZmq::pipe ( ) const
virtual

Returns pipe

Reimplemented from Salsa::TaskExecutor.

Definition at line 50 of file TaskExecutorForkZmq.cc.

References mpZActor.

Referenced by handlePipe(), and run().

◆ run()

bool Salsa::TaskExecutorForkZmq::run ( std::string  ,
std::string   
)
virtual

Run task.

Run

Implements Salsa::TaskExecutor.

Definition at line 19 of file TaskExecutorForkZmq.cc.

References Salsa::TaskExecutor::mpTaskState, pipe(), and Salsa::TaskState::task().

◆ taskState() [1/2]

TaskState * Salsa::TaskExecutor::taskState ( ) const
inherited

Returns task state

Definition at line 30 of file TaskExecutor.cc.

References Salsa::TaskExecutor::mpTaskState.

◆ taskState() [2/2]

void Salsa::TaskExecutor::taskState ( TaskState pTS)
inherited

Sets task state

Definition at line 22 of file TaskExecutor.cc.

References Salsa::TaskExecutor::mpTaskState.

Referenced by Salsa::NodeManagerZyre::addTaskSlot().


The documentation for this class was generated from the following files: