TcpServer.cpp

Go to the documentation of this file.

 
#include "rogue/Directives.h"
 
#include "rogue/interfaces/stream/TcpServer.h"
 
#include <zmq.h>
 
#include <memory>
#include <string>
 
#include "rogue/GeneralError.h"
#include "rogue/GilRelease.h"
#include "rogue/Logging.h"
#include "rogue/interfaces/stream/Buffer.h"
#include "rogue/interfaces/stream/Frame.h"
#include "rogue/interfaces/stream/FrameIterator.h"
#include "rogue/interfaces/stream/FrameLock.h"
 
namespace ris = rogue::interfaces::stream;
 
#ifndef NO_PYTHON
    #include <boost/python.hpp>
namespace bp = boost::python;
#endif
 
ris::TcpServerPtr ris::TcpServer::create(std::string addr, uint16_t port) {
    ris::TcpServerPtr r = std::make_shared<ris::TcpServer>(addr, port);
    return (r);
}
 
ris::TcpServer::TcpServer(std::string addr, uint16_t port) : ris::TcpCore(addr, port, true) {}
 
ris::TcpServer::~TcpServer() {}
 
void ris::TcpServer::setup_python() {
#ifndef NO_PYTHON
 
    bp::class_<ris::TcpServer, ris::TcpServerPtr, bp::bases<ris::TcpCore>, boost::noncopyable>(
        "TcpServer",
        bp::init<std::string, uint16_t>())
        .def("_stop", &ris::TcpCore::stop);
 
    bp::implicitly_convertible<ris::TcpServerPtr, ris::TcpCorePtr>();
#endif
}