Toyomasa Watarai
/
Mbed-example-WS-W27
easy-connect/esp8266-driver/TESTS/net/tcp_echo/main.cpp@0:119624335925, 2018-06-30 (annotated)
- Committer:
- MACRUM
- Date:
- Sat Jun 30 01:40:30 2018 +0000
- Revision:
- 0:119624335925
Initial commit
Who changed what in which revision?
User | Revision | Line number | New contents of line |
---|---|---|---|
MACRUM | 0:119624335925 | 1 | #include "mbed.h" |
MACRUM | 0:119624335925 | 2 | #include "ESP8266Interface.h" |
MACRUM | 0:119624335925 | 3 | #include "TCPSocket.h" |
MACRUM | 0:119624335925 | 4 | #include "greentea-client/test_env.h" |
MACRUM | 0:119624335925 | 5 | #include "unity/unity.h" |
MACRUM | 0:119624335925 | 6 | #include "utest.h" |
MACRUM | 0:119624335925 | 7 | |
MACRUM | 0:119624335925 | 8 | using namespace utest::v1; |
MACRUM | 0:119624335925 | 9 | |
MACRUM | 0:119624335925 | 10 | |
MACRUM | 0:119624335925 | 11 | #ifndef MBED_CFG_TCP_CLIENT_ECHO_BUFFER_SIZE |
MACRUM | 0:119624335925 | 12 | #define MBED_CFG_TCP_CLIENT_ECHO_BUFFER_SIZE 256 |
MACRUM | 0:119624335925 | 13 | #endif |
MACRUM | 0:119624335925 | 14 | |
MACRUM | 0:119624335925 | 15 | #ifndef MBED_CFG_ESP8266_TX |
MACRUM | 0:119624335925 | 16 | #define MBED_CFG_ESP8266_TX D1 |
MACRUM | 0:119624335925 | 17 | #endif |
MACRUM | 0:119624335925 | 18 | |
MACRUM | 0:119624335925 | 19 | #ifndef MBED_CFG_ESP8266_RX |
MACRUM | 0:119624335925 | 20 | #define MBED_CFG_ESP8266_RX D0 |
MACRUM | 0:119624335925 | 21 | #endif |
MACRUM | 0:119624335925 | 22 | |
MACRUM | 0:119624335925 | 23 | #ifndef MBED_CFG_ESP8266_DEBUG |
MACRUM | 0:119624335925 | 24 | #define MBED_CFG_ESP8266_DEBUG false |
MACRUM | 0:119624335925 | 25 | #endif |
MACRUM | 0:119624335925 | 26 | |
MACRUM | 0:119624335925 | 27 | #define STRINGIZE(x) STRINGIZE2(x) |
MACRUM | 0:119624335925 | 28 | #define STRINGIZE2(x) #x |
MACRUM | 0:119624335925 | 29 | |
MACRUM | 0:119624335925 | 30 | namespace { |
MACRUM | 0:119624335925 | 31 | char tx_buffer[MBED_CFG_TCP_CLIENT_ECHO_BUFFER_SIZE] = {0}; |
MACRUM | 0:119624335925 | 32 | char rx_buffer[MBED_CFG_TCP_CLIENT_ECHO_BUFFER_SIZE] = {0}; |
MACRUM | 0:119624335925 | 33 | const char ASCII_MAX = '~' - ' '; |
MACRUM | 0:119624335925 | 34 | } |
MACRUM | 0:119624335925 | 35 | |
MACRUM | 0:119624335925 | 36 | void prep_buffer(char *tx_buffer, size_t tx_size) { |
MACRUM | 0:119624335925 | 37 | for (size_t i=0; i<tx_size; ++i) { |
MACRUM | 0:119624335925 | 38 | tx_buffer[i] = (rand() % 10) + '0'; |
MACRUM | 0:119624335925 | 39 | } |
MACRUM | 0:119624335925 | 40 | } |
MACRUM | 0:119624335925 | 41 | |
MACRUM | 0:119624335925 | 42 | void test_tcp_echo() { |
MACRUM | 0:119624335925 | 43 | ESP8266Interface net(MBED_CFG_ESP8266_TX, MBED_CFG_ESP8266_RX, MBED_CFG_ESP8266_DEBUG); |
MACRUM | 0:119624335925 | 44 | int err = net.connect(STRINGIZE(MBED_CFG_ESP8266_SSID), STRINGIZE(MBED_CFG_ESP8266_PASS)); |
MACRUM | 0:119624335925 | 45 | |
MACRUM | 0:119624335925 | 46 | if (err) { |
MACRUM | 0:119624335925 | 47 | printf("MBED: failed to connect with an error of %d\r\n", err); |
MACRUM | 0:119624335925 | 48 | TEST_ASSERT_EQUAL(0, err); |
MACRUM | 0:119624335925 | 49 | } |
MACRUM | 0:119624335925 | 50 | |
MACRUM | 0:119624335925 | 51 | printf("MBED: TCPClient IP address is '%s'\n", net.get_ip_address()); |
MACRUM | 0:119624335925 | 52 | printf("MBED: TCPClient waiting for server IP and port...\n"); |
MACRUM | 0:119624335925 | 53 | |
MACRUM | 0:119624335925 | 54 | greentea_send_kv("target_ip", net.get_ip_address()); |
MACRUM | 0:119624335925 | 55 | |
MACRUM | 0:119624335925 | 56 | bool result = false; |
MACRUM | 0:119624335925 | 57 | |
MACRUM | 0:119624335925 | 58 | char recv_key[] = "host_port"; |
MACRUM | 0:119624335925 | 59 | char ipbuf[60] = {0}; |
MACRUM | 0:119624335925 | 60 | char portbuf[16] = {0}; |
MACRUM | 0:119624335925 | 61 | unsigned int port = 0; |
MACRUM | 0:119624335925 | 62 | |
MACRUM | 0:119624335925 | 63 | greentea_send_kv("host_ip", " "); |
MACRUM | 0:119624335925 | 64 | greentea_parse_kv(recv_key, ipbuf, sizeof(recv_key), sizeof(ipbuf)); |
MACRUM | 0:119624335925 | 65 | |
MACRUM | 0:119624335925 | 66 | greentea_send_kv("host_port", " "); |
MACRUM | 0:119624335925 | 67 | greentea_parse_kv(recv_key, portbuf, sizeof(recv_key), sizeof(ipbuf)); |
MACRUM | 0:119624335925 | 68 | sscanf(portbuf, "%u", &port); |
MACRUM | 0:119624335925 | 69 | |
MACRUM | 0:119624335925 | 70 | printf("MBED: Server IP address received: %s:%d \n", ipbuf, port); |
MACRUM | 0:119624335925 | 71 | |
MACRUM | 0:119624335925 | 72 | TCPSocket sock(&net); |
MACRUM | 0:119624335925 | 73 | SocketAddress tcp_addr(ipbuf, port); |
MACRUM | 0:119624335925 | 74 | if (sock.connect(tcp_addr) == 0) { |
MACRUM | 0:119624335925 | 75 | printf("HTTP: Connected to %s:%d\r\n", ipbuf, port); |
MACRUM | 0:119624335925 | 76 | printf("tx_buffer buffer size: %u\r\n", sizeof(tx_buffer)); |
MACRUM | 0:119624335925 | 77 | printf("rx_buffer buffer size: %u\r\n", sizeof(rx_buffer)); |
MACRUM | 0:119624335925 | 78 | |
MACRUM | 0:119624335925 | 79 | prep_buffer(tx_buffer, sizeof(tx_buffer)); |
MACRUM | 0:119624335925 | 80 | sock.send(tx_buffer, sizeof(tx_buffer)); |
MACRUM | 0:119624335925 | 81 | printf("MBED: Finished sending\r\n"); |
MACRUM | 0:119624335925 | 82 | // Server will respond with HTTP GET's success code |
MACRUM | 0:119624335925 | 83 | const int ret = sock.recv(rx_buffer, sizeof(rx_buffer)); |
MACRUM | 0:119624335925 | 84 | printf("MBED: Finished receiving\r\n"); |
MACRUM | 0:119624335925 | 85 | |
MACRUM | 0:119624335925 | 86 | result = !memcmp(tx_buffer, rx_buffer, sizeof(tx_buffer)); |
MACRUM | 0:119624335925 | 87 | TEST_ASSERT_EQUAL(ret, sizeof(rx_buffer)); |
MACRUM | 0:119624335925 | 88 | TEST_ASSERT_EQUAL(true, result); |
MACRUM | 0:119624335925 | 89 | } |
MACRUM | 0:119624335925 | 90 | |
MACRUM | 0:119624335925 | 91 | sock.close(); |
MACRUM | 0:119624335925 | 92 | net.disconnect(); |
MACRUM | 0:119624335925 | 93 | TEST_ASSERT_EQUAL(true, result); |
MACRUM | 0:119624335925 | 94 | } |
MACRUM | 0:119624335925 | 95 | |
MACRUM | 0:119624335925 | 96 | |
MACRUM | 0:119624335925 | 97 | // Test setup |
MACRUM | 0:119624335925 | 98 | utest::v1::status_t test_setup(const size_t number_of_cases) { |
MACRUM | 0:119624335925 | 99 | GREENTEA_SETUP(120, "tcp_echo"); |
MACRUM | 0:119624335925 | 100 | return verbose_test_setup_handler(number_of_cases); |
MACRUM | 0:119624335925 | 101 | } |
MACRUM | 0:119624335925 | 102 | |
MACRUM | 0:119624335925 | 103 | Case cases[] = { |
MACRUM | 0:119624335925 | 104 | Case("TCP echo", test_tcp_echo), |
MACRUM | 0:119624335925 | 105 | }; |
MACRUM | 0:119624335925 | 106 | |
MACRUM | 0:119624335925 | 107 | Specification specification(test_setup, cases); |
MACRUM | 0:119624335925 | 108 | |
MACRUM | 0:119624335925 | 109 | int main() { |
MACRUM | 0:119624335925 | 110 | return !Harness::run(specification); |
MACRUM | 0:119624335925 | 111 | } |
MACRUM | 0:119624335925 | 112 |