ACKme / Mbed 2 deprecated wiconnect-test-console

Important changes to repositories hosted on mbed.com

Mbed hosted mercurial repositories are deprecated and are due to be permanently deleted in July 2026.

To keep a copy of this software download the repository Zip archive or clone locally using Mercurial.

It is also possible to export all your personal repositories from the account settings page.

Dependencies:   WiConnect mbed

tests/blocking/socket/UdpEchoTest.cpp@12:3dd3a1be40c1, 2014-08-13 (annotated)

Committer:
dan_ackme
Date:
Wed Aug 13 04:42:11 2014 -0700
Revision:
12:3dd3a1be40c1
Parent:
3:dddd476d5967
Child:
15:a835e28308b6
updated copyright

Who changed what in which revision?

UserRevisionLine numberNew contents of line
dan_ackme 12:3dd3a1be40c1 1 /**
dan_ackme 12:3dd3a1be40c1 2 * ACKme WiConnect Host Library is licensed under the BSD licence:
dan_ackme 12:3dd3a1be40c1 3 *
dan_ackme 12:3dd3a1be40c1 4 * Copyright (c)2014 ACKme Networks.
dan_ackme 12:3dd3a1be40c1 5 * All rights reserved.
dan_ackme 12:3dd3a1be40c1 6 *
dan_ackme 12:3dd3a1be40c1 7 * Redistribution and use in source and binary forms, with or without modification,
dan_ackme 12:3dd3a1be40c1 8 * are permitted provided that the following conditions are met:
dan_ackme 12:3dd3a1be40c1 9 *
dan_ackme 12:3dd3a1be40c1 10 * 1. Redistributions of source code must retain the above copyright notice,
dan_ackme 12:3dd3a1be40c1 11 * this list of conditions and the following disclaimer.
dan_ackme 12:3dd3a1be40c1 12 * 2. Redistributions in binary form must reproduce the above copyright notice,
dan_ackme 12:3dd3a1be40c1 13 * this list of conditions and the following disclaimer in the documentation
dan_ackme 12:3dd3a1be40c1 14 * and/or other materials provided with the distribution.
dan_ackme 12:3dd3a1be40c1 15 * 3. The name of the author may not be used to endorse or promote products
dan_ackme 12:3dd3a1be40c1 16 * derived from this software without specific prior written permission.
dan_ackme 12:3dd3a1be40c1 17 *
dan_ackme 12:3dd3a1be40c1 18 * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS AND ANY EXPRESS OR IMPLIED
dan_ackme 12:3dd3a1be40c1 19 * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF
dan_ackme 12:3dd3a1be40c1 20 * MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT
dan_ackme 12:3dd3a1be40c1 21 * SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL,
dan_ackme 12:3dd3a1be40c1 22 * EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT
dan_ackme 12:3dd3a1be40c1 23 * OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
dan_ackme 12:3dd3a1be40c1 24 * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
dan_ackme 12:3dd3a1be40c1 25 * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING
dan_ackme 12:3dd3a1be40c1 26 * IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY
dan_ackme 12:3dd3a1be40c1 27 * OF SUCH DAMAGE.
dan_ackme 0:836c9a6383e0 28 */
dan_ackme 0:836c9a6383e0 29
dan_ackme 0:836c9a6383e0 30 #include "tests/Tests.h"
dan_ackme 0:836c9a6383e0 31 #include "Wiconnect.h"
dan_ackme 0:836c9a6383e0 32
dan_ackme 0:836c9a6383e0 33
dan_ackme 0:836c9a6383e0 34
dan_ackme 0:836c9a6383e0 35
dan_ackme 0:836c9a6383e0 36 static WiconnectResult processData(Socket &socket, uint32_t count, uint32_t delay, uint32_t size);
dan_ackme 0:836c9a6383e0 37
dan_ackme 0:836c9a6383e0 38
dan_ackme 0:836c9a6383e0 39
dan_ackme 0:836c9a6383e0 40 /*************************************************************************************************/
dan_ackme 0:836c9a6383e0 41 WiconnectResult socketUdpClientEchoCommand(int argc, char **argv)
dan_ackme 0:836c9a6383e0 42 {
dan_ackme 0:836c9a6383e0 43 WiconnectResult result;
dan_ackme 0:836c9a6383e0 44 Wiconnect *wiconnect = Wiconnect::getInstance();
dan_ackme 3:dddd476d5967 45 Socket socket(TEST_BUFFER_LENGTH/2, TEST_BUFFER, TEST_BUFFER_LENGTH/2, TEST_BUFFER + TEST_BUFFER_LENGTH/2);
dan_ackme 0:836c9a6383e0 46 const char *host;
dan_ackme 0:836c9a6383e0 47 uint32_t port;
dan_ackme 0:836c9a6383e0 48 uint32_t delay = 5;
dan_ackme 0:836c9a6383e0 49 uint32_t count = 1000;
dan_ackme 0:836c9a6383e0 50 uint32_t size = 256;
dan_ackme 0:836c9a6383e0 51
dan_ackme 0:836c9a6383e0 52 if(argc < 2)
dan_ackme 0:836c9a6383e0 53 {
dan_ackme 0:836c9a6383e0 54 LOG_ERROR("Must specify host and port");
dan_ackme 0:836c9a6383e0 55 return WICONNECT_BAD_ARG;
dan_ackme 0:836c9a6383e0 56 }
dan_ackme 0:836c9a6383e0 57 host = argv[0];
dan_ackme 0:836c9a6383e0 58
dan_ackme 0:836c9a6383e0 59 if(!StringUtil::strToUint32((const char*)argv[1], &port))
dan_ackme 0:836c9a6383e0 60 {
dan_ackme 0:836c9a6383e0 61 LOG_ERROR("Invalid port");
dan_ackme 0:836c9a6383e0 62 return WICONNECT_BAD_ARG;
dan_ackme 0:836c9a6383e0 63 }
dan_ackme 0:836c9a6383e0 64 if(argc > 2 && !StringUtil::strToUint32((const char*)argv[2], &count))
dan_ackme 0:836c9a6383e0 65 {
dan_ackme 0:836c9a6383e0 66 LOG_ERROR("Invalid packet count");
dan_ackme 0:836c9a6383e0 67 return WICONNECT_BAD_ARG;
dan_ackme 0:836c9a6383e0 68 }
dan_ackme 0:836c9a6383e0 69 if(argc > 3 && !StringUtil::strToUint32((const char*)argv[3], &delay))
dan_ackme 0:836c9a6383e0 70 {
dan_ackme 0:836c9a6383e0 71 LOG_ERROR("Invalid packet delay");
dan_ackme 0:836c9a6383e0 72 return WICONNECT_BAD_ARG;
dan_ackme 0:836c9a6383e0 73 }
dan_ackme 0:836c9a6383e0 74 if(argc > 4 && (!StringUtil::strToUint32((const char*)argv[4], &size) || size > sizeof(testBuffer)/2))
dan_ackme 0:836c9a6383e0 75 {
dan_ackme 0:836c9a6383e0 76 LOG_ERROR("Invalid packet size");
dan_ackme 0:836c9a6383e0 77 return WICONNECT_BAD_ARG;
dan_ackme 0:836c9a6383e0 78 }
dan_ackme 0:836c9a6383e0 79
dan_ackme 0:836c9a6383e0 80 if(WICONNECT_FAILED(result, wiconnect->udpConnect(socket, host, port)))
dan_ackme 0:836c9a6383e0 81 {
dan_ackme 0:836c9a6383e0 82 LOG_ERROR("Failed to connect to server");
dan_ackme 0:836c9a6383e0 83 }
dan_ackme 0:836c9a6383e0 84 else
dan_ackme 0:836c9a6383e0 85 {
dan_ackme 0:836c9a6383e0 86 result = processData(socket, count, delay, size);
dan_ackme 0:836c9a6383e0 87 }
dan_ackme 0:836c9a6383e0 88
dan_ackme 0:836c9a6383e0 89 return result;
dan_ackme 0:836c9a6383e0 90 }
dan_ackme 0:836c9a6383e0 91
dan_ackme 0:836c9a6383e0 92
dan_ackme 0:836c9a6383e0 93 /*************************************************************************************************/
dan_ackme 0:836c9a6383e0 94 static WiconnectResult processData(Socket &socket, uint32_t count, uint32_t delay, uint32_t size)
dan_ackme 0:836c9a6383e0 95 {
dan_ackme 2:2f222449973a 96 WiconnectResult result = WICONNECT_ERROR;
dan_ackme 0:836c9a6383e0 97 uint8_t *txBuffer = socket.getTxBuffer();
dan_ackme 0:836c9a6383e0 98 const int txBufferLen = socket.getTxBufferSize();
dan_ackme 0:836c9a6383e0 99 uint8_t writeCounter = 32;
dan_ackme 0:836c9a6383e0 100 uint8_t readCounter = 32;
dan_ackme 0:836c9a6383e0 101 uint32_t bytesSent = 0;
dan_ackme 0:836c9a6383e0 102 uint32_t bytesReceived = 0;
dan_ackme 0:836c9a6383e0 103
dan_ackme 0:836c9a6383e0 104 LOG_INFO("\r\n------------------\r\n"
dan_ackme 0:836c9a6383e0 105 "Starting UDP Echo Test:\r\n"
dan_ackme 0:836c9a6383e0 106 "Packet count: %d\r\n"
dan_ackme 0:836c9a6383e0 107 "Packet size: %d\r\n"
dan_ackme 0:836c9a6383e0 108 "Packet delay: %d\r\n"
dan_ackme 0:836c9a6383e0 109 "(Press any key to terminate)",
dan_ackme 0:836c9a6383e0 110 count, size, delay);
dan_ackme 0:836c9a6383e0 111
dan_ackme 0:836c9a6383e0 112 for(int i = 0; i < count || bytesReceived < bytesSent; ++i)
dan_ackme 0:836c9a6383e0 113 {
dan_ackme 0:836c9a6383e0 114 if(i < count)
dan_ackme 0:836c9a6383e0 115 {
dan_ackme 0:836c9a6383e0 116 uint8_t *ptr = txBuffer;
dan_ackme 0:836c9a6383e0 117 int l = size;
dan_ackme 0:836c9a6383e0 118 while(l--)
dan_ackme 0:836c9a6383e0 119 {
dan_ackme 0:836c9a6383e0 120 *ptr++ = writeCounter++;
dan_ackme 0:836c9a6383e0 121 if(writeCounter == 128)
dan_ackme 0:836c9a6383e0 122 writeCounter = 32;
dan_ackme 0:836c9a6383e0 123 }
dan_ackme 0:836c9a6383e0 124
dan_ackme 0:836c9a6383e0 125 if(WICONNECT_FAILED(result, socket.write(size)))
dan_ackme 0:836c9a6383e0 126 {
dan_ackme 0:836c9a6383e0 127 break;
dan_ackme 0:836c9a6383e0 128 }
dan_ackme 0:836c9a6383e0 129 bytesSent += size;
dan_ackme 0:836c9a6383e0 130 consoleSerial.putc('.');
dan_ackme 0:836c9a6383e0 131 }
dan_ackme 0:836c9a6383e0 132
dan_ackme 0:836c9a6383e0 133 if(consoleSerial.readable())
dan_ackme 0:836c9a6383e0 134 {
dan_ackme 0:836c9a6383e0 135 int c = consoleSerial.getc();
dan_ackme 0:836c9a6383e0 136 break;
dan_ackme 0:836c9a6383e0 137 }
dan_ackme 0:836c9a6383e0 138
dan_ackme 0:836c9a6383e0 139 delayMs(delay);
dan_ackme 0:836c9a6383e0 140
dan_ackme 0:836c9a6383e0 141 uint8_t *readPtr;
dan_ackme 0:836c9a6383e0 142 uint16_t readLen;
dan_ackme 0:836c9a6383e0 143 if(WICONNECT_FAILED(result, socket.read(&readPtr, &readLen)))
dan_ackme 0:836c9a6383e0 144 {
dan_ackme 0:836c9a6383e0 145 break;
dan_ackme 0:836c9a6383e0 146 }
dan_ackme 0:836c9a6383e0 147 bytesReceived += readLen;
dan_ackme 0:836c9a6383e0 148
dan_ackme 0:836c9a6383e0 149 while(readLen--)
dan_ackme 0:836c9a6383e0 150 {
dan_ackme 0:836c9a6383e0 151 if(*readPtr != readCounter)
dan_ackme 0:836c9a6383e0 152 {
dan_ackme 0:836c9a6383e0 153 LOG_ERROR("Invalid: %02X != %02X", *readPtr, readCounter);
dan_ackme 0:836c9a6383e0 154 }
dan_ackme 0:836c9a6383e0 155 ++readPtr;
dan_ackme 0:836c9a6383e0 156 ++readCounter;
dan_ackme 0:836c9a6383e0 157 if(readCounter == 128)
dan_ackme 0:836c9a6383e0 158 readCounter = 32;
dan_ackme 0:836c9a6383e0 159 }
dan_ackme 0:836c9a6383e0 160 }
dan_ackme 0:836c9a6383e0 161
dan_ackme 0:836c9a6383e0 162 consoleSerial.write("\r\n");
dan_ackme 0:836c9a6383e0 163 LOG_INFO("------------------\r\n"
dan_ackme 0:836c9a6383e0 164 "UDP Echo Test Complete:\r\n"
dan_ackme 0:836c9a6383e0 165 "Bytes sent: %d\r\n"
dan_ackme 0:836c9a6383e0 166 "Bytes received: %d\r\n",
dan_ackme 0:836c9a6383e0 167 bytesSent, bytesReceived);
dan_ackme 0:836c9a6383e0 168
dan_ackme 0:836c9a6383e0 169 return result;
dan_ackme 0:836c9a6383e0 170 }