123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122 |
- /*
- * Copyright (c) 2006-2018, RT-Thread Development Team
- *
- * SPDX-License-Identifier: Apache-2.0
- *
- * Change Logs:
- * Date Author Notes
- * 2018-05-23 ChenYong First version
- * 2018-11-12 ChenYong Add TLS support
- */
- #include <rtthread.h>
- #include <rthw.h>
- #include <sys/time.h>
- #include <sal_socket.h>
- #include <sal_netdb.h>
- #ifdef SAL_USING_TLS
- #include <sal_tls.h>
- #endif
- #include <sal.h>
- #include <netdev.h>
- #include <ipc/workqueue.h>
- /* check system workqueue stack size */
- #if RT_SYSTEM_WORKQUEUE_STACKSIZE < 1536
- #error "The system workqueue stack size must more than 1536 bytes"
- #endif
- #define DBG_TAG "sal.skt"
- #define DBG_LVL DBG_INFO
- #include <rtdbg.h>
- #define SOCKET_TABLE_STEP_LEN 4
- /* the socket table used to dynamic allocate sockets */
- struct sal_socket_table
- {
- uint32_t max_socket;
- struct sal_socket **sockets;
- };
- #ifdef SAL_USING_TLS
- /* The global TLS protocol options */
- static struct sal_proto_tls *proto_tls;
- #endif
- /* The global socket table */
- static struct sal_socket_table socket_table;
- static struct rt_mutex sal_core_lock;
- static rt_bool_t init_ok = RT_FALSE;
- #define IS_SOCKET_PROTO_TLS(sock) (((sock)->protocol == PROTOCOL_TLS) || \
- ((sock)->protocol == PROTOCOL_DTLS))
- #define SAL_SOCKOPS_PROTO_TLS_VALID(sock, name) (proto_tls && (proto_tls->ops->name) && IS_SOCKET_PROTO_TLS(sock))
- #define SAL_SOCKOPT_PROTO_TLS_EXEC(sock, name, optval, optlen) \
- do { \
- if (SAL_SOCKOPS_PROTO_TLS_VALID(sock, name)){ \
- return proto_tls->ops->name((sock)->user_data_tls, (optval), (optlen)); \
- } \
- }while(0) \
- #define SAL_SOCKET_OBJ_GET(sock, socket) \
- do { \
- (sock) = sal_get_socket(socket); \
- if ((sock) == RT_NULL) { \
- return -1; \
- } \
- }while(0) \
- #define SAL_NETDEV_IS_UP(netdev) \
- do { \
- if (!netdev_is_up(netdev)) { \
- return -1; \
- } \
- }while(0) \
- #define SAL_NETDEV_SOCKETOPS_VALID(netdev, pf, ops) \
- do { \
- (pf) = (struct sal_proto_family *) netdev->sal_user_data; \
- if ((pf)->skt_ops->ops == RT_NULL){ \
- return -1; \
- } \
- }while(0) \
- #define SAL_NETDEV_NETDBOPS_VALID(netdev, pf, ops) \
- ((netdev) && netdev_is_up(netdev) && \
- ((pf) = (struct sal_proto_family *) (netdev)->sal_user_data) != RT_NULL && \
- (pf)->netdb_ops->ops) \
- /**
- * SAL (Socket Abstraction Layer) initialize.
- *
- * @return result 0: initialize success
- * -1: initialize failed
- */
- int sal_init(void)
- {
- int cn;
- if (init_ok)
- {
- LOG_D("Socket Abstraction Layer is already initialized.");
- return 0;
- }
- /* init sal socket table */
- cn = SOCKET_TABLE_STEP_LEN < SAL_SOCKETS_NUM ? SOCKET_TABLE_STEP_LEN : SAL_SOCKETS_NUM;
- socket_table.max_socket = cn;
- socket_table.sockets = rt_calloc(1, cn * sizeof(struct sal_socket *));
- if (socket_table.sockets == RT_NULL)
- {
- LOG_E("No memory for socket table.\n");
- return -1;
- }
- /* create sal socket lock */
- rt_mutex_init(&sal_core_lock, "sal_lock", RT_IPC_FLAG_FIFO);
- LOG_I("Socket Abstraction Layer initialize success.");
- init_ok = RT_TRUE;
- return 0;
- }
- INIT_COMPONENT_EXPORT(sal_init);
- /* check SAL network interface device internet status */
- static void check_netdev_internet_up_work(struct rt_work *work, void *work_data)
- {
- #define SAL_INTERNET_VERSION 0x00
- #define SAL_INTERNET_BUFF_LEN 12
- #define SAL_INTERNET_TIMEOUT (2)
- #define SAL_INTERNET_HOST "link.rt-thread.org"
- #define SAL_INTERNET_PORT 8101
- #define SAL_INTERNET_MONTH_LEN 4
- #define SAL_INTERNET_DATE_LEN 16
- int index, sockfd = -1, result = 0;
- struct sockaddr_in server_addr;
- struct hostent *host;
- struct timeval timeout;
- struct netdev *netdev = (struct netdev *)work_data;
- socklen_t addr_len = sizeof(struct sockaddr_in);
- char send_data[SAL_INTERNET_BUFF_LEN], recv_data = 0;
- struct rt_delayed_work *delay_work = (struct rt_delayed_work *)work;
- const char month[][SAL_INTERNET_MONTH_LEN] = {"Jan", "Feb", "Mar", "Apr", "May", "Jun", "Jul", "Aug", "Sep", "Oct", "Nov", "Dec"};
- char date[SAL_INTERNET_DATE_LEN];
- int moth_num = 0;
- struct sal_proto_family *pf = (struct sal_proto_family *) netdev->sal_user_data;
- const struct sal_socket_ops *skt_ops;
- if (work)
- {
- rt_free(delay_work);
- }
- /* get network interface socket operations */
- if (pf == RT_NULL || pf->skt_ops == RT_NULL)
- {
- result = -RT_ERROR;
- goto __exit;
- }
- host = (struct hostent *) pf->netdb_ops->gethostbyname(SAL_INTERNET_HOST);
- if (host == RT_NULL)
- {
- result = -RT_ERROR;
- goto __exit;
- }
- skt_ops = pf->skt_ops;
- if ((sockfd = skt_ops->socket(AF_INET, SOCK_DGRAM, 0)) < 0)
- {
- result = -RT_ERROR;
- goto __exit;
- }
- server_addr.sin_family = AF_INET;
- server_addr.sin_port = htons(SAL_INTERNET_PORT);
- server_addr.sin_addr = *((struct in_addr *)host->h_addr);
- rt_memset(&(server_addr.sin_zero), 0, sizeof(server_addr.sin_zero));
- timeout.tv_sec = SAL_INTERNET_TIMEOUT;
- timeout.tv_usec = 0;
- /* set receive and send timeout */
- skt_ops->setsockopt(sockfd, SOL_SOCKET, SO_RCVTIMEO, (void *) &timeout, sizeof(timeout));
- skt_ops->setsockopt(sockfd, SOL_SOCKET, SO_SNDTIMEO, (void *) &timeout, sizeof(timeout));
- /* get build moth value*/
- rt_memset(date, 0x00, SAL_INTERNET_DATE_LEN);
- rt_snprintf(date, SAL_INTERNET_DATE_LEN, "%s", __DATE__);
- for (index = 0; index < sizeof(month) / SAL_INTERNET_MONTH_LEN; index++)
- {
- if (rt_memcmp(date, month[index], SAL_INTERNET_MONTH_LEN - 1) == 0)
- {
- moth_num = index + 1;
- break;
- }
- }
- /* not find build month */
- if (moth_num == 0 || moth_num > sizeof(month) / SAL_INTERNET_MONTH_LEN)
- {
- result = -RT_ERROR;
- goto __exit;
- }
- rt_memset(send_data, 0x00, SAL_INTERNET_BUFF_LEN);
- send_data[0] = SAL_INTERNET_VERSION;
- for (index = 0; index < netdev->hwaddr_len; index++)
- {
- send_data[index + 1] = netdev->hwaddr[index] + moth_num;
- }
- send_data[9] = RT_VERSION;
- send_data[10] = RT_SUBVERSION;
- send_data[11] = RT_REVISION;
- skt_ops->sendto(sockfd, send_data, SAL_INTERNET_BUFF_LEN, 0,
- (struct sockaddr *)&server_addr, sizeof(struct sockaddr));
- result = skt_ops->recvfrom(sockfd, &recv_data, sizeof(recv_data), 0, (struct sockaddr *)&server_addr, &addr_len);
- if (result < 0)
- {
- goto __exit;
- }
- if (recv_data == RT_FALSE)
- {
- result = -RT_ERROR;
- goto __exit;
- }
- __exit:
- if (result > 0)
- {
- LOG_D("Set network interface device(%s) internet status up.", netdev->name);
- netdev->flags |= NETDEV_FLAG_INTERNET_UP;
- }
- else
- {
- LOG_D("Set network interface device(%s) internet status down.", netdev->name);
- netdev->flags &= ~NETDEV_FLAG_INTERNET_UP;
- }
- if (sockfd >= 0)
- {
- skt_ops->closesocket(sockfd);
- }
- }
- /**
- * This function will check SAL network interface device internet status.
- *
- * @param netdev the network interface device to check
- */
- int sal_check_netdev_internet_up(struct netdev *netdev)
- {
- /* workqueue for network connect */
- struct rt_delayed_work *net_work = RT_NULL;
- RT_ASSERT(netdev);
- net_work = (struct rt_delayed_work *)rt_calloc(1, sizeof(struct rt_delayed_work));
- if (net_work == RT_NULL)
- {
- LOG_W("No memory for network interface device(%s) delay work.", netdev->name);
- return -1;
- }
- rt_delayed_work_init(net_work, check_netdev_internet_up_work, (void *)netdev);
- rt_work_submit(&(net_work->work), RT_TICK_PER_SECOND);
- return 0;
- }
- /**
- * This function will register TLS protocol to the global TLS protocol.
- *
- * @param pt TLS protocol object
- *
- * @return 0: TLS protocol object register success
- */
- #ifdef SAL_USING_TLS
- int sal_proto_tls_register(const struct sal_proto_tls *pt)
- {
- RT_ASSERT(pt);
- proto_tls = (struct sal_proto_tls *) pt;
- return 0;
- }
- #endif
- /**
- * This function will get sal socket object by sal socket descriptor.
- *
- * @param socket sal socket index
- *
- * @return sal socket object of the current sal socket index
- */
- struct sal_socket *sal_get_socket(int socket)
- {
- struct sal_socket_table *st = &socket_table;
- if (socket < 0 || socket >= (int) st->max_socket)
- {
- return RT_NULL;
- }
- socket = socket - SAL_SOCKET_OFFSET;
- /* check socket structure valid or not */
- RT_ASSERT(st->sockets[socket]->magic == SAL_SOCKET_MAGIC);
- return st->sockets[socket];
- }
- /**
- * This function will lock sal socket.
- *
- * @note please don't invoke it on ISR.
- */
- static void sal_lock(void)
- {
- rt_err_t result;
- result = rt_mutex_take(&sal_core_lock, RT_WAITING_FOREVER);
- if (result != RT_EOK)
- {
- RT_ASSERT(0);
- }
- }
- /**
- * This function will lock sal socket.
- *
- * @note please don't invoke it on ISR.
- */
- static void sal_unlock(void)
- {
- rt_mutex_release(&sal_core_lock);
- }
- /**
- * This function will clean the netdev.
- *
- * @note please don't invoke it on ISR.
- */
- int sal_netdev_cleanup(struct netdev *netdev)
- {
- int idx = 0, find_dev;
- do
- {
- find_dev = 0;
- sal_lock();
- for (idx = 0; idx < socket_table.max_socket; idx++)
- {
- if (socket_table.sockets[idx] && socket_table.sockets[idx]->netdev == netdev)
- {
- find_dev = 1;
- break;
- }
- }
- sal_unlock();
- if (find_dev)
- {
- rt_thread_mdelay(100);
- }
- }
- while (find_dev);
- return 0;
- }
- /**
- * This function will initialize sal socket object and set socket options
- *
- * @param family protocol family
- * @param type socket type
- * @param protocol transfer Protocol
- * @param res sal socket object address
- *
- * @return 0 : socket initialize success
- * -1 : input the wrong family
- * -2 : input the wrong socket type
- * -3 : get network interface failed
- */
- static int socket_init(int family, int type, int protocol, struct sal_socket **res)
- {
- struct sal_socket *sock;
- struct sal_proto_family *pf;
- struct netdev *netdv_def = netdev_default;
- struct netdev *netdev = RT_NULL;
- rt_bool_t flag = RT_FALSE;
- if (family < 0 || family > AF_MAX)
- {
- return -1;
- }
- if (type < 0 || type > SOCK_MAX)
- {
- return -2;
- }
- sock = *res;
- sock->domain = family;
- sock->type = type;
- sock->protocol = protocol;
- if (netdv_def && netdev_is_up(netdv_def))
- {
- /* check default network interface device protocol family */
- pf = (struct sal_proto_family *) netdv_def->sal_user_data;
- if (pf != RT_NULL && pf->skt_ops && (pf->family == family || pf->sec_family == family))
- {
- sock->netdev = netdv_def;
- flag = RT_TRUE;
- }
- }
- if (flag == RT_FALSE)
- {
- /* get network interface device by protocol family */
- netdev = netdev_get_by_family(family);
- if (netdev == RT_NULL)
- {
- LOG_E("not find network interface device by protocol family(%d).", family);
- return -3;
- }
- sock->netdev = netdev;
- }
- return 0;
- }
- static int socket_alloc(struct sal_socket_table *st, int f_socket)
- {
- int idx;
- /* find an empty socket entry */
- for (idx = f_socket; idx < (int) st->max_socket; idx++)
- {
- if (st->sockets[idx] == RT_NULL)
- {
- break;
- }
- }
- /* allocate a larger sockte container */
- if (idx == (int) st->max_socket && st->max_socket < SAL_SOCKETS_NUM)
- {
- int cnt, index;
- struct sal_socket **sockets;
- /* increase the number of socket with 4 step length */
- cnt = st->max_socket + SOCKET_TABLE_STEP_LEN;
- cnt = cnt > SAL_SOCKETS_NUM ? SAL_SOCKETS_NUM : cnt;
- sockets = rt_realloc(st->sockets, cnt * sizeof(struct sal_socket *));
- if (sockets == RT_NULL)
- goto __result; /* return st->max_socket */
- /* clean the new allocated fds */
- for (index = st->max_socket; index < cnt; index++)
- {
- sockets[index] = RT_NULL;
- }
- st->sockets = sockets;
- st->max_socket = cnt;
- }
- /* allocate 'struct sal_socket' */
- if (idx < (int) st->max_socket && st->sockets[idx] == RT_NULL)
- {
- st->sockets[idx] = rt_calloc(1, sizeof(struct sal_socket));
- if (st->sockets[idx] == RT_NULL)
- {
- idx = st->max_socket;
- }
- }
- __result:
- return idx;
- }
- static void socket_free(struct sal_socket_table *st, int idx)
- {
- struct sal_socket *sock;
- sock = st->sockets[idx];
- st->sockets[idx] = RT_NULL;
- rt_free(sock);
- }
- static int socket_new(void)
- {
- struct sal_socket *sock;
- struct sal_socket_table *st = &socket_table;
- int idx;
- sal_lock();
- /* find an empty sal socket entry */
- idx = socket_alloc(st, 0);
- /* can't find an empty sal socket entry */
- if (idx == (int) st->max_socket)
- {
- idx = -(1 + SAL_SOCKET_OFFSET);
- goto __result;
- }
- sock = st->sockets[idx];
- sock->socket = idx + SAL_SOCKET_OFFSET;
- sock->magic = SAL_SOCKET_MAGIC;
- sock->netdev = RT_NULL;
- sock->user_data = RT_NULL;
- #ifdef SAL_USING_TLS
- sock->user_data_tls = RT_NULL;
- #endif
- __result:
- sal_unlock();
- return idx + SAL_SOCKET_OFFSET;
- }
- static void socket_delete(int socket)
- {
- struct sal_socket *sock;
- struct sal_socket_table *st = &socket_table;
- int idx;
- idx = socket - SAL_SOCKET_OFFSET;
- if (idx < 0 || idx >= (int) st->max_socket)
- {
- return;
- }
- sal_lock();
- sock = sal_get_socket(socket);
- RT_ASSERT(sock != RT_NULL);
- sock->magic = 0;
- sock->netdev = RT_NULL;
- socket_free(st, idx);
- sal_unlock();
- }
- int sal_accept(int socket, struct sockaddr *addr, socklen_t *addrlen)
- {
- int new_socket;
- struct sal_socket *sock;
- struct sal_proto_family *pf;
- /* get the socket object by socket descriptor */
- SAL_SOCKET_OBJ_GET(sock, socket);
- /* check the network interface socket operations */
- SAL_NETDEV_SOCKETOPS_VALID(sock->netdev, pf, accept);
- new_socket = pf->skt_ops->accept((int) sock->user_data, addr, addrlen);
- if (new_socket != -1)
- {
- int retval;
- int new_sal_socket;
- struct sal_socket *new_sock;
- /* allocate a new socket structure and registered socket options */
- new_sal_socket = socket_new();
- new_sock = sal_get_socket(new_sal_socket);
- if (new_sock == RT_NULL)
- {
- pf->skt_ops->closesocket(new_socket);
- return -1;
- }
- retval = socket_init(sock->domain, sock->type, sock->protocol, &new_sock);
- if (retval < 0)
- {
- pf->skt_ops->closesocket(new_socket);
- rt_memset(new_sock, 0x00, sizeof(struct sal_socket));
- /* socket init failed, delete socket */
- socket_delete(new_sal_socket);
- LOG_E("New socket registered failed, return error %d.", retval);
- return -1;
- }
- /* socket structure user_data used to store the acquired new socket */
- new_sock->user_data = (void *) new_socket;
- return new_sal_socket;
- }
- return -1;
- }
- static void sal_sockaddr_to_ipaddr(const struct sockaddr *name, ip_addr_t *local_ipaddr)
- {
- const struct sockaddr_in *svr_addr = (const struct sockaddr_in *) name;
- #if NETDEV_IPV4 && NETDEV_IPV6
- local_ipaddr->u_addr.ip4.addr = svr_addr->sin_addr.s_addr;
- local_ipaddr->type = IPADDR_TYPE_V4;
- #elif NETDEV_IPV4
- local_ipaddr->addr = svr_addr->sin_addr.s_addr;
- #elif NETDEV_IPV6
- #error "not only support IPV6"
- #endif /* NETDEV_IPV4 && NETDEV_IPV6*/
- }
- int sal_bind(int socket, const struct sockaddr *name, socklen_t namelen)
- {
- struct sal_socket *sock;
- struct sal_proto_family *pf;
- ip_addr_t input_ipaddr;
- RT_ASSERT(name);
- /* get the socket object by socket descriptor */
- SAL_SOCKET_OBJ_GET(sock, socket);
- /* bind network interface by ip address */
- sal_sockaddr_to_ipaddr(name, &input_ipaddr);
- /* check input ipaddr is default netdev ipaddr */
- if (!ip_addr_isany_val(input_ipaddr))
- {
- struct sal_proto_family *input_pf = RT_NULL, *local_pf = RT_NULL;
- struct netdev *new_netdev = RT_NULL;
- new_netdev = netdev_get_by_ipaddr(&input_ipaddr);
- if (new_netdev == RT_NULL)
- {
- return -1;
- }
- /* get input and local ip address proto_family */
- SAL_NETDEV_SOCKETOPS_VALID(sock->netdev, local_pf, bind);
- SAL_NETDEV_SOCKETOPS_VALID(new_netdev, input_pf, bind);
- /* check the network interface protocol family type */
- if (input_pf->family != local_pf->family)
- {
- int new_socket = -1;
- /* protocol family is different, close old socket and create new socket by input ip address */
- local_pf->skt_ops->closesocket(socket);
- new_socket = input_pf->skt_ops->socket(input_pf->family, sock->type, sock->protocol);
- if (new_socket < 0)
- {
- return -1;
- }
- sock->netdev = new_netdev;
- sock->user_data = (void *) new_socket;
- }
- }
- /* check and get protocol families by the network interface device */
- SAL_NETDEV_SOCKETOPS_VALID(sock->netdev, pf, bind);
- return pf->skt_ops->bind((int) sock->user_data, name, namelen);
- }
- int sal_shutdown(int socket, int how)
- {
- struct sal_socket *sock;
- struct sal_proto_family *pf;
- int error = 0;
- /* get the socket object by socket descriptor */
- SAL_SOCKET_OBJ_GET(sock, socket);
- /* shutdown operation not nead to check network interface status */
- /* check the network interface socket opreation */
- SAL_NETDEV_SOCKETOPS_VALID(sock->netdev, pf, shutdown);
- if (pf->skt_ops->shutdown((int) sock->user_data, how) == 0)
- {
- #ifdef SAL_USING_TLS
- if (SAL_SOCKOPS_PROTO_TLS_VALID(sock, closesocket))
- {
- if (proto_tls->ops->closesocket(sock->user_data_tls) < 0)
- {
- return -1;
- }
- }
- #endif
- error = 0;
- }
- else
- {
- error = -1;
- }
- return error;
- }
- int sal_getpeername(int socket, struct sockaddr *name, socklen_t *namelen)
- {
- struct sal_socket *sock;
- struct sal_proto_family *pf;
- /* get the socket object by socket descriptor */
- SAL_SOCKET_OBJ_GET(sock, socket);
- /* check the network interface socket opreation */
- SAL_NETDEV_SOCKETOPS_VALID(sock->netdev, pf, getpeername);
- return pf->skt_ops->getpeername((int) sock->user_data, name, namelen);
- }
- int sal_getsockname(int socket, struct sockaddr *name, socklen_t *namelen)
- {
- struct sal_socket *sock;
- struct sal_proto_family *pf;
- /* get socket object by socket descriptor */
- SAL_SOCKET_OBJ_GET(sock, socket);
- /* check the network interface socket opreation */
- SAL_NETDEV_SOCKETOPS_VALID(sock->netdev, pf, getsockname);
- return pf->skt_ops->getsockname((int) sock->user_data, name, namelen);
- }
- int sal_getsockopt(int socket, int level, int optname, void *optval, socklen_t *optlen)
- {
- struct sal_socket *sock;
- struct sal_proto_family *pf;
- /* get the socket object by socket descriptor */
- SAL_SOCKET_OBJ_GET(sock, socket);
- /* check the network interface socket opreation */
- SAL_NETDEV_SOCKETOPS_VALID(sock->netdev, pf, getsockopt);
- return pf->skt_ops->getsockopt((int) sock->user_data, level, optname, optval, optlen);
- }
- int sal_setsockopt(int socket, int level, int optname, const void *optval, socklen_t optlen)
- {
- struct sal_socket *sock;
- struct sal_proto_family *pf;
- /* get the socket object by socket descriptor */
- SAL_SOCKET_OBJ_GET(sock, socket);
- /* check the network interface socket opreation */
- SAL_NETDEV_SOCKETOPS_VALID(sock->netdev, pf, setsockopt);
- #ifdef SAL_USING_TLS
- if (level == SOL_TLS)
- {
- switch (optname)
- {
- case TLS_CRET_LIST:
- SAL_SOCKOPT_PROTO_TLS_EXEC(sock, set_cret_list, optval, optlen);
- break;
- case TLS_CIPHERSUITE_LIST:
- SAL_SOCKOPT_PROTO_TLS_EXEC(sock, set_ciphersurite, optval, optlen);
- break;
- case TLS_PEER_VERIFY:
- SAL_SOCKOPT_PROTO_TLS_EXEC(sock, set_peer_verify, optval, optlen);
- break;
- case TLS_DTLS_ROLE:
- SAL_SOCKOPT_PROTO_TLS_EXEC(sock, set_dtls_role, optval, optlen);
- break;
- default:
- return -1;
- }
- return 0;
- }
- else
- {
- return pf->skt_ops->setsockopt((int) sock->user_data, level, optname, optval, optlen);
- }
- #else
- return pf->skt_ops->setsockopt((int) sock->user_data, level, optname, optval, optlen);
- #endif /* SAL_USING_TLS */
- }
- int sal_connect(int socket, const struct sockaddr *name, socklen_t namelen)
- {
- struct sal_socket *sock;
- struct sal_proto_family *pf;
- int ret;
- /* get the socket object by socket descriptor */
- SAL_SOCKET_OBJ_GET(sock, socket);
- /* check the network interface is up status */
- SAL_NETDEV_IS_UP(sock->netdev);
- /* check the network interface socket opreation */
- SAL_NETDEV_SOCKETOPS_VALID(sock->netdev, pf, connect);
- ret = pf->skt_ops->connect((int) sock->user_data, name, namelen);
- #ifdef SAL_USING_TLS
- if (ret >= 0 && SAL_SOCKOPS_PROTO_TLS_VALID(sock, connect))
- {
- if (proto_tls->ops->connect(sock->user_data_tls) < 0)
- {
- return -1;
- }
- return ret;
- }
- #endif
- return ret;
- }
- int sal_listen(int socket, int backlog)
- {
- struct sal_socket *sock;
- struct sal_proto_family *pf;
- /* get the socket object by socket descriptor */
- SAL_SOCKET_OBJ_GET(sock, socket);
- /* check the network interface socket opreation */
- SAL_NETDEV_SOCKETOPS_VALID(sock->netdev, pf, listen);
- return pf->skt_ops->listen((int) sock->user_data, backlog);
- }
- int sal_recvfrom(int socket, void *mem, size_t len, int flags,
- struct sockaddr *from, socklen_t *fromlen)
- {
- struct sal_socket *sock;
- struct sal_proto_family *pf;
- /* get the socket object by socket descriptor */
- SAL_SOCKET_OBJ_GET(sock, socket);
- /* check the network interface is up status */
- SAL_NETDEV_IS_UP(sock->netdev);
- /* check the network interface socket opreation */
- SAL_NETDEV_SOCKETOPS_VALID(sock->netdev, pf, recvfrom);
- #ifdef SAL_USING_TLS
- if (SAL_SOCKOPS_PROTO_TLS_VALID(sock, recv))
- {
- int ret;
- if ((ret = proto_tls->ops->recv(sock->user_data_tls, mem, len)) < 0)
- {
- return -1;
- }
- return ret;
- }
- else
- {
- return pf->skt_ops->recvfrom((int) sock->user_data, mem, len, flags, from, fromlen);
- }
- #else
- return pf->skt_ops->recvfrom((int) sock->user_data, mem, len, flags, from, fromlen);
- #endif
- }
- int sal_sendto(int socket, const void *dataptr, size_t size, int flags,
- const struct sockaddr *to, socklen_t tolen)
- {
- struct sal_socket *sock;
- struct sal_proto_family *pf;
- /* get the socket object by socket descriptor */
- SAL_SOCKET_OBJ_GET(sock, socket);
- /* check the network interface is up status */
- SAL_NETDEV_IS_UP(sock->netdev);
- /* check the network interface socket opreation */
- SAL_NETDEV_SOCKETOPS_VALID(sock->netdev, pf, sendto);
- #ifdef SAL_USING_TLS
- if (SAL_SOCKOPS_PROTO_TLS_VALID(sock, send))
- {
- int ret;
- if ((ret = proto_tls->ops->send(sock->user_data_tls, dataptr, size)) < 0)
- {
- return -1;
- }
- return ret;
- }
- else
- {
- return pf->skt_ops->sendto((int) sock->user_data, dataptr, size, flags, to, tolen);
- }
- #else
- return pf->skt_ops->sendto((int) sock->user_data, dataptr, size, flags, to, tolen);
- #endif
- }
- int sal_socket(int domain, int type, int protocol)
- {
- int retval;
- int socket, proto_socket;
- struct sal_socket *sock;
- struct sal_proto_family *pf;
- /* allocate a new socket and registered socket options */
- socket = socket_new();
- if (socket < 0)
- {
- return -1;
- }
- /* get sal socket object by socket descriptor */
- sock = sal_get_socket(socket);
- if (sock == RT_NULL)
- {
- return -1;
- }
- /* Initialize sal socket object */
- retval = socket_init(domain, type, protocol, &sock);
- if (retval < 0)
- {
- LOG_E("SAL socket protocol family input failed, return error %d.", retval);
- socket_delete(socket);
- return -1;
- }
- /* valid the network interface socket opreation */
- SAL_NETDEV_SOCKETOPS_VALID(sock->netdev, pf, socket);
- proto_socket = pf->skt_ops->socket(domain, type, protocol);
- if (proto_socket >= 0)
- {
- #ifdef SAL_USING_TLS
- if (SAL_SOCKOPS_PROTO_TLS_VALID(sock, socket))
- {
- sock->user_data_tls = proto_tls->ops->socket(socket);
- if (sock->user_data_tls == RT_NULL)
- {
- socket_delete(socket);
- return -1;
- }
- }
- #endif
- sock->user_data = (void *) proto_socket;
- return sock->socket;
- }
- return -1;
- }
- int sal_closesocket(int socket)
- {
- struct sal_socket *sock;
- struct sal_proto_family *pf;
- int error = 0;
- /* get the socket object by socket descriptor */
- SAL_SOCKET_OBJ_GET(sock, socket);
- /* clsoesocket operation not nead to vaild network interface status */
- /* valid the network interface socket opreation */
- SAL_NETDEV_SOCKETOPS_VALID(sock->netdev, pf, socket);
- if (pf->skt_ops->closesocket((int) sock->user_data) == 0)
- {
- #ifdef SAL_USING_TLS
- if (SAL_SOCKOPS_PROTO_TLS_VALID(sock, closesocket))
- {
- if (proto_tls->ops->closesocket(sock->user_data_tls) < 0)
- {
- return -1;
- }
- }
- #endif
- error = 0;
- }
- else
- {
- error = -1;
- }
- /* delete socket */
- socket_delete(socket);
- return error;
- }
- int sal_ioctlsocket(int socket, long cmd, void *arg)
- {
- struct sal_socket *sock;
- struct sal_proto_family *pf;
- /* get the socket object by socket descriptor */
- SAL_SOCKET_OBJ_GET(sock, socket);
- /* check the network interface socket opreation */
- SAL_NETDEV_SOCKETOPS_VALID(sock->netdev, pf, ioctlsocket);
- return pf->skt_ops->ioctlsocket((int) sock->user_data, cmd, arg);
- }
- #ifdef SAL_USING_POSIX
- int sal_poll(struct dfs_fd *file, struct rt_pollreq *req)
- {
- struct sal_socket *sock;
- struct sal_proto_family *pf;
- int socket = (int) file->data;
- /* get the socket object by socket descriptor */
- SAL_SOCKET_OBJ_GET(sock, socket);
- /* check the network interface is up status */
- SAL_NETDEV_IS_UP(sock->netdev);
- /* check the network interface socket opreation */
- SAL_NETDEV_SOCKETOPS_VALID(sock->netdev, pf, poll);
- return pf->skt_ops->poll(file, req);
- }
- #endif
- struct hostent *sal_gethostbyname(const char *name)
- {
- struct netdev *netdev = netdev_default;
- struct sal_proto_family *pf;
- if (SAL_NETDEV_NETDBOPS_VALID(netdev, pf, gethostbyname))
- {
- return pf->netdb_ops->gethostbyname(name);
- }
- else
- {
- /* get the first network interface device with up status */
- netdev = netdev_get_first_by_flags(NETDEV_FLAG_UP);
- if (SAL_NETDEV_NETDBOPS_VALID(netdev, pf, gethostbyname))
- {
- return pf->netdb_ops->gethostbyname(name);
- }
- }
- return RT_NULL;
- }
- int sal_gethostbyname_r(const char *name, struct hostent *ret, char *buf,
- size_t buflen, struct hostent **result, int *h_errnop)
- {
- struct netdev *netdev = netdev_default;
- struct sal_proto_family *pf;
- if (SAL_NETDEV_NETDBOPS_VALID(netdev, pf, gethostbyname_r))
- {
- return pf->netdb_ops->gethostbyname_r(name, ret, buf, buflen, result, h_errnop);
- }
- else
- {
- /* get the first network interface device with up status */
- netdev = netdev_get_first_by_flags(NETDEV_FLAG_UP);
- if (SAL_NETDEV_NETDBOPS_VALID(netdev, pf, gethostbyname_r))
- {
- return pf->netdb_ops->gethostbyname_r(name, ret, buf, buflen, result, h_errnop);
- }
- }
- return -1;
- }
- int sal_getaddrinfo(const char *nodename,
- const char *servname,
- const struct addrinfo *hints,
- struct addrinfo **res)
- {
- struct netdev *netdev = netdev_default;
- struct sal_proto_family *pf;
- if (SAL_NETDEV_NETDBOPS_VALID(netdev, pf, getaddrinfo))
- {
- return pf->netdb_ops->getaddrinfo(nodename, servname, hints, res);
- }
- else
- {
- /* get the first network interface device with up status */
- netdev = netdev_get_first_by_flags(NETDEV_FLAG_UP);
- if (SAL_NETDEV_NETDBOPS_VALID(netdev, pf, getaddrinfo))
- {
- return pf->netdb_ops->getaddrinfo(nodename, servname, hints, res);
- }
- }
- return -1;
- }
- void sal_freeaddrinfo(struct addrinfo *ai)
- {
- struct netdev *netdev = netdev_default;
- struct sal_proto_family *pf;
- if (SAL_NETDEV_NETDBOPS_VALID(netdev, pf, freeaddrinfo))
- {
- pf->netdb_ops->freeaddrinfo(ai);
- }
- else
- {
- /* get the first network interface device with up status */
- netdev = netdev_get_first_by_flags(NETDEV_FLAG_UP);
- if (SAL_NETDEV_NETDBOPS_VALID(netdev, pf, freeaddrinfo))
- {
- pf->netdb_ops->freeaddrinfo(ai);
- }
- }
- }
|