Ian Kilburn / WIZnet_Library

Important changes to repositories hosted on mbed.com

Mbed hosted mercurial repositories are deprecated and are due to be permanently deleted in July 2026.

To keep a copy of this software download the repository Zip archive or clone locally using Mercurial.

It is also possible to export all your personal repositories from the account settings page.

Fork of WIZnet_Library by IPN ESIME ZACATENCO

WIZnetInterface/Socket/TCPSocketServer.cpp@3:53191b0b1f16, 2014-07-01 (annotated)

Committer:
Ademir501
Date:
Tue Jul 01 17:52:55 2014 +0000
Revision:
3:53191b0b1f16
Parent:
0:b72d22e10709 
wiznet.h

Who changed what in which revision?

UserRevisionLine numberNew contents of line
Ademir501 3:53191b0b1f16 1 /* Copyright (C) 2012 mbed.org, MIT License
Ademir501 3:53191b0b1f16 2 *
Ademir501 3:53191b0b1f16 3 * Permission is hereby granted, free of charge, to any person obtaining a copy of this software
Ademir501 3:53191b0b1f16 4 * and associated documentation files (the "Software"), to deal in the Software without restriction,
Ademir501 3:53191b0b1f16 5 * including without limitation the rights to use, copy, modify, merge, publish, distribute,
Ademir501 3:53191b0b1f16 6 * sublicense, and/or sell copies of the Software, and to permit persons to whom the Software is
Ademir501 3:53191b0b1f16 7 * furnished to do so, subject to the following conditions:
Ademir501 3:53191b0b1f16 8 *
Ademir501 3:53191b0b1f16 9 * The above copyright notice and this permission notice shall be included in all copies or
Ademir501 3:53191b0b1f16 10 * substantial portions of the Software.
Ademir501 3:53191b0b1f16 11 *
Ademir501 3:53191b0b1f16 12 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING
Ademir501 3:53191b0b1f16 13 * BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
Ademir501 3:53191b0b1f16 14 * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM,
Ademir501 3:53191b0b1f16 15 * DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
Ademir501 3:53191b0b1f16 16 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
Ademir501 3:53191b0b1f16 17 */
Ademir501 3:53191b0b1f16 18
Ademir501 3:53191b0b1f16 19 #include "TCPSocketServer.h"
Ademir501 3:53191b0b1f16 20
Ademir501 3:53191b0b1f16 21 TCPSocketServer::TCPSocketServer() {}
jbkim 0:b72d22e10709 22
Ademir501 3:53191b0b1f16 23 // Server initialization
Ademir501 3:53191b0b1f16 24 int TCPSocketServer::bind(int port) {
Ademir501 3:53191b0b1f16 25 if (_sock_fd < 0) {
Ademir501 3:53191b0b1f16 26 _sock_fd = eth->new_socket();
Ademir501 3:53191b0b1f16 27 if (_sock_fd < 0) {
Ademir501 3:53191b0b1f16 28 return -1;
Ademir501 3:53191b0b1f16 29 }
Ademir501 3:53191b0b1f16 30 }
Ademir501 3:53191b0b1f16 31 // set TCP protocol
Ademir501 3:53191b0b1f16 32 eth->setProtocol(_sock_fd, TCP);
Ademir501 3:53191b0b1f16 33 // set local port
Ademir501 3:53191b0b1f16 34 eth->sreg<uint16_t>(_sock_fd, Sn_PORT, port);
Ademir501 3:53191b0b1f16 35 // connect the network
Ademir501 3:53191b0b1f16 36 eth->scmd(_sock_fd, OPEN);
Ademir501 3:53191b0b1f16 37 return 0;
Ademir501 3:53191b0b1f16 38 }
Ademir501 3:53191b0b1f16 39
Ademir501 3:53191b0b1f16 40 int TCPSocketServer::listen(int backlog) {
Ademir501 3:53191b0b1f16 41 if (_sock_fd < 0) {
Ademir501 3:53191b0b1f16 42 return -1;
Ademir501 3:53191b0b1f16 43 }
Ademir501 3:53191b0b1f16 44 if (backlog != 1) {
Ademir501 3:53191b0b1f16 45 return -1;
Ademir501 3:53191b0b1f16 46 }
Ademir501 3:53191b0b1f16 47 eth->scmd(_sock_fd, LISTEN);
Ademir501 3:53191b0b1f16 48 return 0;
Ademir501 3:53191b0b1f16 49 }
Ademir501 3:53191b0b1f16 50
Ademir501 3:53191b0b1f16 51
Ademir501 3:53191b0b1f16 52 int TCPSocketServer::accept(TCPSocketConnection& connection) {
Ademir501 3:53191b0b1f16 53 if (_sock_fd < 0) {
Ademir501 3:53191b0b1f16 54 return -1;
Ademir501 3:53191b0b1f16 55 }
Ademir501 3:53191b0b1f16 56 Timer t;
Ademir501 3:53191b0b1f16 57 t.reset();
Ademir501 3:53191b0b1f16 58 t.start();
Ademir501 3:53191b0b1f16 59 while(1) {
Ademir501 3:53191b0b1f16 60 if (t.read_ms() > _timeout && _blocking == false) {
Ademir501 3:53191b0b1f16 61 return -1;
Ademir501 3:53191b0b1f16 62 }
Ademir501 3:53191b0b1f16 63 if (eth->sreg<uint8_t>(_sock_fd, Sn_SR) == SOCK_ESTABLISHED) {
Ademir501 3:53191b0b1f16 64 break;
Ademir501 3:53191b0b1f16 65 }
Ademir501 3:53191b0b1f16 66 }
Ademir501 3:53191b0b1f16 67 uint32_t ip = eth->sreg<uint32_t>(_sock_fd, Sn_DIPR);
Ademir501 3:53191b0b1f16 68 char host[16];
Ademir501 3:53191b0b1f16 69 snprintf(host, sizeof(host), "%d.%d.%d.%d", (ip>>24)&0xff, (ip>>16)&0xff, (ip>>8)&0xff, ip&0xff);
Ademir501 3:53191b0b1f16 70 uint16_t port = eth->sreg<uint16_t>(_sock_fd, Sn_DPORT);
Ademir501 3:53191b0b1f16 71 connection._sock_fd = _sock_fd;
Ademir501 3:53191b0b1f16 72 connection.set_address(host, port);
Ademir501 3:53191b0b1f16 73 return 0;
Ademir501 3:53191b0b1f16 74 }
Ademir501 3:53191b0b1f16 75