Lines Matching +full:socket +full:- +full:based
1 // SPDX-License-Identifier: GPL-2.0
3 * Copyright (c) 2015-2018 National Instruments
4 * Copyright (c) 2015-2018 Joe Hershberger <joe.hershberger@ni.com>
7 #include <asm/eth-raw-os.h>
20 #include <sys/socket.h>
41 int fd = socket(AF_INET, SOCK_DGRAM, 0); in sandbox_eth_raw_os_is_local()
46 return -errno; in sandbox_eth_raw_os_is_local()
51 ret = -errno; in sandbox_eth_raw_os_is_local()
62 if (!if_indextoname(priv->host_ifindex, priv->host_ifname)) in sandbox_eth_raw_os_idx_to_name()
63 return -errno; in sandbox_eth_raw_os_idx_to_name()
76 priv->local_bind_sd = -1; in _raw_packet_start()
77 priv->device = os_malloc(sizeof(struct sockaddr_ll)); in _raw_packet_start()
78 if (priv->device == NULL) in _raw_packet_start()
79 return -ENOMEM; in _raw_packet_start()
80 device = priv->device; in _raw_packet_start()
82 device->sll_ifindex = if_nametoindex(priv->host_ifname); in _raw_packet_start()
83 priv->host_ifindex = device->sll_ifindex; in _raw_packet_start()
84 device->sll_family = AF_PACKET; in _raw_packet_start()
85 memcpy(device->sll_addr, ethmac, 6); in _raw_packet_start()
86 device->sll_halen = htons(6); in _raw_packet_start()
88 /* Open socket */ in _raw_packet_start()
89 priv->sd = socket(PF_PACKET, SOCK_RAW, htons(ETH_P_ALL)); in _raw_packet_start()
90 if (priv->sd < 0) { in _raw_packet_start()
91 printf("Failed to open socket: %d %s\n", errno, in _raw_packet_start()
93 return -errno; in _raw_packet_start()
96 ret = setsockopt(priv->sd, SOL_SOCKET, SO_BINDTODEVICE, in _raw_packet_start()
97 priv->host_ifname, strlen(priv->host_ifname) + 1); in _raw_packet_start()
99 printf("Failed to bind to '%s': %d %s\n", priv->host_ifname, in _raw_packet_start()
101 return -errno; in _raw_packet_start()
104 /* Make the socket non-blocking */ in _raw_packet_start()
105 flags = fcntl(priv->sd, F_GETFL, 0); in _raw_packet_start()
106 fcntl(priv->sd, F_SETFL, flags | O_NONBLOCK); in _raw_packet_start()
109 mr.mr_ifindex = device->sll_ifindex; in _raw_packet_start()
111 ret = setsockopt(priv->sd, SOL_PACKET, PACKET_ADD_MEMBERSHIP, in _raw_packet_start()
119 if (strlen(priv->host_ifname) >= IFNAMSIZ) { in _raw_packet_start()
121 priv->host_ifname); in _raw_packet_start()
122 return -EINVAL; in _raw_packet_start()
124 strncpy(ifr.ifr_name, priv->host_ifname, IFNAMSIZ); in _raw_packet_start()
125 if (ioctl(priv->sd, SIOCGIFFLAGS, &ifr) < 0) { in _raw_packet_start()
128 return -errno; in _raw_packet_start()
131 if (ioctl(priv->sd, SIOCSIFFLAGS, &ifr) < 0) { in _raw_packet_start()
134 return -errno; in _raw_packet_start()
148 priv->local_bind_sd = -1; in _local_inet_start()
149 priv->local_bind_udp_port = 0; in _local_inet_start()
150 priv->device = os_malloc(sizeof(struct sockaddr_in)); in _local_inet_start()
151 if (priv->device == NULL) in _local_inet_start()
152 return -ENOMEM; in _local_inet_start()
153 device = priv->device; in _local_inet_start()
155 device->sin_family = AF_INET; in _local_inet_start()
156 device->sin_addr.s_addr = htonl(INADDR_LOOPBACK); in _local_inet_start()
159 * Open socket in _local_inet_start()
164 priv->sd = socket(AF_INET, SOCK_RAW, IPPROTO_UDP); in _local_inet_start()
165 if (priv->sd < 0) { in _local_inet_start()
166 printf("Failed to open socket: %d %s\n", errno, in _local_inet_start()
168 return -errno; in _local_inet_start()
171 /* Make the socket non-blocking */ in _local_inet_start()
172 flags = fcntl(priv->sd, F_GETFL, 0); in _local_inet_start()
173 fcntl(priv->sd, F_SETFL, flags | O_NONBLOCK); in _local_inet_start()
176 ret = setsockopt(priv->sd, IPPROTO_IP, IP_HDRINCL, &one, in _local_inet_start()
181 return -errno; in _local_inet_start()
189 if (priv->local) in sandbox_eth_raw_os_start()
201 if (priv->sd < 0 || !priv->device) in sandbox_eth_raw_os_send()
202 return -EINVAL; in sandbox_eth_raw_os_send()
207 * in play responding to incoming traffic based on open "ports". Since in sandbox_eth_raw_os_send()
211 * packet as formulated by the u-boot network stack to determine the in sandbox_eth_raw_os_send()
213 * opens a typical UDP socket on that port, thus preventing the network in sandbox_eth_raw_os_send()
215 * bound socket. in sandbox_eth_raw_os_send()
217 if (priv->local && (priv->local_bind_sd == -1 || in sandbox_eth_raw_os_send()
218 priv->local_bind_udp_port != udph->source)) { in sandbox_eth_raw_os_send()
222 if (priv->local_bind_sd != -1) in sandbox_eth_raw_os_send()
223 close(priv->local_bind_sd); in sandbox_eth_raw_os_send()
225 /* A normal UDP socket is required to bind */ in sandbox_eth_raw_os_send()
226 priv->local_bind_sd = socket(AF_INET, SOCK_DGRAM, 0); in sandbox_eth_raw_os_send()
227 if (priv->local_bind_sd < 0) { in sandbox_eth_raw_os_send()
230 return -errno; in sandbox_eth_raw_os_send()
232 priv->local_bind_udp_port = udph->source; in sandbox_eth_raw_os_send()
240 addr.sin_port = udph->source; in sandbox_eth_raw_os_send()
241 addr.sin_addr.s_addr = iph->saddr; in sandbox_eth_raw_os_send()
242 retval = bind(priv->local_bind_sd, (struct sockaddr *)&addr, in sandbox_eth_raw_os_send()
249 retval = sendto(priv->sd, packet, length, 0, in sandbox_eth_raw_os_send()
250 (struct sockaddr *)priv->device, in sandbox_eth_raw_os_send()
255 return -errno; in sandbox_eth_raw_os_send()
266 if (priv->sd < 0 || !priv->device) in sandbox_eth_raw_os_recv()
267 return -EINVAL; in sandbox_eth_raw_os_recv()
269 retval = recvfrom(priv->sd, packet, 1536, 0, in sandbox_eth_raw_os_recv()
270 (struct sockaddr *)priv->device, in sandbox_eth_raw_os_recv()
277 /* The socket is non-blocking, so expect EAGAIN when there is no data */ in sandbox_eth_raw_os_recv()
280 return -errno; in sandbox_eth_raw_os_recv()
285 os_free(priv->device); in sandbox_eth_raw_os_stop()
286 priv->device = NULL; in sandbox_eth_raw_os_stop()
287 close(priv->sd); in sandbox_eth_raw_os_stop()
288 priv->sd = -1; in sandbox_eth_raw_os_stop()
289 if (priv->local) { in sandbox_eth_raw_os_stop()
290 if (priv->local_bind_sd != -1) in sandbox_eth_raw_os_stop()
291 close(priv->local_bind_sd); in sandbox_eth_raw_os_stop()
292 priv->local_bind_sd = -1; in sandbox_eth_raw_os_stop()
293 priv->local_bind_udp_port = 0; in sandbox_eth_raw_os_stop()