1/* 2 * Copyright (c) 2001-2003 Swedish Institute of Computer Science. 3 * All rights reserved. 4 * 5 * Redistribution and use in source and binary forms, with or without modification, 6 * are permitted provided that the following conditions are met: 7 * 8 * 1. Redistributions of source code must retain the above copyright notice, 9 * this list of conditions and the following disclaimer. 10 * 2. Redistributions in binary form must reproduce the above copyright notice, 11 * this list of conditions and the following disclaimer in the documentation 12 * and/or other materials provided with the distribution. 13 * 3. The name of the author may not be used to endorse or promote products 14 * derived from this software without specific prior written permission. 15 * 16 * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR IMPLIED 17 * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF 18 * MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT 19 * SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, 20 * EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT 21 * OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS 22 * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN 23 * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING 24 * IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY 25 * OF SUCH DAMAGE. 26 * 27 * This file is part of the lwIP TCP/IP stack. 28 * 29 * Author: Adam Dunkels <adam@sics.se> 30 * 31 */ 32#include "tcpecho.h" 33 34#include "lwip/opt.h" 35 36#if LWIP_NETCONN 37 38#include "lwip/sys.h" 39#include "lwip/api.h" 40/*-----------------------------------------------------------------------------------*/ 41static void 42tcpecho_thread(void *arg) 43{ 44 struct netconn *conn, *newconn; 45 err_t err; 46 LWIP_UNUSED_ARG(arg); 47 48 /* Create a new connection identifier. */ 49 /* Bind connection to well known port number 7. */ 50#if LWIP_IPV6 51 conn = netconn_new(NETCONN_TCP_IPV6); 52 netconn_bind(conn, IP6_ADDR_ANY, 7); 53#else /* LWIP_IPV6 */ 54 conn = netconn_new(NETCONN_TCP); 55 netconn_bind(conn, IP_ADDR_ANY, 7); 56#endif /* LWIP_IPV6 */ 57 LWIP_ERROR("tcpecho: invalid conn", (conn != NULL), return;); 58 59 /* Tell connection to go into listening mode. */ 60 netconn_listen(conn); 61 62 while (1) { 63 64 /* Grab new connection. */ 65 err = netconn_accept(conn, &newconn); 66 /*printf("accepted new connection %p\n", newconn);*/ 67 /* Process the new connection. */ 68 if (err == ERR_OK) { 69 struct netbuf *buf; 70 void *data; 71 u16_t len; 72 73 while ((err = netconn_recv(newconn, &buf)) == ERR_OK) { 74 /*printf("Recved\n");*/ 75 do { 76 netbuf_data(buf, &data, &len); 77 err = netconn_write(newconn, data, len, NETCONN_COPY); 78#if 0 79 if (err != ERR_OK) { 80 printf("tcpecho: netconn_write: error \"%s\"\n", lwip_strerr(err)); 81 } 82#endif 83 } while (netbuf_next(buf) >= 0); 84 netbuf_delete(buf); 85 } 86 /*printf("Got EOF, looping\n");*/ 87 /* Close connection and discard connection identifier. */ 88 netconn_close(newconn); 89 netconn_delete(newconn); 90 } 91 } 92} 93/*-----------------------------------------------------------------------------------*/ 94void 95tcpecho_init(void) 96{ 97 sys_thread_new("tcpecho_thread", tcpecho_thread, NULL, DEFAULT_THREAD_STACKSIZE, DEFAULT_THREAD_PRIO); 98} 99/*-----------------------------------------------------------------------------------*/ 100 101#endif /* LWIP_NETCONN */ 102