Poerting the Xbee library to use teh wifi functionality of the LPC4088.
Dependents: XBee_WiFi_EA_LPC4088
Fork of XBee by
XBeeWiFi.cpp@3:8573b122fa84, 2012-03-08 (annotated)
- Committer:
- okini3939
- Date:
- Thu Mar 08 17:41:29 2012 +0000
- Revision:
- 3:8573b122fa84
- Parent:
- 2:6efb3541af61
- Child:
- 4:f6d73acc1f75
Who changed what in which revision?
User | Revision | Line number | New contents of line |
---|---|---|---|
okini3939 | 2:6efb3541af61 | 1 | /** |
okini3939 | 2:6efb3541af61 | 2 | * XBee Wi-Fi library for mbed |
okini3939 | 2:6efb3541af61 | 3 | * Copyright (c) 2011 Hiroshi Suga |
okini3939 | 2:6efb3541af61 | 4 | * Released under the MIT License: http://mbed.org/license/mit |
okini3939 | 2:6efb3541af61 | 5 | */ |
okini3939 | 2:6efb3541af61 | 6 | |
okini3939 | 2:6efb3541af61 | 7 | /** @file |
okini3939 | 3:8573b122fa84 | 8 | * @brief XBee Wi-Fi library for mbed |
okini3939 | 2:6efb3541af61 | 9 | */ |
okini3939 | 2:6efb3541af61 | 10 | |
okini3939 | 3:8573b122fa84 | 11 | //#define DEBUG |
okini3939 | 3:8573b122fa84 | 12 | #include "dbg.h" |
okini3939 | 3:8573b122fa84 | 13 | |
okini3939 | 2:6efb3541af61 | 14 | #include "mbed.h" |
okini3939 | 2:6efb3541af61 | 15 | #include "XBee.h" |
okini3939 | 2:6efb3541af61 | 16 | #include "XBeeWiFi.h" |
okini3939 | 2:6efb3541af61 | 17 | #include "EthernetNetIf.h" |
okini3939 | 2:6efb3541af61 | 18 | |
okini3939 | 2:6efb3541af61 | 19 | #define REVERSE_ENDIAN(x) (uint16_t)(((uint16_t)x >> 8) | ((uint16_t)x << 8)) |
okini3939 | 2:6efb3541af61 | 20 | |
okini3939 | 2:6efb3541af61 | 21 | #ifdef USE_WIFICLASS |
okini3939 | 3:8573b122fa84 | 22 | XBeeWiFi::XBeeWiFi (PinName p_tx, PinName p_rx, PinName p_cts) : XBee(p_tx, p_rx, p_cts) { |
okini3939 | 2:6efb3541af61 | 23 | } |
okini3939 | 2:6efb3541af61 | 24 | |
okini3939 | 2:6efb3541af61 | 25 | int XBeeWiFi::setup (int security, const char *ssid, const char *pin) { |
okini3939 | 3:8573b122fa84 | 26 | int len, r; |
okini3939 | 2:6efb3541af61 | 27 | uint8_t cmd[2], val[32]; |
okini3939 | 2:6efb3541af61 | 28 | AtCommandRequest atRequest; |
okini3939 | 2:6efb3541af61 | 29 | |
okini3939 | 3:8573b122fa84 | 30 | // SSID |
okini3939 | 3:8573b122fa84 | 31 | memcpy(cmd, "ID", 2); |
okini3939 | 3:8573b122fa84 | 32 | len = strlen(ssid); |
okini3939 | 3:8573b122fa84 | 33 | memcpy(val, ssid, len); |
okini3939 | 3:8573b122fa84 | 34 | atRequest.setCommand(cmd); |
okini3939 | 3:8573b122fa84 | 35 | atRequest.setCommandValue(val); |
okini3939 | 3:8573b122fa84 | 36 | atRequest.setCommandValueLength(len); |
okini3939 | 3:8573b122fa84 | 37 | atRequest.setFrameId(getNextFrameId()); |
okini3939 | 3:8573b122fa84 | 38 | send(atRequest); |
okini3939 | 3:8573b122fa84 | 39 | r = getWiResponse(AT_COMMAND_RESPONSE, atRequest.getFrameId()); |
okini3939 | 3:8573b122fa84 | 40 | DBG("wifi ID: %d\r\n", r); |
okini3939 | 3:8573b122fa84 | 41 | if (r < 0) return -1; |
okini3939 | 3:8573b122fa84 | 42 | |
okini3939 | 3:8573b122fa84 | 43 | if (security != SECURITY_OPEN) { |
okini3939 | 3:8573b122fa84 | 44 | // PIN |
okini3939 | 3:8573b122fa84 | 45 | memcpy(cmd, "PK", 2); |
okini3939 | 3:8573b122fa84 | 46 | len = strlen(pin); |
okini3939 | 3:8573b122fa84 | 47 | memcpy(val, pin, len); |
okini3939 | 3:8573b122fa84 | 48 | atRequest.setCommand(cmd); |
okini3939 | 3:8573b122fa84 | 49 | atRequest.setCommandValue(val); |
okini3939 | 3:8573b122fa84 | 50 | atRequest.setCommandValueLength(len); |
okini3939 | 3:8573b122fa84 | 51 | atRequest.setFrameId(getNextFrameId()); |
okini3939 | 3:8573b122fa84 | 52 | send(atRequest); |
okini3939 | 3:8573b122fa84 | 53 | r = getWiResponse(AT_COMMAND_RESPONSE, atRequest.getFrameId()); |
okini3939 | 3:8573b122fa84 | 54 | DBG("wifi PK: %d\r\n", r); |
okini3939 | 3:8573b122fa84 | 55 | if (r < 0) return -1; |
okini3939 | 3:8573b122fa84 | 56 | } |
okini3939 | 3:8573b122fa84 | 57 | |
okini3939 | 2:6efb3541af61 | 58 | // security type |
okini3939 | 2:6efb3541af61 | 59 | memcpy(cmd, "EE", 2); |
okini3939 | 2:6efb3541af61 | 60 | val[0] = security; |
okini3939 | 2:6efb3541af61 | 61 | atRequest.setCommand(cmd); |
okini3939 | 2:6efb3541af61 | 62 | atRequest.setCommandValue(val); |
okini3939 | 2:6efb3541af61 | 63 | atRequest.setCommandValueLength(1); |
okini3939 | 3:8573b122fa84 | 64 | atRequest.setFrameId(getNextFrameId()); |
okini3939 | 2:6efb3541af61 | 65 | send(atRequest); |
okini3939 | 3:8573b122fa84 | 66 | r = getWiResponse(AT_COMMAND_RESPONSE, atRequest.getFrameId()); |
okini3939 | 3:8573b122fa84 | 67 | DBG("wifi EE: %d\r\n", r); |
okini3939 | 3:8573b122fa84 | 68 | if (r < 0) return -1; |
okini3939 | 2:6efb3541af61 | 69 | |
okini3939 | 2:6efb3541af61 | 70 | return 0; |
okini3939 | 2:6efb3541af61 | 71 | } |
okini3939 | 2:6efb3541af61 | 72 | |
okini3939 | 2:6efb3541af61 | 73 | int XBeeWiFi::setup (const char *ssid) { |
okini3939 | 2:6efb3541af61 | 74 | return setup(SECURITY_OPEN, ssid, NULL); |
okini3939 | 2:6efb3541af61 | 75 | } |
okini3939 | 2:6efb3541af61 | 76 | |
okini3939 | 2:6efb3541af61 | 77 | int XBeeWiFi::reset () { |
okini3939 | 2:6efb3541af61 | 78 | // RESET |
okini3939 | 3:8573b122fa84 | 79 | uint8_t cmd[2] = {'N', 'R'}; // Network reset |
okini3939 | 3:8573b122fa84 | 80 | // uint8_t cmd[2] = {'F', 'R'}; // Software reset |
okini3939 | 2:6efb3541af61 | 81 | AtCommandRequest atRequest; |
okini3939 | 2:6efb3541af61 | 82 | |
okini3939 | 2:6efb3541af61 | 83 | atRequest.setCommand(cmd); |
okini3939 | 3:8573b122fa84 | 84 | atRequest.setFrameId(getNextFrameId()); |
okini3939 | 2:6efb3541af61 | 85 | send(atRequest); |
okini3939 | 3:8573b122fa84 | 86 | return getWiResponse(AT_COMMAND_RESPONSE, atRequest.getFrameId()); |
okini3939 | 2:6efb3541af61 | 87 | } |
okini3939 | 2:6efb3541af61 | 88 | |
okini3939 | 2:6efb3541af61 | 89 | int XBeeWiFi::setAddress () { |
okini3939 | 2:6efb3541af61 | 90 | // DHCP |
okini3939 | 2:6efb3541af61 | 91 | uint8_t cmd[2] = {'M', 'A'}; |
okini3939 | 2:6efb3541af61 | 92 | char val[1] = {0}; |
okini3939 | 2:6efb3541af61 | 93 | AtCommandRequest atRequest; |
okini3939 | 2:6efb3541af61 | 94 | |
okini3939 | 2:6efb3541af61 | 95 | atRequest.setCommand(cmd); |
okini3939 | 2:6efb3541af61 | 96 | atRequest.setCommandValue((uint8_t*)val); |
okini3939 | 2:6efb3541af61 | 97 | atRequest.setCommandValueLength(1); |
okini3939 | 3:8573b122fa84 | 98 | atRequest.setFrameId(getNextFrameId()); |
okini3939 | 2:6efb3541af61 | 99 | send(atRequest); |
okini3939 | 2:6efb3541af61 | 100 | |
okini3939 | 3:8573b122fa84 | 101 | return getWiResponse(AT_COMMAND_RESPONSE, atRequest.getFrameId()); |
okini3939 | 2:6efb3541af61 | 102 | } |
okini3939 | 2:6efb3541af61 | 103 | |
okini3939 | 2:6efb3541af61 | 104 | int XBeeWiFi::setAddress (IpAddr &ipaddr, IpAddr &netmask, IpAddr &gateway, IpAddr &nameserver) { |
okini3939 | 2:6efb3541af61 | 105 | uint8_t cmd[2]; |
okini3939 | 2:6efb3541af61 | 106 | char val[32]; |
okini3939 | 2:6efb3541af61 | 107 | AtCommandRequest atRequest; |
okini3939 | 2:6efb3541af61 | 108 | |
okini3939 | 2:6efb3541af61 | 109 | // Static |
okini3939 | 2:6efb3541af61 | 110 | memcpy(cmd, "MA", 2); |
okini3939 | 2:6efb3541af61 | 111 | val[0] = 1; |
okini3939 | 2:6efb3541af61 | 112 | atRequest.setCommand(cmd); |
okini3939 | 2:6efb3541af61 | 113 | atRequest.setCommandValue((uint8_t*)val); |
okini3939 | 2:6efb3541af61 | 114 | atRequest.setCommandValueLength(1); |
okini3939 | 3:8573b122fa84 | 115 | atRequest.setFrameId(getNextFrameId()); |
okini3939 | 2:6efb3541af61 | 116 | send(atRequest); |
okini3939 | 3:8573b122fa84 | 117 | getWiResponse(AT_COMMAND_RESPONSE, atRequest.getFrameId()); |
okini3939 | 2:6efb3541af61 | 118 | |
okini3939 | 2:6efb3541af61 | 119 | // IP address |
okini3939 | 2:6efb3541af61 | 120 | memcpy(cmd, "MY", 2); |
okini3939 | 2:6efb3541af61 | 121 | sprintf(val, "%d.%d.%d.%d", ipaddr[0], ipaddr[1], ipaddr[2], ipaddr[3]); |
okini3939 | 2:6efb3541af61 | 122 | atRequest.setCommand(cmd); |
okini3939 | 2:6efb3541af61 | 123 | atRequest.setCommandValue((uint8_t*)val); |
okini3939 | 2:6efb3541af61 | 124 | atRequest.setCommandValueLength(strlen(val)); |
okini3939 | 3:8573b122fa84 | 125 | atRequest.setFrameId(getNextFrameId()); |
okini3939 | 2:6efb3541af61 | 126 | send(atRequest); |
okini3939 | 3:8573b122fa84 | 127 | getWiResponse(AT_COMMAND_RESPONSE, atRequest.getFrameId()); |
okini3939 | 2:6efb3541af61 | 128 | |
okini3939 | 2:6efb3541af61 | 129 | // sub netmask |
okini3939 | 2:6efb3541af61 | 130 | memcpy(cmd, "NK", 2); |
okini3939 | 2:6efb3541af61 | 131 | sprintf(val, "%d.%d.%d.%d", netmask[0], netmask[1], netmask[2], netmask[3]); |
okini3939 | 2:6efb3541af61 | 132 | atRequest.setCommand(cmd); |
okini3939 | 2:6efb3541af61 | 133 | atRequest.setCommandValue((uint8_t*)val); |
okini3939 | 2:6efb3541af61 | 134 | atRequest.setCommandValueLength(strlen(val)); |
okini3939 | 3:8573b122fa84 | 135 | atRequest.setFrameId(getNextFrameId()); |
okini3939 | 2:6efb3541af61 | 136 | send(atRequest); |
okini3939 | 3:8573b122fa84 | 137 | getWiResponse(AT_COMMAND_RESPONSE, atRequest.getFrameId()); |
okini3939 | 2:6efb3541af61 | 138 | |
okini3939 | 2:6efb3541af61 | 139 | // default gateway |
okini3939 | 2:6efb3541af61 | 140 | memcpy(cmd, "GW", 2); |
okini3939 | 2:6efb3541af61 | 141 | sprintf(val, "%d.%d.%d.%d", gateway[0], gateway[1], gateway[2], gateway[3]); |
okini3939 | 2:6efb3541af61 | 142 | atRequest.setCommand(cmd); |
okini3939 | 2:6efb3541af61 | 143 | atRequest.setCommandValue((uint8_t*)val); |
okini3939 | 2:6efb3541af61 | 144 | atRequest.setCommandValueLength(strlen(val)); |
okini3939 | 3:8573b122fa84 | 145 | atRequest.setFrameId(getNextFrameId()); |
okini3939 | 2:6efb3541af61 | 146 | send(atRequest); |
okini3939 | 3:8573b122fa84 | 147 | getWiResponse(AT_COMMAND_RESPONSE, atRequest.getFrameId()); |
okini3939 | 2:6efb3541af61 | 148 | |
okini3939 | 2:6efb3541af61 | 149 | // name server |
okini3939 | 2:6efb3541af61 | 150 | _nameserver = nameserver; |
okini3939 | 2:6efb3541af61 | 151 | |
okini3939 | 2:6efb3541af61 | 152 | return 0; |
okini3939 | 2:6efb3541af61 | 153 | } |
okini3939 | 2:6efb3541af61 | 154 | |
okini3939 | 3:8573b122fa84 | 155 | int XBeeWiFi::getAddress (IpAddr &ipaddr, IpAddr &netmask, IpAddr &gateway, IpAddr &nameserver) { |
okini3939 | 3:8573b122fa84 | 156 | int r; |
okini3939 | 3:8573b122fa84 | 157 | uint8_t cmd[2]; |
okini3939 | 3:8573b122fa84 | 158 | AtCommandRequest atRequest; |
okini3939 | 3:8573b122fa84 | 159 | AtCommandResponse atResponse; |
okini3939 | 3:8573b122fa84 | 160 | |
okini3939 | 3:8573b122fa84 | 161 | memcpy(cmd, "MY", 2); |
okini3939 | 3:8573b122fa84 | 162 | atRequest.setCommand(cmd); |
okini3939 | 3:8573b122fa84 | 163 | atRequest.clearCommandValue(); |
okini3939 | 3:8573b122fa84 | 164 | atRequest.setFrameId(getNextFrameId()); |
okini3939 | 3:8573b122fa84 | 165 | send(atRequest); |
okini3939 | 3:8573b122fa84 | 166 | r = getWiResponse(AT_COMMAND_RESPONSE, atRequest.getFrameId()); |
okini3939 | 3:8573b122fa84 | 167 | DBG("wifi MY: %d\r\n", r); |
okini3939 | 3:8573b122fa84 | 168 | if (r >= 0) { |
okini3939 | 3:8573b122fa84 | 169 | r = getWiAddr(ipaddr); |
okini3939 | 3:8573b122fa84 | 170 | } |
okini3939 | 3:8573b122fa84 | 171 | |
okini3939 | 3:8573b122fa84 | 172 | memcpy(cmd, "MK", 2); |
okini3939 | 3:8573b122fa84 | 173 | atRequest.setCommand(cmd); |
okini3939 | 3:8573b122fa84 | 174 | atRequest.clearCommandValue(); |
okini3939 | 3:8573b122fa84 | 175 | atRequest.setFrameId(getNextFrameId()); |
okini3939 | 3:8573b122fa84 | 176 | send(atRequest); |
okini3939 | 3:8573b122fa84 | 177 | r = getWiResponse(AT_COMMAND_RESPONSE, atRequest.getFrameId()); |
okini3939 | 3:8573b122fa84 | 178 | DBG("wifi MK: %d\r\n", r); |
okini3939 | 3:8573b122fa84 | 179 | if (r >= 0) { |
okini3939 | 3:8573b122fa84 | 180 | r = getWiAddr(netmask); |
okini3939 | 3:8573b122fa84 | 181 | } |
okini3939 | 3:8573b122fa84 | 182 | |
okini3939 | 3:8573b122fa84 | 183 | memcpy(cmd, "GW", 2); |
okini3939 | 3:8573b122fa84 | 184 | atRequest.setCommand(cmd); |
okini3939 | 3:8573b122fa84 | 185 | atRequest.clearCommandValue(); |
okini3939 | 3:8573b122fa84 | 186 | atRequest.setFrameId(getNextFrameId()); |
okini3939 | 3:8573b122fa84 | 187 | send(atRequest); |
okini3939 | 3:8573b122fa84 | 188 | r = getWiResponse(AT_COMMAND_RESPONSE, atRequest.getFrameId()); |
okini3939 | 3:8573b122fa84 | 189 | DBG("wifi GW: %d\r\n", r); |
okini3939 | 3:8573b122fa84 | 190 | if (r >= 0) { |
okini3939 | 3:8573b122fa84 | 191 | r = getWiAddr(gateway); |
okini3939 | 3:8573b122fa84 | 192 | } |
okini3939 | 3:8573b122fa84 | 193 | |
okini3939 | 3:8573b122fa84 | 194 | nameserver = _nameserver; |
okini3939 | 3:8573b122fa84 | 195 | |
okini3939 | 3:8573b122fa84 | 196 | return 0; |
okini3939 | 3:8573b122fa84 | 197 | } |
okini3939 | 3:8573b122fa84 | 198 | |
okini3939 | 3:8573b122fa84 | 199 | int XBeeWiFi::getWiAddr (IpAddr &ipaddr) { |
okini3939 | 3:8573b122fa84 | 200 | int ip1, ip2, ip3, ip4; |
okini3939 | 3:8573b122fa84 | 201 | AtCommandResponse atResponse; |
okini3939 | 3:8573b122fa84 | 202 | |
okini3939 | 3:8573b122fa84 | 203 | getResponse().getAtCommandResponse(atResponse); |
okini3939 | 3:8573b122fa84 | 204 | if (atResponse.isOk() && atResponse.getValueLength() >= 7) { |
okini3939 | 3:8573b122fa84 | 205 | sscanf((char*)atResponse.getValue(), "%d.%d.%d.%d", &ip1, &ip2, &ip3, &ip4); |
okini3939 | 3:8573b122fa84 | 206 | ipaddr = IpAddr(ip1, ip2, ip3, ip4); |
okini3939 | 3:8573b122fa84 | 207 | return 0; |
okini3939 | 3:8573b122fa84 | 208 | } |
okini3939 | 3:8573b122fa84 | 209 | return -1; |
okini3939 | 3:8573b122fa84 | 210 | } |
okini3939 | 3:8573b122fa84 | 211 | |
okini3939 | 2:6efb3541af61 | 212 | int XBeeWiFi::setTimeout (int timeout) { |
okini3939 | 2:6efb3541af61 | 213 | // timeout |
okini3939 | 2:6efb3541af61 | 214 | uint8_t cmd[2] = {'T', 'P'}; |
okini3939 | 2:6efb3541af61 | 215 | char val[1]; |
okini3939 | 2:6efb3541af61 | 216 | AtCommandRequest atRequest; |
okini3939 | 2:6efb3541af61 | 217 | |
okini3939 | 2:6efb3541af61 | 218 | val[0] = timeout; |
okini3939 | 2:6efb3541af61 | 219 | atRequest.setCommand(cmd); |
okini3939 | 2:6efb3541af61 | 220 | atRequest.setCommandValue((uint8_t*)val); |
okini3939 | 2:6efb3541af61 | 221 | atRequest.setCommandValueLength(1); |
okini3939 | 3:8573b122fa84 | 222 | atRequest.setFrameId(getNextFrameId()); |
okini3939 | 2:6efb3541af61 | 223 | send(atRequest); |
okini3939 | 2:6efb3541af61 | 224 | |
okini3939 | 2:6efb3541af61 | 225 | return getWiResponse(AT_COMMAND_RESPONSE); |
okini3939 | 2:6efb3541af61 | 226 | } |
okini3939 | 2:6efb3541af61 | 227 | |
okini3939 | 2:6efb3541af61 | 228 | int XBeeWiFi::getStatus () { |
okini3939 | 2:6efb3541af61 | 229 | // AI |
okini3939 | 2:6efb3541af61 | 230 | uint8_t cmd[2] = {'A', 'I'}; |
okini3939 | 2:6efb3541af61 | 231 | AtCommandRequest atRequest; |
okini3939 | 2:6efb3541af61 | 232 | |
okini3939 | 2:6efb3541af61 | 233 | atRequest.setCommand(cmd); |
okini3939 | 3:8573b122fa84 | 234 | atRequest.setFrameId(getNextFrameId()); |
okini3939 | 2:6efb3541af61 | 235 | send(atRequest); |
okini3939 | 2:6efb3541af61 | 236 | |
okini3939 | 3:8573b122fa84 | 237 | return getWiResponse(AT_COMMAND_RESPONSE, atRequest.getFrameId()); |
okini3939 | 2:6efb3541af61 | 238 | } |
okini3939 | 2:6efb3541af61 | 239 | |
okini3939 | 3:8573b122fa84 | 240 | int XBeeWiFi::getWiResponse (int apiId, int frameid, int timeout) { |
okini3939 | 2:6efb3541af61 | 241 | AtCommandResponse atResponse; |
okini3939 | 2:6efb3541af61 | 242 | |
okini3939 | 2:6efb3541af61 | 243 | if (readPacket(timeout)) { |
okini3939 | 3:8573b122fa84 | 244 | if (frameid && frameid != getResponse().getFrameData()[0]) { |
okini3939 | 3:8573b122fa84 | 245 | DBG("Expected AT response but got %x (frame %d)\r\n", getResponse().getApiId(), getResponse().getFrameData()[0]); |
okini3939 | 3:8573b122fa84 | 246 | if (! readPacket(timeout)) return -1; |
okini3939 | 3:8573b122fa84 | 247 | DBG("Retry ok\r\n"); |
okini3939 | 3:8573b122fa84 | 248 | } |
okini3939 | 3:8573b122fa84 | 249 | |
okini3939 | 2:6efb3541af61 | 250 | if (getResponse().getApiId() == apiId) { |
okini3939 | 2:6efb3541af61 | 251 | getResponse().getAtCommandResponse(atResponse); |
okini3939 | 2:6efb3541af61 | 252 | |
okini3939 | 3:8573b122fa84 | 253 | if (getResponse().getApiId() == IPv4_RX_FRAME) { |
okini3939 | 3:8573b122fa84 | 254 | return 0; |
okini3939 | 3:8573b122fa84 | 255 | } else |
okini3939 | 2:6efb3541af61 | 256 | if (atResponse.isOk()) { |
okini3939 | 2:6efb3541af61 | 257 | |
okini3939 | 3:8573b122fa84 | 258 | // if (getResponse().getFrameDataLength() > 4) { |
okini3939 | 2:6efb3541af61 | 259 | return atResponse.getValue()[0]; |
okini3939 | 2:6efb3541af61 | 260 | |
okini3939 | 2:6efb3541af61 | 261 | } else { |
okini3939 | 3:8573b122fa84 | 262 | DBG("Command return error code: %x\r\n", atResponse.getStatus()); |
okini3939 | 2:6efb3541af61 | 263 | } |
okini3939 | 2:6efb3541af61 | 264 | } else { |
okini3939 | 3:8573b122fa84 | 265 | DBG("Expected AT response but got %x\r\n", getResponse().getApiId()); |
okini3939 | 2:6efb3541af61 | 266 | } |
okini3939 | 2:6efb3541af61 | 267 | } else { |
okini3939 | 2:6efb3541af61 | 268 | if (getResponse().isError()) { |
okini3939 | 3:8573b122fa84 | 269 | DBG("Error reading packet. Error code: %x\r\n", getResponse().getErrorCode()); |
okini3939 | 2:6efb3541af61 | 270 | } else { |
okini3939 | 3:8573b122fa84 | 271 | DBG("No response from radio\r\n"); |
okini3939 | 2:6efb3541af61 | 272 | } |
okini3939 | 2:6efb3541af61 | 273 | } |
okini3939 | 2:6efb3541af61 | 274 | |
okini3939 | 2:6efb3541af61 | 275 | return -1; |
okini3939 | 2:6efb3541af61 | 276 | } |
okini3939 | 2:6efb3541af61 | 277 | |
okini3939 | 2:6efb3541af61 | 278 | #ifdef USE_WIFIDNS |
okini3939 | 3:8573b122fa84 | 279 | int XBeeWiFi::setNameserver (IpAddr &nameserver) { |
okini3939 | 3:8573b122fa84 | 280 | _nameserver = nameserver; |
okini3939 | 3:8573b122fa84 | 281 | return 0; |
okini3939 | 3:8573b122fa84 | 282 | } |
okini3939 | 3:8573b122fa84 | 283 | |
okini3939 | 2:6efb3541af61 | 284 | int XBeeWiFi::getHostByName (const char* name, IpAddr &addr) { |
okini3939 | 2:6efb3541af61 | 285 | char buf[1024]; |
okini3939 | 3:8573b122fa84 | 286 | int i, r, len; |
okini3939 | 3:8573b122fa84 | 287 | uint8_t cmd[2] = {'C', '0'}; |
okini3939 | 3:8573b122fa84 | 288 | char val[2]; |
okini3939 | 2:6efb3541af61 | 289 | IPv4TransmitRequest dnsRequest; |
okini3939 | 2:6efb3541af61 | 290 | AtCommandRequest atRequest; |
okini3939 | 2:6efb3541af61 | 291 | AtCommandResponse atResponse; |
okini3939 | 2:6efb3541af61 | 292 | |
okini3939 | 2:6efb3541af61 | 293 | if (!strcmp(name, "localhost")) { |
okini3939 | 2:6efb3541af61 | 294 | addr = IpAddr(127, 0, 0, 1); |
okini3939 | 2:6efb3541af61 | 295 | return 0; |
okini3939 | 2:6efb3541af61 | 296 | } |
okini3939 | 3:8573b122fa84 | 297 | |
okini3939 | 3:8573b122fa84 | 298 | // bind src port |
okini3939 | 3:8573b122fa84 | 299 | val[0] = (DNS_SRC_PORT >> 8) & 0xff; |
okini3939 | 3:8573b122fa84 | 300 | val[1] = DNS_SRC_PORT & 0xff; |
okini3939 | 3:8573b122fa84 | 301 | atRequest.setCommand(cmd); |
okini3939 | 3:8573b122fa84 | 302 | atRequest.setCommandValue((uint8_t*)val); |
okini3939 | 3:8573b122fa84 | 303 | atRequest.setCommandValueLength(2); |
okini3939 | 3:8573b122fa84 | 304 | atRequest.setFrameId(getNextFrameId()); |
okini3939 | 3:8573b122fa84 | 305 | send(atRequest); |
okini3939 | 3:8573b122fa84 | 306 | r = getWiResponse(AT_COMMAND_RESPONSE); |
okini3939 | 3:8573b122fa84 | 307 | DBG("wifi C0: %d\r\n", r); |
okini3939 | 2:6efb3541af61 | 308 | |
okini3939 | 2:6efb3541af61 | 309 | // send DNS request |
okini3939 | 3:8573b122fa84 | 310 | len = createDnsRequest(name, buf); |
okini3939 | 2:6efb3541af61 | 311 | dnsRequest.setAddress(_nameserver); |
okini3939 | 3:8573b122fa84 | 312 | dnsRequest.setDstPort(DNS_PORT); |
okini3939 | 3:8573b122fa84 | 313 | dnsRequest.setSrcPort(DNS_SRC_PORT); |
okini3939 | 2:6efb3541af61 | 314 | dnsRequest.setProtocol(PROTOCOL_UDP); |
okini3939 | 2:6efb3541af61 | 315 | dnsRequest.setPayload((uint8_t*)buf); |
okini3939 | 2:6efb3541af61 | 316 | dnsRequest.setPayloadLength(len); |
okini3939 | 3:8573b122fa84 | 317 | for (i = 0; i < DNS_TIMEOUT; i ++) { |
okini3939 | 3:8573b122fa84 | 318 | dnsRequest.setFrameId(getNextFrameId()); |
okini3939 | 3:8573b122fa84 | 319 | send(dnsRequest); |
okini3939 | 3:8573b122fa84 | 320 | |
okini3939 | 3:8573b122fa84 | 321 | r = getWiResponse(TX_STATUS_RESPONSE, dnsRequest.getFrameId()); |
okini3939 | 3:8573b122fa84 | 322 | DBG("wifi TX: %d\r\n", r); |
okini3939 | 2:6efb3541af61 | 323 | |
okini3939 | 3:8573b122fa84 | 324 | if (r == 0) { |
okini3939 | 3:8573b122fa84 | 325 | // recv DNS request |
okini3939 | 3:8573b122fa84 | 326 | r = getWiResponse(IPv4_RX_FRAME, 0, 3000); |
okini3939 | 3:8573b122fa84 | 327 | DBG("wifi RX: %d\r\n", r); |
okini3939 | 3:8573b122fa84 | 328 | if (r >= 0) { |
okini3939 | 3:8573b122fa84 | 329 | getResponse().getAtCommandResponse(atResponse); |
okini3939 | 3:8573b122fa84 | 330 | return getDnsResponse(atResponse.getValue() + 6, atResponse.getValueLength() - 6, addr); |
okini3939 | 2:6efb3541af61 | 331 | } |
okini3939 | 3:8573b122fa84 | 332 | } else { |
okini3939 | 3:8573b122fa84 | 333 | break; |
okini3939 | 2:6efb3541af61 | 334 | } |
okini3939 | 2:6efb3541af61 | 335 | } |
okini3939 | 2:6efb3541af61 | 336 | |
okini3939 | 2:6efb3541af61 | 337 | return -1; |
okini3939 | 2:6efb3541af61 | 338 | } |
okini3939 | 2:6efb3541af61 | 339 | |
okini3939 | 2:6efb3541af61 | 340 | int XBeeWiFi::createDnsRequest (const char* name, char *buf) { |
okini3939 | 2:6efb3541af61 | 341 | struct DNSHeader *dnsHeader; |
okini3939 | 2:6efb3541af61 | 342 | struct DnsQuestionEnd *dnsEnd; |
okini3939 | 2:6efb3541af61 | 343 | int len, num; |
okini3939 | 2:6efb3541af61 | 344 | |
okini3939 | 2:6efb3541af61 | 345 | // DNS header |
okini3939 | 2:6efb3541af61 | 346 | dnsHeader = (DNSHeader*)buf; |
okini3939 | 2:6efb3541af61 | 347 | dnsHeader->id = REVERSE_ENDIAN(0xdead); |
okini3939 | 2:6efb3541af61 | 348 | dnsHeader->flags = REVERSE_ENDIAN(0x100); |
okini3939 | 2:6efb3541af61 | 349 | dnsHeader->questions = REVERSE_ENDIAN(1); |
okini3939 | 2:6efb3541af61 | 350 | dnsHeader->answers = 0; |
okini3939 | 2:6efb3541af61 | 351 | dnsHeader->authorities = 0; |
okini3939 | 2:6efb3541af61 | 352 | dnsHeader->additional = 0; |
okini3939 | 2:6efb3541af61 | 353 | |
okini3939 | 2:6efb3541af61 | 354 | // DNS question |
okini3939 | 3:8573b122fa84 | 355 | len = sizeof(DNSHeader); |
okini3939 | 3:8573b122fa84 | 356 | while ((num = (int)strchr(name, '.')) != NULL) { |
okini3939 | 2:6efb3541af61 | 357 | num = num - (int)name; |
okini3939 | 2:6efb3541af61 | 358 | buf[len] = num; |
okini3939 | 2:6efb3541af61 | 359 | len ++; |
okini3939 | 2:6efb3541af61 | 360 | strncpy(&buf[len], name, num); |
okini3939 | 3:8573b122fa84 | 361 | name = name + num + 1; |
okini3939 | 2:6efb3541af61 | 362 | len = len + num; |
okini3939 | 2:6efb3541af61 | 363 | } |
okini3939 | 2:6efb3541af61 | 364 | |
okini3939 | 3:8573b122fa84 | 365 | if ((num = strlen(name)) != NULL) { |
okini3939 | 2:6efb3541af61 | 366 | buf[len] = num; |
okini3939 | 2:6efb3541af61 | 367 | len ++; |
okini3939 | 2:6efb3541af61 | 368 | strncpy(&buf[len], name, num); |
okini3939 | 3:8573b122fa84 | 369 | len = len + num; |
okini3939 | 2:6efb3541af61 | 370 | } |
okini3939 | 3:8573b122fa84 | 371 | buf[len] = 0; |
okini3939 | 3:8573b122fa84 | 372 | len ++; |
okini3939 | 2:6efb3541af61 | 373 | |
okini3939 | 2:6efb3541af61 | 374 | dnsEnd = (DnsQuestionEnd*)&buf[len]; |
okini3939 | 2:6efb3541af61 | 375 | dnsEnd->type = REVERSE_ENDIAN(DNS_QUERY_A); |
okini3939 | 2:6efb3541af61 | 376 | dnsEnd->clas = REVERSE_ENDIAN(DNS_CLASS_IN); |
okini3939 | 2:6efb3541af61 | 377 | |
okini3939 | 3:8573b122fa84 | 378 | return len + sizeof(DnsQuestionEnd); |
okini3939 | 2:6efb3541af61 | 379 | } |
okini3939 | 2:6efb3541af61 | 380 | |
okini3939 | 2:6efb3541af61 | 381 | int XBeeWiFi::getDnsResponse (const uint8_t *buf, int len, IpAddr &addr) { |
okini3939 | 2:6efb3541af61 | 382 | int i; |
okini3939 | 2:6efb3541af61 | 383 | struct DNSHeader *dnsHeader; |
okini3939 | 2:6efb3541af61 | 384 | struct DnsAnswer *dnsAnswer; |
okini3939 | 2:6efb3541af61 | 385 | |
okini3939 | 2:6efb3541af61 | 386 | // DNS header |
okini3939 | 2:6efb3541af61 | 387 | dnsHeader = (DNSHeader*)buf; |
okini3939 | 2:6efb3541af61 | 388 | if (REVERSE_ENDIAN(dnsHeader->id) != 0xdead || (REVERSE_ENDIAN(dnsHeader->flags) & 0x800f) != 0x8000) { |
okini3939 | 2:6efb3541af61 | 389 | return -1; |
okini3939 | 2:6efb3541af61 | 390 | } |
okini3939 | 2:6efb3541af61 | 391 | |
okini3939 | 2:6efb3541af61 | 392 | // skip question |
okini3939 | 3:8573b122fa84 | 393 | for (i = sizeof(DNSHeader); buf[i] && i < len; i ++); |
okini3939 | 2:6efb3541af61 | 394 | i = i + 1 + sizeof(DnsQuestionEnd); |
okini3939 | 2:6efb3541af61 | 395 | |
okini3939 | 2:6efb3541af61 | 396 | // DNS answer |
okini3939 | 2:6efb3541af61 | 397 | while (i < len) { |
okini3939 | 2:6efb3541af61 | 398 | dnsAnswer = (DnsAnswer*)&buf[i]; |
okini3939 | 2:6efb3541af61 | 399 | if (dnsAnswer->clas != REVERSE_ENDIAN(DNS_CLASS_IN)) { |
okini3939 | 2:6efb3541af61 | 400 | return -1; |
okini3939 | 2:6efb3541af61 | 401 | } |
okini3939 | 2:6efb3541af61 | 402 | |
okini3939 | 3:8573b122fa84 | 403 | i = i + sizeof(DnsAnswer); |
okini3939 | 2:6efb3541af61 | 404 | if (dnsAnswer->type == REVERSE_ENDIAN(DNS_QUERY_A)) { |
okini3939 | 2:6efb3541af61 | 405 | addr = IpAddr(buf[i], buf[i + 1], buf[i + 2], buf[i + 3]); |
okini3939 | 2:6efb3541af61 | 406 | return 0; |
okini3939 | 2:6efb3541af61 | 407 | } |
okini3939 | 2:6efb3541af61 | 408 | i = i + dnsAnswer->length; |
okini3939 | 2:6efb3541af61 | 409 | } |
okini3939 | 2:6efb3541af61 | 410 | |
okini3939 | 2:6efb3541af61 | 411 | return -1; |
okini3939 | 2:6efb3541af61 | 412 | } |
okini3939 | 2:6efb3541af61 | 413 | #endif |
okini3939 | 2:6efb3541af61 | 414 | |
okini3939 | 2:6efb3541af61 | 415 | #endif |
okini3939 | 2:6efb3541af61 | 416 | |
okini3939 | 2:6efb3541af61 | 417 | |
okini3939 | 2:6efb3541af61 | 418 | IPv4TransmitRequest::IPv4TransmitRequest() : PayloadRequest(IPv4_TRANSMIT_REQUEST, DEFAULT_FRAME_ID, NULL, 0) { |
okini3939 | 2:6efb3541af61 | 419 | } |
okini3939 | 2:6efb3541af61 | 420 | |
okini3939 | 2:6efb3541af61 | 421 | IPv4TransmitRequest::IPv4TransmitRequest(IpAddr &dstAddr, uint16_t dstPort, uint16_t srcPort, uint8_t protocol, uint8_t option, uint8_t *data, uint8_t dataLength, uint8_t frameId): PayloadRequest(IPv4_TRANSMIT_REQUEST, frameId, data, dataLength) { |
okini3939 | 2:6efb3541af61 | 422 | _dstAddr = dstAddr; |
okini3939 | 2:6efb3541af61 | 423 | _dstPort = dstPort; |
okini3939 | 2:6efb3541af61 | 424 | _srcPort = srcPort; |
okini3939 | 2:6efb3541af61 | 425 | _protocol = protocol; |
okini3939 | 2:6efb3541af61 | 426 | _option = option; |
okini3939 | 2:6efb3541af61 | 427 | } |
okini3939 | 2:6efb3541af61 | 428 | |
okini3939 | 2:6efb3541af61 | 429 | IPv4TransmitRequest::IPv4TransmitRequest(IpAddr &dstAddr, uint16_t dstPort, uint8_t *data, uint8_t dataLength): PayloadRequest(IPv4_TRANSMIT_REQUEST, DEFAULT_FRAME_ID, data, dataLength) { |
okini3939 | 2:6efb3541af61 | 430 | _dstAddr = dstAddr; |
okini3939 | 2:6efb3541af61 | 431 | _dstPort = dstPort; |
okini3939 | 2:6efb3541af61 | 432 | _srcPort = 0x270f; |
okini3939 | 2:6efb3541af61 | 433 | _protocol = PROTOCOL_UDP; |
okini3939 | 2:6efb3541af61 | 434 | _option = 0; |
okini3939 | 2:6efb3541af61 | 435 | } |
okini3939 | 2:6efb3541af61 | 436 | |
okini3939 | 2:6efb3541af61 | 437 | uint8_t IPv4TransmitRequest::getFrameData(uint8_t pos) { |
okini3939 | 2:6efb3541af61 | 438 | if (pos == 0) { |
okini3939 | 2:6efb3541af61 | 439 | return _dstAddr[0]; |
okini3939 | 2:6efb3541af61 | 440 | } else if (pos == 1) { |
okini3939 | 2:6efb3541af61 | 441 | return _dstAddr[1]; |
okini3939 | 2:6efb3541af61 | 442 | } else if (pos == 2) { |
okini3939 | 2:6efb3541af61 | 443 | return _dstAddr[2]; |
okini3939 | 2:6efb3541af61 | 444 | } else if (pos == 3) { |
okini3939 | 2:6efb3541af61 | 445 | return _dstAddr[3]; |
okini3939 | 2:6efb3541af61 | 446 | } else if (pos == 4) { |
okini3939 | 2:6efb3541af61 | 447 | return (_dstPort >> 8) & 0xff; |
okini3939 | 2:6efb3541af61 | 448 | } else if (pos == 5) { |
okini3939 | 2:6efb3541af61 | 449 | return _dstPort & 0xff; |
okini3939 | 2:6efb3541af61 | 450 | } else if (pos == 6) { |
okini3939 | 2:6efb3541af61 | 451 | return (_srcPort >> 8) & 0xff; |
okini3939 | 2:6efb3541af61 | 452 | } else if (pos == 7) { |
okini3939 | 2:6efb3541af61 | 453 | return _srcPort & 0xff; |
okini3939 | 2:6efb3541af61 | 454 | } else if (pos == 8) { |
okini3939 | 2:6efb3541af61 | 455 | return _protocol; |
okini3939 | 2:6efb3541af61 | 456 | } else if (pos == 9) { |
okini3939 | 2:6efb3541af61 | 457 | return _option; |
okini3939 | 2:6efb3541af61 | 458 | } else { |
okini3939 | 2:6efb3541af61 | 459 | return getPayload()[pos - IPv4_TRANSMIT_REQUEST_API_LENGTH]; |
okini3939 | 2:6efb3541af61 | 460 | } |
okini3939 | 2:6efb3541af61 | 461 | } |
okini3939 | 2:6efb3541af61 | 462 | |
okini3939 | 2:6efb3541af61 | 463 | uint8_t IPv4TransmitRequest::getFrameDataLength() { |
okini3939 | 2:6efb3541af61 | 464 | return IPv4_TRANSMIT_REQUEST_API_LENGTH + getPayloadLength(); |
okini3939 | 2:6efb3541af61 | 465 | } |
okini3939 | 2:6efb3541af61 | 466 | |
okini3939 | 2:6efb3541af61 | 467 | IpAddr& IPv4TransmitRequest::getAddress() { |
okini3939 | 2:6efb3541af61 | 468 | return _dstAddr; |
okini3939 | 2:6efb3541af61 | 469 | } |
okini3939 | 2:6efb3541af61 | 470 | |
okini3939 | 2:6efb3541af61 | 471 | uint16_t IPv4TransmitRequest::getDstPort() { |
okini3939 | 2:6efb3541af61 | 472 | return _dstPort; |
okini3939 | 2:6efb3541af61 | 473 | } |
okini3939 | 2:6efb3541af61 | 474 | |
okini3939 | 2:6efb3541af61 | 475 | uint16_t IPv4TransmitRequest::getSrcPort() { |
okini3939 | 2:6efb3541af61 | 476 | return _srcPort; |
okini3939 | 2:6efb3541af61 | 477 | } |
okini3939 | 2:6efb3541af61 | 478 | |
okini3939 | 2:6efb3541af61 | 479 | uint8_t IPv4TransmitRequest::getProtocol() { |
okini3939 | 2:6efb3541af61 | 480 | return _protocol; |
okini3939 | 2:6efb3541af61 | 481 | } |
okini3939 | 2:6efb3541af61 | 482 | |
okini3939 | 2:6efb3541af61 | 483 | uint8_t IPv4TransmitRequest::getOption() { |
okini3939 | 2:6efb3541af61 | 484 | return _option; |
okini3939 | 2:6efb3541af61 | 485 | } |
okini3939 | 2:6efb3541af61 | 486 | |
okini3939 | 2:6efb3541af61 | 487 | void IPv4TransmitRequest::setAddress(IpAddr &dstAddr) { |
okini3939 | 2:6efb3541af61 | 488 | _dstAddr = dstAddr; |
okini3939 | 2:6efb3541af61 | 489 | } |
okini3939 | 2:6efb3541af61 | 490 | |
okini3939 | 2:6efb3541af61 | 491 | void IPv4TransmitRequest::setDstPort(uint16_t dstPort) { |
okini3939 | 2:6efb3541af61 | 492 | _dstPort = dstPort; |
okini3939 | 2:6efb3541af61 | 493 | } |
okini3939 | 2:6efb3541af61 | 494 | |
okini3939 | 2:6efb3541af61 | 495 | void IPv4TransmitRequest::setSrcPort(uint16_t srcPort) { |
okini3939 | 2:6efb3541af61 | 496 | _srcPort = srcPort; |
okini3939 | 2:6efb3541af61 | 497 | } |
okini3939 | 2:6efb3541af61 | 498 | |
okini3939 | 2:6efb3541af61 | 499 | void IPv4TransmitRequest::setProtocol(uint8_t protocol) { |
okini3939 | 2:6efb3541af61 | 500 | _protocol = protocol; |
okini3939 | 2:6efb3541af61 | 501 | } |
okini3939 | 2:6efb3541af61 | 502 | |
okini3939 | 2:6efb3541af61 | 503 | void IPv4TransmitRequest::setOption(uint8_t option) { |
okini3939 | 2:6efb3541af61 | 504 | _option = option; |
okini3939 | 2:6efb3541af61 | 505 | } |
okini3939 | 2:6efb3541af61 | 506 | |
okini3939 | 2:6efb3541af61 | 507 | |
okini3939 | 2:6efb3541af61 | 508 | Transmit_Status::Transmit_Status() : FrameIdResponse() { |
okini3939 | 2:6efb3541af61 | 509 | |
okini3939 | 2:6efb3541af61 | 510 | } |
okini3939 | 2:6efb3541af61 | 511 | |
okini3939 | 2:6efb3541af61 | 512 | uint8_t Transmit_Status::getStatus() { |
okini3939 | 2:6efb3541af61 | 513 | return getFrameData()[1]; |
okini3939 | 2:6efb3541af61 | 514 | } |
okini3939 | 2:6efb3541af61 | 515 | |
okini3939 | 2:6efb3541af61 | 516 | bool Transmit_Status::isSuccess() { |
okini3939 | 2:6efb3541af61 | 517 | return getStatus() == SUCCESS; |
okini3939 | 2:6efb3541af61 | 518 | } |
okini3939 | 2:6efb3541af61 | 519 | |
okini3939 | 2:6efb3541af61 | 520 | |
okini3939 | 2:6efb3541af61 | 521 | IpAddr& IPV4RxFrame::getSrcAddress() { |
okini3939 | 2:6efb3541af61 | 522 | _srcAddr = IpAddr(getFrameData()[4], getFrameData()[5], getFrameData()[6], getFrameData()[7]); |
okini3939 | 2:6efb3541af61 | 523 | return _srcAddr; |
okini3939 | 2:6efb3541af61 | 524 | } |
okini3939 | 2:6efb3541af61 | 525 | |
okini3939 | 2:6efb3541af61 | 526 | uint16_t IPV4RxFrame::getDstPort() { |
okini3939 | 2:6efb3541af61 | 527 | return (getFrameData()[8] << 8) + getFrameData()[9]; |
okini3939 | 2:6efb3541af61 | 528 | } |
okini3939 | 2:6efb3541af61 | 529 | |
okini3939 | 2:6efb3541af61 | 530 | uint16_t IPV4RxFrame::getSrcPort() { |
okini3939 | 2:6efb3541af61 | 531 | return (getFrameData()[10] << 8) + getFrameData()[11]; |
okini3939 | 2:6efb3541af61 | 532 | } |
okini3939 | 2:6efb3541af61 | 533 | |
okini3939 | 2:6efb3541af61 | 534 | uint8_t IPV4RxFrame::getProtocol() { |
okini3939 | 2:6efb3541af61 | 535 | return getFrameData()[12]; |
okini3939 | 2:6efb3541af61 | 536 | } |
okini3939 | 2:6efb3541af61 | 537 | |
okini3939 | 2:6efb3541af61 | 538 | uint8_t IPV4RxFrame::getStatus() { |
okini3939 | 2:6efb3541af61 | 539 | return getFrameData()[13]; |
okini3939 | 2:6efb3541af61 | 540 | } |
okini3939 | 2:6efb3541af61 | 541 | |
okini3939 | 2:6efb3541af61 | 542 | // markers to read data from packet array. this is the index, so the 12th item in the array |
okini3939 | 2:6efb3541af61 | 543 | uint8_t IPV4RxFrame::getDataOffset() { |
okini3939 | 2:6efb3541af61 | 544 | return 14; |
okini3939 | 2:6efb3541af61 | 545 | } |
okini3939 | 2:6efb3541af61 | 546 | |
okini3939 | 2:6efb3541af61 | 547 | uint8_t IPV4RxFrame::getDataLength() { |
okini3939 | 2:6efb3541af61 | 548 | return getPacketLength() - getDataOffset() - 1; |
okini3939 | 2:6efb3541af61 | 549 | } |