Salsa::TaskExecutorForkZmq Class Reference

TaskExecutorForkZmq class. More...

#include <TaskExecutorForkZmq.hh>

Inheritance diagram for Salsa::TaskExecutorForkZmq:

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.

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

Detailed Description

TaskExecutorForkZmq class.

Author

Matej Fedor matej.nosp@m..fed.nosp@m.or.mf.nosp@m.@gma.nosp@m.il.co.nosp@m.m

Martin Vala mvala.nosp@m.@cer.nosp@m.n.ch

Branislav Beke bbeke.nosp@m.@bad.nosp@m.haven.nosp@m..dev

Definition at line 16 of file TaskExecutorForkZmq.hh.

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

Handle pipe.

Handle pipe

Implements Salsa::TaskExecutor.

Definition at line 58 of file TaskExecutorForkZmq.cc.

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

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:

• zyre/TaskExecutorForkZmq.hh
• zyre/TaskExecutorForkZmq.cc