Measuring throughput

Hi Yuri,

Below is the code I'm using with CC3100 SimpleLink Studio for UDP Tx.

I hope it helps.

Best Regards,
Nir Nitzani

void udpTx(int argc, char *argv[] )
{
SlSockAddrIn_t Addr;
SlSockAddrIn_t LocalAddr;
unsigned char BsdBuf[1500];
int i;
short TestBufLen;
int AddrSize;
int SockID;
int Status;
long LoopCount = 0;
long long BytesSent = 0;
SYSTEMTIME st={0};
SYSTEMTIME st_start={0};
FILETIME startTime;
FILETIME currTime;
ULONGLONG diff;
long numOfSeconds=0,oldNumOfSeconds=0;
float throughput;
unsigned long ip;
unsigned long packetSent=0;
long packetCount=0;


printf(" UDP Tx Test\n\n");

TestBufLen = 1470;

for (i=0 ; i<TestBufLen ; i++)
{

BsdBuf[i] = 0x30 + (char)(i % 10);
}


if( (0 < argc) && (NULL != argv) )
{
ip = getIp( argv[0] );
}
else
{
logTimeStamp(0);
printf("Error in Paramaters\n");
return;
}

if(1 == gLowTP)
{
TestBufLen = 40;
}

Addr.sin_family = SL_AF_INET;
Addr.sin_port = sl_Htons(5001);
Addr.sin_addr.s_addr = sl_Htonl(ip);

AddrSize = sizeof(SlSockAddrIn_t);


LocalAddr.sin_family = SL_AF_INET;
LocalAddr.sin_port = sl_Htons(5001);
LocalAddr.sin_addr.s_addr = sl_Htonl(g_LocalIp);

GetSystemTimeAsFileTime(&startTime);
GetSystemTimeAsFileTime(&currTime);
diff = (((ULONGLONG)(currTime.dwHighDateTime))<<32 | ((ULONGLONG)(currTime.dwLowDateTime))) -
(((ULONGLONG)(startTime.dwHighDateTime))<<32 | ((ULONGLONG)(startTime.dwLowDateTime)));
oldNumOfSeconds = (long)(diff/10000000);

srand(time(NULL));


SockID = sl_Socket(SL_AF_INET,SL_SOCK_DGRAM, SL_IPPROTO_UDP);
if( SockID < 0 )
{
// error
logTimeStamp(0);
printf("Error Opening Socket\n");
while (1);
}

printf("UDP RX - Bind to Address : %d.%d.%d.%d\n",
SL_IPV4_BYTE(LocalAddr.sin_addr.s_addr,0),
SL_IPV4_BYTE(LocalAddr.sin_addr.s_addr,1),
SL_IPV4_BYTE(LocalAddr.sin_addr.s_addr,2),
SL_IPV4_BYTE(LocalAddr.sin_addr.s_addr,3));

// This is not a must but it will allow running UDP Tx number of times without resting the IPERF
Status = sl_Bind(SockID, (SlSockAddr_t *)&LocalAddr, AddrSize);
if( Status < 0 )
{
logTimeStamp(0);
printf("Error Binding\n");
while (1);
}

GetSystemTime(&st);

do
{

*(long*)&BsdBuf[4] = sl_Htonl(((st.wHour - st_start.wHour)*3600 + st.wSecond - st_start.wSecond));
*(long*)&BsdBuf[8] = sl_Htonl(st.wMilliseconds*1000);

packetSent++;

BsdBuf[0] = packetCount >> 24 & 0xFF;
BsdBuf[1] = packetCount >> 16 & 0xFF;
BsdBuf[2] = packetCount >> 8 & 0xFF;
BsdBuf[3] = packetCount & 0xFF;

packetCount++;


Status = sl_SendTo(SockID, BsdBuf, TestBufLen, 0, ( SlSockAddr_t *)&Addr, sizeof(Addr));
if( Status <= 0 )
{
// error
logTimeStamp(0);
printf("Error on sl_SendTo %d\n",Status);
while (1);
}

LoopCount++;
BytesSent += Status;

GetSystemTimeAsFileTime(&currTime);
diff = (((ULONGLONG)(currTime.dwHighDateTime))<<32 | ((ULONGLONG)(currTime.dwLowDateTime))) -
(((ULONGLONG)(startTime.dwHighDateTime))<<32 | ((ULONGLONG)(startTime.dwLowDateTime)));
numOfSeconds = (long)(diff/10000000);

if(numOfSeconds > oldNumOfSeconds)
{
oldNumOfSeconds = numOfSeconds;
throughput = ((float)BytesSent)*8/1024/1024;
printf("%10d : UDP Tx TEST [Packets=%10d , Mbits=%3.3f]\n",numOfSeconds,LoopCount,throughput);
BytesSent =0;
}



} while (0 == UDP_TX_RUN_TIME || numOfSeconds<UDP_TX_RUN_TIME);

sl_Close(SockID);

Sleep(100);

logTimeStamp(0);
printf("Info : UDP TX Close Socket\n");

sl_Close(SockID);

return;
}