ZmqClient.h

Go to the documentation of this file.

 
#ifndef __ROGUE_ZMQ_CLIENT_H__
#define __ROGUE_ZMQ_CLIENT_H__
#include "rogue/Directives.h"
 
#include <memory>
#include <string>
#include <thread>
 
#include "rogue/Logging.h"
 
#ifndef NO_PYTHON
    #include <boost/python.hpp>
#endif
 
namespace rogue {
namespace interfaces {
 
class ZmqClient {
    // ZeroMQ context.
    void* zmqCtx_;
 
    // ZeroMQ subscriber socket for async updates.
    void* zmqSub_;
 
    // ZeroMQ request socket for RPC.
    void* zmqReq_;
 
    // Logger instance.
    std::shared_ptr<rogue::Logging> log_;
 
    // Request timeout in milliseconds.
    uint32_t timeout_;
 
    // Continue retrying after timeout when true.
    bool waitRetry_;
 
    // Background update thread (binary mode).
    std::thread* thread_;
    bool threadEn_;
    bool running_;
 
    // True when operating in string request mode.
    bool doString_;
 
    void runThread();
 
  public:
    static std::shared_ptr<rogue::interfaces::ZmqClient> create(const std::string& addr, uint16_t port, bool doString);
 
    static void setup_python();
 
    ZmqClient(const std::string& addr, uint16_t port, bool doString);
 
    virtual ~ZmqClient();
 
    void setTimeout(uint32_t msecs, bool waitRetry);
 
    std::string sendString(const std::string& path, const std::string& attr, const std::string& arg);
 
    std::string getDisp(const std::string& path);
 
    void setDisp(const std::string& path, const std::string& value);
 
    std::string exec(const std::string& path, const std::string& arg = "");
 
    std::string valueDisp(const std::string& path);
 
#ifndef NO_PYTHON
    boost::python::object send(boost::python::object data);
 
    virtual void doUpdate(boost::python::object data);
#endif
 
    void stop();
};
typedef std::shared_ptr<rogue::interfaces::ZmqClient> ZmqClientPtr;
 
#ifndef NO_PYTHON
 
class ZmqClientWrap : public rogue::interfaces::ZmqClient, public boost::python::wrapper<rogue::interfaces::ZmqClient> {
  public:
    ZmqClientWrap(const std::string& addr, uint16_t port, bool doString);
 
    void doUpdate(boost::python::object data);
 
    void defDoUpdate(boost::python::object data);
};
 
typedef std::shared_ptr<rogue::interfaces::ZmqClientWrap> ZmqClientWrapPtr;
#endif
}  // namespace interfaces
}  // namespace rogue
 
#endif