/**************************************************************************** * net/usrsock/usrsock_setsockopt.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) && \ defined(CONFIG_NET_SOCKOPTS) #include #include #include #include #include #include #include #include #include #include "usrsock/usrsock.h" /**************************************************************************** * Private Functions ****************************************************************************/ static uint16_t setsockopt_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_setsockopt_request ****************************************************************************/ static int do_setsockopt_request(FAR struct usrsock_conn_s *conn, int level, int option, FAR const void *value, socklen_t value_len) { struct usrsock_request_setsockopt_s req = { }; struct iovec bufs[2]; if (level < INT16_MIN || level > INT16_MAX) { return -EINVAL; } if (option < INT16_MIN || option > INT16_MAX) { return -EINVAL; } if (value_len > UINT16_MAX) { value_len = UINT16_MAX; } /* Prepare request for daemon to read. */ req.head.reqid = USRSOCK_REQUEST_SETSOCKOPT; req.usockid = conn->usockid; req.level = level; req.option = option; req.valuelen = value_len; bufs[0].iov_base = (FAR void *)&req; bufs[0].iov_len = sizeof(req); bufs[1].iov_base = (FAR void *)value; bufs[1].iov_len = req.valuelen; return usrsock_do_request(conn, bufs, nitems(bufs)); } /**************************************************************************** * Public Functions ****************************************************************************/ /**************************************************************************** * Name: usrsock_setsockopt * * Description: * psock_setsockopt() sets the option specified by the 'option' argument, * at the protocol level specified by the 'level' argument, to the value * pointed to by the 'value' argument for the usrsock connection. * * The 'level' argument specifies the protocol level of the option. To set * options at the socket level, specify the level argument as SOL_SOCKET. * * See a complete list of values for the 'option' argument. * * Input Parameters: * psock Socket structure of the socket to query * level Protocol level to set the option * option identifies the option to set * value Points to the argument value * value_len The length of the argument value * ****************************************************************************/ int usrsock_setsockopt(FAR struct socket *psock, int level, int option, FAR const void *value, socklen_t value_len) { FAR struct usrsock_conn_s *conn = psock->s_conn; struct usrsock_reqstate_s state = { }; int ret; /* SO_[RCV|SND]TIMEO have to be handled locally to break the block i/o */ if (level == SOL_SOCKET && (option == SO_TYPE || option == SO_RCVTIMEO || option == SO_SNDTIMEO)) { return -ENOPROTOOPT; } net_lock(); if (conn->state == USRSOCK_CONN_STATE_UNINITIALIZED || conn->state == USRSOCK_CONN_STATE_ABORTED) { /* Invalid state or closed by daemon. */ ninfo("usockid=%d; setsockopt() 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, setsockopt_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 handle request. */ ret = do_setsockopt_request(conn, level, option, value, value_len); if (ret >= 0) { /* Wait for completion of request. */ net_sem_wait_uninterruptible(&state.recvsem); ret = state.result; } usrsock_teardown_request_callback(&state); /* Skip the default socket option handler */ if (ret == -ENOPROTOOPT) { ret = -ENOTTY; } errout_unlock: net_unlock(); return ret; } #endif /* CONFIG_NET && CONFIG_NET_USRSOCK && CONFIG_NET_SOCKOPTS */