salsa  0.7.1
NodeManagerZyre.hh
1 #pragma once
2 
3 #include "NodeManager.hh"
4 #include "NodeZyre.hh"
5 #include "PollerZmq.hh"
6 
7 namespace Salsa {
16 
17 class NodeManagerZyre : public NodeManager {
18 public:
19  NodeManagerZyre(NodeZyre * pNodeZyre);
20  virtual ~NodeManagerZyre();
21 
22  virtual void resultTaskToExternal(Job * job, TaskInfo * task);
23 
24  virtual Socket * onEnter(std::string self, std::string fromType, Message * pMsg, std::vector<std::string> & out);
25  virtual Socket * onExit(std::string self, Message * pMsg, std::vector<std::string> & out);
26  virtual Socket * onWhisper(std::string self, Message * pMsg, std::vector<std::string> & out);
27 
28  virtual bool handleTaskPool(void * pPool);
29  virtual void addTaskSlot();
30  virtual void runTask(TaskState * pTaskState, std::string wk, std::string upstream);
31  virtual bool sendWhisper(Socket * pSocket, std::string to, std::vector<std::string> & vect);
32 
33 private:
34  NodeZyre * mpNodeZyre = nullptr;
35 };
36 } // namespace Salsa
Job class.
Definition: Job.hh:16
Base Message class.
Definition: Message.hh:15
NodeManagerZyre class.
virtual Socket * onEnter(std::string self, std::string fromType, Message *pMsg, std::vector< std::string > &out)
NodeZyre * mpNodeZyre
Current zyre node.
virtual void runTask(TaskState *pTaskState, std::string wk, std::string upstream)
Run task interface.
virtual void addTaskSlot()
virtual bool handleTaskPool(void *pPool)
virtual void resultTaskToExternal(Job *job, TaskInfo *task)
Handle return of task and send it to external client.
virtual Socket * onExit(std::string self, Message *pMsg, std::vector< std::string > &out)
virtual bool sendWhisper(Socket *pSocket, std::string to, std::vector< std::string > &vect)
NodeManagerZyre(NodeZyre *pNodeZyre)
virtual Socket * onWhisper(std::string self, Message *pMsg, std::vector< std::string > &out)
NodeManager class.
Definition: NodeManager.hh:22
Job * job(std::string uuid)
Definition: NodeManager.cc:482
salsa node class
Definition: NodeZyre.hh:20
Base Socket class.
Definition: Socket.hh:15
Base salsa TaskState class.
Definition: TaskState.hh:16