From 1fe4406f374291ab2e86e95a97341fd9c475fcb8 Mon Sep 17 00:00:00 2001 From: Jun Wako Date: Fri, 24 Apr 2015 16:26:14 +0900 Subject: Squashed 'tmk_core/' changes from 7967731..b9e0ea0 b9e0ea0 Merge commit '7fa9d8bdea3773d1195b04d98fcf27cf48ddd81d' as 'tool/mbed/mbed-sdk' 7fa9d8b Squashed 'tool/mbed/mbed-sdk/' content from commit 7c21ce5 git-subtree-dir: tmk_core git-subtree-split: b9e0ea08cb940de20b3610ecdda18e9d8cd7c552 --- .../tests/net/echo/tcp_client_loop/main.cpp | 78 ++++++++++++++++++++++ 1 file changed, 78 insertions(+) create mode 100644 tool/mbed/mbed-sdk/libraries/tests/net/echo/tcp_client_loop/main.cpp (limited to 'tool/mbed/mbed-sdk/libraries/tests/net/echo/tcp_client_loop/main.cpp') diff --git a/tool/mbed/mbed-sdk/libraries/tests/net/echo/tcp_client_loop/main.cpp b/tool/mbed/mbed-sdk/libraries/tests/net/echo/tcp_client_loop/main.cpp new file mode 100644 index 0000000000..6c797e7443 --- /dev/null +++ b/tool/mbed/mbed-sdk/libraries/tests/net/echo/tcp_client_loop/main.cpp @@ -0,0 +1,78 @@ +#include "mbed.h" +#include "test_env.h" +#include "EthernetInterface.h" +#include + +namespace { + const int BUFFER_SIZE = 64; + const int MAX_ECHO_LOOPS = 1000; + const char ASCII_MAX = '~' - ' '; + + struct s_ip_address + { + int ip_1; + int ip_2; + int ip_3; + int ip_4; + }; +} + +char char_rand() { + return (rand() % ASCII_MAX) + ' '; +} + +int main() { + MBED_HOSTTEST_TIMEOUT(20); + MBED_HOSTTEST_SELECT(tcpecho_client_auto); + MBED_HOSTTEST_DESCRIPTION(TCP client echo loop); + MBED_HOSTTEST_START("NET_13"); + + char buffer[BUFFER_SIZE] = {0}; + char out_buffer[BUFFER_SIZE] = {0}; + s_ip_address ip_addr = {0, 0, 0, 0}; + int port = 0; + + printf("MBED: TCPCllient waiting for server IP and port...\r\n"); + scanf("%d.%d.%d.%d:%d", &ip_addr.ip_1, &ip_addr.ip_2, &ip_addr.ip_3, &ip_addr.ip_4, &port); + printf("MBED: Address received: %d.%d.%d.%d:%d\r\n", ip_addr.ip_1, ip_addr.ip_2, ip_addr.ip_3, ip_addr.ip_4, port); + + EthernetInterface eth; + eth.init(); //Use DHCP + eth.connect(); + + printf("MBED: TCPClient IP Address is %s\r\n", eth.getIPAddress()); + sprintf(buffer, "%d.%d.%d.%d", ip_addr.ip_1, ip_addr.ip_2, ip_addr.ip_3, ip_addr.ip_4); + + TCPSocketConnection socket; + while (socket.connect(buffer, port) < 0) { + printf("MBED: TCPCllient unable to connect to %s:%d\r\n", buffer, port); + wait(1); + } + + // Test loop for multiple client connections + bool result = true; + int count_error = 0; + for (int i = 0; i < MAX_ECHO_LOOPS; i++) { + std::generate(out_buffer, out_buffer + BUFFER_SIZE, char_rand); + socket.send_all(out_buffer, BUFFER_SIZE); + + int n = socket.receive(buffer, BUFFER_SIZE); + if (n > 0) + { + bool echoed = memcmp(out_buffer, buffer, BUFFER_SIZE) == 0; + result = result && echoed; + if (echoed == false) { + count_error++; // Count error messages + } + } + } + + printf("MBED: Loop messages passed: %d / %d\r\n", MAX_ECHO_LOOPS - count_error, MAX_ECHO_LOOPS); + + if (notify_completion_str(result, buffer)) { + socket.send_all(buffer, strlen(buffer)); + } + socket.close(); + eth.disconnect(); + MBED_HOSTTEST_RESULT(result); +} -- cgit v1.2.3