Toyomasa Watarai / Mbed OS Mbed-example-WS-W27

Dependencies:   MMA7660 LM75B

easy-connect/wizfi310-driver/TESTS/net/udp_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?

UserRevisionLine numberNew contents of line
MACRUM 0:119624335925 1 #include "mbed.h"
MACRUM 0:119624335925 2 #include "WizFi310Interface.h"
MACRUM 0:119624335925 3 #include "UDPSocket.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_UDP_CLIENT_ECHO_BUFFER_SIZE
MACRUM 0:119624335925 12 #define MBED_CFG_UDP_CLIENT_ECHO_BUFFER_SIZE 64
MACRUM 0:119624335925 13 #endif
MACRUM 0:119624335925 14
MACRUM 0:119624335925 15 #ifndef MBED_CFG_UDP_CLIENT_ECHO_TIMEOUT
MACRUM 0:119624335925 16 #define MBED_CFG_UDP_CLIENT_ECHO_TIMEOUT 500
MACRUM 0:119624335925 17 #endif
MACRUM 0:119624335925 18
MACRUM 0:119624335925 19 #ifndef MBED_CFG_WIZFI310_TX
MACRUM 0:119624335925 20 #define MBED_CFG_WIZFI310_TX D1
MACRUM 0:119624335925 21 #endif
MACRUM 0:119624335925 22
MACRUM 0:119624335925 23 #ifndef MBED_CFG_WIZFI310_RX
MACRUM 0:119624335925 24 #define MBED_CFG_WIZFI310_RX D0
MACRUM 0:119624335925 25 #endif
MACRUM 0:119624335925 26
MACRUM 0:119624335925 27 #ifndef MBED_CFG_WIZFI310_DEBUG
MACRUM 0:119624335925 28 #define MBED_CFG_WIZFI310_DEBUG false
MACRUM 0:119624335925 29 #endif
MACRUM 0:119624335925 30
MACRUM 0:119624335925 31 #define STRINGIZE(x) STRINGIZE2(x)
MACRUM 0:119624335925 32 #define STRINGIZE2(x) #x
MACRUM 0:119624335925 33
MACRUM 0:119624335925 34
MACRUM 0:119624335925 35 namespace {
MACRUM 0:119624335925 36 char tx_buffer[MBED_CFG_UDP_CLIENT_ECHO_BUFFER_SIZE] = {0};
MACRUM 0:119624335925 37 char rx_buffer[MBED_CFG_UDP_CLIENT_ECHO_BUFFER_SIZE] = {0};
MACRUM 0:119624335925 38 const char ASCII_MAX = '~' - ' ';
MACRUM 0:119624335925 39 const int ECHO_LOOPS = 16;
MACRUM 0:119624335925 40 char uuid[48] = {0};
MACRUM 0:119624335925 41 }
MACRUM 0:119624335925 42
MACRUM 0:119624335925 43 void prep_buffer(char *uuid, char *tx_buffer, size_t tx_size) {
MACRUM 0:119624335925 44 size_t i = 0;
MACRUM 0:119624335925 45
MACRUM 0:119624335925 46 memcpy(tx_buffer, uuid, strlen(uuid));
MACRUM 0:119624335925 47 i += strlen(uuid);
MACRUM 0:119624335925 48
MACRUM 0:119624335925 49 tx_buffer[i++] = ' ';
MACRUM 0:119624335925 50
MACRUM 0:119624335925 51 for (; i<tx_size; ++i) {
MACRUM 0:119624335925 52 tx_buffer[i] = (rand() % 10) + '0';
MACRUM 0:119624335925 53 }
MACRUM 0:119624335925 54 }
MACRUM 0:119624335925 55
MACRUM 0:119624335925 56 void test_udp_echo() {
MACRUM 0:119624335925 57 WizFi310Interface net(MBED_CFG_WIZFI310_TX, MBED_CFG_WIZFI310_RX, MBED_CFG_WIZFI310_DEBUG);
MACRUM 0:119624335925 58
MACRUM 0:119624335925 59 int err = net.connect(STRINGIZE(MBED_CFG_WIZFI310_SSID), STRINGIZE(MBED_CFG_WIZFI310_PASS));
MACRUM 0:119624335925 60 TEST_ASSERT_EQUAL(0, err);
MACRUM 0:119624335925 61
MACRUM 0:119624335925 62 if (err) {
MACRUM 0:119624335925 63 printf("MBED: failed to connect with an error of %d\r\n", err);
MACRUM 0:119624335925 64 TEST_ASSERT_EQUAL(0, err);
MACRUM 0:119624335925 65 }
MACRUM 0:119624335925 66
MACRUM 0:119624335925 67 printf("UDP client IP Address is %s\n", net.get_ip_address());
MACRUM 0:119624335925 68
MACRUM 0:119624335925 69 greentea_send_kv("target_ip", net.get_ip_address());
MACRUM 0:119624335925 70
MACRUM 0:119624335925 71 char recv_key[] = "host_port";
MACRUM 0:119624335925 72 char ipbuf[60] = {0};
MACRUM 0:119624335925 73 char portbuf[16] = {0};
MACRUM 0:119624335925 74 unsigned int port = 0;
MACRUM 0:119624335925 75
MACRUM 0:119624335925 76 UDPSocket sock;
MACRUM 0:119624335925 77 sock.open(&net);
MACRUM 0:119624335925 78 sock.set_timeout(MBED_CFG_UDP_CLIENT_ECHO_TIMEOUT);
MACRUM 0:119624335925 79
MACRUM 0:119624335925 80 greentea_send_kv("host_ip", " ");
MACRUM 0:119624335925 81 greentea_parse_kv(recv_key, ipbuf, sizeof(recv_key), sizeof(ipbuf));
MACRUM 0:119624335925 82
MACRUM 0:119624335925 83 greentea_send_kv("host_port", " ");
MACRUM 0:119624335925 84 greentea_parse_kv(recv_key, portbuf, sizeof(recv_key), sizeof(ipbuf));
MACRUM 0:119624335925 85 sscanf(portbuf, "%u", &port);
MACRUM 0:119624335925 86
MACRUM 0:119624335925 87 printf("MBED: UDP Server IP address received: %s:%d \n", ipbuf, port);
MACRUM 0:119624335925 88 SocketAddress udp_addr(ipbuf, port);
MACRUM 0:119624335925 89
MACRUM 0:119624335925 90 int success = 0;
MACRUM 0:119624335925 91 for (int i = 0; success < ECHO_LOOPS; i++) {
MACRUM 0:119624335925 92 prep_buffer(uuid, tx_buffer, sizeof(tx_buffer));
MACRUM 0:119624335925 93 const int ret = sock.sendto(udp_addr, tx_buffer, sizeof(tx_buffer));
MACRUM 0:119624335925 94 if (ret >= 0) {
MACRUM 0:119624335925 95 printf("[%02d] sent %d bytes - %.*s \n", i, ret, ret, tx_buffer);
MACRUM 0:119624335925 96 } else {
MACRUM 0:119624335925 97 printf("[%02d] Network error %d\n", i, ret);
MACRUM 0:119624335925 98 continue;
MACRUM 0:119624335925 99 }
MACRUM 0:119624335925 100
MACRUM 0:119624335925 101 SocketAddress temp_addr;
MACRUM 0:119624335925 102 const int n = sock.recvfrom(&temp_addr, rx_buffer, sizeof(rx_buffer));
MACRUM 0:119624335925 103 if (n >= 0) {
MACRUM 0:119624335925 104 printf("[%02d] recv %d bytes - %.*s \n", i, n, n, tx_buffer);
MACRUM 0:119624335925 105 } else {
MACRUM 0:119624335925 106 printf("[%02d] Network error %d\n", i, n);
MACRUM 0:119624335925 107 continue;
MACRUM 0:119624335925 108 }
MACRUM 0:119624335925 109
MACRUM 0:119624335925 110 if ((temp_addr == udp_addr &&
MACRUM 0:119624335925 111 n == sizeof(tx_buffer) &&
MACRUM 0:119624335925 112 memcmp(rx_buffer, tx_buffer, sizeof(rx_buffer)) == 0)) {
MACRUM 0:119624335925 113 success += 1;
MACRUM 0:119624335925 114
MACRUM 0:119624335925 115 printf("[%02d] success #%d\n", i, success);
MACRUM 0:119624335925 116 continue;
MACRUM 0:119624335925 117 }
MACRUM 0:119624335925 118
MACRUM 0:119624335925 119 // failed, clean out any remaining bad packets
MACRUM 0:119624335925 120 sock.set_timeout(0);
MACRUM 0:119624335925 121 while (true) {
MACRUM 0:119624335925 122 err = sock.recvfrom(NULL, NULL, 0);
MACRUM 0:119624335925 123 if (err == NSAPI_ERROR_WOULD_BLOCK) {
MACRUM 0:119624335925 124 break;
MACRUM 0:119624335925 125 }
MACRUM 0:119624335925 126 }
MACRUM 0:119624335925 127 sock.set_timeout(MBED_CFG_UDP_CLIENT_ECHO_TIMEOUT);
MACRUM 0:119624335925 128 }
MACRUM 0:119624335925 129
MACRUM 0:119624335925 130 sock.close();
MACRUM 0:119624335925 131 net.disconnect();
MACRUM 0:119624335925 132 TEST_ASSERT_EQUAL(ECHO_LOOPS, success);
MACRUM 0:119624335925 133 }
MACRUM 0:119624335925 134
MACRUM 0:119624335925 135
MACRUM 0:119624335925 136 // Test setup
MACRUM 0:119624335925 137 utest::v1::status_t test_setup(const size_t number_of_cases) {
MACRUM 0:119624335925 138 GREENTEA_SETUP(120, "udp_echo");
MACRUM 0:119624335925 139 return verbose_test_setup_handler(number_of_cases);
MACRUM 0:119624335925 140 }
MACRUM 0:119624335925 141
MACRUM 0:119624335925 142 Case cases[] = {
MACRUM 0:119624335925 143 Case("UDP echo", test_udp_echo),
MACRUM 0:119624335925 144 };
MACRUM 0:119624335925 145
MACRUM 0:119624335925 146 Specification specification(test_setup, cases);
MACRUM 0:119624335925 147
MACRUM 0:119624335925 148 int main() {
MACRUM 0:119624335925 149 return !Harness::run(specification);
MACRUM 0:119624335925 150 }
MACRUM 0:119624335925 151