rx_engine.hpp

Go to the documentation of this file.

 
 
 
#ifndef _TOE_RXE_H_
#define _TOE_RXE_H_
 
#include "../../../../../NTS/nts.hpp"
#include "../../../../../NTS/nts_utils.hpp"
#include "../../../../../NTS/SimNtsUtils.hpp"
#include "../../../../../NTS/toe/src/toe.hpp"
#include "../../../../../NTS/AxisIp4.hpp"
#include "../../../../../NTS/AxisTcp.hpp"
#include "../../../../../NTS/AxisPsd4.hpp"
 
using namespace hls;
 
 
class RXeMeta {
  public:
    TcpSeqNum   seqNumb;    // TCP Sequence Number
    TcpAckNum   ackNumb;    // TCP Acknowledgment Number
    TcpWindow   winSize;    // TCP Window Size
    TcpSegLen   length;     // TCP Segment Length
    TcpCtrlBit  ack;
    TcpCtrlBit  rst;
    TcpCtrlBit  syn;
    TcpCtrlBit  fin;
    RXeMeta() {}
};
 
 
class RXeFsmMeta {
  public:
    SessionId           sessionId;
    Ip4SrcAddr          ip4SrcAddr;
    TcpSrcPort          tcpSrcPort;
    TcpDstPort          tcpDstPort;
    RXeMeta             meta;
    RXeFsmMeta() {}
    RXeFsmMeta(SessionId sessId,  Ip4SrcAddr ipSA,  TcpSrcPort tcpSP,  TcpDstPort tcpDP,  RXeMeta rxeMeta) :
               sessionId(sessId), ip4SrcAddr(ipSA), tcpSrcPort(tcpSP), tcpDstPort(tcpDP),    meta(rxeMeta) {}
};
 
 
const int cDepth_FsmToEve_Event    =  4;
const int cDepth_FsmToMwr_WrCmd    = 16;
const int cDepth_FsmToRan_Notif    = 16;  // This depends on the memory delay
const int cDepth_FsmToTsd_DropCmd  = 16;
 
const int cDepth_MdhToEvm_Event    =  4;
const int cDepth_MdhToTsd_DropCmd  = 16;
 
const int cDepth_MwrToRan_SplitSeg = 16;
 
 
void rx_engine(
        //-- IP Rx Interface
        stream<AxisIp4>                 &siIPRX_Data,
        //-- Session Lookup Controller Interface
        stream<SessionLookupQuery>      &soSLc_SessLkReq,
        stream<SessionLookupReply>      &siSLc_SessLkRep,
        //-- State Table Interface
        stream<StateQuery>              &soSTt_StateQry,
        stream<TcpState>                &siSTt_StateRep,
        //-- Port Table Interface
        stream<TcpPort>                 &soPRt_PortStateReq,
        stream<RepBit>                  &siPRt_PortStateRep,
        //-- Rx SAR Table Interface
        stream<RXeRxSarQuery>           &soRSt_RxSarQry,
        stream<RxSarReply>              &siRSt_RxSarRep,
        //-- Tx SAR Table Interface
        stream<RXeTxSarQuery>           &soTSt_TxSarQry,
        stream<RXeTxSarReply>           &siTSt_TxSarRep,
            //-- Timers Interface
        stream<RXeReTransTimerCmd>      &soTIm_ReTxTimerCmd,
        stream<SessionId>               &soTIm_ClearProbeTimer,
        stream<SessionId>               &soTIm_CloseTimer,
        //-- Event Engine Interface
        stream<ExtendedEvent>           &soEVe_SetEvent,
        //-- Tx Application Interface
        stream<SessState>               &soTAi_SessOpnSts,
        //-- Rx Application Interface
        stream<TcpAppNotif>             &soRAi_RxNotif,
        //-- MEM / Rx Write Path Interface
        stream<DmCmd>                   &soMEM_WrCmd,
        stream<AxisApp>                 &soMEM_WrData,
        stream<DmSts>                   &siMEM_WrSts,
        //--MMIO Interfaces
        stream<StsBit>                  &soMMIO_RxMemWrErr,
        stream<ap_uint<8> >             &soMMIO_CrcDropCnt,
        stream<ap_uint<8> >             &soMMIO_SessDropCnt,
        stream<ap_uint<8> >             &soMMIO_OooDropCnt,
        //-- DEBUG Interfaces
        stream<RxBufPtr>                &soDBG_RxFreeSpace,
        stream<ap_uint<32> >            &soDBG_TcpIpRxByteCnt,
        stream<ap_uint<8> >             &soDBG_oooDebug
);
 
#endif