ZmqServer.h

Go to the documentation of this file.

 
#ifndef __ROGUE_ZMQ_SERVER_H__
#define __ROGUE_ZMQ_SERVER_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 ZmqServer {
    // ZeroMQ context.
    void* zmqCtx_;
 
    // ZeroMQ publish socket.
    void* zmqPub_;
 
    // ZeroMQ binary response socket.
    void* zmqRep_;
 
    // ZeroMQ string response socket.
    void* zmqStr_;
 
    // Request worker threads.
    std::thread* rThread_;
    std::thread* sThread_;
    bool threadEn_;
 
    // 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