W5500 driver for mbed OS 5
Dependents: http-webserver-example mbed-os-example-sockets
Fork of W5500Interface by
W5500Interface.cpp@10:925201b1603f, 2018-08-13 (annotated)
- Committer:
- Bongjun
- Date:
- Mon Aug 13 02:30:22 2018 +0000
- Revision:
- 10:925201b1603f
- Parent:
- 8:c71c66d43703
- Child:
- 11:5118c2bff025
add functions in W5500Interface.; - virtual const char *get_netmask();; - virtual const char *get_gateway();;
Who changed what in which revision?
User | Revision | Line number | New contents of line |
---|---|---|---|
Bongjun | 6:e2ab76b2be07 | 1 | |
Bongjun | 6:e2ab76b2be07 | 2 | /** |
Bongjun | 6:e2ab76b2be07 | 3 | ****************************************************************************** |
Bongjun | 6:e2ab76b2be07 | 4 | * @file W5500Interface.h |
Bongjun | 6:e2ab76b2be07 | 5 | * @author Bongjun Hur (modified version from Sergei G (https://os.mbed.com/users/sgnezdov/)) |
Bongjun | 6:e2ab76b2be07 | 6 | * @brief Implementation file of the NetworkStack for the W5500 Device |
Bongjun | 6:e2ab76b2be07 | 7 | ****************************************************************************** |
Bongjun | 6:e2ab76b2be07 | 8 | * @attention |
Bongjun | 6:e2ab76b2be07 | 9 | * |
Bongjun | 6:e2ab76b2be07 | 10 | * THE PRESENT FIRMWARE WHICH IS FOR GUIDANCE ONLY AIMS AT PROVIDING CUSTOMERS |
Bongjun | 6:e2ab76b2be07 | 11 | * WITH CODING INFORMATION REGARDING THEIR PRODUCTS IN ORDER FOR THEM TO SAVE |
Bongjun | 6:e2ab76b2be07 | 12 | * TIME. AS A RESULT, WIZnet SHALL NOT BE HELD LIABLE FOR ANY |
Bongjun | 6:e2ab76b2be07 | 13 | * DIRECT, INDIRECT OR CONSEQUENTIAL DAMAGES WITH RESPECT TO ANY CLAIMS ARISING |
Bongjun | 6:e2ab76b2be07 | 14 | * FROM THE CONTENT OF SUCH FIRMWARE AND/OR THE USE MADE BY CUSTOMERS OF THE |
Bongjun | 6:e2ab76b2be07 | 15 | * CODING INFORMATION CONTAINED HEREIN IN CONNECTION WITH THEIR PRODUCTS. |
Bongjun | 6:e2ab76b2be07 | 16 | * |
Bongjun | 6:e2ab76b2be07 | 17 | * <h2><center>© COPYRIGHT 2017 WIZnet Co.,Ltd.</center></h2> |
Bongjun | 6:e2ab76b2be07 | 18 | ****************************************************************************** |
Bongjun | 6:e2ab76b2be07 | 19 | */ |
Bongjun | 6:e2ab76b2be07 | 20 | |
Bongjun | 6:e2ab76b2be07 | 21 | #include "mbed.h" |
Bongjun | 6:e2ab76b2be07 | 22 | #include "W5500Interface.h" |
Bongjun | 6:e2ab76b2be07 | 23 | |
Bongjun | 8:c71c66d43703 | 24 | /* |
Bongjun | 8:c71c66d43703 | 25 | #include "DHCPClient/DHCPClient.h" |
Bongjun | 8:c71c66d43703 | 26 | #include "DNSClient/DNSClient.h" |
Bongjun | 8:c71c66d43703 | 27 | #include "nsapi_dns.h" |
Bongjun | 8:c71c66d43703 | 28 | DHCPClient dhcp; |
Bongjun | 8:c71c66d43703 | 29 | DNSClient dns; |
Bongjun | 8:c71c66d43703 | 30 | uint8_t mac_addr[6] = {0x00, 0x08, 0xdc, 0x45, 0x56, 0x67}; |
Bongjun | 8:c71c66d43703 | 31 | */ |
Bongjun | 8:c71c66d43703 | 32 | |
Bongjun | 6:e2ab76b2be07 | 33 | static int udp_local_port = 0; |
Bongjun | 6:e2ab76b2be07 | 34 | |
Bongjun | 6:e2ab76b2be07 | 35 | #define SKT(h) ((w5500_socket*)h) |
Bongjun | 6:e2ab76b2be07 | 36 | #define w5500_WAIT_TIMEOUT 1500 |
Bongjun | 6:e2ab76b2be07 | 37 | #define w5500_ACCEPT_TIMEOUT 30000 |
Bongjun | 6:e2ab76b2be07 | 38 | |
Bongjun | 6:e2ab76b2be07 | 39 | #define w5500_INTF_DBG 0 |
Bongjun | 6:e2ab76b2be07 | 40 | |
Bongjun | 6:e2ab76b2be07 | 41 | #if w5500_INTF_DBG |
Bongjun | 6:e2ab76b2be07 | 42 | #define DBG(...) do{debug("[%s:%d]", __PRETTY_FUNCTION__,__LINE__);debug(__VA_ARGS__);} while(0); |
Bongjun | 6:e2ab76b2be07 | 43 | #else |
Bongjun | 6:e2ab76b2be07 | 44 | #define DBG(...) while(0); |
Bongjun | 6:e2ab76b2be07 | 45 | #endif |
Bongjun | 6:e2ab76b2be07 | 46 | |
Bongjun | 8:c71c66d43703 | 47 | /** |
Bongjun | 8:c71c66d43703 | 48 | * @brief Defines a custom MAC address |
Bongjun | 8:c71c66d43703 | 49 | * @note Have to be unique within the connected network! |
Bongjun | 8:c71c66d43703 | 50 | * Modify the mac array items as needed. |
Bongjun | 8:c71c66d43703 | 51 | * @param mac A 6-byte array defining the MAC address |
Bongjun | 8:c71c66d43703 | 52 | * @retval |
Bongjun | 8:c71c66d43703 | 53 | */ |
Bongjun | 6:e2ab76b2be07 | 54 | /* Interface implementation */ |
Bongjun | 6:e2ab76b2be07 | 55 | |
Bongjun | 6:e2ab76b2be07 | 56 | W5500Interface::W5500Interface(PinName mosi, PinName miso, PinName sclk, PinName cs, PinName reset) : |
Bongjun | 6:e2ab76b2be07 | 57 | _w5500(mosi, miso, sclk, cs, reset) |
Bongjun | 6:e2ab76b2be07 | 58 | { |
Bongjun | 6:e2ab76b2be07 | 59 | ip_set = false; |
Bongjun | 6:e2ab76b2be07 | 60 | } |
Bongjun | 6:e2ab76b2be07 | 61 | |
Bongjun | 8:c71c66d43703 | 62 | /* |
Bongjun | 6:e2ab76b2be07 | 63 | W5500Interface::W5500Interface(SPI* spi, PinName cs, PinName reset) : |
Bongjun | 6:e2ab76b2be07 | 64 | _w5500(spi, cs, reset) |
Bongjun | 6:e2ab76b2be07 | 65 | { |
Bongjun | 6:e2ab76b2be07 | 66 | ip_set = false; |
Bongjun | 6:e2ab76b2be07 | 67 | } |
Bongjun | 8:c71c66d43703 | 68 | */ |
Bongjun | 6:e2ab76b2be07 | 69 | |
Bongjun | 6:e2ab76b2be07 | 70 | w5500_socket* W5500Interface::get_sock(int fd) |
Bongjun | 6:e2ab76b2be07 | 71 | { |
Bongjun | 6:e2ab76b2be07 | 72 | for (int i=0; i<MAX_SOCK_NUM ; i++) { |
Bongjun | 6:e2ab76b2be07 | 73 | if (w5500_sockets[i].fd == -1) { |
Bongjun | 6:e2ab76b2be07 | 74 | w5500_sockets[i].fd = fd; |
Bongjun | 6:e2ab76b2be07 | 75 | w5500_sockets[i].proto = NSAPI_TCP; |
Bongjun | 6:e2ab76b2be07 | 76 | w5500_sockets[i].connected = false; |
Bongjun | 6:e2ab76b2be07 | 77 | w5500_sockets[i].callback = NULL; |
Bongjun | 6:e2ab76b2be07 | 78 | w5500_sockets[i].callback_data = NULL; |
Bongjun | 6:e2ab76b2be07 | 79 | return &w5500_sockets[i]; |
Bongjun | 6:e2ab76b2be07 | 80 | } |
Bongjun | 6:e2ab76b2be07 | 81 | } |
Bongjun | 6:e2ab76b2be07 | 82 | return NULL; |
Bongjun | 6:e2ab76b2be07 | 83 | } |
Bongjun | 6:e2ab76b2be07 | 84 | |
Bongjun | 6:e2ab76b2be07 | 85 | void W5500Interface::init_socks() |
Bongjun | 6:e2ab76b2be07 | 86 | { |
Bongjun | 6:e2ab76b2be07 | 87 | for (int i=0; i<MAX_SOCK_NUM ; i++) { |
Bongjun | 6:e2ab76b2be07 | 88 | w5500_sockets[i].fd = -1; |
Bongjun | 6:e2ab76b2be07 | 89 | w5500_sockets[i].proto = NSAPI_TCP; |
Bongjun | 6:e2ab76b2be07 | 90 | w5500_sockets[i].connected = false; |
Bongjun | 6:e2ab76b2be07 | 91 | w5500_sockets[i].callback = NULL; |
Bongjun | 6:e2ab76b2be07 | 92 | w5500_sockets[i].callback_data = NULL; |
Bongjun | 6:e2ab76b2be07 | 93 | } |
Bongjun | 6:e2ab76b2be07 | 94 | |
Bongjun | 6:e2ab76b2be07 | 95 | //initialize the socket isr |
Bongjun | 6:e2ab76b2be07 | 96 | //_daemon = new Thread(osPriorityNormal, 1024); |
Bongjun | 6:e2ab76b2be07 | 97 | //_daemon->start(callback(this, &W5500Interface::daemon)); |
Bongjun | 6:e2ab76b2be07 | 98 | } |
Bongjun | 6:e2ab76b2be07 | 99 | |
Bongjun | 6:e2ab76b2be07 | 100 | int W5500Interface::init() |
Bongjun | 6:e2ab76b2be07 | 101 | { |
Bongjun | 6:e2ab76b2be07 | 102 | _w5500.reg_wr<uint32_t>(SIPR, 0x00000000); // local ip "0.0.0.0" |
Bongjun | 6:e2ab76b2be07 | 103 | //_w5500.reg_wr<uint8_t>(SIMR, 0xFF); // |
Bongjun | 6:e2ab76b2be07 | 104 | _w5500.reset(); |
Bongjun | 6:e2ab76b2be07 | 105 | init_socks(); |
Bongjun | 6:e2ab76b2be07 | 106 | return 0; |
Bongjun | 6:e2ab76b2be07 | 107 | } |
Bongjun | 6:e2ab76b2be07 | 108 | |
Bongjun | 6:e2ab76b2be07 | 109 | int W5500Interface::init(uint8_t * mac) |
Bongjun | 6:e2ab76b2be07 | 110 | { |
Bongjun | 6:e2ab76b2be07 | 111 | _w5500.reg_wr<uint32_t>(SIPR, 0x00000000); // local ip "0.0.0.0" |
Bongjun | 8:c71c66d43703 | 112 | // should set the mac address and keep the value in this class |
Bongjun | 6:e2ab76b2be07 | 113 | for (int i =0; i < 6; i++) _w5500.mac[i] = mac[i]; |
Bongjun | 6:e2ab76b2be07 | 114 | _w5500.setmac(); |
Bongjun | 8:c71c66d43703 | 115 | _w5500.reset(); // reset chip and write mac address |
Bongjun | 6:e2ab76b2be07 | 116 | init_socks(); |
Bongjun | 6:e2ab76b2be07 | 117 | return 0; |
Bongjun | 6:e2ab76b2be07 | 118 | } |
Bongjun | 6:e2ab76b2be07 | 119 | |
Bongjun | 6:e2ab76b2be07 | 120 | // add this function, because sometimes no needed MAC address in init calling. |
Bongjun | 6:e2ab76b2be07 | 121 | int W5500Interface::init(const char* ip, const char* mask, const char* gateway) |
Bongjun | 6:e2ab76b2be07 | 122 | { |
Bongjun | 6:e2ab76b2be07 | 123 | _w5500.ip = str_to_ip(ip); |
Bongjun | 6:e2ab76b2be07 | 124 | strcpy(ip_string, ip); |
Bongjun | 6:e2ab76b2be07 | 125 | ip_set = true; |
Bongjun | 6:e2ab76b2be07 | 126 | _w5500.netmask = str_to_ip(mask); |
Bongjun | 6:e2ab76b2be07 | 127 | _w5500.gateway = str_to_ip(gateway); |
Bongjun | 6:e2ab76b2be07 | 128 | _w5500.reset(); |
Bongjun | 6:e2ab76b2be07 | 129 | |
Bongjun | 6:e2ab76b2be07 | 130 | // @Jul. 8. 2014 add code. should be called to write chip. |
Bongjun | 6:e2ab76b2be07 | 131 | _w5500.setip(); |
Bongjun | 6:e2ab76b2be07 | 132 | init_socks(); |
Bongjun | 6:e2ab76b2be07 | 133 | |
Bongjun | 6:e2ab76b2be07 | 134 | return 0; |
Bongjun | 6:e2ab76b2be07 | 135 | } |
Bongjun | 6:e2ab76b2be07 | 136 | |
Bongjun | 6:e2ab76b2be07 | 137 | int W5500Interface::init(uint8_t * mac, const char* ip, const char* mask, const char* gateway) |
Bongjun | 6:e2ab76b2be07 | 138 | { |
Bongjun | 6:e2ab76b2be07 | 139 | // |
Bongjun | 6:e2ab76b2be07 | 140 | for (int i =0; i < 6; i++) _w5500.mac[i] = mac[i]; |
Bongjun | 6:e2ab76b2be07 | 141 | // |
Bongjun | 6:e2ab76b2be07 | 142 | _w5500.ip = str_to_ip(ip); |
Bongjun | 6:e2ab76b2be07 | 143 | strcpy(ip_string, ip); |
Bongjun | 6:e2ab76b2be07 | 144 | ip_set = true; |
Bongjun | 6:e2ab76b2be07 | 145 | _w5500.netmask = str_to_ip(mask); |
Bongjun | 6:e2ab76b2be07 | 146 | _w5500.gateway = str_to_ip(gateway); |
Bongjun | 6:e2ab76b2be07 | 147 | _w5500.reset(); |
Bongjun | 6:e2ab76b2be07 | 148 | |
Bongjun | 6:e2ab76b2be07 | 149 | // @Jul. 8. 2014 add code. should be called to write chip. |
Bongjun | 6:e2ab76b2be07 | 150 | _w5500.setmac(); |
Bongjun | 6:e2ab76b2be07 | 151 | _w5500.setip(); |
Bongjun | 6:e2ab76b2be07 | 152 | init_socks(); |
Bongjun | 6:e2ab76b2be07 | 153 | |
Bongjun | 6:e2ab76b2be07 | 154 | return 0; |
Bongjun | 6:e2ab76b2be07 | 155 | } |
Bongjun | 6:e2ab76b2be07 | 156 | |
Bongjun | 6:e2ab76b2be07 | 157 | /* |
Bongjun | 6:e2ab76b2be07 | 158 | void W5500Interface::daemon () { |
Bongjun | 6:e2ab76b2be07 | 159 | for (;;) { |
Bongjun | 6:e2ab76b2be07 | 160 | for (int i=0; i<MAX_SOCK_NUM ; i++) { |
Bongjun | 6:e2ab76b2be07 | 161 | if (w5500_sockets[i].fd > 0 && w5500_sockets[i].callback) { |
Bongjun | 6:e2ab76b2be07 | 162 | int size = _w5500.sreg<uint16_t>(w5500_sockets[i].fd, Sn_RX_RSR); |
Bongjun | 6:e2ab76b2be07 | 163 | if (size > 0) { |
Bongjun | 6:e2ab76b2be07 | 164 | led1 = !led1; |
Bongjun | 6:e2ab76b2be07 | 165 | w5500_sockets[i].callback(w5500_sockets[i].callback_data); |
Bongjun | 6:e2ab76b2be07 | 166 | } |
Bongjun | 6:e2ab76b2be07 | 167 | } |
Bongjun | 6:e2ab76b2be07 | 168 | } |
Bongjun | 6:e2ab76b2be07 | 169 | wait(0.2); |
Bongjun | 6:e2ab76b2be07 | 170 | } |
Bongjun | 6:e2ab76b2be07 | 171 | } |
Bongjun | 6:e2ab76b2be07 | 172 | */ |
Bongjun | 6:e2ab76b2be07 | 173 | |
Bongjun | 6:e2ab76b2be07 | 174 | int W5500Interface::connect() |
Bongjun | 6:e2ab76b2be07 | 175 | { |
Bongjun | 6:e2ab76b2be07 | 176 | ///////////////////////////// |
Bongjun | 7:1877881f3516 | 177 | // will add DHCP fuction here |
Bongjun | 8:c71c66d43703 | 178 | /* |
Bongjun | 8:c71c66d43703 | 179 | // 이부분은 W5500Interface 의 connect 함수로 옮기는 게 맞을 듯 하다... |
Bongjun | 8:c71c66d43703 | 180 | printf("[EasyConnect] DHCP start\n"); |
Bongjun | 8:c71c66d43703 | 181 | int timeout_ms = 15*1000; |
Bongjun | 8:c71c66d43703 | 182 | int err = dhcp.setup((NetworkStack*)this, _w5500.mac, timeout_ms); |
Bongjun | 8:c71c66d43703 | 183 | if (err == (-1)) { |
Bongjun | 8:c71c66d43703 | 184 | printf("[EasyConnect] Timeout.\n"); |
Bongjun | 8:c71c66d43703 | 185 | return 0; |
Bongjun | 8:c71c66d43703 | 186 | } |
Bongjun | 8:c71c66d43703 | 187 | printf("[EasyConnect] DHCP completed\n"); |
Bongjun | 8:c71c66d43703 | 188 | printf("[EasyConnect] Connected, IP: %d.%d.%d.%d\r\n", dhcp.yiaddr[0], dhcp.yiaddr[1], dhcp.yiaddr[2], dhcp.yiaddr[3]); |
Bongjun | 8:c71c66d43703 | 189 | |
Bongjun | 8:c71c66d43703 | 190 | char ip[24], gateway[24], netmask[24], dnsaddr[24]; |
Bongjun | 8:c71c66d43703 | 191 | sprintf(ip, "%d.%d.%d.%d", dhcp.yiaddr[0], dhcp.yiaddr[1], dhcp.yiaddr[2], dhcp.yiaddr[3]); |
Bongjun | 8:c71c66d43703 | 192 | sprintf(gateway, "%d.%d.%d.%d", dhcp.gateway[0], dhcp.gateway[1], dhcp.gateway[2], dhcp.gateway[3]); |
Bongjun | 8:c71c66d43703 | 193 | sprintf(netmask, "%d.%d.%d.%d", dhcp.netmask[0], dhcp.netmask[1], dhcp.netmask[2], dhcp.netmask[3]); |
Bongjun | 8:c71c66d43703 | 194 | sprintf(dnsaddr, "%d.%d.%d.%d", dhcp.dnsaddr[0], dhcp.dnsaddr[1], dhcp.dnsaddr[2], dhcp.dnsaddr[3]); |
Bongjun | 8:c71c66d43703 | 195 | init(ip, netmask, gateway); |
Bongjun | 8:c71c66d43703 | 196 | */ |
Bongjun | 6:e2ab76b2be07 | 197 | if (_w5500.setip() == false) return NSAPI_ERROR_DHCP_FAILURE; |
Bongjun | 6:e2ab76b2be07 | 198 | return 0; |
Bongjun | 6:e2ab76b2be07 | 199 | } |
Bongjun | 6:e2ab76b2be07 | 200 | |
Bongjun | 6:e2ab76b2be07 | 201 | int W5500Interface::disconnect() |
Bongjun | 6:e2ab76b2be07 | 202 | { |
Bongjun | 6:e2ab76b2be07 | 203 | _w5500.disconnect(); |
Bongjun | 6:e2ab76b2be07 | 204 | return 0; |
Bongjun | 6:e2ab76b2be07 | 205 | } |
Bongjun | 6:e2ab76b2be07 | 206 | |
Bongjun | 6:e2ab76b2be07 | 207 | const char *W5500Interface::get_ip_address() |
Bongjun | 6:e2ab76b2be07 | 208 | { |
Bongjun | 6:e2ab76b2be07 | 209 | uint32_t ip = _w5500.reg_rd<uint32_t>(SIPR); |
Bongjun | 6:e2ab76b2be07 | 210 | snprintf(ip_string, sizeof(ip_string), "%d.%d.%d.%d", (ip>>24)&0xff, (ip>>16)&0xff, (ip>>8)&0xff, ip&0xff); |
Bongjun | 6:e2ab76b2be07 | 211 | return ip_string; |
Bongjun | 6:e2ab76b2be07 | 212 | } |
Bongjun | 6:e2ab76b2be07 | 213 | |
Bongjun | 10:925201b1603f | 214 | const char *W5500Interface::get_netmask() |
Bongjun | 10:925201b1603f | 215 | { |
Bongjun | 10:925201b1603f | 216 | uint32_t netmask = _w5500.reg_rd<uint32_t>(SUBR); |
Bongjun | 10:925201b1603f | 217 | snprintf(netmask_string, sizeof(netmask_string), "%d.%d.%d.%d", (netmask>>24)&0xff, (netmask>>16)&0xff, (netmask>>8)&0xff, netmask&0xff); |
Bongjun | 10:925201b1603f | 218 | return netmask_string; |
Bongjun | 10:925201b1603f | 219 | } |
Bongjun | 10:925201b1603f | 220 | |
Bongjun | 10:925201b1603f | 221 | const char *W5500Interface::get_gateway() |
Bongjun | 10:925201b1603f | 222 | { |
Bongjun | 10:925201b1603f | 223 | uint32_t gateway = _w5500.reg_rd<uint32_t>(GAR); |
Bongjun | 10:925201b1603f | 224 | snprintf(gateway_string, sizeof(gateway_string), "%d.%d.%d.%d", (gateway>>24)&0xff, (gateway>>16)&0xff, (gateway>>8)&0xff, gateway&0xff); |
Bongjun | 10:925201b1603f | 225 | return gateway_string; |
Bongjun | 10:925201b1603f | 226 | } |
Bongjun | 10:925201b1603f | 227 | |
Bongjun | 6:e2ab76b2be07 | 228 | const char *W5500Interface::get_mac_address() |
Bongjun | 6:e2ab76b2be07 | 229 | { |
Bongjun | 6:e2ab76b2be07 | 230 | uint8_t mac[6]; |
Bongjun | 6:e2ab76b2be07 | 231 | _w5500.reg_rd_mac(SHAR, mac); |
Bongjun | 6:e2ab76b2be07 | 232 | snprintf(mac_string, sizeof(mac_string), "%02X:%02X:%02X:%02X:%02X:%02X", mac[0], mac[1], mac[2], mac[3], mac[4], mac[5]); |
Bongjun | 6:e2ab76b2be07 | 233 | return mac_string; |
Bongjun | 6:e2ab76b2be07 | 234 | } |
Bongjun | 6:e2ab76b2be07 | 235 | |
Bongjun | 6:e2ab76b2be07 | 236 | void W5500Interface::get_mac(uint8_t mac[6]) |
Bongjun | 6:e2ab76b2be07 | 237 | { |
Bongjun | 6:e2ab76b2be07 | 238 | _w5500.reg_rd_mac(SHAR, mac); |
Bongjun | 6:e2ab76b2be07 | 239 | } |
Bongjun | 6:e2ab76b2be07 | 240 | |
Bongjun | 6:e2ab76b2be07 | 241 | nsapi_error_t W5500Interface::socket_open(nsapi_socket_t *handle, nsapi_protocol_t proto) |
Bongjun | 6:e2ab76b2be07 | 242 | { |
Bongjun | 6:e2ab76b2be07 | 243 | //a socket is created the same way regardless of the protocol |
Bongjun | 6:e2ab76b2be07 | 244 | int sock_fd = _w5500.new_socket(); |
Bongjun | 6:e2ab76b2be07 | 245 | if (sock_fd < 0) { |
Bongjun | 6:e2ab76b2be07 | 246 | return NSAPI_ERROR_NO_SOCKET; |
Bongjun | 6:e2ab76b2be07 | 247 | } |
Bongjun | 6:e2ab76b2be07 | 248 | |
Bongjun | 6:e2ab76b2be07 | 249 | w5500_socket *h = get_sock(sock_fd); |
Bongjun | 6:e2ab76b2be07 | 250 | |
Bongjun | 6:e2ab76b2be07 | 251 | if (!h) { |
Bongjun | 6:e2ab76b2be07 | 252 | return NSAPI_ERROR_NO_SOCKET; |
Bongjun | 6:e2ab76b2be07 | 253 | } |
Bongjun | 6:e2ab76b2be07 | 254 | |
Bongjun | 6:e2ab76b2be07 | 255 | h->proto = proto; |
Bongjun | 6:e2ab76b2be07 | 256 | h->connected = false; |
Bongjun | 6:e2ab76b2be07 | 257 | h->callback = NULL; |
Bongjun | 6:e2ab76b2be07 | 258 | h->callback_data = NULL; |
Bongjun | 6:e2ab76b2be07 | 259 | |
Bongjun | 6:e2ab76b2be07 | 260 | //new up an int to store the socket fd |
Bongjun | 6:e2ab76b2be07 | 261 | *handle = h; |
Bongjun | 6:e2ab76b2be07 | 262 | DBG("fd: %d\n", sock_fd); |
Bongjun | 6:e2ab76b2be07 | 263 | return 0; |
Bongjun | 6:e2ab76b2be07 | 264 | } |
Bongjun | 6:e2ab76b2be07 | 265 | |
Bongjun | 6:e2ab76b2be07 | 266 | /* |
Bongjun | 6:e2ab76b2be07 | 267 | void W5500Interface::signal_event(nsapi_socket_t handle) |
Bongjun | 6:e2ab76b2be07 | 268 | { |
Bongjun | 6:e2ab76b2be07 | 269 | DBG("fd: %d\n", SKT(handle)->fd); |
Bongjun | 6:e2ab76b2be07 | 270 | if (SKT(handle)->callback != NULL) { |
Bongjun | 6:e2ab76b2be07 | 271 | SKT(handle)->callback(SKT(handle)->callback_data); |
Bongjun | 6:e2ab76b2be07 | 272 | } |
Bongjun | 6:e2ab76b2be07 | 273 | } |
Bongjun | 6:e2ab76b2be07 | 274 | */ |
Bongjun | 6:e2ab76b2be07 | 275 | |
Bongjun | 6:e2ab76b2be07 | 276 | nsapi_error_t W5500Interface::socket_close(nsapi_socket_t handle) |
Bongjun | 6:e2ab76b2be07 | 277 | { |
Bongjun | 6:e2ab76b2be07 | 278 | if (handle == NULL) return 0; |
Bongjun | 6:e2ab76b2be07 | 279 | DBG("fd: %d\n", SKT(handle)->fd); |
Bongjun | 6:e2ab76b2be07 | 280 | _w5500.close(SKT(handle)->fd); |
Bongjun | 6:e2ab76b2be07 | 281 | |
Bongjun | 6:e2ab76b2be07 | 282 | SKT(handle)->fd = -1; |
Bongjun | 6:e2ab76b2be07 | 283 | |
Bongjun | 6:e2ab76b2be07 | 284 | return 0; |
Bongjun | 6:e2ab76b2be07 | 285 | } |
Bongjun | 6:e2ab76b2be07 | 286 | |
Bongjun | 6:e2ab76b2be07 | 287 | nsapi_error_t W5500Interface::socket_bind(nsapi_socket_t handle, const SocketAddress &address) |
Bongjun | 6:e2ab76b2be07 | 288 | { |
Bongjun | 6:e2ab76b2be07 | 289 | if (handle < 0) { |
Bongjun | 6:e2ab76b2be07 | 290 | return NSAPI_ERROR_DEVICE_ERROR; |
Bongjun | 6:e2ab76b2be07 | 291 | } |
Bongjun | 6:e2ab76b2be07 | 292 | DBG("fd: %d, port: %d\n", SKT(handle)->fd, address.get_port()); |
Bongjun | 6:e2ab76b2be07 | 293 | |
Bongjun | 6:e2ab76b2be07 | 294 | switch (SKT(handle)->proto) { |
Bongjun | 6:e2ab76b2be07 | 295 | case NSAPI_UDP: |
Bongjun | 6:e2ab76b2be07 | 296 | // set local port |
Bongjun | 6:e2ab76b2be07 | 297 | if (address.get_port() != 0) { |
Bongjun | 6:e2ab76b2be07 | 298 | _w5500.setLocalPort( SKT(handle)->fd, address.get_port() ); |
Bongjun | 6:e2ab76b2be07 | 299 | } else { |
Bongjun | 6:e2ab76b2be07 | 300 | udp_local_port++; |
Bongjun | 6:e2ab76b2be07 | 301 | _w5500.setLocalPort( SKT(handle)->fd, udp_local_port ); |
Bongjun | 6:e2ab76b2be07 | 302 | } |
Bongjun | 6:e2ab76b2be07 | 303 | // set udp protocol |
Bongjun | 6:e2ab76b2be07 | 304 | _w5500.setProtocol(SKT(handle)->fd, UDP); |
Bongjun | 6:e2ab76b2be07 | 305 | _w5500.scmd(SKT(handle)->fd, OPEN); |
Bongjun | 6:e2ab76b2be07 | 306 | /* |
Bongjun | 6:e2ab76b2be07 | 307 | uint8_t tmpSn_SR; |
Bongjun | 6:e2ab76b2be07 | 308 | tmpSn_SR = _w5500.sreg<uint8_t>(SKT(handle)->fd, Sn_SR); |
Bongjun | 6:e2ab76b2be07 | 309 | DBG("open socket status: %2x\n", tmpSn_SR); |
Bongjun | 6:e2ab76b2be07 | 310 | */ |
Bongjun | 6:e2ab76b2be07 | 311 | return 0; |
Bongjun | 6:e2ab76b2be07 | 312 | case NSAPI_TCP: |
Bongjun | 6:e2ab76b2be07 | 313 | listen_port = address.get_port(); |
Bongjun | 6:e2ab76b2be07 | 314 | // set TCP protocol |
Bongjun | 6:e2ab76b2be07 | 315 | _w5500.setProtocol(SKT(handle)->fd, TCP); |
Bongjun | 6:e2ab76b2be07 | 316 | // set local port |
Bongjun | 6:e2ab76b2be07 | 317 | _w5500.setLocalPort( SKT(handle)->fd, address.get_port() ); |
Bongjun | 6:e2ab76b2be07 | 318 | // connect the network |
Bongjun | 6:e2ab76b2be07 | 319 | _w5500.scmd(SKT(handle)->fd, OPEN); |
Bongjun | 6:e2ab76b2be07 | 320 | return 0; |
Bongjun | 6:e2ab76b2be07 | 321 | } |
Bongjun | 6:e2ab76b2be07 | 322 | |
Bongjun | 6:e2ab76b2be07 | 323 | return NSAPI_ERROR_DEVICE_ERROR; |
Bongjun | 6:e2ab76b2be07 | 324 | } |
Bongjun | 6:e2ab76b2be07 | 325 | |
Bongjun | 6:e2ab76b2be07 | 326 | nsapi_error_t W5500Interface::socket_listen(nsapi_socket_t handle, int backlog) |
Bongjun | 6:e2ab76b2be07 | 327 | { |
Bongjun | 6:e2ab76b2be07 | 328 | DBG("fd: %d\n", SKT(handle)->fd); |
Bongjun | 6:e2ab76b2be07 | 329 | if (SKT(handle)->fd < 0) { |
Bongjun | 6:e2ab76b2be07 | 330 | return NSAPI_ERROR_NO_SOCKET; |
Bongjun | 6:e2ab76b2be07 | 331 | } |
Bongjun | 6:e2ab76b2be07 | 332 | /* if (backlog != 1) { |
Bongjun | 6:e2ab76b2be07 | 333 | return NSAPI_ERROR_NO_SOCKET; |
Bongjun | 6:e2ab76b2be07 | 334 | } |
Bongjun | 6:e2ab76b2be07 | 335 | */ |
Bongjun | 6:e2ab76b2be07 | 336 | _w5500.scmd(SKT(handle)->fd, LISTEN); |
Bongjun | 6:e2ab76b2be07 | 337 | return 0; |
Bongjun | 6:e2ab76b2be07 | 338 | } |
Bongjun | 6:e2ab76b2be07 | 339 | |
Bongjun | 6:e2ab76b2be07 | 340 | nsapi_size_or_error_t W5500Interface::socket_connect(nsapi_socket_t handle, const SocketAddress &address) |
Bongjun | 6:e2ab76b2be07 | 341 | { |
Bongjun | 6:e2ab76b2be07 | 342 | DBG("fd: %d\n", SKT(handle)->fd); |
Bongjun | 6:e2ab76b2be07 | 343 | //check for a valid socket |
Bongjun | 6:e2ab76b2be07 | 344 | if (SKT(handle)->fd < 0) { |
Bongjun | 6:e2ab76b2be07 | 345 | return NSAPI_ERROR_NO_SOCKET; |
Bongjun | 6:e2ab76b2be07 | 346 | } |
Bongjun | 6:e2ab76b2be07 | 347 | |
Bongjun | 6:e2ab76b2be07 | 348 | //before we attempt to connect, we are not connected |
Bongjun | 6:e2ab76b2be07 | 349 | SKT(handle)->connected = false; |
Bongjun | 6:e2ab76b2be07 | 350 | |
Bongjun | 6:e2ab76b2be07 | 351 | //try to connect |
Bongjun | 6:e2ab76b2be07 | 352 | if (!_w5500.connect(SKT(handle)->fd, address.get_ip_address(), address.get_port(), 0)) { |
Bongjun | 6:e2ab76b2be07 | 353 | return -1; |
Bongjun | 6:e2ab76b2be07 | 354 | } |
Bongjun | 6:e2ab76b2be07 | 355 | |
Bongjun | 6:e2ab76b2be07 | 356 | //we are now connected |
Bongjun | 6:e2ab76b2be07 | 357 | SKT(handle)->connected = true; |
Bongjun | 6:e2ab76b2be07 | 358 | |
Bongjun | 6:e2ab76b2be07 | 359 | return 0; |
Bongjun | 6:e2ab76b2be07 | 360 | } |
Bongjun | 6:e2ab76b2be07 | 361 | |
Bongjun | 6:e2ab76b2be07 | 362 | nsapi_error_t W5500Interface::socket_accept(nsapi_socket_t server, nsapi_socket_t *handle, SocketAddress *address) |
Bongjun | 6:e2ab76b2be07 | 363 | { |
Bongjun | 6:e2ab76b2be07 | 364 | SocketAddress _addr; |
Bongjun | 6:e2ab76b2be07 | 365 | |
Bongjun | 6:e2ab76b2be07 | 366 | DBG("fd: %d\n", SKT(handle)->fd); |
Bongjun | 6:e2ab76b2be07 | 367 | if (SKT(server)->fd < 0) { |
Bongjun | 6:e2ab76b2be07 | 368 | return NSAPI_ERROR_NO_SOCKET; |
Bongjun | 6:e2ab76b2be07 | 369 | } |
Bongjun | 6:e2ab76b2be07 | 370 | |
Bongjun | 6:e2ab76b2be07 | 371 | SKT(server)->connected = false; |
Bongjun | 6:e2ab76b2be07 | 372 | |
Bongjun | 6:e2ab76b2be07 | 373 | Timer t; |
Bongjun | 6:e2ab76b2be07 | 374 | t.reset(); |
Bongjun | 6:e2ab76b2be07 | 375 | t.start(); |
Bongjun | 6:e2ab76b2be07 | 376 | |
Bongjun | 6:e2ab76b2be07 | 377 | while(1) { |
Bongjun | 6:e2ab76b2be07 | 378 | if (t.read_ms() > w5500_ACCEPT_TIMEOUT) { |
Bongjun | 6:e2ab76b2be07 | 379 | printf("W5500Interface::socket_accept, timed out\r\n"); |
Bongjun | 6:e2ab76b2be07 | 380 | return NSAPI_ERROR_WOULD_BLOCK; |
Bongjun | 6:e2ab76b2be07 | 381 | } |
Bongjun | 6:e2ab76b2be07 | 382 | if (_w5500.is_connected(SKT(server)->fd)) break; |
Bongjun | 6:e2ab76b2be07 | 383 | } |
Bongjun | 6:e2ab76b2be07 | 384 | |
Bongjun | 6:e2ab76b2be07 | 385 | //get socket for the connection |
Bongjun | 6:e2ab76b2be07 | 386 | *handle = get_sock(SKT(server)->fd); |
Bongjun | 6:e2ab76b2be07 | 387 | |
Bongjun | 6:e2ab76b2be07 | 388 | if (!(*handle)) { |
Bongjun | 6:e2ab76b2be07 | 389 | error("No more sockets for binding"); |
Bongjun | 6:e2ab76b2be07 | 390 | return NSAPI_ERROR_NO_SOCKET; |
Bongjun | 6:e2ab76b2be07 | 391 | } |
Bongjun | 6:e2ab76b2be07 | 392 | |
Bongjun | 6:e2ab76b2be07 | 393 | //give it all of the socket info from the server |
Bongjun | 6:e2ab76b2be07 | 394 | SKT(*handle)->proto = SKT(server)->proto; |
Bongjun | 6:e2ab76b2be07 | 395 | SKT(*handle)->connected = true; |
Bongjun | 6:e2ab76b2be07 | 396 | |
Bongjun | 6:e2ab76b2be07 | 397 | if (address) { |
Bongjun | 6:e2ab76b2be07 | 398 | uint32_t ip = _w5500.sreg<uint32_t>(SKT(*handle)->fd, Sn_DIPR); |
Bongjun | 6:e2ab76b2be07 | 399 | char host[17]; |
Bongjun | 6:e2ab76b2be07 | 400 | snprintf(host, sizeof(host), "%d.%d.%d.%d", (ip>>24)&0xff, (ip>>16)&0xff, (ip>>8)&0xff, ip&0xff); |
Bongjun | 6:e2ab76b2be07 | 401 | int port = _w5500.sreg<uint16_t>(SKT(*handle)->fd, Sn_DPORT); |
Bongjun | 6:e2ab76b2be07 | 402 | |
Bongjun | 6:e2ab76b2be07 | 403 | _addr.set_ip_address(host); |
Bongjun | 6:e2ab76b2be07 | 404 | _addr.set_port(port); |
Bongjun | 6:e2ab76b2be07 | 405 | *address = _addr; |
Bongjun | 6:e2ab76b2be07 | 406 | } |
Bongjun | 6:e2ab76b2be07 | 407 | |
Bongjun | 6:e2ab76b2be07 | 408 | |
Bongjun | 6:e2ab76b2be07 | 409 | //create a new tcp socket for the server |
Bongjun | 6:e2ab76b2be07 | 410 | SKT(server)->fd = _w5500.new_socket(); |
Bongjun | 6:e2ab76b2be07 | 411 | if (SKT(server)->fd < 0) { |
Bongjun | 6:e2ab76b2be07 | 412 | error("No more sockets for listening"); |
Bongjun | 6:e2ab76b2be07 | 413 | //return NSAPI_ERROR_NO_SOCKET; |
Bongjun | 6:e2ab76b2be07 | 414 | // already accepted socket, so return 0, but there is no listen socket anymore. |
Bongjun | 6:e2ab76b2be07 | 415 | return 0; |
Bongjun | 6:e2ab76b2be07 | 416 | } |
Bongjun | 6:e2ab76b2be07 | 417 | |
Bongjun | 6:e2ab76b2be07 | 418 | SKT(server)->proto = NSAPI_TCP; |
Bongjun | 6:e2ab76b2be07 | 419 | SKT(server)->connected = false; |
Bongjun | 6:e2ab76b2be07 | 420 | |
Bongjun | 6:e2ab76b2be07 | 421 | _addr.set_port(listen_port); |
Bongjun | 6:e2ab76b2be07 | 422 | |
Bongjun | 6:e2ab76b2be07 | 423 | // and then, for the next connection, server socket should be assigned new one. |
Bongjun | 6:e2ab76b2be07 | 424 | if (socket_bind(server, _addr) < 0) { |
Bongjun | 6:e2ab76b2be07 | 425 | error("No more sockets for listening"); |
Bongjun | 6:e2ab76b2be07 | 426 | //return NSAPI_ERROR_NO_SOCKET; |
Bongjun | 6:e2ab76b2be07 | 427 | // already accepted socket, so return 0, but there is no listen socket anymore. |
Bongjun | 6:e2ab76b2be07 | 428 | return 0; |
Bongjun | 6:e2ab76b2be07 | 429 | } |
Bongjun | 6:e2ab76b2be07 | 430 | |
Bongjun | 6:e2ab76b2be07 | 431 | if (socket_listen(server, 1) < 0) { |
Bongjun | 6:e2ab76b2be07 | 432 | error("No more sockets for listening"); |
Bongjun | 6:e2ab76b2be07 | 433 | // already accepted socket, so return 0, but there is no listen socket anymore. |
Bongjun | 6:e2ab76b2be07 | 434 | return 0; |
Bongjun | 6:e2ab76b2be07 | 435 | } |
Bongjun | 6:e2ab76b2be07 | 436 | |
Bongjun | 6:e2ab76b2be07 | 437 | return 0; |
Bongjun | 6:e2ab76b2be07 | 438 | } |
Bongjun | 6:e2ab76b2be07 | 439 | |
Bongjun | 6:e2ab76b2be07 | 440 | nsapi_size_or_error_t W5500Interface::socket_send(nsapi_socket_t handle, const void *data, nsapi_size_t size) |
Bongjun | 6:e2ab76b2be07 | 441 | { |
Bongjun | 6:e2ab76b2be07 | 442 | DBG("fd: %d\n", SKT(handle)->fd); |
Bongjun | 6:e2ab76b2be07 | 443 | int writtenLen = 0; |
Bongjun | 6:e2ab76b2be07 | 444 | while (writtenLen < size) { |
Bongjun | 6:e2ab76b2be07 | 445 | int _size = _w5500.wait_writeable(SKT(handle)->fd, w5500_WAIT_TIMEOUT); |
Bongjun | 6:e2ab76b2be07 | 446 | if (_size < 0) { |
Bongjun | 6:e2ab76b2be07 | 447 | return NSAPI_ERROR_WOULD_BLOCK; |
Bongjun | 6:e2ab76b2be07 | 448 | } |
Bongjun | 6:e2ab76b2be07 | 449 | if (_size > (size-writtenLen)) { |
Bongjun | 6:e2ab76b2be07 | 450 | _size = (size-writtenLen); |
Bongjun | 6:e2ab76b2be07 | 451 | } |
Bongjun | 6:e2ab76b2be07 | 452 | int ret = _w5500.send(SKT(handle)->fd, (char*)data, (int)_size); |
Bongjun | 6:e2ab76b2be07 | 453 | if (ret < 0) { |
Bongjun | 6:e2ab76b2be07 | 454 | DBG("returning error -1\n"); |
Bongjun | 6:e2ab76b2be07 | 455 | return -1; |
Bongjun | 6:e2ab76b2be07 | 456 | } |
Bongjun | 6:e2ab76b2be07 | 457 | writtenLen += ret; |
Bongjun | 6:e2ab76b2be07 | 458 | } |
Bongjun | 6:e2ab76b2be07 | 459 | return writtenLen; |
Bongjun | 6:e2ab76b2be07 | 460 | } |
Bongjun | 6:e2ab76b2be07 | 461 | |
Bongjun | 6:e2ab76b2be07 | 462 | nsapi_size_or_error_t W5500Interface::socket_recv(nsapi_socket_t handle, void *data, nsapi_size_t size) |
Bongjun | 6:e2ab76b2be07 | 463 | { |
Bongjun | 6:e2ab76b2be07 | 464 | DBG("fd: %d\n", SKT(handle)->fd); |
Bongjun | 6:e2ab76b2be07 | 465 | // add to cover exception. |
Bongjun | 6:e2ab76b2be07 | 466 | if ((SKT(handle)->fd < 0) || !SKT(handle)->connected) { |
Bongjun | 6:e2ab76b2be07 | 467 | return -1; |
Bongjun | 6:e2ab76b2be07 | 468 | } |
Bongjun | 6:e2ab76b2be07 | 469 | |
Bongjun | 6:e2ab76b2be07 | 470 | int _size = _w5500.wait_readable(SKT(handle)->fd, w5500_WAIT_TIMEOUT); |
Bongjun | 6:e2ab76b2be07 | 471 | |
Bongjun | 6:e2ab76b2be07 | 472 | if (_size < 0) { |
Bongjun | 6:e2ab76b2be07 | 473 | return NSAPI_ERROR_WOULD_BLOCK; |
Bongjun | 6:e2ab76b2be07 | 474 | } |
Bongjun | 6:e2ab76b2be07 | 475 | |
Bongjun | 6:e2ab76b2be07 | 476 | if (_size > size) { |
Bongjun | 6:e2ab76b2be07 | 477 | _size = size; |
Bongjun | 6:e2ab76b2be07 | 478 | } |
Bongjun | 6:e2ab76b2be07 | 479 | return _w5500.recv(SKT(handle)->fd, (char*)data, (int)_size); |
Bongjun | 6:e2ab76b2be07 | 480 | } |
Bongjun | 6:e2ab76b2be07 | 481 | |
Bongjun | 6:e2ab76b2be07 | 482 | nsapi_size_or_error_t W5500Interface::socket_sendto(nsapi_socket_t handle, const SocketAddress &address, |
Bongjun | 6:e2ab76b2be07 | 483 | const void *data, nsapi_size_t size) |
Bongjun | 6:e2ab76b2be07 | 484 | { |
Bongjun | 6:e2ab76b2be07 | 485 | DBG("fd: %d, ip: %s:%d\n", SKT(handle)->fd, address.get_ip_address(), address.get_port()); |
Bongjun | 6:e2ab76b2be07 | 486 | if (_w5500.is_closed(SKT(handle)->fd)) { |
Bongjun | 6:e2ab76b2be07 | 487 | nsapi_error_t err = socket_bind(handle, address); |
Bongjun | 6:e2ab76b2be07 | 488 | if (err < 0 ) { |
Bongjun | 6:e2ab76b2be07 | 489 | DBG("failed to bind socket: %d\n", err); |
Bongjun | 6:e2ab76b2be07 | 490 | return err; |
Bongjun | 6:e2ab76b2be07 | 491 | } |
Bongjun | 6:e2ab76b2be07 | 492 | } |
Bongjun | 6:e2ab76b2be07 | 493 | //compare with original: int size = eth->wait_writeable(_sock_fd, _blocking ? -1 : _timeout, length-1); |
Bongjun | 6:e2ab76b2be07 | 494 | int len = _w5500.wait_writeable(SKT(handle)->fd, w5500_WAIT_TIMEOUT, size-1); |
Bongjun | 6:e2ab76b2be07 | 495 | if (len < 0) { |
Bongjun | 6:e2ab76b2be07 | 496 | DBG("error: NSAPI_ERROR_WOULD_BLOCK\n"); |
Bongjun | 6:e2ab76b2be07 | 497 | return NSAPI_ERROR_WOULD_BLOCK;; |
Bongjun | 6:e2ab76b2be07 | 498 | } |
Bongjun | 6:e2ab76b2be07 | 499 | |
Bongjun | 6:e2ab76b2be07 | 500 | // set remote host |
Bongjun | 6:e2ab76b2be07 | 501 | _w5500.sreg_ip(SKT(handle)->fd, Sn_DIPR, address.get_ip_address()); |
Bongjun | 6:e2ab76b2be07 | 502 | // set remote port |
Bongjun | 6:e2ab76b2be07 | 503 | _w5500.sreg<uint16_t>(SKT(handle)->fd, Sn_DPORT, address.get_port()); |
Bongjun | 6:e2ab76b2be07 | 504 | |
Bongjun | 6:e2ab76b2be07 | 505 | nsapi_size_or_error_t err = _w5500.send(SKT(handle)->fd, (const char*)data, size); |
Bongjun | 6:e2ab76b2be07 | 506 | DBG("rv: %d, size: %d\n", err, size); |
Bongjun | 6:e2ab76b2be07 | 507 | |
Bongjun | 6:e2ab76b2be07 | 508 | #if w5500_INTF_DBG |
Bongjun | 6:e2ab76b2be07 | 509 | if (err > 0) { |
Bongjun | 6:e2ab76b2be07 | 510 | debug("[socket_sendto] data: "); |
Bongjun | 6:e2ab76b2be07 | 511 | for(int i = 0; i < err; i++) { |
Bongjun | 6:e2ab76b2be07 | 512 | if ((i%16) == 0) { |
Bongjun | 6:e2ab76b2be07 | 513 | debug("\n"); |
Bongjun | 6:e2ab76b2be07 | 514 | } |
Bongjun | 6:e2ab76b2be07 | 515 | debug(" %02x", ((uint8_t*)data)[i]); |
Bongjun | 6:e2ab76b2be07 | 516 | } |
Bongjun | 6:e2ab76b2be07 | 517 | if ((err-1%16) != 0) { |
Bongjun | 6:e2ab76b2be07 | 518 | debug("\n"); |
Bongjun | 6:e2ab76b2be07 | 519 | } |
Bongjun | 6:e2ab76b2be07 | 520 | } |
Bongjun | 6:e2ab76b2be07 | 521 | #endif |
Bongjun | 6:e2ab76b2be07 | 522 | return err; |
Bongjun | 6:e2ab76b2be07 | 523 | } |
Bongjun | 6:e2ab76b2be07 | 524 | |
Bongjun | 6:e2ab76b2be07 | 525 | nsapi_size_or_error_t W5500Interface::socket_recvfrom(nsapi_socket_t handle, SocketAddress *address, |
Bongjun | 6:e2ab76b2be07 | 526 | void *buffer, nsapi_size_t size) |
Bongjun | 6:e2ab76b2be07 | 527 | { |
Bongjun | 6:e2ab76b2be07 | 528 | DBG("fd: %d\n", SKT(handle)->fd); |
Bongjun | 6:e2ab76b2be07 | 529 | //check for null pointers |
Bongjun | 6:e2ab76b2be07 | 530 | if (buffer == NULL) { |
Bongjun | 6:e2ab76b2be07 | 531 | DBG("buffer is NULL; receive is ABORTED\n"); |
Bongjun | 6:e2ab76b2be07 | 532 | return -1; |
Bongjun | 6:e2ab76b2be07 | 533 | } |
Bongjun | 6:e2ab76b2be07 | 534 | |
Bongjun | 6:e2ab76b2be07 | 535 | uint8_t info[8]; |
Bongjun | 6:e2ab76b2be07 | 536 | int len = _w5500.wait_readable(SKT(handle)->fd, w5500_WAIT_TIMEOUT, sizeof(info)); |
Bongjun | 6:e2ab76b2be07 | 537 | if (len < 0) { |
Bongjun | 6:e2ab76b2be07 | 538 | DBG("error: NSAPI_ERROR_WOULD_BLOCK\n"); |
Bongjun | 6:e2ab76b2be07 | 539 | return NSAPI_ERROR_WOULD_BLOCK; |
Bongjun | 6:e2ab76b2be07 | 540 | } |
Bongjun | 6:e2ab76b2be07 | 541 | |
Bongjun | 6:e2ab76b2be07 | 542 | //receive endpoint information |
Bongjun | 6:e2ab76b2be07 | 543 | _w5500.recv(SKT(handle)->fd, (char*)info, sizeof(info)); |
Bongjun | 6:e2ab76b2be07 | 544 | |
Bongjun | 6:e2ab76b2be07 | 545 | char addr[17]; |
Bongjun | 6:e2ab76b2be07 | 546 | snprintf(addr, sizeof(addr), "%d.%d.%d.%d", info[0], info[1], info[2], info[3]); |
Bongjun | 6:e2ab76b2be07 | 547 | uint16_t port = info[4]<<8|info[5]; |
Bongjun | 6:e2ab76b2be07 | 548 | // original behavior was to terminate execution if address is NULL |
Bongjun | 6:e2ab76b2be07 | 549 | if (address != NULL) { |
Bongjun | 6:e2ab76b2be07 | 550 | //DBG("[socket_recvfrom] warn: addressis NULL"); |
Bongjun | 6:e2ab76b2be07 | 551 | address->set_ip_address(addr); |
Bongjun | 6:e2ab76b2be07 | 552 | address->set_port(port); |
Bongjun | 6:e2ab76b2be07 | 553 | } |
Bongjun | 6:e2ab76b2be07 | 554 | |
Bongjun | 6:e2ab76b2be07 | 555 | int udp_size = info[6]<<8|info[7]; |
Bongjun | 6:e2ab76b2be07 | 556 | |
Bongjun | 6:e2ab76b2be07 | 557 | if (udp_size > (len-sizeof(info))) { |
Bongjun | 6:e2ab76b2be07 | 558 | DBG("error: udp_size > (len-sizeof(info))\n"); |
Bongjun | 6:e2ab76b2be07 | 559 | return -1; |
Bongjun | 6:e2ab76b2be07 | 560 | } |
Bongjun | 6:e2ab76b2be07 | 561 | |
Bongjun | 6:e2ab76b2be07 | 562 | //receive from socket |
Bongjun | 6:e2ab76b2be07 | 563 | nsapi_size_or_error_t err = _w5500.recv(SKT(handle)->fd, (char*)buffer, udp_size); |
Bongjun | 6:e2ab76b2be07 | 564 | DBG("rv: %d\n", err); |
Bongjun | 6:e2ab76b2be07 | 565 | #if w5500_INTF_DBG |
Bongjun | 6:e2ab76b2be07 | 566 | if (err > 0) { |
Bongjun | 6:e2ab76b2be07 | 567 | debug("[socket_recvfrom] buffer:"); |
Bongjun | 6:e2ab76b2be07 | 568 | for(int i = 0; i < err; i++) { |
Bongjun | 6:e2ab76b2be07 | 569 | if ((i%16) == 0) { |
Bongjun | 6:e2ab76b2be07 | 570 | debug("\n"); |
Bongjun | 6:e2ab76b2be07 | 571 | } |
Bongjun | 6:e2ab76b2be07 | 572 | debug(" %02x", ((uint8_t*)buffer)[i]); |
Bongjun | 6:e2ab76b2be07 | 573 | } |
Bongjun | 6:e2ab76b2be07 | 574 | if ((err-1%16) != 0) { |
Bongjun | 6:e2ab76b2be07 | 575 | debug("\n"); |
Bongjun | 6:e2ab76b2be07 | 576 | } |
Bongjun | 6:e2ab76b2be07 | 577 | } |
Bongjun | 6:e2ab76b2be07 | 578 | #endif |
Bongjun | 6:e2ab76b2be07 | 579 | return err; |
Bongjun | 6:e2ab76b2be07 | 580 | } |
Bongjun | 6:e2ab76b2be07 | 581 | |
Bongjun | 6:e2ab76b2be07 | 582 | void W5500Interface::socket_attach(void *handle, void (*callback)(void *), void *data) |
Bongjun | 6:e2ab76b2be07 | 583 | { |
Bongjun | 6:e2ab76b2be07 | 584 | /* |
Bongjun | 6:e2ab76b2be07 | 585 | if (handle == NULL) return; |
Bongjun | 6:e2ab76b2be07 | 586 | DBG("fd: %d, callback: %p\n", SKT(handle)->fd, callback); |
Bongjun | 6:e2ab76b2be07 | 587 | SKT(handle)->callback = callback; |
Bongjun | 6:e2ab76b2be07 | 588 | SKT(handle)->callback_data = data; |
Bongjun | 6:e2ab76b2be07 | 589 | */ |
Bongjun | 6:e2ab76b2be07 | 590 | if (handle == NULL) return; |
Bongjun | 6:e2ab76b2be07 | 591 | w5500_socket *socket = (w5500_socket *)handle; |
Bongjun | 6:e2ab76b2be07 | 592 | w5500_sockets[socket->fd].callback = callback; |
Bongjun | 6:e2ab76b2be07 | 593 | w5500_sockets[socket->fd].callback_data = data; |
Bongjun | 6:e2ab76b2be07 | 594 | } |
Bongjun | 6:e2ab76b2be07 | 595 | |
Bongjun | 6:e2ab76b2be07 | 596 | /* |
Bongjun | 6:e2ab76b2be07 | 597 | void W5500Interface::event() |
Bongjun | 6:e2ab76b2be07 | 598 | { |
Bongjun | 6:e2ab76b2be07 | 599 | for(int i=0; i<MAX_SOCK_NUM; i++){ |
Bongjun | 6:e2ab76b2be07 | 600 | if (w5500_sockets[i].callback) { |
Bongjun | 6:e2ab76b2be07 | 601 | w5500_sockets[i].callback(w5500_sockets[i].data); |
Bongjun | 6:e2ab76b2be07 | 602 | } |
Bongjun | 6:e2ab76b2be07 | 603 | } |
Bongjun | 6:e2ab76b2be07 | 604 | } |
Bongjun | 6:e2ab76b2be07 | 605 | */ |