Application.h

Go to the documentation of this file.

 
#ifndef __ROGUE_PROTOCOLS_PACKETIZER_APPLICATION_H__
#define __ROGUE_PROTOCOLS_PACKETIZER_APPLICATION_H__
#include "rogue/Directives.h"
 
#include <stdint.h>
 
#include <atomic>
#include <memory>
 
#include "rogue/Queue.h"
#include "rogue/interfaces/stream/Master.h"
#include "rogue/interfaces/stream/Slave.h"
 
namespace rogue {
namespace protocols {
namespace packetizer {
 
class Controller;
 
class Application : public rogue::interfaces::stream::Master, public rogue::interfaces::stream::Slave {
    // Core module
    std::shared_ptr<rogue::protocols::packetizer::Controller> cntl_;
 
    // ID
    uint8_t id_;
 
  protected:
    std::thread* thread_ = nullptr;
    std::atomic<bool> threadEn_{false};
 
  private:
    // Thread background
    void runThread();
 
    // Application queue
    rogue::Queue<std::shared_ptr<rogue::interfaces::stream::Frame>> queue_;
 
  public:
    static std::shared_ptr<rogue::protocols::packetizer::Application> create(uint8_t id);
 
    static void setup_python();
 
    explicit Application(uint8_t id);
 
    ~Application();
 
    void setController(std::shared_ptr<rogue::protocols::packetizer::Controller> cntl);
 
    void pushFrame(std::shared_ptr<rogue::interfaces::stream::Frame> frame);
 
    std::shared_ptr<rogue::interfaces::stream::Frame> acceptReq(uint32_t size, bool zeroCopyEn);
 
    void acceptFrame(std::shared_ptr<rogue::interfaces::stream::Frame> frame);
};
 
// Convenience
typedef std::shared_ptr<rogue::protocols::packetizer::Application> ApplicationPtr;
 
}  // namespace packetizer
}  // namespace protocols
};  // namespace rogue
 
#endif