sim_interface.h

浏览该文件的文档.

//
// Created by 56585 on 2023/8/17.
//
 
#ifndef NSUKIT_SIM_INTERFACE_H
#define NSUKIT_SIM_INTERFACE_H
 
#include "base_itf.h"
 
 
namespace nsukit {
    class NSU_DLLEXPORT SimCmdUItf : public I_BaseCmdUItf {
    protected:
        int sim_target = 0;
        float simTimeout = 0;
 
    public:
        SimCmdUItf();
 
        ~SimCmdUItf() override;
 
        nsukitStatus_t accept(nsuInitParam_t *param) override;
 
        nsukitStatus_t close() override;
 
        nsukitStatus_t set_timeout(float s) override;
 
        nsukitStatus_t write(nsuRegAddr_t addr, nsuRegValue_t value) override;
 
        nsukitStatus_t read(nsuRegAddr_t addr, nsuRegValue_t *buf) override;
 
        nsukitStatus_t send_bytes(nsuBytes_t &bytes) override;
 
        nsukitStatus_t send_bytes(nsuCharBuf_p bytes, nsuSize_t length) override;
 
        nsukitStatus_t recv_bytes(nsuSize_t size, nsuCharBuf_p buf) override;
    };
 
 
    class NSU_DLLEXPORT SimStreamUItf : public I_BaseStreamUItf {
    protected:
        struct DMAMemory {
            nsuStreamLen_t length = 0;
            bool self_malloc = false;
            nsuVoidBuf_p buffer = nullptr;
        };
        int sim_target = 0;
        void (*sim_stream_func)(nsuCharBuf_p buf, nsuSize_t length);
 
        std::map<nsuMemory_p, DMAMemory *> fdMap;
    public:
        SimStreamUItf();
 
        ~SimStreamUItf() override = default;
 
        nsukitStatus_t accept(nsuInitParam_t *param) override;
 
        nsukitStatus_t close() override;
 
        nsukitStatus_t set_timeout(float s) override;
 
        nsuMemory_p alloc_buffer(nsuStreamLen_t length, nsuVoidBuf_p buf = nullptr) override;
 
        nsukitStatus_t free_buffer(nsuMemory_p fd) override;
 
        nsuVoidBuf_p get_buffer(nsuMemory_p fd, nsuStreamLen_t length) override;
 
        nsukitStatus_t
        open_send(nsuChnlNum_t chnl, nsuMemory_p fd, nsuStreamLen_t length, nsuStreamLen_t offset = 0) override;
 
        nsukitStatus_t
        open_recv(nsuChnlNum_t chnl, nsuMemory_p fd, nsuStreamLen_t length, nsuStreamLen_t offset = 0) override;
 
        nsukitStatus_t wait_stream(nsuMemory_p fd, float timeout = 1.) override;
 
        nsukitStatus_t break_stream(nsuMemory_p fd) override;
 
        nsukitStatus_t
        stream_recv(nsuChnlNum_t chnl, nsuMemory_p fd, nsuStreamLen_t length, nsuStreamLen_t offset = 0,
                    bool(*stop_event) () = nullptr, float timeout = 5., int flag = 1) override;
 
        nsukitStatus_t
        stream_send(nsuChnlNum_t chnl, nsuMemory_p fd, nsuStreamLen_t length, nsuStreamLen_t offset = 0,
                    bool(*stop_event) () = nullptr, float timeout = 5., int flag = 1) override;
    };
}
 
#endif //NSUKIT_SIM_INTERFACE_H