Master.h

Go to the documentation of this file.

 
#ifndef __ROGUE_INTERFACES_STREAM_MASTER_H__
#define __ROGUE_INTERFACES_STREAM_MASTER_H__
#include "rogue/Directives.h"
 
#include <stdint.h>
 
#include <cstdio>
#include <memory>
#include <mutex>
#include <string>
#include <thread>
#include <vector>
 
#include "rogue/EnableSharedFromThis.h"
 
#ifndef NO_PYTHON
    #include <boost/python.hpp>
#endif
 
namespace rogue {
namespace interfaces {
namespace stream {
 
class Slave;
class Frame;
 
class Master : public rogue::EnableSharedFromThis<rogue::interfaces::stream::Master> {
    // Vector of slaves
    std::vector<std::shared_ptr<rogue::interfaces::stream::Slave> > slaves_;
 
    // Slave mutex
    std::mutex slaveMtx_;
 
    // Default slave if not connected
    std::shared_ptr<rogue::interfaces::stream::Slave> defSlave_;
 
  public:
    static std::shared_ptr<rogue::interfaces::stream::Master> create();
 
    static void setup_python();
 
    Master();
 
    virtual ~Master();
 
    uint32_t slaveCount();
 
    void addSlave(std::shared_ptr<rogue::interfaces::stream::Slave> slave);
 
    std::shared_ptr<rogue::interfaces::stream::Frame> reqFrame(uint32_t size, bool zeroCopyEn);
 
    void sendFrame(std::shared_ptr<rogue::interfaces::stream::Frame> frame);
 
    bool ensureSingleBuffer(std::shared_ptr<rogue::interfaces::stream::Frame>& frame, bool reqEn);
 
    virtual void stop();
 
#ifndef NO_PYTHON
 
    void equalsPy(boost::python::object p);
 
    boost::python::object rshiftPy(boost::python::object p);
 
#endif
 
    void operator==(std::shared_ptr<rogue::interfaces::stream::Slave>& other);
 
    std::shared_ptr<rogue::interfaces::stream::Slave>& operator>>(
        std::shared_ptr<rogue::interfaces::stream::Slave>& other);
};
 
typedef std::shared_ptr<rogue::interfaces::stream::Master> MasterPtr;
}  // namespace stream
}  // namespace interfaces
}  // namespace rogue
#endif