Client.h

Go to the documentation of this file.

 
#ifndef __ROGUE_PROTOCOLS_RSSI_CLIENT_H__
#define __ROGUE_PROTOCOLS_RSSI_CLIENT_H__
#include "rogue/Directives.h"
 
#include <stdint.h>
 
#include <memory>
#include <thread>
 
namespace rogue {
namespace protocols {
namespace rssi {
 
class Transport;
class Application;
class Controller;
 
class Client {
    // Transport endpoint.
    std::shared_ptr<rogue::protocols::rssi::Transport> tran_;
 
    // Application endpoint.
    std::shared_ptr<rogue::protocols::rssi::Application> app_;
 
    // Protocol controller.
    std::shared_ptr<rogue::protocols::rssi::Controller> cntl_;
 
  public:
    static std::shared_ptr<rogue::protocols::rssi::Client> create(uint32_t segSize);
 
    static void setup_python();
 
    explicit Client(uint32_t segSize);
 
    ~Client();
 
    std::shared_ptr<rogue::protocols::rssi::Transport> transport();
 
    std::shared_ptr<rogue::protocols::rssi::Application> application();
 
    bool getOpen();
 
    uint32_t getDownCount();
 
    uint32_t getDropCount();
 
    uint32_t getRetranCount();
 
    bool getLocBusy();
 
    uint32_t getLocBusyCnt();
 
    bool getRemBusy();
 
    uint32_t getRemBusyCnt();
 
    void setLocTryPeriod(uint32_t val);
    uint32_t getLocTryPeriod();
 
    void setLocMaxBuffers(uint8_t val);
    uint8_t getLocMaxBuffers();
 
    void setLocMaxSegment(uint16_t val);
    uint16_t getLocMaxSegment();
 
    void setLocCumAckTout(uint16_t val);
    uint16_t getLocCumAckTout();
 
    void setLocRetranTout(uint16_t val);
    uint16_t getLocRetranTout();
 
    void setLocNullTout(uint16_t val);
    uint16_t getLocNullTout();
 
    void setLocMaxRetran(uint8_t val);
    uint8_t getLocMaxRetran();
 
    void setLocMaxCumAck(uint8_t val);
    uint8_t getLocMaxCumAck();
 
    uint8_t curMaxBuffers();
    uint16_t curMaxSegment();
    uint16_t curCumAckTout();
    uint16_t curRetranTout();
    uint16_t curNullTout();
    uint8_t curMaxRetran();
    uint8_t curMaxCumAck();
 
    void resetCounters();
 
    void setTimeout(uint32_t timeout);
 
    void stop();
 
    void start();
};
 
// Convenience
typedef std::shared_ptr<rogue::protocols::rssi::Client> ClientPtr;
 
}  // namespace rssi
}  // namespace protocols
};  // namespace rogue
 
#endif