Host library for controlling a WiConnect enabled Wi-Fi module.
Dependents: wiconnect-ota_example wiconnect-web_setup_example wiconnect-test-console wiconnect-tcp_server_example ... more
WiconnectUdpServer.cpp@42:8ffb253b09e7, 2015-09-28 (annotated)
- Committer:
- aymangrais
- Date:
- Mon Sep 28 03:38:43 2015 +0000
- Revision:
- 42:8ffb253b09e7
- Parent:
- 29:b6af04b77a56
increase ota timeout to be 5 seconds (instead of 1.5 sec)
Who changed what in which revision?
User | Revision | Line number | New contents of line |
---|---|---|---|
dan_ackme | 29:b6af04b77a56 | 1 | /** |
dan_ackme | 29:b6af04b77a56 | 2 | * ACKme WiConnect Host Library is licensed under the BSD licence: |
dan_ackme | 29:b6af04b77a56 | 3 | * |
dan_ackme | 29:b6af04b77a56 | 4 | * Copyright (c)2014 ACKme Networks. |
dan_ackme | 29:b6af04b77a56 | 5 | * All rights reserved. |
dan_ackme | 29:b6af04b77a56 | 6 | * |
dan_ackme | 29:b6af04b77a56 | 7 | * Redistribution and use in source and binary forms, with or without modification, |
dan_ackme | 29:b6af04b77a56 | 8 | * are permitted provided that the following conditions are met: |
dan_ackme | 29:b6af04b77a56 | 9 | * |
dan_ackme | 29:b6af04b77a56 | 10 | * 1. Redistributions of source code must retain the above copyright notice, |
dan_ackme | 29:b6af04b77a56 | 11 | * this list of conditions and the following disclaimer. |
dan_ackme | 29:b6af04b77a56 | 12 | * 2. Redistributions in binary form must reproduce the above copyright notice, |
dan_ackme | 29:b6af04b77a56 | 13 | * this list of conditions and the following disclaimer in the documentation |
dan_ackme | 29:b6af04b77a56 | 14 | * and/or other materials provided with the distribution. |
dan_ackme | 29:b6af04b77a56 | 15 | * 3. The name of the author may not be used to endorse or promote products |
dan_ackme | 29:b6af04b77a56 | 16 | * derived from this software without specific prior written permission. |
dan_ackme | 29:b6af04b77a56 | 17 | * |
dan_ackme | 29:b6af04b77a56 | 18 | * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS AND ANY EXPRESS OR IMPLIED |
dan_ackme | 29:b6af04b77a56 | 19 | * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF |
dan_ackme | 29:b6af04b77a56 | 20 | * MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT |
dan_ackme | 29:b6af04b77a56 | 21 | * SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, |
dan_ackme | 29:b6af04b77a56 | 22 | * EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT |
dan_ackme | 29:b6af04b77a56 | 23 | * OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS |
dan_ackme | 29:b6af04b77a56 | 24 | * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN |
dan_ackme | 29:b6af04b77a56 | 25 | * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING |
dan_ackme | 29:b6af04b77a56 | 26 | * IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY |
dan_ackme | 29:b6af04b77a56 | 27 | * OF SUCH DAMAGE. |
dan_ackme | 29:b6af04b77a56 | 28 | */ |
dan_ackme | 29:b6af04b77a56 | 29 | #include <stdarg.h> |
dan_ackme | 29:b6af04b77a56 | 30 | |
dan_ackme | 29:b6af04b77a56 | 31 | #include "Wiconnect.h" |
dan_ackme | 29:b6af04b77a56 | 32 | #include "internal/common.h" |
dan_ackme | 29:b6af04b77a56 | 33 | #include "api/StringUtil.h" |
dan_ackme | 29:b6af04b77a56 | 34 | |
dan_ackme | 29:b6af04b77a56 | 35 | |
dan_ackme | 29:b6af04b77a56 | 36 | #define CHECK_CONNECTED() if(!isConnected()) return WICONNECT_NOT_CONNECTED |
dan_ackme | 29:b6af04b77a56 | 37 | |
dan_ackme | 29:b6af04b77a56 | 38 | extern WiconnectResult readerCallback(void *user, void *data, int maxReadSize, int *bytesRead); |
dan_ackme | 29:b6af04b77a56 | 39 | |
dan_ackme | 29:b6af04b77a56 | 40 | |
dan_ackme | 29:b6af04b77a56 | 41 | /*************************************************************************************************/ |
dan_ackme | 29:b6af04b77a56 | 42 | WiconnectUdpServer::WiconnectUdpServer(int rxBufferLen_, void *rxBuffer_, int txBufferLen_, void *txBuffer_) : |
dan_ackme | 29:b6af04b77a56 | 43 | WiconnectSocket(rxBufferLen_, rxBuffer_, txBufferLen_, txBuffer_) |
dan_ackme | 29:b6af04b77a56 | 44 | { |
dan_ackme | 29:b6af04b77a56 | 45 | } |
dan_ackme | 29:b6af04b77a56 | 46 | |
dan_ackme | 29:b6af04b77a56 | 47 | /*************************************************************************************************/ |
dan_ackme | 29:b6af04b77a56 | 48 | WiconnectResult WiconnectUdpServer::getRemoteClient(uint32_t *ipAddress, uint16_t *port) |
dan_ackme | 29:b6af04b77a56 | 49 | { |
dan_ackme | 29:b6af04b77a56 | 50 | WiconnectResult result; |
dan_ackme | 29:b6af04b77a56 | 51 | |
dan_ackme | 29:b6af04b77a56 | 52 | CHECK_CONNECTED(); |
dan_ackme | 29:b6af04b77a56 | 53 | CHECK_OTHER_COMMAND_EXECUTING(); |
dan_ackme | 29:b6af04b77a56 | 54 | |
dan_ackme | 29:b6af04b77a56 | 55 | if(WICONNECT_SUCCEEDED(result, wiconnect->sendCommand("udps read -q"))) |
dan_ackme | 29:b6af04b77a56 | 56 | { |
dan_ackme | 29:b6af04b77a56 | 57 | char *portStr = strchr(wiconnect->internalBuffer, ','); |
dan_ackme | 29:b6af04b77a56 | 58 | if(portStr == NULL) |
dan_ackme | 29:b6af04b77a56 | 59 | { |
dan_ackme | 29:b6af04b77a56 | 60 | result = WICONNECT_RESPONSE_PARSE_ERROR; |
dan_ackme | 29:b6af04b77a56 | 61 | } |
dan_ackme | 29:b6af04b77a56 | 62 | else |
dan_ackme | 29:b6af04b77a56 | 63 | { |
dan_ackme | 29:b6af04b77a56 | 64 | *portStr++ = 0; |
dan_ackme | 29:b6af04b77a56 | 65 | Wiconnect::strToIp(wiconnect->internalBuffer, ipAddress); |
dan_ackme | 29:b6af04b77a56 | 66 | StringUtil::strToUint16(portStr, port); |
dan_ackme | 29:b6af04b77a56 | 67 | } |
dan_ackme | 29:b6af04b77a56 | 68 | } |
dan_ackme | 29:b6af04b77a56 | 69 | |
dan_ackme | 29:b6af04b77a56 | 70 | CHECK_CLEANUP_COMMAND(); |
dan_ackme | 29:b6af04b77a56 | 71 | |
dan_ackme | 29:b6af04b77a56 | 72 | return result; |
dan_ackme | 29:b6af04b77a56 | 73 | } |
dan_ackme | 29:b6af04b77a56 | 74 | |
dan_ackme | 29:b6af04b77a56 | 75 | /*************************************************************************************************/ |
dan_ackme | 29:b6af04b77a56 | 76 | WiconnectResult WiconnectUdpServer::setRemoteClient(const char* _host, uint16_t port) |
dan_ackme | 29:b6af04b77a56 | 77 | { |
dan_ackme | 29:b6af04b77a56 | 78 | WiconnectResult result; |
dan_ackme | 29:b6af04b77a56 | 79 | uint32_t ip; |
dan_ackme | 29:b6af04b77a56 | 80 | |
dan_ackme | 29:b6af04b77a56 | 81 | if(WICONNECT_SUCCEEDED(result, wiconnect->lookup(_host, &ip))) |
dan_ackme | 29:b6af04b77a56 | 82 | { |
dan_ackme | 29:b6af04b77a56 | 83 | ip = htonl(ip); // due to a bug in the firmware, need to reserve byte order |
dan_ackme | 29:b6af04b77a56 | 84 | Wiconnect::ipToStr(ip, host); |
dan_ackme | 29:b6af04b77a56 | 85 | remotePort = port; |
dan_ackme | 29:b6af04b77a56 | 86 | } |
dan_ackme | 29:b6af04b77a56 | 87 | |
dan_ackme | 29:b6af04b77a56 | 88 | return result; |
dan_ackme | 29:b6af04b77a56 | 89 | } |
dan_ackme | 29:b6af04b77a56 | 90 | |
dan_ackme | 29:b6af04b77a56 | 91 | /*************************************************************************************************/ |
dan_ackme | 29:b6af04b77a56 | 92 | WiconnectResult WiconnectUdpServer::setRemoteClient(uint32_t ip, uint16_t port) |
dan_ackme | 29:b6af04b77a56 | 93 | { |
dan_ackme | 29:b6af04b77a56 | 94 | ip = htonl(ip); // due to a bug in the firmware, need to reserve byte order |
dan_ackme | 29:b6af04b77a56 | 95 | Wiconnect::ipToStr(ip, host); |
dan_ackme | 29:b6af04b77a56 | 96 | remotePort = port; |
dan_ackme | 29:b6af04b77a56 | 97 | return WICONNECT_SUCCESS; |
dan_ackme | 29:b6af04b77a56 | 98 | } |
dan_ackme | 29:b6af04b77a56 | 99 | |
dan_ackme | 29:b6af04b77a56 | 100 | /*************************************************************************************************/ |
dan_ackme | 29:b6af04b77a56 | 101 | WiconnectResult WiconnectUdpServer::flushTxBuffer() |
dan_ackme | 29:b6af04b77a56 | 102 | { |
dan_ackme | 29:b6af04b77a56 | 103 | WiconnectResult result = WICONNECT_SUCCESS; |
dan_ackme | 29:b6af04b77a56 | 104 | |
dan_ackme | 29:b6af04b77a56 | 105 | CHECK_CONNECTED(); |
dan_ackme | 29:b6af04b77a56 | 106 | |
dan_ackme | 29:b6af04b77a56 | 107 | if(txBuffer.size == 0) |
dan_ackme | 29:b6af04b77a56 | 108 | { |
dan_ackme | 29:b6af04b77a56 | 109 | CHECK_OTHER_COMMAND_EXECUTING(); |
dan_ackme | 29:b6af04b77a56 | 110 | } |
dan_ackme | 29:b6af04b77a56 | 111 | |
dan_ackme | 29:b6af04b77a56 | 112 | |
dan_ackme | 29:b6af04b77a56 | 113 | if(txBuffer.bytesPending > 0) |
dan_ackme | 29:b6af04b77a56 | 114 | { |
dan_ackme | 29:b6af04b77a56 | 115 | loop: |
dan_ackme | 29:b6af04b77a56 | 116 | if(host[0] != 0) |
dan_ackme | 29:b6af04b77a56 | 117 | { |
dan_ackme | 29:b6af04b77a56 | 118 | result = wiconnect->sendCommand(ReaderFunc(readerCallback), &this->txBuffer, "udps write %u %s %u", txBuffer.bytesPending, host, remotePort); |
dan_ackme | 29:b6af04b77a56 | 119 | } |
dan_ackme | 29:b6af04b77a56 | 120 | else |
dan_ackme | 29:b6af04b77a56 | 121 | { |
dan_ackme | 29:b6af04b77a56 | 122 | result = wiconnect->sendCommand(ReaderFunc(readerCallback), &this->txBuffer, "udps write %u", txBuffer.bytesPending); |
dan_ackme | 29:b6af04b77a56 | 123 | } |
dan_ackme | 29:b6af04b77a56 | 124 | |
dan_ackme | 29:b6af04b77a56 | 125 | // if still processing and in non-blocking mode and using a txtBuffer, |
dan_ackme | 29:b6af04b77a56 | 126 | // then this api call must block until all the data is sent |
dan_ackme | 29:b6af04b77a56 | 127 | if(result == WICONNECT_PROCESSING && wiconnect->nonBlocking && txBuffer.size > 0) |
dan_ackme | 29:b6af04b77a56 | 128 | { |
dan_ackme | 29:b6af04b77a56 | 129 | goto loop; |
dan_ackme | 29:b6af04b77a56 | 130 | } |
dan_ackme | 29:b6af04b77a56 | 131 | } |
dan_ackme | 29:b6af04b77a56 | 132 | |
dan_ackme | 29:b6af04b77a56 | 133 | if(txBuffer.size == 0) |
dan_ackme | 29:b6af04b77a56 | 134 | { |
dan_ackme | 29:b6af04b77a56 | 135 | CHECK_CLEANUP_COMMAND(); |
dan_ackme | 29:b6af04b77a56 | 136 | } |
dan_ackme | 29:b6af04b77a56 | 137 | |
dan_ackme | 29:b6af04b77a56 | 138 | if(result != WICONNECT_PROCESSING) |
dan_ackme | 29:b6af04b77a56 | 139 | { |
dan_ackme | 29:b6af04b77a56 | 140 | txBuffer.ptr = txBuffer.buffer; |
dan_ackme | 29:b6af04b77a56 | 141 | txBuffer.bytesPending = 0; |
dan_ackme | 29:b6af04b77a56 | 142 | } |
dan_ackme | 29:b6af04b77a56 | 143 | |
dan_ackme | 29:b6af04b77a56 | 144 | return result; |
dan_ackme | 29:b6af04b77a56 | 145 | } |