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@3:dddd476d5967, 2014-08-11 (annotated)

Committer:
dan_ackme
Date:
Mon Aug 11 13:55:39 2014 -0700
Revision:
3:dddd476d5967
Parent:
2:2f222449973a
Child:
12:3dd3a1be40c1
use static buffers instead of malloc since default heap is so small

Who changed what in which revision?

UserRevisionLine numberNew contents of line
dan_ackme 0:836c9a6383e0 1 /*
dan_ackme 0:836c9a6383e0 2 * Copyright 2014, ACKme Networks
dan_ackme 0:836c9a6383e0 3 * All Rights Reserved.
dan_ackme 0:836c9a6383e0 4 *
dan_ackme 0:836c9a6383e0 5 * This is UNPUBLISHED PROPRIETARY SOURCE CODE of ACKme Networks;
dan_ackme 0:836c9a6383e0 6 * the contents of this file may not be disclosed to third parties, copied
dan_ackme 0:836c9a6383e0 7 * or duplicated in any form, in whole or in part, without the prior
dan_ackme 0:836c9a6383e0 8 * written permission of ACKme Networks.
dan_ackme 0:836c9a6383e0 9 */
dan_ackme 0:836c9a6383e0 10
dan_ackme 0:836c9a6383e0 11
dan_ackme 0:836c9a6383e0 12 #include "tests/Tests.h"
dan_ackme 0:836c9a6383e0 13 #include "Wiconnect.h"
dan_ackme 0:836c9a6383e0 14
dan_ackme 0:836c9a6383e0 15
dan_ackme 0:836c9a6383e0 16
dan_ackme 0:836c9a6383e0 17
dan_ackme 0:836c9a6383e0 18 static WiconnectResult processData(Socket &socket, uint32_t count, uint32_t delay, uint32_t size);
dan_ackme 0:836c9a6383e0 19
dan_ackme 0:836c9a6383e0 20
dan_ackme 0:836c9a6383e0 21
dan_ackme 0:836c9a6383e0 22 /*************************************************************************************************/
dan_ackme 0:836c9a6383e0 23 WiconnectResult socketUdpClientEchoCommand(int argc, char **argv)
dan_ackme 0:836c9a6383e0 24 {
dan_ackme 0:836c9a6383e0 25 WiconnectResult result;
dan_ackme 0:836c9a6383e0 26 Wiconnect *wiconnect = Wiconnect::getInstance();
dan_ackme 3:dddd476d5967 27 Socket socket(TEST_BUFFER_LENGTH/2, TEST_BUFFER, TEST_BUFFER_LENGTH/2, TEST_BUFFER + TEST_BUFFER_LENGTH/2);
dan_ackme 0:836c9a6383e0 28 const char *host;
dan_ackme 0:836c9a6383e0 29 uint32_t port;
dan_ackme 0:836c9a6383e0 30 uint32_t delay = 5;
dan_ackme 0:836c9a6383e0 31 uint32_t count = 1000;
dan_ackme 0:836c9a6383e0 32 uint32_t size = 256;
dan_ackme 0:836c9a6383e0 33
dan_ackme 0:836c9a6383e0 34 if(argc < 2)
dan_ackme 0:836c9a6383e0 35 {
dan_ackme 0:836c9a6383e0 36 LOG_ERROR("Must specify host and port");
dan_ackme 0:836c9a6383e0 37 return WICONNECT_BAD_ARG;
dan_ackme 0:836c9a6383e0 38 }
dan_ackme 0:836c9a6383e0 39 host = argv[0];
dan_ackme 0:836c9a6383e0 40
dan_ackme 0:836c9a6383e0 41 if(!StringUtil::strToUint32((const char*)argv[1], &port))
dan_ackme 0:836c9a6383e0 42 {
dan_ackme 0:836c9a6383e0 43 LOG_ERROR("Invalid port");
dan_ackme 0:836c9a6383e0 44 return WICONNECT_BAD_ARG;
dan_ackme 0:836c9a6383e0 45 }
dan_ackme 0:836c9a6383e0 46 if(argc > 2 && !StringUtil::strToUint32((const char*)argv[2], &count))
dan_ackme 0:836c9a6383e0 47 {
dan_ackme 0:836c9a6383e0 48 LOG_ERROR("Invalid packet count");
dan_ackme 0:836c9a6383e0 49 return WICONNECT_BAD_ARG;
dan_ackme 0:836c9a6383e0 50 }
dan_ackme 0:836c9a6383e0 51 if(argc > 3 && !StringUtil::strToUint32((const char*)argv[3], &delay))
dan_ackme 0:836c9a6383e0 52 {
dan_ackme 0:836c9a6383e0 53 LOG_ERROR("Invalid packet delay");
dan_ackme 0:836c9a6383e0 54 return WICONNECT_BAD_ARG;
dan_ackme 0:836c9a6383e0 55 }
dan_ackme 0:836c9a6383e0 56 if(argc > 4 && (!StringUtil::strToUint32((const char*)argv[4], &size) || size > sizeof(testBuffer)/2))
dan_ackme 0:836c9a6383e0 57 {
dan_ackme 0:836c9a6383e0 58 LOG_ERROR("Invalid packet size");
dan_ackme 0:836c9a6383e0 59 return WICONNECT_BAD_ARG;
dan_ackme 0:836c9a6383e0 60 }
dan_ackme 0:836c9a6383e0 61
dan_ackme 0:836c9a6383e0 62 if(WICONNECT_FAILED(result, wiconnect->udpConnect(socket, host, port)))
dan_ackme 0:836c9a6383e0 63 {
dan_ackme 0:836c9a6383e0 64 LOG_ERROR("Failed to connect to server");
dan_ackme 0:836c9a6383e0 65 }
dan_ackme 0:836c9a6383e0 66 else
dan_ackme 0:836c9a6383e0 67 {
dan_ackme 0:836c9a6383e0 68 result = processData(socket, count, delay, size);
dan_ackme 0:836c9a6383e0 69 }
dan_ackme 0:836c9a6383e0 70
dan_ackme 0:836c9a6383e0 71 return result;
dan_ackme 0:836c9a6383e0 72 }
dan_ackme 0:836c9a6383e0 73
dan_ackme 0:836c9a6383e0 74
dan_ackme 0:836c9a6383e0 75 /*************************************************************************************************/
dan_ackme 0:836c9a6383e0 76 static WiconnectResult processData(Socket &socket, uint32_t count, uint32_t delay, uint32_t size)
dan_ackme 0:836c9a6383e0 77 {
dan_ackme 2:2f222449973a 78 WiconnectResult result = WICONNECT_ERROR;
dan_ackme 0:836c9a6383e0 79 uint8_t *txBuffer = socket.getTxBuffer();
dan_ackme 0:836c9a6383e0 80 const int txBufferLen = socket.getTxBufferSize();
dan_ackme 0:836c9a6383e0 81 uint8_t writeCounter = 32;
dan_ackme 0:836c9a6383e0 82 uint8_t readCounter = 32;
dan_ackme 0:836c9a6383e0 83 uint32_t bytesSent = 0;
dan_ackme 0:836c9a6383e0 84 uint32_t bytesReceived = 0;
dan_ackme 0:836c9a6383e0 85
dan_ackme 0:836c9a6383e0 86 LOG_INFO("\r\n------------------\r\n"
dan_ackme 0:836c9a6383e0 87 "Starting UDP Echo Test:\r\n"
dan_ackme 0:836c9a6383e0 88 "Packet count: %d\r\n"
dan_ackme 0:836c9a6383e0 89 "Packet size: %d\r\n"
dan_ackme 0:836c9a6383e0 90 "Packet delay: %d\r\n"
dan_ackme 0:836c9a6383e0 91 "(Press any key to terminate)",
dan_ackme 0:836c9a6383e0 92 count, size, delay);
dan_ackme 0:836c9a6383e0 93
dan_ackme 0:836c9a6383e0 94 for(int i = 0; i < count || bytesReceived < bytesSent; ++i)
dan_ackme 0:836c9a6383e0 95 {
dan_ackme 0:836c9a6383e0 96 if(i < count)
dan_ackme 0:836c9a6383e0 97 {
dan_ackme 0:836c9a6383e0 98 uint8_t *ptr = txBuffer;
dan_ackme 0:836c9a6383e0 99 int l = size;
dan_ackme 0:836c9a6383e0 100 while(l--)
dan_ackme 0:836c9a6383e0 101 {
dan_ackme 0:836c9a6383e0 102 *ptr++ = writeCounter++;
dan_ackme 0:836c9a6383e0 103 if(writeCounter == 128)
dan_ackme 0:836c9a6383e0 104 writeCounter = 32;
dan_ackme 0:836c9a6383e0 105 }
dan_ackme 0:836c9a6383e0 106
dan_ackme 0:836c9a6383e0 107 if(WICONNECT_FAILED(result, socket.write(size)))
dan_ackme 0:836c9a6383e0 108 {
dan_ackme 0:836c9a6383e0 109 break;
dan_ackme 0:836c9a6383e0 110 }
dan_ackme 0:836c9a6383e0 111 bytesSent += size;
dan_ackme 0:836c9a6383e0 112 consoleSerial.putc('.');
dan_ackme 0:836c9a6383e0 113 }
dan_ackme 0:836c9a6383e0 114
dan_ackme 0:836c9a6383e0 115 if(consoleSerial.readable())
dan_ackme 0:836c9a6383e0 116 {
dan_ackme 0:836c9a6383e0 117 int c = consoleSerial.getc();
dan_ackme 0:836c9a6383e0 118 break;
dan_ackme 0:836c9a6383e0 119 }
dan_ackme 0:836c9a6383e0 120
dan_ackme 0:836c9a6383e0 121 delayMs(delay);
dan_ackme 0:836c9a6383e0 122
dan_ackme 0:836c9a6383e0 123 uint8_t *readPtr;
dan_ackme 0:836c9a6383e0 124 uint16_t readLen;
dan_ackme 0:836c9a6383e0 125 if(WICONNECT_FAILED(result, socket.read(&readPtr, &readLen)))
dan_ackme 0:836c9a6383e0 126 {
dan_ackme 0:836c9a6383e0 127 break;
dan_ackme 0:836c9a6383e0 128 }
dan_ackme 0:836c9a6383e0 129 bytesReceived += readLen;
dan_ackme 0:836c9a6383e0 130
dan_ackme 0:836c9a6383e0 131 while(readLen--)
dan_ackme 0:836c9a6383e0 132 {
dan_ackme 0:836c9a6383e0 133 if(*readPtr != readCounter)
dan_ackme 0:836c9a6383e0 134 {
dan_ackme 0:836c9a6383e0 135 LOG_ERROR("Invalid: %02X != %02X", *readPtr, readCounter);
dan_ackme 0:836c9a6383e0 136 }
dan_ackme 0:836c9a6383e0 137 ++readPtr;
dan_ackme 0:836c9a6383e0 138 ++readCounter;
dan_ackme 0:836c9a6383e0 139 if(readCounter == 128)
dan_ackme 0:836c9a6383e0 140 readCounter = 32;
dan_ackme 0:836c9a6383e0 141 }
dan_ackme 0:836c9a6383e0 142 }
dan_ackme 0:836c9a6383e0 143
dan_ackme 0:836c9a6383e0 144 consoleSerial.write("\r\n");
dan_ackme 0:836c9a6383e0 145 LOG_INFO("------------------\r\n"
dan_ackme 0:836c9a6383e0 146 "UDP Echo Test Complete:\r\n"
dan_ackme 0:836c9a6383e0 147 "Bytes sent: %d\r\n"
dan_ackme 0:836c9a6383e0 148 "Bytes received: %d\r\n",
dan_ackme 0:836c9a6383e0 149 bytesSent, bytesReceived);
dan_ackme 0:836c9a6383e0 150
dan_ackme 0:836c9a6383e0 151 return result;
dan_ackme 0:836c9a6383e0 152 }