cliff Hong / WizFi250Interface_170921

123

Fork of WizFi250Interface_1 by cliff Hong

WizFi250/WizFi250_sock.cpp@3:f78b0e66ed67, 2017-09-21 (annotated)

Committer:
cliff1
Date:
Thu Sep 21 01:01:02 2017 +0000
Revision:
3:f78b0e66ed67
Parent:
0:e3dc9e54a15b 
test20170921

Who changed what in which revision?

UserRevisionLine numberNew contents of line
kaizen 0:e3dc9e54a15b 1 /*
kaizen 0:e3dc9e54a15b 2 /* Copyright (C) 2013 gsfan, MIT License
kaizen 0:e3dc9e54a15b 3 *
kaizen 0:e3dc9e54a15b 4 * Permission is hereby granted, free of charge, to any person obtaining a copy of this software
kaizen 0:e3dc9e54a15b 5 * and associated documentation files (the "Software"), to deal in the Software without restriction,
kaizen 0:e3dc9e54a15b 6 * including without limitation the rights to use, copy, modify, merge, publish, distribute,
kaizen 0:e3dc9e54a15b 7 * sublicense, and/or sell copies of the Software, and to permit persons to whom the Software is
kaizen 0:e3dc9e54a15b 8 * furnished to do so, subject to the following conditions:
kaizen 0:e3dc9e54a15b 9 *
kaizen 0:e3dc9e54a15b 10 * The above copyright notice and this permission notice shall be included in all copies or
kaizen 0:e3dc9e54a15b 11 * substantial portions of the Software.
kaizen 0:e3dc9e54a15b 12 *
kaizen 0:e3dc9e54a15b 13 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING
kaizen 0:e3dc9e54a15b 14 * BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
kaizen 0:e3dc9e54a15b 15 * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM,
kaizen 0:e3dc9e54a15b 16 * DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
kaizen 0:e3dc9e54a15b 17 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
kaizen 0:e3dc9e54a15b 18 */
kaizen 0:e3dc9e54a15b 19 /* Copyright (C) 2014 Wiznet, MIT License
kaizen 0:e3dc9e54a15b 20 * port to the Wiznet Module WizFi250
kaizen 0:e3dc9e54a15b 21 */
kaizen 0:e3dc9e54a15b 22
kaizen 0:e3dc9e54a15b 23 #include "WizFi250.h"
kaizen 0:e3dc9e54a15b 24
kaizen 0:e3dc9e54a15b 25
kaizen 0:e3dc9e54a15b 26 int WizFi250::getHostByName(const char * host, char *ip)
kaizen 0:e3dc9e54a15b 27 {
kaizen 0:e3dc9e54a15b 28 int i, flg = 0;
kaizen 0:e3dc9e54a15b 29
kaizen 0:e3dc9e54a15b 30 if(!isAssociated() || _state.status != STAT_READY) return -1;
kaizen 0:e3dc9e54a15b 31
kaizen 0:e3dc9e54a15b 32 for(i=0; i<strlen(host); i++)
kaizen 0:e3dc9e54a15b 33 {
kaizen 0:e3dc9e54a15b 34 if( (host[i] < '0' || host[i] > '9') && host[i] != '.')
kaizen 0:e3dc9e54a15b 35 {
kaizen 0:e3dc9e54a15b 36 flg = 1;
kaizen 0:e3dc9e54a15b 37 break;
kaizen 0:e3dc9e54a15b 38 }
kaizen 0:e3dc9e54a15b 39 }
kaizen 0:e3dc9e54a15b 40 if (!flg)
kaizen 0:e3dc9e54a15b 41 {
kaizen 0:e3dc9e54a15b 42 strncpy(ip, host, 16);
kaizen 0:e3dc9e54a15b 43 return 0;
kaizen 0:e3dc9e54a15b 44 }
kaizen 0:e3dc9e54a15b 45
kaizen 0:e3dc9e54a15b 46 if ( cmdFDNS(host) )
kaizen 0:e3dc9e54a15b 47 {
kaizen 0:e3dc9e54a15b 48 wait_ms(1000);
kaizen 0:e3dc9e54a15b 49 if( cmdFDNS(host) ) return -1;
kaizen 0:e3dc9e54a15b 50 }
kaizen 0:e3dc9e54a15b 51 strncpy(ip, _state.resolv, 16);
kaizen 0:e3dc9e54a15b 52 return 0;
kaizen 0:e3dc9e54a15b 53 }
kaizen 0:e3dc9e54a15b 54
kaizen 0:e3dc9e54a15b 55 int WizFi250::open(Protocol proto, const char *ip, int remotePort, int localPort, void(*func)(int))
kaizen 0:e3dc9e54a15b 56 {
kaizen 0:e3dc9e54a15b 57 int cid;
kaizen 0:e3dc9e54a15b 58
kaizen 0:e3dc9e54a15b 59 if (!isAssociated() || _state.status != STAT_READY) return -1;
kaizen 0:e3dc9e54a15b 60
kaizen 0:e3dc9e54a15b 61 _state.cid = -1;
kaizen 0:e3dc9e54a15b 62
kaizen 0:e3dc9e54a15b 63 if (proto == PROTO_TCP)
kaizen 0:e3dc9e54a15b 64 {
kaizen 0:e3dc9e54a15b 65 if( cmdSCON( "O","TCN",ip, remotePort, localPort, "0" ) ) return -1;
kaizen 0:e3dc9e54a15b 66 }
kaizen 0:e3dc9e54a15b 67 else if(proto == PROTO_UDP)
kaizen 0:e3dc9e54a15b 68 {
kaizen 0:e3dc9e54a15b 69 if( cmdSCON( "O","UCN",ip, remotePort, localPort, "0" ) ) return -1;
kaizen 0:e3dc9e54a15b 70 }
kaizen 0:e3dc9e54a15b 71 if(_state.cid < 0) return -1;
cliff1 3:f78b0e66ed67 72
kaizen 0:e3dc9e54a15b 73
kaizen 0:e3dc9e54a15b 74 initCon(_state.cid, true);
kaizen 0:e3dc9e54a15b 75 cid = _state.cid;
kaizen 0:e3dc9e54a15b 76 _con[cid].protocol = proto;
kaizen 0:e3dc9e54a15b 77 _con[cid].type = TYPE_CLIENT;
kaizen 0:e3dc9e54a15b 78 _con[cid].func = func;
kaizen 0:e3dc9e54a15b 79 return cid;
kaizen 0:e3dc9e54a15b 80 }
kaizen 0:e3dc9e54a15b 81
kaizen 0:e3dc9e54a15b 82 int WizFi250::listen (Protocol proto, int port, void(*func)(int))
kaizen 0:e3dc9e54a15b 83 {
kaizen 0:e3dc9e54a15b 84 int cid;
kaizen 0:e3dc9e54a15b 85
kaizen 0:e3dc9e54a15b 86 if(!isAssociated() || _state.status != STAT_READY) return -1;
kaizen 0:e3dc9e54a15b 87
kaizen 0:e3dc9e54a15b 88 _state.cid = -1;
kaizen 0:e3dc9e54a15b 89
kaizen 0:e3dc9e54a15b 90 if(proto == PROTO_TCP)
kaizen 0:e3dc9e54a15b 91 {
kaizen 0:e3dc9e54a15b 92 if( sendCommand("AT+MEVTMSG=1") ) return -1;
kaizen 0:e3dc9e54a15b 93 if( cmdSCON("O","TSN",port) ) return -1;
kaizen 0:e3dc9e54a15b 94 }
kaizen 0:e3dc9e54a15b 95 else
kaizen 0:e3dc9e54a15b 96 {
kaizen 0:e3dc9e54a15b 97 if( cmdSCON("O","USN",port) ) return -1;
kaizen 0:e3dc9e54a15b 98 }
kaizen 0:e3dc9e54a15b 99
kaizen 0:e3dc9e54a15b 100 if (_state.cid < 0) return -1;
kaizen 0:e3dc9e54a15b 101 cid = _state.cid;
kaizen 0:e3dc9e54a15b 102 _con[cid].protocol = proto;
kaizen 0:e3dc9e54a15b 103 _con[cid].type = TYPE_SERVER;
kaizen 0:e3dc9e54a15b 104 _con[cid].func = func;
kaizen 0:e3dc9e54a15b 105
kaizen 0:e3dc9e54a15b 106 return cid;
kaizen 0:e3dc9e54a15b 107 }
kaizen 0:e3dc9e54a15b 108
kaizen 0:e3dc9e54a15b 109 int WizFi250::close (int cid)
kaizen 0:e3dc9e54a15b 110 {
kaizen 0:e3dc9e54a15b 111 // if(!isConnected(cid)) return -1;
kaizen 0:e3dc9e54a15b 112
kaizen 0:e3dc9e54a15b 113 _con[cid].connected = false;
kaizen 0:e3dc9e54a15b 114 return cmdCLOSE(cid);
kaizen 0:e3dc9e54a15b 115 }
kaizen 0:e3dc9e54a15b 116
kaizen 0:e3dc9e54a15b 117
kaizen 0:e3dc9e54a15b 118 void WizFi250::initCon ( int cid, bool connected )
kaizen 0:e3dc9e54a15b 119 {
kaizen 0:e3dc9e54a15b 120 _con[cid].parent = -1; // It will be delete because It is not need
kaizen 0:e3dc9e54a15b 121 _con[cid].func = NULL;
kaizen 0:e3dc9e54a15b 122 _con[cid].accept = false;
kaizen 0:e3dc9e54a15b 123
kaizen 0:e3dc9e54a15b 124 //#ifndef CFG_ENABLE_RTOS
kaizen 0:e3dc9e54a15b 125 if ( _con[cid].buf == NULL )
kaizen 0:e3dc9e54a15b 126 {
kaizen 0:e3dc9e54a15b 127 _con[cid].buf = new CircBuffer<char>(CFG_DATA_SIZE);
kaizen 0:e3dc9e54a15b 128 if ( _con[cid].buf == NULL ) error("Can't allocate memory");
kaizen 0:e3dc9e54a15b 129 }
kaizen 0:e3dc9e54a15b 130 //#endif
kaizen 0:e3dc9e54a15b 131 if ( _con[cid].buf != NULL )
kaizen 0:e3dc9e54a15b 132 {
kaizen 0:e3dc9e54a15b 133 _con[cid].buf->flush();
kaizen 0:e3dc9e54a15b 134 }
kaizen 0:e3dc9e54a15b 135 _con[cid].connected = connected;
kaizen 0:e3dc9e54a15b 136 }
kaizen 0:e3dc9e54a15b 137
kaizen 0:e3dc9e54a15b 138 int WizFi250::send(int cid, const char *buf, int len)
kaizen 0:e3dc9e54a15b 139 {
kaizen 0:e3dc9e54a15b 140 if(!isConnected(cid)) return -1;
kaizen 0:e3dc9e54a15b 141
kaizen 0:e3dc9e54a15b 142 if((_con[cid].protocol == PROTO_TCP) ||
kaizen 0:e3dc9e54a15b 143 (_con[cid].protocol == PROTO_UDP && _con[cid].type == TYPE_CLIENT) )
kaizen 0:e3dc9e54a15b 144 {
kaizen 0:e3dc9e54a15b 145 // if ( len > CFG_DATA_SIZE) len = CFG_DATA_SIZE;
kaizen 0:e3dc9e54a15b 146 return cmdSSEND(buf,cid,len);
kaizen 0:e3dc9e54a15b 147 }
kaizen 0:e3dc9e54a15b 148 else
kaizen 0:e3dc9e54a15b 149 {
kaizen 0:e3dc9e54a15b 150 return -1;
kaizen 0:e3dc9e54a15b 151 }
kaizen 0:e3dc9e54a15b 152 }
kaizen 0:e3dc9e54a15b 153
kaizen 0:e3dc9e54a15b 154 int WizFi250::sendto (int cid, const char *buf, int len, const char *ip, int port)
kaizen 0:e3dc9e54a15b 155 {
kaizen 0:e3dc9e54a15b 156 if(!isConnected(cid)) return -1;
kaizen 0:e3dc9e54a15b 157
kaizen 0:e3dc9e54a15b 158 if((_con[cid].protocol == PROTO_UDP && _con[cid].type == TYPE_SERVER))
kaizen 0:e3dc9e54a15b 159 {
kaizen 0:e3dc9e54a15b 160 if ( len > CFG_DATA_SIZE ) len = CFG_DATA_SIZE;
kaizen 0:e3dc9e54a15b 161 return cmdSSEND(buf,cid,len,ip,port);
kaizen 0:e3dc9e54a15b 162 }
kaizen 0:e3dc9e54a15b 163 else
kaizen 0:e3dc9e54a15b 164 {
kaizen 0:e3dc9e54a15b 165 return -1;
kaizen 0:e3dc9e54a15b 166 }
kaizen 0:e3dc9e54a15b 167 }
kaizen 0:e3dc9e54a15b 168
kaizen 0:e3dc9e54a15b 169 int WizFi250::recv (int cid, char *buf, int len)
kaizen 0:e3dc9e54a15b 170 {
kaizen 0:e3dc9e54a15b 171 int i;
kaizen 0:e3dc9e54a15b 172
kaizen 0:e3dc9e54a15b 173 if (!isConnected(cid)) return -1;
kaizen 0:e3dc9e54a15b 174
kaizen 0:e3dc9e54a15b 175 if (_con[cid].buf == NULL ) return 0;
kaizen 0:e3dc9e54a15b 176 while (!_con[cid].received && _state.mode != MODE_COMMAND);
kaizen 0:e3dc9e54a15b 177 _con[cid].received = false;
kaizen 0:e3dc9e54a15b 178 for(i=0; i<len; i++)
kaizen 0:e3dc9e54a15b 179 {
kaizen 0:e3dc9e54a15b 180 if(_con[cid].buf->dequeue(&buf[i]) == false) break;
kaizen 0:e3dc9e54a15b 181 }
kaizen 0:e3dc9e54a15b 182 setRts(true); // release
kaizen 0:e3dc9e54a15b 183 return i;
kaizen 0:e3dc9e54a15b 184 }
kaizen 0:e3dc9e54a15b 185
kaizen 0:e3dc9e54a15b 186 int WizFi250::recvfrom (int cid, char *buf, int len, char *ip, int *port)
kaizen 0:e3dc9e54a15b 187 {
kaizen 0:e3dc9e54a15b 188 int i;
kaizen 0:e3dc9e54a15b 189
kaizen 0:e3dc9e54a15b 190 if (!isConnected(cid)) return -1;
kaizen 0:e3dc9e54a15b 191
kaizen 0:e3dc9e54a15b 192 if (_con[cid].buf == NULL) return 0;
kaizen 0:e3dc9e54a15b 193
kaizen 0:e3dc9e54a15b 194 while (!_con[cid].received && _state.mode != MODE_COMMAND);
kaizen 0:e3dc9e54a15b 195
kaizen 0:e3dc9e54a15b 196 _con[cid].received = false;
kaizen 0:e3dc9e54a15b 197 for(i=0; i<len; i++)
kaizen 0:e3dc9e54a15b 198 {
kaizen 0:e3dc9e54a15b 199 if( _con[cid].buf->dequeue(&buf[i]) == false ) break;
kaizen 0:e3dc9e54a15b 200 }
kaizen 0:e3dc9e54a15b 201 //buf[i] = '\0';
kaizen 0:e3dc9e54a15b 202 strncpy(ip, _con[cid].ip, 16);
kaizen 0:e3dc9e54a15b 203 *port = _con[cid].port;
kaizen 0:e3dc9e54a15b 204 setRts(true); // release
kaizen 0:e3dc9e54a15b 205
kaizen 0:e3dc9e54a15b 206 return i;
kaizen 0:e3dc9e54a15b 207 }
kaizen 0:e3dc9e54a15b 208
kaizen 0:e3dc9e54a15b 209 int WizFi250::readable (int cid)
kaizen 0:e3dc9e54a15b 210 {
kaizen 0:e3dc9e54a15b 211 if (!isConnected(cid)) return -1;
kaizen 0:e3dc9e54a15b 212
kaizen 0:e3dc9e54a15b 213 if(_con[cid].buf == NULL) return -1;
kaizen 0:e3dc9e54a15b 214 return _con[cid].buf->available();
kaizen 0:e3dc9e54a15b 215 }
kaizen 0:e3dc9e54a15b 216
kaizen 0:e3dc9e54a15b 217 bool WizFi250::isConnected (int cid)
kaizen 0:e3dc9e54a15b 218 {
kaizen 0:e3dc9e54a15b 219 if ( cid < 0 || cid >=8 ) return false;
kaizen 0:e3dc9e54a15b 220
kaizen 0:e3dc9e54a15b 221 return _con[cid].connected;
kaizen 0:e3dc9e54a15b 222 }
kaizen 0:e3dc9e54a15b 223
kaizen 0:e3dc9e54a15b 224 int WizFi250::accept (int cid)
kaizen 0:e3dc9e54a15b 225 {
kaizen 0:e3dc9e54a15b 226 if(!isConnected(cid)) return -1;
kaizen 0:e3dc9e54a15b 227
kaizen 0:e3dc9e54a15b 228 if(_con[cid].connected && _con[cid].accept)
kaizen 0:e3dc9e54a15b 229 {
kaizen 0:e3dc9e54a15b 230 _con[cid].accept = false;
kaizen 0:e3dc9e54a15b 231 return cid;
kaizen 0:e3dc9e54a15b 232 }
kaizen 0:e3dc9e54a15b 233
kaizen 0:e3dc9e54a15b 234 return -1;
kaizen 0:e3dc9e54a15b 235 }
kaizen 0:e3dc9e54a15b 236
kaizen 0:e3dc9e54a15b 237 int WizFi250::getRemote(int cid, char **ip, int *port)
kaizen 0:e3dc9e54a15b 238 {
kaizen 0:e3dc9e54a15b 239 if (!isConnected(cid)) return -1;
kaizen 0:e3dc9e54a15b 240
kaizen 0:e3dc9e54a15b 241 *ip = _con[cid].ip;
kaizen 0:e3dc9e54a15b 242 *port = _con[cid].port;
kaizen 0:e3dc9e54a15b 243 return 0;
kaizen 0:e3dc9e54a15b 244 }