RemoteGrabber.cpp

Go to the documentation of this file.

#include <RemoteGrabber.h>
#include <iostream>

_RemoteGrabberImpl::_RemoteGrabberImpl(const std::string & _deviceName, const std::string & _deviceSource, zmq::context_t & _ctx) :
    deviceName(_deviceName),
    deviceSource(_deviceSource),
    ctx(_ctx)
{
}

_RemoteGrabberImpl::~_RemoteGrabberImpl() {

}

int _RemoteGrabberImpl::getWidth() {
    return width;
}

int _RemoteGrabberImpl::getHeight() {
    return height;
}

int _RemoteGrabberImpl::getBytesPerPixel() {
    return bytesPerPixel;
}

void _RemoteGrabberImpl::startServing() {
    enableAcquisition = true;
    acquisitionThread = std::thread(&_RemoteGrabberImpl::acquisition, this);
}

void _RemoteGrabberImpl::stopServing() {
    enableAcquisition = false;
    if (acquisitionThread.joinable()) {
        std::cout << "wait for remote grabber thread to join" << std::endl;
        acquisitionThread.join();
    }
}

void _RemoteGrabberImpl::addEndpoint(const std::string & _endpoint) {
    endpoints.push_back(_endpoint);
}

void _RemoteGrabberImpl::acquisition() {

    zmq::socket_t subSocket(ctx, ZMQ_SUB);
    zmq::socket_t pubSocket(ctx, ZMQ_PUB);
    subSocket.connect(deviceSource);
    subSocket.setsockopt(ZMQ_SUBSCRIBE, "", 0);
    for (const auto & ep : endpoints) {
        pubSocket.bind(ep.c_str());
    }
    while (enableAcquisition) {
        int64_t more = 1;
        while (more) {
            zmq::message_t msg;
            subSocket.recv(&msg);
            size_t more_size = sizeof(more);
            subSocket.getsockopt(ZMQ_RCVMORE, &more, &more_size);
            pubSocket.send(msg, more?ZMQ_SNDMORE:0);
        }
    }
}