salsa  0.3.0
 All Classes Functions Variables Enumerations Pages
TaskExecutorForkZmq.hh
1 #pragma once
2 
3 #include <ActorZmq.hh>
4 #include <TaskExecutor.hh>
5 
6 namespace Salsa {
15 
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
virtual bool handlePipe(std::vector< std::string > &extra)
Handle pipe.
zactor_t * mpZActor
ZMQ Actor pointer.
TaskExecutorForkZmq(zactor_t *pActor=nullptr)
TaskExecutorForkZmq class.
virtual void * pipe() const
virtual bool run(std::string worker, std::string upstream)
Run task.
Base TaskExecutor class.
Definition: TaskExecutor.hh:14