GrabberStatsPublisher.cpp

Go to the documentation of this file.

#include <GrabberStatsPublisher.h>
#include <stringtricks.h>

GrabberStatsPublisher::GrabberStatsPublisher(zmq::context_t & _ctx,
                                             const std::string & _cameraName) :
        publishHeader(SSTR("ROCS\x01grabber.", _cameraName)),
        destinationSocket(_ctx, ZMQ_PUB) {
    destinationSocket.connect("inproc://log");
}

void GrabberStatsPublisher::publishJsonValue(Json::Value & _value) {
    zmq::message_t msgHdr(publishHeader.length());
    memcpy((char*)msgHdr.data(), publishHeader.c_str(), publishHeader.length());
    destinationSocket.send(msgHdr, ZMQ_SNDMORE);

    Json::FastWriter writer;
    std::string data = writer.write(_value);
    zmq::message_t msgData(data.length());
    memcpy((char *)msgData.data(), data.c_str(), data.length());
    destinationSocket.send(msgData);
}

void GrabberStatsPublisher::publishBufferLoad(const int usedBuffers, const int totalBuffers) {
    Json::Value value;
    value["usedBuffers"] = usedBuffers;
    value["totalBuffers"] = totalBuffers;
    publishJsonValue(value);
}