Slave.h

Go to the documentation of this file.

 
#ifndef __ROGUE_INTERFACES_STREAM_SLAVE_H__
#define __ROGUE_INTERFACES_STREAM_SLAVE_H__
#include "rogue/Directives.h"
 
#include <stdint.h>
 
#include <memory>
#include <string>
#include <thread>
 
#include "rogue/EnableSharedFromThis.h"
#include "rogue/Logging.h"
#include "rogue/interfaces/stream/Pool.h"
 
#ifndef NO_PYTHON
    #include <boost/python.hpp>
#endif
 
namespace rogue {
namespace interfaces {
namespace stream {
 
class Frame;
class Buffer;
class Master;
 
class Slave : public rogue::interfaces::stream::Pool,
              public rogue::EnableSharedFromThis<rogue::interfaces::stream::Slave> {
    // Mutex
    std::mutex mtx_;
 
    // Debug control
    uint32_t debug_;
    std::shared_ptr<rogue::Logging> log_;
 
    // Counters
    uint64_t frameCount_;
    uint64_t frameBytes_;
 
  public:
    static std::shared_ptr<rogue::interfaces::stream::Slave> create();
 
    static void setup_python();
 
    Slave();
 
    virtual ~Slave();
 
    virtual void stop();
 
    void setDebug(uint32_t debug, std::string name);
 
    virtual void acceptFrame(std::shared_ptr<rogue::interfaces::stream::Frame> frame);
 
    uint64_t getFrameCount();
 
    uint64_t getByteCount();
 
    bool ensureSingleBuffer(std::shared_ptr<rogue::interfaces::stream::Frame>& frame, bool reqEn);
 
    std::shared_ptr<rogue::interfaces::stream::Frame> reqLocalFrame(uint32_t size, bool zeroCopyEn);
 
#ifndef NO_PYTHON
 
    boost::python::object lshiftPy(boost::python::object p);
 
#endif
 
    std::shared_ptr<rogue::interfaces::stream::Master>& operator<<(
        std::shared_ptr<rogue::interfaces::stream::Master>& other);
};
 
typedef std::shared_ptr<rogue::interfaces::stream::Slave> SlavePtr;
 
#ifndef NO_PYTHON
 
class SlaveWrap : public rogue::interfaces::stream::Slave,
                  public boost::python::wrapper<rogue::interfaces::stream::Slave> {
  public:
    void acceptFrame(std::shared_ptr<rogue::interfaces::stream::Frame> frame);
 
    void defAcceptFrame(std::shared_ptr<rogue::interfaces::stream::Frame> frame);
};
 
typedef std::shared_ptr<rogue::interfaces::stream::SlaveWrap> SlaveWrapPtr;
#endif
 
}  // namespace stream
}  // namespace interfaces
}  // namespace rogue
#endif