WIZ820io(W5200) network interface、EthernetNetIf compatible.

/media/uploads/va009039/wiz820ionetif.jpg

example

#include "WIZ820ioNetIf.h"
#include "HTTPClient.h"
#include "HTTPServer.h"

#if defined(TARGET_KL25Z)
WIZ820ioNetIf eth(PTD2,PTD3,PTD1,PTD0,PTD5);
#endif
HTTPClient http;
HTTPStream stream;

void callback(HTTPResult r){
    printf("callback %d %s\n", r, HTTPClient::ResultStr(r));
}

int main() {
    int err = eth.setup();
    if (err < 0) {
        printf("setup error %d\n", err);
        exit(-1);
    }    

    HTTPServer svr;
    svr.addHandler<SimpleHandler>("/");
    svr.bind(80);

    const char* uri = "http://va009039-mbed.appspot.com/kl25z/";
    http.get(uri, &stream, callback);
    uint8_t buf[256];
    int total = 0;
    stream.readNext(buf, sizeof(buf));
    while(1) {
        if(stream.readable()) {
            int len = stream.readLen();
            total += len;
            printf("%d %d\n", total, len);
            stream.readNext(buf, sizeof(buf));
        }
        Net::poll();
    }
}
Committer:
va009039
Date:
Fri Mar 22 11:51:24 2013 +0000
Revision:
0:bdeec5f86894
Child:
1:22b9052d864d
[mbed] converted /w5200NetIf/w5200NetIf

Who changed what in which revision?

UserRevisionLine numberNew contents of line
va009039 0:bdeec5f86894 1 // MyNetTcpSocket.cpp 2012/4/22
va009039 0:bdeec5f86894 2 #include "mbed.h"
va009039 0:bdeec5f86894 3 #include "w5100.h"
va009039 0:bdeec5f86894 4 #include "MyNetTcpSocket.h"
va009039 0:bdeec5f86894 5 //#define __DEBUG
va009039 0:bdeec5f86894 6 #include "dbg/dbg.h"
va009039 0:bdeec5f86894 7
va009039 0:bdeec5f86894 8 #ifdef __DEBUG
va009039 0:bdeec5f86894 9 #define DBG2(...) do{ DebugStream::debug("%p %s ", this,__PRETTY_FUNCTION__); DebugStream::debug(__VA_ARGS__); } while(0);
va009039 0:bdeec5f86894 10 #else
va009039 0:bdeec5f86894 11 #define DBG2(...) while(0);
va009039 0:bdeec5f86894 12 #endif //__DEBUG
va009039 0:bdeec5f86894 13
va009039 0:bdeec5f86894 14 //#define DEBUG
va009039 0:bdeec5f86894 15
va009039 0:bdeec5f86894 16 #ifdef DEBUG
va009039 0:bdeec5f86894 17 #include "Utils.h"
va009039 0:bdeec5f86894 18 #define PRINT_FUNC() printf("%p %d:%s\n", this,__LINE__,__PRETTY_FUNCTION__)
va009039 0:bdeec5f86894 19 #else //DEBUG
va009039 0:bdeec5f86894 20 #define PRINT_FUNC()
va009039 0:bdeec5f86894 21 #endif //DEBUG
va009039 0:bdeec5f86894 22
va009039 0:bdeec5f86894 23 #define USE_NO_DELAYED_ACK 1
va009039 0:bdeec5f86894 24
va009039 0:bdeec5f86894 25 int w5200_new_socket()
va009039 0:bdeec5f86894 26 {
va009039 0:bdeec5f86894 27 for(int i = 0; i < MAX_SOCK_NUM; i++) {
va009039 0:bdeec5f86894 28 if (W5100.readSnMR(i) == SnMR::CLOSE) { // 0x00
va009039 0:bdeec5f86894 29 if (W5100.readSnSR(i) != SnSR::LISTEN) { // 0x14
va009039 0:bdeec5f86894 30 return i;
va009039 0:bdeec5f86894 31 }
va009039 0:bdeec5f86894 32 }
va009039 0:bdeec5f86894 33 }
va009039 0:bdeec5f86894 34 return -1; // not found
va009039 0:bdeec5f86894 35 }
va009039 0:bdeec5f86894 36
va009039 0:bdeec5f86894 37 MyNetTcpSocket::MyNetTcpSocket(int socket) : NetTcpSocket(),_socket(socket),wait_accept(false) {
va009039 0:bdeec5f86894 38 PRINT_FUNC();
va009039 0:bdeec5f86894 39 DBG2("socket: %d\n", socket);
va009039 0:bdeec5f86894 40 if (_socket == (-1)) {
va009039 0:bdeec5f86894 41 _socket = w5200_new_socket();
va009039 0:bdeec5f86894 42 }
va009039 0:bdeec5f86894 43 #ifdef DEBUG
va009039 0:bdeec5f86894 44 printf("%p socket: %d\n", this, _socket);
va009039 0:bdeec5f86894 45 #endif //DEBUG
va009039 0:bdeec5f86894 46 if (_socket != (-1)) {
va009039 0:bdeec5f86894 47 uint8_t Sn_MR = SnMR::TCP; // set TCP mode
va009039 0:bdeec5f86894 48 #if USE_NO_DELAYED_ACK
va009039 0:bdeec5f86894 49 Sn_MR |= SnMR::ND;
va009039 0:bdeec5f86894 50 #endif
va009039 0:bdeec5f86894 51 W5100.writeSnMR(_socket, Sn_MR);
va009039 0:bdeec5f86894 52 }
va009039 0:bdeec5f86894 53 }
va009039 0:bdeec5f86894 54
va009039 0:bdeec5f86894 55 MyNetTcpSocket::~MyNetTcpSocket() {
va009039 0:bdeec5f86894 56 PRINT_FUNC();
va009039 0:bdeec5f86894 57 DBG2("socket=%d\n", _socket);
va009039 0:bdeec5f86894 58 close();
va009039 0:bdeec5f86894 59 if (_socket != (-1)) {
va009039 0:bdeec5f86894 60 W5100.writeSnMR(_socket, SnMR::CLOSE);
va009039 0:bdeec5f86894 61 }
va009039 0:bdeec5f86894 62 }
va009039 0:bdeec5f86894 63
va009039 0:bdeec5f86894 64 NetTcpSocketErr MyNetTcpSocket::bind(const Host& me) {
va009039 0:bdeec5f86894 65 PRINT_FUNC();
va009039 0:bdeec5f86894 66 if (_socket == (-1)) {
va009039 0:bdeec5f86894 67 return NETTCPSOCKET_MEM;
va009039 0:bdeec5f86894 68 }
va009039 0:bdeec5f86894 69 int port = me.getPort();
va009039 0:bdeec5f86894 70 W5100.writeSnPORT(_socket, port);
va009039 0:bdeec5f86894 71 return NETTCPSOCKET_OK;
va009039 0:bdeec5f86894 72 }
va009039 0:bdeec5f86894 73
va009039 0:bdeec5f86894 74 NetTcpSocketErr MyNetTcpSocket::listen() {
va009039 0:bdeec5f86894 75 PRINT_FUNC();
va009039 0:bdeec5f86894 76 if (_socket == (-1)) {
va009039 0:bdeec5f86894 77 return NETTCPSOCKET_MEM;
va009039 0:bdeec5f86894 78 }
va009039 0:bdeec5f86894 79 W5100.execCmdSn(_socket, Sock_OPEN); // set OPEN command
va009039 0:bdeec5f86894 80 W5100.execCmdSn(_socket, Sock_LISTEN); // listen
va009039 0:bdeec5f86894 81 #ifdef DEBUG
va009039 0:bdeec5f86894 82 uint8_t ip[4];
va009039 0:bdeec5f86894 83 printf("socket:%d SnMR:%02x SnIR:%02x SnSR:%02x\n", _socket,
va009039 0:bdeec5f86894 84 W5100.readSnMR(_socket), W5100.readSnIR(_socket), W5100.readSnSR(_socket));
va009039 0:bdeec5f86894 85 W5100.getIPAddress(ip);
va009039 0:bdeec5f86894 86 printf("SIPR: %d.%d.%d.%d Sn_PORT:%d\n", ip[0], ip[1], ip[2], ip[3], W5100.readSnPORT(_socket));
va009039 0:bdeec5f86894 87 #endif //DEBUG
va009039 0:bdeec5f86894 88 wait_accept = true;
va009039 0:bdeec5f86894 89 return NETTCPSOCKET_OK;
va009039 0:bdeec5f86894 90 }
va009039 0:bdeec5f86894 91
va009039 0:bdeec5f86894 92 NetTcpSocketErr MyNetTcpSocket::connect(const Host& host) {
va009039 0:bdeec5f86894 93 PRINT_FUNC();
va009039 0:bdeec5f86894 94 if (_socket == (-1)) {
va009039 0:bdeec5f86894 95 return NETTCPSOCKET_MEM;
va009039 0:bdeec5f86894 96 }
va009039 0:bdeec5f86894 97 uint8_t ip[4];
va009039 0:bdeec5f86894 98 ip[0] = host.getIp()[0];
va009039 0:bdeec5f86894 99 ip[1] = host.getIp()[1];
va009039 0:bdeec5f86894 100 ip[2] = host.getIp()[2];
va009039 0:bdeec5f86894 101 ip[3] = host.getIp()[3];
va009039 0:bdeec5f86894 102 int port = host.getPort();
va009039 0:bdeec5f86894 103 W5100.writeSnDIPR(_socket, ip);
va009039 0:bdeec5f86894 104 W5100.writeSnDPORT(_socket, port);
va009039 0:bdeec5f86894 105 if (W5100.readSnPORT(_socket) == 0) {
va009039 0:bdeec5f86894 106 W5100.writeSnPORT(_socket, 1024 + _socket);
va009039 0:bdeec5f86894 107 }
va009039 0:bdeec5f86894 108 W5100.execCmdSn(_socket, Sock_OPEN); // set OPEN command
va009039 0:bdeec5f86894 109 W5100.execCmdSn(_socket, Sock_CONNECT);
va009039 0:bdeec5f86894 110 #ifdef DEBUG
va009039 0:bdeec5f86894 111 printf("socket:%d SnMR:%02x SnIR:%02x SnSR:%02x\n", _socket,
va009039 0:bdeec5f86894 112 W5100.readSnMR(_socket), W5100.readSnIR(_socket), W5100.readSnSR(_socket));
va009039 0:bdeec5f86894 113 W5100.getIPAddress(ip);
va009039 0:bdeec5f86894 114 printf("SIPR: %d.%d.%d.%d Sn_PORT:%d\n", ip[0], ip[1], ip[2], ip[3], W5100.readSnPORT(_socket));
va009039 0:bdeec5f86894 115 W5100.readSnDIPR(_socket, ip);
va009039 0:bdeec5f86894 116 printf("Sn_DIPR: %d.%d.%d.%d Sn_DPORT:%d\n", ip[0], ip[1], ip[2], ip[3], W5100.readSnDPORT(_socket));
va009039 0:bdeec5f86894 117 #endif //DEBUG
va009039 0:bdeec5f86894 118 return NETTCPSOCKET_OK;
va009039 0:bdeec5f86894 119 }
va009039 0:bdeec5f86894 120
va009039 0:bdeec5f86894 121 NetTcpSocketErr MyNetTcpSocket::accept(Host* pClient, NetTcpSocket** ppNewNetTcpSocket) {
va009039 0:bdeec5f86894 122 PRINT_FUNC();
va009039 0:bdeec5f86894 123 if (_socket == (-1)) {
va009039 0:bdeec5f86894 124 return NETTCPSOCKET_MEM;
va009039 0:bdeec5f86894 125 }
va009039 0:bdeec5f86894 126 uint8_t ip[4];
va009039 0:bdeec5f86894 127 W5100.readSnDIPR(_socket, ip);
va009039 0:bdeec5f86894 128 pClient->setIp(IpAddr(ip[0],ip[1],ip[2],ip[3]));
va009039 0:bdeec5f86894 129 int port = W5100.readSnDPORT(_socket);
va009039 0:bdeec5f86894 130 pClient->setPort(port);
va009039 0:bdeec5f86894 131 Host me;
va009039 0:bdeec5f86894 132 me.setPort(W5100.readSnPORT(_socket));
va009039 0:bdeec5f86894 133 MyNetTcpSocket* pNewNetTcpSocket = new MyNetTcpSocket(_socket);
va009039 0:bdeec5f86894 134 if (pNewNetTcpSocket == NULL) {
va009039 0:bdeec5f86894 135 return NETTCPSOCKET_EMPTY;
va009039 0:bdeec5f86894 136 }
va009039 0:bdeec5f86894 137 pNewNetTcpSocket->m_refs++;
va009039 0:bdeec5f86894 138 *ppNewNetTcpSocket = pNewNetTcpSocket;
va009039 0:bdeec5f86894 139 _socket = w5200_new_socket();
va009039 0:bdeec5f86894 140 if (_socket != (-1)) {
va009039 0:bdeec5f86894 141 uint8_t Sn_MR = SnMR::TCP; // set TCP mode
va009039 0:bdeec5f86894 142 #if USE_NO_DELAYED_ACK
va009039 0:bdeec5f86894 143 Sn_MR |= SnMR::ND;
va009039 0:bdeec5f86894 144 #endif
va009039 0:bdeec5f86894 145 W5100.writeSnMR(_socket, Sn_MR);
va009039 0:bdeec5f86894 146 bind(me);
va009039 0:bdeec5f86894 147 listen();
va009039 0:bdeec5f86894 148 }
va009039 0:bdeec5f86894 149 return NETTCPSOCKET_OK;
va009039 0:bdeec5f86894 150 }
va009039 0:bdeec5f86894 151
va009039 0:bdeec5f86894 152 int /*if < 0 : NetTcpSocketErr*/ MyNetTcpSocket::send(const char* buf, int len) {
va009039 0:bdeec5f86894 153 PRINT_FUNC();
va009039 0:bdeec5f86894 154 #ifdef DEBUG
va009039 0:bdeec5f86894 155 printf("buf:%p, len=%d\n", buf, len);
va009039 0:bdeec5f86894 156 printHex((u8*)buf, len);
va009039 0:bdeec5f86894 157 #endif //DEBUG
va009039 0:bdeec5f86894 158 if (_socket == (-1)) {
va009039 0:bdeec5f86894 159 return NETTCPSOCKET_MEM;
va009039 0:bdeec5f86894 160 }
va009039 0:bdeec5f86894 161 if (len > 0) {
va009039 0:bdeec5f86894 162 W5100.send_data_processing(_socket, (uint8_t*)buf, len);
va009039 0:bdeec5f86894 163 W5100.execCmdSn(_socket, Sock_SEND);
va009039 0:bdeec5f86894 164 }
va009039 0:bdeec5f86894 165 return len;
va009039 0:bdeec5f86894 166 }
va009039 0:bdeec5f86894 167
va009039 0:bdeec5f86894 168 int /*if < 0 : NetTcpSocketErr*/ MyNetTcpSocket::recv(char* buf, int len){
va009039 0:bdeec5f86894 169 PRINT_FUNC();
va009039 0:bdeec5f86894 170 if (_socket == (-1)) {
va009039 0:bdeec5f86894 171 return NETTCPSOCKET_MEM;
va009039 0:bdeec5f86894 172 }
va009039 0:bdeec5f86894 173 int size = W5100.getRXReceivedSize(_socket);
va009039 0:bdeec5f86894 174 if (size > len) {
va009039 0:bdeec5f86894 175 size = len;
va009039 0:bdeec5f86894 176 }
va009039 0:bdeec5f86894 177 if (size > 0) {
va009039 0:bdeec5f86894 178 W5100.recv_data_processing(_socket, (uint8_t*)buf, size);
va009039 0:bdeec5f86894 179 W5100.execCmdSn(_socket, Sock_RECV);
va009039 0:bdeec5f86894 180 }
va009039 0:bdeec5f86894 181 #ifdef DEBUG
va009039 0:bdeec5f86894 182 printHex((uint8_t*)buf, size);
va009039 0:bdeec5f86894 183 #endif //DEBUG
va009039 0:bdeec5f86894 184 return size;
va009039 0:bdeec5f86894 185 }
va009039 0:bdeec5f86894 186
va009039 0:bdeec5f86894 187 NetTcpSocketErr MyNetTcpSocket::close() {
va009039 0:bdeec5f86894 188 PRINT_FUNC();
va009039 0:bdeec5f86894 189 DBG2("m_closed=%d m_refs=%d\n", m_closed, m_refs);
va009039 0:bdeec5f86894 190 if(m_closed) {
va009039 0:bdeec5f86894 191 return NETTCPSOCKET_OK;
va009039 0:bdeec5f86894 192 }
va009039 0:bdeec5f86894 193 m_closed = true;
va009039 0:bdeec5f86894 194 cleanUp();
va009039 0:bdeec5f86894 195 if (_socket != (-1)) {
va009039 0:bdeec5f86894 196 W5100.execCmdSn(_socket, Sock_DISCON);
va009039 0:bdeec5f86894 197 W5100.execCmdSn(_socket, Sock_CLOSE);
va009039 0:bdeec5f86894 198 }
va009039 0:bdeec5f86894 199 return NETTCPSOCKET_OK;
va009039 0:bdeec5f86894 200 }
va009039 0:bdeec5f86894 201
va009039 0:bdeec5f86894 202 NetTcpSocketErr MyNetTcpSocket::poll(){
va009039 0:bdeec5f86894 203 PRINT_FUNC();
va009039 0:bdeec5f86894 204 NetTcpSocket::flushEvents();
va009039 0:bdeec5f86894 205 #ifdef DEBUG
va009039 0:bdeec5f86894 206 printf("%p socket:%d\n", this,_socket);
va009039 0:bdeec5f86894 207 if (_socket != (-1)) {
va009039 0:bdeec5f86894 208 printf("SnMR:%02x SnIR:%02x SnSR:%02x\n",
va009039 0:bdeec5f86894 209 W5100.readSnMR(_socket), W5100.readSnIR(_socket), W5100.readSnSR(_socket));
va009039 0:bdeec5f86894 210 uint8_t ip[4];
va009039 0:bdeec5f86894 211 W5100.readSnDIPR(_socket, ip);
va009039 0:bdeec5f86894 212 printf("Sn_DIPR: %d.%d.%d.%d Sn_DPORT: %d\n", ip[0], ip[1], ip[2], ip[3], W5100.readSnDPORT(_socket));
va009039 0:bdeec5f86894 213 printf("Sn_RX_RSR:%5d, Sn_RX_RD:%5d, Sn_RX_WR:%5d\n",
va009039 0:bdeec5f86894 214 W5100.readSnRX_RSR(_socket), W5100.readSnRX_RD(_socket), W5100.readSnRX_WR(_socket));
va009039 0:bdeec5f86894 215 printf("Sn_TX_FSR:%5d, Sn_TX_RD:%5d, Sn_TX_WR:%5d\n",
va009039 0:bdeec5f86894 216 W5100.readSnTX_FSR(_socket), W5100.readSnTX_RD(_socket), W5100.readSnTX_WR(_socket));
va009039 0:bdeec5f86894 217 }
va009039 0:bdeec5f86894 218 wait_ms(200);
va009039 0:bdeec5f86894 219 #endif //DEBUG
va009039 0:bdeec5f86894 220 if (_socket == (-1)) {
va009039 0:bdeec5f86894 221 return NETTCPSOCKET_OK;
va009039 0:bdeec5f86894 222 }
va009039 0:bdeec5f86894 223 uint8_t Sn_SR = W5100.readSnSR(_socket);
va009039 0:bdeec5f86894 224 if (wait_accept) {
va009039 0:bdeec5f86894 225 if (Sn_SR == 0x17) {
va009039 0:bdeec5f86894 226 queueEvent(NETTCPSOCKET_ACCEPT);
va009039 0:bdeec5f86894 227 wait_accept = false;
va009039 0:bdeec5f86894 228 }
va009039 0:bdeec5f86894 229 }
va009039 0:bdeec5f86894 230 if (Sn_SR == 0x1c) {
va009039 0:bdeec5f86894 231 queueEvent(NETTCPSOCKET_CONRST);
va009039 0:bdeec5f86894 232 }
va009039 0:bdeec5f86894 233 if (W5100.getRXReceivedSize(_socket) > 0) {
va009039 0:bdeec5f86894 234 queueEvent(NETTCPSOCKET_READABLE);
va009039 0:bdeec5f86894 235 }
va009039 0:bdeec5f86894 236 if (Sn_SR == 0x17) {
va009039 0:bdeec5f86894 237 queueEvent(NETTCPSOCKET_CONNECTED);
va009039 0:bdeec5f86894 238 if (W5100.getTXFreeSize(_socket) > 0) {
va009039 0:bdeec5f86894 239 queueEvent(NETTCPSOCKET_WRITEABLE);
va009039 0:bdeec5f86894 240 }
va009039 0:bdeec5f86894 241 }
va009039 0:bdeec5f86894 242 if (Sn_SR == 0x00) {
va009039 0:bdeec5f86894 243 queueEvent(NETTCPSOCKET_DISCONNECTED);
va009039 0:bdeec5f86894 244 }
va009039 0:bdeec5f86894 245 return NETTCPSOCKET_OK;
va009039 0:bdeec5f86894 246 }
va009039 0:bdeec5f86894 247
va009039 0:bdeec5f86894 248 void MyNetTcpSocket::cleanUp() //Flush input buffer
va009039 0:bdeec5f86894 249 {
va009039 0:bdeec5f86894 250 PRINT_FUNC();
va009039 0:bdeec5f86894 251 if (_socket == (-1)) {
va009039 0:bdeec5f86894 252 return;
va009039 0:bdeec5f86894 253 }
va009039 0:bdeec5f86894 254 while(W5100.getRXReceivedSize(_socket) > 0) {
va009039 0:bdeec5f86894 255 uint8_t temp[1];
va009039 0:bdeec5f86894 256 W5100.recv_data_processing(_socket, temp, 1);
va009039 0:bdeec5f86894 257 W5100.execCmdSn(_socket, Sock_RECV);
va009039 0:bdeec5f86894 258 }
va009039 0:bdeec5f86894 259 }