TcpClient.h

Go to the documentation of this file.

 
#ifndef __ROGUE_INTERFACES_MEMORY_TCP_CLIENT_H__
#define __ROGUE_INTERFACES_MEMORY_TCP_CLIENT_H__
#include "rogue/Directives.h"
 
#include <stdint.h>
 
#include <memory>
#include <string>
#include <thread>
#include <condition_variable>
 
#include "rogue/Logging.h"
#include "rogue/interfaces/memory/Slave.h"
 
namespace rogue {
namespace interfaces {
namespace memory {
 
class TcpClient : public rogue::interfaces::memory::Slave {
    // Inbound Address
    std::string reqAddr_;
 
    // Outbound Address
    std::string respAddr_;
 
    // Zeromq Context
    void* zmqCtx_;
 
    // Zeromq inbound port
    void* zmqReq_;
 
    // Zeromq outbound port
    void* zmqResp_;
 
    // Thread background
    void runThread();
 
    // Log
    std::shared_ptr<rogue::Logging> bridgeLog_;
 
    // Thread
    std::thread* thread_;
    bool threadEn_;
 
    // Lock
    std::mutex bridgeMtx_;
 
    // Probe state
    std::mutex probeMtx_;
    std::condition_variable probeCond_;
    uint32_t probeSeq_;
    uint32_t probeId_;
    bool probeDone_;
    std::string probeResult_;
    bool waitReadyOnStart_;
 
  public:
    static std::shared_ptr<rogue::interfaces::memory::TcpClient> create(std::string addr, uint16_t port, bool waitReady = false);
 
    static void setup_python();
 
    TcpClient(std::string addr, uint16_t port, bool waitReady = false);
 
    ~TcpClient();
 
    void close();
 
    void stop();
 
    bool waitReady(double timeout, double period);
 
    void start();
 
    void doTransaction(std::shared_ptr<rogue::interfaces::memory::Transaction> tran);
};
 
typedef std::shared_ptr<rogue::interfaces::memory::TcpClient> TcpClientPtr;
 
}  // namespace memory
}  // namespace interfaces
};  // namespace rogue
 
#endif