salsa
0.7.1
Loading...
Searching...
No Matches
TaskExecutorForkZmq.hh
1
#pragma once
2
3
#include "ActorZmq.hh"
4
#include "TaskExecutor.hh"
5
6
namespace
Salsa {
15
16
class
TaskExecutorForkZmq
:
public
TaskExecutor
{
17
public
:
18
TaskExecutorForkZmq
(zactor_t * pActor =
nullptr
);
19
virtual
~TaskExecutorForkZmq
();
20
21
virtual
bool
run
(std::string worker, std::string upstream);
22
virtual
void
*
pipe
()
const
;
23
virtual
bool
handlePipe
(std::vector<std::string> & extra);
24
25
protected
:
26
zactor_t *
mpZActor
=
nullptr
;
27
};
28
}
// namespace Salsa
Salsa::TaskExecutorForkZmq::handlePipe
virtual bool handlePipe(std::vector< std::string > &extra)
Handle pipe.
Definition
TaskExecutorForkZmq.cc:58
Salsa::TaskExecutorForkZmq::pipe
virtual void * pipe() const
Definition
TaskExecutorForkZmq.cc:50
Salsa::TaskExecutorForkZmq::run
virtual bool run(std::string worker, std::string upstream)
Run task.
Definition
TaskExecutorForkZmq.cc:19
Salsa::TaskExecutorForkZmq::~TaskExecutorForkZmq
virtual ~TaskExecutorForkZmq()
Definition
TaskExecutorForkZmq.cc:10
Salsa::TaskExecutorForkZmq::TaskExecutorForkZmq
TaskExecutorForkZmq(zactor_t *pActor=nullptr)
Definition
TaskExecutorForkZmq.cc:4
Salsa::TaskExecutorForkZmq::mpZActor
zactor_t * mpZActor
ZMQ Actor pointer.
Definition
TaskExecutorForkZmq.hh:26
Salsa::TaskExecutor::TaskExecutor
TaskExecutor()
Definition
TaskExecutor.cc:3
zyre
TaskExecutorForkZmq.hh
Generated by
1.13.2