rx_sar_table.cpp

Go to the documentation of this file.

 
 
 
#include "rx_sar_table.hpp"
 
using namespace hls;
 
 
#ifndef __SYNTHESIS__
  extern bool gTraceEvent;
#endif
 
#define THIS_NAME "TOE/RSt"
 
#define TRACE_OFF  0x0000
#define TRACE_RST 1 <<  1
#define TRACE_ALL  0xFFFF
 
#define DEBUG_LEVEL (TRACE_OFF)
 
 
void rx_sar_table(
        stream<RXeRxSarQuery>      &siRXe_RxSarQry,
        stream<RxSarReply>         &soRXe_RxSarRep,
        stream<RAiRxSarQuery>      &siRAi_RxSarQry,
        stream<RAiRxSarReply>      &soRAi_RxSarRep,
        stream<SessionId>          &siTXe_RxSarReq,
        stream<RxSarReply>         &soTxe_RxSarRep)
{
    //-- DIRECTIVES FOR THIS PROCESS -------------------------------------------
    #pragma HLS PIPELINE II=1 enable_flush
 
    const char *myName = THIS_NAME;
 
    //-- STATIC ARRAYS ---------------------------------------------------------
    static RxSarEntry               RX_SAR_TABLE[TOE_MAX_SESSIONS];
    #pragma HLS RESOURCE   variable=RX_SAR_TABLE core=RAM_2P
    #pragma HLS DEPENDENCE variable=RX_SAR_TABLE inter false
 
    if(!siTXe_RxSarReq.empty()) {
        SessionId sessId;
        //---------------------------------------
        // [TXe] - Read only access
        //---------------------------------------
        siTXe_RxSarReq.read(sessId);
        soTxe_RxSarRep.write(RxSarReply(RX_SAR_TABLE[sessId].appd,
                                        RX_SAR_TABLE[sessId].rcvd,
                                        RX_SAR_TABLE[sessId].ooo,
                                        RX_SAR_TABLE[sessId].oooHead,
                                        RX_SAR_TABLE[sessId].oooTail));
        if (DEBUG_LEVEL & TRACE_RST) {
            RxBufPtr free_space = ((RX_SAR_TABLE[sessId].appd -
                          (RxBufPtr)RX_SAR_TABLE[sessId].oooHead(TOE_WINDOW_BITS-1, 0)) - 1);
            printInfo(myName, "[TXe] Read  S%d - FreeSpace=%d\n",
                              sessId.to_uint(), free_space.to_uint());
        }
    }
    else if(!siRAi_RxSarQry.empty()) {
        RAiRxSarQuery raiQry;
        //----------------------------------------------------------------
        // [RAi] - Read or write access to update the application pointer
        //----------------------------------------------------------------
        siRAi_RxSarQry.read(raiQry);
        if(raiQry.write) {
            RX_SAR_TABLE[raiQry.sessionID].appd = raiQry.appd;
            if (DEBUG_LEVEL & TRACE_RST) {
                RxBufPtr free_space = ((RX_SAR_TABLE[raiQry.sessionID].appd -
                              (RxBufPtr)RX_SAR_TABLE[raiQry.sessionID].oooHead(TOE_WINDOW_BITS-1, 0)) - 1);
                printInfo(myName, "[RAi] Write S%d - FreeSpace=%d\n",
                                  raiQry.sessionID.to_uint(), free_space.to_uint());
            }
        }
        else {
            soRAi_RxSarRep.write(RAiRxSarReply(raiQry.sessionID,
                                               RX_SAR_TABLE[raiQry.sessionID].appd));
            if (DEBUG_LEVEL & TRACE_RST) {
                RxBufPtr free_space = ((RX_SAR_TABLE[raiQry.sessionID].appd -
                              (RxBufPtr)RX_SAR_TABLE[raiQry.sessionID].oooHead(TOE_WINDOW_BITS-1, 0)) - 1);
                printInfo(myName, "[RAi] Read  S%d - FreeSpace=%d\n",
                                  raiQry.sessionID.to_uint(), free_space.to_uint());
            }
        }
    }
    else if(!siRXe_RxSarQry.empty()) {
        RXeRxSarQuery rxeQry = siRXe_RxSarQry.read();
        //---------------------------------------
        // [RXe] - Write access
        //---------------------------------------
        if (rxeQry.write) {
            RX_SAR_TABLE[rxeQry.sessionID].rcvd = rxeQry.rcvd;
            if (rxeQry.init) {
                RX_SAR_TABLE[rxeQry.sessionID].appd    = rxeQry.rcvd;
            }
            if (rxeQry.ooo) {
                RX_SAR_TABLE[rxeQry.sessionID].ooo     = true;
                RX_SAR_TABLE[rxeQry.sessionID].oooHead = rxeQry.oooHead;
                RX_SAR_TABLE[rxeQry.sessionID].oooTail = rxeQry.oooTail;
            }
            else {
                RX_SAR_TABLE[rxeQry.sessionID].ooo     = false;
                RX_SAR_TABLE[rxeQry.sessionID].oooHead = rxeQry.rcvd;
                RX_SAR_TABLE[rxeQry.sessionID].oooTail = rxeQry.rcvd;
            }
            if (DEBUG_LEVEL & TRACE_RST) {
                RxBufPtr free_space = ((RX_SAR_TABLE[rxeQry.sessionID].appd -
                              (RxBufPtr)RX_SAR_TABLE[rxeQry.sessionID].oooHead(TOE_WINDOW_BITS-1, 0)) - 1);
                printInfo(myName, "[RXe] Write S%d - FreeSpace=%d\n",
                                  rxeQry.sessionID.to_uint(), free_space.to_uint());
            }
        }
        else {
            // Read access from [RXe]
            soRXe_RxSarRep.write(RxSarReply(RX_SAR_TABLE[rxeQry.sessionID].appd,
                                            RX_SAR_TABLE[rxeQry.sessionID].rcvd,
                                            RX_SAR_TABLE[rxeQry.sessionID].ooo,
                                            RX_SAR_TABLE[rxeQry.sessionID].oooHead,
                                            RX_SAR_TABLE[rxeQry.sessionID].oooTail));
            if (DEBUG_LEVEL & TRACE_RST) {
                RxBufPtr free_space = ((RX_SAR_TABLE[rxeQry.sessionID].appd -
                              (RxBufPtr)RX_SAR_TABLE[rxeQry.sessionID].oooHead(TOE_WINDOW_BITS-1, 0)) - 1);
                printInfo(myName, "[RXe] Read  S%d - FreeSpace=%d\n",
                                  rxeQry.sessionID.to_uint(), free_space.to_uint());
            }
        }
    }
}