SplitterV1.cpp

Go to the documentation of this file.

 
#include "rogue/Directives.h"
 
#include "rogue/protocols/batcher/SplitterV1.h"
 
#include <stdint.h>
 
#include <cmath>
#include <memory>
#include <thread>
 
#include "rogue/GilRelease.h"
#include "rogue/Logging.h"
#include "rogue/interfaces/stream/Frame.h"
#include "rogue/interfaces/stream/FrameIterator.h"
#include "rogue/interfaces/stream/FrameLock.h"
#include "rogue/interfaces/stream/Master.h"
#include "rogue/interfaces/stream/Slave.h"
#include "rogue/protocols/batcher/CoreV1.h"
#include "rogue/protocols/batcher/Data.h"
 
namespace rpb = rogue::protocols::batcher;
namespace ris = rogue::interfaces::stream;
 
#ifndef NO_PYTHON
    #include <boost/python.hpp>
namespace bp = boost::python;
#endif
 
rpb::SplitterV1Ptr rpb::SplitterV1::create() {
    rpb::SplitterV1Ptr p = std::make_shared<rpb::SplitterV1>();
    return (p);
}
 
void rpb::SplitterV1::setup_python() {
#ifndef NO_PYTHON
    bp::class_<rpb::SplitterV1, rpb::SplitterV1Ptr, bp::bases<ris::Master, ris::Slave>, boost::noncopyable>(
        "SplitterV1",
        bp::init<>());
#endif
}
 
rpb::SplitterV1::SplitterV1() : ris::Master(), ris::Slave() {}
 
rpb::SplitterV1::~SplitterV1() {}
 
void rpb::SplitterV1::acceptFrame(ris::FramePtr frame) {
    rpb::CoreV1 core;
    ris::FramePtr nFrame;
    rpb::DataPtr data;
    uint32_t x;
 
    // Lock frame
    rogue::GilRelease noGil;
    ris::FrameLockPtr lock = frame->lock();
 
    core.processFrame(frame);
 
    for (x = 0; x < core.count(); x++) {
        data = core.record(x);
 
        // Create a new frame
        nFrame = reqFrame(data->size(), true);
        nFrame->setPayload(data->size());
 
        ris::FrameIterator fIter = nFrame->begin();
        ris::FrameIterator dIter = data->begin();
        ris::copyFrame(dIter, data->size(), fIter);
 
        // Set flags
        nFrame->setFirstUser(data->fUser());
        nFrame->setLastUser(data->lUser());
        nFrame->setChannel(data->dest());
 
        sendFrame(nFrame);
    }
}