1*10465441SEvalZero /*
2*10465441SEvalZero * Copyright (c) 2006-2018, RT-Thread Development Team
3*10465441SEvalZero *
4*10465441SEvalZero * SPDX-License-Identifier: Apache-2.0
5*10465441SEvalZero *
6*10465441SEvalZero * Change Logs:
7*10465441SEvalZero * Date Author Notes
8*10465441SEvalZero * 2018-06-06 ChenYong First version
9*10465441SEvalZero */
10*10465441SEvalZero
11*10465441SEvalZero #include <rtthread.h>
12*10465441SEvalZero
13*10465441SEvalZero #include <netdb.h>
14*10465441SEvalZero #include <sal.h>
15*10465441SEvalZero
16*10465441SEvalZero #include <at_socket.h>
17*10465441SEvalZero #include <af_inet.h>
18*10465441SEvalZero
19*10465441SEvalZero #ifdef SAL_USING_POSIX
20*10465441SEvalZero #include <dfs_poll.h>
21*10465441SEvalZero #endif
22*10465441SEvalZero
23*10465441SEvalZero #ifdef SAL_USING_AT
24*10465441SEvalZero
25*10465441SEvalZero #ifdef SAL_USING_POSIX
at_poll(struct dfs_fd * file,struct rt_pollreq * req)26*10465441SEvalZero static int at_poll(struct dfs_fd *file, struct rt_pollreq *req)
27*10465441SEvalZero {
28*10465441SEvalZero int mask = 0;
29*10465441SEvalZero struct at_socket *sock;
30*10465441SEvalZero struct sal_socket *sal_sock;
31*10465441SEvalZero
32*10465441SEvalZero sal_sock = sal_get_socket((int) file->data);
33*10465441SEvalZero if(!sal_sock)
34*10465441SEvalZero {
35*10465441SEvalZero return -1;
36*10465441SEvalZero }
37*10465441SEvalZero
38*10465441SEvalZero sock = at_get_socket((int)sal_sock->user_data);
39*10465441SEvalZero if (sock != NULL)
40*10465441SEvalZero {
41*10465441SEvalZero rt_base_t level;
42*10465441SEvalZero
43*10465441SEvalZero rt_poll_add(&sock->wait_head, req);
44*10465441SEvalZero
45*10465441SEvalZero level = rt_hw_interrupt_disable();
46*10465441SEvalZero if (sock->rcvevent)
47*10465441SEvalZero {
48*10465441SEvalZero mask |= POLLIN;
49*10465441SEvalZero }
50*10465441SEvalZero if (sock->sendevent)
51*10465441SEvalZero {
52*10465441SEvalZero mask |= POLLOUT;
53*10465441SEvalZero }
54*10465441SEvalZero if (sock->errevent)
55*10465441SEvalZero {
56*10465441SEvalZero mask |= POLLERR;
57*10465441SEvalZero }
58*10465441SEvalZero rt_hw_interrupt_enable(level);
59*10465441SEvalZero }
60*10465441SEvalZero
61*10465441SEvalZero return mask;
62*10465441SEvalZero }
63*10465441SEvalZero #endif
64*10465441SEvalZero
65*10465441SEvalZero static const struct sal_socket_ops at_socket_ops =
66*10465441SEvalZero {
67*10465441SEvalZero at_socket,
68*10465441SEvalZero at_closesocket,
69*10465441SEvalZero at_bind,
70*10465441SEvalZero NULL,
71*10465441SEvalZero at_connect,
72*10465441SEvalZero NULL,
73*10465441SEvalZero at_sendto,
74*10465441SEvalZero at_recvfrom,
75*10465441SEvalZero at_getsockopt,
76*10465441SEvalZero at_setsockopt,
77*10465441SEvalZero at_shutdown,
78*10465441SEvalZero NULL,
79*10465441SEvalZero NULL,
80*10465441SEvalZero NULL,
81*10465441SEvalZero
82*10465441SEvalZero #ifdef SAL_USING_POSIX
83*10465441SEvalZero at_poll,
84*10465441SEvalZero #endif /* SAL_USING_POSIX */
85*10465441SEvalZero };
86*10465441SEvalZero
at_create(struct sal_socket * socket,int type,int protocol)87*10465441SEvalZero static int at_create(struct sal_socket *socket, int type, int protocol)
88*10465441SEvalZero {
89*10465441SEvalZero RT_ASSERT(socket);
90*10465441SEvalZero
91*10465441SEvalZero //TODO Check type & protocol
92*10465441SEvalZero
93*10465441SEvalZero socket->ops = &at_socket_ops;
94*10465441SEvalZero
95*10465441SEvalZero return 0;
96*10465441SEvalZero }
97*10465441SEvalZero
98*10465441SEvalZero static struct sal_proto_ops at_proto_ops =
99*10465441SEvalZero {
100*10465441SEvalZero at_gethostbyname,
101*10465441SEvalZero NULL,
102*10465441SEvalZero at_getaddrinfo,
103*10465441SEvalZero at_freeaddrinfo,
104*10465441SEvalZero };
105*10465441SEvalZero
106*10465441SEvalZero static const struct sal_proto_family at_inet_family =
107*10465441SEvalZero {
108*10465441SEvalZero AF_AT,
109*10465441SEvalZero AF_INET,
110*10465441SEvalZero at_create,
111*10465441SEvalZero &at_proto_ops,
112*10465441SEvalZero };
113*10465441SEvalZero
at_inet_init(void)114*10465441SEvalZero int at_inet_init(void)
115*10465441SEvalZero {
116*10465441SEvalZero sal_proto_family_register(&at_inet_family);
117*10465441SEvalZero
118*10465441SEvalZero return 0;
119*10465441SEvalZero }
120*10465441SEvalZero INIT_COMPONENT_EXPORT(at_inet_init);
121*10465441SEvalZero
122*10465441SEvalZero #endif /* SAL_USING_AT */
123