/**************************************************************************** * net/usrsock/usrsock_socket.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 "devif/devif.h" #include "usrsock/usrsock.h" /**************************************************************************** * Private Functions ****************************************************************************/ static uint16_t socket_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 = -ENETDOWN; /* 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; if (pstate->result >= 0) { /* We might start getting events for this socket right after * returning to daemon, so setup 'conn' already here. */ conn->state = USRSOCK_CONN_STATE_READY; conn->usockid = pstate->result; if (flags & USRSOCK_EVENT_SENDTO_READY) { conn->flags |= USRSOCK_EVENT_SENDTO_READY; } } /* 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_socket_request ****************************************************************************/ static int do_socket_request(FAR struct usrsock_conn_s *conn, int domain, int type, int protocol) { struct usrsock_request_socket_s req = { }; struct iovec bufs[1]; /* Prepare request for daemon to read. */ req.head.reqid = USRSOCK_REQUEST_SOCKET; req.domain = domain; req.type = type; req.protocol = protocol; if (req.domain != domain) { return -EINVAL; } if (req.type != type) { return -EINVAL; } if (req.protocol != protocol) { return -EINVAL; } bufs[0].iov_base = (FAR void *)&req; bufs[0].iov_len = sizeof(req); return usrsock_do_request(conn, bufs, ARRAY_SIZE(bufs)); } /**************************************************************************** * Public Functions ****************************************************************************/ /**************************************************************************** * Name: usrsock_socket * * Description: * socket() creates an endpoint for communication and returns a socket * structure. * * Input Parameters: * domain - (see sys/socket.h) * type - (see sys/socket.h) * protocol - (see sys/socket.h) * psock - A pointer to a user allocated socket structure to be * initialized. * * Returned Value: * 0 on success; negative error-code on error * * EACCES * Permission to create a socket of the specified type and/or protocol * is denied. * EAFNOSUPPORT * The implementation does not support the specified address family. * EINVAL * Unknown protocol, or protocol family not available. * EMFILE * Process file table overflow. * ENFILE * The system limit on the total number of open files has been reached. * ENOBUFS or ENOMEM * Insufficient memory is available. The socket cannot be created until * sufficient resources are freed. * EPROTONOSUPPORT * The protocol type or the specified protocol is not supported within * this domain. * ****************************************************************************/ int usrsock_socket(int domain, int type, int protocol, FAR struct socket *psock) { struct usrsock_reqstate_s state = { }; FAR struct usrsock_conn_s *conn; int err; /* Allocate the usrsock socket connection structure and save in the new * socket instance. */ conn = usrsock_alloc(); if (!conn) { /* Failed to reserve a connection structure */ return -ENOMEM; } net_lock(); /* Set up event callback for usrsock. */ err = usrsock_setup_request_callback(conn, &state, socket_event, USRSOCK_EVENT_ABORT | USRSOCK_EVENT_REQ_COMPLETE); if (err < 0) { goto errout_free_conn; } /* Request user-space daemon for new socket. */ err = do_socket_request(conn, domain, type, protocol); if (err < 0) { goto errout_teardown_callback; } /* Wait for completion of request. */ net_sem_wait_uninterruptible(&state.recvsem); if (state.result < 0) { err = state.result; goto errout_teardown_callback; } psock->s_conn = conn; conn->crefs = 1; usrsock_teardown_request_callback(&state); net_unlock(); return OK; errout_teardown_callback: usrsock_teardown_request_callback(&state); errout_free_conn: usrsock_free(conn); net_unlock(); return err; } #endif /* CONFIG_NET && CONFIG_NET_USRSOCK */