socket.c 21 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725
  1. //*****************************************************************************
  2. //
  3. //! \file socket.c
  4. //! \brief SOCKET APIs Implements file.
  5. //! \details SOCKET APIs like as Berkeley Socket APIs.
  6. //! \version 1.0.3
  7. //! \date 2013/10/21
  8. //! \par Revision history
  9. //! <2014/05/01> V1.0.3. Refer to M20140501
  10. //! 1. Implicit type casting -> Explicit type casting.
  11. //! 2. replace 0x01 with PACK_REMAINED in recvfrom()
  12. //! 3. Validation a destination ip in connect() & sendto():
  13. //! It occurs a fatal error on converting unint32 address if uint8* addr parameter is not aligned by 4byte address.
  14. //! Copy 4 byte addr value into temporary uint32 variable and then compares it.
  15. //! <2013/12/20> V1.0.2 Refer to M20131220
  16. //! Remove Warning.
  17. //! <2013/11/04> V1.0.1 2nd Release. Refer to "20131104".
  18. //! In sendto(), Add to clear timeout interrupt status (Sn_IR_TIMEOUT)
  19. //! <2013/10/21> 1st Release
  20. //! \author MidnightCow
  21. //! \copyright
  22. //!
  23. //! Copyright (c) 2013, WIZnet Co., LTD.
  24. //! All rights reserved.
  25. //!
  26. //! Redistribution and use in source and binary forms, with or without
  27. //! modification, are permitted provided that the following conditions
  28. //! are met:
  29. //!
  30. //! * Redistributions of source code must retain the above copyright
  31. //! notice, this list of conditions and the following disclaimer.
  32. //! * Redistributions in binary form must reproduce the above copyright
  33. //! notice, this list of conditions and the following disclaimer in the
  34. //! documentation and/or other materials provided with the distribution.
  35. //! * Neither the name of the <ORGANIZATION> nor the names of its
  36. //! contributors may be used to endorse or promote products derived
  37. //! from this software without specific prior written permission.
  38. //!
  39. //! THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
  40. //! AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
  41. //! IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
  42. //! ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE
  43. //! LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
  44. //! CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
  45. //! SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
  46. //! INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
  47. //! CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
  48. //! ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF
  49. //! THE POSSIBILITY OF SUCH DAMAGE.
  50. //
  51. //*****************************************************************************
  52. #include <string.h>
  53. #include "py/mpthread.h"
  54. #include "socket.h"
  55. #define SOCK_ANY_PORT_NUM 0xC000;
  56. static uint16_t sock_any_port = SOCK_ANY_PORT_NUM;
  57. static uint16_t sock_io_mode = 0;
  58. static uint16_t sock_is_sending = 0;
  59. static uint16_t sock_remained_size[_WIZCHIP_SOCK_NUM_] = {0,0,};
  60. static uint8_t sock_pack_info[_WIZCHIP_SOCK_NUM_] = {0,};
  61. #if _WIZCHIP_ == 5200
  62. static uint16_t sock_next_rd[_WIZCHIP_SOCK_NUM_] ={0,};
  63. #endif
  64. #define CHECK_SOCKNUM() \
  65. do{ \
  66. if(sn > _WIZCHIP_SOCK_NUM_) return SOCKERR_SOCKNUM; \
  67. }while(0); \
  68. #define CHECK_SOCKMODE(mode) \
  69. do{ \
  70. if((getSn_MR(sn) & 0x0F) != mode) return SOCKERR_SOCKMODE; \
  71. }while(0); \
  72. #define CHECK_SOCKINIT() \
  73. do{ \
  74. if((getSn_SR(sn) != SOCK_INIT)) return SOCKERR_SOCKINIT; \
  75. }while(0); \
  76. #define CHECK_SOCKDATA() \
  77. do{ \
  78. if(len == 0) return SOCKERR_DATALEN; \
  79. }while(0); \
  80. void WIZCHIP_EXPORT(socket_reset)(void) {
  81. sock_any_port = SOCK_ANY_PORT_NUM;
  82. sock_io_mode = 0;
  83. sock_is_sending = 0;
  84. /*
  85. memset(sock_remained_size, 0, _WIZCHIP_SOCK_NUM_ * sizeof(uint16_t));
  86. memset(sock_pack_info, 0, _WIZCHIP_SOCK_NUM_ * sizeof(uint8_t));
  87. */
  88. #if _WIZCHIP_ == 5200
  89. memset(sock_next_rd, 0, _WIZCHIP_SOCK_NUM_ * sizeof(uint16_t));
  90. #endif
  91. }
  92. int8_t WIZCHIP_EXPORT(socket)(uint8_t sn, uint8_t protocol, uint16_t port, uint8_t flag)
  93. {
  94. CHECK_SOCKNUM();
  95. switch(protocol)
  96. {
  97. case Sn_MR_TCP :
  98. case Sn_MR_UDP :
  99. case Sn_MR_MACRAW :
  100. break;
  101. #if ( _WIZCHIP_ < 5200 )
  102. case Sn_MR_IPRAW :
  103. case Sn_MR_PPPoE :
  104. break;
  105. #endif
  106. default :
  107. return SOCKERR_SOCKMODE;
  108. }
  109. if((flag & 0x06) != 0) return SOCKERR_SOCKFLAG;
  110. #if _WIZCHIP_ == 5200
  111. if(flag & 0x10) return SOCKERR_SOCKFLAG;
  112. #endif
  113. if(flag != 0)
  114. {
  115. switch(protocol)
  116. {
  117. case Sn_MR_TCP:
  118. if((flag & (SF_TCP_NODELAY|SF_IO_NONBLOCK))==0) return SOCKERR_SOCKFLAG;
  119. break;
  120. case Sn_MR_UDP:
  121. if(flag & SF_IGMP_VER2)
  122. {
  123. if((flag & SF_MULTI_ENABLE)==0) return SOCKERR_SOCKFLAG;
  124. }
  125. #if _WIZCHIP_ == 5500
  126. if(flag & SF_UNI_BLOCK)
  127. {
  128. if((flag & SF_MULTI_ENABLE) == 0) return SOCKERR_SOCKFLAG;
  129. }
  130. #endif
  131. break;
  132. default:
  133. break;
  134. }
  135. }
  136. WIZCHIP_EXPORT(close)(sn);
  137. setSn_MR(sn, (protocol | (flag & 0xF0)));
  138. if(!port)
  139. {
  140. port = sock_any_port++;
  141. if(sock_any_port == 0xFFF0) sock_any_port = SOCK_ANY_PORT_NUM;
  142. }
  143. setSn_PORT(sn,port);
  144. setSn_CR(sn,Sn_CR_OPEN);
  145. while(getSn_CR(sn));
  146. sock_io_mode |= ((flag & SF_IO_NONBLOCK) << sn);
  147. sock_is_sending &= ~(1<<sn);
  148. sock_remained_size[sn] = 0;
  149. sock_pack_info[sn] = 0;
  150. while(getSn_SR(sn) == SOCK_CLOSED);
  151. return (int8_t)sn;
  152. }
  153. int8_t WIZCHIP_EXPORT(close)(uint8_t sn)
  154. {
  155. CHECK_SOCKNUM();
  156. setSn_CR(sn,Sn_CR_CLOSE);
  157. /* wait to process the command... */
  158. while( getSn_CR(sn) );
  159. /* clear all interrupt of the socket. */
  160. setSn_IR(sn, 0xFF);
  161. sock_is_sending &= ~(1<<sn);
  162. sock_remained_size[sn] = 0;
  163. sock_pack_info[sn] = 0;
  164. while(getSn_SR(sn) != SOCK_CLOSED);
  165. return SOCK_OK;
  166. }
  167. int8_t WIZCHIP_EXPORT(listen)(uint8_t sn)
  168. {
  169. CHECK_SOCKNUM();
  170. CHECK_SOCKMODE(Sn_MR_TCP);
  171. CHECK_SOCKINIT();
  172. setSn_CR(sn,Sn_CR_LISTEN);
  173. while(getSn_CR(sn));
  174. while(getSn_SR(sn) != SOCK_LISTEN)
  175. {
  176. if(getSn_CR(sn) == SOCK_CLOSED)
  177. {
  178. WIZCHIP_EXPORT(close)(sn);
  179. return SOCKERR_SOCKCLOSED;
  180. }
  181. }
  182. return SOCK_OK;
  183. }
  184. int8_t WIZCHIP_EXPORT(connect)(uint8_t sn, uint8_t * addr, uint16_t port)
  185. {
  186. CHECK_SOCKNUM();
  187. CHECK_SOCKMODE(Sn_MR_TCP);
  188. CHECK_SOCKINIT();
  189. //M20140501 : For avoiding fatal error on memory align mismatched
  190. //if( *((uint32_t*)addr) == 0xFFFFFFFF || *((uint32_t*)addr) == 0) return SOCKERR_IPINVALID;
  191. {
  192. uint32_t taddr;
  193. taddr = ((uint32_t)addr[0] & 0x000000FF);
  194. taddr = (taddr << 8) + ((uint32_t)addr[1] & 0x000000FF);
  195. taddr = (taddr << 8) + ((uint32_t)addr[2] & 0x000000FF);
  196. taddr = (taddr << 8) + ((uint32_t)addr[3] & 0x000000FF);
  197. if (taddr == 0xFFFFFFFF || taddr == 0) return SOCKERR_IPINVALID;
  198. }
  199. //
  200. if(port == 0) return SOCKERR_PORTZERO;
  201. setSn_DIPR(sn,addr);
  202. setSn_DPORT(sn,port);
  203. #if _WIZCHIP_ == 5200 // for W5200 ARP errata
  204. setSUBR(wizchip_getsubn());
  205. #endif
  206. setSn_CR(sn,Sn_CR_CONNECT);
  207. while(getSn_CR(sn));
  208. if(sock_io_mode & (1<<sn)) return SOCK_BUSY;
  209. while(getSn_SR(sn) != SOCK_ESTABLISHED)
  210. {
  211. if (getSn_SR(sn) == SOCK_CLOSED) {
  212. #if _WIZCHIP_ == 5200 // for W5200 ARP errata
  213. setSUBR((uint8_t*)"\x00\x00\x00\x00");
  214. #endif
  215. return SOCKERR_SOCKCLOSED;
  216. }
  217. if (getSn_IR(sn) & Sn_IR_TIMEOUT)
  218. {
  219. setSn_IR(sn, Sn_IR_TIMEOUT);
  220. #if _WIZCHIP_ == 5200 // for W5200 ARP errata
  221. setSUBR((uint8_t*)"\x00\x00\x00\x00");
  222. #endif
  223. return SOCKERR_TIMEOUT;
  224. }
  225. MICROPY_THREAD_YIELD();
  226. }
  227. #if _WIZCHIP_ == 5200 // for W5200 ARP errata
  228. setSUBR((uint8_t*)"\x00\x00\x00\x00");
  229. #endif
  230. return SOCK_OK;
  231. }
  232. int8_t WIZCHIP_EXPORT(disconnect)(uint8_t sn)
  233. {
  234. CHECK_SOCKNUM();
  235. CHECK_SOCKMODE(Sn_MR_TCP);
  236. setSn_CR(sn,Sn_CR_DISCON);
  237. /* wait to process the command... */
  238. while(getSn_CR(sn));
  239. sock_is_sending &= ~(1<<sn);
  240. if(sock_io_mode & (1<<sn)) return SOCK_BUSY;
  241. while(getSn_SR(sn) != SOCK_CLOSED)
  242. {
  243. if(getSn_IR(sn) & Sn_IR_TIMEOUT)
  244. {
  245. WIZCHIP_EXPORT(close)(sn);
  246. return SOCKERR_TIMEOUT;
  247. }
  248. }
  249. return SOCK_OK;
  250. }
  251. int32_t WIZCHIP_EXPORT(send)(uint8_t sn, uint8_t * buf, uint16_t len)
  252. {
  253. uint8_t tmp=0;
  254. uint16_t freesize=0;
  255. CHECK_SOCKNUM();
  256. CHECK_SOCKMODE(Sn_MR_TCP);
  257. CHECK_SOCKDATA();
  258. tmp = getSn_SR(sn);
  259. if(tmp != SOCK_ESTABLISHED && tmp != SOCK_CLOSE_WAIT) return SOCKERR_SOCKSTATUS;
  260. if( sock_is_sending & (1<<sn) )
  261. {
  262. tmp = getSn_IR(sn);
  263. if(tmp & Sn_IR_SENDOK)
  264. {
  265. setSn_IR(sn, Sn_IR_SENDOK);
  266. #if _WZICHIP_ == 5200
  267. if(getSn_TX_RD(sn) != sock_next_rd[sn])
  268. {
  269. setSn_CR(sn,Sn_CR_SEND);
  270. while(getSn_CR(sn));
  271. return SOCKERR_BUSY;
  272. }
  273. #endif
  274. sock_is_sending &= ~(1<<sn);
  275. }
  276. else if(tmp & Sn_IR_TIMEOUT)
  277. {
  278. WIZCHIP_EXPORT(close)(sn);
  279. return SOCKERR_TIMEOUT;
  280. }
  281. else return SOCK_BUSY;
  282. }
  283. freesize = getSn_TxMAX(sn);
  284. if (len > freesize) len = freesize; // check size not to exceed MAX size.
  285. while(1)
  286. {
  287. freesize = getSn_TX_FSR(sn);
  288. tmp = getSn_SR(sn);
  289. if ((tmp != SOCK_ESTABLISHED) && (tmp != SOCK_CLOSE_WAIT))
  290. {
  291. WIZCHIP_EXPORT(close)(sn);
  292. return SOCKERR_SOCKSTATUS;
  293. }
  294. if( (sock_io_mode & (1<<sn)) && (len > freesize) ) return SOCK_BUSY;
  295. if(len <= freesize) break;
  296. MICROPY_THREAD_YIELD();
  297. }
  298. wiz_send_data(sn, buf, len);
  299. #if _WIZCHIP_ == 5200
  300. sock_next_rd[sn] = getSn_TX_RD(sn) + len;
  301. #endif
  302. setSn_CR(sn,Sn_CR_SEND);
  303. /* wait to process the command... */
  304. while(getSn_CR(sn));
  305. sock_is_sending |= (1 << sn);
  306. return len;
  307. }
  308. int32_t WIZCHIP_EXPORT(recv)(uint8_t sn, uint8_t * buf, uint16_t len)
  309. {
  310. uint8_t tmp = 0;
  311. uint16_t recvsize = 0;
  312. CHECK_SOCKNUM();
  313. CHECK_SOCKMODE(Sn_MR_TCP);
  314. CHECK_SOCKDATA();
  315. recvsize = getSn_RxMAX(sn);
  316. if(recvsize < len) len = recvsize;
  317. while(1)
  318. {
  319. recvsize = getSn_RX_RSR(sn);
  320. tmp = getSn_SR(sn);
  321. if (tmp != SOCK_ESTABLISHED)
  322. {
  323. if(tmp == SOCK_CLOSE_WAIT)
  324. {
  325. if(recvsize != 0) break;
  326. else if(getSn_TX_FSR(sn) == getSn_TxMAX(sn))
  327. {
  328. // dpgeorge: Getting here seems to be an orderly shutdown of the
  329. // socket, and trying to get POSIX behaviour we return 0 because:
  330. // "If no messages are available to be received and the peer has per‐
  331. // formed an orderly shutdown, recv() shall return 0".
  332. // TODO this return value clashes with SOCK_BUSY in non-blocking mode.
  333. WIZCHIP_EXPORT(close)(sn);
  334. return 0;
  335. }
  336. }
  337. else
  338. {
  339. WIZCHIP_EXPORT(close)(sn);
  340. return SOCKERR_SOCKSTATUS;
  341. }
  342. }
  343. if((sock_io_mode & (1<<sn)) && (recvsize == 0)) return SOCK_BUSY;
  344. if(recvsize != 0) break;
  345. MICROPY_THREAD_YIELD();
  346. };
  347. if(recvsize < len) len = recvsize;
  348. wiz_recv_data(sn, buf, len);
  349. setSn_CR(sn,Sn_CR_RECV);
  350. while(getSn_CR(sn));
  351. return len;
  352. }
  353. int32_t WIZCHIP_EXPORT(sendto)(uint8_t sn, uint8_t * buf, uint16_t len, uint8_t * addr, uint16_t port)
  354. {
  355. uint8_t tmp = 0;
  356. uint16_t freesize = 0;
  357. CHECK_SOCKNUM();
  358. switch(getSn_MR(sn) & 0x0F)
  359. {
  360. case Sn_MR_UDP:
  361. case Sn_MR_MACRAW:
  362. break;
  363. default:
  364. return SOCKERR_SOCKMODE;
  365. }
  366. CHECK_SOCKDATA();
  367. //M20140501 : For avoiding fatal error on memory align mismatched
  368. //if(*((uint32_t*)addr) == 0) return SOCKERR_IPINVALID;
  369. {
  370. uint32_t taddr;
  371. taddr = ((uint32_t)addr[0]) & 0x000000FF;
  372. taddr = (taddr << 8) + ((uint32_t)addr[1] & 0x000000FF);
  373. taddr = (taddr << 8) + ((uint32_t)addr[2] & 0x000000FF);
  374. taddr = (taddr << 8) + ((uint32_t)addr[3] & 0x000000FF);
  375. if (taddr == 0xFFFFFFFF || taddr == 0) return SOCKERR_IPINVALID;
  376. }
  377. //
  378. if(port == 0) return SOCKERR_PORTZERO;
  379. tmp = getSn_SR(sn);
  380. if(tmp != SOCK_MACRAW && tmp != SOCK_UDP) return SOCKERR_SOCKSTATUS;
  381. setSn_DIPR(sn,addr);
  382. setSn_DPORT(sn,port);
  383. freesize = getSn_TxMAX(sn);
  384. if (len > freesize) len = freesize; // check size not to exceed MAX size.
  385. while(1)
  386. {
  387. freesize = getSn_TX_FSR(sn);
  388. if(getSn_SR(sn) == SOCK_CLOSED) return SOCKERR_SOCKCLOSED;
  389. if( (sock_io_mode & (1<<sn)) && (len > freesize) ) return SOCK_BUSY;
  390. if(len <= freesize) break;
  391. MICROPY_THREAD_YIELD();
  392. };
  393. wiz_send_data(sn, buf, len);
  394. #if _WIZCHIP_ == 5200 // for W5200 ARP errata
  395. setSUBR(wizchip_getsubn());
  396. #endif
  397. setSn_CR(sn,Sn_CR_SEND);
  398. /* wait to process the command... */
  399. while(getSn_CR(sn));
  400. while(1)
  401. {
  402. tmp = getSn_IR(sn);
  403. if(tmp & Sn_IR_SENDOK)
  404. {
  405. setSn_IR(sn, Sn_IR_SENDOK);
  406. break;
  407. }
  408. //M:20131104
  409. //else if(tmp & Sn_IR_TIMEOUT) return SOCKERR_TIMEOUT;
  410. else if(tmp & Sn_IR_TIMEOUT)
  411. {
  412. setSn_IR(sn, Sn_IR_TIMEOUT);
  413. #if _WIZCHIP_ == 5200 // for W5200 ARP errata
  414. setSUBR((uint8_t*)"\x00\x00\x00\x00");
  415. #endif
  416. return SOCKERR_TIMEOUT;
  417. }
  418. ////////////
  419. MICROPY_THREAD_YIELD();
  420. }
  421. #if _WIZCHIP_ == 5200 // for W5200 ARP errata
  422. setSUBR((uint8_t*)"\x00\x00\x00\x00");
  423. #endif
  424. return len;
  425. }
  426. int32_t WIZCHIP_EXPORT(recvfrom)(uint8_t sn, uint8_t * buf, uint16_t len, uint8_t * addr, uint16_t *port)
  427. {
  428. uint8_t mr;
  429. uint8_t head[8];
  430. uint16_t pack_len=0;
  431. CHECK_SOCKNUM();
  432. //CHECK_SOCKMODE(Sn_MR_UDP);
  433. switch((mr=getSn_MR(sn)) & 0x0F)
  434. {
  435. case Sn_MR_UDP:
  436. case Sn_MR_MACRAW:
  437. break;
  438. #if ( _WIZCHIP_ < 5200 )
  439. case Sn_MR_IPRAW:
  440. case Sn_MR_PPPoE:
  441. break;
  442. #endif
  443. default:
  444. return SOCKERR_SOCKMODE;
  445. }
  446. CHECK_SOCKDATA();
  447. if(sock_remained_size[sn] == 0)
  448. {
  449. while(1)
  450. {
  451. pack_len = getSn_RX_RSR(sn);
  452. if(getSn_SR(sn) == SOCK_CLOSED) return SOCKERR_SOCKCLOSED;
  453. if( (sock_io_mode & (1<<sn)) && (pack_len == 0) ) return SOCK_BUSY;
  454. if(pack_len != 0) break;
  455. MICROPY_THREAD_YIELD();
  456. };
  457. }
  458. sock_pack_info[sn] = PACK_COMPLETED;
  459. switch (mr & 0x07)
  460. {
  461. case Sn_MR_UDP :
  462. if(sock_remained_size[sn] == 0)
  463. {
  464. wiz_recv_data(sn, head, 8);
  465. setSn_CR(sn,Sn_CR_RECV);
  466. while(getSn_CR(sn));
  467. // read peer's IP address, port number & packet length
  468. addr[0] = head[0];
  469. addr[1] = head[1];
  470. addr[2] = head[2];
  471. addr[3] = head[3];
  472. *port = head[4];
  473. *port = (*port << 8) + head[5];
  474. sock_remained_size[sn] = head[6];
  475. sock_remained_size[sn] = (sock_remained_size[sn] << 8) + head[7];
  476. sock_pack_info[sn] = PACK_FIRST;
  477. }
  478. if(len < sock_remained_size[sn]) pack_len = len;
  479. else pack_len = sock_remained_size[sn];
  480. //
  481. // Need to packet length check (default 1472)
  482. //
  483. wiz_recv_data(sn, buf, pack_len); // data copy.
  484. break;
  485. case Sn_MR_MACRAW :
  486. if(sock_remained_size[sn] == 0)
  487. {
  488. wiz_recv_data(sn, head, 2);
  489. setSn_CR(sn,Sn_CR_RECV);
  490. while(getSn_CR(sn));
  491. // read peer's IP address, port number & packet length
  492. sock_remained_size[sn] = head[0];
  493. sock_remained_size[sn] = (sock_remained_size[sn] <<8) + head[1];
  494. sock_remained_size[sn] -= 2; // len includes 2 len bytes
  495. if(sock_remained_size[sn] > 1514)
  496. {
  497. WIZCHIP_EXPORT(close)(sn);
  498. return SOCKFATAL_PACKLEN;
  499. }
  500. sock_pack_info[sn] = PACK_FIRST;
  501. }
  502. if(len < sock_remained_size[sn]) pack_len = len;
  503. else pack_len = sock_remained_size[sn];
  504. wiz_recv_data(sn,buf,pack_len);
  505. break;
  506. #if ( _WIZCHIP_ < 5200 )
  507. case Sn_MR_IPRAW:
  508. if(sock_remained_size[sn] == 0)
  509. {
  510. wiz_recv_data(sn, head, 6);
  511. setSn_CR(sn,Sn_CR_RECV);
  512. while(getSn_CR(sn));
  513. addr[0] = head[0];
  514. addr[1] = head[1];
  515. addr[2] = head[2];
  516. addr[3] = head[3];
  517. sock_remained_size[sn] = head[4];
  518. sock_remaiend_size[sn] = (sock_remained_size[sn] << 8) + head[5];
  519. sock_pack_info[sn] = PACK_FIRST;
  520. }
  521. //
  522. // Need to packet length check
  523. //
  524. if(len < sock_remained_size[sn]) pack_len = len;
  525. else pack_len = sock_remained_size[sn];
  526. wiz_recv_data(sn, buf, pack_len); // data copy.
  527. break;
  528. #endif
  529. default:
  530. wiz_recv_ignore(sn, pack_len); // data copy.
  531. sock_remained_size[sn] = pack_len;
  532. break;
  533. }
  534. setSn_CR(sn,Sn_CR_RECV);
  535. /* wait to process the command... */
  536. while(getSn_CR(sn)) ;
  537. sock_remained_size[sn] -= pack_len;
  538. //M20140501 : replace 0x01 with PACK_REMAINED
  539. //if(sock_remained_size[sn] != 0) sock_pack_info[sn] |= 0x01;
  540. if(sock_remained_size[sn] != 0) sock_pack_info[sn] |= PACK_REMAINED;
  541. //
  542. return pack_len;
  543. }
  544. int8_t WIZCHIP_EXPORT(ctlsocket)(uint8_t sn, ctlsock_type cstype, void* arg)
  545. {
  546. uint8_t tmp = 0;
  547. CHECK_SOCKNUM();
  548. switch(cstype)
  549. {
  550. case CS_SET_IOMODE:
  551. tmp = *((uint8_t*)arg);
  552. if(tmp == SOCK_IO_NONBLOCK) sock_io_mode |= (1<<sn);
  553. else if(tmp == SOCK_IO_BLOCK) sock_io_mode &= ~(1<<sn);
  554. else return SOCKERR_ARG;
  555. break;
  556. case CS_GET_IOMODE:
  557. //M20140501 : implict type casting -> explict type casting
  558. //*((uint8_t*)arg) = (sock_io_mode >> sn) & 0x0001;
  559. *((uint8_t*)arg) = (uint8_t)((sock_io_mode >> sn) & 0x0001);
  560. //
  561. break;
  562. case CS_GET_MAXTXBUF:
  563. *((uint16_t*)arg) = getSn_TxMAX(sn);
  564. break;
  565. case CS_GET_MAXRXBUF:
  566. *((uint16_t*)arg) = getSn_RxMAX(sn);
  567. break;
  568. case CS_CLR_INTERRUPT:
  569. if( (*(uint8_t*)arg) > SIK_ALL) return SOCKERR_ARG;
  570. setSn_IR(sn,*(uint8_t*)arg);
  571. break;
  572. case CS_GET_INTERRUPT:
  573. *((uint8_t*)arg) = getSn_IR(sn);
  574. break;
  575. case CS_SET_INTMASK:
  576. if( (*(uint8_t*)arg) > SIK_ALL) return SOCKERR_ARG;
  577. setSn_IMR(sn,*(uint8_t*)arg);
  578. break;
  579. case CS_GET_INTMASK:
  580. *((uint8_t*)arg) = getSn_IMR(sn);
  581. default:
  582. return SOCKERR_ARG;
  583. }
  584. return SOCK_OK;
  585. }
  586. int8_t WIZCHIP_EXPORT(setsockopt)(uint8_t sn, sockopt_type sotype, void* arg)
  587. {
  588. // M20131220 : Remove warning
  589. //uint8_t tmp;
  590. CHECK_SOCKNUM();
  591. switch(sotype)
  592. {
  593. case SO_TTL:
  594. setSn_TTL(sn,*(uint8_t*)arg);
  595. break;
  596. case SO_TOS:
  597. setSn_TOS(sn,*(uint8_t*)arg);
  598. break;
  599. case SO_MSS:
  600. setSn_MSSR(sn,*(uint16_t*)arg);
  601. break;
  602. case SO_DESTIP:
  603. setSn_DIPR(sn, (uint8_t*)arg);
  604. break;
  605. case SO_DESTPORT:
  606. setSn_DPORT(sn, *(uint16_t*)arg);
  607. break;
  608. #if _WIZCHIP_ != 5100
  609. case SO_KEEPALIVESEND:
  610. CHECK_SOCKMODE(Sn_MR_TCP);
  611. #if _WIZCHIP_ > 5200
  612. if(getSn_KPALVTR(sn) != 0) return SOCKERR_SOCKOPT;
  613. #endif
  614. setSn_CR(sn,Sn_CR_SEND_KEEP);
  615. while(getSn_CR(sn) != 0)
  616. {
  617. // M20131220
  618. //if ((tmp = getSn_IR(sn)) & Sn_IR_TIMEOUT)
  619. if (getSn_IR(sn) & Sn_IR_TIMEOUT)
  620. {
  621. setSn_IR(sn, Sn_IR_TIMEOUT);
  622. return SOCKERR_TIMEOUT;
  623. }
  624. }
  625. break;
  626. #if _WIZCHIP_ > 5200
  627. case SO_KEEPALIVEAUTO:
  628. CHECK_SOCKMODE(Sn_MR_TCP);
  629. setSn_KPALVTR(sn,*(uint8_t*)arg);
  630. break;
  631. #endif
  632. #endif
  633. default:
  634. return SOCKERR_ARG;
  635. }
  636. return SOCK_OK;
  637. }
  638. int8_t WIZCHIP_EXPORT(getsockopt)(uint8_t sn, sockopt_type sotype, void* arg)
  639. {
  640. CHECK_SOCKNUM();
  641. switch(sotype)
  642. {
  643. case SO_FLAG:
  644. *(uint8_t*)arg = getSn_MR(sn) & 0xF0;
  645. break;
  646. case SO_TTL:
  647. *(uint8_t*) arg = getSn_TTL(sn);
  648. break;
  649. case SO_TOS:
  650. *(uint8_t*) arg = getSn_TOS(sn);
  651. break;
  652. case SO_MSS:
  653. *(uint8_t*) arg = getSn_MSSR(sn);
  654. case SO_DESTIP:
  655. getSn_DIPR(sn, (uint8_t*)arg);
  656. break;
  657. case SO_DESTPORT:
  658. *(uint16_t*) arg = getSn_DPORT(sn);
  659. break;
  660. #if _WIZCHIP_ > 5200
  661. case SO_KEEPALIVEAUTO:
  662. CHECK_SOCKMODE(Sn_MR_TCP);
  663. *(uint16_t*) arg = getSn_KPALVTR(sn);
  664. break;
  665. #endif
  666. case SO_SENDBUF:
  667. *(uint16_t*) arg = getSn_TX_FSR(sn);
  668. case SO_RECVBUF:
  669. *(uint16_t*) arg = getSn_RX_RSR(sn);
  670. case SO_STATUS:
  671. *(uint8_t*) arg = getSn_SR(sn);
  672. break;
  673. case SO_REMAINSIZE:
  674. if(getSn_MR(sn) == Sn_MR_TCP)
  675. *(uint16_t*)arg = getSn_RX_RSR(sn);
  676. else
  677. *(uint16_t*)arg = sock_remained_size[sn];
  678. break;
  679. case SO_PACKINFO:
  680. CHECK_SOCKMODE(Sn_MR_TCP);
  681. *(uint8_t*)arg = sock_pack_info[sn];
  682. break;
  683. default:
  684. return SOCKERR_SOCKOPT;
  685. }
  686. return SOCK_OK;
  687. }