InverterV1.cpp

Go to the documentation of this file.

 
#include "rogue/Directives.h"
 
#include "rogue/protocols/batcher/InverterV1.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::InverterV1Ptr rpb::InverterV1::create() {
    rpb::InverterV1Ptr p = std::make_shared<rpb::InverterV1>();
    return (p);
}
 
void rpb::InverterV1::setup_python() {
#ifndef NO_PYTHON
    bp::class_<rpb::InverterV1, rpb::InverterV1Ptr, bp::bases<ris::Master, ris::Slave>, boost::noncopyable>(
        "InverterV1",
        bp::init<>());
#endif
}
 
rpb::InverterV1::InverterV1() : ris::Master(), ris::Slave() {}
 
rpb::InverterV1::~InverterV1() {}
 
void rpb::InverterV1::acceptFrame(ris::FramePtr frame) {
    rpb::CoreV1 core;
    rpb::DataPtr data;
    uint32_t x;
 
    // Lock frame
    rogue::GilRelease noGil;
    ris::FrameLockPtr lock = frame->lock();
 
    core.processFrame(frame);
 
    // Header and tail size must match, must have at least one record
    if ((core.headerSize() != core.tailSize()) || (core.count() == 0)) return;
 
    // Copy first tail to head
    std::memcpy(core.beginHeader().ptr(), core.beginTail(0).ptr(), core.headerSize());
 
    // Copy remaining tails
    for (x = 1; x < core.count(); x++)
        std::memcpy(core.beginTail(x - 1).ptr(), core.beginTail(x).ptr(), core.headerSize());
 
    // Remove last tail from frame
    frame->adjustPayload(-1 * core.headerSize());
 
    // Send the frame
    lock->unlock();
    sendFrame(frame);
}