CoreV2.cpp

Go to the documentation of this file.

 
#include "rogue/Directives.h"
 
#include "rogue/protocols/packetizer/CoreV2.h"
 
#include <memory>
 
#include "rogue/GeneralError.h"
#include "rogue/GilRelease.h"
#include "rogue/protocols/packetizer/Application.h"
#include "rogue/protocols/packetizer/ControllerV2.h"
#include "rogue/protocols/packetizer/Transport.h"
 
namespace rpp = rogue::protocols::packetizer;
namespace ris = rogue::interfaces::stream;
 
#ifndef NO_PYTHON
    #include <boost/python.hpp>
namespace bp = boost::python;
#endif
 
rpp::CoreV2Ptr rpp::CoreV2::create(bool enIbCrc, bool enObCrc, bool enSsi) {
    rpp::CoreV2Ptr r = std::make_shared<rpp::CoreV2>(enIbCrc, enObCrc, enSsi);
    return (r);
}
 
void rpp::CoreV2::setup_python() {
#ifndef NO_PYTHON
 
    bp::class_<rpp::CoreV2, rpp::CoreV2Ptr, boost::noncopyable>("CoreV2", bp::init<bool, bool, bool>())
        .def("transport", &rpp::CoreV2::transport)
        .def("application", &rpp::CoreV2::application)
        .def("getDropCount", &rpp::CoreV2::getDropCount);
#endif
}
 
rpp::CoreV2::CoreV2(bool enIbCrc, bool enObCrc, bool enSsi) {
    tran_ = rpp::Transport::create();
    cntl_ = rpp::ControllerV2::create(enIbCrc, enObCrc, enSsi, tran_, app_);
 
    tran_->setController(cntl_);
}
 
rpp::CoreV2::~CoreV2() {
    uint32_t x;
 
    tran_.reset();
    cntl_.reset();
 
    for (x = 0; x < 256; x++) app_[x].reset();
}
 
rpp::TransportPtr rpp::CoreV2::transport() {
    return (tran_);
}
 
rpp::ApplicationPtr rpp::CoreV2::application(uint8_t dest) {
    if (!app_[dest]) {
        app_[dest] = rpp::Application::create(dest);
        app_[dest]->setController(cntl_);
    }
    return (app_[dest]);
}
 
uint32_t rpp::CoreV2::getDropCount() {
    return (cntl_->getDropCount());
}
 
void rpp::CoreV2::setTimeout(uint32_t timeout) {
    cntl_->setTimeout(timeout);
}