Diff: main.cpp

Revision:

5:16d6db68e32f

Parent:

4:0406e4e7639f

--- a/main.cpp	Mon Feb 10 08:38:15 2014 +0000
+++ b/main.cpp	Wed Apr 09 13:50:55 2014 +0000
@@ -1,3 +1,7 @@
+/*
+*   This is an endurance test that downloads text, an image and a pdf file from the web in a loop using PicoTCP
+*   Debug output is printed to the USB serial port (what it is doing and memory stats)
+*/
 #include "mbed.h"
 #include <stdarg.h>
 #include "EthernetInterface.h"
@@ -6,22 +10,21 @@
 
 //#define msgdbg printf
 
-
-#define SENDING_RETRIES    3u
-#define READING_RETRIES    7u
-#define DHCP_RETRIES       10u
+#define SENDING_RETRIES    3
+#define READING_RETRIES    10
+#define DHCP_RETRIES       10
 #define BUFFER_SIZE        256
 
-#define NUMBER_OF_HOSTS   3u
+#define NUMBER_OF_HOSTS   3
 
-#define MBED_HOST               "www.mbed.org"
-#define MBED_HOST_REQUEST       "GET /media/uploads/mbed_official/hello.txt HTTP/1.0\n\n"
+#define HOST_1              "www.mbed.org"
+#define HOST_1_REQUEST      "GET /media/uploads/mbed_official/hello.txt HTTP/1.0\n\n"
 
-#define MEDIAFAX_HOST           "www.mediafax.ro"
-#define MEDIAFAX_HOST_REQUEST   "GET / HTTP/1.1\nHost: www.mediafax.ro\n\n"
+#define HOST_2              "www.mbed.org"
+#define HOST_2_REQUEST      "GET /media/img/boardlogos/lpc1768/pinout.png\nHost: www.mbed.org\n\n"
 
-#define NXP_HOST                "www.nxp.com"
-#define NXP_HOST_REQUEST        "GET /documents/user_manual/UM10360.pdf HTTP/1.0\nHost: www.nxp.com\n\n"
+#define HOST_3              "www.nxp.com"
+#define HOST_3_REQUEST      "GET /documents/user_manual/UM10360.pdf HTTP/1.0\nHost: www.nxp.com\n\n"
 
 int totalTime = 0;
 
@@ -29,29 +32,29 @@
 {
     char request[70];
     char host[20];
-    int avgDuration;
+    int sumDuration;
     int maxReceived;
     int minReceived;
     int snapshots;
 };
 
-struct WebStats webStatistics[NUMBER_OF_HOSTS]= 
+struct WebStats webStatistics[NUMBER_OF_HOSTS]=
 {
-    {MBED_HOST_REQUEST,MBED_HOST,0,0,0x7FFFFFFF,0},
-    {MEDIAFAX_HOST_REQUEST,MEDIAFAX_HOST,0,0,0x7FFFFFFF,0},
-    {NXP_HOST_REQUEST,NXP_HOST,0,0,0x7FFFFFFF,0}
+    {HOST_1_REQUEST,HOST_1,0,0,0x7FFFFFFF,0},
+    {HOST_2_REQUEST,HOST_2,0,0,0x7FFFFFFF,0},
+    {HOST_3_REQUEST,HOST_3,0,0,0x7FFFFFFF,0}
 };
 
 void inline printMemoryStats(void);
 void printStatistics(void)
 {
-    printf("\nTotal Time : %f seconds\n",(float)totalTime/1000.0f);    
+    printf("\nTotal Time : %f seconds\n",(float)totalTime/1000.0f);
     for(int i=0;i<NUMBER_OF_HOSTS;i++)
     {
         printf("Host number : %d | %s\n",i, webStatistics[i].host);
-        printf("MaxRecv : %d\n",webStatistics[i].maxReceived);
-        printf("MinRecv : %d\n",webStatistics[i].minReceived);
-        printf("Avg duration : %d ms\n",webStatistics[i].avgDuration);
+        printf("MaxRecv : %d\n", webStatistics[i].maxReceived);
+        printf("MinRecv : %d\n", webStatistics[i].minReceived);
+        printf("Avg duration : %d ms\n", webStatistics[i].sumDuration / webStatistics[i].snapshots);
         printf("Total snapshots : %d\n\n",webStatistics[i].snapshots);
     }
     printMemoryStats();
@@ -74,7 +77,7 @@
     struct MemoryUsage * memStat = (struct MemoryUsage *)pvHeapInfo;
     static const char* freeRamFormat = "%d bytes in";
     va_list valist;
-    
+
     if(memcmp(pFormatString,freeRamFormat,strlen(freeRamFormat)) == 0)
     {
         va_start(valist, pFormatString);
@@ -82,11 +85,12 @@
         memStat->curFreeRam = freeSize;
         if(memStat->minFreeRam > freeSize)
             memStat->minFreeRam = freeSize;
-        
+
         if(memStat->maxFreeRam < freeSize)
             memStat->maxFreeRam = freeSize;
-            
-        memStat->avgFreeRam = ((memStat->avgFreeRam * memStat->cntSamples) + freeSize)/(++memStat->cntSamples);
+
+        memStat->avgFreeRam = ((memStat->avgFreeRam * memStat->cntSamples) + freeSize)/(memStat->cntSamples + 1);
+        memStat->cntSamples++;
     }
     else
     {
@@ -101,11 +105,11 @@
         printf("\n\n***** Initial Memory Report *****\n");
     else
         printf("\n\n********* Memory Report *********\n");
-    
-    printf("Current free memory : %d bytes\n",memoryStats.curFreeRam);
-    printf("Maximum free memory : %d bytes\n",memoryStats.maxFreeRam);
-    printf("Minimum free memory : %d bytes\n",memoryStats.minFreeRam);
-    printf("Average free memory : %d bytes\n",memoryStats.avgFreeRam);
+
+    printf("Current free memory : %d bytes\n", (int)memoryStats.curFreeRam);
+    printf("Maximum free memory : %d bytes\n", (int)memoryStats.maxFreeRam);
+    printf("Minimum free memory : %d bytes\n", (int)memoryStats.minFreeRam);
+    printf("Average free memory : %d bytes\n", (int)memoryStats.avgFreeRam);
     printf("****************************\n");
 }
 
@@ -114,13 +118,12 @@
     __heapstats((__heapprt)fakePrintf, &memoryStats);
 }
 
+int main() {
 
-int main() {
-    
     int retries = 0;
     EthernetInterface eth;
     TCPSocketConnection client;
-    
+
     printf("Initialising...\n");
 
     // use DHCP
@@ -136,11 +139,12 @@
             goto failure;
         }
     };
-    
+
     printf("[%llu] Starting the robustness test...\n",PICO_TIME_MS());
-    
-    while(1) 
+
+    while(1)
     {
+        printf("Starting cycle ****************************************\n");
         for(int i=0;i<NUMBER_OF_HOSTS;i++,client.close())
         {
             int retries = 0;
@@ -148,28 +152,26 @@
             int time = 0;
             char tmpBuffer[BUFFER_SIZE];
             int ret;
-            
+
             printf("Mbed --> %s\n",webStatistics[i].host);
-            
+
             time = PICO_TIME_MS();
             // connecting
             if (client.connect(webStatistics[i].host, 80)) {
                 printf("Failed to connect to : %s\n",webStatistics[i].host);
                 continue;
-            }                    
-            
-            client.set_blocking(false,8000);
+            }
+
+            client.set_blocking(false, 8000);
             retries = 0;
-            
+
             // sending request
-
             ret = client.send_all(webStatistics[i].request,strlen(webStatistics[i].request));
-            if (ret <= 0) 
-            {
+            if (ret <= 0) {
                 printf("This test failed big time, ret=%d, err=%d!!\n", ret, pico_err);
                 while(1);;;
             }
-            
+
             retries = 0;
             // start reading
             while(true)
@@ -180,49 +182,42 @@
                     retries++;
                 } else if (ret < 0) {
                     if (pico_err != PICO_ERR_ESHUTDOWN) {
-                        printf("Read error, bailing out. Ret = %d, err = %d\n", ret, pico_err);
-                        while(1);;;
+                        printf("Read error, skipping. Ret = %d, err = %d\n", ret, pico_err);
+                        break;
                     }
                     client.close();
                     break;
                 } else {
                     received += ret;
                 }
-                
+
                 if(retries == READING_RETRIES) {
-                    printf("Read operation failed too many times. Giving up.\n");
+                    printf("Read operation failed too many times: skipping.\n");
                     break;
-                }      
+                }
             }
-            
-            
-            
+
             //Snapshot!
             time = PICO_TIME_MS() - time;
-            
+
             if(webStatistics[i].maxReceived < received)
-            {
                 webStatistics[i].maxReceived = received;
-            }
-            
+
             if(webStatistics[i].minReceived > received)
-            {
                 webStatistics[i].minReceived = received;
-            }
+
             printf("Received : %d bytes\n",received);
-            if (received <= 0) {
-               printf("Test FAILED!\n"); 
-               while(1);;;  
-            }
-            webStatistics[i].avgDuration = ((webStatistics[i].avgDuration *(webStatistics[i].snapshots++) ) + time)/webStatistics[i].snapshots;
+            webStatistics[i].sumDuration += time;
+            webStatistics[i].snapshots++;
             totalTime += time;
             memoryStamp();
         }
-        
+
         printStatistics();
         Thread::wait(500);
     }
-    failure:    
+    failure:
     printf("Fatal error. Main thread is inactive\n");
     while(1);
 }
+