Core.cpp

Go to the documentation of this file.

 
#include "rogue/Directives.h"
 
#include "rogue/protocols/packetizer/Core.h"
 
#include <memory>
 
#include "rogue/GeneralError.h"
#include "rogue/GilRelease.h"
#include "rogue/protocols/packetizer/Application.h"
#include "rogue/protocols/packetizer/ControllerV1.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::CorePtr rpp::Core::create(bool enSsi) {
    rpp::CorePtr r = std::make_shared<rpp::Core>(enSsi);
    return (r);
}
 
void rpp::Core::setup_python() {
#ifndef NO_PYTHON
 
    bp::class_<rpp::Core, rpp::CorePtr, boost::noncopyable>("Core", bp::init<bool>())
        .def("transport", &rpp::Core::transport)
        .def("application", &rpp::Core::application)
        .def("getDropCount", &rpp::Core::getDropCount);
#endif
}
 
rpp::Core::Core(bool enSsi) {
    tran_ = rpp::Transport::create();
    cntl_ = rpp::ControllerV1::create(enSsi, tran_, app_);
 
    tran_->setController(cntl_);
}
 
rpp::Core::~Core() {
    uint32_t x;
 
    tran_.reset();
    cntl_.reset();
 
    for (x = 0; x < 256; x++) app_[x].reset();
}
 
rpp::TransportPtr rpp::Core::transport() {
    return (tran_);
}
 
rpp::ApplicationPtr rpp::Core::application(uint8_t dest) {
    if (!app_[dest]) {
        app_[dest] = rpp::Application::create(dest);
        app_[dest]->setController(cntl_);
    }
    return (app_[dest]);
}
 
uint32_t rpp::Core::getDropCount() {
    return (cntl_->getDropCount());
}
 
void rpp::Core::setTimeout(uint32_t timeout) {
    cntl_->setTimeout(timeout);
}