diff options
Diffstat (limited to 'nuttx/net/uip/uip-listen.c')
-rw-r--r-- | nuttx/net/uip/uip-listen.c | 206 |
1 files changed, 206 insertions, 0 deletions
diff --git a/nuttx/net/uip/uip-listen.c b/nuttx/net/uip/uip-listen.c new file mode 100644 index 000000000..edbb9d469 --- /dev/null +++ b/nuttx/net/uip/uip-listen.c @@ -0,0 +1,206 @@ +/**************************************************************************** + * net/uip/uip-listen.c + * + * Copyright (C) 2007 Gregory Nutt. All rights reserved. + * Author: Gregory Nutt <spudmonkey@racsa.co.cr> + * + * A direct leverage of logic from uIP which also has b BSD style license + * + * Author: Adam Dunkels <adam@dunkels.com> + * Copyright (c) 2001-2003, Adam Dunkels. + * All rights reserved. + * + * Redistribution and use in source and binary forms, with or without + * modification, are permitted provided that the following conditions + * are met: + * + * 1. Redistributions of source code must retain the above copyright + * notice, this list of conditions and the following disclaimer. + * 2. Redistributions in binary form must reproduce the above copyright + * notice, this list of conditions and the following disclaimer in the + * documentation and/or other materials provided with the distribution. + * 3. The name of the author may not be used to endorse or promote + * products derived from this software without specific prior + * written permission. + * + * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS + * OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED + * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE + * ARE DISCLAIMED. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY + * DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL + * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE + * GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS + * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, + * WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING + * NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS + * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. + * + ****************************************************************************/ + +/**************************************************************************** + * Included Files + ****************************************************************************/ + +#include <nuttx/config.h> +#ifdef CONFIG_NET + +#include <sys/types.h> +#include <net/uip/uipopt.h> + +#include "uip-internal.h" + +/**************************************************************************** + * Private Data + ****************************************************************************/ + +/* The uip_listenports list all currently listening ports. */ + +static uint16 uip_listenports[UIP_LISTENPORTS]; + +/**************************************************************************** + * Private Functions + ****************************************************************************/ + +/**************************************************************************** + * Public Functions + ****************************************************************************/ + +/**************************************************************************** + * Function: uip_listeninit + * + * Description: + * Setup the listening data structures + * + * Assumptions: + * Called early in the inialization phase while the system is still + * single-threaded. + * + ****************************************************************************/ + +void uip_listeninit(void) +{ + int ndx; + for (ndx = 0; ndx < UIP_LISTENPORTS; ndx++) + { + uip_listenports[ndx] = 0; + } +} + +/**************************************************************************** + * Function: uip_unlisten + * + * Description: + * Stop listening on a port + * + * Assumptions: + * Called from normal user code. + * + ****************************************************************************/ + +int uip_unlisten(uint16 port) +{ + irqstate_t flags; + int ndx; + int ret = -EINVAL; + + flags = irqsave(); + for (ndx = 0; ndx < UIP_LISTENPORTS; ndx++) + { + if (uip_listenports[ndx] == port) + { + uip_listenports[ndx] = 0; + ret = OK; + break; + } + } + irqrestore(flags); + return ret; +} + +/**************************************************************************** + * Function: uip_listen + * + * Description: + * Start listening on a port + * + * Assumptions: + * Called from normal user code. + * + ****************************************************************************/ + +int uip_listen(uint16 port) +{ + irqstate_t flags; + int ndx; + int ret = -ENOBUFS; + + flags = irqsave(); + for (ndx = 0; ndx < UIP_LISTENPORTS; ndx++) + { + if (uip_listenports[ndx] == 0) + { + uip_listenports[ndx] = port; + ret = OK; + break; + } + } + irqrestore(flags); + return ret; +} + +/**************************************************************************** + * Function: uip_islistener + * + * Description: + * Return TRUE is there is a listener for the specified port + * + * Assumptions: + * Called at interrupt level + * + ****************************************************************************/ + +boolean uip_islistener(uint16 portno) +{ + int ndx; + for (ndx = 0; ndx < UIP_LISTENPORTS; ndx++) + { + if (uip_listenports[ndx] == portno) + { + return TRUE; + } + } + return FALSE; +} + +/**************************************************************************** + * Function: uip_accept + * + * Description: + * Accept the new connection for the specified listening port. + * + * Assumptions: + * Called at interrupt level + * + ****************************************************************************/ + +int uip_accept(struct uip_conn *conn, uint16 portno) +{ + struct uip_conn *listener; + int ret = ERROR; + + /* The interrupt logic has already allocated and initialized a TCP + * connection -- now check if is an application in place to accept the + * connection. + */ + + listener = uip_tcplistener(portno); + if (listener && listener->accept) + { + /* Yes.. accept the connection */ + + ret = listener->accept(listener->accept_private, conn); + } + return ret; +} + +#endif /* CONFIG_NET */ |