Merge pull request #4546 from bridadan/fix_test_prints

Fix bad test print and move locks for printf into macro.

Author: adbridge

features/FEATURE_LWIP/TESTS/mbedmicro-net/udp_echo_parallel/main.cpp

@@ -34,6 +34,13 @@ SocketAddress udp_addr;
 Mutex iomutex;
 char uuid[GREENTEA_UUID_LENGTH] = {0};
 
+// Thread safe printf macro
+#define TS_PRINTF(...) {\
+    iomutex.lock();\
+    printf(__VA_ARGS__);\
+    iomutex.unlock();\
+}
+
 // NOTE: assuming that "id" stays in the single digits
 //
 // Creates a buffer that first contains the thread's id.
@@ -64,7 +71,6 @@ void prep_buffer(unsigned int id, char *uuid, char *tx_buffer, size_t tx_size) {
     }
 }
 
-
 // Each echo class is in charge of one parallel transaction
 class Echo {
 private:
@@ -105,36 +111,26 @@ class Echo {
             prep_buffer(id, uuid, tx_buffer, sizeof(tx_buffer));
             int ret = sock.sendto(udp_addr, tx_buffer, sizeof(tx_buffer));
             if (ret >= 0) {
-                iomutex.lock();
-                printf("[ID:%01u][%02u] sent %d bytes - %.*s  \n", id, i, ret, ret, tx_buffer);
-                iomutex.unlock();
+                TS_PRINTF("[ID:%01u][%02u] sent %d bytes - %.*s  \n", id, i, ret, ret, tx_buffer);
             } else {
-                iomutex.lock();
-                printf("[ID:%01u][%02u] Network error %d\n", id, i, ret);
-                iomutex.unlock();
+                TS_PRINTF("[ID:%01u][%02u] Network error %d\n", id, i, ret);
                 continue;
             }
 
             SocketAddress temp_addr;
             ret = sock.recvfrom(&temp_addr, rx_buffer, sizeof(rx_buffer));
             if (ret >= 0) {
-                iomutex.lock();
-                printf("[ID:%01u][%02u] recv %d bytes - %.*s  \n", id, i, ret, ret, tx_buffer);
-                iomutex.unlock();
+                TS_PRINTF("[ID:%01u][%02u] recv %d bytes - %.*s  \n", id, i, ret, ret, tx_buffer);
             } else {
-                iomutex.lock();
-                printf("[ID:%01u][%02u] Network error %d\n", id, i, ret);
-                iomutex.unlock();
+                TS_PRINTF("[ID:%01u][%02u] Network error %d\n", id, i, ret);
                 continue;
             }
 
             if ((temp_addr == udp_addr &&
                  ret == sizeof(tx_buffer) &&
                  memcmp(rx_buffer, tx_buffer, sizeof(rx_buffer)) == 0)) {
                 success += 1;
-                iomutex.lock();
-                printf("[ID:%01u][%02u] success #%d\n", id, i, success);
-                iomutex.unlock();
+                TS_PRINTF("[ID:%01u][%02u] success #%d\n", id, i, success);
                 continue;
             }
 
@@ -151,9 +147,15 @@ class Echo {
 
         result = success == ECHO_LOOPS;
 
+        if (result) {
+            TS_PRINTF("[ID:%01u] Succeeded all %d times!\n", id, success);
+        } else {
+            TS_PRINTF("[ID:%01u] Only succeeded %d times out of a required %d.\n", id, success, ECHO_LOOPS);
+        }
+
         err = sock.close();
-        printf("[ID:%01u] Failed to close socket!\n", id);
         if (err) {
+            TS_PRINTF("[ID:%01u] Failed to close socket!\n", id);
             result = false;
         }
     }