ZmqServer.h

Go to the documentation of this file.

 
#ifndef __ROGUE_ZMQ_SERVER_H__
#define __ROGUE_ZMQ_SERVER_H__
#include "rogue/Directives.h"
 
#include <atomic>
#include <memory>
#include <string>
#include <thread>
 
#include "rogue/Logging.h"
 
#ifndef NO_PYTHON
    #include <boost/python.hpp>
#endif
 
namespace rogue {
namespace interfaces {
 
class ZmqServer {
    void* zmqCtx_ = nullptr;
    void* zmqPub_ = nullptr;
    void* zmqRep_ = nullptr;
    void* zmqStr_ = nullptr;
 
  protected:
    std::thread* rThread_ = nullptr;
    std::thread* sThread_ = nullptr;
    std::atomic<bool> threadEn_{false};
 
  private:
    // Bind address and base port configuration.
    std::string addr_;
    uint16_t basePort_;
 
    // Logger instance.
    std::shared_ptr<rogue::Logging> log_;
 
    void runThread();
    void strThread();
 
    bool tryConnect();
 
  public:
    static std::shared_ptr<rogue::interfaces::ZmqServer> create(const std::string& addr, uint16_t port);
 
    static void setup_python();
 
    ZmqServer(const std::string& addr, uint16_t port);
 
    virtual ~ZmqServer();
 
#ifndef NO_PYTHON
    void publish(boost::python::object data);
 
    virtual boost::python::object doRequest(boost::python::object data);
#endif
 
    virtual std::string doString(const std::string& data);
 
    uint16_t port();
 
    void stop();
 
    void start();
};
typedef std::shared_ptr<rogue::interfaces::ZmqServer> ZmqServerPtr;
 
#ifndef NO_PYTHON
 
class ZmqServerWrap : public rogue::interfaces::ZmqServer, public boost::python::wrapper<rogue::interfaces::ZmqServer> {
  public:
    ZmqServerWrap(std::string addr, uint16_t port);
 
    boost::python::object doRequest(boost::python::object data);
 
    boost::python::object defDoRequest(boost::python::object data);
 
    std::string doString(const std::string& data);
 
    std::string defDoString(const std::string& data);
};
 
typedef std::shared_ptr<rogue::interfaces::ZmqServerWrap> ZmqServerWrapPtr;
#endif
}  // namespace interfaces
}  // namespace rogue
 
#endif