Filter.cpp

Go to the documentation of this file.

 
#include "rogue/Directives.h"
 
#include "rogue/interfaces/stream/Filter.h"
 
#include <inttypes.h>
#include <stdint.h>
 
#include <memory>
 
#include "rogue/Logging.h"
#include "rogue/interfaces/stream/Frame.h"
#include "rogue/interfaces/stream/Master.h"
#include "rogue/interfaces/stream/Slave.h"
 
namespace ris = rogue::interfaces::stream;
 
#ifndef NO_PYTHON
    #include <boost/python.hpp>
namespace bp = boost::python;
#endif
 
ris::FilterPtr ris::Filter::create(bool dropErrors, uint8_t channel) {
    ris::FilterPtr p = std::make_shared<ris::Filter>(dropErrors, channel);
    return (p);
}
 
void ris::Filter::setup_python() {
#ifndef NO_PYTHON
    bp::class_<ris::Filter, ris::FilterPtr, bp::bases<ris::Master, ris::Slave>, boost::noncopyable>(
        "Filter",
        bp::init<bool, uint8_t>());
#endif
}
 
ris::Filter::Filter(bool dropErrors, uint8_t channel) : ris::Master(), ris::Slave() {
    dropErrors_ = dropErrors;
    channel_    = channel;
 
    log_ = rogue::Logging::create("stream.Filter");
}
 
ris::Filter::~Filter() {}
 
void ris::Filter::acceptFrame(ris::FramePtr frame) {
    // Drop channel mismatches
    if (frame->getChannel() != channel_) return;
 
    // Drop errored frames
    if (dropErrors_ && (frame->getError() != 0)) {
        log_->debug("Dropping errored frame: Channel=%" PRIu8 ", Error=0x%" PRIx8, channel_, frame->getError());
        return;
    }
 
    sendFrame(frame);
}