mirror of
https://github.com/apache/nuttx.git
synced 2026-05-26 10:46:28 +08:00
Socket interface: Added bind() and connect() interfaces.
This commit is contained in:
Gregory Nutt
+8
-225
@@ -1,7 +1,7 @@
|
||||
/****************************************************************************
|
||||
* net/socket/bind.c
|
||||
*
|
||||
* Copyright (C) 2007-2009, 2012, 2014-2016 Gregory Nutt. All rights reserved.
|
||||
* Copyright (C) 2007-2009, 2012, 2014-2017 Gregory Nutt. All rights reserved.
|
||||
* Author: Gregory Nutt <gnutt@nuttx.org>
|
||||
*
|
||||
* Redistribution and use in source and binary forms, with or without
|
||||
@@ -38,85 +38,23 @@
|
||||
****************************************************************************/
|
||||
|
||||
#include <nuttx/config.h>
|
||||
#ifdef CONFIG_NET
|
||||
|
||||
#include <sys/types.h>
|
||||
#include <sys/socket.h>
|
||||
#include <sys/un.h>
|
||||
#include <errno.h>
|
||||
#include <string.h>
|
||||
#include <debug.h>
|
||||
#include <assert.h>
|
||||
|
||||
#ifdef CONFIG_NET_PKT
|
||||
# include <netpacket/packet.h>
|
||||
#endif
|
||||
#include <errno.h>
|
||||
#include <debug.h>
|
||||
|
||||
#include <nuttx/net/net.h>
|
||||
#include <nuttx/net/udp.h>
|
||||
|
||||
#include "socket/socket.h"
|
||||
#include "netdev/netdev.h"
|
||||
#include "tcp/tcp.h"
|
||||
#include "udp/udp.h"
|
||||
#include "pkt/pkt.h"
|
||||
#include "local/local.h"
|
||||
#include "usrsock/usrsock.h"
|
||||
|
||||
#ifdef CONFIG_NET
|
||||
|
||||
/****************************************************************************
|
||||
* Private Functions
|
||||
****************************************************************************/
|
||||
|
||||
/****************************************************************************
|
||||
* Name: pkt_bind
|
||||
*
|
||||
* Description:
|
||||
* Bind a raw socket to an network device.
|
||||
*
|
||||
* Parameters:
|
||||
* conn AF_PACKET connection structure
|
||||
* addr Peer address information
|
||||
*
|
||||
* Returned Value:
|
||||
* 0 on success; -1 on error with errno set appropriately
|
||||
*
|
||||
****************************************************************************/
|
||||
|
||||
#ifdef CONFIG_NET_PKT
|
||||
static int pkt_bind(FAR struct pkt_conn_s *conn,
|
||||
FAR const struct sockaddr_ll *addr)
|
||||
{
|
||||
int ifindex;
|
||||
#if 0
|
||||
char hwaddr[6] = /* our MAC for debugging */
|
||||
{
|
||||
0x00, 0xa1, 0xb1, 0xc1, 0xd1, 0xe1
|
||||
};
|
||||
#endif
|
||||
char hwaddr[6] = /* MAC from ifconfig */
|
||||
{
|
||||
0x00, 0xe0, 0xde, 0xad, 0xbe, 0xef
|
||||
};
|
||||
|
||||
/* Look at the addr and identify network interface */
|
||||
|
||||
ifindex = addr->sll_ifindex;
|
||||
|
||||
#if 0
|
||||
/* Get the MAC address of that interface */
|
||||
|
||||
memcpy(hwaddr, g_netdevices->d_mac.ether, 6);
|
||||
#endif
|
||||
|
||||
/* Put ifindex and mac address into connection */
|
||||
|
||||
conn->ifindex = ifindex;
|
||||
memcpy(conn->lmac, hwaddr, 6);
|
||||
|
||||
return OK;
|
||||
}
|
||||
#endif /* CONFIG_NET_PKT */
|
||||
|
||||
/****************************************************************************
|
||||
* Public Functions
|
||||
****************************************************************************/
|
||||
@@ -169,165 +107,10 @@ int psock_bind(FAR struct socket *psock, const struct sockaddr *addr,
|
||||
goto errout;
|
||||
}
|
||||
|
||||
/* Verify that a valid address has been provided */
|
||||
/* Let the address family's connect() method handle the operation */
|
||||
|
||||
switch (addr->sa_family)
|
||||
{
|
||||
#ifdef CONFIG_NET_IPv4
|
||||
case AF_INET:
|
||||
minlen = sizeof(struct sockaddr_in);
|
||||
break;
|
||||
#endif
|
||||
|
||||
#ifdef CONFIG_NET_IPv6
|
||||
case AF_INET6:
|
||||
minlen = sizeof(struct sockaddr_in6);
|
||||
break;
|
||||
#endif
|
||||
|
||||
#ifdef CONFIG_NET_LOCAL
|
||||
case AF_LOCAL:
|
||||
minlen = sizeof(sa_family_t);
|
||||
break;
|
||||
#endif
|
||||
|
||||
#ifdef CONFIG_NET_PKT
|
||||
case AF_PACKET:
|
||||
minlen = sizeof(struct sockaddr_ll);
|
||||
break;
|
||||
#endif
|
||||
|
||||
default:
|
||||
nerr("ERROR: Unrecognized address family: %d\n", addr->sa_family);
|
||||
errcode = EAFNOSUPPORT;
|
||||
goto errout;
|
||||
}
|
||||
|
||||
if (addrlen < minlen)
|
||||
{
|
||||
nerr("ERROR: Invalid address length: %d < %d\n", addrlen, minlen);
|
||||
errcode = EBADF;
|
||||
goto errout;
|
||||
}
|
||||
|
||||
/* Perform the binding depending on the protocol type */
|
||||
|
||||
switch (psock->s_type)
|
||||
{
|
||||
#ifdef CONFIG_NET_USRSOCK
|
||||
case SOCK_USRSOCK_TYPE:
|
||||
{
|
||||
FAR struct usrsock_conn_s *conn = psock->s_conn;
|
||||
|
||||
DEBUGASSERT(conn);
|
||||
|
||||
/* Perform the usrsock bind operation */
|
||||
|
||||
ret = usrsock_bind(conn, addr, addrlen);
|
||||
}
|
||||
break;
|
||||
#endif
|
||||
|
||||
#ifdef CONFIG_NET_PKT
|
||||
case SOCK_RAW:
|
||||
ret = pkt_bind(psock->s_conn, lladdr);
|
||||
break;
|
||||
#endif
|
||||
|
||||
/* Bind a stream socket which may either be TCP/IP or a local, Unix
|
||||
* domain socket.
|
||||
*/
|
||||
|
||||
#if defined(CONFIG_NET_TCP) || defined(CONFIG_NET_LOCAL_STREAM)
|
||||
case SOCK_STREAM:
|
||||
{
|
||||
#ifdef CONFIG_NET_LOCAL_STREAM
|
||||
#ifdef CONFIG_NET_TCP
|
||||
/* Is this a Unix domain socket? */
|
||||
|
||||
if (psock->s_domain == PF_LOCAL)
|
||||
#endif
|
||||
{
|
||||
/* Bind the Unix domain connection structure */
|
||||
|
||||
ret = psock_local_bind(psock, addr, addrlen);
|
||||
}
|
||||
#endif /* CONFIG_NET_LOCAL_STREAM */
|
||||
|
||||
#ifdef CONFIG_NET_TCP
|
||||
#ifdef CONFIG_NET_LOCAL_STREAM
|
||||
else
|
||||
#endif
|
||||
{
|
||||
#ifdef NET_TCP_HAVE_STACK
|
||||
/* Bind the TCP/IP connection structure */
|
||||
|
||||
ret = tcp_bind(psock->s_conn, addr);
|
||||
#else
|
||||
ret = -ENOSYS;
|
||||
#endif
|
||||
}
|
||||
#endif /* CONFIG_NET_TCP */
|
||||
|
||||
/* Mark the socket bound */
|
||||
|
||||
if (ret >= 0)
|
||||
{
|
||||
psock->s_flags |= _SF_BOUND;
|
||||
}
|
||||
}
|
||||
break;
|
||||
#endif /* CONFIG_NET_TCP || CONFIG_NET_LOCAL_STREAM */
|
||||
|
||||
/* Bind a datagram socket which may either be TCP/IP or a local, Unix
|
||||
* domain socket.
|
||||
*/
|
||||
|
||||
#if defined(CONFIG_NET_UDP) || defined(CONFIG_NET_LOCAL_DGRAM)
|
||||
case SOCK_DGRAM:
|
||||
{
|
||||
#ifdef CONFIG_NET_LOCAL_DGRAM
|
||||
#ifdef CONFIG_NET_UDP
|
||||
/* Is this a Unix domain socket? */
|
||||
|
||||
if (psock->s_domain == PF_LOCAL)
|
||||
#endif
|
||||
{
|
||||
/* Bind the Unix domain connection structure */
|
||||
|
||||
ret = psock_local_bind(psock, addr, addrlen);
|
||||
}
|
||||
#endif /* CONFIG_NET_LOCAL_DGRAM */
|
||||
|
||||
#ifdef CONFIG_NET_UDP
|
||||
#ifdef CONFIG_NET_LOCAL_DGRAM
|
||||
else
|
||||
#endif
|
||||
{
|
||||
#ifdef NET_UDP_HAVE_STACK
|
||||
/* Bind the UDPP/IP connection structure */
|
||||
|
||||
ret = udp_bind(psock->s_conn, addr);
|
||||
#else
|
||||
ret = -ENOSYS;
|
||||
#endif
|
||||
}
|
||||
#endif /* CONFIG_NET_UDP */
|
||||
|
||||
/* Mark the socket bound */
|
||||
|
||||
if (ret >= 0)
|
||||
{
|
||||
psock->s_flags |= _SF_BOUND;
|
||||
}
|
||||
}
|
||||
break;
|
||||
#endif /* CONFIG_NET_UDP || CONFIG_NET_LOCAL_DGRAM */
|
||||
|
||||
default:
|
||||
errcode = EBADF;
|
||||
goto errout;
|
||||
}
|
||||
DEBUGASSERT(psock->s_sockif != NULL && psock->s_sockif->si_bind != NULL);
|
||||
ret = psock->s_sockif->si_bind(psock, addr, addrlen);
|
||||
|
||||
/* Was the bind successful */
|
||||
|
||||
|
||||
Reference in New Issue
Block a user