winwet w7500 / WizFi310Interface_Legacy_newv2789

jhgfd

Fork of WizFi310Interface_Legacy_newv34 by ajeet prajapati

WizFi310/WizFi310_sock.cpp@5:1c1c8d8e07b0, 2017-11-28 (annotated)

Committer:
wiznetw7500
Date:
Tue Nov 28 09:03:26 2017 +0000
Revision:
5:1c1c8d8e07b0
Parent:
2:3194ebe06182 
wefgygf

Who changed what in which revision?

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