Change TESTS/netsocket/ for cellular testing

Author: Ari Parkkila

TESTS/netsocket/README.md

@@ -402,7 +402,7 @@ Call `Socket::open()` and then destruct the socket
 1.  Create a object by calling `new Socket()`
 2.  Call `Socket::open(stack)`
 3.  Call "delete" for the object
-4.  Repeat 1000 times.
+4.  Repeat 100 times.
 
 **Expected result:**
 
@@ -1027,7 +1027,7 @@ Repeatedly send small packets.
 
 1.  Call `TCPSocket::connect("echo.mbedcloudtesting.com", 9);`
 2.  Call `TCPSocket::send("hello", 5);`
-3.  repeat 1000 times
+3.  repeat 100 times
 4.  destroy the socket
 
 **Expected result:**

TESTS/netsocket/dns/asynchronous_dns_simultaneous_repeat.cpp

@@ -33,7 +33,7 @@ int result_exp_timeout;
 void ASYNCHRONOUS_DNS_SIMULTANEOUS_REPEAT()
 {
 
-    for (int i = 0; i < 100; i++) {
+    for (int i = 0; i < 10; i++) {
         do_asynchronous_gethostbyname(dns_test_hosts, MBED_CONF_APP_DNS_SIMULT_QUERIES + 1, &result_ok, &result_no_mem,
                                       &result_dns_failure, &result_exp_timeout);
 

TESTS/netsocket/dns/main.cpp

@@ -157,14 +157,26 @@ static void net_bringup()
     printf("MBED: IP address is '%s'\n", net->get_ip_address());
 }
 
+static void net_bringdown()
+{
+    NetworkInterface::get_default_instance()->disconnect();
+    printf("MBED: ifdown\n");
+}
+
 // Test setup
 utest::v1::status_t test_setup(const size_t number_of_cases)
 {
-    GREENTEA_SETUP(200, "default_auto");
+    GREENTEA_SETUP(10 * 60, "default_auto");
     net_bringup();
     return verbose_test_setup_handler(number_of_cases);
 }
 
+void greentea_teardown(const size_t passed, const size_t failed, const failure_t failure)
+{
+    net_bringdown();
+    return greentea_test_teardown_handler(passed, failed, failure);
+}
+
 Case cases[] = {
     Case("ASYNCHRONOUS_DNS", ASYNCHRONOUS_DNS),
     Case("ASYNCHRONOUS_DNS_SIMULTANEOUS", ASYNCHRONOUS_DNS_SIMULTANEOUS),
@@ -181,7 +193,7 @@ Case cases[] = {
     Case("SYNCHRONOUS_DNS_INVALID", SYNCHRONOUS_DNS_INVALID),
 };
 
-Specification specification(test_setup, cases, greentea_continue_handlers);
+Specification specification(test_setup, cases, greentea_teardown, greentea_continue_handlers);
 
 int main()
 {

TESTS/netsocket/tcp/tcp_tests.h

@@ -36,7 +36,7 @@ int fetch_stats(void);
 int split2half_rmng_tcp_test_time(); // [s]
 
 namespace tcp_global {
-static const int TESTS_TIMEOUT = 480;
+static const int TESTS_TIMEOUT = (10 * 60);
 static const int TCP_OS_STACK_SIZE = 2048;
 
 static const int RX_BUFF_SIZE = 1220;

TESTS/netsocket/tcp/tcpsocket_echotest.cpp

@@ -96,29 +96,32 @@ void TCPSOCKET_ECHOTEST()
 
 void tcpsocket_echotest_nonblock_receive()
 {
-    int recvd = sock.recv(&(tcp_global::rx_buffer[bytes2recv_total - bytes2recv]), bytes2recv);
-    if (recvd == NSAPI_ERROR_WOULD_BLOCK) {
-        if (tc_exec_time.read() >= time_allotted) {
+    while (bytes2recv > 0) {
+        int recvd = sock.recv(&(tcp_global::rx_buffer[bytes2recv_total - bytes2recv]), bytes2recv);
+        if (recvd == NSAPI_ERROR_WOULD_BLOCK) {
+            if (tc_exec_time.read() >= time_allotted) {
+                TEST_FAIL();
+                receive_error = true;
+                tx_sem.release();
+                return;
+            }
+            continue;
+        } else if (recvd < 0) {
+            TEST_FAIL();
             receive_error = true;
+            tx_sem.release();
+            return;
         }
-        return;
-    } else if (recvd < 0) {
-        receive_error = true;
-    } else {
-        bytes2recv -= recvd;
-    }
 
-    if (bytes2recv == 0) {
-        TEST_ASSERT_EQUAL(0, memcmp(tcp_global::tx_buffer, tcp_global::rx_buffer, bytes2recv_total));
-
-        static int round = 0;
-        printf("[Recevr#%02d] bytes received: %d\n", round++, bytes2recv_total);
-        tx_sem.release();
-    } else if (receive_error || bytes2recv < 0) {
-        TEST_FAIL();
-        tx_sem.release();
+        bytes2recv -= recvd;
+        if (!bytes2recv) {
+            TEST_ASSERT_EQUAL(0, memcmp(tcp_global::tx_buffer, tcp_global::rx_buffer, bytes2recv_total));
+            static int round = 0;
+            printf("[Recevr#%02d] bytes received: %d\n", round++, bytes2recv_total);
+            tx_sem.release();
+            break;
+        }
     }
-    // else - no error, not all bytes were received yet.
 }
 
 void TCPSOCKET_ECHOTEST_NONBLOCK()

TESTS/netsocket/tcp/tcpsocket_echotest_burst.cpp

@@ -28,7 +28,7 @@ namespace {
 static const int SIGNAL_SIGIO = 0x1;
 static const int SIGIO_TIMEOUT = 20000; //[ms]
 
-static const int BURST_CNT = 100;
+static const int BURST_CNT = 20;
 static const int BURST_SIZE = 1220;
 }
 

TESTS/netsocket/tcp/tcpsocket_endpoint_close.cpp

@@ -24,6 +24,16 @@
 
 using namespace utest::v1;
 
+namespace {
+static const int SIGNAL_SIGIO = 0x1;
+static const int SIGIO_TIMEOUT = 20000; //[ms]
+}
+
+static void _sigio_handler(osThreadId id)
+{
+    osSignalSet(id, SIGNAL_SIGIO);
+}
+
 static nsapi_error_t _tcpsocket_connect_to_daytime_srv(TCPSocket &sock)
 {
     SocketAddress tcp_addr;
@@ -52,6 +62,7 @@ void TCPSOCKET_ENDPOINT_CLOSE()
         TEST_FAIL();
         return;
     }
+    sock.sigio(callback(_sigio_handler, ThisThread::get_id()));
 
     int recvd = 0;
     int recvd_total = 0;
@@ -62,6 +73,13 @@ void TCPSOCKET_ENDPOINT_CLOSE()
         } else if (recvd <= 0) {
             TEST_ASSERT_EQUAL(0, recvd);
             break;
+        } else if (recvd == NSAPI_ERROR_WOULD_BLOCK) {
+            if (tc_exec_time.read() >= time_allotted ||
+                    osSignalWait(SIGNAL_SIGIO, SIGIO_TIMEOUT).status == osEventTimeout) {
+                TEST_FAIL();
+                break;
+            }
+            continue;
         }
         recvd_total += recvd;
         TEST_ASSERT(recvd_total < MORE_THAN_AVAILABLE);

TESTS/netsocket/tcp/tcpsocket_open_destruct.cpp

@@ -33,7 +33,7 @@ void TCPSOCKET_OPEN_DESTRUCT()
     }
 #endif
 
-    for (int i = 0; i < 1000; i++) {
+    for (int i = 0; i < 100; i++) {
         TCPSocket *sock = new TCPSocket;
         if (!sock) {
             TEST_FAIL();

TESTS/netsocket/tcp/tcpsocket_send_repeat.cpp

@@ -32,7 +32,7 @@ void TCPSOCKET_SEND_REPEAT()
     int snd;
     Timer timer;
     static const char tx_buffer[] = {'h', 'e', 'l', 'l', 'o'};
-    for (int i = 0; i < 1000; i++) {
+    for (int i = 0; i < 100; i++) {
         snd = sock.send(tx_buffer, sizeof(tx_buffer));
         if (snd != sizeof(tx_buffer)) {
             TEST_FAIL();

TESTS/netsocket/tcp/tcpsocket_send_timeout.cpp

@@ -44,6 +44,7 @@ void TCPSOCKET_SEND_TIMEOUT()
                 (timer.read_ms() <= 800)) {
             continue;
         }
+        printf("send: err %d, time %d", err, timer.read_ms());
         TEST_FAIL();
         break;
     }