/**************************************************************************** * net/usrsock/usrsock_bind.c * * Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements. See the NOTICE file distributed with * this work for additional information regarding copyright ownership. The * ASF licenses this file to you under the Apache License, Version 2.0 (the * "License"); you may not use this file except in compliance with the * License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the * License for the specific language governing permissions and limitations * under the License. * ****************************************************************************/ /**************************************************************************** * Included Files ****************************************************************************/ #include #if defined(CONFIG_NET) && defined(CONFIG_NET_USRSOCK) #include #include #include #include #include #include #include #include #include #include "usrsock/usrsock.h" /**************************************************************************** * Private Functions ****************************************************************************/ static uint16_t bind_event(FAR struct net_driver_s *dev, FAR void *pvpriv, uint16_t flags) { FAR struct usrsock_reqstate_s *pstate = pvpriv; FAR struct usrsock_conn_s *conn = pstate->conn; if (flags & USRSOCK_EVENT_ABORT) { ninfo("socket aborted.\n"); pstate->result = -ECONNABORTED; /* Stop further callbacks */ pstate->cb->flags = 0; pstate->cb->priv = NULL; pstate->cb->event = NULL; /* Wake up the waiting thread */ nxsem_post(&pstate->recvsem); } else if (flags & USRSOCK_EVENT_REQ_COMPLETE) { ninfo("request completed.\n"); pstate->result = conn->resp.result; /* Stop further callbacks */ pstate->cb->flags = 0; pstate->cb->priv = NULL; pstate->cb->event = NULL; /* Wake up the waiting thread */ nxsem_post(&pstate->recvsem); } return flags; } /**************************************************************************** * Name: do_bind_request ****************************************************************************/ static int do_bind_request(FAR struct usrsock_conn_s *conn, FAR const struct sockaddr *addr, socklen_t addrlen) { struct usrsock_request_bind_s req = { }; struct iovec bufs[2]; /* Prepare request for daemon to read. */ req.head.reqid = USRSOCK_REQUEST_BIND; req.usockid = conn->usockid; req.addrlen = addrlen; bufs[0].iov_base = (FAR void *)&req; bufs[0].iov_len = sizeof(req); bufs[1].iov_base = (FAR void *)addr; bufs[1].iov_len = req.addrlen; return usrsock_do_request(conn, bufs, nitems(bufs)); } /**************************************************************************** * Public Functions ****************************************************************************/ /**************************************************************************** * Name: usrsock_bind * * Description: * usrsock_bind() gives the socket 'psock' the local address 'addr'. 'addr' * is 'addrlen' bytes long. Traditionally, this is called "assigning a name * to a socket." When a socket is created with socket, it exists in a name * space (address family) but has no name assigned. * * Input Parameters: * psock A reference to the socket structure of the socket to be bound * addr Socket local address * addrlen Length of 'addr' * * Returned Value: * 0 on success; -1 on error with errno set appropriately * * EACCES * The address is protected, and the user is not the superuser. * EADDRINUSE * The given address is already in use. * EINVAL * The socket is already bound to an address. * ENOTSOCK * psock is a descriptor for a file, not a socket. * ****************************************************************************/ int usrsock_bind(FAR struct socket *psock, FAR const struct sockaddr *addr, socklen_t addrlen) { FAR struct usrsock_conn_s *conn = psock->s_conn; struct usrsock_reqstate_s state = { }; int ret; net_lock(); if (conn->state == USRSOCK_CONN_STATE_UNINITIALIZED || conn->state == USRSOCK_CONN_STATE_ABORTED) { /* Invalid state or closed by daemon. */ ninfo("usockid=%d; bind() with uninitialized usrsock.\n", conn->usockid); ret = (conn->state == USRSOCK_CONN_STATE_ABORTED) ? -EPIPE : -ECONNRESET; goto errout_unlock; } /* Set up event callback for usrsock. */ ret = usrsock_setup_request_callback(conn, &state, bind_event, USRSOCK_EVENT_ABORT | USRSOCK_EVENT_REQ_COMPLETE); if (ret < 0) { nwarn("usrsock_setup_request_callback failed: %d\n", ret); goto errout_unlock; } /* Request user-space daemon to bind address. */ ret = do_bind_request(conn, addr, addrlen); if (ret >= 0) { /* Wait for completion of request. */ net_sem_wait_uninterruptible(&state.recvsem); ret = state.result; } usrsock_teardown_request_callback(&state); errout_unlock: net_unlock(); return ret; } #endif /* CONFIG_NET && CONFIG_NET_USRSOCK */