Controller.h

Go to the documentation of this file.

 
#ifndef __ROGUE_PROTOCOLS_PACKETIZER_CONTROLLER_H__
#define __ROGUE_PROTOCOLS_PACKETIZER_CONTROLLER_H__
#include "rogue/Directives.h"
 
#include <stdint.h>
 
#include <atomic>
#include <memory>
 
#include "rogue/Logging.h"
#include "rogue/Queue.h"
#include "rogue/interfaces/stream/Master.h"
#include "rogue/interfaces/stream/Slave.h"
 
namespace rogue {
namespace protocols {
namespace packetizer {
 
class Application;
class Transport;
class Header;
 
class Controller {
  protected:
    // parameters
    bool enSsi_;
    uint32_t appIndex_;
    uint32_t tranIndex_;
    bool transSof_[256];
    uint32_t tranCount_[256];
    uint32_t crc_[256];
    uint8_t tranDest_;
    std::atomic<uint32_t> dropCount_;
    uint32_t headSize_;
    uint32_t tailSize_;
    uint32_t alignSize_;
 
    struct timeval timeout_;
 
    std::shared_ptr<rogue::Logging> log_;
 
    std::shared_ptr<rogue::interfaces::stream::Frame> tranFrame_[256];
 
    std::mutex appMtx_;
    std::mutex tranMtx_;
 
    std::shared_ptr<rogue::protocols::packetizer::Transport> tran_;
    std::shared_ptr<rogue::protocols::packetizer::Application>* app_;
 
    rogue::Queue<std::shared_ptr<rogue::interfaces::stream::Frame>> tranQueue_;
 
  public:
    Controller(std::shared_ptr<rogue::protocols::packetizer::Transport> tran,
               std::shared_ptr<rogue::protocols::packetizer::Application>* app,
               uint32_t headSize,
               uint32_t tailSize,
               uint32_t alignSize,
               bool enSsi);
 
    ~Controller();
 
    std::shared_ptr<rogue::interfaces::stream::Frame> reqFrame(uint32_t size);
 
    virtual void transportRx(std::shared_ptr<rogue::interfaces::stream::Frame> frame);
 
    void stopQueue();
 
    void stop();
 
    std::shared_ptr<rogue::interfaces::stream::Frame> transportTx();
 
    virtual void applicationRx(std::shared_ptr<rogue::interfaces::stream::Frame> frame, uint8_t id);
 
    uint32_t getDropCount();
 
    void setTimeout(uint32_t timeout);
};
 
// Convenience
typedef std::shared_ptr<rogue::protocols::packetizer::Controller> ControllerPtr;
 
}  // namespace packetizer
}  // namespace protocols
};  // namespace rogue
 
#endif