6a3c2aded6
* Simplify EINTR/ECANCEL error handling 1. Add semaphore uninterruptible wait function 2 .Replace semaphore wait loop with a single uninterruptible wait 3. Replace all sem_xxx to nxsem_xxx * Unify the void cast usage 1. Remove void cast for function because many place ignore the returned value witout cast 2. Replace void cast for variable with UNUSED macro
258 lines
9.1 KiB
C
258 lines
9.1 KiB
C
/****************************************************************************
|
|
* net/socket/connect.c
|
|
*
|
|
* Copyright (C) 2007-2012, 2015-2017 Gregory Nutt. All rights reserved.
|
|
* Author: Gregory Nutt <gnutt@nuttx.org>
|
|
*
|
|
* 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. Neither the name NuttX nor the names of its contributors may be
|
|
* used to endorse or promote products derived from this software
|
|
* without specific prior written permission.
|
|
*
|
|
* THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
|
|
* "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
|
|
* COPYRIGHT OWNER OR CONTRIBUTORS 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>
|
|
|
|
#include <sys/types.h>
|
|
#include <sys/socket.h>
|
|
|
|
#include <stdint.h>
|
|
#include <errno.h>
|
|
#include <assert.h>
|
|
#include <debug.h>
|
|
|
|
#include <nuttx/cancelpt.h>
|
|
#include <nuttx/net/net.h>
|
|
|
|
#include "socket/socket.h"
|
|
|
|
#ifdef CONFIG_NET
|
|
|
|
/****************************************************************************
|
|
* Public Functions
|
|
****************************************************************************/
|
|
|
|
/****************************************************************************
|
|
* Name: psock_connect
|
|
*
|
|
* Description:
|
|
* connect() connects the socket referred to by the structure 'psock'
|
|
* to the address specified by 'addr'. The addrlen argument specifies
|
|
* the size of 'addr'. The format of the address in 'addr' is
|
|
* determined by the address space of the socket 'psock'.
|
|
*
|
|
* If the socket 'psock' is of type SOCK_DGRAM then 'addr' is the address
|
|
* to which datagrams are sent by default, and the only address from which
|
|
* datagrams are received. If the socket is of type SOCK_STREAM or
|
|
* SOCK_SEQPACKET, this call attempts to make a connection to the socket
|
|
* that is bound to the address specified by 'addr'.
|
|
*
|
|
* Generally, connection-based protocol sockets may successfully connect()
|
|
* only once; connectionless protocol sockets may use connect() multiple
|
|
* times to change their association. Connectionless sockets may dissolve
|
|
* the association by connecting to an address with the sa_family member of
|
|
* sockaddr set to AF_UNSPEC.
|
|
*
|
|
* Input Parameters:
|
|
* psock Pointer to a socket structure initialized by psock_socket()
|
|
* addr Server address (form depends on type of socket)
|
|
* addrlen Length of actual 'addr'
|
|
*
|
|
* Returned Value:
|
|
* Returns zero (OK) on success. On failure, it returns a negated errno
|
|
* value to indicate the nature of the error.
|
|
*
|
|
* EACCES, EPERM
|
|
* The user tried to connect to a broadcast address without having the
|
|
* socket broadcast flag enabled or the connection request failed
|
|
* because of a local firewall rule.
|
|
* EADDRINUSE
|
|
* Local address is already in use.
|
|
* EAFNOSUPPORT
|
|
* The passed address didn't have the correct address family in its
|
|
* sa_family field.
|
|
* EAGAIN
|
|
* No more free local ports or insufficient entries in the routing
|
|
* cache.
|
|
* EALREADY
|
|
* The socket is non-blocking and a previous connection attempt has
|
|
* not yet been completed.
|
|
* EBADF
|
|
* The file descriptor is not a valid index in the descriptor table.
|
|
* ECONNREFUSED
|
|
* No one listening on the remote address.
|
|
* EFAULT
|
|
* The socket structure address is outside the user's address space.
|
|
* EINPROGRESS
|
|
* The socket is non-blocking and the connection cannot be completed
|
|
* immediately.
|
|
* EINTR
|
|
* The system call was interrupted by a signal that was caught.
|
|
* EISCONN
|
|
* The socket is already connected.
|
|
* ENETUNREACH
|
|
* Network is unreachable.
|
|
* ENOTSOCK
|
|
* The file descriptor is not associated with a socket.
|
|
* ETIMEDOUT
|
|
* Timeout while attempting connection. The server may be too busy
|
|
* to accept new connections.
|
|
*
|
|
* Assumptions:
|
|
*
|
|
****************************************************************************/
|
|
|
|
int psock_connect(FAR struct socket *psock, FAR const struct sockaddr *addr,
|
|
socklen_t addrlen)
|
|
{
|
|
int ret;
|
|
|
|
/* Verify that the psock corresponds to valid, allocated socket */
|
|
|
|
if (psock == NULL || psock->s_crefs <= 0)
|
|
{
|
|
return -EBADF;
|
|
}
|
|
|
|
/* Make sure that an address was provided */
|
|
|
|
if (addr == NULL)
|
|
{
|
|
return -EFAULT;
|
|
}
|
|
|
|
/* Let the address family's connect() method handle the operation */
|
|
|
|
DEBUGASSERT(psock->s_sockif != NULL && psock->s_sockif->si_connect != NULL);
|
|
ret = psock->s_sockif->si_connect(psock, addr, addrlen);
|
|
if (ret < 0)
|
|
{
|
|
return ret;
|
|
}
|
|
|
|
return OK;
|
|
}
|
|
|
|
/****************************************************************************
|
|
* Name: connect
|
|
*
|
|
* Description:
|
|
* connect() connects the socket referred to by the file descriptor 'sockfd'
|
|
* to the address specified by 'addr'. The addrlen argument specifies
|
|
* the size of 'addr'. The format of the address in 'addr' is
|
|
* determined by the address space of the socket 'sockfd'.
|
|
*
|
|
* If the socket 'sockfd' is of type SOCK_DGRAM then 'addr' is the address
|
|
* to which datagrams are sent by default, and the only address from which
|
|
* datagrams are received. If the socket is of type SOCK_STREAM or
|
|
* SOCK_SEQPACKET, this call attempts to make a connection to the socket
|
|
* that is bound to the address specified by 'addr'.
|
|
*
|
|
* Generally, connection-based protocol sockets may successfully connect()
|
|
* only once; connectionless protocol sockets may use connect() multiple
|
|
* times to change their association. Connectionless sockets may dissolve
|
|
* the association by connecting to an address with the sa_family member of
|
|
* sockaddr set to AF_UNSPEC.
|
|
*
|
|
* Input Parameters:
|
|
* sockfd Socket descriptor returned by socket()
|
|
* addr Server address (form depends on type of socket)
|
|
* addrlen Length of actual 'addr'
|
|
*
|
|
* Returned Value:
|
|
* 0 on success; -1 on error with errno set appropriately
|
|
*
|
|
* EACCES, EPERM
|
|
* The user tried to connect to a broadcast address without having the
|
|
* socket broadcast flag enabled or the connection request failed
|
|
* because of a local firewall rule.
|
|
* EADDRINUSE
|
|
* Local address is already in use.
|
|
* EAFNOSUPPORT
|
|
* The passed address didn't have the correct address family in its
|
|
* sa_family field.
|
|
* EAGAIN
|
|
* No more free local ports or insufficient entries in the routing
|
|
* cache.
|
|
* EALREADY
|
|
* The socket is non-blocking and a previous connection attempt has
|
|
* not yet been completed.
|
|
* EBADF
|
|
* The file descriptor is not a valid index in the descriptor table.
|
|
* ECONNREFUSED
|
|
* No one listening on the remote address.
|
|
* EFAULT
|
|
* The socket structure address is outside the user's address space.
|
|
* EINPROGRESS
|
|
* The socket is non-blocking and the connection cannot be completed
|
|
* immediately.
|
|
* EINTR
|
|
* The system call was interrupted by a signal that was caught.
|
|
* EISCONN
|
|
* The socket is already connected.
|
|
* ENETUNREACH
|
|
* Network is unreachable.
|
|
* ENOTSOCK
|
|
* The file descriptor is not associated with a socket.
|
|
* ETIMEDOUT
|
|
* Timeout while attempting connection. The server may be too busy
|
|
* to accept new connections.
|
|
*
|
|
* Assumptions:
|
|
*
|
|
****************************************************************************/
|
|
|
|
int connect(int sockfd, FAR const struct sockaddr *addr, socklen_t addrlen)
|
|
{
|
|
FAR struct socket *psock;
|
|
int ret;
|
|
|
|
/* accept() is a cancellation point */
|
|
|
|
enter_cancellation_point();
|
|
|
|
/* Get the underlying socket structure */
|
|
|
|
psock = sockfd_socket(sockfd);
|
|
|
|
/* Then let psock_connect() do all of the work */
|
|
|
|
ret = psock_connect(psock, addr, addrlen);
|
|
if (ret < 0)
|
|
{
|
|
_SO_SETERRNO(psock, -ret);
|
|
ret = ERROR;
|
|
}
|
|
|
|
leave_cancellation_point();
|
|
return ret;
|
|
}
|
|
|
|
#endif /* CONFIG_NET */
|