Application.cpp

Go to the documentation of this file.

 
#include "rogue/Directives.h"
 
#include "rogue/protocols/rssi/Application.h"
 
#include <memory>
 
#include "rogue/GeneralError.h"
#include "rogue/GilRelease.h"
#include "rogue/Logging.h"
#include "rogue/interfaces/stream/Buffer.h"
#include "rogue/interfaces/stream/Frame.h"
#include "rogue/protocols/rssi/Controller.h"
 
namespace rpr = rogue::protocols::rssi;
namespace ris = rogue::interfaces::stream;
 
#ifndef NO_PYTHON
    #include <boost/python.hpp>
namespace bp = boost::python;
#endif
 
rpr::ApplicationPtr rpr::Application::create() {
    rpr::ApplicationPtr r = std::make_shared<rpr::Application>();
    return (r);
}
 
void rpr::Application::setup_python() {
#ifndef NO_PYTHON
 
    bp::class_<rpr::Application, rpr::ApplicationPtr, bp::bases<ris::Master, ris::Slave>, boost::noncopyable>(
        "Application",
        bp::init<>());
 
    bp::implicitly_convertible<rpr::ApplicationPtr, ris::MasterPtr>();
    bp::implicitly_convertible<rpr::ApplicationPtr, ris::SlavePtr>();
#endif
}
 
rpr::Application::Application() {}
 
rpr::Application::~Application() {
    threadEn_ = false;
    cntl_->stopQueue();
    thread_->join();
}
 
void rpr::Application::setController(rpr::ControllerPtr cntl) {
    cntl_ = cntl;
 
    // Start read thread
    threadEn_ = true;
    thread_   = new std::thread(&rpr::Application::runThread, this);
 
    // Set a thread name
#ifndef __MACH__
    pthread_setname_np(thread_->native_handle(), "RssiApp");
#endif
}
 
ris::FramePtr rpr::Application::acceptReq(uint32_t size, bool zeroCopyEn) {
    return (cntl_->reqFrame(size));
}
 
void rpr::Application::acceptFrame(ris::FramePtr frame) {
    cntl_->applicationRx(frame);
}
 
void rpr::Application::runThread() {
    ris::FramePtr frame;
    Logging log("rssi.Application");
    log.logThreadId();
 
    while (threadEn_) {
        if ((frame = cntl_->applicationTx()) != NULL) sendFrame(frame);
    }
}