TOE_TEST

Testbench for the TCP Offload Engine (TOE) of the Network Transport Stack (NTS). More...

Collaboration diagram for TOE_TEST:

Macros
#define	THIS_NAME   "TB"
#define	TRACE_OFF   0x0000
#define	TRACE_RCV   1 << 1
#define	TRACE_SND   1 << 2
#define	TRACE_ALL   0xFFFF
#define	DEBUG_LEVEL   (TRACE_OFF)
#define	TB_STARTUP_DELAY   25
#define	TB_GRACE_TIME   2500
#define	TB_STARTUP_TIME   25
#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)
#define	TB_STARTUP_DELAY   (TOE_SIZEOF_LISTEN_PORT_TABLE)
#define	TB_GRACE_TIME   2500
#define	TB_STARTUP_TIME   25
#define	DEFAULT_FPGA_IP4_ADDR   0x0A0CC801
#define	DEFAULT_FPGA_LSN_PORT   0x0057
#define	DEFAULT_FPGA_SND_PORT   TOE_FIRST_EPHEMERAL_PORT_NUM
#define	DEFAULT_HOST_IP4_ADDR   0x0A0CC832
#define	DEFAULT_HOST_LSN_PORT   0x0058
#define	DEFAULT_HOST_SND_PORT   0x8058
#define	APP_RSP_LATENCY   10
#define	MEM_RD_CMD_LATENCY   10
#define	MEM_RD_DAT_LATENCY   10
#define	MEM_RD_STS_LATENCY   10
#define	MEM_WR_CMD_LATENCY   10
#define	MEM_WR_DAT_LATENCY   10
#define	MEM_WR_STS_LATENCY   10
#define	CAM_LOOKUP_LATENCY   1
#define	CAM_UPDATE_LATENCY   10
#define	RTT_LINK   25
#define	FPGA_CLIENT_CONNECT_TIMEOUT   250
#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)
#define	TB_STARTUP_DELAY   (TOE_SIZEOF_LISTEN_PORT_TABLE)
#define	TB_GRACE_TIME   2500
#define	TB_STARTUP_TIME   25
#define	DEFAULT_FPGA_IP4_ADDR   0x0A0CC801
#define	DEFAULT_FPGA_LSN_PORT   0x0057
#define	DEFAULT_FPGA_SND_PORT   TOE_FIRST_EPHEMERAL_PORT_NUM
#define	DEFAULT_HOST_IP4_ADDR   0x0A0CC832
#define	DEFAULT_HOST_LSN_PORT   0x0058
#define	DEFAULT_HOST_SND_PORT   0x8058
#define	APP_RSP_LATENCY   10
#define	MEM_RD_CMD_LATENCY   10
#define	MEM_RD_DAT_LATENCY   10
#define	MEM_RD_STS_LATENCY   10
#define	MEM_WR_CMD_LATENCY   10
#define	MEM_WR_DAT_LATENCY   10
#define	MEM_WR_STS_LATENCY   10
#define	CAM_LOOKUP_LATENCY   1
#define	CAM_UPDATE_LATENCY   10
#define	RTT_LINK   25
#define	FPGA_CLIENT_CONNECT_TIMEOUT   250
#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)
#define	TB_STARTUP_DELAY   (TOE_SIZEOF_LISTEN_PORT_TABLE)
#define	TB_GRACE_TIME   2500
#define	TB_STARTUP_TIME   25
#define	DEFAULT_FPGA_IP4_ADDR   0x0A0CC801
#define	DEFAULT_FPGA_LSN_PORT   0x0057
#define	DEFAULT_FPGA_SND_PORT   TOE_FIRST_EPHEMERAL_PORT_NUM
#define	DEFAULT_HOST_IP4_ADDR   0x0A0CC832
#define	DEFAULT_HOST_LSN_PORT   0x0058
#define	DEFAULT_HOST_SND_PORT   0x8058
#define	APP_RSP_LATENCY   10
#define	MEM_RD_CMD_LATENCY   10
#define	MEM_RD_DAT_LATENCY   10
#define	MEM_RD_STS_LATENCY   10
#define	MEM_WR_CMD_LATENCY   10
#define	MEM_WR_DAT_LATENCY   10
#define	MEM_WR_STS_LATENCY   10
#define	CAM_LOOKUP_LATENCY   1
#define	CAM_UPDATE_LATENCY   10
#define	RTT_LINK   25
#define	FPGA_CLIENT_CONNECT_TIMEOUT   250

Enumerations
enum	TestingMode {   RX_MODE ='0' , TX_MODE ='1' , BIDIR_MODE ='2' , ECHO_MODE ='3' ,   RX_MODE ='0' , TX_MODE ='1' , BIDIR_MODE ='2' , ECHO_MODE ='3' ,   RX_MODE ='0' , TX_MODE ='1' , BIDIR_MODE ='2' , ECHO_MODE ='3' }
enum	TestingMode {   RX_MODE ='0' , TX_MODE ='1' , BIDIR_MODE ='2' , ECHO_MODE ='3' ,   RX_MODE ='0' , TX_MODE ='1' , BIDIR_MODE ='2' , ECHO_MODE ='3' ,   RX_MODE ='0' , TX_MODE ='1' , BIDIR_MODE ='2' , ECHO_MODE ='3' }
enum	TestingMode {   RX_MODE ='0' , TX_MODE ='1' , BIDIR_MODE ='2' , ECHO_MODE ='3' ,   RX_MODE ='0' , TX_MODE ='1' , BIDIR_MODE ='2' , ECHO_MODE ='3' ,   RX_MODE ='0' , TX_MODE ='1' , BIDIR_MODE ='2' , ECHO_MODE ='3' }

Functions
void	stepSim ()
	Increment the simulation counter. More...
int	main (int argc, char *argv[])
	Main (does use any param). More...
void	increaseSimTime (unsigned int cycles)
	Increase the simulation time of the testbench. More...
const char *	myCamAccessToString (int initiator)
	Convert an access CAM initiator into a string. More...
template<typename T >
int	drainMmioDropCounter (stream< T > &ss, string ssName)
	Empty a DropCounter stream and throw it away. More...
void	pEmulateCam (stream< CamSessionLookupRequest > &siTOE_SssLkpReq, stream< CamSessionLookupReply > &soTOE_SssLkpRep, stream< CamSessionUpdateRequest > &siTOE_SssUpdReq, stream< CamSessionUpdateReply > &soTOE_SssUpdRep)
	Emulate the behavior of the Content Addressable Memory (TOECAM). More...
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)
	Emulate the behavior of the Receive DDR4 Buffer Memory (RXMEM). More...
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)
	Emulate the behavior of the Transmit DDR4 Buffer Memory (TXMEM). More...
bool	setGlobalParameters (const char *callerName, unsigned int startupDelay, ifstream &inputFile)
	Parse the input test file and set the global parameters of the TB. More...
void	cmdSetCommandParser (const char *callerName, vector< string > stringVector)
	Parse and handle a 'COMMAND/SET' request. More...
void	cmdTestCommandParser (const char *callerName, vector< string > stringVector)
	Parse and handle a 'COMMAND/TEST' request. More...
int	pIPRX_InjectAckNumber (SimIp4Packet &ipRxPacket, map< SocketPair, TcpAckNum > &sessAckList)
	Take the ACK number of a session and inject it into the sequence number field of the current packet. More...
void	pIPRX_FeedTOE (deque< SimIp4Packet > &ipRxPacketizer, int &ipRxPktCounter, stream< AxisIp4 > &soTOE_Data, map< SocketPair, TcpAckNum > &sessAckList)
	Feed TOE with an IP packet. More...
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)
	Emulate the behavior of the IP Rx Path (IPRX). More...
bool	pIPTX_Parse (SimIp4Packet &ipTxPacket, map< SocketPair, TcpAckNum > &sessAckList, deque< SimIp4Packet > &ipRxPacketizer)
	Parse the TCP/IP packets generated by the TOE. More...
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)
	Emulate the behavior of the IP Tx Handler (IPTX). More...
bool	pTcpAppListen (TcpPort lsnPortNum, set< TcpPort > &openedPorts, stream< TcpAppLsnReq > &soTOE_LsnReq, stream< TcpAppLsnRep > &siTOE_LsnRep)
	TCP Application Listen (Tal). Requests TOE to listen on a new port. More...
bool	pTcpAppConnect (int &nrError, SocketPair &aSocketPair, map< SocketPair, SessionId > &openSessList, stream< SockAddr > &soTOE_OpnReq, stream< TcpAppOpnRep > &siTOE_OpnRep)
	TCP Application Connect (Tac). Requests TOE to open a new connection to a HOST socket. More...
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)
	TCP Application Echo (Tae). Performs an echo loopback between the receive and send parts of the TCP Application. More...
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)
	TCP Application Receive (TAr). Emulates the Rx process of the TAIF. More...
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)
	TCP Application Send (TAs). Emulates the Tx process of the TAIF. More...
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, 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< TcpAppOpnReq > &soTOE_OpnReq, stream< TcpAppOpnRep > &siTOE_OpnRep, stream< TcpAppData > &soTOE_Data, stream< TcpAppSndReq > &soTOE_SndReq, stream< TcpAppSndRep > &siTOE_SndRep, stream< TcpAppClsReq > &soTOE_ClsReq)
	Emulates the behavior of the TCP application interface (TAIF). More...
void	toe_top_wrap (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, StsBit &poNTS_Ready, stream< AxisIp4 > &siIPRX_Data, stream< AxisIp4 > &soIPTX_Data, stream< TcpAppNotif > &soTAIF_Notif, stream< TcpAppRdReq > &siTAIF_DReq, stream< TcpAppData > &soTAIF_Data, stream< TcpAppMeta > &soTAIF_Meta, stream< TcpAppLsnReq > &siTAIF_LsnReq, stream< TcpAppLsnRep > &soTAIF_LsnRep, stream< TcpAppData > &siTAIF_Data, stream< TcpAppSndReq > &siTAIF_SndReq, stream< TcpAppSndRep > &soTAIF_SndRep, stream< TcpAppOpnReq > &siTAIF_OpnReq, stream< TcpAppOpnRep > &soTAIF_OpnRep, stream< TcpAppClsReq > &siTAIF_ClsReq, 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, 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, stream< CamSessionLookupRequest > &soCAM_SssLkpReq, stream< CamSessionLookupReply > &siCAM_SssLkpRep, stream< CamSessionUpdateRequest > &soCAM_SssUpdReq, stream< CamSessionUpdateReply > &siCAM_SssUpdRep, stream< ap_uint< 16 > > &soDBG_SssRelCnt, stream< ap_uint< 16 > > &soDBG_SssRegCnt, stream< RxBufPtr > &soDBG_RxFreeSpace, stream< ap_uint< 32 > > &soDBG_TcpIpRxByteCnt, stream< ap_uint< 8 > > &soDBG_OooDebug)
	A wrapper for the Toplevel of the TCP Offload Engine (TOE). More...

Variables
bool	gTraceEvent = false
bool	gFatalError = false
unsigned int	gSimCycCnt = 0
unsigned int	gMaxSimCycles = 25 + 2500
const char *	camAccessorStrings [] = { "RXe", "TAi" }
bool	gTraceEvent = false
bool	gFatalError = false
unsigned int	gSimCycCnt = 0
unsigned int	gMaxSimCycles = ( 0x8000 ) + 2500
Ip4Addr	gFpgaIp4Addr = 0x0A0CC801
TcpPort	gFpgaLsnPort = 0x0057
TcpPort	gFpgaSndPort = 0x8000
Ip4Addr	gHostIp4Addr = 0x0A0CC832
TcpPort	gHostLsnPort = 0x0058
bool	gSortTaifGold = false
bool	gTest_RcvdIp4Packet = true
bool	gTest_RcvdIp4TotLen = true
bool	gTest_RcvdIp4HdrCsum = true
bool	gTest_RcvdUdpLen = true
bool	gTest_RcvdLy4Csum = true
bool	gTest_SentIp4TotLen = true
bool	gTest_SentIp4HdrCsum = true
bool	gTest_SentUdpLen = true
bool	gTest_SentLy4Csum = true
const char *	camAccessorStrings [] = { "RXe", "TAi" }
bool	gTraceEvent = false
bool	gFatalError = false
unsigned int	gSimCycCnt = 0
unsigned int	gMaxSimCycles = ( 0x8000 ) + 2500
Ip4Addr	gFpgaIp4Addr = 0x0A0CC801
TcpPort	gFpgaLsnPort = 0x0057
TcpPort	gFpgaSndPort = 0x8000
Ip4Addr	gHostIp4Addr = 0x0A0CC832
TcpPort	gHostLsnPort = 0x0058
bool	gSortTaifGold = false
bool	gTest_RcvdIp4Packet = true
bool	gTest_RcvdIp4TotLen = true
bool	gTest_RcvdIp4HdrCsum = true
bool	gTest_RcvdUdpLen = true
bool	gTest_RcvdLy4Csum = true
bool	gTest_SentIp4TotLen = true
bool	gTest_SentIp4HdrCsum = true
bool	gTest_SentUdpLen = true
bool	gTest_SentLy4Csum = true
const char *	camAccessorStrings [] = { "RXe", "TAi" }
bool	gTraceEvent = false
bool	gFatalError = false
unsigned int	gSimCycCnt = 0
unsigned int	gMaxSimCycles = ( 0x8000 ) + 2500
Ip4Addr	gFpgaIp4Addr = 0x0A0CC801
TcpPort	gFpgaLsnPort = 0x0057
TcpPort	gFpgaSndPort = 0x8000
Ip4Addr	gHostIp4Addr = 0x0A0CC832
TcpPort	gHostLsnPort = 0x0058
bool	gSortTaifGold = false
bool	gTest_RcvdIp4Packet = true
bool	gTest_RcvdIp4TotLen = true
bool	gTest_RcvdIp4HdrCsum = true
bool	gTest_RcvdUdpLen = true
bool	gTest_RcvdLy4Csum = true
bool	gTest_SentIp4TotLen = true
bool	gTest_SentIp4HdrCsum = true
bool	gTest_SentUdpLen = true
bool	gTest_SentLy4Csum = true

Detailed Description

Testbench for the TCP Offload Engine (TOE) of the Network Transport Stack (NTS).

Macro Definition Documentation

APP_RSP_LATENCY [1/3]

#define APP_RSP_LATENCY   10

Definition at line 98 of file test_rx_engine.hpp.

APP_RSP_LATENCY [2/3]

#define APP_RSP_LATENCY   10

Definition at line 97 of file test_tx_engine.hpp.

APP_RSP_LATENCY [3/3]

#define APP_RSP_LATENCY   10

Definition at line 112 of file test_toe.hpp.

CAM_LOOKUP_LATENCY [1/3]

#define CAM_LOOKUP_LATENCY   1

Definition at line 108 of file test_rx_engine.hpp.

CAM_LOOKUP_LATENCY [2/3]

#define CAM_LOOKUP_LATENCY   1

Definition at line 107 of file test_tx_engine.hpp.

CAM_LOOKUP_LATENCY [3/3]

#define CAM_LOOKUP_LATENCY   1

Definition at line 122 of file test_toe.hpp.

CAM_UPDATE_LATENCY [1/3]

#define CAM_UPDATE_LATENCY   10

Definition at line 109 of file test_rx_engine.hpp.

CAM_UPDATE_LATENCY [2/3]

#define CAM_UPDATE_LATENCY   10

Definition at line 108 of file test_tx_engine.hpp.

CAM_UPDATE_LATENCY [3/3]

#define CAM_UPDATE_LATENCY   10

Definition at line 123 of file test_toe.hpp.

DEBUG_LEVEL [1/4]

#define DEBUG_LEVEL   (TRACE_OFF)

Definition at line 45 of file test_ack_delay.cpp.

DEBUG_LEVEL [2/4]

#define DEBUG_LEVEL   (TRACE_OFF)

Definition at line 55 of file test_rx_engine.cpp.

DEBUG_LEVEL [3/4]

#define DEBUG_LEVEL   (TRACE_OFF)

Definition at line 55 of file test_tx_engine.cpp.

DEBUG_LEVEL [4/4]

#define DEBUG_LEVEL   (TRACE_OFF)

Definition at line 55 of file test_toe.cpp.

DEFAULT_FPGA_IP4_ADDR [1/3]

#define DEFAULT_FPGA_IP4_ADDR   0x0A0CC801

Definition at line 81 of file test_rx_engine.hpp.

DEFAULT_FPGA_IP4_ADDR [2/3]

#define DEFAULT_FPGA_IP4_ADDR   0x0A0CC801

Definition at line 80 of file test_tx_engine.hpp.

DEFAULT_FPGA_IP4_ADDR [3/3]

#define DEFAULT_FPGA_IP4_ADDR   0x0A0CC801

Definition at line 95 of file test_toe.hpp.

DEFAULT_FPGA_LSN_PORT [1/3]

#define DEFAULT_FPGA_LSN_PORT   0x0057

Definition at line 82 of file test_rx_engine.hpp.

DEFAULT_FPGA_LSN_PORT [2/3]

#define DEFAULT_FPGA_LSN_PORT   0x0057

Definition at line 81 of file test_tx_engine.hpp.

DEFAULT_FPGA_LSN_PORT [3/3]

#define DEFAULT_FPGA_LSN_PORT   0x0057

Definition at line 96 of file test_toe.hpp.

DEFAULT_FPGA_SND_PORT [1/3]

#define DEFAULT_FPGA_SND_PORT   TOE_FIRST_EPHEMERAL_PORT_NUM

Definition at line 83 of file test_rx_engine.hpp.

DEFAULT_FPGA_SND_PORT [2/3]

#define DEFAULT_FPGA_SND_PORT   TOE_FIRST_EPHEMERAL_PORT_NUM

Definition at line 82 of file test_tx_engine.hpp.

DEFAULT_FPGA_SND_PORT [3/3]

#define DEFAULT_FPGA_SND_PORT   TOE_FIRST_EPHEMERAL_PORT_NUM

Definition at line 97 of file test_toe.hpp.

DEFAULT_HOST_IP4_ADDR [1/3]

#define DEFAULT_HOST_IP4_ADDR   0x0A0CC832

Definition at line 85 of file test_rx_engine.hpp.

DEFAULT_HOST_IP4_ADDR [2/3]

#define DEFAULT_HOST_IP4_ADDR   0x0A0CC832

Definition at line 84 of file test_tx_engine.hpp.

DEFAULT_HOST_IP4_ADDR [3/3]

#define DEFAULT_HOST_IP4_ADDR   0x0A0CC832

Definition at line 99 of file test_toe.hpp.

DEFAULT_HOST_LSN_PORT [1/3]

#define DEFAULT_HOST_LSN_PORT   0x0058

Definition at line 86 of file test_rx_engine.hpp.

DEFAULT_HOST_LSN_PORT [2/3]

#define DEFAULT_HOST_LSN_PORT   0x0058

Definition at line 85 of file test_tx_engine.hpp.

DEFAULT_HOST_LSN_PORT [3/3]

#define DEFAULT_HOST_LSN_PORT   0x0058

Definition at line 100 of file test_toe.hpp.

DEFAULT_HOST_SND_PORT [1/3]

#define DEFAULT_HOST_SND_PORT   0x8058

Definition at line 87 of file test_rx_engine.hpp.

DEFAULT_HOST_SND_PORT [2/3]

#define DEFAULT_HOST_SND_PORT   0x8058

Definition at line 86 of file test_tx_engine.hpp.

DEFAULT_HOST_SND_PORT [3/3]

#define DEFAULT_HOST_SND_PORT   0x8058

Definition at line 101 of file test_toe.hpp.

FPGA_CLIENT_CONNECT_TIMEOUT [1/3]

#define FPGA_CLIENT_CONNECT_TIMEOUT   250

Definition at line 113 of file test_rx_engine.hpp.

FPGA_CLIENT_CONNECT_TIMEOUT [2/3]

#define FPGA_CLIENT_CONNECT_TIMEOUT   250

Definition at line 112 of file test_tx_engine.hpp.

FPGA_CLIENT_CONNECT_TIMEOUT [3/3]

#define FPGA_CLIENT_CONNECT_TIMEOUT   250

Definition at line 127 of file test_toe.hpp.

MEM_RD_CMD_LATENCY [1/3]

#define MEM_RD_CMD_LATENCY   10

Definition at line 100 of file test_rx_engine.hpp.

MEM_RD_CMD_LATENCY [2/3]

#define MEM_RD_CMD_LATENCY   10

Definition at line 99 of file test_tx_engine.hpp.

MEM_RD_CMD_LATENCY [3/3]

#define MEM_RD_CMD_LATENCY   10

Definition at line 114 of file test_toe.hpp.

MEM_RD_DAT_LATENCY [1/3]

#define MEM_RD_DAT_LATENCY   10

Definition at line 101 of file test_rx_engine.hpp.

MEM_RD_DAT_LATENCY [2/3]

#define MEM_RD_DAT_LATENCY   10

Definition at line 100 of file test_tx_engine.hpp.

MEM_RD_DAT_LATENCY [3/3]

#define MEM_RD_DAT_LATENCY   10

Definition at line 115 of file test_toe.hpp.

MEM_RD_STS_LATENCY [1/3]

#define MEM_RD_STS_LATENCY   10

Definition at line 102 of file test_rx_engine.hpp.

MEM_RD_STS_LATENCY [2/3]

#define MEM_RD_STS_LATENCY   10

Definition at line 101 of file test_tx_engine.hpp.

MEM_RD_STS_LATENCY [3/3]

#define MEM_RD_STS_LATENCY   10

Definition at line 116 of file test_toe.hpp.

MEM_WR_CMD_LATENCY [1/3]

#define MEM_WR_CMD_LATENCY   10

Definition at line 104 of file test_rx_engine.hpp.

MEM_WR_CMD_LATENCY [2/3]

#define MEM_WR_CMD_LATENCY   10

Definition at line 103 of file test_tx_engine.hpp.

MEM_WR_CMD_LATENCY [3/3]

#define MEM_WR_CMD_LATENCY   10

Definition at line 118 of file test_toe.hpp.

MEM_WR_DAT_LATENCY [1/3]

#define MEM_WR_DAT_LATENCY   10

Definition at line 105 of file test_rx_engine.hpp.

MEM_WR_DAT_LATENCY [2/3]

#define MEM_WR_DAT_LATENCY   10

Definition at line 104 of file test_tx_engine.hpp.

MEM_WR_DAT_LATENCY [3/3]

#define MEM_WR_DAT_LATENCY   10

Definition at line 119 of file test_toe.hpp.

MEM_WR_STS_LATENCY [1/3]

#define MEM_WR_STS_LATENCY   10

Definition at line 106 of file test_rx_engine.hpp.

MEM_WR_STS_LATENCY [2/3]

#define MEM_WR_STS_LATENCY   10

Definition at line 105 of file test_tx_engine.hpp.

MEM_WR_STS_LATENCY [3/3]

#define MEM_WR_STS_LATENCY   10

Definition at line 120 of file test_toe.hpp.

RTT_LINK [1/3]

#define RTT_LINK   25

Definition at line 111 of file test_rx_engine.hpp.

RTT_LINK [2/3]

#define RTT_LINK   25

Definition at line 110 of file test_tx_engine.hpp.

RTT_LINK [3/3]

#define RTT_LINK   25

Definition at line 125 of file test_toe.hpp.

TB_GRACE_TIME [1/4]

#define TB_GRACE_TIME   2500

Definition at line 40 of file test_ack_delay.hpp.

TB_GRACE_TIME [2/4]

#define TB_GRACE_TIME   2500

Definition at line 69 of file test_rx_engine.hpp.

TB_GRACE_TIME [3/4]

#define TB_GRACE_TIME   2500

Definition at line 68 of file test_tx_engine.hpp.

TB_GRACE_TIME [4/4]

#define TB_GRACE_TIME   2500

Definition at line 83 of file test_toe.hpp.

TB_STARTUP_DELAY [1/4]

#define TB_STARTUP_DELAY   25

Definition at line 39 of file test_ack_delay.hpp.

TB_STARTUP_DELAY [2/4]

#define TB_STARTUP_DELAY   (TOE_SIZEOF_LISTEN_PORT_TABLE)

Definition at line 68 of file test_rx_engine.hpp.

TB_STARTUP_DELAY [3/4]

#define TB_STARTUP_DELAY   (TOE_SIZEOF_LISTEN_PORT_TABLE)

Definition at line 67 of file test_tx_engine.hpp.

TB_STARTUP_DELAY [4/4]

#define TB_STARTUP_DELAY   (TOE_SIZEOF_LISTEN_PORT_TABLE)

Definition at line 82 of file test_toe.hpp.

TB_STARTUP_TIME [1/4]

#define TB_STARTUP_TIME   25

Definition at line 41 of file test_ack_delay.hpp.

TB_STARTUP_TIME [2/4]

#define TB_STARTUP_TIME   25

Definition at line 73 of file test_rx_engine.hpp.

TB_STARTUP_TIME [3/4]

#define TB_STARTUP_TIME   25

Definition at line 72 of file test_tx_engine.hpp.

TB_STARTUP_TIME [4/4]

#define TB_STARTUP_TIME   25

Definition at line 87 of file test_toe.hpp.

THIS_NAME [1/4]

#define THIS_NAME   "TB"

Definition at line 39 of file test_ack_delay.cpp.

THIS_NAME [2/4]

#define THIS_NAME   "TB"

Definition at line 39 of file test_rx_engine.cpp.

THIS_NAME [3/4]

#define THIS_NAME   "TB"

Definition at line 39 of file test_tx_engine.cpp.

THIS_NAME [4/4]

#define THIS_NAME   "TB"

Definition at line 39 of file test_toe.cpp.

TRACE_ALL [1/4]

#define TRACE_ALL   0xFFFF

Definition at line 44 of file test_ack_delay.cpp.

TRACE_ALL [2/4]

#define TRACE_ALL   0xFFFF

Definition at line 54 of file test_rx_engine.cpp.

TRACE_ALL [3/4]

#define TRACE_ALL   0xFFFF

Definition at line 54 of file test_tx_engine.cpp.

TRACE_ALL [4/4]

#define TRACE_ALL   0xFFFF

Definition at line 54 of file test_toe.cpp.

TRACE_CAM [1/3]

#define TRACE_CAM   1 << 1

Definition at line 42 of file test_rx_engine.cpp.

TRACE_CAM [2/3]

#define TRACE_CAM   1 << 1

Definition at line 42 of file test_tx_engine.cpp.

TRACE_CAM [3/3]

#define TRACE_CAM   1 << 1

Definition at line 42 of file test_toe.cpp.

TRACE_IPRX [1/3]

#define TRACE_IPRX   1 << 2

Definition at line 43 of file test_rx_engine.cpp.

TRACE_IPRX [2/3]

#define TRACE_IPRX   1 << 2

Definition at line 43 of file test_tx_engine.cpp.

TRACE_IPRX [3/3]

#define TRACE_IPRX   1 << 2

Definition at line 43 of file test_toe.cpp.

TRACE_IPTX [1/3]

#define TRACE_IPTX   1 << 3

Definition at line 44 of file test_rx_engine.cpp.

TRACE_IPTX [2/3]

#define TRACE_IPTX   1 << 3

Definition at line 44 of file test_tx_engine.cpp.

TRACE_IPTX [3/3]

#define TRACE_IPTX   1 << 3

Definition at line 44 of file test_toe.cpp.

TRACE_MAIN [1/3]

#define TRACE_MAIN   1 << 4

Definition at line 45 of file test_rx_engine.cpp.

TRACE_MAIN [2/3]

#define TRACE_MAIN   1 << 4

Definition at line 45 of file test_tx_engine.cpp.

TRACE_MAIN [3/3]

#define TRACE_MAIN   1 << 4

Definition at line 45 of file test_toe.cpp.

TRACE_OFF [1/4]

#define TRACE_OFF   0x0000

Definition at line 41 of file test_ack_delay.cpp.

TRACE_OFF [2/4]

#define TRACE_OFF   0x0000

Definition at line 41 of file test_rx_engine.cpp.

TRACE_OFF [3/4]

#define TRACE_OFF   0x0000

Definition at line 41 of file test_tx_engine.cpp.

TRACE_OFF [4/4]

#define TRACE_OFF   0x0000

Definition at line 41 of file test_toe.cpp.

TRACE_RCV

#define TRACE_RCV   1 << 1

Definition at line 42 of file test_ack_delay.cpp.

TRACE_RXMEM [1/3]

#define TRACE_RXMEM   1 << 5

Definition at line 46 of file test_rx_engine.cpp.

TRACE_RXMEM [2/3]

#define TRACE_RXMEM   1 << 5

Definition at line 46 of file test_tx_engine.cpp.

TRACE_RXMEM [3/3]

#define TRACE_RXMEM   1 << 5

Definition at line 46 of file test_toe.cpp.

TRACE_SND

#define TRACE_SND   1 << 2

Definition at line 43 of file test_ack_delay.cpp.

TRACE_Tac [1/3]

#define TRACE_Tac   1 << 9

Definition at line 50 of file test_rx_engine.cpp.

TRACE_Tac [2/3]

#define TRACE_Tac   1 << 9

Definition at line 50 of file test_tx_engine.cpp.

TRACE_Tac [3/3]

#define TRACE_Tac   1 << 9

Definition at line 50 of file test_toe.cpp.

TRACE_Tae [1/3]

#define TRACE_Tae   1 << 10

Definition at line 51 of file test_rx_engine.cpp.

TRACE_Tae [2/3]

#define TRACE_Tae   1 << 10

Definition at line 51 of file test_tx_engine.cpp.

TRACE_Tae [3/3]

#define TRACE_Tae   1 << 10

Definition at line 51 of file test_toe.cpp.

TRACE_TAIF [1/3]

#define TRACE_TAIF   1 << 6

Definition at line 47 of file test_rx_engine.cpp.

TRACE_TAIF [2/3]

#define TRACE_TAIF   1 << 6

Definition at line 47 of file test_tx_engine.cpp.

TRACE_TAIF [3/3]

#define TRACE_TAIF   1 << 6

Definition at line 47 of file test_toe.cpp.

TRACE_Tal [1/3]

#define TRACE_Tal   1 << 11

Definition at line 52 of file test_rx_engine.cpp.

TRACE_Tal [2/3]

#define TRACE_Tal   1 << 11

Definition at line 52 of file test_tx_engine.cpp.

TRACE_Tal [3/3]

#define TRACE_Tal   1 << 11

Definition at line 52 of file test_toe.cpp.

TRACE_TAr [1/3]

#define TRACE_TAr   1 << 7

Definition at line 48 of file test_rx_engine.cpp.

TRACE_TAr [2/3]

#define TRACE_TAr   1 << 7

Definition at line 48 of file test_tx_engine.cpp.

TRACE_TAr [3/3]

#define TRACE_TAr   1 << 7

Definition at line 48 of file test_toe.cpp.

TRACE_TAs [1/3]

#define TRACE_TAs   1 << 8

Definition at line 49 of file test_rx_engine.cpp.

TRACE_TAs [2/3]

#define TRACE_TAs   1 << 8

Definition at line 49 of file test_tx_engine.cpp.

TRACE_TAs [3/3]

#define TRACE_TAs   1 << 8

Definition at line 49 of file test_toe.cpp.

TRACE_TXMEM [1/3]

#define TRACE_TXMEM   1 << 12

Definition at line 53 of file test_rx_engine.cpp.

TRACE_TXMEM [2/3]

#define TRACE_TXMEM   1 << 12

Definition at line 53 of file test_tx_engine.cpp.

TRACE_TXMEM [3/3]

#define TRACE_TXMEM   1 << 12

Definition at line 53 of file test_toe.cpp.

Enumeration Type Documentation

TestingMode [1/3]

enum TestingMode

Enumerator
RX_MODE
TX_MODE
BIDIR_MODE
ECHO_MODE
RX_MODE
TX_MODE
BIDIR_MODE
ECHO_MODE
RX_MODE
TX_MODE
BIDIR_MODE
ECHO_MODE

Definition at line 92 of file test_rx_engine.hpp.

{ RX_MODE='0', TX_MODE='1', BIDIR_MODE='2', ECHO_MODE='3' };

TestingMode [2/3]

enum TestingMode

Enumerator
RX_MODE
TX_MODE
BIDIR_MODE
ECHO_MODE
RX_MODE
TX_MODE
BIDIR_MODE
ECHO_MODE
RX_MODE
TX_MODE
BIDIR_MODE
ECHO_MODE

Definition at line 91 of file test_tx_engine.hpp.

{ RX_MODE='0', TX_MODE='1', BIDIR_MODE='2', ECHO_MODE='3' };

TestingMode [3/3]

enum TestingMode

Enumerator
RX_MODE
TX_MODE
BIDIR_MODE
ECHO_MODE
RX_MODE
TX_MODE
BIDIR_MODE
ECHO_MODE
RX_MODE
TX_MODE
BIDIR_MODE
ECHO_MODE

Definition at line 106 of file test_toe.hpp.

{ RX_MODE='0', TX_MODE='1', BIDIR_MODE='2', ECHO_MODE='3' };

Function Documentation

cmdSetCommandParser()

void cmdSetCommandParser	(	const char *	callerName,
		vector< string >	stringVector
	)

Parse and handle a 'COMMAND/SET' request.

Parameters

[in]	callerName	The name of the caller process (e.g. "TB/IPRX").
[in]	stringVector	A tokenized vector of strings.

A test vector file may contain commands for setting testbench parameters such as an IP address or a TCP port number. Such a 'COMMAND/SET'can be identified by the presence of a character '>' at the first position of a '.dat' file's line, followed by a space character and the string 'SET'. Examples:

SET FpgatIp4Addr 192.168.1.23

Warning: This function does not return any thing but may set a specific global variable.

Definition at line 690 of file test_rx_engine.cpp.

                                                                              {
    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;
}

Here is the call graph for this function:

Here is the caller graph for this function:

cmdTestCommandParser()

void cmdTestCommandParser	(	const char *	callerName,
		vector< string >	stringVector
	)

Parse and handle a 'COMMAND/TEST' request.

Parameters

[in]	callerName	The name of the caller process (e.g. "TB/IPRX").
[in]	stringVector	A tokenized vector of strings.

A test vector file may contain commands for setting a testbench checker such as the verification of the IPv4-Header-Checksum field or the TCP checksum field. Such a 'COMMAND/TEST' can be identified by the presence of a character '>' at the first position of a '.dat' file's line, followed by a space character and the string 'TEST'. Examples:

TEST Ip4HdrCsum false TEST RcvdIp4Packet false

Warning: This function returns nothing but may set a specific global variable.

Definition at line 787 of file test_rx_engine.cpp.

                                                                               {
    //-- 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;
}

Here is the caller graph for this function:

drainMmioDropCounter()

template<typename T >

int drainMmioDropCounter	(	stream< T > &	ss,
		string	ssName
	)

Empty a DropCounter stream and throw it away.

Parameters

	[in/out]	ss A ref to the stream to drain.
[in]	ssName	The name of the stream to drain.

Returns

the number of dropped ellements.

Definition at line 101 of file test_rx_engine.cpp.

                                                                            {
    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);
}

increaseSimTime()

void increaseSimTime

(

unsigned int

cycles

)

Increase the simulation time of the testbench.

Parameters

[in]

The

number of cycles to increase.

Definition at line 77 of file test_rx_engine.cpp.

                                          {
    gMaxSimCycles += cycles;
}

Here is the caller graph for this function:

main()

int main	(	int	argc,
		char *	argv[]
	)

Main (does use any param).

Main function.

Parameters

[in]	mode	The test mode (0=RX_MODE, 1=TX_MODE, 2=BIDIR_MODE, 3=ECHO_MODE).
[in]	inpFile1	The pathname of the input file containing the test vectors to be fed to the TOE: If (mode==0 || mode=2) inpFile1 = siIPRX_<TestName> Else inpFile1 = siTAIF_<TestName>.
[in]	inpFile2	The pathname of the second input file containing the test vectors to be fed to the TOE: inpFile2 == siTAIF_<TestName>.

Remarks

: The number of input parameters is variable and depends on the testing mode. Example (see also file '../run_hls.tcl'): csim_design -argv "0 ../../../../test/testVectors/ipRx_OneSynPkt.dat"

Definition at line 64 of file test_ack_delay.cpp.

{
 
    //------------------------------------------------------
    //-- TESTBENCH GLOBAL VARIABLES
    //------------------------------------------------------
    gTraceEvent   = false;
    gFatalError   = false;
    gSimCycCnt    = 0;
    // gMaxSimCycles = TB_STARTUP_DELAY + TB_MAX_SIM_CYCLES;
 
    //------------------------------------------------------
    //-- TESTBENCH LOCAL VARIABLES
    //------------------------------------------------------
    int          nrErr = 0;     // Tb error counter.
    unsigned int rxEventSig=0;
    unsigned int txEventSig=0;
    int          nrInpSyn = 0;
    int          nrInpAck = 0;
    int          nrOutSyn = 0;
    int          nrOutAck = 0;
 
    //------------------------------------------------------
    //-- DUT STREAM INTERFACES and RELATED VARIABLEs
    //------------------------------------------------------
    //-- Incoming streams
    stream<ExtendedEvent> ssEVeToAKd_Event;
    //-- Outgoing streams
    stream<ExtendedEvent> ssAKdToTXe_Event;
    stream<SigBit>        ssAKdToEVe_RxEventSig;
    stream<SigBit>        ssAKdToEVe_TxEventSig;
 
    SessionId      sessId = TOE_MAX_SESSIONS-1;
    ExtendedEvent  outEvent;
 
 
 
    printInfo(THIS_NAME, "############################################################################\n");
    printInfo(THIS_NAME, "## TESTBENCH 'test_iprx' STARTS HERE                                      ##\n");
    printInfo(THIS_NAME, "############################################################################\n");
 
    int tbRun = 1000;
    int loop  = 0;
 
    while (tbRun) {
 
        //------------------------------------------------------
        //-- CREATE DUT INPUT TRAFFIC AS STREAMS
        //------------------------------------------------------
        if (loop == 5) {
            // Create a SYN event
            ssEVeToAKd_Event.write(Event(SYN_EVENT, sessId));
            nrInpSyn++;
        }
        else if (loop >= 10 and loop <  25) {
            // Create a burst of 10 ACKs every second clock cycle
            if (loop % 2 == 0) {
                ssEVeToAKd_Event.write(Event(ACK_EVENT, sessId));
                nrInpAck++;
            }
        }
        else if (loop > 100 and loop < 150) {
            // Create a burst of 10 ACKs every fourth loop
            if (loop % 4 == 0) {
                ssEVeToAKd_Event.write(Event(ACK_EVENT, sessId));
                nrInpAck++;
            }
        }
        else if (loop > 200 and loop < 300) {
            // Create a burst of ACKs every 10th loop
            if (loop % 10 == 0) {
                ssEVeToAKd_Event.write(Event(ACK_EVENT, sessId));
                nrInpAck++;
            }
        }
        loop++;
 
        //------------------------------------------------------
        //-- RUN DUT
        //------------------------------------------------------
        ack_delay(
            //-- Event Engine Interfaces
            ssEVeToAKd_Event,
            ssAKdToEVe_RxEventSig,
            ssAKdToEVe_TxEventSig,
            //-- Tx Engine Interface
            ssAKdToTXe_Event);
        tbRun--;
        stepSim();
 
        //---------------------------------------------------------------
        //-- DRAIN DUT OUTPUT STREAMS
        //---------------------------------------------------------------
        if (!ssAKdToTXe_Event.empty()) {
            ssAKdToTXe_Event.read(outEvent);
            if (outEvent.type == ACK_EVENT) {
                nrOutAck++;
            }
            else if (outEvent.type == SYN_EVENT) {
                nrOutSyn++;
            }
        }
        if (!ssAKdToEVe_RxEventSig.empty()) {
            ssAKdToEVe_RxEventSig.read();
            rxEventSig++;
        }
        if (!ssAKdToEVe_TxEventSig.empty()) {
            ssAKdToEVe_TxEventSig.read();
            txEventSig++;
        }
    }
 
    //---------------------------------------------------------------
    //-- PRINT OVERALL TESTBENCH STATUS
    //---------------------------------------------------------------
    printInfo(THIS_NAME, "Number of received  SYNs   : %5d \n", nrInpSyn);
    printInfo(THIS_NAME, "Number of forwarded SYNs   : %5d \n", nrOutSyn);
    printInfo(THIS_NAME, "Number of received  ACKs   : %5d \n", nrInpAck);
    printInfo(THIS_NAME, "Number of forwarded ACKs   : %5d \n", nrOutAck);
    printInfo(THIS_NAME, "Number of Rx event signals : %5d \n", rxEventSig);
    printInfo(THIS_NAME, "Number of Tx event signals : %5d \n", txEventSig);
 
    //---------------------------------------------------------------
    //-- ASSESS TESTBENCH RESULTS
    //---------------------------------------------------------------
    if (nrInpSyn != nrOutSyn)
        nrErr++;
    if (nrInpAck < nrOutAck)
        nrErr++;
    if ((nrInpSyn + nrInpAck) != rxEventSig)
        nrErr++;
    if ((nrOutSyn + nrOutAck) != txEventSig)
        nrErr++;
 
    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;
}

myCamAccessToString()

const char * myCamAccessToString

(

int

initiator

)

Convert an access CAM initiator into a string.

Parameters

[in]

initiator

The ID of the CAM accessor.

Returns

the corresponding string.

Definition at line 89 of file test_rx_engine.cpp.

                                               {
    return camAccessorStrings[initiator];
}

Here is the caller graph for this function:

pEmulateCam()

void pEmulateCam	(	stream< CamSessionLookupRequest > &	siTOE_SssLkpReq,
		stream< CamSessionLookupReply > &	soTOE_SssLkpRep,
		stream< CamSessionUpdateRequest > &	siTOE_SssUpdReq,
		stream< CamSessionUpdateReply > &	soTOE_SssUpdRep
	)

Emulate the behavior of the Content Addressable Memory (TOECAM).

Parameters

[in]	siTOE_SssLkpReq	Session lookup request from [TOE].
[out]	soTOE_SssLkpRep	Session lookup reply to [TOE].
[in]	siTOE_SssUpdReq	Session update request from [TOE].
[out]	soTOE_SssUpdRep	Session update reply to [TOE].

Definition at line 128 of file test_rx_engine.cpp.

{
    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()

Here is the call graph for this function:

pEmulateRxBufMem()

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
	)

Emulate the behavior of the Receive DDR4 Buffer Memory (RXMEM).

Parameters

	[in/out]	*memory A pointer to a dummy model of the DDR4 memory.
[in]	nrError	A reference to the error counter of the [TB].
[in]	siTOE_RxP_WrCmd	A ref to the write command stream from [TOE].
[in]	siTOE_RxP_Data	A ref to the data stream from [TOE].
[out]	soTOE_RxP_WrSts	A ref to the write status stream to [TOE].
[in]	siTOE_RxP_RdCmd	A ref to the read command stream from [TOE].
[out]	soTOE_RxP_Data	A ref to the data stream to [TOE].

Definition at line 238 of file test_rx_engine.cpp.

{
    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

Here is the call graph for this function:

pEmulateTxBufMem()

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
	)

Emulate the behavior of the Transmit DDR4 Buffer Memory (TXMEM).

Parameters

	[in/out]	*memory A pointer to a dummy model of the DDR4 memory.
[in]	nrError	A reference to the error counter of the [TB].
[in]	siTOE_TxP_WrCmd	A ref to the write command stream from TOE.
[in]	siTOE_TxP_Data	A ref to the data stream from TOE.
[out]	soTOE_TxP_WrSts	A ref to the write status stream to TOE.
[in]	siTOE_TxP_RdCmd	A ref to the read command stream from TOE.
[out]	soTOE_TxP_Data	A ref to the data stream to TOE.

Definition at line 391 of file test_rx_engine.cpp.

{
    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

Here is the call graph for this function:

pIPRX()

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
	)

Emulate the behavior of the IP Rx Path (IPRX).

Parameters

[in]	ifIPRX_Data	A ref to the input file w/ IP Rx packets.
[in]	ofTAIF_Gold	A ref to the output file w/ TCP App segments.
[in]	testRxPath	Indicates if the test of the Rx path is enabled.
	[i/o]	ipRxPktCounter A ref to the IP Rx packet counter. (counts all kinds and from all sessions).
	[i/o]	tcpBytCntr_IPRX_TOE A ref to the counter of TCP bytes sent from IPRX-to-TOE. (counts all kinds and from all sessions).
	[i/o]	ipRxPacketizer A ref to the RxPacketizer (double-ended queue).
[in]	sessAckList	A ref to an associative container which holds the sessions as socket pair associations.
[in]	piTOE_Ready	A reference to the ready signal of TOE.
[out]	soTOE_Data	A reference to the data stream to TOE.

Reads in new IPv4 packets from the Rx input file and stores them into the the IPv4 RxPacketizer (ipRxPacketizer). This ipRxPacketizer is a double-ended queue that is also fed by the process 'pIPTX' when it wants to generate ACK packets. If packets are stored in the 'ipRxPacketizer', they will be forwarded to the TOE over the 'sIRPX_Toe_Data' stream at the pace of one chunk per clock cycle.

Definition at line 1039 of file test_rx_engine.cpp.

{
    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

Here is the call graph for this function:

pIPRX_FeedTOE()

void pIPRX_FeedTOE	(	deque< SimIp4Packet > &	ipRxPacketizer,
		int &	ipRxPktCounter,
		stream< AxisIp4 > &	soTOE_Data,
		map< SocketPair, TcpAckNum > &	sessAckList
	)

Feed TOE with an IP packet.

Parameters

[in]	ipRxPacketizer	A ref to the deque w/ an IP Rx packets.
	[i/o]	ipRxPktCounter A ref to the IP Rx packet counter. (counts all kinds of packets and from all sessions).
[out]	soTOE_Data	A reference to the data stream to TOE.
[in]	sessAckList	a ref to an associative container that holds the sessions as socket pair associations.

: Empties the double-ended packetizer queue which contains the IPv4 packet chunks intended for the IPRX interface of the TOE. These chunks are written onto the 'sIPRX_Toe_Data' stream.

Definition at line 976 of file test_rx_engine.cpp.

{
    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();
        }
    }
}

Here is the call graph for this function:

Here is the caller graph for this function:

pIPRX_InjectAckNumber()

int pIPRX_InjectAckNumber	(	SimIp4Packet &	ipRxPacket,
		map< SocketPair, TcpAckNum > &	sessAckList
	)

Take the ACK number of a session and inject it into the sequence number field of the current packet.

Parameters

[in]	ipRxPacket	A ref to an IP packet.
[in]	sessAckList	A ref to an associative container which holds the sessions as socket pair associations.

Returns

0 or 1 if success otherwise -1.

Definition at line 893 of file test_rx_engine.cpp.

{
    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()

Here is the call graph for this function:

Here is the caller graph for this function:

pIPTX()

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
	)

Emulate the behavior of the IP Tx Handler (IPTX).

Parameters

[in]	piTOE_Ready	A reference to the ready signal of TOE.
[in]	siTOE_Data	A reference to the data stream from TOE.
[in]	ofIPTX_Data1	The output file to write.
[in]	ofIPTX_Data2	The output file to write.
[in]	sessAckList	A ref to an associative container which holds the sessions as socket pair associations.
	[i/o]	pktCounter_TOE_IPTX A ref to the counter of packets sent from TOE-to-IPTX (counts all kinds and from all sessions).
	[i/o]	tcpBytCntr_TOE_IPTX A ref to the TCP byte counter on the IP Tx I/F.
[out]	ipRxPacketizer	A ref to the IPv4 Rx packetizer.

Drains the data from the IPTX interface of the TOE and stores them into an IPv4 Tx Packet (ipTxPacket). This ipTxPacket is a double-ended queue used to accumulate all the data chunks until a whole packet is received. This queue is further read by a packet parser which either forwards the packets to an output file, or which generates an ACK packet that is injected into the 'ipRxPacketizer' (see process 'pIPRX').

Definition at line 1434 of file test_rx_engine.cpp.

{
    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

Here is the call graph for this function:

pIPTX_Parse()

bool pIPTX_Parse	(	SimIp4Packet &	ipTxPacket,
		map< SocketPair, TcpAckNum > &	sessAckList,
		deque< SimIp4Packet > &	ipRxPacketizer
	)

Parse the TCP/IP packets generated by the TOE.

Parameters

[in]	ipTxPacket	A ref to the packet received from the TOE.
[in]	sessAckList	A ref to an associative container which holds the sessions as socket pair associations.
[out]	ipRxPacketizer	A ref to dequeue w/ packets for IPRX.

Returns

true if an ACK was found [FIXME].

Looks for an ACK in the IP packet. If found, stores the 'ackNumber' from that packet into the 'seqNumber' deque of the Rx input stream and clears the deque containing the IP Tx packet.

Definition at line 1252 of file test_rx_engine.cpp.

{
    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()

Here is the call graph for this function:

Here is the caller graph for this function:

pTAIF()

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,
		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< TcpAppOpnReq > &	soTOE_OpnReq,
		stream< TcpAppOpnRep > &	siTOE_OpnRep,
		stream< TcpAppData > &	soTOE_Data,
		stream< TcpAppSndReq > &	soTOE_SndReq,
		stream< TcpAppSndRep > &	siTOE_SndRep,
		stream< TcpAppClsReq > &	soTOE_ClsReq
	)

Emulates the behavior of the TCP application interface (TAIF).

Parameters

[in]	testTxPath	Indicates if the Tx path is to be tested.
[in]	testMode	Indicates the test mode of operation (0|1|2|3).
[in]	nrError	A reference to the error counter of the [TB].
[in]	toeIpAddress	The local IP address used by the TOE.
[in]	ifTAIF_Data	A ref to the input Rx application file to read from.
[in]	ofTAIF_Data	A ref to the output Tx application file to write to.
[in]	ofIPTX_Gold2	A ref to the IPTX gold file to write to.
	[i/o]	appRxBytCntr A ref to the counter of bytes on the APP Rx I/F.
	[i/o]	appTxBytCntr A ref to the counter of bytes on the APP Tx I/F.
[in]	piTOE_Ready	A reference to the ready signal of [TOE].
[out]	soTOE_LsnReq	TCP listen port request to [TOE].
[in]	siTOE_LsnAck	TCP listen port acknowledge from [TOE].
[in]	siTOE_Notif	TCP notification from [TOE].
[out]	soTOE_DReq	TCP data request to [TOE].
[in]	siTOE_Data	TCP data stream from [TOE].
[in]	siTOE_Meta	TCP metadata stream from [TOE].
[out]	soTOE_OpnReq	TCP open port request to [TOE].
[in]	siTOE_OpnRep	TCP open port reply from [TOE].
[out]	soTOE_Data	TCP data stream to [TOE].
[out]	soTOE_SndReq	TCP data send request to [TOE].
[in]	siTOE_SndRep	TCP data send reply from [TOE].
[out]	soTOE_ClsReq	TCP close connection request to [TOE].

: The TCP Application Interface (TAIF) implements two processes: 1) pTAIF_Recv (TAr) that emulates the receive part of the application. 2) pTAIF_Send (TAs) that emulates the transmit part of the application.

Definition at line 2289 of file test_rx_engine.cpp.

{
 
    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

Here is the call graph for this function:

pTAIF_Recv()

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
	)

TCP Application Receive (TAr). Emulates the Rx process of the TAIF.

Parameters

[in]	nrError	A reference to the error counter of the [TB].
[in]	testMode	Indicates the test mode of operation (0|1|2|3).
[in]	ofTAIF_Data	A ref to the output Tx application file to write to.
	[i/o]	appTxBytCntr A ref to the counter of bytes on the Tx APP I/F.
[in]	piTOE_Ready	A reference to the ready signal of TOE.
[out]	soTOE_LsnReq	TCP listen port request to TOE.
[in]	siTOE_LsnAck	TCP listen port acknowledge from TOE.
[in]	siTOE_Notif	TCP notification from TOE.
[out]	soTOE_DReq	TCP data request to TOE.
[in]	siTOE_Data	TCP data stream from TOE.
[in]	siTOE_Meta	TCP metadata stream from TOE.
[out]	soTAs_Data	TCP data stream forwarded to TcpAppSend (TAs).
[out]	soTAs_SndReq	TCP data send request forwarded to [TAs].

Definition at line 1798 of file test_rx_engine.cpp.

{
    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

Here is the call graph for this function:

Here is the caller graph for this function:

pTAIF_Send()

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
	)

TCP Application Send (TAs). Emulates the Tx process of the TAIF.

Parameters

[in]	nrError	A reference to the error counter of the [TB].
[in]	testMode	Indicates the test mode of operation (0|1|2|3).
[in]	testTxPath	Indicates if the Tx path is to be tested.
[in]	toeIpAddress	The local IP address used by the TOE.
[in]	ifTAIF_Data	A ref to the input TAIF file to read.
[in]	ofIPTX_Gold2	A ref to the IPTX gold file to write.
	[i/o]	apRxBytCntr A ref to the counter of bytes on the APP Rx I/F.
[in]	piTOE_Ready	A reference to the ready signal of TOE.
[out]	soTOE_OpnReq	TCP open port request to [TOE].
[in]	siTOE_OpnRep	TCP open port reply to [TOE].
[out]	soTOE_Data	TCP data stream to [TOE].
[out]	soTOE_SndReq	TCP data send request to [TOE].
[in]	siTOE_SndRep	TCP data send reply from [TOE].
[out]	soTOE_ClsReq	TCP close connection request to [TOE].
[in]	siTAr_Data	TCP data stream from TcpAppRecv (TAr) process.
[in]	siTAr_SndReq	TCP data send request from [TAr].

: The max number of connections that can be opened is given by 'NO_TX_SESSIONS'.

Definition at line 1968 of file test_rx_engine.cpp.

{
    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

Here is the call graph for this function:

Here is the caller graph for this function:

pTcpAppConnect()

bool pTcpAppConnect	(	int &	nrError,
		SocketPair &	aSocketPair,
		map< SocketPair, SessionId > &	openSessList,
		stream< SockAddr > &	soTOE_OpnReq,
		stream< TcpAppOpnRep > &	siTOE_OpnRep
	)

TCP Application Connect (Tac). Requests TOE to open a new connection to a HOST socket.

Parameters

[in]	nrError	A reference to the error counter of the [TB].
[in]	aSocketPair	The socket pair of the connection to open.
[in]	openSessList	A ref to an associative container that holds the IDs of the opened sessions.
[out]	soTOE_OpnReq	TCP open connection request to [TOE].
[in]	siTOE_OpnRep	TCP open connection reply from [TOE].

Returns

true if the connection was successfully opened otherwise false.

Remarks

For testbench convenience, this is a sub-process of TcpAppSend (TAs).

Definition at line 1606 of file test_rx_engine.cpp.

{
    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

Here is the call graph for this function:

Here is the caller graph for this function:

pTcpAppEcho()

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
	)

TCP Application Echo (Tae). Performs an echo loopback between the receive and send parts of the TCP Application.

Parameters

[in]	nrError	A reference to the error counter of the [TB].
[in]	ofIPTX_Gold2	A ref to the IPTX gold file to write.
	[i/o]	apRxBytCntr A ref to the counter of bytes on the APP Rx I/F.
[out]	soTOE_Data	TCP data stream to [TOE].
[out]	soTOE_SndReq	TCP data send request to [TOE].
[in]	siTOE_SndRep	TCP data send reply from [TOE].
[in]	siTAr_Data	TCP data stream from TcpAppRecv (TAr) process.
[in]	siTAr_SndReq	TCP data send request from [TAr].

Remarks

For convenience, this is a sub-process of TcpAppSend (TAs).

Definition at line 1708 of file test_rx_engine.cpp.

{
    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

Here is the call graph for this function:

Here is the caller graph for this function:

pTcpAppListen()

bool pTcpAppListen	(	TcpPort	lsnPortNum,
		set< TcpPort > &	openedPorts,
		stream< TcpAppLsnReq > &	soTOE_LsnReq,
		stream< TcpAppLsnRep > &	siTOE_LsnRep
	)

TCP Application Listen (Tal). Requests TOE to listen on a new port.

Parameters

[in]	lsnPortNum	The port # to listen to.
[in]	openedPorts	A ref to the set of ports opened in listening mode.
[out]	soTOE_LsnReq	TCP listen port request to TOE.
[in]	siTOE_LsnRep	TCP listen port status from TOE.

Returns

true if listening was successful, otherwise false.

Remarks

For convenience, this is a sub-process of TcpAppRecv (TAr).

Definition at line 1533 of file test_rx_engine.cpp.

{
    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;
}

Here is the caller graph for this function:

setGlobalParameters()

bool setGlobalParameters	(	const char *	callerName,
		unsigned int	startupDelay,
		ifstream &	inputFile
	)

Parse the input test file and set the global parameters of the TB.

Parameters

[in]	callerName	The name of the caller process (e.g. "TB/IPRX").
[in]	startupDelay	The time it takes for TOE to be ready.
[in]	inputFile	A ref to the input file to parse.

: A global parameter specifies a general property of the testbench such as the minimum number of simulation cycles, the default IP address of the TOE or the default port to listen to. Such a parameter is passed to the TB via the test vector file. The line containing such a parameter must start with the single upper character 'G' followed by a space character. Examples: G PARAM SimCycles <NUM> G PARAM LocalSocket <ADDR> <PORT>

Definition at line 548 of file test_rx_engine.cpp.

{
    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

Here is the call graph for this function:

Here is the caller graph for this function:

stepSim()

void stepSim

(

)

Increment the simulation counter.

Increment the simulation counter of the testbench.

Definition at line 50 of file test_ack_delay.cpp.

               {
    gSimCycCnt++;
    if (gTraceEvent || ((gSimCycCnt % 100) == 0)) {
        printInfo(THIS_NAME, "-- [@%4.4d] -----------------------------\n", gSimCycCnt);
        gTraceEvent = false;
    }
    else if (0) {
        printInfo(THIS_NAME, "------------------- [@%d] ------------\n", gSimCycCnt);
    }
}

toe_top_wrap()

void toe_top_wrap	(	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,
		StsBit &	poNTS_Ready,
		stream< AxisIp4 > &	siIPRX_Data,
		stream< AxisIp4 > &	soIPTX_Data,
		stream< TcpAppNotif > &	soTAIF_Notif,
		stream< TcpAppRdReq > &	siTAIF_DReq,
		stream< TcpAppData > &	soTAIF_Data,
		stream< TcpAppMeta > &	soTAIF_Meta,
		stream< TcpAppLsnReq > &	siTAIF_LsnReq,
		stream< TcpAppLsnRep > &	soTAIF_LsnRep,
		stream< TcpAppData > &	siTAIF_Data,
		stream< TcpAppSndReq > &	siTAIF_SndReq,
		stream< TcpAppSndRep > &	soTAIF_SndRep,
		stream< TcpAppOpnReq > &	siTAIF_OpnReq,
		stream< TcpAppOpnRep > &	soTAIF_OpnRep,
		stream< TcpAppClsReq > &	siTAIF_ClsReq,
		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,
		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,
		stream< CamSessionLookupRequest > &	soCAM_SssLkpReq,
		stream< CamSessionLookupReply > &	siCAM_SssLkpRep,
		stream< CamSessionUpdateRequest > &	soCAM_SssUpdReq,
		stream< CamSessionUpdateReply > &	siCAM_SssUpdRep,
		stream< ap_uint< 16 > > &	soDBG_SssRelCnt,
		stream< ap_uint< 16 > > &	soDBG_SssRegCnt,
		stream< RxBufPtr > &	soDBG_RxFreeSpace,
		stream< ap_uint< 32 > > &	soDBG_TcpIpRxByteCnt,
		stream< ap_uint< 8 > > &	soDBG_OooDebug
	)

A wrapper for the Toplevel of the TCP Offload Engine (TOE).

Parameters

[in]	piMMIO_IpAddr	IP4 Address from [MMIO].
[out]	soMMIO_RxMemWrErr	Reports a Rx memory write error.
[out]	soMMIO_NotifDrop	The value of the notification drop counter.
[out]	soMMIO_MetaDrop	The value of the metadata drop counter.
[out]	soMMIO_DataDrop	The value of the data drop counter.
[out]	soMMIO_CrcDrop	The value of the CRC drop counter.
[out]	soMMIO_SessDrop	The value of the session drop counter.
[out]	soMMIO_OooDrop	The value of the out-of-order drop counter.
[out]	poNTS_Ready	Ready signal of TOE.
[in]	siIPRX_Data	IP4 data stream from [IPRX].
[out]	soIPTX_Data	IP4 data stream to [IPTX].
[out]	soTAIF_Notif	APP data notification to [TAIF].
[in]	siTAIF_DReq	APP data request from [TAIF].
[out]	soTAIF_Data	APP data stream to [TAIF].
[out]	soTAIF_Meta	APP metadata stream to [TAIF].
[in]	siTAIF_LsnReq	APP listen port request from [TAIF].
[out]	soTAIF_LsnRep	APP listen port reply to [TAIF].
[in]	siTAIF_Data	APP data stream from [TAIF].
[in]	siTAIF_SndReq	APP request to send from [TAIF].
[out]	soTAIF_SndRep	APP send reply to [TAIF].
[in]	siTAIF_OpnReq	APP open port request from [TAIF].
[out]	soTAIF_OpnRep	APP open port reply to [TAIF].
[in]	siTAIF_ClsReq	APP close connection request from [TAIF].

Warning

: Not-Used APP close connection status to [TAIF].

: Not-Used Rx memory read status from [MEM].

Parameters

[out]	soMEM_RxP_RdCmd	Rx memory read command to [MEM].
[in]	siMEM_RxP_Data	Rx memory data from [MEM].
[in]	siMEM_RxP_WrSts	Rx memory write status from [MEM].
[out]	soMEM_RxP_WrCmd	Rx memory write command to [MEM].
[out]	soMEM_RxP_Data	Rx memory data to [MEM].

Warning

: Not-Used Tx memory read status from [MEM].

Parameters

[out]	soMEM_TxP_RdCmd	Tx memory read command to [MEM].
[in]	siMEM_TxP_Data	Tx memory data from [MEM].
[in]	siMEM_TxP_WrSts	Tx memory write status from [MEM].
[out]	soMEM_TxP_WrCmd	Tx memory write command to [MEM].
[out]	soMEM_TxP_Data	Tx memory data to [MEM].
[out]	soCAM_SssLkpReq	Session lookup request to [CAM].
[in]	siCAM_SssLkpRep	Session lookup reply from [CAM].
[out]	soCAM_SssUpdReq	Session update request to [CAM].
[in]	siCAM_SssUpdRep	Session update reply from [CAM].
[out]	soDBG_SssRelCnt	Session release count (for DEBUG).
[out]	soDBG_SssRegCnt	Session register count (foe DEBUG).

This process is a wrapper for the 'toe_top' entity. It instantiates such an entity and further connects it with base 'AxisRaw' streams as expected by the 'toe_top'.

Definition at line 2437 of file test_rx_engine.cpp.

{
    //-- 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);
}

Here is the call graph for this function:

Variable Documentation

camAccessorStrings [1/3]

const char* camAccessorStrings[] = { "RXe", "TAi" }

Definition at line 81 of file test_rx_engine.cpp.

camAccessorStrings [2/3]

const char* camAccessorStrings[] = { "RXe", "TAi" }

Definition at line 81 of file test_tx_engine.cpp.

camAccessorStrings [3/3]

const char* camAccessorStrings[] = { "RXe", "TAi" }

Definition at line 81 of file test_toe.cpp.

gFatalError [1/4]

bool gFatalError = false

Definition at line 49 of file test_ack_delay.hpp.

gFatalError [2/4]

bool gFatalError = false

Definition at line 121 of file test_rx_engine.hpp.

gFatalError [3/4]

bool gFatalError = false

Definition at line 120 of file test_tx_engine.hpp.

gFatalError [4/4]

bool gFatalError = false

Definition at line 135 of file test_toe.hpp.

gFpgaIp4Addr [1/3]

Ip4Addr gFpgaIp4Addr = 0x0A0CC801

Definition at line 126 of file test_rx_engine.hpp.

gFpgaIp4Addr [2/3]

Ip4Addr gFpgaIp4Addr = 0x0A0CC801

Definition at line 125 of file test_tx_engine.hpp.

gFpgaIp4Addr [3/3]

Ip4Addr gFpgaIp4Addr = 0x0A0CC801

Definition at line 140 of file test_toe.hpp.

gFpgaLsnPort [1/3]

TcpPort gFpgaLsnPort = 0x0057

Definition at line 127 of file test_rx_engine.hpp.

gFpgaLsnPort [2/3]

TcpPort gFpgaLsnPort = 0x0057

Definition at line 126 of file test_tx_engine.hpp.

gFpgaLsnPort [3/3]

TcpPort gFpgaLsnPort = 0x0057

Definition at line 141 of file test_toe.hpp.

gFpgaSndPort [1/3]

TcpPort gFpgaSndPort = 0x8000

Definition at line 128 of file test_rx_engine.hpp.

gFpgaSndPort [2/3]

TcpPort gFpgaSndPort = 0x8000

Definition at line 127 of file test_tx_engine.hpp.

gFpgaSndPort [3/3]

TcpPort gFpgaSndPort = 0x8000

Definition at line 142 of file test_toe.hpp.

gHostIp4Addr [1/3]

Ip4Addr gHostIp4Addr = 0x0A0CC832

Definition at line 129 of file test_rx_engine.hpp.

gHostIp4Addr [2/3]

Ip4Addr gHostIp4Addr = 0x0A0CC832

Definition at line 128 of file test_tx_engine.hpp.

gHostIp4Addr [3/3]

Ip4Addr gHostIp4Addr = 0x0A0CC832

Definition at line 143 of file test_toe.hpp.

gHostLsnPort [1/3]

TcpPort gHostLsnPort = 0x0058

Definition at line 130 of file test_rx_engine.hpp.

gHostLsnPort [2/3]

TcpPort gHostLsnPort = 0x0058

Definition at line 129 of file test_tx_engine.hpp.

gHostLsnPort [3/3]

TcpPort gHostLsnPort = 0x0058

Definition at line 144 of file test_toe.hpp.

gMaxSimCycles [1/4]

unsigned int gMaxSimCycles = 25 + 2500

Definition at line 51 of file test_ack_delay.hpp.

gMaxSimCycles [2/4]

unsigned int gMaxSimCycles = ( 0x8000 ) + 2500

Definition at line 123 of file test_rx_engine.hpp.

gMaxSimCycles [3/4]

unsigned int gMaxSimCycles = ( 0x8000 ) + 2500

Definition at line 122 of file test_tx_engine.hpp.

gMaxSimCycles [4/4]

unsigned int gMaxSimCycles = ( 0x8000 ) + 2500

Definition at line 137 of file test_toe.hpp.

gSimCycCnt [1/4]

unsigned int gSimCycCnt = 0

GLOBAL VARIABLES USED BY THE SIMULATION ENVIRONMENT

Definition at line 50 of file test_ack_delay.hpp.

gSimCycCnt [2/4]

unsigned int gSimCycCnt = 0

GLOBAL VARIABLES USED BY THE SIMULATION ENVIRONMENT

Definition at line 122 of file test_rx_engine.hpp.

gSimCycCnt [3/4]

unsigned int gSimCycCnt = 0

GLOBAL VARIABLES USED BY THE SIMULATION ENVIRONMENT

Definition at line 121 of file test_tx_engine.hpp.

gSimCycCnt [4/4]

unsigned int gSimCycCnt = 0

GLOBAL VARIABLES USED BY THE SIMULATION ENVIRONMENT

Definition at line 136 of file test_toe.hpp.

gSortTaifGold [1/3]

bool gSortTaifGold = false

Definition at line 131 of file test_rx_engine.hpp.

gSortTaifGold [2/3]

bool gSortTaifGold = false

Definition at line 130 of file test_tx_engine.hpp.

gSortTaifGold [3/3]

bool gSortTaifGold = false

Definition at line 145 of file test_toe.hpp.

gTest_RcvdIp4HdrCsum [1/3]

bool gTest_RcvdIp4HdrCsum = true

Definition at line 135 of file test_rx_engine.hpp.

gTest_RcvdIp4HdrCsum [2/3]

bool gTest_RcvdIp4HdrCsum = true

Definition at line 134 of file test_tx_engine.hpp.

gTest_RcvdIp4HdrCsum [3/3]

bool gTest_RcvdIp4HdrCsum = true

Definition at line 149 of file test_toe.hpp.

gTest_RcvdIp4Packet [1/3]

bool gTest_RcvdIp4Packet = true

Definition at line 133 of file test_rx_engine.hpp.

gTest_RcvdIp4Packet [2/3]

bool gTest_RcvdIp4Packet = true

Definition at line 132 of file test_tx_engine.hpp.

gTest_RcvdIp4Packet [3/3]

bool gTest_RcvdIp4Packet = true

Definition at line 147 of file test_toe.hpp.

gTest_RcvdIp4TotLen [1/3]

bool gTest_RcvdIp4TotLen = true

Definition at line 134 of file test_rx_engine.hpp.

gTest_RcvdIp4TotLen [2/3]

bool gTest_RcvdIp4TotLen = true

Definition at line 133 of file test_tx_engine.hpp.

gTest_RcvdIp4TotLen [3/3]

bool gTest_RcvdIp4TotLen = true

Definition at line 148 of file test_toe.hpp.

gTest_RcvdLy4Csum [1/3]

bool gTest_RcvdLy4Csum = true

Definition at line 137 of file test_rx_engine.hpp.

gTest_RcvdLy4Csum [2/3]

bool gTest_RcvdLy4Csum = true

Definition at line 136 of file test_tx_engine.hpp.

gTest_RcvdLy4Csum [3/3]

bool gTest_RcvdLy4Csum = true

Definition at line 151 of file test_toe.hpp.

gTest_RcvdUdpLen [1/3]

bool gTest_RcvdUdpLen = true

Definition at line 136 of file test_rx_engine.hpp.

gTest_RcvdUdpLen [2/3]

bool gTest_RcvdUdpLen = true

Definition at line 135 of file test_tx_engine.hpp.

gTest_RcvdUdpLen [3/3]

bool gTest_RcvdUdpLen = true

Definition at line 150 of file test_toe.hpp.

gTest_SentIp4HdrCsum [1/3]

bool gTest_SentIp4HdrCsum = true

Definition at line 139 of file test_rx_engine.hpp.

gTest_SentIp4HdrCsum [2/3]

bool gTest_SentIp4HdrCsum = true

Definition at line 138 of file test_tx_engine.hpp.

gTest_SentIp4HdrCsum [3/3]

bool gTest_SentIp4HdrCsum = true

Definition at line 153 of file test_toe.hpp.

gTest_SentIp4TotLen [1/3]

bool gTest_SentIp4TotLen = true

Definition at line 138 of file test_rx_engine.hpp.

gTest_SentIp4TotLen [2/3]

bool gTest_SentIp4TotLen = true

Definition at line 137 of file test_tx_engine.hpp.

gTest_SentIp4TotLen [3/3]

bool gTest_SentIp4TotLen = true

Definition at line 152 of file test_toe.hpp.

gTest_SentLy4Csum [1/3]

bool gTest_SentLy4Csum = true

Definition at line 141 of file test_rx_engine.hpp.

gTest_SentLy4Csum [2/3]

bool gTest_SentLy4Csum = true

Definition at line 140 of file test_tx_engine.hpp.

gTest_SentLy4Csum [3/3]

bool gTest_SentLy4Csum = true

Definition at line 155 of file test_toe.hpp.

gTest_SentUdpLen [1/3]

bool gTest_SentUdpLen = true

Definition at line 140 of file test_rx_engine.hpp.

gTest_SentUdpLen [2/3]

bool gTest_SentUdpLen = true

Definition at line 139 of file test_tx_engine.hpp.

gTest_SentUdpLen [3/3]

bool gTest_SentUdpLen = true

Definition at line 154 of file test_toe.hpp.

gTraceEvent [1/4]

bool gTraceEvent = false

HELPERS FOR THE DEBUGGING TRACES .e.g: DEBUG_LEVEL = (MDL_TRACE | IPS_TRACE)

Definition at line 48 of file test_ack_delay.hpp.

gTraceEvent [2/4]

bool gTraceEvent = false

HELPERS FOR THE DEBUGGING TRACES .e.g: DEBUG_LEVEL = (MDL_TRACE | IPS_TRACE)

Definition at line 120 of file test_rx_engine.hpp.

gTraceEvent [3/4]

bool gTraceEvent = false

HELPERS FOR THE DEBUGGING TRACES .e.g: DEBUG_LEVEL = (MDL_TRACE | IPS_TRACE)

Definition at line 119 of file test_tx_engine.hpp.

gTraceEvent [4/4]

bool gTraceEvent = false

HELPERS FOR THE DEBUGGING TRACES .e.g: DEBUG_LEVEL = (MDL_TRACE | IPS_TRACE)

Definition at line 134 of file test_toe.hpp.