InverterV2.cpp

Go to the documentation of this file.

 
#include "rogue/Directives.h"
 
#include "rogue/protocols/batcher/InverterV2.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/CoreV2.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::InverterV2Ptr rpb::InverterV2::create() {
    rpb::InverterV2Ptr p = std::make_shared<rpb::InverterV2>();
    return (p);
}
 
void rpb::InverterV2::setup_python() {
#ifndef NO_PYTHON
    bp::class_<rpb::InverterV2, rpb::InverterV2Ptr, bp::bases<ris::Master, ris::Slave>, boost::noncopyable>(
        "InverterV2",
        bp::init<>());
#endif
}
 
rpb::InverterV2::InverterV2() : ris::Master(), ris::Slave() {}
 
rpb::InverterV2::~InverterV2() {}
 
void rpb::InverterV2::acceptFrame(ris::FramePtr frame) {
    rpb::CoreV2 core;
    rpb::DataPtr data;
    uint32_t x;
 
    // Lock frame
    rogue::GilRelease noGil;
    ris::FrameLockPtr lock = frame->lock();
 
    core.processFrame(frame);
 
    // Must have at least one record
    if (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);
}