Fifo.h

Go to the documentation of this file.

 
#ifndef __ROGUE_INTERFACES_STREAM_FIFO_H__
#define __ROGUE_INTERFACES_STREAM_FIFO_H__
#include "rogue/Directives.h"
 
#include <stdint.h>
 
#include <atomic>
#include <memory>
#include <thread>
 
#include "rogue/Logging.h"
#include "rogue/interfaces/stream/Master.h"
#include "rogue/interfaces/stream/Slave.h"
 
namespace rogue {
namespace interfaces {
namespace stream {
 
class Fifo : public rogue::interfaces::stream::Master, public rogue::interfaces::stream::Slave {
    std::shared_ptr<rogue::Logging> log_;
 
    // Configurations
    uint32_t maxDepth_;
    uint32_t trimSize_;
    bool noCopy_;
 
    // Drop frame counter
    std::atomic<std::size_t> dropFrameCnt_{0};
 
    // Queue
    rogue::Queue<std::shared_ptr<rogue::interfaces::stream::Frame>> queue_;
 
  protected:
    std::atomic<bool> threadEn_{false};
    std::thread* thread_ = nullptr;
 
  private:
    // Thread background
    void runThread();
 
  public:
    static std::shared_ptr<rogue::interfaces::stream::Fifo> create(uint32_t maxDepth, uint32_t trimSize, bool noCopy);
 
    static void setup_python();
 
    Fifo(uint32_t maxDepth, uint32_t trimSize, bool noCopy);
 
    ~Fifo();
 
    std::size_t size();
 
    std::size_t dropCnt() const;
 
    void clearCnt();
 
    void acceptFrame(std::shared_ptr<rogue::interfaces::stream::Frame> frame);
};
 
typedef std::shared_ptr<rogue::interfaces::stream::Fifo> FifoPtr;
}  // namespace stream
}  // namespace interfaces
}  // namespace rogue
#endif