test_tx_engine.cpp

Go to the documentation of this file.

/*
 * Copyright 2016 -- 2021 IBM Corporation
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
 
 
#include "test_tx_engine.hpp"
 
using namespace hls;
using namespace std;
 
//---------------------------------------------------------
// HELPERS FOR THE DEBUGGING TRACES
//  .e.g: DEBUG_LEVEL = (MDL_TRACE | IPS_TRACE)
//---------------------------------------------------------
#define THIS_NAME "TB"
 
#define TRACE_OFF    0x0000
#define TRACE_CAM    1 <<  1
#define TRACE_IPRX   1 <<  2
#define TRACE_IPTX   1 <<  3
#define TRACE_MAIN   1 <<  4
#define TRACE_RXMEM  1 <<  5
#define TRACE_TAIF   1 <<  6
#define TRACE_TAr    1 <<  7
#define TRACE_TAs    1 <<  8
#define TRACE_Tac    1 <<  9
#define TRACE_Tae    1 << 10
#define TRACE_Tal    1 << 11
#define TRACE_TXMEM  1 << 12
#define TRACE_ALL    0xFFFF
#define DEBUG_LEVEL (TRACE_OFF)
 
 
 
void stepSim() {
    gSimCycCnt++;
    if (gTraceEvent || ((gSimCycCnt % 1000) == 0)) {
        printInfo(THIS_NAME, "-- [@%4.4d] -----------------------------\n", gSimCycCnt);
        gTraceEvent = false;
    }
    else if (0) {
        printInfo(THIS_NAME, "------------------- [@%d] ------------\n", gSimCycCnt);
    }
}
 
 
void increaseSimTime(unsigned int cycles) {
    gMaxSimCycles += cycles;
}
 
const char *camAccessorStrings[] = { "RXe", "TAi" };
 
 
const char *myCamAccessToString(int initiator) {
    return camAccessorStrings[initiator];
}
 
 
template<typename T> int drainMmioDropCounter(stream<T> &ss, string ssName) {
    int          nrDrops=0;
    const char  *myName  = concat3(THIS_NAME, "/", "DMDC");
    T  currDropCount;
    T  prevDropCount=0;
 
    //-- READ FROM STREAM
    while (!(ss.empty())) {
        ss.read(currDropCount);
        if (currDropCount != prevDropCount) {
            printWarn(myName, "Detected a drop event on stream '%s' (currDropCounter=%d). \n",
                      ssName.c_str(), currDropCount.to_ushort());
            nrDrops++;
        }
        prevDropCount = currDropCount;
    }
    return(nrDrops);
}
 
 
void pEmulateCam(
        stream<CamSessionLookupRequest>  &siTOE_SssLkpReq,
        stream<CamSessionLookupReply>    &soTOE_SssLkpRep,
        stream<CamSessionUpdateRequest>  &siTOE_SssUpdReq,
        stream<CamSessionUpdateReply>    &soTOE_SssUpdRep)
{
    const char *myName  = concat3(THIS_NAME, "/", "CAM");
 
    static map<FourTuple, ap_uint<14> > cam_lookupTable;
 
    static enum FsmStates { CAM_WAIT_4_REQ=0,
                            CAM_LOOKUP_REP, CAM_UPDATE_REP } cam_fsmState=CAM_WAIT_4_REQ;
 
    static CamSessionLookupRequest cam_request;
    static CamSessionUpdateRequest cam_update;
    static int                     cam_updateIdleCnt = 0;
    volatile static int            cam_lookupIdleCnt = 0;
 
    map<FourTuple, ap_uint<14> >::const_iterator findPos;
 
    //-----------------------------------------------------
    //-- CONTENT ADDRESSABLE MEMORY PROCESS
    //-----------------------------------------------------
    switch (cam_fsmState) {
    case CAM_WAIT_4_REQ:
        if (!siTOE_SssLkpReq.empty()) {
            siTOE_SssLkpReq.read(cam_request);
            cam_lookupIdleCnt = CAM_LOOKUP_LATENCY;
            cam_fsmState = CAM_LOOKUP_REP;
            if (DEBUG_LEVEL & TRACE_CAM) {
                printInfo(myName, "Received a session lookup request from [%s] for socket pair: \n",
                          myCamAccessToString(cam_request.source.to_int()));
                printFourTuple(myName, cam_request.source.to_int(), cam_request.key);
            }
        }
        else if (!siTOE_SssUpdReq.empty()) {
            siTOE_SssUpdReq.read(cam_update);
            cam_updateIdleCnt = CAM_UPDATE_LATENCY;
            cam_fsmState = CAM_UPDATE_REP;
            if (DEBUG_LEVEL & TRACE_CAM) {
                 printInfo(myName, "Received a session update request from [%s] for socket pair: \n",
                           myCamAccessToString(cam_update.source.to_int()));
                 printFourTuple(myName, cam_update.source.to_int(), cam_update.key);
            }
        }
        break;
    case CAM_LOOKUP_REP:
        //-- Wait some cycles to match the co-simulation --
        if (cam_lookupIdleCnt > 0) {
            cam_lookupIdleCnt--;
        }
        else {
            findPos = cam_lookupTable.find(cam_request.key);
            if (findPos != cam_lookupTable.end()) { // hit
                soTOE_SssLkpRep.write(CamSessionLookupReply(true, findPos->second, cam_request.source));
                if (DEBUG_LEVEL & TRACE_CAM) {
                    printInfo(myName, "Result of session lookup = HIT \n");
                }
            }
            else {
                soTOE_SssLkpRep.write(CamSessionLookupReply(false, cam_request.source));
                if (DEBUG_LEVEL & TRACE_CAM) {
                    printInfo(myName, "Result of session lookup = NO-HIT\n");
                }
            }
            cam_fsmState = CAM_WAIT_4_REQ;
        }
        break;
    case CAM_UPDATE_REP:
        //-- Wait some cycles to match the co-simulation --
        if (cam_updateIdleCnt > 0) {
            cam_updateIdleCnt--;
        }
        else {
            // [TODO - What if element does not exist]
            if (cam_update.op == INSERT) {
                //Is there a check if it already exists?
                cam_lookupTable[cam_update.key] = cam_update.value;
                soTOE_SssUpdRep.write(CamSessionUpdateReply(cam_update.value, INSERT, cam_update.source));
                if (DEBUG_LEVEL & TRACE_CAM) {
                    printInfo(myName, "Successful insertion of session ID #%d for [%s].\n", cam_update.value.to_int(),
                              myCamAccessToString(cam_update.source.to_int()));
                }
            }
            else {  // DELETE
                cam_lookupTable.erase(cam_update.key);
                soTOE_SssUpdRep.write(CamSessionUpdateReply(cam_update.value, DELETE, cam_update.source));
                if (DEBUG_LEVEL & TRACE_CAM) {
                     printInfo(myName, "Successful deletion of session ID #%d for [%s].\n", cam_update.value.to_int(),
                               myCamAccessToString(cam_update.source.to_int()));
                 }
            }
            cam_fsmState = CAM_WAIT_4_REQ;
        }
        break;
    } // End-of: switch()
 
} // End-of: pEmulateCam()
 
 
void pEmulateRxBufMem(
        DummyMemory         *memory,
        int                 &nrError,
        stream<DmCmd>       &siTOE_RxP_WrCmd,
        stream<AxisApp>     &siTOE_RxP_Data,
        stream<DmSts>       &soTOE_RxP_WrSts,
        stream<DmCmd>       &siTOE_RxP_RdCmd,
        stream<AxisApp>     &soTOE_RxP_Data)
{
    const char *myName  = concat3(THIS_NAME, "/", "RXMEM");
 
    //-- STATIC VARIABLES ------------------------------------------------------
    static int      rxmem_wrCounter = 0;
    static int      rxmem_rdCounter = 0;
    static int      rxmem_noBytesToWrite = 0;
    static int      rxmem_noBytesToRead  = 0;
    static int      rxmem_rdIdleCnt   = 0;
    static int      rxmem_wrIdleCnt   = 0;
    static DmCmd    rxmem_dmCmd;     // Data Mover Command
 
    static enum  WrStates { WAIT_4_WR_CMD, MWR_DATA, MWR_STS } rxmem_WrState;
    static enum  RdStates { WAIT_4_RD_CMD, MRD_DATA, MRD_STS } rxmem_RdState;
 
    //-- DYNAMIC VARIABLES -----------------------------------------------------
    DmSts    dmSts;     // Data Mover Status
 
    AxisApp  tmpInChunk  = AxisApp(0, 0, 0);
    AxisApp  inChunk     = AxisApp(0, 0, 0);
    AxisApp  outChunk    = AxisApp(0, 0, 0);
    AxisApp  tmpOutChunk = AxisApp(0, 0, 0);
 
    //-----------------------------------------------------
    //-- MEMORY WRITE PROCESS
    //-----------------------------------------------------
    switch (rxmem_WrState) {
    case WAIT_4_WR_CMD:
        if (!siTOE_RxP_WrCmd.empty()) {
            // Memory Write Command
            siTOE_RxP_WrCmd.read(rxmem_dmCmd);
            if (DEBUG_LEVEL & TRACE_RXMEM) {
                printInfo(myName, "Received memory write command from TOE: (addr=0x%llx, btt=%d).\n",
                          rxmem_dmCmd.saddr.to_uint64(), rxmem_dmCmd.btt.to_uint());
            }
            memory->setWriteCmd(rxmem_dmCmd);
            rxmem_noBytesToWrite = rxmem_dmCmd.btt.to_int();
            rxmem_wrCounter = 0;
            rxmem_wrIdleCnt   = MEM_WR_CMD_LATENCY;
            rxmem_WrState     = MWR_DATA;
        }
        break;
    case MWR_DATA:
        if (rxmem_wrIdleCnt > 0) {
            //-- Emulate the latency of the memory --------
            rxmem_wrIdleCnt--;
        }
        else if (!siTOE_RxP_Data.empty()) {
            //-- Data Memory Write Transfer ---------------
            siTOE_RxP_Data.read(tmpInChunk);
            inChunk = tmpInChunk;
            memory->writeChunk(inChunk);
            rxmem_wrCounter += inChunk.getLen();
            if (inChunk.getTLast() or (rxmem_wrCounter == rxmem_noBytesToWrite)) {
                rxmem_wrIdleCnt  = MEM_WR_STS_LATENCY;
                rxmem_WrState    = MWR_STS;
            }
        }
        break;
    case MWR_STS:
        if (rxmem_wrIdleCnt > 0) {
            //-- Emulate the latency of the memory --------
            rxmem_wrIdleCnt--;
        }
        else if (!soTOE_RxP_WrSts.full()) {
            //-- Data Memory Write Status -----------------
            if (rxmem_noBytesToWrite != rxmem_wrCounter) {
                printError(myName, "The number of bytes received from TOE (%d) does not match the expected number specified by the command (%d)!\n",
                           rxmem_wrCounter, rxmem_noBytesToWrite);
                nrError += 1;
                dmSts.okay = 0;
            }
            else {
                dmSts.okay = 1;
            }
            soTOE_RxP_WrSts.write(dmSts);
 
            if (DEBUG_LEVEL & TRACE_RXMEM) {
                printInfo(myName, "Sending memory status back to TOE: (OK=%d).\n",
                          dmSts.okay.to_int());
            }
            rxmem_WrState = WAIT_4_WR_CMD;
        }
        break;
    } // End of: switch (rxmem_WrState)
 
    //-----------------------------------------------------
    //-- MEMORY READ PROCESS
    //-----------------------------------------------------
    switch (rxmem_RdState) {
    case WAIT_4_RD_CMD:
        if (!siTOE_RxP_RdCmd.empty()) {
            // Memory Read Command
            siTOE_RxP_RdCmd.read(rxmem_dmCmd);
            if (DEBUG_LEVEL & TRACE_RXMEM) {
                 printInfo(myName, "Received memory read command from TOE: (addr=0x%llx, btt=%d).\n",
                           rxmem_dmCmd.saddr.to_uint64(), rxmem_dmCmd.btt.to_uint());
            }
            memory->setReadCmd(rxmem_dmCmd);
            rxmem_noBytesToRead = rxmem_dmCmd.btt.to_int();
            rxmem_rdCounter = 0;
            rxmem_rdIdleCnt = MEM_RD_CMD_LATENCY;
            rxmem_RdState   = MRD_DATA;
        }
        break;
    case MRD_DATA:
        if (rxmem_rdIdleCnt > 0) {
            //-- Emulate the latency of the memory --------
            rxmem_rdIdleCnt--;
        }
        else if (!soTOE_RxP_Data.full()) {
            // Data Memory Read Transfer
            memory->readChunk(tmpOutChunk);
            outChunk = tmpOutChunk;
            rxmem_rdCounter += outChunk.getLen();
            soTOE_RxP_Data.write(outChunk);
            if ((outChunk.getTLast()) or (rxmem_rdCounter == rxmem_noBytesToRead)) {
                rxmem_rdIdleCnt = MEM_RD_STS_LATENCY;
                rxmem_RdState   = MRD_STS;
            }
        }
        break;
    case MRD_STS:
        if (rxmem_wrIdleCnt > 0) {
            //-- Emulate the latency of the memory --------
            rxmem_wrIdleCnt--;
        }
        //-- [TOE] won't send a status back to us
        rxmem_RdState = WAIT_4_RD_CMD;
        break;
    } // End-of: switch (memRdState)
 
} // End of: pEmulateRxBufMem
 
 
void pEmulateTxBufMem(
        DummyMemory         *memory,
        int                 &nrError,
        stream<DmCmd>       &siTOE_TxP_WrCmd,
        stream<AxisApp>     &siTOE_TxP_Data,
        stream<DmSts>       &soTOE_TxP_WrSts,
        stream<DmCmd>       &siTOE_TxP_RdCmd,
        stream<AxisApp>     &soTOE_TxP_Data)
{
    const char *myName  = concat3(THIS_NAME, "/", "TXMEM");
 
    //-- STATIC VARIABLES ------------------------------------------------------
    static int   txmem_wrCounter = 0;
    static int   txmem_rdCounter = 0;
    static int   txmem_noBytesToWrite = 0;
    static int   txmem_noBytesToRead  = 0;
    static int   txmem_wrIdleCnt = 0;
    static int   txmem_rdIdleCnt = 0;
    static DmCmd txmem_dmCmd;     // Data Mover Command
    static enum  WrStates { WAIT_4_WR_CMD, MWR_DATA, MWR_STS } txmem_WrState;
    static enum  RdStates { WAIT_4_RD_CMD, MRD_DATA, MRD_STS } txmem_RdState;
 
    //-- DYNAMIC VARIABLES -----------------------------------------------------
    DmSts    dmSts;     // Data Mover Status
    AxisApp  tmpInChunk  = AxisApp(0, 0, 0);
    AxisApp  inChunk     = AxisApp(0, 0, 0);
    AxisApp  outChunk    = AxisApp(0, 0, 0);
    AxisApp  tmpOutChunk = AxisApp(0, 0, 0);
 
    //-----------------------------------------------------
    //-- MEMORY WRITE PROCESS
    //-----------------------------------------------------
    switch (txmem_WrState) {
    case WAIT_4_WR_CMD:
        if (!siTOE_TxP_WrCmd.empty()) {
            // Memory Write Command -----------------------
            siTOE_TxP_WrCmd.read(txmem_dmCmd);
            if (DEBUG_LEVEL & TRACE_TXMEM) {
                printInfo(myName, "Received memory write command from TOE: (addr=0x%llx, btt=%d).\n",
                          txmem_dmCmd.saddr.to_uint64(), txmem_dmCmd.btt.to_uint());
            }
            memory->setWriteCmd(txmem_dmCmd);
            txmem_noBytesToWrite = txmem_dmCmd.btt.to_int();
            txmem_wrCounter = 0;
            txmem_wrIdleCnt = MEM_WR_CMD_LATENCY;
            txmem_WrState   = MWR_DATA;
        }
        break;
    case MWR_DATA:
        if (txmem_wrIdleCnt > 0) {
            //-- Emulate the latency of the memory --------
            txmem_wrIdleCnt--;
        }
        else if (!siTOE_TxP_Data.empty()) {
            //-- Data Memory Write Transfer ---------------
            siTOE_TxP_Data.read(tmpInChunk);
            inChunk = tmpInChunk;
            memory->writeChunk(inChunk);
            txmem_wrCounter += inChunk.getLen();
            if (inChunk.getTLast() or (txmem_wrCounter == txmem_noBytesToWrite)) {
                txmem_wrIdleCnt  = MEM_WR_STS_LATENCY;
                txmem_WrState    = MWR_STS;
            }
        }
        break;
    case MWR_STS:
        if (txmem_wrIdleCnt > 0) {
            //-- Data Memory Write Transfer ---------------
            txmem_wrIdleCnt--;
        }
        else if (!soTOE_TxP_WrSts.full()) {
            //-- Data Memory Write Status -----------------
            if (txmem_noBytesToWrite != txmem_wrCounter) {
                printError(myName, "The number of bytes received from TOE (%d) does not match the expected number specified by the command (%d)!\n",
                           txmem_wrCounter, txmem_noBytesToWrite);
                nrError += 1;
                dmSts.okay = 0;
            }
            else {
                dmSts.okay = 1;
            }
            soTOE_TxP_WrSts.write(dmSts);
            if (DEBUG_LEVEL & TRACE_TXMEM) {
                printInfo(myName, "Sending memory status back to TOE: (OK=%d).\n",
                          dmSts.okay.to_int());
            }
            txmem_WrState = WAIT_4_WR_CMD;
        }
        break;
    } // End-of: switch(txmem_WrState)
 
    //-----------------------------------------------------
    //-- MEMORY READ PROCESS
    //-----------------------------------------------------
    switch (txmem_RdState) {
    case WAIT_4_WR_CMD:
        if (!siTOE_TxP_RdCmd.empty()) {
            // Memory Read Command
            siTOE_TxP_RdCmd.read(txmem_dmCmd);
            if (DEBUG_LEVEL & TRACE_TXMEM) {
                 printInfo(myName, "Received memory read command from TOE: (addr=0x%llx, btt=%d).\n",
                           txmem_dmCmd.saddr.to_uint64(), txmem_dmCmd.btt.to_uint());
            }
            memory->setReadCmd(txmem_dmCmd);
            txmem_noBytesToRead = txmem_dmCmd.btt.to_int();
            txmem_rdCounter = 0;
            txmem_rdIdleCnt = MEM_RD_CMD_LATENCY;
            txmem_RdState   = MRD_DATA;
        }
        break;
    case MRD_DATA:
        if (txmem_rdIdleCnt > 0) {
            //-- Emulate the latency of the memory --------
            txmem_rdIdleCnt--;
        }
        else if (!soTOE_TxP_Data.full()) {
            // Data Memory Read Transfer
            memory->readChunk(tmpOutChunk);
            outChunk = tmpOutChunk;
            txmem_rdCounter += outChunk.getLen();
            soTOE_TxP_Data.write(outChunk);
            if (outChunk.getTLast() or (txmem_rdCounter == txmem_noBytesToRead)) {
                txmem_rdIdleCnt = MEM_RD_STS_LATENCY;
                txmem_RdState   = MRD_STS;
            }
        }
        break;
    case MRD_STS:
        //-- Wait some cycles to match the co-simulation --
        if (txmem_rdIdleCnt > 0) {
            //-- Emulate the latency of the memory --------
            txmem_rdIdleCnt--;
        }
        //-- [TOE] won't send a status back to us
        txmem_RdState = WAIT_4_RD_CMD;
        break;
    } // End-of: switch(memRdState)
 
} // End of: pEmulateTxBufMem
 
 
bool setGlobalParameters(const char *callerName, unsigned int startupDelay, ifstream &inputFile)
{
    char myName[120];
    strcpy(myName, callerName);
    strcat(myName, "/setGlobalParameters");
 
    string              rxStringBuffer;
    vector<string>      stringVector;
 
    do {
        //-- READ ONE LINE AT A TIME FROM INPUT FILE ---------------
        getline(inputFile, rxStringBuffer);
        stringVector = myTokenizer(rxStringBuffer, ' ');
 
        if (stringVector[0] == "") {
            continue;
        }
        else if (stringVector[0].length() == 1) {
            // By convention, a global parameter must start with a single 'G' character.
            if ((stringVector[0] == "G") and (stringVector[1] == "PARAM")) {
                if (stringVector[2] == "SimCycles") {
                    // The test vector file is specifying a minimum number of simulation cycles.
                    int noSimCycles = atoi(stringVector[3].c_str());
                    noSimCycles += startupDelay;
                    if (noSimCycles > gMaxSimCycles) {
                        gMaxSimCycles = noSimCycles;
                    }
                    if ((DEBUG_LEVEL & TRACE_IPRX) or (DEBUG_LEVEL & TRACE_TAIF)) {
                        printInfo(myName, "Requesting the simulation to last for %d cycles. \n", gMaxSimCycles);
                    }
                }
                else if (stringVector[2] == "FpgaIp4Addr") {
                    char * ptr;
                    // Retrieve the IPv4 address to set
                    unsigned int ip4Addr;
                    if (isDottedDecimal(stringVector[3]))
                        ip4Addr = myDottedDecimalIpToUint32(stringVector[3]);
                    else if (isHexString(stringVector[3]))
                        ip4Addr = strtoul(stringVector[3].c_str(), &ptr, 16);
                    else
                        ip4Addr = strtoul(stringVector[3].c_str(), &ptr, 10);
                    gFpgaIp4Addr = ip4Addr;
                    printInfo(myName, "Redefining the default FPGA IPv4 address to be: ");
                    printIp4Addr(myName, gFpgaIp4Addr);
                }
                else if (stringVector[2] == "FpgaLsnPort") {
                    char * ptr;
                    // Retrieve the TCP-Port to set
                    unsigned int tcpPort;
                    if (isHexString(stringVector[3]))
                        tcpPort = strtoul(stringVector[3].c_str(), &ptr, 16);
                    else
                        tcpPort = strtoul(stringVector[3].c_str(), &ptr, 10);
                    gFpgaLsnPort = tcpPort;
                    printInfo(myName, "Redefining the default FPGA listen port to be: ");
                    printTcpPort(myName, gFpgaLsnPort);
                }
                else if (stringVector[2] == "HostIp4Addr") {
                    char * ptr;
                    // Retrieve the IPv4 address to set
                    unsigned int ip4Addr;
                    if (isDottedDecimal(stringVector[3]))
                        ip4Addr = myDottedDecimalIpToUint32(stringVector[3]);
                    else if (isHexString(stringVector[3]))
                        ip4Addr = strtoul(stringVector[3].c_str(), &ptr, 16);
                    else
                        ip4Addr = strtoul(stringVector[3].c_str(), &ptr, 10);
                    gHostIp4Addr = ip4Addr;
                    printInfo(myName, "Redefining the default HOST IPv4 address to be: ");
                    printIp4Addr(myName, gHostIp4Addr);
                }
                else if (stringVector[2] == "HostLsnPort") {
                    char * ptr;
                    // Retrieve the TCP-Port to set
                    unsigned int tcpPort;
                    if (isHexString(stringVector[3]))
                        tcpPort = strtoul(stringVector[3].c_str(), &ptr, 16);
                    else
                        tcpPort = strtoul(stringVector[3].c_str(), &ptr, 10);
                    gHostLsnPort = tcpPort;
                    printInfo(myName, "Redefining the default HOST listen port to be: \n");
                    printTcpPort(myName, gHostLsnPort);
                }
                else if (stringVector[2] == "SortTaifGold") {
                    if (stringVector[3] == "true") {
                        gSortTaifGold = true;
                        printInfo(callerName, "Requesting the 'soTAIF.gold' file to be sorted.\n");
                    }
                    else {
                        gSortTaifGold = false;
                        printInfo(callerName, "Disabling the sorting of the 'soTAIF.gold' file.\n");
                    }
                }
                else if (stringVector[2] == "FpgaServerSocket") {  // DEPRECATED
                    printFatal(myName, "The global parameter \'FpgaServerSockett\' is not supported anymore.\n\tPLEASE UPDATE YOUR TEST VECTOR FILE ACCORDINGLY.\n");
                }
                else if (stringVector[2] == "ForeignSocket") {     // DEPRECATED
                    printFatal(myName, "The global parameter \'ForeignSocket\' is not supported anymore.\n\tPLEASE UPDATE YOUR TEST VECTOR FILE ACCORDINGLY.\n");
                    exit(1);
                }
                else if (stringVector[2] == "LocalSocket") {       // DEPRECATED
                    printFatal(myName, "The global parameter \'LocalSocket\' is not supported anymore.\n\tPLEASE UPDATE YOUR TESTVECTOR FILE ACCORDINGLY.\n");
                }
                else {
                    printError(myName, "Unknown parameter \'%s\'.\n", stringVector[2].c_str());
                    return false;
                }
            }
            else
                continue;
        }
    } while(!inputFile.eof());
 
    if ((DEBUG_LEVEL & TRACE_IPRX) or (DEBUG_LEVEL & TRACE_TAIF)) {
        printInfo(myName, "Done with the parsing of the input test file.\n");
    }
 
    // Seek back to the start of stream
    inputFile.clear();
    inputFile.seekg(0, ios::beg);
 
    return true;
 
} // End of: setGlopbalParameters
 
 
void cmdSetCommandParser(const char *callerName, vector<string> stringVector) {
    if (stringVector[2] == "HostIp4Addr") {
        //--------------------------------------------
        //-- COMMAND = Set the active host IP address
        //--------------------------------------------
        char * ptr;
        // Retrieve the IPv4 address to set
        unsigned int ip4Addr;
        if (isDottedDecimal(stringVector[3]))
            ip4Addr = myDottedDecimalIpToUint32(stringVector[3]);
        else if (isHexString(stringVector[3]))
            ip4Addr = strtoul(stringVector[3].c_str(), &ptr, 16);
        else
            ip4Addr = strtoul(stringVector[3].c_str(), &ptr, 10);
        gHostIp4Addr = ip4Addr;
        printInfo(callerName, "Setting the current HOST IPv4 address to be: \n");
        printIp4Addr(callerName, gHostIp4Addr);
    }
    else if (stringVector[2] == "HostLsnPort") {
        //---------------------------------------------
        //-- COMMAND = Set the active host listen port
        //---------------------------------------------
        char * ptr;
        // Retrieve the TCP-Port to set
        unsigned int tcpPort;
        if (isHexString(stringVector[3]))
            tcpPort = strtoul(stringVector[3].c_str(), &ptr, 16);
        else
           tcpPort = strtoul(stringVector[3].c_str(), &ptr, 10);
        gHostLsnPort = tcpPort;
        printInfo(callerName, "Setting the current HOST listen port to be: \n");
        printTcpPort(callerName, gHostLsnPort);
    }
    else if (stringVector[2] == "FpgaLsnPort") {
        //---------------------------------------------
        //-- COMMAND = Set the active fpga listen port
        //---------------------------------------------
        char * ptr;
        // Retrieve the TCP-Port to set
        unsigned int tcpPort;
        if (isHexString(stringVector[3]))
            tcpPort = strtoul(stringVector[3].c_str(), &ptr, 16);
        else
           tcpPort = strtoul(stringVector[3].c_str(), &ptr, 10);
        gFpgaLsnPort = tcpPort;
        printInfo(callerName, "Setting the current FPGA listen port to be: \n");
        printTcpPort(callerName, gFpgaLsnPort);
    }
    else if (stringVector[2] == "HostServerSocket") {
        //------------------------------------------------------
        //-- COMMAND = Set the active host server socket
        //--  If socket does not exist, host must create, bind,
        //--  listen and accept new connections from the client.
        //------------------------------------------------------
        char *pEnd;
        // Retrieve the current foreign IPv4 address to set
        unsigned int ip4Addr;
        if (isDottedDecimal(stringVector[3]))
            ip4Addr = myDottedDecimalIpToUint32(stringVector[3]);
        else if (isHexString(stringVector[3]))
            ip4Addr = strtoul(stringVector[3].c_str(), &pEnd, 16);
        else
            ip4Addr = strtoul(stringVector[3].c_str(), &pEnd, 10);
        gHostIp4Addr = ip4Addr;
        // Retrieve the current foreign TCP-Port to set
        unsigned int tcpPort;
        if (isHexString(stringVector[4]))
            tcpPort = strtoul(stringVector[4].c_str(), &pEnd, 16);
        else
            tcpPort = strtoul(stringVector[4].c_str(), &pEnd, 10);
        gHostLsnPort = tcpPort;
        SockAddr newHostServerSocket(gHostIp4Addr, gHostLsnPort);
        printInfo(callerName, "Setting current host server socket to be: \n");
        printSockAddr(callerName, newHostServerSocket);
    }
    return;
}
 
 
void cmdTestCommandParser(const char *callerName, vector<string> stringVector) {
    //-- RECEIVE CHECKERS -------------
    if (stringVector[2] == "RcvdIp4Packet") {
        if (stringVector[3] == "false") {
            gTest_RcvdIp4Packet = false;
            printWarn(callerName, "Disabling receive IPv4 checker.\n");
        }
        else {
            gTest_RcvdIp4Packet = true;
            printWarn(callerName, "Enabling  receive IPv4 checker.\n");
        }
    }
    else if (stringVector[2] == "RcvdIp4TotLen") {
        if (stringVector[3] == "false") {
            gTest_RcvdIp4TotLen = false;
            printWarn(callerName, "Disabling receive IPv4-Total-Length checker.\n");
        }
        else {
            gTest_RcvdIp4HdrCsum = true;
            printWarn(callerName, "Enabling  receive IPv4-Total_Length checker.\n");
        }
    }
    else if (stringVector[2] == "RcvdIp4HdrCsum") {
        if (stringVector[3] == "false") {
            gTest_RcvdIp4HdrCsum = false;
            printWarn(callerName, "Disabling receive IPv4-Header-Checksum checker.\n");
        }
        else {
            gTest_RcvdIp4HdrCsum = true;
            printWarn(callerName, "Enabling  receive IPv4-Header-Checksum checker.\n");
        }
    }
    else if (stringVector[2] == "RcvdUdpLen") {
        if (stringVector[3] == "false") {
            gTest_RcvdUdpLen = false;
            printWarn(callerName, "Disabling receive UDP-Length Checker.\n");
        }
        else {
            gTest_RcvdUdpLen = true;
            printWarn(callerName, "Enabling  receive IPv4-Header-Checksum checker.\n");
        }
    }
    else if (stringVector[2] == "RcvdLy4Csum") {
        if (stringVector[3] == "false") {
            gTest_RcvdLy4Csum = false;
            printWarn(callerName, "Disabling receive TCP|UDP-Checksum checker.\n");
        }
        else {
            gTest_RcvdUdpLen = true;
            printWarn(callerName, "Enabling  receive TCP|UDP-Checksum checker.\n");
        }
    }
    //-- SEND CHECKERS ----------------
    if (stringVector[2] == "SentIp4TotLen") {
        if (stringVector[3] == "false") {
            gTest_SentIp4TotLen = false;
            printWarn(callerName, "Disabling send IPv4-Total-Length checker.\n");
        }
        else {
            gTest_SentIp4HdrCsum = true;
            printWarn(callerName, "Enabling  send IPv4-Total_Length checker.\n");
        }
    }
    else if (stringVector[2] == "SentIp4HdrCsum") {
        if (stringVector[3] == "false") {
            gTest_SentIp4HdrCsum = false;
            printWarn(callerName, "Disabling send IPv4-Header-Checksum checker.\n");
        }
        else {
            gTest_SentIp4HdrCsum = true;
            printWarn(callerName, "Enabling  send IPv4-Header-Checksum checker.\n");
        }
    }
    else if (stringVector[2] == "SentUdpLen") {
        if (stringVector[3] == "false") {
            gTest_SentUdpLen = false;
            printWarn(callerName, "Disabling send UDP-Length Checker.\n");
        }
        else {
            gTest_SentUdpLen = true;
            printWarn(callerName, "Enabling  send IPv4-Header-Checksum checker.\n");
        }
    }
    else if (stringVector[2] == "SentLy4Csum") {
        if (stringVector[3] == "false") {
            gTest_SentLy4Csum = false;
            printWarn(callerName, "Disabling send TCP|UDP-Checksum checker.\n");
        }
        else {
            gTest_SentUdpLen = true;
            printWarn(callerName, "Enabling  send TCP|UDP-Checksum checker.\n");
        }
    }
    return;
}
 
 
 
int pIPRX_InjectAckNumber(
        SimIp4Packet                   &ipRxPacket,
        map<SocketPair, TcpAckNum>     &sessAckList)
{
    const char *myName  = concat3(THIS_NAME, "/", "IPRX/InjectAck");
 
    SockAddr  srcSock = SockAddr(ipRxPacket.getIpSourceAddress(),
                                 ipRxPacket.getTcpSourcePort());
    SockAddr  dstSock = SockAddr(ipRxPacket.getIpDestinationAddress(),
                                 ipRxPacket.getTcpDestinationPort());
    SocketPair newSockPair = SocketPair(srcSock, dstSock);
 
    if (ipRxPacket.isSYN()) {
        // This packet is a SYN and there's no need to inject anything
        if (DEBUG_LEVEL & TRACE_IPRX) { printInfo(myName, "Packet is SYN\n"); }
        if (sessAckList.find(newSockPair) != sessAckList.end()) {
            printWarn(myName, "Trying to open an existing session !\n");
            printSockPair(myName, newSockPair);
            return -1;
        }
        else {
            // Let's check the pseudo-header checksum of the packet
            int computedCsum = ipRxPacket.tcpRecalculateChecksum();
            int embeddedCsum = ipRxPacket.getTcpChecksum();
            if (computedCsum != embeddedCsum) {
                printError(myName, "WRONG PSEUDO-HEADER CHECKSUM (0x%4.4X) - Expected 0x%4.4X \n",
                           embeddedCsum, byteSwap16(computedCsum).to_uint());
                return -1;
            }
            else {
                // Create a new entry (with TcpAckNum=0) in the session table
                sessAckList[newSockPair] = 0;
                if (DEBUG_LEVEL & TRACE_IPRX) {
                    printInfo(myName, "Successfully opened a new session for connection:\n");
                    printSockPair(myName, newSockPair);
                }
                return 0;
            }
        }
    }
    else if (ipRxPacket.isACK()) {
        // This packet is an ACK and we must update the its acknowledgment number
        if (DEBUG_LEVEL & TRACE_IPRX) { printInfo(myName, "Packet is ACK\n"); }
        if (sessAckList.find(newSockPair) != sessAckList.end()) {
            // Inject the oldest acknowledgment number in the ACK number field
            TcpAckNum newAckNum = sessAckList[newSockPair];
            ipRxPacket.setTcpAcknowledgeNumber(newAckNum);
            if (DEBUG_LEVEL & TRACE_IPRX)
                printInfo(myName, "Setting the TCP Acknowledge of this segment to: %u (0x%8.8X) \n",
                          newAckNum.to_uint(), byteSwap32(newAckNum).to_uint());
            // Recalculate and update the checksum
            int oldCsum = ipRxPacket.getTcpChecksum();
            int newCsum = ipRxPacket.tcpRecalculateChecksum();
            if (DEBUG_LEVEL & TRACE_IPRX)
                printInfo(myName, "Updating the checksum of this packet from 0x%4.4X to 0x%4.4X\n",
                          oldCsum, newCsum);
            if (DEBUG_LEVEL & TRACE_IPRX) { ipRxPacket.printRaw(myName); }
            return 1;
        }
        else {
            printWarn(myName, "Trying to send data to a non-existing session! \n");
            return -1;
        }
    }
    return -1;
} // End of: injectAckNumber()
 
 
 
void pIPRX_FeedTOE(
        deque<SimIp4Packet>         &ipRxPacketizer,
        int                         &ipRxPktCounter,
        stream<AxisIp4>             &soTOE_Data,
        map<SocketPair, TcpAckNum>  &sessAckList)
{
    const char *myName = concat3(THIS_NAME, "/", "IPRX/FeedToe");
 
    if (ipRxPacketizer.size() != 0) {
        // Insert proper ACK Number in packet at the head of the queue
        pIPRX_InjectAckNumber(ipRxPacketizer[0], sessAckList);
        // Assert proper SEQ Number in packet
        // [TODO]
        if (DEBUG_LEVEL & TRACE_IPRX) {
            ipRxPacketizer[0].printHdr(myName);
        }
        // Write stream IPRX->TOE
        int noPackets= ipRxPacketizer.size();
        for (int p=0; p<noPackets; p++) {
            SimIp4Packet ipRxPacket = ipRxPacketizer.front();
            AxisIp4 ip4Chunk;
            do {
                ip4Chunk = ipRxPacket.pullChunk();
                if (not soTOE_Data.full()) {
                    soTOE_Data.write(ip4Chunk);
                }
                else {
                    printFatal(myName, "Cannot write \'soTOE_Data\'. Stream is full!\n");
                }
            } while (!ip4Chunk.getTLast());
            ipRxPktCounter++;
            ipRxPacketizer.pop_front();
        }
    }
}
 
 
 
void pIPRX(
        ifstream                    &ifIPRX_Data,
        ofstream                    &ofTAIF_Gold,
        bool                        &testRxPath,
        int                         &ipRxPktCounter,
        int                         &tcpBytCntr_IPRX_TOE,
        deque<SimIp4Packet>         &ipRxPacketizer,
        map<SocketPair, TcpAckNum>  &sessAckList,
        StsBit                      &piTOE_Ready,
        stream<AxisIp4>             &soTOE_Data)
{
    const char *myName  = concat3(THIS_NAME, "/", "IPRX");
 
    //-- STATIC VARIABLES ------------------------------------------------------
    static bool         iprx_globParseDone  = false;
    static bool         iprx_idlingReq  = false; // Request to idle (.i.e, do not feed TOE's input stream)
    static unsigned int iprx_idleCycReq = 0;     // The requested number of idle cycles
    static unsigned int iprx_idleCycCnt = 0;     // The count of idle cycles
    static unsigned int iprx_toeReadyDelay = 0;  // The time it takes for TOE to be ready
    static int          iprx_inpPackets = 0;     // Counts the number of packets fed to [TOE].
 
    //-- DYNAMIC VARIABLES -----------------------------------------------------
    string              rxStringBuffer;
    vector<string>      stringVector;
 
    //---------------------------------------
    //-- STEP-0 : RETURN IF TOE IS NOT READY
    //---------------------------------------
    if (piTOE_Ready == 0) {
        iprx_toeReadyDelay++;
        return;
    }
 
    //-------------------------------------------------------------------------
    //-- STEP-1: PARSE THE IP RX FILE.
    //     THIS FIRST PASS WILL SPECIFICALLY SEARCH FOR GLOBAL PARAMETERS.
    //-------------------------------------------------------------------------
    if (!iprx_globParseDone) {
        iprx_globParseDone = setGlobalParameters(myName, iprx_toeReadyDelay, ifIPRX_Data);
        if (iprx_globParseDone == false) {
            printInfo(myName, "Aborting testbench (check for previous error).\n");
            exit(1);
        }
        return;
    }
 
    //-----------------------------------------------------
    //-- STEP-2 : ALWAYS FEED the IP Rx INTERFACE
    //-----------------------------------------------------
    // Note: The IPv4 RxPacketizer may contain an ACK packet generated by the
    //  process which emulates the Ip Tx Handler (.i.e, pITPX).
    //  Therefore, we start by flushing these packets (if any) before reading a
    //  new packet from the IP Rx input file.
    //  We also drain any existing packet before emulating the IDLE time.
    pIPRX_FeedTOE(ipRxPacketizer, ipRxPktCounter, soTOE_Data, sessAckList);
 
    //------------------------------------------
    //-- STEP-3 : RETURN IF IDLING IS REQUESTED
    //------------------------------------------
    if (iprx_idlingReq == true) {
        if (iprx_idleCycCnt >= iprx_idleCycReq) {
            iprx_idleCycCnt = 0;
            iprx_idlingReq = false;
        }
        else {
            iprx_idleCycCnt++;
        }
        return;
    }
 
    //-------------------------------------------------------------------------
    //-- STEP-4: QUIT HERE IF RX TEST MODE IS DISABLED OR EOF IS REACHED
    //-------------------------------------------------------------------------
    if ((not testRxPath) || (ifIPRX_Data.eof()))
        return;
 
    //------------------------------------------------------
    //-- STEP-? : [TODO] CHECK IF CURRENT LOCAL SOCKET IS LISTENING
    //------------------------------------------------------
    // SocketPair  currSocketPair(gLocalSocket, currForeignSocket);
    // isOpen = pTAIF_Send_OpenSess(currSocketPair, openSessList, soTOE_OpnReq, siTOE_OpnRep);
    // if (!isOpen)
    //     return;
 
    //-----------------------------------------------------
    //-- STEP-5 : READ THE IP RX FILE
    //-----------------------------------------------------
    do {
        //-- READ A LINE FROM IPRX INPUT FILE -------------
        getline(ifIPRX_Data, rxStringBuffer);
        stringVector = myTokenizer(rxStringBuffer, ' ');
        if (stringVector[0] == "") {
            continue;
        }
        else if (stringVector[0].length() == 1) {
            //------------------------------------------------------
            //-- Process the command and comment lines
            //--  FYI: A command or a comment start with a single
            //--       character followed by a space character.
            //------------------------------------------------------
            if (stringVector[0] == "#") {
                // This is a comment line
                if (DEBUG_LEVEL & TRACE_IPRX) {
                    for (int t=0; t<stringVector.size(); t++) {
                        printf("%s ", stringVector[t].c_str());
                    }
                    printf("\n");
                }
                continue;
            }
            else if (stringVector[0] == "G") {
                // We can skip all the global parameters as they were already parsed.
                continue;
            }
            else if (stringVector[0] == ">") {
                // The test vector is issuing a command
                //  FYI, don't forget to return at the end of command execution.
                if (stringVector[1] == "IDLE") {
                    // COMMAND = Request to idle for <NUM> cycles.
                    iprx_idleCycReq = atoi(stringVector[2].c_str());
                    iprx_idlingReq = true;
                    if (DEBUG_LEVEL & TRACE_IPRX) {
                        printInfo(myName, "Request to idle for %d cycles. \n", iprx_idleCycReq);
                    }
                    increaseSimTime(iprx_idleCycReq);
                    return;
                }
                if (stringVector[1] == "SET") {
                    cmdSetCommandParser(myName, stringVector);
                    return;
                }
                if (stringVector[1] == "TEST") {
                    cmdTestCommandParser(myName, stringVector);
                    return;
                }
                else {
                    printFatal(myName, "Read unknown command \"> %s\".\n", stringVector[1].c_str());
                }
            }
        }
        else if (ifIPRX_Data.fail() == 1 || rxStringBuffer.empty()) {
            return;
        }
        else {
            SimIp4Packet ipRxPacket;
            AxisIp4      ipRxChunk;
            bool         firstChunkFlag = true; // Flags the first chunk of a packet
            // Build a new packet from data file
            do {
                if (firstChunkFlag == false) {
                    getline(ifIPRX_Data, rxStringBuffer);
                    stringVector = myTokenizer(rxStringBuffer, ' ');
                }
                if (stringVector[0] == "#") {
                    // This is a comment line
                    if (DEBUG_LEVEL & TRACE_IPRX) {
                        for (int t=0; t<stringVector.size(); t++) {
                            printf("%s ", stringVector[t].c_str());
                        }
                        printf("\n");
                    }
                    continue;
                }
                firstChunkFlag = false;
                bool rc = readAxisRawFromLine(ipRxChunk, rxStringBuffer);
                if (rc) {
                    ipRxPacket.pushChunk(ipRxChunk);
                    increaseSimTime(1);
                }
            } while (not ipRxChunk.getTLast());
            iprx_inpPackets++;
 
            // Check consistency of the assembled packet
            bool wellFormed = ipRxPacket.isWellFormed(myName,
                                     gTest_RcvdIp4TotLen, gTest_RcvdIp4HdrCsum,
                                     gTest_RcvdUdpLen,    gTest_RcvdLy4Csum);
            if (not wellFormed)  {
                printFatal(myName, "IP packet #%d is malformed!\n", iprx_inpPackets);
            }
            else {
                // Count the number of data bytes contained in the TCP payload
                tcpBytCntr_IPRX_TOE += ipRxPacket.sizeOfTcpData();
                // Write to the Application Tx Gold file
                if (gTest_RcvdIp4Packet) {
                    ipRxPacket.writeTcpDataToDatFile(ofTAIF_Gold);
                }
                // Push that packet into the packetizer queue and feed the TOE
                ipRxPacketizer.push_back(ipRxPacket);
                pIPRX_FeedTOE(ipRxPacketizer, ipRxPktCounter, soTOE_Data, sessAckList);
            }
            return;
        }
 
    } while(!ifIPRX_Data.eof());
 
} // End of: pIPRX
 
 
 
bool pIPTX_Parse(
        SimIp4Packet                &ipTxPacket,
        map<SocketPair, TcpAckNum>  &sessAckList,
        deque<SimIp4Packet>         &ipRxPacketizer)
{
    bool        returnValue    = false;
    bool        isFinAck       = false;
    bool        isSynAck       = false;
    static int  currAckNum     = 0;
 
    const char *myName = concat3(THIS_NAME, "/", "IPTX/Parse");
 
    if (DEBUG_LEVEL & TRACE_IPTX) {
        ipTxPacket.printHdr(myName);
    }
 
    if (ipTxPacket.isSYN() and !ipTxPacket.isACK()) {
        //------------------------------------------------------
        // This is a SYN segment. Reply with a SYN+ACK packet.
        //------------------------------------------------------
        if (DEBUG_LEVEL & TRACE_IPTX) {
            printInfo(myName, "Got a SYN from TOE. Replying with a SYN+ACK.\n");
        }
        SimIp4Packet synAckPacket;
        synAckPacket.clone(ipTxPacket);
        // Swap IP_SA and IP_DA
        synAckPacket.setIpDestinationAddress(ipTxPacket.getIpSourceAddress());
        synAckPacket.setIpSourceAddress(ipTxPacket.getIpDestinationAddress());
        // Swap TCP_SP and TCP_DP
        synAckPacket.setTcpDestinationPort(ipTxPacket.getTcpSourcePort());
        synAckPacket.setTcpSourcePort(ipTxPacket.getTcpDestinationPort());
        // Set the SEQ to zero (for simplicity) and ACK to (received SEQ+1)
        synAckPacket.setTcpSequenceNumber(0);
        synAckPacket.setTcpAcknowledgeNumber(ipTxPacket.getTcpSequenceNumber() + 1);
        // Set the ACK bit and Recalculate the Checksum
        synAckPacket.setTcpControlAck(1);
        int newTcpCsum = synAckPacket.tcpRecalculateChecksum();
        synAckPacket.setTcpChecksum(newTcpCsum);
        // Add the created SYN+ACK packet to the ipRxPacketizer
        ipRxPacketizer.push_back(synAckPacket);
    }
    else if (ipTxPacket.isFIN() and !ipTxPacket.isACK()) {
        //------------------------------------------------------
        // This is a FIN segment. Close the connection.
        //------------------------------------------------------
        // Retrieve the initial socket pair information.
        // Note how we call the constructor with swapped source and destination.
        // Destination is now the former source and vice-versa.
        SockAddr  srcSock = SockAddr(ipTxPacket.getIpSourceAddress(),
                                     ipTxPacket.getTcpSourcePort());
        SockAddr  dstSock = SockAddr(ipTxPacket.getIpDestinationAddress(),
                                     ipTxPacket.getTcpDestinationPort());
        SocketPair sockPair(dstSock, srcSock);
        if (DEBUG_LEVEL & TRACE_IPTX) {
            printInfo(myName, "Got a FIN from TOE. Closing the following connection:\n");
            printSockPair(myName, sockPair);
        }
        // Erase the socket pair for this session from the map.
        sessAckList.erase(sockPair);
    }
    else if (ipTxPacket.isACK()) {
        //---------------------------------------
        // This is an ACK segment.
        //---------------------------------------
        returnValue = true;
        // Retrieve IP packet length and TCP sequence numbers
        int ip4PktLen  = ipTxPacket.getIpTotalLength();
        int nextAckNum = ipTxPacket.getTcpSequenceNumber();
        currAckNum     = ipTxPacket.getTcpAcknowledgeNumber();
        // Retrieve the initial socket pair information.
        // Note how we call the constructor with swapped source and destination.
        // Destination is now the former source and vice-versa.
        SockAddr  srcSock = SockAddr(ipTxPacket.getIpSourceAddress(),
                                     ipTxPacket.getTcpSourcePort());
        SockAddr  dstSock = SockAddr(ipTxPacket.getIpDestinationAddress(),
                                     ipTxPacket.getTcpDestinationPort());
        SocketPair sockPair(dstSock, srcSock);
 
        if (ipTxPacket.isFIN() and !ipTxPacket.isSYN()) {
            // The FIN bit is also set
            nextAckNum++;  // A FIN consumes 1 sequence #
            if (DEBUG_LEVEL & TRACE_IPTX)
               printInfo(myName, "Got a FIN+ACK from TOE.\n");
        }
        else if (ipTxPacket.isSYN() and !ipTxPacket.isFIN()) {
            // The SYN bit is also set
            nextAckNum++;  // A SYN consumes 1 sequence #
            if (DEBUG_LEVEL & TRACE_IPTX)
                printInfo(myName, "Got a SYN+ACK from TOE.\n");
        }
        else if (ipTxPacket.isFIN() and ipTxPacket.isSYN()) {
             printError(myName, "Got a SYN+FIN+ACK from TOE.\n");
             // [FIXME - MUST CREATE AND INCREMENT A GLOBAL ERROR COUNTER]
        }
        else if (ip4PktLen >= 40) {
            // Decrement by 40B (.i.e, 20B of IP Header + 20B of TCP Header
            // [FIXME - What if we add options???]
            // [TODO - Print the TCP options ]
            ip4PktLen -= 40;
            nextAckNum += ip4PktLen;
        }
 
        // Update the Session List with the new sequence number
        sessAckList[sockPair] = nextAckNum;
        if (ipTxPacket.isFIN()) {
            //------------------------------------------------
            // This is an ACK+FIN segment.
            //------------------------------------------------
            isFinAck = true;
            if (DEBUG_LEVEL & TRACE_IPTX)
                printInfo(myName, "Got an ACK+FIN from TOE.\n");
            // Erase this session from the list
            int itemsErased = sessAckList.erase(sockPair);
            if (itemsErased != 1) {
                printError(myName, "Received a ACK+FIN segment for a non-existing session. \n");
                printSockPair(myName, sockPair);
                // [FIXME - MUST CREATE AND INCREMENT A GLOBAL ERROR COUNTER]
            }
            else {
                if (DEBUG_LEVEL & TRACE_IPTX) {
                    printInfo(myName, "Connection was successfully closed.\n");
                    printSockPair(myName, sockPair);
                }
            }
        } // End of: isFIN
        if (ip4PktLen > 0 and !isFinAck) {
            //--------------------------------------------------------
            // ACK segment contains more data and is not a FIN+ACK.
            // Reply with an empty ACK packet.
            //--------------------------------------------------------
            SimIp4Packet ackPacket(40);  // [FIXME - What if we generate options ???]
            // [TODO - Add TCP Window option]
            // Set IP protocol field to TCP
            ackPacket.setIpProtocol(IP4_PROT_TCP);
            // Swap IP_SA and IP_DA
            ackPacket.setIpDestinationAddress(ipTxPacket.getIpSourceAddress());
            ackPacket.setIpSourceAddress(ipTxPacket.getIpDestinationAddress());
            // Swap TCP_SP and TCP_DP
            ackPacket.setTcpDestinationPort(ipTxPacket.getTcpSourcePort());
            ackPacket.setTcpSourcePort(ipTxPacket.getTcpDestinationPort());
            // Swap the SEQ and ACK Numbers while incrementing the ACK
            ackPacket.setTcpSequenceNumber(currAckNum);
            ackPacket.setTcpAcknowledgeNumber(nextAckNum);
            // Set the ACK bit and un-set the FIN bit
            ackPacket.setTcpControlAck(1);
            ackPacket.setTcpControlFin(0);
            // Set the Window size
            ackPacket.setTcpWindow(7777);
            // Recalculate the Checksum
            int newTcpCsum = ackPacket.tcpRecalculateChecksum();
            ackPacket.setTcpChecksum(newTcpCsum);
            // Add the created ACK packet to the ipRxPacketizer
            ipRxPacketizer.push_back(ackPacket);
            currAckNum = nextAckNum;
        }
    }
    return returnValue;
} // End of: pIPTX_Parse()
 
 
 
void pIPTX(
        StsBit                      &piTOE_Ready,
        stream<AxisIp4>             &siTOE_Data,
        ofstream                    &ofIPTX_Data1,
        ofstream                    &ofIPTX_Data2,
        map<SocketPair, TcpAckNum>  &sessAckList,
        int                         &pktCounter_TOE_IPTX,
        int                         &tcpBytCntr_TOE_IPTX,
        deque<SimIp4Packet>         &ipRxPacketizer)
{
    const char *myName  = concat3(THIS_NAME, "/", "IPTX");
 
    //-- STATIC VARIABLES ------------------------------------------------------
    static SimIp4Packet iptx_ipPacket;
    static int          iptx_rttSim = RTT_LINK;
    // [TODO] static ap_shift_reg<SimIp4Packet, RTT_LINK> rttPktBuffer; // A shift reg. holding RTT packets
 
 
    //-- DYNAMIC VARIABLES -----------------------------------------------------
    AxisIp4     ipTxChunk;  // An IP4 chunk
    uint16_t    ipTxChunkCounter = 0;
 
    //---------------------------------------
    //-- STEP-0 : RETURN IF TOE IS NOT READY
    //---------------------------------------
    if (piTOE_Ready == 0) {
        return;
    }
 
    if (!siTOE_Data.empty()) {
        //---------------------------------
        //-- STEP-0 : Emulate the link RTT [FIXME - Move before '!siTOE_Data.empty()' check
        //---------------------------------
        if (iptx_rttSim) {
            iptx_rttSim--;
            return;
        }
        //--------------------------
        //-- STEP-1 : Drain the TOE
        //--------------------------
        siTOE_Data.read(ipTxChunk);
        if (DEBUG_LEVEL & TRACE_IPTX) {
            printAxisRaw(myName, ipTxChunk);
        }
        //----------------------------
        //-- STEP-2 : Write to packet
        //----------------------------
        iptx_ipPacket.pushChunk(ipTxChunk);
 
        //--------------------------------------
        //-- STEP-3 : Parse the received packet
        //--------------------------------------
        if (ipTxChunk.getTLast()) {
            // The whole packet is now into the deque. Check its consistency
            // except for the IPv4-Header-Checksum which will be computed and
            // inserted later by IPTX.
            if (not iptx_ipPacket.isWellFormed(myName, gTest_SentIp4TotLen, false,
                                                       gTest_SentUdpLen,    gTest_SentLy4Csum)) {
                printFatal(myName, "IP packet #%d is malformed!\n", pktCounter_TOE_IPTX);
            }
            if (pIPTX_Parse(iptx_ipPacket, sessAckList, ipRxPacketizer) == true) {
                // Found an ACK
                pktCounter_TOE_IPTX++;
                int tcpPayloadSize = iptx_ipPacket.sizeOfTcpData();
                if (tcpPayloadSize) {
                    tcpBytCntr_TOE_IPTX += tcpPayloadSize;
                    // Write to the IP Tx Gold file
                    iptx_ipPacket.writeTcpDataToDatFile(ofIPTX_Data2);
                }
            }
            // Clear the chunk counter and the received IP packet
            ipTxChunkCounter = 0;
            iptx_ipPacket.clear();
            // Re-initialize the RTT counter
            iptx_rttSim = RTT_LINK;
        }
        else
            ipTxChunkCounter++;
 
        //--------------------------
        //-- STEP-4 : Write to file
        //--------------------------
        int writtenBytes = writeAxisRawToFile(ipTxChunk, ofIPTX_Data1);
    }
} // End of: pIPTX
 
 
 
bool pTcpAppListen(
        TcpPort               lsnPortNum,
        set<TcpPort>          &openedPorts,
        stream<TcpAppLsnReq>  &soTOE_LsnReq,
        stream<TcpAppLsnRep>  &siTOE_LsnRep)
{
    const char *myName  = concat3(THIS_NAME, "/", "Tal");
 
    //-- STATIC VARIABLES ------------------------------------------------------
    static ap_uint<1> tal_fsmState = 0;
    static TcpPort    tal_portNum;
    static int        tal_watchDogTimer = 100;
 
    //-- DYNAMIC VARIABLES -----------------------------------------------------
    StsBool           rc = STS_KO;
 
    switch (tal_fsmState) {
    case 0:
        tal_portNum = lsnPortNum;
        soTOE_LsnReq.write(tal_portNum);
        if (DEBUG_LEVEL & TRACE_Tal) {
            printInfo(myName, "Request to listen on port %d (0x%4.4X).\n",
                      tal_portNum.to_uint(), tal_portNum.to_uint());
        }
        tal_watchDogTimer = 100;
        tal_fsmState++;
        break;
    case 1:
        tal_watchDogTimer--;
        if (!siTOE_LsnRep.empty()) {
            siTOE_LsnRep.read(rc);
            if (rc) {
                // Add the current port # to the set of opened ports
                openedPorts.insert(tal_portNum);
                if (DEBUG_LEVEL & TRACE_Tal) {
                    printInfo(myName, "TOE is now listening on port %d (0x%4.4X).\n",
                              tal_portNum.to_uint(), tal_portNum.to_uint());
                }
            }
            else {
                printWarn(myName, "TOE denied listening on port %d (0x%4.4X).\n",
                          tal_portNum.to_uint(), tal_portNum.to_uint());
            }
            tal_fsmState = 0;
        }
        else {
            if (tal_watchDogTimer == 0) {
                printError(myName, "Timeout: Failed to listen on port %d (0x%4.4X).\n",
                           tal_portNum.to_uint(), tal_portNum.to_uint());
                tal_fsmState = 0;
            }
        }
        break;
    }
    return rc;
}
 
 
 
bool pTcpAppConnect(
        int                         &nrError,
        SocketPair                  &aSocketPair,
        map<SocketPair, SessionId>  &openSessList,
        stream<SockAddr>            &soTOE_OpnReq,
        stream<TcpAppOpnRep>        &siTOE_OpnRep)
{
    const char *myName  = concat3(THIS_NAME, "/", "Tac");
 
    //-- STATIC VARIABLES ------------------------------------------------------
    static int tac_watchDogTimer = FPGA_CLIENT_CONNECT_TIMEOUT;
    // A set to keep track of the ports opened in transmission mode
    static TcpPort      tac_ephemeralPortCounter = TOE_FIRST_EPHEMERAL_PORT_NUM;
    static set<TcpPort> tac_dynamicPorts;
    static int          tac_fsmState = 0;
 
    //-- DYNAMIC VARIABLES -----------------------------------------------------
    bool rc = false;
    // Prepare to open a new connection
    SockAddr hostServerSocket(SockAddr(aSocketPair.dst.addr, aSocketPair.dst.port));
 
    switch (tac_fsmState) {
    case 0:
        // Let's search for an unused ephemeral port
        if (tac_dynamicPorts.empty()) {
            aSocketPair.src.port = tac_ephemeralPortCounter;
            tac_ephemeralPortCounter++;
        }
        else {
            do {
                aSocketPair.src.port = tac_ephemeralPortCounter;
                tac_ephemeralPortCounter++;
            } while(tac_dynamicPorts.find(aSocketPair.src.port) != tac_dynamicPorts.end());
        }
        soTOE_OpnReq.write(hostServerSocket);
        if (DEBUG_LEVEL & TRACE_Tac) {
            printInfo(myName, "The FPGA client is requesting to connect to the following HOST socket: \n");
            printSockAddr(myName, hostServerSocket);
        }
        tac_watchDogTimer = FPGA_CLIENT_CONNECT_TIMEOUT;
        tac_fsmState++;
        rc = false;
        break;
    case 1:
        tac_watchDogTimer--;
        if (!siTOE_OpnRep.empty()) {
            TcpAppOpnRep appOpenRep = siTOE_OpnRep.read();
            if(appOpenRep.tcpState == ESTABLISHED) {
                // Create a new entry in the list of established sessions
                openSessList[aSocketPair] = appOpenRep.sessId;
                if (DEBUG_LEVEL & TRACE_Tac) {
                    printInfo(myName, "Successfully opened a new active session (%d) for connection:\n", appOpenRep.sessId.to_int());
                    printSockPair(myName, aSocketPair);
                }
                // Add this port # to the set of opened ports
                tac_dynamicPorts.insert(aSocketPair.src.port);
                // Check maximum number of opened sessions
                if (tac_ephemeralPortCounter-0x8000 > TOE_MAX_SESSIONS) {
                    printError(myName, "Trying to open too many FPGA client sessions. Max. is %d.\n", TOE_MAX_SESSIONS);
                    nrError += 1;
                }
                rc = true;
            }
            else {
                printError(myName, "Failed to open a new active session (%d).\n", appOpenRep.sessId.to_uint());
                printInfo(myName, "The connection is in TCP state: %s.\n", getTcpStateName(appOpenRep.tcpState));
                rc = false;
                nrError += 1;
            }
            tac_fsmState = 0;
        }
        else {
            if (tac_watchDogTimer == 0) {
                printError(myName, "Timeout: Failed to open the following FPGA client session:\n");
                printSockPair(myName, aSocketPair);
                nrError += 1;
                tac_fsmState = 0;
                rc = false;
            }
        }
        break;
    } // End Of: switch
    return rc;
} // End-of: Tac
 
 
 
void pTcpAppEcho(
        int                     &nrError,
        ofstream                &ofIPTX_Gold2,
        int                     &apRxBytCntr,
        stream<TcpAppData>      &soTOE_Data,
        stream<TcpAppSndReq>    &soTOE_SndReq,
        stream<TcpAppSndRep>    &siTOE_SndRep,
        stream<TcpAppData>      &siTAr_Data,
        stream<TcpAppSndReq>    &siTAr_SndReq)
{
    const char *myName  = concat3(THIS_NAME, "/", "Tae");
 
    //-- STATIC VARIABLES ------------------------------------------------------
    static enum FsmStates { IDLE=0, START_OF_SEGMENT,
                            CONTINUATION_OF_SEGMENT } tae_fsmState = IDLE;
    static int  tae_mssCounter = 0; // Maximum Segment Size counter
 
    //-- DYNAMIC VARIABLES -----------------------------------------------------
    TcpAppData   appChunk;
    TcpAppSndReq appSndReq;
 
    switch (tae_fsmState) {
    case IDLE:
        if ( !siTAr_SndReq.empty() and !soTOE_SndReq.full()) {
            //-- Forward the send request received from [TAr]
            siTAr_SndReq.read(appSndReq);
            soTOE_SndReq.write(appSndReq);
            tae_fsmState = START_OF_SEGMENT;
        }
        break;
    case START_OF_SEGMENT:
        if (!siTOE_SndRep.empty()) {
            //-- Read the request to send reply and continue accordingly
            TcpAppSndRep appSndRep = siTOE_SndRep.read();
            switch (appSndRep.error) {
            case NO_ERROR:
                tae_fsmState = CONTINUATION_OF_SEGMENT;
                break;
            case NO_SPACE:
                printError(THIS_NAME, "Not enough space for writing %d bytes in the Tx buffer of session #%d. Available space is %d bytes.\n",
                           appSndRep.length.to_uint(), appSndRep.sessId.to_uint(), appSndRep.spaceLeft.to_uint());
                nrError++;
                tae_fsmState = IDLE;
                break;
            case NO_CONNECTION:
                printError(THIS_NAME, "Attempt to write data for a session that is not established.\n");
                nrError++;
                tae_fsmState = IDLE;
                break;
            default:
                printError(THIS_NAME, "Received unknown TCP request to send reply from [TOE].\n");
                nrError++;
                tae_fsmState = IDLE;
                break;
            }
        }
        break;
    case CONTINUATION_OF_SEGMENT:
        if ( !siTAr_Data.empty() and !soTOE_Data.full()) {
            //-- Feed the TOE with the data received from [TAr]
            siTAr_Data.read(appChunk);
            soTOE_Data.write(appChunk);
            apRxBytCntr += writeAxisAppToFile(appChunk, ofIPTX_Gold2, tae_mssCounter);
            if (appChunk.getTLast())
                tae_fsmState = IDLE;
        }
        break;
    } // End-of: switch()
} // End-of: Tae
 
 
void pTAIF_Recv(
        int                     &nrError,
        char                    &testMode,
        ofstream                &ofTAIF_Data,
        int                     &appTxBytCntr,
        StsBit                  &piTOE_Ready,
        stream<TcpAppLsnReq>    &soTOE_LsnReq,
        stream<TcpAppLsnRep>    &siTOE_LsnRep,
        stream<TcpAppNotif>     &siTOE_Notif,
        stream<TcpAppRdReq>     &soTOE_DReq,
        stream<TcpAppData>      &siTOE_Data,
        stream<TcpAppMeta>      &siTOE_Meta,
        stream<TcpAppData>      &soTAs_Data,
        stream<TcpAppSndReq>    &soTAs_SndReq)
{
    const char *myName  = concat3(THIS_NAME, "/", "TAr");
 
    //-- STATIC VARIABLES ------------------------------------------------------
    static bool         tar_idlingReq  = false; // Request to idle (.i.e, do not feed TOE's input stream)
    static unsigned int tar_idleCycReq = 0;     // The requested number of idle cycles
    static unsigned int tar_idleCycCnt = 0;     // The count of idle cycles
    static int          tar_startupDelay = 0;
    static bool         tar_dualTest   = false;
    static int          tar_appRspIdle = 0;
    static ap_uint<32>  tar_mAmount    = 0;
    static set<TcpPort> tar_listeningPorts;  // A set to keep track of the ports opened in listening mode
    static TcpAppNotif  tar_notification;
    static vector<SessionId> tar_txSessIdVector; // A vector containing the Tx session IDs to be send from TAIF/Meta to TOE/Meta
    static enum FsmStates { WAIT_NOTIF=0, SEND_DREQ,
                            WAIT_SEG,     CONSUME } tar_fsmState = WAIT_NOTIF;
 
    //-- DYNAMIC VARIABLES -----------------------------------------------------
    string              rxStringBuffer;
    vector<string>      stringVector;
    TcpAppOpnRep        newConStatus;
    SessionId           tcpSessId;
    AxisApp             currChunk;
 
    //---------------------------------------
    //-- STEP-0 : RETURN IF TOE IS NOT READY
    //---------------------------------------
    if (piTOE_Ready == 0) {
        return;
    }
 
    //------------------------------------------------
    //-- STEP-1 : REQUEST TO LISTEN ON A PORT
    //------------------------------------------------
    // Check if a port is already opened
    if (tar_listeningPorts.find(gFpgaLsnPort) == tar_listeningPorts.end()) {
        bool listenStatus = pTcpAppListen(
                gFpgaLsnPort,
                tar_listeningPorts,
                soTOE_LsnReq,
                siTOE_LsnRep);
        if (listenStatus == false) {
            return;
        }
    }
 
    //------------------------------------------------
    //-- STEP-2 : READ NOTIF and DRAIN TOE-->TAIF
    //------------------------------------------------
    currChunk.setTLast(0);
    switch (tar_fsmState) {
    case WAIT_NOTIF:
        if (!siTOE_Notif.empty()) {
            siTOE_Notif.read(tar_notification);
            if (DEBUG_LEVEL & TRACE_TAr) {
                printInfo(myName, "Received data notification from TOE: (sessId=%d, tcpDataLen=%d) and {IP_SA, TCP_DP} is:\n",
                          tar_notification.sessionID.to_int(), tar_notification.tcpDatLen.to_int());
                printSockAddr(myName, SockAddr(tar_notification.ip4SrcAddr, tar_notification.tcpDstPort));
            }
            tar_appRspIdle = APP_RSP_LATENCY;
            tar_fsmState   = SEND_DREQ;
        }
        break;
    case SEND_DREQ:
        //-- Wait some cycles to match the co-simulation
        if (tar_appRspIdle > 0) {
            tar_appRspIdle--;
        }
        else if (!soTOE_DReq.full()) {
            if (tar_notification.tcpDatLen != 0) {
                soTOE_DReq.write(TcpAppRdReq(tar_notification.sessionID,
                                             tar_notification.tcpDatLen));
                tar_fsmState = WAIT_SEG;
            }
            else {
                printWarn(myName, "Received a data notification of length \'0\'. Please double check!!!\n");
                nrError += 1;
                tar_fsmState = WAIT_NOTIF;
            }
        }
        break;
    case WAIT_SEG:  // Wait for start of new segment
        switch (testMode) {
        case RX_MODE:
            if (!siTOE_Meta.empty()) {
                // Read the TCP session ID
                siTOE_Meta.read(tcpSessId);
                tar_fsmState = CONSUME;
            }
            break;
        case ECHO_MODE: // Forward sessId and data length a send request to TAIF_Send (Snd) process
            if (!siTOE_Meta.empty() and !soTAs_SndReq.full()) {
                siTOE_Meta.read(tcpSessId);
                soTAs_SndReq.write(TcpAppSndReq(tcpSessId, tar_notification.tcpDatLen));
                tar_fsmState = CONSUME;
            }
            break;
        default:
            printFatal(myName, "Aborting testbench (The code should never end-up here).\n");
            break;
        } // End-of switch(testMode)
        break;
    case CONSUME:  // Read all the remaining TCP data chunks
        switch (testMode) {
        case RX_MODE:  // Dump incoming data to file
            if (!siTOE_Data.empty()) {
                siTOE_Data.read(currChunk);
                appTxBytCntr += writeAxisAppToFile(currChunk, ofTAIF_Data);
                // Consume incoming stream until LAST bit is set
                if (currChunk.getTLast() == 1)
                    tar_fsmState = WAIT_NOTIF;
            }
            break;
        case ECHO_MODE: // Forward incoming data to the TcpAppSend process (TAs)
            if (!siTOE_Data.empty() and !soTAs_Data.full()) {
                siTOE_Data.read(currChunk);
                soTAs_Data.write(currChunk);
                appTxBytCntr += writeAxisAppToFile(currChunk, ofTAIF_Data);
                // Consume until LAST bit is set
                if (currChunk.getTLast() == 1) {
                    tar_fsmState = WAIT_NOTIF;
                }
            }
            break;
        default:
            printFatal(myName, "Aborting testbench (The code should never end-up here).\n");
            break;
        } // End-of switch(testMode)
        break;
    }
 
} // End of: pTAr
 
 
void pTAIF_Send(
        int                     &nrError,
        char                    &testMode,
        bool                    &testTxPath,
        Ip4Address              &toeIpAddress,
        ifstream                &ifTAIF_Data,
        ofstream                &ofIPTX_Gold2,
        int                     &apRxBytCntr,
        StsBit                  &piTOE_Ready,
        stream<TcpAppOpnReq>    &soTOE_OpnReq,
        stream<TcpAppOpnRep>    &siTOE_OpnRep,
        stream<TcpAppData>      &soTOE_Data,
        stream<TcpAppSndReq>    &soTOE_SndReq,
        stream<TcpAppSndRep>    &siTOE_SndRep,
        stream<TcpAppClsReq>    &soTOE_ClsReq,
        stream<TcpAppData>      &siTAr_Data,
        stream<TcpAppSndReq>    &siTAr_SndReq)
{
    const char *myName  = concat3(THIS_NAME, "/", "TAs");
 
    //-- STATIC VARIABLES ------------------------------------------------------
    static bool         tas_globParseDone   = false;
    static bool         tas_appTxIdlingReq  = false; // Request to idle (i.e., do not feed TOE's input stream)
    static unsigned int tas_appTxIdleCycReq = 0;  // The requested number of idle cycles
    static unsigned int tas_appTxIdleCycCnt = 0;  // The count of idle cycles
    static unsigned int tas_toeReadyDelay   = 0;  // The time it takes for TOE to be ready
    static vector<SessionId> tas_txSessIdVector;  // A vector containing the Tx session IDs to be send from TAIF/Meta to TOE/Meta
    static map<SocketPair, SessionId> tas_openSessList; // Keeps track of the sessions opened by the TOE
    static bool         tas_clearToSend = false;
    static SimAppData   tas_simAppData;
 
    //-- DYNAMIC VARIABLES -----------------------------------------------------
    string              rxStringBuffer;
    vector<string>      stringVector;
    TcpAppOpnRep        newConStatus;
    bool                done;
    char               *pEnd;
 
    //----------------------------------------
    //-- STEP-1 : RETURN IF TOE IS NOT READY
    //----------------------------------------
    if (piTOE_Ready == 0) {
        tas_toeReadyDelay++;
        return;
    }
 
    //------------------------------------------------------
    //-- STEP-1 : ARE WE ASKED TO OPEN A NEW CONNECTION
    //------------------------------------------------------
    SockAddr   fpgaClientSocket(gFpgaIp4Addr, gFpgaSndPort);
    SockAddr   hostServerSocket(gHostIp4Addr, gHostLsnPort);
    SocketPair currSocketPair(fpgaClientSocket, hostServerSocket);
    // Open current session if it does not yet exist
    if (tas_openSessList.find(currSocketPair) == tas_openSessList.end()) {
         // Let's open a new session
        done = pTcpAppConnect(
                nrError,
                currSocketPair,
                tas_openSessList,
                soTOE_OpnReq,
                siTOE_OpnRep);
        if (!done) {
            // The open session is not yet completed
            return;
        }
    }
 
    //-------------------------------------------------------------
    //-- STEP-2a : IMMEDIATELY QUIT IF TX TEST MODE IS NOT ENABLED
    //-------------------------------------------------------------
    if (not testTxPath)
        return;
 
    //-----------------------------------------------------
    //-- STEP-2b : ALSO RETURN IF IDLING IS REQUESTED
    //-----------------------------------------------------
    if (tas_appTxIdlingReq == true) {
        if (tas_appTxIdleCycCnt >= tas_appTxIdleCycReq) {
            tas_appTxIdleCycCnt = 0;
            tas_appTxIdlingReq = false;
            if (DEBUG_LEVEL & TRACE_TAs) {
                printInfo(myName, "End of APP Tx idling phase. \n");
            }
        }
        else {
            tas_appTxIdleCycCnt++;
        }
        return;
    }
 
    //----------------------------------------------------------------
    //-- STEP-3 : SHORT EXECUTION PATH WHEN TestingMode == ECHO_MODE
    //----------------------------------------------------------------
    if (testMode == ECHO_MODE) {
        pTcpAppEcho(
                nrError,
                ofIPTX_Gold2,
                apRxBytCntr,
                soTOE_Data,
                soTOE_SndReq,
                siTOE_SndRep,
                siTAr_Data,
                siTAr_SndReq);
        return;
    }
 
    //------------------------------------------------------
    //-- STEP-4 : HANDLE THE SEND REPLY INTERFACE
    //------------------------------------------------------
    if (!siTOE_SndRep.empty()) {
        TcpAppSndRep appSndRep = siTOE_SndRep.read();
        TcpAppSndErr rc = appSndRep.error;
        switch (rc) {
            case NO_ERROR:
                tas_clearToSend = true;
                break;
            case NO_CONNECTION: // [FIXME-Must handle this scenario]
                printFatal(myName, "Attempt to write data for session %d which is not established.\n", appSndRep.sessId.to_uint());
                nrError++;
                break;
            case NO_SPACE: // [FIXME-Must handle this scenario]
                printFatal(myName, "There is not enough TxBuf memory space available for session %d.\n",
                           appSndRep.sessId.to_uint());
                nrError++;
                break;
            default:
                printFatal(myName, "Received unknown reply error (%d) from [TOE].\n", rc);
                nrError++;
                break;
        }
    }
 
    //------------------------------------------------------
    //-- STEP-5 : FEED DATA STREAM or BUILD A NEW ONE FROM FILE
    //------------------------------------------------------
    if (tas_simAppData.size() and tas_clearToSend) {
        if (!soTOE_Data.full()) {
            //-------------------------------------------------
            //-- Feed TOE with a new APP chunk
            //-------------------------------------------------
            AxisApp appChunk = tas_simAppData.pullChunk();
            soTOE_Data.write(appChunk);
            increaseSimTime(1);
            if (appChunk.getTLast()) {
                tas_clearToSend = false;
            }
        }
    }
    else if (tas_simAppData.size() == 0) {
        //------------------------------------------------------
        //-- Build a new DATA stream from FILE
        //------------------------------------------------------
        while (!ifTAIF_Data.eof()) {
            //-- Read a line from the test vector file -----------
            getline(ifTAIF_Data, rxStringBuffer);
            if (DEBUG_LEVEL & TRACE_TAs) { printf("%s ", rxStringBuffer.c_str()); fflush(stdout); }
            stringVector = myTokenizer(rxStringBuffer, ' ');
            if (stringVector[0] == "") {
                continue;
            }
            else if (stringVector[0].length() == 1) {
                //------------------------------------------------------
                //-- Process the command and comment lines
                //--  FYI: A command or a comment start with a single
                //--       character followed by a space character.
                //------------------------------------------------------
                if (stringVector[0] == "#") {
                    // This is a comment line.
                    continue;
                }
                else if (stringVector[0] == "G") {
                    // This is a global parameter. It can be skipped because it was already parsed.
                    continue;
                }
                else if (stringVector[0] == ">") {
                    // The test vector is issuing a command.
                    //  FYI, don't forget to return at the end of command execution.
                    if (stringVector[1] == "IDLE") {
                        // Cmd = Request to idle for <NUM> cycles.
                        tas_appTxIdleCycReq = strtol(stringVector[2].c_str(), &pEnd, 10);
                        tas_appTxIdlingReq = true;
                        if (DEBUG_LEVEL & TRACE_TAs) {
                            printInfo(myName, "Request to idle for %d cycles. \n", tas_appTxIdleCycReq);
                        }
                        increaseSimTime(tas_appTxIdleCycReq);
                        return;
                    }
                    if (stringVector[1] == "SET") {
                        if (stringVector[2] == "HostIp4Addr") {
                            // COMMAND = Set the active host IP address.
                            char * ptr;
                            // Retrieve the IPv4 address to set
                            unsigned int ip4Addr;
                            if (isDottedDecimal(stringVector[3]))
                                ip4Addr = myDottedDecimalIpToUint32(stringVector[3]);
                            else if (isHexString(stringVector[3]))
                                ip4Addr = strtoul(stringVector[3].c_str(), &ptr, 16);
                            else
                                ip4Addr = strtoul(stringVector[3].c_str(), &ptr, 10);
                            gHostIp4Addr = ip4Addr;
                            printInfo(myName, "Setting the current HOST IPv4 address to be: ");
                            printIp4Addr(myName, gHostIp4Addr);
                            return;
                        }
                        else if (stringVector[2] == "HostLsnPort") {
                            // COMMAND = Set the active host listen port.
                            char * ptr;
                            // Retrieve the TCP-Port to set
                            unsigned int tcpPort;
                            if (isHexString(stringVector[3]))
                                tcpPort = strtoul(stringVector[3].c_str(), &ptr, 16);
                            else
                                tcpPort = strtoul(stringVector[3].c_str(), &ptr, 10);
                            gHostLsnPort = tcpPort;
                            printInfo(myName, "Setting the current HOST listen port to be: ");
                            printTcpPort(myName, gHostLsnPort);
                            return;
                        }
                        else if (stringVector[2] == "HostServerSocket") {
                            // COMMAND = Set the active host server socket.
                            //   If socket does not exist, host must create, bind,
                            //   listen and accept new connections from the client.
                            char *pEnd;
                            // Retrieve the current foreign IPv4 address to set
                            unsigned int ip4Addr;
                            if (isDottedDecimal(stringVector[3]))
                                ip4Addr = myDottedDecimalIpToUint32(stringVector[3]);
                            else if (isHexString(stringVector[3]))
                                ip4Addr = strtoul(stringVector[3].c_str(), &pEnd, 16);
                            else
                                ip4Addr = strtoul(stringVector[3].c_str(), &pEnd, 10);
                            gHostIp4Addr = ip4Addr;
                            // Retrieve the current foreign TCP-Port to set
                            unsigned int tcpPort;
                            if (isHexString(stringVector[4]))
                                tcpPort = strtoul(stringVector[4].c_str(), &pEnd, 16);
                            else
                                tcpPort = strtoul(stringVector[4].c_str(), &pEnd, 10);
                            gHostLsnPort = tcpPort;
 
                            SockAddr newHostServerSocket(gHostIp4Addr, gHostLsnPort);
                            printInfo(myName, "Setting current host server socket to be: \n");
                            printSockAddr(myName, newHostServerSocket);
                            return;
                        }
                    }
                }
                else {
                    printFatal(myName, "Read unknown command \"%s\" from TAIF.\n", stringVector[0].c_str());
                }
            }
            else if (ifTAIF_Data.fail() == 1 || rxStringBuffer.empty()) {
                return;
            }
            else if (!tas_clearToSend) {
                //-- Build a new simAppData from file
                AxisApp appChunk;
                bool    firstChunkFlag = true; // Axis chunk is first data chunk
                int     writtenBytes = 0;
                do {
                    if (firstChunkFlag == false) {
                        getline(ifTAIF_Data, rxStringBuffer);
                        stringVector = myTokenizer(rxStringBuffer, ' ');
                        // Skip lines that might be commented out
                        if (stringVector[0] == "#") {
                            // This is a comment line.
                            if (DEBUG_LEVEL & TRACE_TAs) { printf("%s ", rxStringBuffer.c_str()); fflush(stdout); }
                            continue;
                        }
                    }
                    firstChunkFlag = false;
                    bool rc = readAxisRawFromLine(appChunk, rxStringBuffer);
                    if (rc) {
                        tas_simAppData.pushChunk(appChunk);
                    }
                    // Write current chunk to the gold file
                    writtenBytes = writeAxisAppToFile(appChunk, ofIPTX_Gold2);
                    apRxBytCntr += writtenBytes;
                    if (appChunk.getTLast()) {
                        // A send request must be sent by TAIF to TOE
                        soTOE_SndReq.write(TcpAppSndReq(tas_openSessList[currSocketPair], tas_simAppData.length()));
                        return;
                    }
                } while (not appChunk.getTLast());
            } // End of: else
        } // End of: while
    } // End of: else
} // End of: pTAs
 
 
void pTAIF(
        bool                    &testTxPath,
        char                    &testMode,
        int                     &nrError,
        Ip4Address              &toeIpAddress,
        ifstream                &ifTAIF_Data,
        ofstream                &ofTAIF_Data,
        ofstream                &ofIPTX_Gold2,
        int                     &appRxBytCntr,
        int                     &appTxBytCntr,
        StsBit                  &piTOE_Ready,
        //-- Receive Interfaces
        stream<TcpAppLsnReq>    &soTOE_LsnReq,
        stream<TcpAppLsnRep>    &siTOE_LsnRep,
        stream<TcpAppNotif>     &siTOE_Notif,
        stream<TcpAppRdReq>     &soTOE_DReq,
        stream<TcpAppData>      &siTOE_Data,
        stream<TcpAppMeta>      &siTOE_Meta,
        //-- Transmit Interfaces
        stream<TcpAppOpnReq>    &soTOE_OpnReq,
        stream<TcpAppOpnRep>    &siTOE_OpnRep,
        stream<TcpAppData>      &soTOE_Data,
        stream<TcpAppSndReq>    &soTOE_SndReq,
        stream<TcpAppSndRep>    &siTOE_SndRep,
        stream<TcpAppClsReq>    &soTOE_ClsReq)
{
 
    const char *myName  = concat3(THIS_NAME, "/", "TAIF");
 
    //-- STATIC VARIABLES ------------------------------------------------------
    static bool         taif_globParseDone = false;
    static unsigned int taif_toeReadyDelay = 0; // The time it takes for TOE to be ready
 
    //-------------------------------------------------------------------------
    //-- LOCAL STREAMS
    //-------------------------------------------------------------------------
    static stream<TcpAppData>   ssTArToTAs_Data   ("ssTArToTAs_Data");
    #pragma HLS STREAM variable=ssTArToTAs_Data   depth=2048
    static stream<TcpAppSndReq> ssTArToTAs_SndReq ("ssTArToTAs_SndReq");
    #pragma HLS STREAM variable=ssTArToTAs_SndReq depth=64
 
    //---------------------------------------
    //-- STEP-0 : RETURN IF TOE IS NOT READY
    //---------------------------------------
    if (piTOE_Ready == 0) {
        taif_toeReadyDelay++;
        return;
    }
 
    //-------------------------------------------------------------------------
    //-- STEP-1: PARSE THE APP RX FILE.
    //     THIS FIRST PASS WILL SPECIFICALLY SEARCH FOR GLOBAL PARAMETERS.
    //-------------------------------------------------------------------------
    if (!taif_globParseDone) {
        taif_globParseDone = setGlobalParameters(myName, taif_toeReadyDelay, ifTAIF_Data);
        if (taif_globParseDone == false) {
            printFatal(myName, "Aborting testbench (check for previous error).\n");
        }
        return;
    }
 
    pTAIF_Recv(
            nrError,
            testMode,
            ofTAIF_Data,
            appTxBytCntr,
            piTOE_Ready,
            soTOE_LsnReq,
            siTOE_LsnRep,
            siTOE_Notif,
            soTOE_DReq,
            siTOE_Data,
            siTOE_Meta,
            ssTArToTAs_Data,
            ssTArToTAs_SndReq);
 
    pTAIF_Send(
            nrError,
            testMode,
            testTxPath,
            toeIpAddress,
            ifTAIF_Data,
            ofIPTX_Gold2,
            appRxBytCntr,
            piTOE_Ready,
            soTOE_OpnReq,
            siTOE_OpnRep,
            soTOE_Data,
            soTOE_SndReq,
            siTOE_SndRep,
            soTOE_ClsReq,
            ssTArToTAs_Data,
            ssTArToTAs_SndReq);
 
} // End of: pTAIF
 
#if HLS_VERSION != 2017
 
  void toe_top_wrap(
        //-- MMIO Interfaces
        Ip4Addr                                  piMMIO_IpAddr,
        stream<StsBit>                          &soMMIO_RxMemWrErr,
        stream<ap_uint<8> >                     &soMMIO_NotifDropCnt,
        stream<ap_uint<8> >                     &soMMIO_MetaDropCnt,
        stream<ap_uint<8> >                     &soMMIO_DataDropCnt,
        stream<ap_uint<8> >                     &soMMIO_CrcDropCnt,
        stream<ap_uint<8> >                     &soMMIO_SessDropCnt,
        stream<ap_uint<8> >                     &soMMIO_OooDropCnt,
        //-- NTS Interfaces
        StsBit                                  &poNTS_Ready,
        //-- IPRX / IP Rx / Data Interface
        stream<AxisIp4>                         &siIPRX_Data,
        //-- IPTX / IP Tx / Data Interface
        stream<AxisIp4>                         &soIPTX_Data,
        //-- TAIF / Receive Data Interfaces
        stream<TcpAppNotif>                     &soTAIF_Notif,
        stream<TcpAppRdReq>                     &siTAIF_DReq,
        stream<TcpAppData>                      &soTAIF_Data,
        stream<TcpAppMeta>                      &soTAIF_Meta,
        //-- TAIF / Listen Interfaces
        stream<TcpAppLsnReq>                    &siTAIF_LsnReq,
        stream<TcpAppLsnRep>                    &soTAIF_LsnRep,
        //-- TAIF / Send Data Interfaces
        stream<TcpAppData>                      &siTAIF_Data,
        stream<TcpAppSndReq>                    &siTAIF_SndReq,
        stream<TcpAppSndRep>                    &soTAIF_SndRep,
        //-- TAIF / Open Connection Interfaces
        stream<TcpAppOpnReq>                    &siTAIF_OpnReq,
        stream<TcpAppOpnRep>                    &soTAIF_OpnRep,
        //-- TAIF / Close Interfaces
        stream<TcpAppClsReq>                    &siTAIF_ClsReq,
        //-- Not Used                           &soTAIF_ClsSts,
        //-- MEM / Rx PATH / S2MM Interface
        //-- Not Used                           &siMEM_RxP_RdSts,
        stream<DmCmd>                           &soMEM_RxP_RdCmd,
        stream<AxisApp>                         &siMEM_RxP_Data,
        stream<DmSts>                           &siMEM_RxP_WrSts,
        stream<DmCmd>                           &soMEM_RxP_WrCmd,
        stream<AxisApp>                         &soMEM_RxP_Data,
        //-- MEM / Tx PATH / S2MM Interface
        //-- Not Used                           &siMEM_TxP_RdSts,
        stream<DmCmd>                           &soMEM_TxP_RdCmd,
        stream<AxisApp>                         &siMEM_TxP_Data,
        stream<DmSts>                           &siMEM_TxP_WrSts,
        stream<DmCmd>                           &soMEM_TxP_WrCmd,
        stream<AxisApp>                         &soMEM_TxP_Data,
        //-- CAM / Session Lookup & Update Interfaces
        stream<CamSessionLookupRequest>         &soCAM_SssLkpReq,
        stream<CamSessionLookupReply>           &siCAM_SssLkpRep,
        stream<CamSessionUpdateRequest>         &soCAM_SssUpdReq,
        stream<CamSessionUpdateReply>           &siCAM_SssUpdRep,
        //-- DEBUG / Interfaces
        //-- DEBUG / Session Statistics Interfaces
        stream<ap_uint<16> >                    &soDBG_SssRelCnt,
        stream<ap_uint<16> >                    &soDBG_SssRegCnt,
        //-- DEBUG / Internal Counters Interfaces
        stream<RxBufPtr>                        &soDBG_RxFreeSpace,
        stream<ap_uint<32> >                    &soDBG_TcpIpRxByteCnt,
        stream<ap_uint< 8> >                    &soDBG_OooDebug
        #if TOE_FEATURE_USED_FOR_DEBUGGING
        //-- DEBUG / SimCycCounter
        ap_uint<32>                             &poSimCycCount
        #endif
  )
{
    //-- LOCAL INPUT and OUTPUT STREAMS ----------------------------------------
    static stream<AxisRaw>      ssiIPRX_Data ("ssiIPRX_Data");
    static stream<AxisRaw>      ssoIPTX_Data ("ssoIPTX_Data");
 
    //-- INPUT STREAM CASTING -----------------------------
    pAxisRawCast(siIPRX_Data, ssiIPRX_Data);
 
    //-- MAIN TOE_TOP PROCESS -----------------------------
    toe_top(
      //-- MMIO Interfaces
      piMMIO_IpAddr,
      soMMIO_RxMemWrErr,
      soMMIO_NotifDropCnt,
      soMMIO_MetaDropCnt,
      soMMIO_DataDropCnt,
      soMMIO_CrcDropCnt,
      soMMIO_SessDropCnt,
      soMMIO_OooDropCnt,
      //-- NTS Interfaces
      poNTS_Ready,
      //-- IPv4 / Rx & Tx Data Interfaces
      ssiIPRX_Data,
      ssoIPTX_Data,
      //-- TAIF / Rx Data Interfaces
      soTAIF_Notif,
      siTAIF_DReq,
      soTAIF_Data,
      soTAIF_Meta,
      //-- TAIF / Listen Port Interfaces
      siTAIF_LsnReq,
      soTAIF_LsnRep,
      //-- TAIF / Tx Data Interfaces
      siTAIF_Data,
      siTAIF_SndReq,
      soTAIF_SndRep,
      //-- TAIF / Open Connection Interfaces
      siTAIF_OpnReq,
      soTAIF_OpnRep,
      //-- TAIF / Close Interfaces
      siTAIF_ClsReq,
      //-- [TODO] &soTAIF_ClsSts,
      //-- MEM / Rx PATH / S2MM Interface
      soMEM_RxP_RdCmd,
      siMEM_RxP_Data,
      siMEM_RxP_WrSts,
      soMEM_RxP_WrCmd,
      soMEM_RxP_Data,
      //-- MEM / Tx PATH / S2MM Interface
      soMEM_TxP_RdCmd,
      siMEM_TxP_Data,
      siMEM_TxP_WrSts,
      soMEM_TxP_WrCmd,
      soMEM_TxP_Data,
      //-- CAM / Session Lookup & Update Interfaces
      soCAM_SssLkpReq,
      siCAM_SssLkpRep,
      soCAM_SssUpdReq,
      siCAM_SssUpdRep,
      //-- DEBUG / Session Statistics Interfaces
      soDBG_SssRelCnt,
      soDBG_SssRegCnt,
      //-- DEBUG / Internal Counter Interfaces
      soDBG_RxFreeSpace,
      soDBG_TcpIpRxByteCnt,
      soDBG_OooDebug
      #if TOE_FEATURE_USED_FOR_DEBUGGING
      ,
      sTOE_TB_SimCycCnt
      #endif
    );
 
    //-- OUTPUT STREAM CASTING ----------------------------
    pAxisRawCast(ssoIPTX_Data,  soIPTX_Data);
}
#endif
 
 
int main(int argc, char *argv[]) {
 
    //------------------------------------------------------
    //-- TESTBENCH GLOBAL VARIABLES
    //------------------------------------------------------
    gSimCycCnt = 0;  // Simulation cycle counter as a global variable
 
    //------------------------------------------------------
    //-- DUT SIGNAL INTERFACES
    //------------------------------------------------------
    StsBit  sTOE_Ready;
 
    //------------------------------------------------------
    //-- DUT STREAM INTERFACES
    //------------------------------------------------------
 
    stream<AxisIp4>                 ssIPRX_TOE_Data      ("ssIPRX_TOE_Data");
 
    stream<AxisIp4>                 ssTOE_IPTX_Data      ("ssTOE_IPTX_Data");
 
    stream<TcpAppData>              ssTAIF_TOE_Data      ("ssTAIF_TOE_Data");
    stream<TcpAppSndReq>            ssTAIF_TOE_SndReq    ("ssTAIF_TOE_SndReq");
    stream<TcpAppSndRep>            ssTOE_TAIF_SndRep    ("ssTOE_TAIF_SndRep");
 
    stream<TcpAppRdReq>             ssTAIF_TOE_DReq      ("ssTAIF_TOE_DReq");
    stream<TcpAppData>              ssTOE_TAIF_Data      ("ssTOE_TAIF_Data");
    stream<TcpAppMeta>              ssTOE_TAIF_Meta      ("ssTOE_TAIF_Meta");
 
    stream<TcpAppLsnReq>            ssTAIF_TOE_LsnReq    ("ssTAIF_TOE_LsnReq");
    stream<TcpAppLsnRep>            ssTOE_TAIF_LsnRep    ("ssTOE_TAIF_LsnRep");
 
    stream<TcpAppOpnReq>            ssTAIF_TOE_OpnReq    ("ssTAIF_TOE_OpnReq");
    stream<TcpAppOpnRep>            ssTOE_TAIF_OpnRep    ("ssTOE_TAIF_OpnRep");
 
    stream<TcpAppNotif>             ssTOE_TAIF_Notif     ("ssTOE_TAIF_Notif");
 
    stream<TcpAppClsReq>            ssTAIF_TOE_ClsReq    ("ssTAIF_TOE_ClsReq");
 
    stream<DmCmd>                   ssTOE_MEM_RxP_RdCmd  ("ssTOE_MEM_RxP_RdCmd");
    stream<AxisApp>                 ssMEM_TOE_RxP_Data   ("ssMEM_TOE_RxP_Data");
    stream<DmSts>                   ssMEM_TOE_RxP_WrSts  ("ssMEM_TOE_RxP_WrSts");
    stream<DmCmd>                   ssTOE_MEM_RxP_WrCmd  ("ssTOE_MEM_RxP_WrCmd");
    stream<AxisApp>                 ssTOE_MEM_RxP_Data   ("ssTOE_MEM_RxP_Data");
 
    stream<DmCmd>                   ssTOE_MEM_TxP_RdCmd  ("ssTOE_MEM_TxP_RdCmd");
    stream<AxisApp>                 ssMEM_TOE_TxP_Data   ("ssMEM_TOE_TxP_Data");
    stream<DmSts>                   ssMEM_TOE_TxP_WrSts  ("ssMEM_TOE_TxP_WrSts");
    stream<DmCmd>                   ssTOE_MEM_TxP_WrCmd  ("ssTOE_MEM_TxP_WrCmd");
    stream<AxisApp>                 ssTOE_MEM_TxP_Data   ("ssTOE_MEM_TxP_Data");
 
    stream<CamSessionLookupRequest> ssTOE_CAM_SssLkpReq  ("ssTOE_CAM_SssLkpReq");
    stream<CamSessionLookupReply>   ssCAM_TOE_SssLkpRep  ("ssCAM_TOE_SssLkpRep");
    stream<CamSessionUpdateRequest> ssTOE_CAM_SssUpdReq  ("ssTOE_CAM_SssUpdReq");
    stream<CamSessionUpdateReply>   ssCAM_TOE_SssUpdRep  ("ssCAM_TOE_SssUpdRep");
 
    stream<StsBit>                  ssTOE_MMIO_RxMemWrErr   ("ssTOE_MMIO_RxMemWrErr");
    stream<ap_uint<8> >             ssTOE_MMIO_NotifDropCnt ("ssTOE_MMIO_NotifDropCnt");
    stream<ap_uint<8> >             ssTOE_MMIO_MetaDropCnt  ("ssTOE_MMIO_MetaDropCnt");
    stream<ap_uint<8> >             ssTOE_MMIO_DataDropCnt  ("ssTOE_MMIO_DataDropCnt");
    stream<ap_uint<8> >             ssTOE_MMIO_CrcDropCnt   ("ssTOE_MMIO_CrcDropCnt");
    stream<ap_uint<8> >             ssTOE_MMIO_SessDropCnt  ("ssTOE_MMIO_SessDropCnt");
    stream<ap_uint<8> >             ssTOE_MMIO_OooDropCnt   ("ssTOE_MMIO_OooDropCnt");
 
    stream<ap_uint<16> >            ssTOE_OpnSessCount   ("ssTOE_OpnSessCount");
    stream<ap_uint<16> >            ssTOE_ClsSessCount   ("ssTOE_ClsSessCount");
    stream<RxBufPtr>                ssTOE_RxFreeSpace    ("ssTOE_RxFreeSpace");
    stream<ap_uint<32> >            ssTOE_TcpIprxByteCnt ("ssTOE_TcpIprxByteCnt");
    stream<ap_uint< 8> >            ssTOE_OooDebugState  ("ssTOE_OooDebugState");
    //------------------------------------------------------
    //-- TB SIGNALS
    //------------------------------------------------------
    StsBit                          sTOE_ReadyDly;
 
    //-----------------------------------------------------
    //-- TESTBENCH VARIABLES
    //-----------------------------------------------------
    #if TOE_FEATURE_USED_FOR_DEBUGGING
        ap_uint<32> sTOE_TB_SimCycCnt;
    #endif
 
    AxisIp4         ipRxData;    // An IP4 chunk
    AxisApp         tcpTxData;   // A  TCP chunk
 
    ap_uint<16>     nrOpenedSessions;
    ap_uint<16>     nrClosedSessions;
    ap_uint<32>     nrTcpIprxBytes;
 
    DummyMemory     rxMemory;
    DummyMemory     txMemory;
 
    map<SocketPair, TcpAckNum>    sessAckList; // [FIXME -Rename to Map]
    map<SocketPair, TcpSeqNum>    sessSeqList; // [FIXME -Rename to Map]
 
    //-- Double-ended queue of packets --------------------
    deque<SimIp4Packet> ipRxPacketizer; // Packets intended for the IPRX interface of TOE
 
    //-----------------------------------------------------
    //-- TESTBENCH INPUT & OUTPUT FILE STREAMS
    //-----------------------------------------------------
    ifstream    ifIPRX_Data;   // IP4 packets from IPRX
    ifstream    ifTAIF_Data;   // APP data    from TAIF
 
    ofstream    ofTAIF_Data;   // APP byte streams delivered to TAIF
    ofstream    ofTAIF_Gold;   // Gold reference file for 'ofTAIF_Data'
    ofstream    ofIPTX_Data1;  // Raw IP packets delivered to IPTX
    ofstream    ofIPTX_Gold1;  // Gold reference file for 'ofIPTX_Data1' (not used)
    ofstream    ofIPTX_Data2;  // Tcp payload of the IP packets delivered to IPTX
    ofstream    ofIPTX_Gold2;  // Gold reference file for 'ofIPTX_Data2'
 
    const char  *ofTAIF_DataName  = "../../../../test/simOutFiles/soTAIF.strm";
    const char  *ofTAIF_GoldName  = "../../../../test/simOutFiles/soTAIF.gold";
    const char  *ofIPTX_Data1Name = "../../../../test/simOutFiles/soIPTX.dat";
    const char  *ofIPTX_Gold1Name = "../../../../test/simOutFiles/soIPTX.gold";
    const char  *ofIPTX_Data2Name = "../../../../test/simOutFiles/soIPTX_TcpData.strm";
    const char  *ofIPTX_Gold2Name = "../../../../test/simOutFiles/soIPTX_TcpData.gold";
 
    string   dataString, keepString;
 
    int      nrErr = 0;            // Total number of testbench errors
 
    int      pktCounter_IPRX_TOE = 0;  // Counts the # IP packets from IPRX-to-TOE (all kinds and from all sessions).
    int      tcpBytCntr_IPRX_TOE = 0;  // Counts the # TCP bytes  from IPRX-to-TOE.
 
    int      pktCounter_TOE_IPTX = 0;  // Counts the # IP packets from TOE-to-IPTX (all kinds and from all sessions).
    int      tcpBytCntr_TOE_IPTX = 0;  // Counts the # TCP bytes  from TOE-to-IPTX.
 
    int      tcpBytCnt_APP_TOE = 0;    // Counts the # TCP bytes from APP-to-TOE.
    int      tcpBytCnt_TOE_APP = 0;    // Counts the # TCP bytes  from TOE-to-APP.
 
    bool     testRxPath      = false; // Indicates if the Rx path is to be tested.
    bool     testTxPath      = false; // Indicates if the Tx path is to be tested.
 
    int      startUpDelay    = TB_STARTUP_TIME;
 
    char     mode            = *argv[1];
    char     cCurrPath[FILENAME_MAX];
 
    //------------------------------------------------------
    //-- REMOVE PREVIOUS OLD SIM FILES and OPEN NEW ONES
    //------------------------------------------------------
    remove(ofTAIF_DataName);
    ofTAIF_Data.open(ofTAIF_DataName);
    if (!ofTAIF_Data) {
        printError(THIS_NAME, "Cannot open the Application Tx file:  \n\t %s \n", ofTAIF_DataName);
        return -1;
    }
    remove(ofTAIF_GoldName);
    ofTAIF_Gold.open(ofTAIF_GoldName);
    if (!ofTAIF_Gold) {
        printInfo(THIS_NAME, "Cannot open the Application Tx gold file:  \n\t %s \n", ofTAIF_GoldName);
        return -1;
    }
    remove(ofIPTX_Data1Name);
    ofIPTX_Data1.open(ofIPTX_Data1Name);
    if (!ofIPTX_Data1) {
        printError(THIS_NAME, "Cannot open the IP Tx file:  \n\t %s \n", ofIPTX_Data1Name);
        return -1;
    }
    remove(ofIPTX_Data2Name);
    ofIPTX_Data2.open(ofIPTX_Data2Name);
    if (!ofIPTX_Data2) {
        printError(THIS_NAME, "Cannot open the IP Tx file:  \n\t %s \n", ofIPTX_Data2Name);
        return -1;
    }
    remove(ofIPTX_Gold2Name);
    ofIPTX_Gold1.open(ofIPTX_Gold1Name);
    if (!ofIPTX_Gold1) {
        printError(THIS_NAME, "Cannot open the IP Tx gold file:  \n\t %s \n", ofIPTX_Gold1Name);
        return -1;
    }
    remove(ofIPTX_Gold2Name);
    ofIPTX_Gold2.open(ofIPTX_Gold2Name);
    if (!ofIPTX_Gold2) {
        printError(THIS_NAME, "Cannot open the IP Tx gold file:  \n\t %s \n", ofIPTX_Gold2Name);
        return -1;
    }
 
    printInfo(THIS_NAME, "############################################################################\n");
    printInfo(THIS_NAME, "## TESTBENCH 'test_toe' STARTS HERE                                       ##\n");
    printInfo(THIS_NAME, "############################################################################\n");
    printInfo(THIS_NAME, "This testbench will be executed with the following parameters: \n");
    for (int i=1; i<argc; i++) {
        printInfo(THIS_NAME, "\t==> Param[%d] = %s\n", (i-1), argv[i]);
    }
    printf("\n\n");
 
    sTOE_ReadyDly = 0;
 
    //------------------------------------------------------
    //-- PARSING TESBENCH ARGUMENTS
    //------------------------------------------------------
    if (argc < 3) {
        printError(THIS_NAME, "Expected a minimum of 2 or 3 parameters with one of the following synopsis:\n \t\t mode(0|3) siIPRX_<TestName>\n \t\t mode(1) siTAIF_<TestName>\n \t\t mode(2) siIPRX_<TestName> siTAIF_<TestName>\n");
        gFatalError = true;
        return 1;
    }
    printInfo(THIS_NAME, "This run executes in mode \'%c\'.\n", mode);
 
    if ((mode == RX_MODE) || (mode == BIDIR_MODE) || (mode == ECHO_MODE)) {
        testRxPath = true;
        //-------------------------------------------------
        //-- Files used for the test of the Rx side
        //-------------------------------------------------
        ifIPRX_Data.open(argv[2]);
        if (!ifIPRX_Data) {
            printError(THIS_NAME, "Cannot open the IP Rx file: \n\t %s \n", argv[2]);
            if (!getcwd(cCurrPath, sizeof(cCurrPath))) {
                return -1;
            }
            printInfo (THIS_NAME, "\t (FYI - The current working directory is: \n\t %s) \n", cCurrPath);
            return -1;
        }
        printInfo(THIS_NAME, "This run executes with IP Rx file  : %s.\n", argv[2]);
    }
 
    if ((mode == TX_MODE) || (mode == BIDIR_MODE) || (mode == ECHO_MODE)) {
        testTxPath = true;
        //-------------------------------------------------
        //-- Files used for the test of the Tx side
        //-------------------------------------------------
        switch (mode) {
        case TX_MODE:
            ifTAIF_Data.open(argv[2]);
            if (!ifTAIF_Data) {
                printError(THIS_NAME, "Cannot open the APP Rx file: \n\t %s \n", argv[2]);
                if (!getcwd(cCurrPath, sizeof(cCurrPath))) {
                    return -1;
                }
                printInfo (THIS_NAME, "\t (FYI - The current working directory is: \n\t %s) \n", cCurrPath);
                return -1;
            }
            printInfo(THIS_NAME, "This run executes with APP Rx file : %s.\n", argv[2]);
            break;
        case BIDIR_MODE:
            ifTAIF_Data.open(argv[3]);
            if (!ifTAIF_Data) {
                printError(THIS_NAME, "Cannot open the APP Rx file: \n\t %s \n", argv[3]);
                if (!getcwd(cCurrPath, sizeof(cCurrPath))) {
                    return -1;
                }
                printf ("\t (FYI - The current working directory is: \n\t %s) \n", cCurrPath);
                return -1;
            }
            printInfo(THIS_NAME, "This run executes with APP Rx file : %s.\n", argv[3]);
            break;
        }
    }
 
    //-----------------------------------------------------
    //-- MAIN LOOP
    //-----------------------------------------------------
    do {
        //-------------------------------------------------
        //-- STEP-1 : Emulate the IPv4 Rx Path
        //-------------------------------------------------
        pIPRX(ifIPRX_Data,    ofTAIF_Gold,
              testRxPath,     pktCounter_IPRX_TOE, tcpBytCntr_IPRX_TOE,
              ipRxPacketizer, sessAckList,
              sTOE_ReadyDly,  ssIPRX_TOE_Data);
 
        //-------------------------------------------------
        //-- STEP-2 : RUN DUT
        //-------------------------------------------------
        #if HLS_VERSION == 2017
          toe_top(
        #else
          toe_top_wrap(
        #endif
            //-- MMIO Interfaces
            gFpgaIp4Addr,
            ssTOE_MMIO_RxMemWrErr,
            ssTOE_MMIO_NotifDropCnt,
            ssTOE_MMIO_MetaDropCnt,
            ssTOE_MMIO_DataDropCnt,
            ssTOE_MMIO_CrcDropCnt,
            ssTOE_MMIO_SessDropCnt,
            ssTOE_MMIO_OooDropCnt,
            //-- NTS Interfaces
            sTOE_Ready,
            //-- IPv4 / Rx & Tx Data Interfaces
            ssIPRX_TOE_Data,
            ssTOE_IPTX_Data,
            //-- TAIF / Rx Data Interfaces
            ssTOE_TAIF_Notif,
            ssTAIF_TOE_DReq,
            ssTOE_TAIF_Data,
            ssTOE_TAIF_Meta,
            //-- TAIF / Listen Port Interfaces
            ssTAIF_TOE_LsnReq,
            ssTOE_TAIF_LsnRep,
            //-- TAIF / Tx Data Interfaces
            ssTAIF_TOE_Data,
            ssTAIF_TOE_SndReq,
            ssTOE_TAIF_SndRep,
            //-- TAIF / Open Connection Interfaces
            ssTAIF_TOE_OpnReq,
            ssTOE_TAIF_OpnRep,
            //-- TAIF / Close Interfaces
            ssTAIF_TOE_ClsReq,
            //-- [TODO] &soTAIF_ClsSts,
            //-- MEM / Rx PATH / S2MM Interface
            ssTOE_MEM_RxP_RdCmd,
            ssMEM_TOE_RxP_Data,
            ssMEM_TOE_RxP_WrSts,
            ssTOE_MEM_RxP_WrCmd,
            ssTOE_MEM_RxP_Data,
            //-- MEM / Tx PATH / S2MM Interface
            ssTOE_MEM_TxP_RdCmd,
            ssMEM_TOE_TxP_Data,
            ssMEM_TOE_TxP_WrSts,
            ssTOE_MEM_TxP_WrCmd,
            ssTOE_MEM_TxP_Data,
            //-- CAM / Session Lookup & Update Interfaces
            ssTOE_CAM_SssLkpReq,
            ssCAM_TOE_SssLkpRep,
            ssTOE_CAM_SssUpdReq,
            ssCAM_TOE_SssUpdRep,
            //-- DEBUG / Session Statistics Interfaces
            ssTOE_ClsSessCount,
            ssTOE_OpnSessCount,
            ssTOE_RxFreeSpace,
            ssTOE_TcpIprxByteCnt,
            ssTOE_OooDebugState
            #if TOE_FEATURE_USED_FOR_DEBUGGING
            ,
            sTOE_TB_SimCycCnt
            #endif
          );
 
        //------------------------------------------------------
        //-- STEP-2.1 : Drain TOE's Debug Streams
        //------------------------------------------------------
        if (!ssTOE_ClsSessCount.empty()) {
            nrClosedSessions = ssTOE_ClsSessCount.read();
        }
        if (!ssTOE_OpnSessCount.empty()) {
            nrOpenedSessions = ssTOE_OpnSessCount.read();
        }
        if (!ssTOE_RxFreeSpace.empty()) {
            nrOpenedSessions = ssTOE_RxFreeSpace.read();
        }
        if (!ssTOE_TcpIprxByteCnt.empty()) {
            nrTcpIprxBytes = ssTOE_TcpIprxByteCnt.read();
        }
        if (!ssTOE_OooDebugState.empty()) {
            ssTOE_OooDebugState.read();
        }
 
        //------------------------------------------------------
        //-- STEP-2.2 : GENERATE THE 'ReadyDly' SIGNAL
        //------------------------------------------------------
        if (sTOE_Ready == 1) {
            if (startUpDelay > 0) {
                startUpDelay--;
                if (DEBUG_LEVEL & TRACE_MAIN) {
                    if (startUpDelay == 0) {
                        printInfo(THIS_NAME, "TOE and TB are ready.\n");
                    }
                }
            }
            else {
                sTOE_ReadyDly = sTOE_Ready;
            }
        }
 
        //-------------------------------------------------
        //-- STEP-3 : Emulate DRAM & CAM Interfaces
        //-------------------------------------------------
        if (sTOE_ReadyDly) {
            pEmulateRxBufMem(
                &rxMemory,          nrErr,
                ssTOE_MEM_RxP_WrCmd, ssTOE_MEM_RxP_Data, ssMEM_TOE_RxP_WrSts,
                ssTOE_MEM_RxP_RdCmd, ssMEM_TOE_RxP_Data);
 
            pEmulateTxBufMem(
                &txMemory,           nrErr,
                ssTOE_MEM_TxP_WrCmd, ssTOE_MEM_TxP_Data, ssMEM_TOE_TxP_WrSts,
                ssTOE_MEM_TxP_RdCmd, ssMEM_TOE_TxP_Data);
 
            pEmulateCam(
                ssTOE_CAM_SssLkpReq, ssCAM_TOE_SssLkpRep,
                ssTOE_CAM_SssUpdReq, ssCAM_TOE_SssUpdRep);
        }
 
        //------------------------------------------------------
        //-- STEP-4 : DRAIN DUT AND WRITE OUTPUT FILE STREAMS
        //------------------------------------------------------
 
        //-------------------------------------------------
        //-- STEP-4.0 : Emulate Layer-3 Multiplexer
        //-------------------------------------------------
        pIPTX(
            sTOE_ReadyDly,
            ssTOE_IPTX_Data,
            ofIPTX_Data1,
            ofIPTX_Data2,
            sessAckList,
            pktCounter_TOE_IPTX,
            tcpBytCntr_TOE_IPTX,
            ipRxPacketizer);
 
        //-------------------------------------------------
        //-- STEP-4.1 : Emulate TCP Application (TAIF)
        //-------------------------------------------------
        pTAIF(
            testTxPath,
            mode,
            nrErr,
            gFpgaIp4Addr,
            ifTAIF_Data,
            ofTAIF_Data,
            ofIPTX_Gold2,
            tcpBytCnt_APP_TOE,
            tcpBytCnt_TOE_APP,
            sTOE_ReadyDly,
            ssTAIF_TOE_LsnReq,
            ssTOE_TAIF_LsnRep,
            ssTOE_TAIF_Notif,
            ssTAIF_TOE_DReq,
            ssTOE_TAIF_Data,
            ssTOE_TAIF_Meta,
            ssTAIF_TOE_OpnReq,
            ssTOE_TAIF_OpnRep,
            ssTAIF_TOE_Data,
            ssTAIF_TOE_SndReq,
            ssTOE_TAIF_SndRep,
            ssTAIF_TOE_ClsReq);
 
        
        //------------------------------------------------------
        //-- STEP-7 : INCREMENT SIMULATION COUNTER
        //------------------------------------------------------
        #if TOE_FEATURE_USED_FOR_DEBUGGING
            // The sim-counter s generated by [TOE]
            gSimCycCnt = sTOE_TB_SimCycCnt.to_uint();
            if (gTraceEvent || ((gSimCycCnt % 1000) == 0)) {
                printf("-- [@%4.4d] -----------------------------\n", gSimCycCnt);
                gTraceEvent = false;
            }
        #else
            stepSim();
        #endif
 
        //------------------------------------------------------
        //-- EXIT UPON FATAL ERROR OR TOO MANY ERRORS
        //------------------------------------------------------
 
    } while ( (gSimCycCnt < gMaxSimCycles) and (not gFatalError) and (nrErr < 10) );
 
 
    printInfo(THIS_NAME, "############################################################################\n");
    printInfo(THIS_NAME, "## TESTBENCH 'test_toe' ENDS HERE                                          ##\n");
    printInfo(THIS_NAME, "############################################################################\n");
    stepSim();
 
    //---------------------------------------------
    //-- DRAIN TOE-->MMIO DROP COUNTER STREAMS
    //---------------------------------------------
    int nrRxMemWrErr = drainMmioDropCounter(ssTOE_MMIO_RxMemWrErr,   "drainMmioDropCounter");
    int nrNotifDrops = drainMmioDropCounter(ssTOE_MMIO_NotifDropCnt, "ssTOE_MMIO_NotifDropCnt");
    int nrMetaDrops  = drainMmioDropCounter(ssTOE_MMIO_MetaDropCnt,  "ssTOE_MMIO_MetaDropCnt");
    int nrDataDrops  = drainMmioDropCounter(ssTOE_MMIO_DataDropCnt,  "ssTOE_MMIO_DataDropCnt");
    int nrCrcDrops   = drainMmioDropCounter(ssTOE_MMIO_CrcDropCnt,   "ssTOE_MMIO_CrcDropCnt");
    int nrSessDrops  = drainMmioDropCounter(ssTOE_MMIO_SessDropCnt,  "ssTOE_MMIO_SessDropCnt");
    int nrOooDrops   = drainMmioDropCounter(ssTOE_MMIO_OooDropCnt,   "ssTOE_MMIO_OooDropCnt");
 
    //---------------------------------
    //-- CLOSING OPEN FILES
    //---------------------------------
    if ((mode == RX_MODE) || (mode == BIDIR_MODE) || (mode == ECHO_MODE)) {
        // Rx side testing only
        ifIPRX_Data.close();
        ofTAIF_Data.close();
        ofTAIF_Gold.close();
    }
 
    if ((mode == TX_MODE) || (mode == BIDIR_MODE) || (mode == ECHO_MODE)) {
        // Tx side testing only
        ifTAIF_Data.close();
        ofIPTX_Data1 << endl; ofIPTX_Data1.close();
        ofIPTX_Data2 << endl; ofIPTX_Data2.close();
        ofIPTX_Gold2 << endl; ofIPTX_Gold2.close();
    }
 
    //---------------------------------------------------------------
    //-- PRINT AN OVERALL TESTBENCH STATUS
    //---------------------------------------------------------------
    printInfo(THIS_NAME, "Number of sessions opened by TOE       : %6d \n", nrOpenedSessions.to_uint());
    printInfo(THIS_NAME, "Number of sessions closed by TOE       : %6d \n", nrClosedSessions.to_uint());
 
    printInfo(THIS_NAME, "Number of IP  Packets from IPRX-to-TOE : %6d \n", pktCounter_IPRX_TOE);
    printInfo(THIS_NAME, "Number of IP  Packets from TOE-to-IPTX : %6d \n", pktCounter_TOE_IPTX);
 
    printInfo(THIS_NAME, "Number of TCP Bytes   from IPRX-to-TOE : %6d \n", tcpBytCntr_IPRX_TOE);
    printInfo(THIS_NAME, "Number of TCP Bytes   from TOE-to-APP  : %6d \n", tcpBytCnt_TOE_APP);
 
    printInfo(THIS_NAME, "Number of TCP Bytes   from APP-to-TOE  : %6d \n", tcpBytCnt_APP_TOE);
    printInfo(THIS_NAME, "Number of TCP Bytes   from TOE-to-IPTX : %6d \n", tcpBytCntr_TOE_IPTX);
 
    printf("\n");
    //---------------------------------------------------------------
    //-- COMPARE TOE's EMBEDDED COUNTERS WITH TESTBENCH COUNTERS
    //---------------------------------------------------------------
    if (tcpBytCntr_IPRX_TOE != nrTcpIprxBytes.to_uint()) {
        printError(THIS_NAME, "The number of TCP bytes received by TOE on its IP interface (%d) does not match the internal TCP bytes counter of TOE (%d). \n", tcpBytCntr_IPRX_TOE, nrTcpIprxBytes.to_uint());
        nrErr++;
    }
 
    //---------------------------------------------------------------
    //-- COMPARE THE RESULTS FILES WITH GOLDEN FILES
    //---------------------------------------------------------------
    if ((mode == RX_MODE) or (mode == ECHO_MODE)) {
        if (mode != ECHO_MODE) {
            printInfo(THIS_NAME, "This testbench was executed in mode \'%c\' with siIPRX file = %s.\n", mode, argv[2]);
        }
        if (gSortTaifGold) {
            //-- Sort and merge the TAIF gold file before comparison
            string sortedTAIF_GoldName = std::string(ofTAIF_GoldName) + ".sorted";
            int rc = system(("sort " + std::string(ofTAIF_GoldName) + " > " +
                                       std::string(sortedTAIF_GoldName)).c_str());
            if (rc != 0) {
                printFatal(THIS_NAME, "Failed to sort output file \"%s\". \n", ofTAIF_GoldName);
            }
            string mergedTAIF_GoldName = std::string(sortedTAIF_GoldName) + ".merged";
            string mergedTAIF_StrmName = std::string(ofTAIF_DataName) + ".merged";
            int mergeCmd1 = system(("paste -sd \"\" "+ std::string(sortedTAIF_GoldName) + " > " + mergedTAIF_GoldName + " ").c_str());
            int mergeCmd2 = system(("paste -sd \"\" "+ std::string(ofTAIF_DataName)     + " > " + mergedTAIF_StrmName + " ").c_str());
            int ipRx_TcpDataCompare = system(("diff --brief -w " + mergedTAIF_GoldName + " " + mergedTAIF_StrmName + " ").c_str());
            if (ipRx_TcpDataCompare != 0) {
                if (nrOooDrops == 0) {
                    printError(THIS_NAME, "File \"%s\" differs from file \"%s\" \n", mergedTAIF_StrmName.c_str(), mergedTAIF_GoldName.c_str());
                    nrErr++;
                }
                else {
                    printWarn(THIS_NAME, "Skipping TCP data comparison on the IP Rx side.\n");
                }
            }
        }
        else {
            //-- Default checkers
            int appTxCompare = system(("diff --brief -w " + std::string(ofTAIF_DataName) + " "
                                                          + std::string(ofTAIF_GoldName) + " ").c_str());
            if (appTxCompare != 0) {
                if (nrOooDrops == 0) {
                    printError(THIS_NAME, "File \"%s\" differs from file \"%s\" \n", ofTAIF_DataName, ofTAIF_GoldName);
                    nrErr++;
                }
                else {
                    printWarn(THIS_NAME, "Skipping comparison between file \"%s\" and file \"%s\" \n", ofTAIF_DataName, ofTAIF_GoldName);
                }
                if (tcpBytCntr_IPRX_TOE != tcpBytCnt_TOE_APP) {
                    if (nrOooDrops == 0) {
                        printError(THIS_NAME, "The number of TCP bytes received by TOE on its IP interface (%d) does not match the number TCP bytes forwarded by TOE to the application over its TAIF interface (%d). \n", tcpBytCntr_IPRX_TOE, tcpBytCnt_TOE_APP);
                        nrErr++;
                    }
                    else {
                        printWarn(THIS_NAME, "Skipping TCP IpRx vs TCP App byte count comparison.\n");
                    }
                }
            }
        }
        if ((nrOpenedSessions == 0) and (pktCounter_IPRX_TOE > 0)) {
            printWarn(THIS_NAME, "No session was opened by the TOE during this run. Please double check!!!\n");
            nrErr++;
        }
    }
 
    if ((mode == TX_MODE)  or (mode == ECHO_MODE)) {
        printf("\n");
        printInfo(THIS_NAME, "This testbench was executed in mode \'%c\' with siTAIF file = %s.\n", mode, argv[2]);
        if (tcpBytCntr_TOE_IPTX != tcpBytCnt_APP_TOE) {
            printError(THIS_NAME, "The number of TCP bytes forwarded from TOE-to-IPTX (%d) does not match the number TCP bytes received from APP-to-TOE (%d). \n", tcpBytCntr_TOE_IPTX, tcpBytCnt_APP_TOE);
            nrErr++;
        }
        string mergedIPTX_Data2Name = std::string(ofIPTX_Data2Name) + ".merged";
        string mergedIPTX_Gold2Name = std::string(ofIPTX_Gold2Name) + ".merged";
        int mergeCmd1 = system(("paste -sd \"\" "+ std::string(ofIPTX_Data2Name) + " > " + mergedIPTX_Data2Name + " ").c_str());
        int mergeCmd2 = system(("paste -sd \"\" "+ std::string(ofIPTX_Gold2Name) + " > " + mergedIPTX_Gold2Name + " ").c_str());
        int ipTx_TcpDataCompare = system(("diff --brief -w " + mergedIPTX_Data2Name + " " + mergedIPTX_Gold2Name + " ").c_str());
        if (ipTx_TcpDataCompare != 0) {
            printError(THIS_NAME, "File \"%s\" differs from file \"%s\" \n", mergedIPTX_Data2Name.c_str(), mergedIPTX_Gold2Name.c_str());
            nrErr++;
        }
    }
 
    //---------------------------------------------------------------
    //-- PRINT TESTBENCH STATUS
    //---------------------------------------------------------------
    printf("\n\n");
    printInfo(THIS_NAME, "This testbench was executed with the following parameters: \n");
    printInfo(THIS_NAME, "\t==> TB Mode  = %c\n", *argv[1]);
    for (int i=2; i<argc; i++) {
        printInfo(THIS_NAME, "\t==> Param[%d] = %s\n", (i-1), argv[i]);
    }
 
 
    if (nrErr) {
        printError(THIS_NAME, "###########################################################\n");
        printError(THIS_NAME, "#### TEST BENCH FAILED : TOTAL NUMBER OF ERROR(S) = %2d ####\n", nrErr);
        printError(THIS_NAME, "###########################################################\n\n");
 
        printInfo(THIS_NAME, "FYI - You may want to check for \'ERROR\' and/or \'WARNING\' alarms in the LOG file...\n\n");
    }
        else {
        printInfo(THIS_NAME, "#############################################################\n");
        printInfo(THIS_NAME, "####               SUCCESSFUL END OF TEST                ####\n");
        printInfo(THIS_NAME, "#############################################################\n");
    }
 
    return nrErr;
 
}