|  | /** | 
|  | * Copyright (c) 2018 Linaro Limited. | 
|  | * | 
|  | * SPDX-License-Identifier: Apache-2.0 | 
|  | */ | 
|  |  | 
|  | #include "simplelink_log.h" | 
|  | LOG_MODULE_DECLARE(LOG_MODULE_NAME); | 
|  |  | 
|  | #include <stdlib.h> | 
|  | #include <limits.h> | 
|  | #include <zephyr/posix/fcntl.h> | 
|  |  | 
|  | #include <zephyr/kernel.h> | 
|  | /* Define sockaddr, etc, before simplelink.h */ | 
|  | #include <zephyr/net/socket_offload.h> | 
|  |  | 
|  | #include <errno.h> | 
|  | #include <ti/drivers/net/wifi/simplelink.h> | 
|  | #include <ti/drivers/net/wifi/source/driver.h> | 
|  | #include <ti/net/slnetutils.h> | 
|  | #include <ti/net/slnetif.h> | 
|  | #include "simplelink_support.h" | 
|  |  | 
|  | #include "sockets_internal.h" | 
|  | #include "tls_internal.h" | 
|  |  | 
|  | #define FAILED (-1) | 
|  |  | 
|  | /* Increment by 1 to make sure we do not store the value of 0, which has | 
|  | * a special meaning in the fdtable subsys. | 
|  | */ | 
|  | #define SD_TO_OBJ(sd) ((void *)(sd + 1)) | 
|  | #define OBJ_TO_SD(obj) (((int)obj) - 1) | 
|  |  | 
|  | static int simplelink_socket_accept(void *obj, struct sockaddr *addr, | 
|  | socklen_t *addrlen); | 
|  |  | 
|  | /* | 
|  | * Convert SL error codes into BSD errno values | 
|  | * note that we are handling the same set of values as in TI SlNetSock | 
|  | * minus the ones that are not defined in ti/drivers/net/wifi/errors.h. | 
|  | */ | 
|  | static int getErrno(_i32 error) | 
|  | { | 
|  | if (error >= 0) { | 
|  | return error; | 
|  | } | 
|  | /* This switch case block is necessary for translating the NWP error | 
|  | * code to BSD ones. The #ifdef in each case are made in order to | 
|  | * reduce code footprint: These cases are compiled if and only if | 
|  | * there's a discrepancy between the BSD error number and the error | 
|  | * code returned by the NWP. | 
|  | */ | 
|  | switch (error) { | 
|  | #if EBADF != SL_ERROR_BSD_EBADF | 
|  | case SL_ERROR_BSD_EBADF: | 
|  | error = EBADF; | 
|  | break; | 
|  | #endif | 
|  | #if ENSOCK !=  SL_ERROR_BSD_ENSOCK | 
|  | case SL_ERROR_BSD_ENSOCK: | 
|  | /* The limit on total # of open sockets has been reached */ | 
|  | error = ENSOCK; | 
|  | break; | 
|  | #endif | 
|  | #if EAGAIN != SL_ERROR_BSD_EAGAIN | 
|  | case SL_ERROR_BSD_EAGAIN: | 
|  | error = EAGAIN; | 
|  | break; | 
|  | #endif | 
|  | #if ENOMEM != SL_ERROR_BSD_ENOMEM | 
|  | case SL_ERROR_BSD_ENOMEM: | 
|  | error = ENOMEM; | 
|  | break; | 
|  | #endif | 
|  | #if EACCES != SL_ERROR_BSD_EACCES | 
|  | case SL_ERROR_BSD_EACCES: | 
|  | error = EACCES; | 
|  | break; | 
|  | #endif | 
|  | #if EFAULT != SL_ERROR_BSD_EFAULT | 
|  | case SL_ERROR_BSD_EFAULT: | 
|  | error = EFAULT; | 
|  | break; | 
|  | #endif | 
|  | #if EINVAL != SL_ERROR_BSD_EINVAL | 
|  | case SL_ERROR_BSD_EINVAL: | 
|  | error = EINVAL; | 
|  | break; | 
|  | #endif | 
|  | #if EDESTADDRREQ != SL_ERROR_BSD_EDESTADDRREQ | 
|  | case SL_ERROR_BSD_EDESTADDRREQ: | 
|  | error = EDESTADDRREQ; | 
|  | break; | 
|  | #endif | 
|  | #if EPROTOTYPE != SL_ERROR_BSD_EPROTOTYPE | 
|  | case SL_ERROR_BSD_EPROTOTYPE: | 
|  | error = EPROTOTYPE; | 
|  | break; | 
|  | #endif | 
|  | #if ENOPROTOOPT != SL_ERROR_BSD_ENOPROTOOPT | 
|  | case SL_ERROR_BSD_ENOPROTOOPT: | 
|  | error = ENOPROTOOPT; | 
|  | break; | 
|  | #endif | 
|  | #if EPROTONOSUPPORT != SL_ERROR_BSD_EPROTONOSUPPORT | 
|  | case SL_ERROR_BSD_EPROTONOSUPPORT: | 
|  | error = EPROTONOSUPPORT; | 
|  | break; | 
|  | #endif | 
|  | #if EOPNOTSUPP != SL_ERROR_BSD_EOPNOTSUPP | 
|  | case SL_ERROR_BSD_EOPNOTSUPP: | 
|  | error = EOPNOTSUPP; | 
|  | break; | 
|  | #endif | 
|  | #if EAFNOSUPPORT != SL_ERROR_BSD_EAFNOSUPPORT | 
|  | case SL_ERROR_BSD_EAFNOSUPPORT: | 
|  | error = EAFNOSUPPORT; | 
|  | break; | 
|  | #endif | 
|  | #if EADDRINUSE != SL_ERROR_BSD_EADDRINUSE | 
|  | case SL_ERROR_BSD_EADDRINUSE: | 
|  | error = EADDRINUSE; | 
|  | break; | 
|  | #endif | 
|  | #if EADDRNOTAVAIL != SL_ERROR_BSD_EADDRNOTAVAIL | 
|  | case SL_ERROR_BSD_EADDRNOTAVAIL: | 
|  | error = EADDRNOTAVAIL; | 
|  | break; | 
|  | #endif | 
|  | #if ENETUNREACH != SL_ERROR_BSD_ENETUNREACH | 
|  | case SL_ERROR_BSD_ENETUNREACH: | 
|  | error = ENETUNREACH; | 
|  | break; | 
|  | #endif | 
|  | #if ENOBUFS != SL_ERROR_BSD_ENOBUFS | 
|  | case SL_ERROR_BSD_ENOBUFS: | 
|  | error = ENOBUFS; | 
|  | break; | 
|  | #endif | 
|  | #if EISCONN != SL_ERROR_BSD_EISCONN | 
|  | case SL_ERROR_BSD_EISCONN: | 
|  | error = EISCONN; | 
|  | break; | 
|  | #endif | 
|  | #if ENOTCONN != SL_ERROR_BSD_ENOTCONN | 
|  | case SL_ERROR_BSD_ENOTCONN: | 
|  | error = ENOTCONN; | 
|  | break; | 
|  | #endif | 
|  | #if ETIMEDOUT != SL_ERROR_BSD_ETIMEDOUT | 
|  | case SL_ERROR_BSD_ETIMEDOUT: | 
|  | error = ETIMEDOUT; | 
|  | break; | 
|  | #endif | 
|  | #if ECONNREFUSED != SL_ERROR_BSD_ECONNREFUSED | 
|  | case SL_ERROR_BSD_ECONNREFUSED: | 
|  | error = ECONNREFUSED; | 
|  | break; | 
|  | #endif | 
|  | /* The cases below are proprietary driver errors, which can | 
|  | * be returned by the SimpleLink Driver, in various cases of failure. | 
|  | * Each is mapped to the corresponding BSD error. | 
|  | */ | 
|  | case SL_POOL_IS_EMPTY: | 
|  | case SL_RET_CODE_NO_FREE_ASYNC_BUFFERS_ERROR: | 
|  | case SL_RET_CODE_MALLOC_ERROR: | 
|  | error = ENOMEM; | 
|  | break; | 
|  | case SL_RET_CODE_INVALID_INPUT: | 
|  | case SL_EZEROLEN: | 
|  | case SL_ESMALLBUF: | 
|  | case SL_INVALPARAM: | 
|  | error = EINVAL; | 
|  | break; | 
|  | default: | 
|  | /* Do nothing .. | 
|  | * If no case is true, that means that the BSD error | 
|  | * code and the code returned by the NWP are either identical, | 
|  | * or no proprietary error has occurred. | 
|  | */ | 
|  | break; | 
|  | } | 
|  |  | 
|  | return error; | 
|  | } | 
|  |  | 
|  | static int simplelink_socket_family_from_posix(int family, int *family_sl) | 
|  | { | 
|  | switch (family) { | 
|  | case AF_INET: | 
|  | *family_sl = SL_AF_INET; | 
|  | break; | 
|  | case AF_INET6: | 
|  | *family_sl = SL_AF_INET6; | 
|  | break; | 
|  | default: | 
|  | return -EAFNOSUPPORT; | 
|  | } | 
|  |  | 
|  | return 0; | 
|  | } | 
|  |  | 
|  | static int simplelink_socket_type_from_posix(int type, int *type_sl) | 
|  | { | 
|  | switch (type) { | 
|  | case SOCK_STREAM: | 
|  | *type_sl = SL_SOCK_STREAM; | 
|  | break; | 
|  | case SOCK_DGRAM: | 
|  | *type_sl = SL_SOCK_DGRAM; | 
|  | break; | 
|  | case SOCK_RAW: | 
|  | *type_sl = SL_SOCK_RAW; | 
|  | break; | 
|  | default: | 
|  | return -ESOCKTNOSUPPORT; | 
|  | } | 
|  |  | 
|  | return 0; | 
|  | } | 
|  |  | 
|  | static int simplelink_socket_proto_from_zephyr(int proto, int *proto_sl) | 
|  | { | 
|  | if (proto >= IPPROTO_TLS_1_0 && proto <= IPPROTO_TLS_1_2) { | 
|  | *proto_sl = SL_SEC_SOCKET; | 
|  | } else if (proto >= IPPROTO_DTLS_1_0 && proto <= IPPROTO_DTLS_1_2) { | 
|  | /* SimpleLink doesn't handle DTLS yet! */ | 
|  | return -EPROTONOSUPPORT; | 
|  | } else { | 
|  | switch (proto) { | 
|  | case IPPROTO_TCP: | 
|  | *proto_sl = SL_IPPROTO_TCP; | 
|  | break; | 
|  | case IPPROTO_UDP: | 
|  | *proto_sl = SL_IPPROTO_UDP; | 
|  | break; | 
|  | default: | 
|  | return -EPROTONOSUPPORT; | 
|  | } | 
|  | } | 
|  |  | 
|  | return 0; | 
|  | } | 
|  |  | 
|  | static int simplelink_socket(int family, int type, int proto) | 
|  | { | 
|  | uint8_t sec_method = SL_SO_SEC_METHOD_SSLv3_TLSV1_2; | 
|  | int sd; | 
|  | int retval = 0; | 
|  | int sl_proto = proto; | 
|  | int err; | 
|  |  | 
|  | /* Map Zephyr socket.h family to SimpleLink's: */ | 
|  | err = simplelink_socket_family_from_posix(family, &family); | 
|  | if (err) { | 
|  | LOG_ERR("unsupported family: %d", family); | 
|  | retval = slcb_SetErrno(-err); | 
|  | goto exit; | 
|  | } | 
|  |  | 
|  | /* Map Zephyr socket.h type to SimpleLink's: */ | 
|  | err = simplelink_socket_type_from_posix(type, &type); | 
|  | if (err) { | 
|  | LOG_ERR("unsupported type: %d", type); | 
|  | retval = slcb_SetErrno(-err); | 
|  | goto exit; | 
|  | } | 
|  |  | 
|  | /* Map Zephyr protocols to TI's values: */ | 
|  | err = simplelink_socket_proto_from_zephyr(proto, &sl_proto); | 
|  | if (err) { | 
|  | LOG_ERR("unsupported proto: %d", proto); | 
|  | retval = slcb_SetErrno(-err); | 
|  | goto exit; | 
|  | } | 
|  |  | 
|  | sd = sl_Socket(family, type, sl_proto); | 
|  | if (sd >= 0) { | 
|  | if (IS_ENABLED(CONFIG_NET_SOCKETS_SOCKOPT_TLS) | 
|  | && sl_proto == SL_SEC_SOCKET) { | 
|  | /* Now, set specific TLS version via setsockopt(): */ | 
|  | sec_method = (proto - IPPROTO_TLS_1_0) + | 
|  | SL_SO_SEC_METHOD_TLSV1; | 
|  | retval = sl_SetSockOpt(sd, SL_SOL_SOCKET, | 
|  | SL_SO_SECMETHOD, | 
|  | &sec_method, sizeof(sec_method)); | 
|  | if (retval < 0) { | 
|  | retval = slcb_SetErrno(EPROTONOSUPPORT); | 
|  | (void)sl_Close(sd); | 
|  | goto exit; | 
|  | } | 
|  | } | 
|  | } | 
|  |  | 
|  | retval = sd; | 
|  |  | 
|  | if (retval < 0) { | 
|  | retval = slcb_SetErrno(getErrno(retval)); | 
|  | } | 
|  |  | 
|  | exit: | 
|  | return retval; | 
|  | } | 
|  |  | 
|  | static int simplelink_close(void *obj) | 
|  | { | 
|  | int sd = OBJ_TO_SD(obj); | 
|  | int retval; | 
|  |  | 
|  | retval = sl_Close(sd); | 
|  |  | 
|  | if (retval < 0) { | 
|  | retval = slcb_SetErrno(getErrno(retval)); | 
|  | } | 
|  |  | 
|  | return retval; | 
|  | } | 
|  |  | 
|  | static SlSockAddr_t *translate_z_to_sl_addrlen(socklen_t addrlen, | 
|  | SlSockAddrIn_t *sl_addr_in, | 
|  | SlSockAddrIn6_t *sl_addr_in6, | 
|  | SlSocklen_t *sl_addrlen) | 
|  | { | 
|  | SlSockAddr_t *sl_addr = NULL; | 
|  |  | 
|  | if (addrlen == sizeof(struct sockaddr_in)) { | 
|  | *sl_addrlen = sizeof(SlSockAddrIn_t); | 
|  | sl_addr = (SlSockAddr_t *)sl_addr_in; | 
|  | } else if (addrlen == sizeof(struct sockaddr_in6)) { | 
|  | *sl_addrlen = sizeof(SlSockAddrIn6_t); | 
|  | sl_addr = (SlSockAddr_t *)sl_addr_in6; | 
|  | } | 
|  |  | 
|  | return sl_addr; | 
|  | } | 
|  |  | 
|  | static SlSockAddr_t *translate_z_to_sl_addrs(const struct sockaddr *addr, | 
|  | socklen_t addrlen, | 
|  | SlSockAddrIn_t *sl_addr_in, | 
|  | SlSockAddrIn6_t *sl_addr_in6, | 
|  | SlSocklen_t *sl_addrlen) | 
|  | { | 
|  | SlSockAddr_t *sl_addr = NULL; | 
|  |  | 
|  | if (addrlen == sizeof(struct sockaddr_in)) { | 
|  | struct sockaddr_in *z_sockaddr_in = (struct sockaddr_in *)addr; | 
|  |  | 
|  | *sl_addrlen = sizeof(SlSockAddrIn_t); | 
|  | sl_addr_in->sin_family = SL_AF_INET; | 
|  | sl_addr_in->sin_port = z_sockaddr_in->sin_port; | 
|  | sl_addr_in->sin_addr.s_addr = | 
|  | z_sockaddr_in->sin_addr.s_addr; | 
|  |  | 
|  | sl_addr = (SlSockAddr_t *)sl_addr_in; | 
|  | } else if (addrlen == sizeof(struct sockaddr_in6)) { | 
|  | struct sockaddr_in6 *z_sockaddr_in6 = | 
|  | (struct sockaddr_in6 *)addr; | 
|  |  | 
|  | *sl_addrlen = sizeof(SlSockAddrIn6_t); | 
|  | sl_addr_in6->sin6_family = SL_AF_INET6; | 
|  | sl_addr_in6->sin6_port = z_sockaddr_in6->sin6_port; | 
|  | memcpy(sl_addr_in6->sin6_addr._S6_un._S6_u32, | 
|  | z_sockaddr_in6->sin6_addr.s6_addr, | 
|  | sizeof(sl_addr_in6->sin6_addr._S6_un._S6_u32)); | 
|  |  | 
|  | sl_addr = (SlSockAddr_t *)sl_addr_in6; | 
|  | } | 
|  |  | 
|  | return sl_addr; | 
|  | } | 
|  |  | 
|  | static void translate_sl_to_z_addr(SlSockAddr_t *sl_addr, | 
|  | SlSocklen_t sl_addrlen, | 
|  | struct sockaddr *addr, | 
|  | socklen_t *addrlen) | 
|  | { | 
|  | SlSockAddrIn_t *sl_addr_in; | 
|  | SlSockAddrIn6_t *sl_addr_in6; | 
|  |  | 
|  | if (sl_addr->sa_family == SL_AF_INET) { | 
|  | if (sl_addrlen == (SlSocklen_t)sizeof(SlSockAddrIn_t)) { | 
|  | struct sockaddr_in *z_sockaddr_in = | 
|  | (struct sockaddr_in *)addr; | 
|  |  | 
|  | sl_addr_in = (SlSockAddrIn_t *)sl_addr; | 
|  | z_sockaddr_in->sin_family = AF_INET; | 
|  | z_sockaddr_in->sin_port = sl_addr_in->sin_port; | 
|  | z_sockaddr_in->sin_addr.s_addr = | 
|  | sl_addr_in->sin_addr.s_addr; | 
|  | *addrlen = sizeof(struct sockaddr_in); | 
|  | } else { | 
|  | *addrlen = sl_addrlen; | 
|  | } | 
|  | } else if (sl_addr->sa_family == SL_AF_INET6) { | 
|  | if (sl_addrlen == sizeof(SlSockAddrIn6_t)) { | 
|  | struct sockaddr_in6 *z_sockaddr_in6 = | 
|  | (struct sockaddr_in6 *)addr; | 
|  | sl_addr_in6 = (SlSockAddrIn6_t *)sl_addr; | 
|  |  | 
|  | z_sockaddr_in6->sin6_family = AF_INET6; | 
|  | z_sockaddr_in6->sin6_port = sl_addr_in6->sin6_port; | 
|  | z_sockaddr_in6->sin6_scope_id = | 
|  | (uint8_t)sl_addr_in6->sin6_scope_id; | 
|  | memcpy(z_sockaddr_in6->sin6_addr.s6_addr, | 
|  | sl_addr_in6->sin6_addr._S6_un._S6_u32, | 
|  | sizeof(z_sockaddr_in6->sin6_addr.s6_addr)); | 
|  | *addrlen = sizeof(struct sockaddr_in6); | 
|  | } else { | 
|  | *addrlen = sl_addrlen; | 
|  | } | 
|  | } | 
|  | } | 
|  |  | 
|  | static int simplelink_accept(void *obj, struct sockaddr *addr, | 
|  | socklen_t *addrlen) | 
|  | { | 
|  | int sd = OBJ_TO_SD(obj); | 
|  | int retval; | 
|  | SlSockAddr_t *sl_addr; | 
|  | SlSockAddrIn_t sl_addr_in; | 
|  | SlSockAddrIn6_t sl_addr_in6; | 
|  | SlSocklen_t sl_addrlen; | 
|  |  | 
|  | if ((addrlen == NULL) || (addr == NULL)) { | 
|  | retval = SL_RET_CODE_INVALID_INPUT; | 
|  | goto exit; | 
|  | } | 
|  |  | 
|  | /* Translate between Zephyr's and SimpleLink's sockaddr's: */ | 
|  | sl_addr = translate_z_to_sl_addrlen(*addrlen, &sl_addr_in, &sl_addr_in6, | 
|  | &sl_addrlen); | 
|  | if (sl_addr == NULL) { | 
|  | retval = SL_RET_CODE_INVALID_INPUT; | 
|  | goto exit; | 
|  | } | 
|  |  | 
|  | retval = sl_Accept(sd, sl_addr, &sl_addrlen); | 
|  | if (retval < 0) { | 
|  | goto exit; | 
|  | } | 
|  |  | 
|  | /* Translate returned sl_addr into *addr and set *addrlen: */ | 
|  | translate_sl_to_z_addr(sl_addr, sl_addrlen, addr, addrlen); | 
|  |  | 
|  | exit: | 
|  | if (retval < 0) { | 
|  | retval = slcb_SetErrno(getErrno(retval)); | 
|  | } | 
|  |  | 
|  | return retval; | 
|  | } | 
|  |  | 
|  | static int simplelink_bind(void *obj, const struct sockaddr *addr, | 
|  | socklen_t addrlen) | 
|  | { | 
|  | int sd = OBJ_TO_SD(obj); | 
|  | int retval; | 
|  | SlSockAddr_t *sl_addr; | 
|  | SlSockAddrIn_t sl_addr_in; | 
|  | SlSockAddrIn6_t sl_addr_in6; | 
|  | SlSocklen_t sl_addrlen; | 
|  |  | 
|  | if (addr == NULL) { | 
|  | retval = slcb_SetErrno(EISDIR); | 
|  | return retval; | 
|  | } | 
|  |  | 
|  | /* Translate to sl_Bind() parameters: */ | 
|  | sl_addr = translate_z_to_sl_addrs(addr, addrlen, &sl_addr_in, | 
|  | &sl_addr_in6, &sl_addrlen); | 
|  |  | 
|  | if (sl_addr == NULL) { | 
|  | retval = SL_RET_CODE_INVALID_INPUT; | 
|  | goto exit; | 
|  | } | 
|  |  | 
|  | retval = sl_Bind(sd, sl_addr, sl_addrlen); | 
|  |  | 
|  | exit: | 
|  | if (retval < 0) { | 
|  | retval = slcb_SetErrno(getErrno(retval)); | 
|  | } | 
|  |  | 
|  | return retval; | 
|  | } | 
|  |  | 
|  | static int simplelink_listen(void *obj, int backlog) | 
|  | { | 
|  | int sd = OBJ_TO_SD(obj); | 
|  | int retval; | 
|  |  | 
|  | retval = (int)sl_Listen(sd, backlog); | 
|  |  | 
|  | if (retval < 0) { | 
|  | retval = slcb_SetErrno(getErrno(retval)); | 
|  | } | 
|  |  | 
|  | return retval; | 
|  | } | 
|  |  | 
|  | static int simplelink_connect(void *obj, const struct sockaddr *addr, | 
|  | socklen_t addrlen) | 
|  | { | 
|  | int sd = OBJ_TO_SD(obj); | 
|  | int retval; | 
|  | SlSockAddr_t *sl_addr; | 
|  | SlSockAddrIn_t sl_addr_in; | 
|  | SlSockAddrIn6_t sl_addr_in6; | 
|  | SlSocklen_t sl_addrlen; | 
|  |  | 
|  | __ASSERT_NO_MSG(addr); | 
|  |  | 
|  | /* Translate to sl_Connect() parameters: */ | 
|  | sl_addr = translate_z_to_sl_addrs(addr, addrlen, &sl_addr_in, | 
|  | &sl_addr_in6, &sl_addrlen); | 
|  |  | 
|  | if (sl_addr == NULL) { | 
|  | retval = SL_RET_CODE_INVALID_INPUT; | 
|  | goto exit; | 
|  | } | 
|  |  | 
|  | retval = sl_Connect(sd, sl_addr, sl_addrlen); | 
|  |  | 
|  | /* TBD: Until we have a good way to get correct date from Zephyr, | 
|  | * log a date validation error as a warning, but continue connection: | 
|  | */ | 
|  | if (retval == SL_ERROR_BSD_ESECDATEERROR) { | 
|  | LOG_WRN("Failed certificate date validation: %d", retval); | 
|  | retval = 0; | 
|  | } | 
|  |  | 
|  | /* Warn users when root CA is not in the certificate catalog. | 
|  | * For enhanced security, users should update the catalog with the | 
|  | * certificates for sites the device is expected to connect to. Note | 
|  | * the connection is established successfully even when the root CA | 
|  | * is not part of the catalog. | 
|  | */ | 
|  | if (retval == SL_ERROR_BSD_ESECUNKNOWNROOTCA) { | 
|  | LOG_WRN("Unknown root CA used. For proper security, please " | 
|  | "use a root CA that is part of the certificate " | 
|  | "catalog in production systems."); | 
|  | retval = 0; | 
|  | } | 
|  |  | 
|  | exit: | 
|  | if (retval < 0) { | 
|  | retval = slcb_SetErrno(getErrno(retval)); | 
|  | } | 
|  |  | 
|  | return retval; | 
|  | } | 
|  |  | 
|  | #define ONE_THOUSAND 1000 | 
|  |  | 
|  | static const struct socket_op_vtable simplelink_socket_fd_op_vtable; | 
|  |  | 
|  | static int simplelink_poll(struct zsock_pollfd *fds, int nfds, int msecs) | 
|  | { | 
|  | int max_sd = 0; | 
|  | struct SlTimeval_t tv, *ptv; | 
|  | SlFdSet_t rfds;	 /* Set of read file descriptors */ | 
|  | SlFdSet_t wfds;	 /* Set of write file descriptors */ | 
|  | int i, retval, sd; | 
|  | void *obj; | 
|  |  | 
|  | if (nfds > SL_FD_SETSIZE) { | 
|  | retval = slcb_SetErrno(EINVAL); | 
|  | goto exit; | 
|  | } | 
|  |  | 
|  | /* Convert time to SlTimeval struct values: */ | 
|  | if (msecs == SYS_FOREVER_MS) { | 
|  | ptv = NULL; | 
|  | } else { | 
|  | tv.tv_sec = msecs / ONE_THOUSAND; | 
|  | tv.tv_usec = (msecs % ONE_THOUSAND) * ONE_THOUSAND; | 
|  | ptv = &tv; | 
|  | } | 
|  |  | 
|  | /* Setup read and write fds for select, based on pollfd fields: */ | 
|  | SL_SOCKET_FD_ZERO(&rfds); | 
|  | SL_SOCKET_FD_ZERO(&wfds); | 
|  |  | 
|  | for (i = 0; i < nfds; i++) { | 
|  | fds[i].revents = 0; | 
|  | if (fds[i].fd < 0) { | 
|  | continue; | 
|  | } else { | 
|  | obj = zvfs_get_fd_obj(fds[i].fd, | 
|  | (const struct fd_op_vtable *) | 
|  | &simplelink_socket_fd_op_vtable, | 
|  | ENOTSUP); | 
|  | if (obj != NULL) { | 
|  | /* Offloaded socket found. */ | 
|  | sd = OBJ_TO_SD(obj); | 
|  | } else { | 
|  | /* Non-offloaded socket, return an error. */ | 
|  | retval = slcb_SetErrno(EINVAL); | 
|  | goto exit; | 
|  | } | 
|  | } | 
|  | if (fds[i].events & ZSOCK_POLLIN) { | 
|  | SL_SOCKET_FD_SET(sd, &rfds); | 
|  | } | 
|  | if (fds[i].events & ZSOCK_POLLOUT) { | 
|  | SL_SOCKET_FD_SET(sd, &wfds); | 
|  | } | 
|  | if (sd > max_sd) { | 
|  | max_sd = sd; | 
|  | } | 
|  | } | 
|  |  | 
|  | /* Wait for requested read and write fds to be ready: */ | 
|  | retval = sl_Select(max_sd + 1, &rfds, &wfds, NULL, ptv); | 
|  | if (retval > 0) { | 
|  | for (i = 0; i < nfds; i++) { | 
|  | if (fds[i].fd >= 0) { | 
|  | obj = zvfs_get_fd_obj( | 
|  | fds[i].fd, | 
|  | (const struct fd_op_vtable *) | 
|  | &simplelink_socket_fd_op_vtable, | 
|  | ENOTSUP); | 
|  | sd = OBJ_TO_SD(obj); | 
|  | if (SL_SOCKET_FD_ISSET(sd, &rfds)) { | 
|  | fds[i].revents |= ZSOCK_POLLIN; | 
|  | } | 
|  | if (SL_SOCKET_FD_ISSET(sd, &wfds)) { | 
|  | fds[i].revents |= ZSOCK_POLLOUT; | 
|  | } | 
|  | } | 
|  | } | 
|  | } | 
|  |  | 
|  | if (retval < 0) { | 
|  | retval = slcb_SetErrno(getErrno(retval)); | 
|  | } | 
|  |  | 
|  | exit: | 
|  | return retval; | 
|  | } | 
|  |  | 
|  | #ifdef CONFIG_NET_SOCKETS_SOCKOPT_TLS | 
|  |  | 
|  | /* Iterate through the list of Zephyr's credential types, and | 
|  | * map to SimpleLink values, then set stored filenames | 
|  | * via SimpleLink's sl_SetSockOpt() | 
|  | */ | 
|  | static int map_credentials(int sd, const void *optval, socklen_t optlen) | 
|  | { | 
|  | sec_tag_t *sec_tags = (sec_tag_t *)optval; | 
|  | int retval = 0; | 
|  | int sec_tags_len; | 
|  | sec_tag_t tag; | 
|  | int opt; | 
|  | int i; | 
|  | struct tls_credential *cert; | 
|  |  | 
|  | if ((optlen % sizeof(sec_tag_t)) != 0 || (optlen == 0)) { | 
|  | retval = EINVAL; | 
|  | goto exit; | 
|  | } else { | 
|  | sec_tags_len = optlen / sizeof(sec_tag_t); | 
|  | } | 
|  |  | 
|  | /* For each tag, retrieve the credentials value and type: */ | 
|  | for (i = 0; i < sec_tags_len; i++) { | 
|  | tag = sec_tags[i]; | 
|  | cert = credential_next_get(tag, NULL); | 
|  | while (cert != NULL) { | 
|  | /* Map Zephyr cert types to Simplelink cert options: */ | 
|  | switch (cert->type) { | 
|  | case TLS_CREDENTIAL_CA_CERTIFICATE: | 
|  | opt = SL_SO_SECURE_FILES_CA_FILE_NAME; | 
|  | break; | 
|  | case TLS_CREDENTIAL_SERVER_CERTIFICATE: | 
|  | opt = SL_SO_SECURE_FILES_CERTIFICATE_FILE_NAME; | 
|  | break; | 
|  | case TLS_CREDENTIAL_PRIVATE_KEY: | 
|  | opt = SL_SO_SECURE_FILES_PRIVATE_KEY_FILE_NAME; | 
|  | break; | 
|  | case TLS_CREDENTIAL_NONE: | 
|  | case TLS_CREDENTIAL_PSK: | 
|  | case TLS_CREDENTIAL_PSK_ID: | 
|  | default: | 
|  | /* Not handled by SimpleLink: */ | 
|  | retval = EINVAL; | 
|  | goto exit; | 
|  | } | 
|  | retval = sl_SetSockOpt(sd, SL_SOL_SOCKET, opt, | 
|  | cert->buf, | 
|  | (SlSocklen_t)cert->len); | 
|  | if (retval < 0) { | 
|  | retval = getErrno(retval); | 
|  | break; | 
|  | } | 
|  | cert = credential_next_get(tag, cert); | 
|  | } | 
|  | } | 
|  |  | 
|  | exit: | 
|  | return retval; | 
|  | } | 
|  | #else | 
|  | static int map_credentials(int sd, const void *optval, socklen_t optlen) | 
|  | { | 
|  | return 0; | 
|  | } | 
|  | #endif  /* CONFIG_NET_SOCKETS_SOCKOPT_TLS */ | 
|  |  | 
|  | /* Needed to keep line lengths < 80: */ | 
|  | #define _SEC_DOMAIN_VERIF SL_SO_SECURE_DOMAIN_NAME_VERIFICATION | 
|  |  | 
|  | static int simplelink_setsockopt(void *obj, int level, int optname, | 
|  | const void *optval, socklen_t optlen) | 
|  | { | 
|  | int sd = OBJ_TO_SD(obj); | 
|  | int retval; | 
|  |  | 
|  | if (IS_ENABLED(CONFIG_NET_SOCKETS_SOCKOPT_TLS) && level == SOL_TLS) { | 
|  | /* Handle Zephyr's SOL_TLS secure socket options: */ | 
|  | switch (optname) { | 
|  | case TLS_SEC_TAG_LIST: | 
|  | /* Bind credential filenames to this socket: */ | 
|  | retval = map_credentials(sd, optval, optlen); | 
|  | if (retval != 0) { | 
|  | retval = slcb_SetErrno(retval); | 
|  | goto exit; | 
|  | } | 
|  | break; | 
|  | case TLS_HOSTNAME: | 
|  | retval = sl_SetSockOpt(sd, SL_SOL_SOCKET, | 
|  | _SEC_DOMAIN_VERIF, | 
|  | (const char *)optval, optlen); | 
|  | break; | 
|  | case TLS_PEER_VERIFY: | 
|  | if (optval) { | 
|  | /* | 
|  | * Not currently supported. Verification | 
|  | * is automatically performed if a CA | 
|  | * certificate is set. We are returning | 
|  | * success here to allow | 
|  | * mqtt_client_tls_connect() | 
|  | * to proceed, given it requires | 
|  | * verification and it is indeed | 
|  | * performed when the cert is set. | 
|  | */ | 
|  | if (*(uint32_t *)optval != 2U) { | 
|  | retval = slcb_SetErrno(ENOTSUP); | 
|  | goto exit; | 
|  | } else { | 
|  | retval = 0; | 
|  | } | 
|  | } else { | 
|  | retval = slcb_SetErrno(EINVAL); | 
|  | goto exit; | 
|  | } | 
|  | break; | 
|  | case TLS_CIPHERSUITE_LIST: | 
|  | case TLS_DTLS_ROLE: | 
|  | /* Not yet supported: */ | 
|  | retval = slcb_SetErrno(ENOTSUP); | 
|  | goto exit; | 
|  | default: | 
|  | retval = slcb_SetErrno(EINVAL); | 
|  | goto exit; | 
|  | } | 
|  | } else { | 
|  | /* Can be SOL_SOCKET or TI specific: */ | 
|  |  | 
|  | /* Note: this logic should match SimpleLink SDK's socket.c: */ | 
|  | switch (optname) { | 
|  | case TCP_NODELAY: | 
|  | if (optval) { | 
|  | /* if user wishes to have TCP_NODELAY = FALSE, | 
|  | * we return EINVAL and fail in the cases below. | 
|  | */ | 
|  | if (*(uint32_t *)optval) { | 
|  | retval = 0; | 
|  | goto exit; | 
|  | } | 
|  | } | 
|  | /* These sock opts aren't supported by the cc32xx | 
|  | * network stack, so we ignore them and set errno to | 
|  | * EINVAL in order to not break "off-the-shelf" BSD | 
|  | * code. | 
|  | */ | 
|  | case SO_BROADCAST: | 
|  | case SO_REUSEADDR: | 
|  | case SO_SNDBUF: | 
|  | retval = slcb_SetErrno(EINVAL); | 
|  | goto exit; | 
|  | default: | 
|  | break; | 
|  | } | 
|  | retval = sl_SetSockOpt(sd, SL_SOL_SOCKET, optname, optval, | 
|  | (SlSocklen_t)optlen); | 
|  | } | 
|  |  | 
|  | if (retval < 0) { | 
|  | retval = slcb_SetErrno(getErrno(retval)); | 
|  | } | 
|  |  | 
|  | exit: | 
|  | return retval; | 
|  | } | 
|  |  | 
|  | static int simplelink_getsockopt(void *obj, int level, int optname, | 
|  | void *optval, socklen_t *optlen) | 
|  | { | 
|  | int sd = OBJ_TO_SD(obj); | 
|  | int retval; | 
|  |  | 
|  | if (IS_ENABLED(CONFIG_NET_SOCKETS_SOCKOPT_TLS) && level == SOL_TLS) { | 
|  | /* Handle Zephyr's SOL_TLS secure socket options: */ | 
|  | switch (optname) { | 
|  | case TLS_SEC_TAG_LIST: | 
|  | case TLS_CIPHERSUITE_LIST: | 
|  | case TLS_CIPHERSUITE_USED: | 
|  | /* Not yet supported: */ | 
|  | retval = slcb_SetErrno(ENOTSUP); | 
|  | goto exit; | 
|  | default: | 
|  | retval = slcb_SetErrno(EINVAL); | 
|  | goto exit; | 
|  | } | 
|  | } else { | 
|  | /* Can be SOL_SOCKET or TI specific: */ | 
|  |  | 
|  | /* Note: this logic should match SimpleLink SDK's socket.c: */ | 
|  | switch (optname) { | 
|  | /* TCP_NODELAY always set by the NWP, so return True */ | 
|  | case TCP_NODELAY: | 
|  | if (optval) { | 
|  | (*(_u32 *)optval) = TRUE; | 
|  | retval = 0; | 
|  | goto exit; | 
|  | } | 
|  | /* These sock opts aren't supported by the cc32xx | 
|  | * network stack, so we silently ignore them and set | 
|  | * errno to EINVAL in order to not break "off-the-shelf" | 
|  | * BSD code. | 
|  | */ | 
|  | case SO_BROADCAST: | 
|  | case SO_REUSEADDR: | 
|  | case SO_SNDBUF: | 
|  | retval = slcb_SetErrno(EINVAL); | 
|  | goto exit; | 
|  | default: | 
|  | break; | 
|  | } | 
|  | retval = sl_GetSockOpt(sd, SL_SOL_SOCKET, optname, optval, | 
|  | (SlSocklen_t *)optlen); | 
|  | } | 
|  |  | 
|  | if (retval < 0) { | 
|  | retval = slcb_SetErrno(getErrno(retval)); | 
|  | } | 
|  |  | 
|  | exit: | 
|  | return retval; | 
|  | } | 
|  |  | 
|  | /* SimpleLink does not support flags in recv. | 
|  | * However, to enable more Zephyr apps to use this socket_offload, rather than | 
|  | * failing with ENOTSUP, we can closely emulate the MSG_DONTWAIT feature using | 
|  | * SimpleLink socket options. | 
|  | */ | 
|  | static int handle_recv_flags(int sd, int flags, bool set, int *nb_enabled) | 
|  | { | 
|  | ssize_t retval = 0; | 
|  | SlSocklen_t optlen = sizeof(SlSockNonblocking_t); | 
|  | SlSockNonblocking_t enableOption; | 
|  |  | 
|  | if (flags & ZSOCK_MSG_PEEK) { | 
|  | retval = ENOTSUP; | 
|  | } else if (flags & ZSOCK_MSG_DONTWAIT) { | 
|  | if (set) { | 
|  | /* Get previous state, to restore later: */ | 
|  | sl_GetSockOpt(sd, SL_SOL_SOCKET, SL_SO_NONBLOCKING, | 
|  | (_u8 *)&enableOption, &optlen); | 
|  | *nb_enabled = enableOption.NonBlockingEnabled; | 
|  |  | 
|  | /* Now, set to non_blocking if not already set: */ | 
|  | if (!*nb_enabled) { | 
|  | enableOption.NonBlockingEnabled = 1; | 
|  | sl_SetSockOpt(sd, SL_SOL_SOCKET, | 
|  | SL_SO_NONBLOCKING, | 
|  | (_u8 *)&enableOption, | 
|  | sizeof(enableOption)); | 
|  | } | 
|  | } else { | 
|  | /* Restore socket to previous state: */ | 
|  | enableOption.NonBlockingEnabled = *nb_enabled; | 
|  | sl_SetSockOpt(sd, SL_SOL_SOCKET, SL_SO_NONBLOCKING, | 
|  | (_u8 *)&enableOption, | 
|  | sizeof(enableOption)); | 
|  | } | 
|  | } | 
|  |  | 
|  | return retval; | 
|  | } | 
|  |  | 
|  | static ssize_t simplelink_recvfrom(void *obj, void *buf, size_t len, int flags, | 
|  | struct sockaddr *from, socklen_t *fromlen) | 
|  | { | 
|  | int sd = OBJ_TO_SD(obj); | 
|  | ssize_t retval; | 
|  | SlSockAddr_t *sl_addr; | 
|  | SlSockAddrIn_t sl_addr_in; | 
|  | SlSockAddrIn6_t sl_addr_in6; | 
|  | SlSocklen_t sl_addrlen; | 
|  | int nb_enabled; | 
|  |  | 
|  | retval = handle_recv_flags(sd, flags, TRUE, &nb_enabled); | 
|  |  | 
|  | if (!retval) { | 
|  | /* Translate to sl_RecvFrom() parameters: */ | 
|  | if (fromlen != NULL) { | 
|  | sl_addr = translate_z_to_sl_addrlen(*fromlen, | 
|  | &sl_addr_in, | 
|  | &sl_addr_in6, | 
|  | &sl_addrlen); | 
|  | retval = (ssize_t)sl_RecvFrom(sd, buf, len, 0, sl_addr, | 
|  | &sl_addrlen); | 
|  | } else { | 
|  | retval = (ssize_t)sl_Recv(sd, buf, len, 0); | 
|  | } | 
|  |  | 
|  | handle_recv_flags(sd, flags, FALSE, &nb_enabled); | 
|  | if (retval >= 0) { | 
|  | if (fromlen != NULL) { | 
|  | /* | 
|  | * Translate sl_addr into *addr and set | 
|  | * *addrlen | 
|  | */ | 
|  | translate_sl_to_z_addr(sl_addr, sl_addrlen, | 
|  | from, fromlen); | 
|  | } | 
|  | } else { | 
|  | retval = slcb_SetErrno(getErrno(retval)); | 
|  | } | 
|  | } else { | 
|  | retval = slcb_SetErrno(retval); | 
|  | } | 
|  |  | 
|  | return retval; | 
|  | } | 
|  |  | 
|  | static ssize_t simplelink_sendto(void *obj, const void *buf, size_t len, | 
|  | int flags, const struct sockaddr *to, | 
|  | socklen_t tolen) | 
|  | { | 
|  | int sd = OBJ_TO_SD(obj); | 
|  | ssize_t retval; | 
|  | SlSockAddr_t *sl_addr; | 
|  | SlSockAddrIn_t sl_addr_in; | 
|  | SlSockAddrIn6_t sl_addr_in6; | 
|  | SlSocklen_t sl_addrlen; | 
|  |  | 
|  | if (to != NULL) { | 
|  | /* Translate to sl_SendTo() parameters: */ | 
|  | sl_addr = translate_z_to_sl_addrs(to, tolen, &sl_addr_in, | 
|  | &sl_addr_in6, &sl_addrlen); | 
|  |  | 
|  | if (sl_addr == NULL) { | 
|  | retval = SL_RET_CODE_INVALID_INPUT; | 
|  | goto exit; | 
|  | } | 
|  |  | 
|  | retval = sl_SendTo(sd, buf, (uint16_t)len, flags, | 
|  | sl_addr, sl_addrlen); | 
|  | } else { | 
|  | retval = (ssize_t)sl_Send(sd, buf, len, flags); | 
|  | } | 
|  |  | 
|  | exit: | 
|  | if (retval < 0) { | 
|  | retval = slcb_SetErrno(getErrno(retval)); | 
|  | } | 
|  |  | 
|  | return retval; | 
|  | } | 
|  |  | 
|  | static ssize_t simplelink_sendmsg(void *obj, const struct msghdr *msg, | 
|  | int flags) | 
|  | { | 
|  | errno = -ENOTSUP; | 
|  | return -1; | 
|  | } | 
|  |  | 
|  | /* Adds address info entry to a list */ | 
|  | static int set_addr_info(const struct SlNetUtil_addrInfo_t *sl_ai, | 
|  | struct zsock_addrinfo **res) | 
|  | { | 
|  | struct zsock_addrinfo *ai; | 
|  | struct sockaddr *ai_addr; | 
|  | int retval = 0; | 
|  |  | 
|  | ai = calloc(1, sizeof(struct zsock_addrinfo)); | 
|  | if (!ai) { | 
|  | retval = DNS_EAI_MEMORY; | 
|  | goto exit; | 
|  | } else { | 
|  | /* Now, alloc the embedded sockaddr struct: */ | 
|  | ai_addr = calloc(1, sizeof(struct sockaddr)); | 
|  | if (!ai_addr) { | 
|  | retval = DNS_EAI_MEMORY; | 
|  | free(ai); | 
|  | goto exit; | 
|  | } | 
|  | } | 
|  |  | 
|  | /* Now, fill in the fields of res (addrinfo struct): */ | 
|  | ai->ai_family = (sl_ai->ai_family == SL_AF_INET6 ? AF_INET6 : AF_INET); | 
|  | ai->ai_socktype = (sl_ai->ai_socktype == SLNETSOCK_SOCK_DGRAM ? | 
|  | SOCK_DGRAM : SOCK_STREAM); | 
|  | ai->ai_protocol = (sl_ai->ai_protocol == SLNETSOCK_PROTO_UDP ? | 
|  | IPPROTO_UDP : IPPROTO_TCP); | 
|  |  | 
|  | /* Fill sockaddr struct fields based on family: */ | 
|  | if (ai->ai_family == AF_INET) { | 
|  | SlNetSock_AddrIn_t *sl_addr = | 
|  | (SlNetSock_AddrIn_t *)sl_ai->ai_addr; | 
|  |  | 
|  | net_sin(ai_addr)->sin_family = ai->ai_family; | 
|  | net_sin(ai_addr)->sin_addr.s_addr = sl_addr->sin_addr.s_addr; | 
|  | net_sin(ai_addr)->sin_port = sl_addr->sin_port; | 
|  | ai->ai_addrlen = sizeof(struct sockaddr_in); | 
|  | } else { | 
|  | SlNetSock_AddrIn6_t *sl_addr = | 
|  | (SlNetSock_AddrIn6_t *)sl_ai->ai_addr; | 
|  |  | 
|  | net_sin6(ai_addr)->sin6_family = ai->ai_family; | 
|  | net_sin6(ai_addr)->sin6_addr.s6_addr32[0] = | 
|  | sl_addr->sin6_addr._S6_un._S6_u32[0]; | 
|  | net_sin6(ai_addr)->sin6_addr.s6_addr32[1] = | 
|  | sl_addr->sin6_addr._S6_un._S6_u32[1]; | 
|  | net_sin6(ai_addr)->sin6_addr.s6_addr32[2] = | 
|  | sl_addr->sin6_addr._S6_un._S6_u32[2]; | 
|  | net_sin6(ai_addr)->sin6_addr.s6_addr32[3] = | 
|  | sl_addr->sin6_addr._S6_un._S6_u32[3]; | 
|  | net_sin6(ai_addr)->sin6_port = sl_addr->sin6_port; | 
|  | ai->ai_addrlen = sizeof(struct sockaddr_in6); | 
|  | } | 
|  | ai->ai_addr = ai_addr; | 
|  | ai->ai_next = *res; | 
|  | *res = ai; | 
|  |  | 
|  | exit: | 
|  | return retval; | 
|  | } | 
|  |  | 
|  | static int simplelink_getaddrinfo(const char *node, const char *service, | 
|  | const struct zsock_addrinfo *hints, | 
|  | struct zsock_addrinfo **res) | 
|  | { | 
|  | int32_t retval; | 
|  | struct SlNetUtil_addrInfo_t sl_hints; | 
|  | struct SlNetUtil_addrInfo_t *sl_res, *sl_ai; | 
|  |  | 
|  | /* Initialize sl_hints to the defaults */ | 
|  | memset(&sl_hints, 0, sizeof(sl_hints)); | 
|  |  | 
|  | /* Check args: */ | 
|  | if (!res) { | 
|  | retval = DNS_EAI_NONAME; | 
|  | goto exit; | 
|  | } | 
|  |  | 
|  | if (hints) { | 
|  | /* | 
|  | * SlNetUtil only supports AI_NUMERICHOST and AI_PASSIVE, so | 
|  | * the rest are ignored. | 
|  | */ | 
|  | sl_hints.ai_flags |= ((hints->ai_flags & AI_PASSIVE) ? | 
|  | SLNETUTIL_AI_PASSIVE : 0); | 
|  | sl_hints.ai_flags |= ((hints->ai_flags & AI_NUMERICHOST) ? | 
|  | SLNETUTIL_AI_NUMERICHOST : 0); | 
|  | if (hints->ai_family == AF_UNSPEC) { | 
|  | sl_hints.ai_family = SLNETSOCK_AF_UNSPEC; | 
|  | } else { | 
|  | sl_hints.ai_family = (hints->ai_family == AF_INET6 ? | 
|  | SLNETSOCK_AF_INET6 : SLNETSOCK_AF_INET); | 
|  | } | 
|  | if (hints->ai_socktype == 0) { | 
|  | sl_hints.ai_socktype = 0; | 
|  | } else { | 
|  | sl_hints.ai_socktype = | 
|  | (hints->ai_socktype == SOCK_DGRAM ? | 
|  | SLNETSOCK_SOCK_DGRAM : SLNETSOCK_SOCK_STREAM); | 
|  | } | 
|  | if (hints->ai_protocol == 0) { | 
|  | sl_hints.ai_protocol = 0; | 
|  | } else { | 
|  | sl_hints.ai_protocol = | 
|  | (hints->ai_protocol == IPPROTO_UDP ? | 
|  | SLNETSOCK_PROTO_UDP : SLNETSOCK_PROTO_TCP); | 
|  | } | 
|  |  | 
|  | } | 
|  |  | 
|  | /* Now, try to resolve host name: */ | 
|  | retval = SlNetUtil_getAddrInfo(SLNETIF_ID_1, node, | 
|  | service, &sl_hints, &sl_res); | 
|  |  | 
|  | if (retval < 0) { | 
|  | LOG_ERR("Could not resolve name: %s, retval: %d", | 
|  | node, retval); | 
|  | retval = DNS_EAI_NONAME; | 
|  | goto exit; | 
|  | } | 
|  |  | 
|  | sl_ai = sl_res; | 
|  | *res = NULL; | 
|  | while (sl_ai != NULL) { | 
|  | retval = set_addr_info(sl_ai, res); | 
|  | if (retval < 0) { | 
|  | LOG_ERR("Unable to set address info, retval: %d", | 
|  | retval); | 
|  | goto exit; | 
|  | } | 
|  | sl_ai = sl_ai->ai_next; | 
|  | } | 
|  | SlNetUtil_freeAddrInfo(sl_res); | 
|  | exit: | 
|  | return retval; | 
|  | } | 
|  |  | 
|  | static void simplelink_freeaddrinfo(struct zsock_addrinfo *res) | 
|  | { | 
|  | __ASSERT_NO_MSG(res); | 
|  |  | 
|  | free(res->ai_addr); | 
|  | free(res); | 
|  | } | 
|  |  | 
|  | static int simplelink_fcntl(int sd, int cmd, va_list args) | 
|  | { | 
|  | int retval = 0; | 
|  | SlSockNonblocking_t enableOption; | 
|  | SlSocklen_t optlen = sizeof(SlSockNonblocking_t); | 
|  |  | 
|  | switch (cmd) { | 
|  | case F_GETFL: | 
|  | retval = sl_GetSockOpt(sd, SL_SOL_SOCKET, SL_SO_NONBLOCKING, | 
|  | (_u8 *)&enableOption, &optlen); | 
|  | if (retval == 0) { | 
|  | if (enableOption.NonBlockingEnabled) { | 
|  | retval |= O_NONBLOCK; | 
|  | } | 
|  | } | 
|  | break; | 
|  | case F_SETFL: | 
|  | if ((va_arg(args, int) & O_NONBLOCK) != 0) { | 
|  | enableOption.NonBlockingEnabled = 1; | 
|  | } else { | 
|  | enableOption.NonBlockingEnabled = 0; | 
|  | } | 
|  | retval = sl_SetSockOpt(sd, SL_SOL_SOCKET, SL_SO_NONBLOCKING, | 
|  | &enableOption, optlen); | 
|  | break; | 
|  | default: | 
|  | LOG_ERR("Invalid command: %d", cmd); | 
|  | retval = slcb_SetErrno(EINVAL); | 
|  | goto exit; | 
|  | } | 
|  |  | 
|  | if (retval < 0) { | 
|  | retval = slcb_SetErrno(getErrno(retval)); | 
|  | } | 
|  |  | 
|  | exit: | 
|  | return retval; | 
|  | } | 
|  |  | 
|  | static int simplelink_ioctl(void *obj, unsigned int request, va_list args) | 
|  | { | 
|  | int sd = OBJ_TO_SD(obj); | 
|  |  | 
|  | switch (request) { | 
|  | case ZFD_IOCTL_POLL_PREPARE: | 
|  | return -EXDEV; | 
|  |  | 
|  | case ZFD_IOCTL_POLL_UPDATE: | 
|  | return -EOPNOTSUPP; | 
|  |  | 
|  | case ZFD_IOCTL_POLL_OFFLOAD: { | 
|  | struct zsock_pollfd *fds; | 
|  | int nfds; | 
|  | int timeout; | 
|  |  | 
|  | fds = va_arg(args, struct zsock_pollfd *); | 
|  | nfds = va_arg(args, int); | 
|  | timeout = va_arg(args, int); | 
|  |  | 
|  | return simplelink_poll(fds, nfds, timeout); | 
|  | } | 
|  |  | 
|  | /* Otherwise, just forward to offloaded fcntl() | 
|  | * In Zephyr, fcntl() is just an alias of ioctl(). | 
|  | */ | 
|  | default: | 
|  | return simplelink_fcntl(sd, request, args); | 
|  | } | 
|  | } | 
|  |  | 
|  | static ssize_t simplelink_read(void *obj, void *buffer, size_t count) | 
|  | { | 
|  | return simplelink_recvfrom(obj, buffer, count, 0, NULL, 0); | 
|  | } | 
|  |  | 
|  | static ssize_t simplelink_write(void *obj, const void *buffer, | 
|  | size_t count) | 
|  | { | 
|  | return simplelink_sendto(obj, buffer, count, 0, NULL, 0); | 
|  | } | 
|  |  | 
|  | static const struct socket_op_vtable simplelink_socket_fd_op_vtable = { | 
|  | .fd_vtable = { | 
|  | .read = simplelink_read, | 
|  | .write = simplelink_write, | 
|  | .close = simplelink_close, | 
|  | .ioctl = simplelink_ioctl, | 
|  | }, | 
|  | .bind = simplelink_bind, | 
|  | .connect = simplelink_connect, | 
|  | .listen = simplelink_listen, | 
|  | .accept = simplelink_socket_accept, | 
|  | .sendto = simplelink_sendto, | 
|  | .sendmsg = simplelink_sendmsg, | 
|  | .recvfrom = simplelink_recvfrom, | 
|  | .getsockopt = simplelink_getsockopt, | 
|  | .setsockopt = simplelink_setsockopt, | 
|  | }; | 
|  |  | 
|  | static bool simplelink_is_supported(int family, int type, int proto) | 
|  | { | 
|  | int dummy; | 
|  | int err; | 
|  |  | 
|  | err = simplelink_socket_family_from_posix(family, &dummy); | 
|  | if (err) { | 
|  | return false; | 
|  | } | 
|  |  | 
|  | err = simplelink_socket_type_from_posix(type, &dummy); | 
|  | if (err) { | 
|  | return false; | 
|  | } | 
|  |  | 
|  | err = simplelink_socket_proto_from_zephyr(proto, &dummy); | 
|  | if (err) { | 
|  | return false; | 
|  | } | 
|  |  | 
|  | return true; | 
|  | } | 
|  |  | 
|  | int simplelink_socket_create(int family, int type, int proto) | 
|  | { | 
|  | int fd = zvfs_reserve_fd(); | 
|  | int sock; | 
|  |  | 
|  | if (fd < 0) { | 
|  | return -1; | 
|  | } | 
|  |  | 
|  | sock = simplelink_socket(family, type, proto); | 
|  | if (sock < 0) { | 
|  | zvfs_free_fd(fd); | 
|  | return -1; | 
|  | } | 
|  |  | 
|  | zvfs_finalize_typed_fd(fd, SD_TO_OBJ(sock), | 
|  | (const struct fd_op_vtable *)&simplelink_socket_fd_op_vtable, | 
|  | ZVFS_MODE_IFSOCK); | 
|  |  | 
|  | return fd; | 
|  | } | 
|  |  | 
|  | static int simplelink_socket_accept(void *obj, struct sockaddr *addr, | 
|  | socklen_t *addrlen) | 
|  | { | 
|  | int fd = zvfs_reserve_fd(); | 
|  | int sock; | 
|  |  | 
|  | if (fd < 0) { | 
|  | return -1; | 
|  | } | 
|  |  | 
|  | sock = simplelink_accept(obj, addr, addrlen); | 
|  | if (sock < 0) { | 
|  | zvfs_free_fd(fd); | 
|  | return -1; | 
|  | } | 
|  |  | 
|  | zvfs_finalize_typed_fd(fd, SD_TO_OBJ(sock), | 
|  | (const struct fd_op_vtable *)&simplelink_socket_fd_op_vtable, | 
|  | ZVFS_MODE_IFSOCK); | 
|  |  | 
|  | return fd; | 
|  | } | 
|  |  | 
|  | #ifdef CONFIG_NET_SOCKETS_OFFLOAD | 
|  | NET_SOCKET_OFFLOAD_REGISTER(simplelink, CONFIG_NET_SOCKETS_OFFLOAD_PRIORITY, AF_UNSPEC, | 
|  | simplelink_is_supported, simplelink_socket_create); | 
|  | #endif | 
|  |  | 
|  | void simplelink_sockets_init(void) | 
|  | { | 
|  | } | 
|  |  | 
|  | const struct socket_dns_offload simplelink_dns_ops = { | 
|  | .getaddrinfo = simplelink_getaddrinfo, | 
|  | .freeaddrinfo = simplelink_freeaddrinfo, | 
|  | }; |