Xvc.h

Go to the documentation of this file.

 
#ifndef __ROGUE_PROTOCOLS_XILINX_XVC_H__
#define __ROGUE_PROTOCOLS_XILINX_XVC_H__
#include "rogue/Directives.h"
 
#include <netdb.h>
#include <netinet/in.h>
#include <netinet/ip.h>
#include <stdint.h>
#include <sys/socket.h>
 
#include <memory>
#include <thread>
 
#include "rogue/GeneralError.h"
#include "rogue/Logging.h"
#include "rogue/Queue.h"
#include "rogue/interfaces/stream/Master.h"
#include "rogue/interfaces/stream/Slave.h"
#include "rogue/protocols/xilinx/JtagDriver.h"
#include "rogue/protocols/xilinx/XvcConnection.h"
#include "rogue/protocols/xilinx/XvcServer.h"
 
namespace rogue {
namespace protocols {
namespace xilinx {
const unsigned int kMaxArgs = 3;
 
class Xvc : public rogue::interfaces::stream::Master,
            public rogue::interfaces::stream::Slave,
            public rogue::protocols::xilinx::JtagDriver {
  protected:
    unsigned mtu_;
 
    // Use rogue frames to exchange data with other rogue objects
    rogue::Queue<std::shared_ptr<rogue::interfaces::stream::Frame>> queue_;
 
    // Log
    std::shared_ptr<rogue::Logging> log_;
 
    // Background server thread.
    std::thread* thread_;
    bool threadEn_;
 
    // Lock
    std::mutex mtx_;
 
    // TCP server thread entry point for Vivado clients.
    void runThread();
 
  public:
    static std::shared_ptr<rogue::protocols::xilinx::Xvc> create(uint16_t port);
 
    static void setup_python();
 
    explicit Xvc(uint16_t port);
 
    ~Xvc();
 
    void start();
 
    void stop();
 
    void acceptFrame(std::shared_ptr<rogue::interfaces::stream::Frame> frame);
 
    uint64_t getMaxVectorSize() final;
 
    int xfer(uint8_t* txBuffer,
             unsigned txBytes,
             uint8_t* hdBuffer,
             unsigned hdBytes,
             uint8_t* rxBuffer,
             unsigned rxBytes) final;
};
 
// Convenience
typedef std::shared_ptr<rogue::protocols::xilinx::Xvc> XvcPtr;
}  // namespace xilinx
}  // namespace protocols
}  // namespace rogue
 
#endif