TcpClient.cpp

Go to the documentation of this file.

 
#include "rogue/Directives.h"
 
#include "rogue/interfaces/stream/TcpClient.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::TcpClientPtr ris::TcpClient::create(std::string addr, uint16_t port) {
    ris::TcpClientPtr r = std::make_shared<ris::TcpClient>(addr, port);
    return (r);
}
 
ris::TcpClient::TcpClient(std::string addr, uint16_t port) : ris::TcpCore(addr, port, false) {}
 
ris::TcpClient::~TcpClient() {}
 
void ris::TcpClient::setup_python() {
#ifndef NO_PYTHON
 
    bp::class_<ris::TcpClient, ris::TcpClientPtr, bp::bases<ris::TcpCore>, boost::noncopyable>(
        "TcpClient",
        bp::init<std::string, uint16_t>())
        .def("_stop", &ris::TcpCore::stop);
 
    bp::implicitly_convertible<ris::TcpClientPtr, ris::TcpCorePtr>();
#endif
}