Steve Sims / X_NUCLEO_IDW01M1_AP

Extending the X_NUCLEO_IDW01M1 to allow configuration of the board as an access point

Dependents:   X_NUCLEO_IDW01M1_AP_Test

Fork of X_NUCLEO_IDW01M1 by ST

SPWFInterface.cpp@22:a1276b7d3b2d, 2016-07-07 (annotated)

Committer:
scsims
Date:
Thu Jul 07 13:54:06 2016 +0000
Revision:
22:a1276b7d3b2d
Parent:
19:9ab60b80872e 
Added wifi_connected_to_ap extern to indicate when BSSS beacons have been lost/picked up. Also added some debugging to get a better idea as to what's going to and from the SPWF01SA.11 over the UART

Who changed what in which revision?

UserRevisionLine numberNew contents of line
mridup 17:2c47c2aab4a4 1 /* mbed Microcontroller Library
mridup 17:2c47c2aab4a4 2 * Copyright (c) 20015 ARM Limited
mridup 17:2c47c2aab4a4 3 *
mridup 17:2c47c2aab4a4 4 * Licensed under the Apache License, Version 2.0 (the "License");
mridup 17:2c47c2aab4a4 5 * you may not use this file except in compliance with the License.
mridup 17:2c47c2aab4a4 6 * You may obtain a copy of the License at
mridup 17:2c47c2aab4a4 7 *
mridup 17:2c47c2aab4a4 8 * http://www.apache.org/licenses/LICENSE-2.0
mridup 17:2c47c2aab4a4 9 *
mridup 17:2c47c2aab4a4 10 * Unless required by applicable law or agreed to in writing, software
mridup 17:2c47c2aab4a4 11 * distributed under the License is distributed on an "AS IS" BASIS,
mridup 17:2c47c2aab4a4 12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
mridup 17:2c47c2aab4a4 13 * See the License for the specific language governing permissions and
mridup 17:2c47c2aab4a4 14 * limitations under the License.
mridup 17:2c47c2aab4a4 15 */
mridup 0:dc55f40eb04f 16
mridup 13:cdcc13d78252 17 /**
mridup 13:cdcc13d78252 18 ******************************************************************************
mridup 13:cdcc13d78252 19 * @file SpwfInterface.cpp
mridup 13:cdcc13d78252 20 * @author STMicroelectronics
mridup 13:cdcc13d78252 21 * @brief Implementation of the NetworkStack for the SPWF Device
mridup 13:cdcc13d78252 22 ******************************************************************************
mridup 13:cdcc13d78252 23 * @copy
mridup 13:cdcc13d78252 24 *
mridup 13:cdcc13d78252 25 * THE PRESENT FIRMWARE WHICH IS FOR GUIDANCE ONLY AIMS AT PROVIDING CUSTOMERS
mridup 13:cdcc13d78252 26 * WITH CODING INFORMATION REGARDING THEIR PRODUCTS IN ORDER FOR THEM TO SAVE
mridup 13:cdcc13d78252 27 * TIME. AS A RESULT, STMICROELECTRONICS SHALL NOT BE HELD LIABLE FOR ANY
mridup 13:cdcc13d78252 28 * DIRECT, INDIRECT OR CONSEQUENTIAL DAMAGES WITH RESPECT TO ANY CLAIMS ARISING
mridup 13:cdcc13d78252 29 * FROM THE CONTENT OF SUCH FIRMWARE AND/OR THE USE MADE BY CUSTOMERS OF THE
mridup 13:cdcc13d78252 30 * CODING INFORMATION CONTAINED HEREIN IN CONNECTION WITH THEIR PRODUCTS.
mridup 13:cdcc13d78252 31 *
mridup 13:cdcc13d78252 32 * <h2><center>&copy; COPYRIGHT 2016 STMicroelectronics</center></h2>
mridup 13:cdcc13d78252 33 ******************************************************************************
mridup 13:cdcc13d78252 34 */
mridup 13:cdcc13d78252 35
mridup 0:dc55f40eb04f 36 #include "SPWFInterface.h"
mridup 0:dc55f40eb04f 37
mridup 0:dc55f40eb04f 38 // Various timeouts for different SPWF operations
mridup 0:dc55f40eb04f 39 #define SPWF_CONNECT_TIMEOUT 20000
mridup 0:dc55f40eb04f 40 #define SPWF_SEND_TIMEOUT 500
mridup 7:0fdd186a7d90 41 #define SPWF_RECV_TIMEOUT 1000
mridup 0:dc55f40eb04f 42 #define SPWF_MISC_TIMEOUT 15000
mridup 5:c83ffd44f40a 43
mridup 16:156be7b55904 44 /** spwf_socket class
mridup 16:156be7b55904 45 * Implementation of SPWF socket structure
mridup 16:156be7b55904 46 */
mridup 5:c83ffd44f40a 47 struct spwf_socket {
mridup 5:c83ffd44f40a 48 int id;
mridup 6:e7a3fca2df10 49 int server_port;
mridup 5:c83ffd44f40a 50 nsapi_protocol_t proto;
mridup 5:c83ffd44f40a 51 bool connected;
mridup 5:c83ffd44f40a 52 };
mridup 0:dc55f40eb04f 53
mridup 11:67a8c3499caf 54
mridup 11:67a8c3499caf 55 /**
mridup 11:67a8c3499caf 56 * @brief SpwfSAInterface constructor
mridup 11:67a8c3499caf 57 * @param tx: Pin USART TX
mridup 11:67a8c3499caf 58 * rx: Pin USART RX
mridup 11:67a8c3499caf 59 * rst: reset pin for Spwf module
mridup 11:67a8c3499caf 60 * wkup: reset pin for Spwf module
mridup 11:67a8c3499caf 61 * rts: Pin USART RTS
mridup 11:67a8c3499caf 62 * debug : not used
mridup 11:67a8c3499caf 63 * @retval none
mridup 11:67a8c3499caf 64 */
mridup 0:dc55f40eb04f 65 SpwfSAInterface::SpwfSAInterface(PinName tx, PinName rx, PinName rst, PinName wkup, PinName rts, bool debug)
mridup 0:dc55f40eb04f 66 : _spwf(tx, rx, rst, wkup, rts)
mridup 0:dc55f40eb04f 67 {
mridup 0:dc55f40eb04f 68 memset(_ids, 0, sizeof(_ids));
mridup 3:fd9d20c4d3f0 69 isInitialized = false;
mridup 6:e7a3fca2df10 70 isListening = false;
mridup 0:dc55f40eb04f 71 }
mridup 12:3799f8475c8a 72
mridup 12:3799f8475c8a 73 /**
mridup 12:3799f8475c8a 74 * @brief SpwfSAInterface destructor
mridup 12:3799f8475c8a 75 * @param none
mridup 12:3799f8475c8a 76 * @retval none
mridup 12:3799f8475c8a 77 */
mridup 0:dc55f40eb04f 78 SpwfSAInterface::~SpwfSAInterface()
mridup 0:dc55f40eb04f 79 {
mridup 0:dc55f40eb04f 80 }
mridup 0:dc55f40eb04f 81
mridup 12:3799f8475c8a 82 /**
mridup 12:3799f8475c8a 83 * @brief init function
mridup 12:3799f8475c8a 84 initializes SPWF FW and module
mridup 12:3799f8475c8a 85 * @param none
mridup 12:3799f8475c8a 86 * @retval error value
mridup 12:3799f8475c8a 87 */
mridup 5:c83ffd44f40a 88 int SpwfSAInterface::init(void)
mridup 0:dc55f40eb04f 89 {
mridup 0:dc55f40eb04f 90 _spwf.setTimeout(SPWF_MISC_TIMEOUT);
scsims 22:a1276b7d3b2d 91 int result = _spwf.init();
scsims 22:a1276b7d3b2d 92 return result;
mridup 0:dc55f40eb04f 93 }
mridup 0:dc55f40eb04f 94
scsims 18:b265b3b696f1 95 /**
scsims 18:b265b3b696f1 96 * @brief Setup as an access point
scsims 18:b265b3b696f1 97 * @param ap: SSID to set the access point up with (1-32 characters)
scsims 18:b265b3b696f1 98 * @param pass_phrase: Password/key of the access point to set up (currently only Open AP is supported, this param is ignored)
scsims 18:b265b3b696f1 99 * @param security: type of NSAPI security supported (currently only Open AP is supported)
scsims 18:b265b3b696f1 100 * @param channelNum: Channel for the AP to operate on 1-14 (depending on region)
scsims 18:b265b3b696f1 101 * @retval NSAPI Error Type
scsims 18:b265b3b696f1 102 */
scsims 18:b265b3b696f1 103 int SpwfSAInterface::start_access_point(
scsims 18:b265b3b696f1 104 const char *ap,
scsims 18:b265b3b696f1 105 const char *pass_phrase,
scsims 18:b265b3b696f1 106 nsapi_security_t security,
scsims 18:b265b3b696f1 107 int channel_num,
scsims 18:b265b3b696f1 108 unsigned int data_rates)
scsims 18:b265b3b696f1 109 {
scsims 18:b265b3b696f1 110 WiFi_Priv_Mode mode = convert_security(security);
scsims 18:b265b3b696f1 111
scsims 18:b265b3b696f1 112 // Check for valid channel_num
scsims 18:b265b3b696f1 113 if (channel_num < 1 || channel_num > 14)
scsims 18:b265b3b696f1 114 {
scsims 19:9ab60b80872e 115 #if DEBUG_PRINT
scsims 18:b265b3b696f1 116 printf("channel_num must be between 1 and 14\n");
scsims 19:9ab60b80872e 117 #endif
scsims 18:b265b3b696f1 118 return NSAPI_ERROR_PARAMETER;
scsims 18:b265b3b696f1 119 }
scsims 18:b265b3b696f1 120
scsims 18:b265b3b696f1 121 // Verify that the access point is between 1-32
scsims 18:b265b3b696f1 122 if ((NULL == ap && mode != None) || strlen(ap) < 1 || strlen(ap) > 32)
scsims 18:b265b3b696f1 123 {
scsims 19:9ab60b80872e 124 #if DEBUG_PRINT
scsims 18:b265b3b696f1 125 printf("ap length must be between 1 and 32\n");
scsims 19:9ab60b80872e 126 #endif
scsims 18:b265b3b696f1 127 return NSAPI_ERROR_PARAMETER;
scsims 18:b265b3b696f1 128 }
scsims 18:b265b3b696f1 129
scsims 18:b265b3b696f1 130 //initialize the device before starting the AP
scsims 18:b265b3b696f1 131 if(!isInitialized)
scsims 18:b265b3b696f1 132 {
scsims 18:b265b3b696f1 133 if(init()==0)
scsims 18:b265b3b696f1 134 isInitialized=true;
scsims 18:b265b3b696f1 135 else return NSAPI_ERROR_DEVICE_ERROR;
scsims 18:b265b3b696f1 136 }
scsims 18:b265b3b696f1 137
scsims 18:b265b3b696f1 138 _spwf.setTimeout(SPWF_CONNECT_TIMEOUT);
scsims 18:b265b3b696f1 139
scsims 18:b265b3b696f1 140 switch (mode)
scsims 18:b265b3b696f1 141 {
scsims 18:b265b3b696f1 142 // case WEP:
scsims 18:b265b3b696f1 143 // {
scsims 18:b265b3b696f1 144 // break;
scsims 18:b265b3b696f1 145 // }
scsims 18:b265b3b696f1 146 // case WPA_Personal:
scsims 18:b265b3b696f1 147 // {
scsims 18:b265b3b696f1 148 // break;
scsims 18:b265b3b696f1 149 // }
scsims 18:b265b3b696f1 150 default:
scsims 18:b265b3b696f1 151 {
scsims 19:9ab60b80872e 152 #if DEBUG_PRINT
scsims 18:b265b3b696f1 153 printf("Assuming open wifi access point\n");
scsims 19:9ab60b80872e 154 #endif
scsims 18:b265b3b696f1 155 mode = None;
scsims 18:b265b3b696f1 156 pass_phrase = NULL;
scsims 18:b265b3b696f1 157 }
scsims 18:b265b3b696f1 158 }
scsims 18:b265b3b696f1 159 return (_spwf.start_access_point((char*)ap, (char*)pass_phrase, mode, channel_num, data_rates));
scsims 18:b265b3b696f1 160 }
scsims 18:b265b3b696f1 161
scsims 18:b265b3b696f1 162 WiFi_Priv_Mode SpwfSAInterface::convert_security(int security)
scsims 18:b265b3b696f1 163 {
scsims 18:b265b3b696f1 164 switch(security)
scsims 18:b265b3b696f1 165 {
scsims 18:b265b3b696f1 166 case NSAPI_SECURITY_NONE:
scsims 18:b265b3b696f1 167 return (WiFi_Priv_Mode) None;
scsims 18:b265b3b696f1 168 case NSAPI_SECURITY_WEP:
scsims 18:b265b3b696f1 169 return (WiFi_Priv_Mode) WEP;
scsims 18:b265b3b696f1 170 case NSAPI_SECURITY_WPA:
scsims 18:b265b3b696f1 171 case NSAPI_SECURITY_WPA2:
scsims 18:b265b3b696f1 172 return (WiFi_Priv_Mode) WPA_Personal;
scsims 18:b265b3b696f1 173 default:
scsims 18:b265b3b696f1 174 return (WiFi_Priv_Mode) WPA_Personal;
scsims 18:b265b3b696f1 175 }
scsims 18:b265b3b696f1 176 }
scsims 18:b265b3b696f1 177
mridup 12:3799f8475c8a 178 /**
mridup 12:3799f8475c8a 179 * @brief network connect
mridup 12:3799f8475c8a 180 connects to Access Point
mridup 12:3799f8475c8a 181 * @param ap: Access Point (AP) Name String
mridup 12:3799f8475c8a 182 * pass_phrase: Password String for AP
mridup 12:3799f8475c8a 183 * security: type of NSAPI security supported
mridup 12:3799f8475c8a 184 * @retval NSAPI Error Type
mridup 12:3799f8475c8a 185 */
mridup 5:c83ffd44f40a 186 int SpwfSAInterface::connect(
mridup 0:dc55f40eb04f 187 const char *ap,
mridup 0:dc55f40eb04f 188 const char *pass_phrase,
mridup 5:c83ffd44f40a 189 nsapi_security_t security)
mridup 0:dc55f40eb04f 190 {
mridup 15:225d5d3c4f84 191 WiFi_Priv_Mode mode;
mridup 15:225d5d3c4f84 192
mridup 3:fd9d20c4d3f0 193 //initialize the device before connecting
mridup 3:fd9d20c4d3f0 194 if(!isInitialized)
mridup 3:fd9d20c4d3f0 195 {
mridup 3:fd9d20c4d3f0 196 if(init()==0)
mridup 3:fd9d20c4d3f0 197 isInitialized=true;
mridup 5:c83ffd44f40a 198 else return NSAPI_ERROR_DEVICE_ERROR;
mridup 3:fd9d20c4d3f0 199 }
mridup 3:fd9d20c4d3f0 200
mridup 15:225d5d3c4f84 201 _spwf.setTimeout(SPWF_CONNECT_TIMEOUT);
scsims 18:b265b3b696f1 202
scsims 18:b265b3b696f1 203 mode = convert_security(security);
scsims 18:b265b3b696f1 204 if ((WiFi_Priv_Mode) None == mode)
mridup 15:225d5d3c4f84 205 {
scsims 18:b265b3b696f1 206 pass_phrase = NULL;
mridup 15:225d5d3c4f84 207 }
mridup 0:dc55f40eb04f 208
mridup 12:3799f8475c8a 209 return (_spwf.connect((char*)ap, (char*)pass_phrase, mode));
mridup 0:dc55f40eb04f 210 }
mridup 12:3799f8475c8a 211
mridup 12:3799f8475c8a 212 /**
mridup 12:3799f8475c8a 213 * @brief network disconnect
mridup 12:3799f8475c8a 214 disconnects from Access Point
mridup 12:3799f8475c8a 215 * @param none
mridup 12:3799f8475c8a 216 * @retval NSAPI Error Type
mridup 12:3799f8475c8a 217 */
mridup 5:c83ffd44f40a 218 int SpwfSAInterface::disconnect()
mridup 5:c83ffd44f40a 219 {
mridup 0:dc55f40eb04f 220 return (_spwf.disconnect());
mridup 0:dc55f40eb04f 221 }
mridup 12:3799f8475c8a 222
mridup 12:3799f8475c8a 223 /**
mridup 12:3799f8475c8a 224 * @brief Get the local IP address
mridup 12:3799f8475c8a 225 * @param none
mridup 12:3799f8475c8a 226 * @retval Null-terminated representation of the local IP address
mridup 12:3799f8475c8a 227 * or null if not yet connected
mridup 12:3799f8475c8a 228 */
mridup 5:c83ffd44f40a 229 const char *SpwfSAInterface::get_ip_address()
mridup 0:dc55f40eb04f 230 {
mridup 0:dc55f40eb04f 231 return _spwf.getIPAddress();
mridup 0:dc55f40eb04f 232 }
mridup 12:3799f8475c8a 233
mridup 12:3799f8475c8a 234 /**
mridup 12:3799f8475c8a 235 * @brief Get the MAC address
mridup 12:3799f8475c8a 236 * @param none
mridup 12:3799f8475c8a 237 * @retval Null-terminated representation of the MAC address
mridup 12:3799f8475c8a 238 * or null if not yet connected
mridup 12:3799f8475c8a 239 */
mridup 5:c83ffd44f40a 240 const char *SpwfSAInterface::get_mac_address()
mridup 0:dc55f40eb04f 241 {
mridup 0:dc55f40eb04f 242 return _spwf.getMACAddress();
mridup 0:dc55f40eb04f 243 }
mridup 0:dc55f40eb04f 244
mridup 12:3799f8475c8a 245 /**
mridup 12:3799f8475c8a 246 * @brief open a socket handle
mridup 12:3799f8475c8a 247 * @param handle: Pointer to handle
mridup 12:3799f8475c8a 248 * proto: TCP/UDP protocol
mridup 12:3799f8475c8a 249 * @retval NSAPI Error Type
mridup 12:3799f8475c8a 250 */
mridup 5:c83ffd44f40a 251 int SpwfSAInterface::socket_open(void **handle, nsapi_protocol_t proto)
mridup 0:dc55f40eb04f 252 {
mridup 5:c83ffd44f40a 253 int id = -1;
mridup 5:c83ffd44f40a 254
mridup 5:c83ffd44f40a 255 struct spwf_socket *socket = new struct spwf_socket;
mridup 5:c83ffd44f40a 256 if (!socket) {
mridup 5:c83ffd44f40a 257 return NSAPI_ERROR_NO_SOCKET;
mridup 5:c83ffd44f40a 258 }
mridup 5:c83ffd44f40a 259
mridup 5:c83ffd44f40a 260 socket->id = id;
mridup 6:e7a3fca2df10 261 socket->server_port = id;
mridup 5:c83ffd44f40a 262 socket->proto = proto;
mridup 5:c83ffd44f40a 263 socket->connected = false;
mridup 5:c83ffd44f40a 264 *handle = socket;
mridup 5:c83ffd44f40a 265 return 0;
mridup 0:dc55f40eb04f 266 }
mridup 5:c83ffd44f40a 267
mridup 12:3799f8475c8a 268 /**
mridup 12:3799f8475c8a 269 * @brief connect to a remote socket
mridup 12:3799f8475c8a 270 * @param handle: Pointer to socket handle
mridup 12:3799f8475c8a 271 * addr: Address to connect to
mridup 12:3799f8475c8a 272 * @retval NSAPI Error Type
mridup 12:3799f8475c8a 273 */
mridup 5:c83ffd44f40a 274 int SpwfSAInterface::socket_connect(void *handle, const SocketAddress &addr)
mridup 5:c83ffd44f40a 275 {
mridup 6:e7a3fca2df10 276 uint8_t sock_id = 99;
mridup 5:c83ffd44f40a 277 struct spwf_socket *socket = (struct spwf_socket *)handle;
mridup 5:c83ffd44f40a 278
mridup 5:c83ffd44f40a 279 const char *proto = (socket->proto == NSAPI_UDP) ? "u" : "t";//"s" for secure socket?
mridup 0:dc55f40eb04f 280
mridup 5:c83ffd44f40a 281 _spwf.socket_client_open((uint8_t*)addr.get_ip_address(), (uint32_t)addr.get_port(), (uint8_t *)proto, &sock_id);//sock ID is allocated NOW
mridup 0:dc55f40eb04f 282
mridup 0:dc55f40eb04f 283 //TODO: Maintain a socket table to map socket ID to host & port
mridup 0:dc55f40eb04f 284 //TODO: lookup on client table to see if already socket is allocated to same host/port
mridup 0:dc55f40eb04f 285 //multimap <char *, vector <uint16_t> > ::iterator i = c_table.find((char*)ip);
mridup 0:dc55f40eb04f 286
mridup 0:dc55f40eb04f 287 if(sock_id <= SPWFSA_SOCKET_COUNT)
mridup 0:dc55f40eb04f 288 {
mridup 5:c83ffd44f40a 289 socket->id = sock_id;//the socket ID of this Socket instance
mridup 5:c83ffd44f40a 290 _ids[socket->id] = true;
mridup 5:c83ffd44f40a 291 socket->connected = true;
mridup 0:dc55f40eb04f 292 }
mridup 0:dc55f40eb04f 293 else
mridup 5:c83ffd44f40a 294 return NSAPI_ERROR_NO_SOCKET;
mridup 0:dc55f40eb04f 295
mridup 12:3799f8475c8a 296 return 0;
mridup 0:dc55f40eb04f 297 }
mridup 5:c83ffd44f40a 298
mridup 12:3799f8475c8a 299 /**
mridup 12:3799f8475c8a 300 * @brief bind to a port number and address
mridup 12:3799f8475c8a 301 * @param handle: Pointer to socket handle
mridup 12:3799f8475c8a 302 * proto: address to bind to
mridup 12:3799f8475c8a 303 * @retval NSAPI Error Type
mridup 12:3799f8475c8a 304 */
mridup 5:c83ffd44f40a 305 int SpwfSAInterface::socket_bind(void *handle, const SocketAddress &address)
mridup 5:c83ffd44f40a 306 {
mridup 7:0fdd186a7d90 307 struct spwf_socket *socket = (struct spwf_socket *)handle;
mridup 6:e7a3fca2df10 308 socket->server_port = address.get_port();
mridup 6:e7a3fca2df10 309 return 0;
mridup 5:c83ffd44f40a 310 }
mridup 5:c83ffd44f40a 311
mridup 12:3799f8475c8a 312 /**
mridup 12:3799f8475c8a 313 * @brief start listening on a port and address
mridup 12:3799f8475c8a 314 * @param handle: Pointer to handle
mridup 12:3799f8475c8a 315 * backlog: not used (always value is 1)
mridup 12:3799f8475c8a 316 * @retval NSAPI Error Type
mridup 12:3799f8475c8a 317 */
mridup 5:c83ffd44f40a 318 int SpwfSAInterface::socket_listen(void *handle, int backlog)
mridup 0:dc55f40eb04f 319 {
mridup 6:e7a3fca2df10 320 struct spwf_socket *socket = (struct spwf_socket *)handle;
mridup 6:e7a3fca2df10 321 int err;
mridup 6:e7a3fca2df10 322
mridup 6:e7a3fca2df10 323 if(socket->server_port==-1 || isListening)
mridup 6:e7a3fca2df10 324 return NSAPI_ERROR_NO_SOCKET; //server socket not bound or already listening
mridup 6:e7a3fca2df10 325
mridup 6:e7a3fca2df10 326 const char *proto = (socket->proto == NSAPI_UDP) ? "u" : "t";
mridup 6:e7a3fca2df10 327
mridup 6:e7a3fca2df10 328 err = _spwf.socket_server_open((uint32_t)socket->server_port, (uint8_t *)proto);
mridup 6:e7a3fca2df10 329 if(err==0)
mridup 6:e7a3fca2df10 330 {
mridup 7:0fdd186a7d90 331 socket->id = SERVER_SOCKET_NO;//Special socket ID number for Server Socket
mridup 6:e7a3fca2df10 332 isListening = true;
mridup 6:e7a3fca2df10 333 }
mridup 6:e7a3fca2df10 334 else
mridup 6:e7a3fca2df10 335 return NSAPI_ERROR_DEVICE_ERROR;
mridup 6:e7a3fca2df10 336
mridup 6:e7a3fca2df10 337 return err;
mridup 5:c83ffd44f40a 338 }
mridup 5:c83ffd44f40a 339
mridup 12:3799f8475c8a 340 /**
mridup 12:3799f8475c8a 341 * @brief accept connections from remote sockets
mridup 12:3799f8475c8a 342 * @param handle: Pointer to handle of client socket (connecting)
mridup 12:3799f8475c8a 343 * proto: handle of server socket which will accept connections
mridup 12:3799f8475c8a 344 * @retval NSAPI Error Type
mridup 12:3799f8475c8a 345 */
mridup 5:c83ffd44f40a 346 int SpwfSAInterface::socket_accept(void **handle, void *server)
mridup 5:c83ffd44f40a 347 {
mridup 6:e7a3fca2df10 348 struct spwf_socket *server_socket = (struct spwf_socket *)server;
mridup 6:e7a3fca2df10 349
mridup 6:e7a3fca2df10 350 if(server_socket->server_port==-1 || !isListening)
mridup 6:e7a3fca2df10 351 return NSAPI_ERROR_NO_SOCKET; //server socket not bound or not listening
mridup 6:e7a3fca2df10 352
mridup 7:0fdd186a7d90 353 if(_spwf.get_wait_for_incoming_client())
mridup 7:0fdd186a7d90 354 {
mridup 7:0fdd186a7d90 355 server_socket->connected = true;
mridup 7:0fdd186a7d90 356 struct spwf_socket *socket = new struct spwf_socket;//create new network socket
mridup 7:0fdd186a7d90 357 if (!socket) {
mridup 7:0fdd186a7d90 358 return NSAPI_ERROR_NO_SOCKET;
mridup 7:0fdd186a7d90 359 }
mridup 7:0fdd186a7d90 360
mridup 7:0fdd186a7d90 361 memset(socket, 0, sizeof (struct spwf_socket));
mridup 11:67a8c3499caf 362
mridup 7:0fdd186a7d90 363 socket->id = server_socket->id;
mridup 7:0fdd186a7d90 364 socket->server_port = server_socket->server_port;
mridup 7:0fdd186a7d90 365 socket->proto = server_socket->proto;
mridup 7:0fdd186a7d90 366 socket->connected = true;
mridup 7:0fdd186a7d90 367
mridup 7:0fdd186a7d90 368 *handle = socket;
mridup 7:0fdd186a7d90 369 socket = 0;
mridup 12:3799f8475c8a 370 _spwf.set_wait_for_incoming_client(false);
mridup 7:0fdd186a7d90 371 wait_ms(50);//CHECK:TODO:Why do we need this?
mridup 7:0fdd186a7d90 372 return 0;
mridup 7:0fdd186a7d90 373 }
mridup 7:0fdd186a7d90 374 return NSAPI_ERROR_WOULD_BLOCK;
mridup 5:c83ffd44f40a 375 }
mridup 5:c83ffd44f40a 376
mridup 12:3799f8475c8a 377 /**
mridup 12:3799f8475c8a 378 * @brief close a socket
mridup 12:3799f8475c8a 379 * @param handle: Pointer to handle
mridup 12:3799f8475c8a 380 * @retval NSAPI Error Type
mridup 12:3799f8475c8a 381 */
mridup 5:c83ffd44f40a 382 int SpwfSAInterface::socket_close(void *handle)
mridup 5:c83ffd44f40a 383 {
mridup 5:c83ffd44f40a 384 struct spwf_socket *socket = (struct spwf_socket *)handle;
mridup 5:c83ffd44f40a 385 int err = 0;
mridup 7:0fdd186a7d90 386 _spwf.setTimeout(SPWF_MISC_TIMEOUT);
mridup 0:dc55f40eb04f 387
mridup 5:c83ffd44f40a 388 if(socket->id!=-1)
mridup 5:c83ffd44f40a 389 {
mridup 6:e7a3fca2df10 390 if(socket->id==SERVER_SOCKET_NO)
mridup 6:e7a3fca2df10 391 {
mridup 6:e7a3fca2df10 392 if (_spwf.socket_server_close()==-1) {
mridup 6:e7a3fca2df10 393 err = NSAPI_ERROR_DEVICE_ERROR;
mridup 6:e7a3fca2df10 394 }
mridup 6:e7a3fca2df10 395 isListening = false;
mridup 5:c83ffd44f40a 396 }
mridup 6:e7a3fca2df10 397 else
mridup 6:e7a3fca2df10 398 {
mridup 6:e7a3fca2df10 399 if (_spwf.socket_client_close(socket->id)==-1) {
mridup 6:e7a3fca2df10 400 err = NSAPI_ERROR_DEVICE_ERROR;
mridup 6:e7a3fca2df10 401 }
mridup 6:e7a3fca2df10 402 _ids[socket->id] = false;
mridup 6:e7a3fca2df10 403 }
mridup 5:c83ffd44f40a 404 }
mridup 5:c83ffd44f40a 405
mridup 5:c83ffd44f40a 406 delete socket;
mridup 0:dc55f40eb04f 407 return err;
mridup 0:dc55f40eb04f 408 }
mridup 5:c83ffd44f40a 409
mridup 12:3799f8475c8a 410 /**
mridup 12:3799f8475c8a 411 * @brief write to a socket
mridup 12:3799f8475c8a 412 * @param handle: Pointer to handle
mridup 12:3799f8475c8a 413 * data: pointer to data
mridup 12:3799f8475c8a 414 * size: size of data
mridup 12:3799f8475c8a 415 * @retval no of bytes sent
mridup 12:3799f8475c8a 416 */
mridup 5:c83ffd44f40a 417 int SpwfSAInterface::socket_send(void *handle, const void *data, unsigned size)
mridup 5:c83ffd44f40a 418 {
mridup 5:c83ffd44f40a 419 struct spwf_socket *socket = (struct spwf_socket *)handle;
mridup 5:c83ffd44f40a 420 int err;
mridup 0:dc55f40eb04f 421
mridup 6:e7a3fca2df10 422 if(socket->id==SERVER_SOCKET_NO)
mridup 6:e7a3fca2df10 423 {
mridup 7:0fdd186a7d90 424 if(socket->server_port==-1 || !isListening)
mridup 7:0fdd186a7d90 425 return NSAPI_ERROR_NO_SOCKET; //server socket not bound or not listening
mridup 7:0fdd186a7d90 426
mridup 6:e7a3fca2df10 427 err = _spwf.socket_server_write((uint16_t)size, (char*)data);
mridup 6:e7a3fca2df10 428 }
mridup 6:e7a3fca2df10 429 else
mridup 6:e7a3fca2df10 430 {
mridup 6:e7a3fca2df10 431 err = _spwf.socket_client_write((uint8_t)socket->id, (uint16_t)size, (char*)data);
mridup 6:e7a3fca2df10 432 }
mridup 0:dc55f40eb04f 433
mridup 0:dc55f40eb04f 434 return err;
mridup 0:dc55f40eb04f 435 }
mridup 0:dc55f40eb04f 436
mridup 12:3799f8475c8a 437 /**
mridup 12:3799f8475c8a 438 * @brief receive data on a socket
mridup 12:3799f8475c8a 439 * @param handle: Pointer to handle
mridup 12:3799f8475c8a 440 * data: pointer to data
mridup 12:3799f8475c8a 441 * size: size of data
mridup 12:3799f8475c8a 442 * @retval no of bytes read
mridup 12:3799f8475c8a 443 */
mridup 5:c83ffd44f40a 444 int SpwfSAInterface::socket_recv(void *handle, void *data, unsigned size)
mridup 0:dc55f40eb04f 445 {
mridup 5:c83ffd44f40a 446 struct spwf_socket *socket = (struct spwf_socket *)handle;
mridup 0:dc55f40eb04f 447 int32_t recv;
mridup 0:dc55f40eb04f 448
mridup 5:c83ffd44f40a 449 _spwf.setTimeout(SPWF_RECV_TIMEOUT);
mridup 0:dc55f40eb04f 450
mridup 6:e7a3fca2df10 451 //CHECK:Receive for both Client and Server Sockets same?
mridup 5:c83ffd44f40a 452 recv = _spwf.socket_client_recv((uint8_t)socket->id, (uint16_t)size, (char*)data);
mridup 5:c83ffd44f40a 453 if (recv < 0) {
mridup 5:c83ffd44f40a 454 return NSAPI_ERROR_WOULD_BLOCK;
mridup 5:c83ffd44f40a 455 }
mridup 0:dc55f40eb04f 456 return recv;
mridup 0:dc55f40eb04f 457
mridup 0:dc55f40eb04f 458 }
mridup 0:dc55f40eb04f 459
mridup 12:3799f8475c8a 460 /**
mridup 12:3799f8475c8a 461 * @brief send data to a udp socket
mridup 12:3799f8475c8a 462 * @param handle: Pointer to handle
mridup 12:3799f8475c8a 463 * addr: address of udp socket
mridup 12:3799f8475c8a 464 * data: pointer to data
mridup 12:3799f8475c8a 465 * size: size of data
mridup 12:3799f8475c8a 466 * @retval no of bytes sent
mridup 12:3799f8475c8a 467 */
mridup 5:c83ffd44f40a 468 int SpwfSAInterface::socket_sendto(void *handle, const SocketAddress &addr, const void *data, unsigned size)
mridup 5:c83ffd44f40a 469 {
mridup 5:c83ffd44f40a 470 struct spwf_socket *socket = (struct spwf_socket *)handle;
mridup 5:c83ffd44f40a 471 if (!socket->connected) {
mridup 5:c83ffd44f40a 472 int err = socket_connect(socket, addr);
mridup 5:c83ffd44f40a 473 if (err < 0) {
mridup 5:c83ffd44f40a 474 return err;
mridup 5:c83ffd44f40a 475 }
mridup 5:c83ffd44f40a 476 }
mridup 5:c83ffd44f40a 477
mridup 5:c83ffd44f40a 478 return socket_send(socket, data, size);
mridup 5:c83ffd44f40a 479 }
mridup 5:c83ffd44f40a 480
mridup 12:3799f8475c8a 481 /**
mridup 12:3799f8475c8a 482 * @brief receive data on a udp socket
mridup 12:3799f8475c8a 483 * @param handle: Pointer to handle
mridup 12:3799f8475c8a 484 * addr: address of udp socket
mridup 12:3799f8475c8a 485 * data: pointer to data
mridup 12:3799f8475c8a 486 * size: size of data
mridup 12:3799f8475c8a 487 * @retval no of bytes read
mridup 12:3799f8475c8a 488 */
mridup 5:c83ffd44f40a 489 int SpwfSAInterface::socket_recvfrom(void *handle, SocketAddress *addr, void *data, unsigned size)
mridup 5:c83ffd44f40a 490 {
mridup 5:c83ffd44f40a 491 struct spwf_socket *socket = (struct spwf_socket *)handle;
mridup 5:c83ffd44f40a 492 return socket_recv(socket, data, size);
mridup 5:c83ffd44f40a 493 }
mridup 5:c83ffd44f40a 494
mridup 12:3799f8475c8a 495 /**
mridup 12:3799f8475c8a 496 * @brief attach function/callback to the socket
mridup 12:3799f8475c8a 497 * Not used
mridup 12:3799f8475c8a 498 * @param handle: Pointer to handle
mridup 12:3799f8475c8a 499 * callback: callback function pointer
mridup 12:3799f8475c8a 500 * data: pointer to data
mridup 12:3799f8475c8a 501 * @retval none
mridup 12:3799f8475c8a 502 */
mridup 5:c83ffd44f40a 503 void SpwfSAInterface::socket_attach(void *handle, void (*callback)(void *), void *data)
mridup 5:c83ffd44f40a 504 {
mridup 5:c83ffd44f40a 505 //No implementation yet
mridup 5:c83ffd44f40a 506 }
mridup 5:c83ffd44f40a 507
mridup 12:3799f8475c8a 508 /**
mridup 12:3799f8475c8a 509 * @brief utility debug function for printing to serial terminal
mridup 12:3799f8475c8a 510 * @param string: Pointer to data
mridup 12:3799f8475c8a 511 * @retval none
mridup 12:3799f8475c8a 512 */
mridup 0:dc55f40eb04f 513 void SpwfSAInterface::debug(const char * string)
mridup 0:dc55f40eb04f 514 {
mridup 0:dc55f40eb04f 515 _spwf.debug_print(string);
mridup 0:dc55f40eb04f 516 }