Subversion Repositories an-fpga-implementation-of-low-latency-noc-based-mpsoc

#ifndef _DPI_INTERFACE_HPP_

#define _DPI_INTERFACE_HPP_

#include <queue>

#include "svdpi.h"

#include "socketstream.h"

#include "messages.h"

#define NE 4*4*2

//***************************************************************************

// DPI-C interface

//***************************************************************************

extern "C" void c_epi_interface (

        svLogic startCom, svLogic getData, svLogic ejectReq,  svLogic queueReq,

        svLogic *endCom, svLogic *newReq,

        svBitVec32 source_all[NE], svBitVec32 destination_all[NE],

        svBitVec32 address_all[NE], svBitVec32 opcode_all[NE],

        svBitVec32 id_all[NE], svBitVec32 valid_all[NE],

        svBitVec32 rtrn_pkgid_all[NE]       ,

        svBitVec32 rtrn_valid_all[NE]       ,

        svBitVec32 NEready_all[NE], svBitVec32 size_all[NE]

        );

extern "C" void connection_init (

        svLogic startCom, svLogic *ready

        );

//***************************************************************************

// Connection manager class

//***************************************************************************

struct ReplyPacket {

        int source;

        int dest;

        int id;

        int network;

        int cl;

        int miss_pred;

};

struct RequestPacket {

        int source;

        int dest;

        int id;

        int size;

        int network;

        int cl;

        int miss_pred;

};

class connection_manager {

    private:

            //SocketStream *_channel;

            SocketStream _listenSocket;

        int _sources;

        int _dests;

        int _duplicate_networks;

    public:

        connection_manager();

        int Init();

        int Step();

        int readMsg();

        int sendResMsg();

        int sendAckMsg();

        int sendAckReqMsg();

        int checkInjection();

        int getSynfullEndPoint(int node);

        int getPronocEndPoint(int node);

        int getMsgType(int opcode);

        int getChiOpc(int opcode, int type);

        ReplyPacket *DequeueReplyPacket();

        int printResMsg(EjectResMsg res);

        int printReqMsg(InjectReqMsg *req);

};

SocketStream *_channel;

connection_manager *_connection_manager ;

//socket communication

StreamMessage *_msg ;

InjectReqMsg  *_req ;

InjectReqMsg  *_req_tmp ;

EjectResMsg  _res    ;

StepResMsg   _ackRes ;

InjectResMsg _ackReq ;

queue<EjectResMsg> _eject_buffer;

queue<InjectReqMsg*> _inject_buffer;

//tmp

RequestPacket *rp;

svLogic _newInjection;

#endif