tx_sar_table.cpp

Go to the documentation of this file.

 
 
 
#include "tx_sar_table.hpp"
 
using namespace hls;
 
 
#ifndef __SYNTHESIS__
  extern bool gTraceEvent;
#endif
 
#define THIS_NAME "TOE/TSt"
 
#define TRACE_OFF  0x0000
#define TRACE_TST 1 <<  1
#define TRACE_ALL  0xFFFF
 
#define DEBUG_LEVEL (TRACE_OFF)
 
 
 
void tx_sar_table(
        stream<RXeTxSarQuery>      &siRXe_TxSarQry,
        stream<RXeTxSarReply>      &soRXe_TxSarRep,
        stream<TXeTxSarQuery>      &siTXe_TxSarQry,
        stream<TXeTxSarReply>      &soTXe_TxSarRep,
        stream<TAiTxSarPush>       &siTAi_PushCmd,
        stream<TStTxSarPush>       &soTAi_PushCmd)
{
    //-- DIRECTIVES FOR THIS PROCESS -------------------------------------------
    #pragma HLS PIPELINE II=1 enable_flush
 
    const char *myName = THIS_NAME;
 
    //-- STATIC ARRAYS ---------------------------------------------------------
    static TxSarEntry               TX_SAR_TABLE[TOE_MAX_SESSIONS];
    #pragma HLS DEPENDENCE variable=TX_SAR_TABLE inter false
    #pragma HLS RESOURCE   variable=TX_SAR_TABLE core=RAM_2P
 
    if (!siTXe_TxSarQry.empty()) {
        TXeTxSarQuery sTXeQry;
        //----------------------------------------
        //-- Rd/Wr Query from TX Engine
        //----------------------------------------
        siTXe_TxSarQry.read(sTXeQry);
        if (sTXeQry.write) {
            //-- TXe Write Query
            if (not sTXeQry.isRtQuery) {
                TX_SAR_TABLE[sTXeQry.sessionID].unak = sTXeQry.not_ackd;
                if (sTXeQry.init) {
                    TX_SAR_TABLE[sTXeQry.sessionID].appw        = sTXeQry.not_ackd;
                    TX_SAR_TABLE[sTXeQry.sessionID].ackd        = sTXeQry.not_ackd-1;
                    TX_SAR_TABLE[sTXeQry.sessionID].cong_window = 0x3908; // 10 x 1460(MSS)
                    TX_SAR_TABLE[sTXeQry.sessionID].slowstart_threshold = 0xFFFF;
                    // Avoid initializing 'finReady' and 'finSent' at two different
                    // places because it will translate into II=2 and DRC message:
                    // 'Unable to schedule store operation on array due to limited memory ports'.
 
                    // Init ACK on the TxAppInterface side
                    soTAi_PushCmd.write(TStTxSarPush(sTXeQry.sessionID,
                                                     sTXeQry.not_ackd, CMD_INIT));
                }
                if (sTXeQry.finReady or sTXeQry.init) {
                    TX_SAR_TABLE[sTXeQry.sessionID].finReady = sTXeQry.finReady;
                }
                if (sTXeQry.finSent or sTXeQry.init) {
                    TX_SAR_TABLE[sTXeQry.sessionID].finSent  = sTXeQry.finSent;
                }
            }
            else {
                //-- TXe Write RtQuery
                TXeTxSarRtQuery sTXeRtQry = sTXeQry;
                TX_SAR_TABLE[sTXeQry.sessionID].slowstart_threshold = sTXeRtQry.getThreshold();
                TX_SAR_TABLE[sTXeQry.sessionID].cong_window = 0x3908; // 10 x 1460(MSS) TODO is this correct or less, eg. 1/2 * MSS
                if (DEBUG_LEVEL & TRACE_TST) {
                    printInfo(myName, "Received a Retry-Write query from TXe for session #%d.\n",
                            sTXeQry.sessionID.to_int());
                }
            }
        }
        else {
            //-- TXe Read Query
            TxSarEntry txSarEntry = TX_SAR_TABLE[sTXeQry.sessionID];
 
            TcpWindow   minWindow;
            if (txSarEntry.cong_window < txSarEntry.recv_window) {
                minWindow = txSarEntry.cong_window;
            }
            else {
                minWindow = TX_SAR_TABLE[sTXeQry.sessionID].recv_window;
            }
            soTXe_TxSarRep.write(TXeTxSarReply(TX_SAR_TABLE[sTXeQry.sessionID].ackd,
                                               TX_SAR_TABLE[sTXeQry.sessionID].unak,
                                               minWindow,
                                               TX_SAR_TABLE[sTXeQry.sessionID].appw,
                                               TX_SAR_TABLE[sTXeQry.sessionID].finReady,
                                               TX_SAR_TABLE[sTXeQry.sessionID].finSent));
        }
    }
    else if (!siTAi_PushCmd.empty()) {
        TAiTxSarPush sTAiCmd;
        //---------------------------------------
        //-- Wr Command from TX APP Interface
        //---------------------------------------
        siTAi_PushCmd.read(sTAiCmd);
        //--  Update the 'txAppWrPtr'
        TX_SAR_TABLE[sTAiCmd.sessionID].appw = sTAiCmd.app;
    }
    else if (!siRXe_TxSarQry.empty()) {
        RXeTxSarQuery sRXeQry;
        //---------------------------------------
        //-- Rd/Wr Query from RX Engine
        //---------------------------------------
        siRXe_TxSarQry.read(sRXeQry);
        if (sRXeQry.write == QUERY_WR) {
            TX_SAR_TABLE[sRXeQry.sessionID].ackd        = sRXeQry.ackd;
            TX_SAR_TABLE[sRXeQry.sessionID].recv_window = sRXeQry.recv_window;
            TX_SAR_TABLE[sRXeQry.sessionID].cong_window = sRXeQry.cong_window;
            TX_SAR_TABLE[sRXeQry.sessionID].count       = sRXeQry.count;
            TX_SAR_TABLE[sRXeQry.sessionID].fastRetransmitted = sRXeQry.fastRetransmitted;
            // Push ACK to txAppInterface
            soTAi_PushCmd.write(TStTxSarPush(sRXeQry.sessionID, sRXeQry.ackd));
        }
        else {
            //-- Read Query
            soRXe_TxSarRep.write(RXeTxSarReply(TX_SAR_TABLE[sRXeQry.sessionID].ackd,
                                               TX_SAR_TABLE[sRXeQry.sessionID].unak,
                                               TX_SAR_TABLE[sRXeQry.sessionID].cong_window,
                                               TX_SAR_TABLE[sRXeQry.sessionID].slowstart_threshold,
                                               TX_SAR_TABLE[sRXeQry.sessionID].count,
                                               TX_SAR_TABLE[sRXeQry.sessionID].fastRetransmitted));
        }
    }
}