MQTT client test with W5200 ethernet shield
Dependents: IBMIoTClientEthernetExample_W5200
Fork of W5500Interface by
Revision 11:313e091ab3f9, committed 2014-12-25
- Comitter:
- hillkim7
- Date:
- Thu Dec 25 11:18:46 2014 +0000
- Parent:
- 7:da52bf0e0e5d
- Commit message:
- The IBM MQTT client demo program that is tested with Nucleo F401 and Seeedstudio Ethernet Shield. It is based on Wiznet sample program.
Changed in this revision
diff -r da52bf0e0e5d -r 313e091ab3f9 WIZnet/W5200.cpp --- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/WIZnet/W5200.cpp Thu Dec 25 11:18:46 2014 +0000 @@ -0,0 +1,414 @@ +/* Copyright (C) 2012 mbed.org, MIT License + * + * Permission is hereby granted, free of charge, to any person obtaining a copy of this software + * and associated documentation files (the "Software"), to deal in the Software without restriction, + * including without limitation the rights to use, copy, modify, merge, publish, distribute, + * sublicense, and/or sell copies of the Software, and to permit persons to whom the Software is + * furnished to do so, subject to the following conditions: + * + * The above copyright notice and this permission notice shall be included in all copies or + * substantial portions of the Software. + * + * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING + * BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND + * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, + * DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, + * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE. + */ + +#include "mbed.h" +#include "mbed_debug.h" +#include "wiznet.h" +#include "DNSClient.h" + +#ifdef USE_W5200 + +//Debug is disabled by default +#if 0 +#define DBG(...) do{debug("%p %d %s ", this,__LINE__,__PRETTY_FUNCTION__); debug(__VA_ARGS__); } while(0); +//#define DBG(x, ...) debug("[WIZnet_Chip:DBG]"x"\r\n", ##__VA_ARGS__); +#define WARN(x, ...) debug("[WIZnet_Chip:WARN]"x"\r\n", ##__VA_ARGS__); +#define ERR(x, ...) debug("[WIZnet_Chip:ERR]"x"\r\n", ##__VA_ARGS__); +#else +#define DBG(x, ...) +#define WARN(x, ...) +#define ERR(x, ...) +#endif + +#if 1 +#define INFO(x, ...) debug("[WIZnet_Chip:INFO]"x"\r\n", ##__VA_ARGS__); +#else +#define INFO(x, ...) +#endif + +#if 0 +#define W printf +#else +#define W(x, ...) +#endif + +#define DBG_SPI 0 + +#define W5200_USE_DEFAULT_MAC 1 + +#if W5200_USE_DEFAULT_MAC +// Random MAC +static const uint8_t default_mac[] = {0xD0, 0xAE, 0xBC, 0x11, 0x22, 0x02}; +#endif + +WIZnet_Chip* WIZnet_Chip::inst; + +WIZnet_Chip::WIZnet_Chip(PinName mosi, PinName miso, PinName sclk, PinName _cs, PinName _reset): + cs(_cs), reset_pin(_reset) +{ + spi = new SPI(mosi, miso, sclk); + cs = 1; + reset_pin = 1; + inst = this; +#if W5200_USE_DEFAULT_MAC + memcpy(mac, default_mac, sizeof(default_mac)); +#endif +} + +WIZnet_Chip::WIZnet_Chip(SPI* spi, PinName _cs, PinName _reset): + cs(_cs), reset_pin(_reset) +{ + this->spi = spi; + cs = 1; + reset_pin = 1; + inst = this; +#if W5200_USE_DEFAULT_MAC + memcpy(mac, default_mac, sizeof(default_mac)); +#endif +} + +bool WIZnet_Chip::setmac() +{ + + for (int i =0; i < 6; i++) reg_wr<uint8_t>(SHAR+i, mac[i]); + + return true; +} + +bool WIZnet_Chip::setip() +{ + reg_wr<uint32_t>(SIPR, ip); + reg_wr<uint32_t>(GAR, gateway); + reg_wr<uint32_t>(SUBR, netmask); + return true; +} + +bool WIZnet_Chip::linkstatus() +{ + /* + if ( (reg_rd<uint8_t>(PHYCFGR) & 0x01) != 0x01 ) + return false; + */ + + return true; +} + +bool WIZnet_Chip::setProtocol(int socket, Protocol p) +{ + if (socket < 0) { + return false; + } + sreg<uint8_t>(socket, Sn_MR, p); + return true; +} + +bool WIZnet_Chip::connect(int socket, const char * host, int port, int timeout_ms) +{ + if (socket < 0) { + return false; + } + sreg<uint8_t>(socket, Sn_MR, TCP); + scmd(socket, OPEN); + sreg_ip(socket, Sn_DIPR, host); + sreg<uint16_t>(socket, Sn_DPORT, port); + sreg<uint16_t>(socket, Sn_PORT, new_port()); + scmd(socket, CONNECT); + Timer t; + t.reset(); + t.start(); + while(!is_connected(socket)) { + if (t.read_ms() > timeout_ms) { + return false; + } + } + W("\033[1;36m""{W5200}connect %d""\033[0m""\n", socket); + return true; +} + +bool WIZnet_Chip::gethostbyname(const char* host, uint32_t* ip) +{ + uint32_t addr = str_to_ip(host); + char buf[17]; + snprintf(buf, sizeof(buf), "%d.%d.%d.%d", (addr>>24)&0xff, (addr>>16)&0xff, (addr>>8)&0xff, addr&0xff); + if (strcmp(buf, host) == 0) { + *ip = addr; + return true; + } + DNSClient client; + if(client.lookup(host)) { + *ip = client.ip; + return true; + } + return false; +} + +bool WIZnet_Chip::disconnect() +{ + return true; +} + +bool WIZnet_Chip::is_connected(int socket) +{ + if (sreg<uint8_t>(socket, Sn_SR) == SOCK_ESTABLISHED) { + return true; + } + return false; +} + +void WIZnet_Chip::reset() +{ + reset_pin = 1; + reset_pin = 0; + wait_us(2); // 2us + reset_pin = 1; + wait_ms(150); // 150ms + + reg_wr<uint8_t>(MR, 1<<7); + + reg_wr_mac(SHAR, mac); +} + +bool WIZnet_Chip::close(int socket) +{ + if (socket < 0) { + return false; + } + // if not connected, return + if (sreg<uint8_t>(socket, Sn_SR) == SOCK_CLOSED) { + return true; + } + if (sreg<uint8_t>(socket, Sn_MR) == TCP) { + scmd(socket, DISCON); + } + scmd(socket, CLOSE); + sreg<uint8_t>(socket, Sn_IR, 0xff); + W("\033[1;36m""{W5200}close %d""\033[0m""\n", socket); + return true; +} + +int WIZnet_Chip::wait_readable(int socket, int wait_time_ms, int req_size) +{ + if (socket < 0) { + return -1; + } + Timer t; + t.reset(); + t.start(); + while(1) { + int size = sreg<uint16_t>(socket, Sn_RX_RSR); + if (size > req_size) { + return size; + } + if (wait_time_ms != (-1) && t.read_ms() > wait_time_ms) { + break; + } + } + return -1; +} + +int WIZnet_Chip::wait_writeable(int socket, int wait_time_ms, int req_size) +{ + if (socket < 0) { + return -1; + } + Timer t; + t.reset(); + t.start(); + while(1) { + int size = sreg<uint16_t>(socket, Sn_TX_FSR); + if (size > req_size) { + return size; + } + if (wait_time_ms != (-1) && t.read_ms() > wait_time_ms) { + break; + } + } + return -1; +} + +int WIZnet_Chip::send(int socket, const char * str, int len) +{ + if (socket < 0) { + return -1; + } + uint16_t base = 0x8000 + socket * 0x800; + uint16_t ptr = sreg<uint16_t>(socket, Sn_TX_WR); + uint16_t dst = base + (ptr&(0x800-1)); + if ((dst + len) > (base+0x800)) { + int len2 = base + 0x800 - dst; + spi_write(dst, (uint8_t*)str, len2); + spi_write(base, (uint8_t*)str+len2, len-len2); + } else { + spi_write(dst, (uint8_t*)str, len); + } + sreg<uint16_t>(socket, Sn_TX_WR, ptr + len); + scmd(socket, SEND); + return len; +} + +int WIZnet_Chip::recv(int socket, char* buf, int len) +{ + if (socket < 0) { + return -1; + } + uint16_t base = 0xc000 + socket * 0x800; + uint16_t ptr = sreg<uint16_t>(socket, Sn_RX_RD); + uint16_t src = base + (ptr&(0x800-1)); + if ((src + len) > (base+0x800)) { + int len2 = base + 0x800 - src; + spi_read(src, (uint8_t*)buf, len2); + spi_read(base, (uint8_t*)buf+len2, len-len2); + } else { + spi_read(src, (uint8_t*)buf, len); + } + sreg<uint16_t>(socket, Sn_RX_RD, ptr + len); + scmd(socket, RECV); + return len; +} + +int WIZnet_Chip::new_socket() +{ + for(int s = 0; s < 8; s++) { + if (sreg<uint8_t>(s, Sn_SR) == SOCK_CLOSED) { + return s; + } + } + return -1; +} + +uint16_t WIZnet_Chip::new_port() +{ + uint16_t port = rand(); + port |= 49152; + return port; +} + +void WIZnet_Chip::scmd(int socket, Command cmd) +{ + sreg<uint8_t>(socket, Sn_CR, cmd); + while(sreg<uint8_t>(socket, Sn_CR)); +} + +void WIZnet_Chip::spi_write(uint16_t addr, const uint8_t *buf, uint16_t len) +{ + cs = 0; + spi->write(addr >> 8); + spi->write(addr & 0xff); + spi->write((0x80 | ((len & 0x7f00) >> 8))); + spi->write(len & 0xff); + for(int i = 0; i < len; i++) { + spi->write(buf[i]); + } + cs = 1; + +#if DBG_SPI + debug("[SPI]W %04x(%d)", addr, len); + for(int i = 0; i < len; i++) { + debug(" %02x", buf[i]); + if (i > 16) { + debug(" ..."); + break; + } + } + debug("\r\n"); +#endif +} + +void WIZnet_Chip::spi_read(uint16_t addr, uint8_t *buf, uint16_t len) +{ + cs = 0; + spi->write(addr >> 8); + spi->write(addr & 0xff); + spi->write((0x00 | ((len & 0x7f00) >> 8))); + spi->write(len & 0xff); + for(int i = 0; i < len; i++) { + buf[i] = spi->write(0); + } + cs = 1; + +#if DBG_SPI + debug("[SPI]R %04x(%d)", addr, len); + for(int i = 0; i < len; i++) { + debug(" %02x", buf[i]); + if (i > 16) { + debug(" ..."); + break; + } + } + debug("\r\n"); + if ((addr&0xf0ff)==0x4026 || (addr&0xf0ff)==0x4003) { + wait_ms(200); + } +#endif +} + +uint32_t str_to_ip(const char* str) +{ + uint32_t ip = 0; + char* p = (char*)str; + for(int i = 0; i < 4; i++) { + ip |= atoi(p); + p = strchr(p, '.'); + if (p == NULL) { + break; + } + ip <<= 8; + p++; + } + return ip; +} + +void printfBytes(char* str, uint8_t* buf, int len) +{ + printf("%s %d:", str, len); + for(int i = 0; i < len; i++) { + printf(" %02x", buf[i]); + } + printf("\n"); +} + +void printHex(uint8_t* buf, int len) +{ + for(int i = 0; i < len; i++) { + if ((i%16) == 0) { + printf("%p", buf+i); + } + printf(" %02x", buf[i]); + if ((i%16) == 15) { + printf("\n"); + } + } + printf("\n"); +} + +void debug_hex(uint8_t* buf, int len) +{ + for(int i = 0; i < len; i++) { + if ((i%16) == 0) { + debug("%p", buf+i); + } + debug(" %02x", buf[i]); + if ((i%16) == 15) { + debug("\n"); + } + } + debug("\n"); +} + +#endif +
diff -r da52bf0e0e5d -r 313e091ab3f9 WIZnet/W5200.h --- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/WIZnet/W5200.h Thu Dec 25 11:18:46 2014 +0000 @@ -0,0 +1,233 @@ + +#pragma once + +#include "mbed.h" +#include "mbed_debug.h" + +#define TEST_ASSERT(A) while(!(A)){debug("\n\n%s@%d %s ASSERT!\n\n",__PRETTY_FUNCTION__,__LINE__,#A);exit(1);}; + +#define DEFAULT_WAIT_RESP_TIMEOUT 500 + +#define MAX_SOCK_NUM 8 + +#define MR 0x0000 +#define GAR 0x0001 +#define SUBR 0x0005 +#define SHAR 0x0009 +#define SIPR 0x000f +#define PHYCFGR 0x002e + +// W5200 socket +#define Sn_MR 0x4000 +#define Sn_CR 0x4001 +#define Sn_IR 0x4002 +#define Sn_SR 0x4003 +#define Sn_PORT 0x4004 +#define Sn_DIPR 0x400c +#define Sn_DPORT 0x4010 +#define Sn_RXBUF_SIZE 0x401e +#define Sn_TXBUF_SIZE 0x401f +#define Sn_TX_FSR 0x4020 +#define Sn_TX_WR 0x4024 +#define Sn_RX_RSR 0x4026 +#define Sn_RX_RD 0x4028 + +class WIZnet_Chip { +public: + + enum Protocol { CLOSED = 0, TCP = 1, UDP = 2,}; + enum Command { OPEN = 0x01, LISTEN = 0x02, CONNECT = 0x04, DISCON = 0x08, CLOSE = 0x10, SEND = 0x20, \ + SEND_MAC = 0x21, SEND_KEEP = 0x22, RECV = 0x40, }; + enum Interrupt { INT_CON = 0x01, INT_DISCON = 0x02, INT_RECV = 0x04, INT_TIMEOUT = 0x08, INT_SEND_OK = 0x10,}; + + enum Status { SOCK_CLOSED = 0x00, SOCK_INIT = 0x13, SOCK_LISTEN = 0x14, SOCK_SYNSENT = 0x15, SOCK_ESTABLISHED = 0x17, \ + SOCK_CLOSE_WAIT = 0x1c, SOCK_UDP = 0x22, }; + + /* + * Set MAC Address + * + * @return true if connected, false otherwise + */ + bool setmac(); + + /* + * Constructor + * + * @param spi spi class + * @param cs cs of the W5200 + * @param reset reset pin of the W5200 + */ + WIZnet_Chip(PinName mosi, PinName miso, PinName sclk, PinName cs, PinName reset); + WIZnet_Chip(SPI* spi, PinName cs, PinName reset); + + /* + * Connect the W5200 module to the ssid contained in the constructor. + * + * @return true if connected, false otherwise + */ + bool setip(); + + /* + * Get Link Status + * + * @return true if Link up, false Link down + */ + bool linkstatus(); + + /* + * Disconnect the W5200 module from the access point + * + * @ returns true if successful + */ + bool disconnect(); + + /* + * Open a tcp connection with the specified host on the specified port + * + * @param host host (can be either an ip address or a name. If a name is provided, a dns request will be established) + * @param port port + * @ returns true if successful + */ + bool connect(int socket, const char * host, int port, int timeout_ms = 10*1000); + + /* + * Set the protocol (UDP or TCP) + * + * @param p protocol + * @ returns true if successful + */ + bool setProtocol(int socket, Protocol p); + + /* + * Reset the W5200 module + */ + void reset(); + + + int wait_readable(int socket, int wait_time_ms, int req_size = 0); + + int wait_writeable(int socket, int wait_time_ms, int req_size = 0); + + /* + * Check if a tcp link is active + * + * @returns true if successful + */ + bool is_connected(int socket); + + /* + * Close a tcp connection + * + * @ returns true if successful + */ + bool close(int socket); + + /* + * @param str string to be sent + * @param len string length + */ + int send(int socket, const char * str, int len); + + int recv(int socket, char* buf, int len); + + /* + * Return true if the module is using dhcp + * + * @returns true if the module is using dhcp + */ + bool isDHCP() { + return dhcp; + } + + bool gethostbyname(const char* host, uint32_t* ip); + + static WIZnet_Chip * getInstance() { + return inst; + }; + + int new_socket(); + uint16_t new_port(); + void scmd(int socket, Command cmd); + + template<typename T> + void sreg(int socket, uint16_t addr, T data) { + reg_wr<T>(addr+0x100*socket, data); + } + + template<typename T> + T sreg(int socket, uint16_t addr) { + return reg_rd<T>(addr+0x100*socket); + } + + template<typename T> + void reg_wr(uint16_t addr, T data) { + uint8_t buf[sizeof(T)]; + *reinterpret_cast<T*>(buf) = data; + for(int i = 0; i < sizeof(buf)/2; i++) { // Little Endian to Big Endian + uint8_t t = buf[i]; + buf[i] = buf[sizeof(buf)-1-i]; + buf[sizeof(buf)-1-i] = t; + } + spi_write(addr, buf, sizeof(buf)); + } + + template<typename T> + T reg_rd(uint16_t addr) { + uint8_t buf[sizeof(T)]; + spi_read(addr, buf, sizeof(buf)); + for(int i = 0; i < sizeof(buf)/2; i++) { // Big Endian to Little Endian + uint8_t t = buf[i]; + buf[i] = buf[sizeof(buf)-1-i]; + buf[sizeof(buf)-1-i] = t; + } + return *reinterpret_cast<T*>(buf); + } + + void reg_rd_mac(uint16_t addr, uint8_t* data) { + spi_read(addr, data, 6); + } + + void reg_wr_ip(uint16_t addr, const char* ip) { + uint8_t buf[4]; + char* p = (char*)ip; + for(int i = 0; i < 4; i++) { + buf[i] = atoi(p); + p = strchr(p, '.'); + if (p == NULL) { + break; + } + p++; + } + spi_write(addr, buf, sizeof(buf)); + } + + void sreg_ip(int socket, uint16_t addr, const char* ip) { + reg_wr_ip(addr+0x100*socket, ip); + } + +protected: + uint8_t mac[6]; + uint32_t ip; + uint32_t netmask; + uint32_t gateway; + uint32_t dnsaddr; + bool dhcp; + + static WIZnet_Chip* inst; + + void reg_wr_mac(uint16_t addr, uint8_t* data) { + spi_write(addr, data, 6); + } + + void spi_write(uint16_t addr, const uint8_t *buf, uint16_t len); + void spi_read(uint16_t addr, uint8_t *buf, uint16_t len); + SPI* spi; + DigitalOut cs; + DigitalOut reset_pin; +}; + +extern uint32_t str_to_ip(const char* str); +extern void printfBytes(char* str, uint8_t* buf, int len); +extern void printHex(uint8_t* buf, int len); +extern void debug_hex(uint8_t* buf, int len); +
diff -r da52bf0e0e5d -r 313e091ab3f9 WIZnet/wiznet.h --- a/WIZnet/wiznet.h Mon Sep 29 05:03:41 2014 +0000 +++ b/WIZnet/wiznet.h Thu Dec 25 11:18:46 2014 +0000 @@ -4,8 +4,8 @@ //#include "mbed.h" //#include "mbed_debug.h" -#define USE_W5500 -//#define USE_W5200 // don't use this library +//#define USE_W5500 +#define USE_W5200 //#define USE_W5100 // don't use this library #if defined(USE_W5500) @@ -13,12 +13,12 @@ //#define USE_WIZ550IO_MAC // want to use the default MAC address stored in the WIZ550io #endif -/* -// current library don't want to support old chips. #if defined(USE_W5200) #include "W5200.h" #endif +/* +// current library don't want to support old chips. #if defined(USE_W5100) #include "W5100.h" #endif