1/*
2 * Wired Ethernet driver interface
3 * Copyright (c) 2005-2009, Jouni Malinen <j@w1.fi>
4 * Copyright (c) 2004, Gunter Burchardt <tira@isx.de>
5 *
6 * This software may be distributed under the terms of the BSD license.
7 * See README for more details.
8 */
9
10#include "includes.h"
11
12#include "common.h"
13#include "eloop.h"
14#include "driver.h"
15#include "driver_wired_common.h"
16
17#include <sys/ioctl.h>
18#undef IFNAMSIZ
19#include <net/if.h>
20#ifdef __linux__
21#include <netpacket/packet.h>
22#include <net/if_arp.h>
23#endif /* __linux__ */
24#if defined(__FreeBSD__) || defined(__DragonFly__) || defined(__FreeBSD_kernel__)
25#include <net/if_dl.h>
26#include <net/if_media.h>
27#endif /* defined(__FreeBSD__) || defined(__DragonFly__) || defined(__FreeBSD_kernel__) */
28#ifdef __sun__
29#include <sys/sockio.h>
30#endif /* __sun__ */
31
32#ifdef _MSC_VER
33#pragma pack(push, 1)
34#endif /* _MSC_VER */
35
36struct ieee8023_hdr {
37	u8 dest[6];
38	u8 src[6];
39	u16 ethertype;
40} STRUCT_PACKED;
41
42#ifdef _MSC_VER
43#pragma pack(pop)
44#endif /* _MSC_VER */
45
46
47struct wpa_driver_wired_data {
48	struct driver_wired_common_data common;
49
50	int dhcp_sock; /* socket for dhcp packets */
51	int use_pae_group_addr;
52};
53
54
55/* TODO: detecting new devices should eventually be changed from using DHCP
56 * snooping to trigger on any packet from a new layer 2 MAC address, e.g.,
57 * based on ebtables, etc. */
58
59struct dhcp_message {
60	u_int8_t op;
61	u_int8_t htype;
62	u_int8_t hlen;
63	u_int8_t hops;
64	u_int32_t xid;
65	u_int16_t secs;
66	u_int16_t flags;
67	u_int32_t ciaddr;
68	u_int32_t yiaddr;
69	u_int32_t siaddr;
70	u_int32_t giaddr;
71	u_int8_t chaddr[16];
72	u_int8_t sname[64];
73	u_int8_t file[128];
74	u_int32_t cookie;
75	u_int8_t options[308]; /* 312 - cookie */
76};
77
78
79#ifdef __linux__
80static void handle_data(void *ctx, unsigned char *buf, size_t len)
81{
82#ifdef HOSTAPD
83	struct ieee8023_hdr *hdr;
84	u8 *pos, *sa;
85	size_t left;
86	union wpa_event_data event;
87
88	/* must contain at least ieee8023_hdr 6 byte source, 6 byte dest,
89	 * 2 byte ethertype */
90	if (len < 14) {
91		wpa_printf(MSG_MSGDUMP, "handle_data: too short (%lu)",
92			   (unsigned long) len);
93		return;
94	}
95
96	hdr = (struct ieee8023_hdr *) buf;
97
98	switch (ntohs(hdr->ethertype)) {
99	case ETH_P_PAE:
100		wpa_printf(MSG_MSGDUMP, "Received EAPOL packet");
101		sa = hdr->src;
102		os_memset(&event, 0, sizeof(event));
103		event.new_sta.addr = sa;
104		wpa_supplicant_event(ctx, EVENT_NEW_STA, &event);
105
106		pos = (u8 *) (hdr + 1);
107		left = len - sizeof(*hdr);
108		drv_event_eapol_rx(ctx, sa, pos, left);
109		break;
110
111	default:
112		wpa_printf(MSG_DEBUG, "Unknown ethertype 0x%04x in data frame",
113			   ntohs(hdr->ethertype));
114		break;
115	}
116#endif /* HOSTAPD */
117}
118
119
120static void handle_read(int sock, void *eloop_ctx, void *sock_ctx)
121{
122	int len;
123	unsigned char buf[3000];
124
125	len = recv(sock, buf, sizeof(buf), 0);
126	if (len < 0) {
127		wpa_printf(MSG_ERROR, "recv: %s", strerror(errno));
128		return;
129	}
130
131	handle_data(eloop_ctx, buf, len);
132}
133
134
135static void handle_dhcp(int sock, void *eloop_ctx, void *sock_ctx)
136{
137	int len;
138	unsigned char buf[3000];
139	struct dhcp_message *msg;
140	u8 *mac_address;
141	union wpa_event_data event;
142
143	len = recv(sock, buf, sizeof(buf), 0);
144	if (len < 0) {
145		wpa_printf(MSG_ERROR, "recv: %s", strerror(errno));
146		return;
147	}
148
149	/* must contain at least dhcp_message->chaddr */
150	if (len < 44) {
151		wpa_printf(MSG_MSGDUMP, "handle_dhcp: too short (%d)", len);
152		return;
153	}
154
155	msg = (struct dhcp_message *) buf;
156	mac_address = (u8 *) &(msg->chaddr);
157
158	wpa_printf(MSG_MSGDUMP, "Got DHCP broadcast packet from " MACSTR,
159		   MAC2STR(mac_address));
160
161	os_memset(&event, 0, sizeof(event));
162	event.new_sta.addr = mac_address;
163	wpa_supplicant_event(eloop_ctx, EVENT_NEW_STA, &event);
164}
165#endif /* __linux__ */
166
167
168static int wired_init_sockets(struct wpa_driver_wired_data *drv, u8 *own_addr)
169{
170#ifdef __linux__
171	struct ifreq ifr;
172	struct sockaddr_ll addr;
173	struct sockaddr_in addr2;
174	int n = 1;
175
176	drv->common.sock = socket(PF_PACKET, SOCK_RAW, htons(ETH_P_PAE));
177	if (drv->common.sock < 0) {
178		wpa_printf(MSG_ERROR, "socket[PF_PACKET,SOCK_RAW]: %s",
179			   strerror(errno));
180		return -1;
181	}
182
183	if (eloop_register_read_sock(drv->common.sock, handle_read,
184				     drv->common.ctx, NULL)) {
185		wpa_printf(MSG_INFO, "Could not register read socket");
186		return -1;
187	}
188
189	os_memset(&ifr, 0, sizeof(ifr));
190	os_strlcpy(ifr.ifr_name, drv->common.ifname, sizeof(ifr.ifr_name));
191	if (ioctl(drv->common.sock, SIOCGIFINDEX, &ifr) != 0) {
192		wpa_printf(MSG_ERROR, "ioctl(SIOCGIFINDEX): %s",
193			   strerror(errno));
194		return -1;
195	}
196
197	os_memset(&addr, 0, sizeof(addr));
198	addr.sll_family = AF_PACKET;
199	addr.sll_ifindex = ifr.ifr_ifindex;
200	wpa_printf(MSG_DEBUG, "Opening raw packet socket for ifindex %d",
201		   addr.sll_ifindex);
202
203	if (bind(drv->common.sock, (struct sockaddr *) &addr, sizeof(addr)) < 0)
204	{
205		wpa_printf(MSG_ERROR, "bind: %s", strerror(errno));
206		return -1;
207	}
208
209	/* filter multicast address */
210	if (wired_multicast_membership(drv->common.sock, ifr.ifr_ifindex,
211				       pae_group_addr, 1) < 0) {
212		wpa_printf(MSG_ERROR, "wired: Failed to add multicast group "
213			   "membership");
214		return -1;
215	}
216
217	os_memset(&ifr, 0, sizeof(ifr));
218	os_strlcpy(ifr.ifr_name, drv->common.ifname, sizeof(ifr.ifr_name));
219	if (ioctl(drv->common.sock, SIOCGIFHWADDR, &ifr) != 0) {
220		wpa_printf(MSG_ERROR, "ioctl(SIOCGIFHWADDR): %s",
221			   strerror(errno));
222		return -1;
223	}
224
225	if (ifr.ifr_hwaddr.sa_family != ARPHRD_ETHER) {
226		wpa_printf(MSG_INFO, "Invalid HW-addr family 0x%04x",
227			   ifr.ifr_hwaddr.sa_family);
228		return -1;
229	}
230	os_memcpy(own_addr, ifr.ifr_hwaddr.sa_data, ETH_ALEN);
231
232	/* setup dhcp listen socket for sta detection */
233	if ((drv->dhcp_sock = socket(PF_INET, SOCK_DGRAM, IPPROTO_UDP)) < 0) {
234		wpa_printf(MSG_ERROR, "socket call failed for dhcp: %s",
235			   strerror(errno));
236		return -1;
237	}
238
239	if (eloop_register_read_sock(drv->dhcp_sock, handle_dhcp,
240				     drv->common.ctx, NULL)) {
241		wpa_printf(MSG_INFO, "Could not register read socket");
242		return -1;
243	}
244
245	os_memset(&addr2, 0, sizeof(addr2));
246	addr2.sin_family = AF_INET;
247	addr2.sin_port = htons(67);
248	addr2.sin_addr.s_addr = INADDR_ANY;
249
250	if (setsockopt(drv->dhcp_sock, SOL_SOCKET, SO_REUSEADDR, (char *) &n,
251		       sizeof(n)) == -1) {
252		wpa_printf(MSG_ERROR, "setsockopt[SOL_SOCKET,SO_REUSEADDR]: %s",
253			   strerror(errno));
254		return -1;
255	}
256	if (setsockopt(drv->dhcp_sock, SOL_SOCKET, SO_BROADCAST, (char *) &n,
257		       sizeof(n)) == -1) {
258		wpa_printf(MSG_ERROR, "setsockopt[SOL_SOCKET,SO_BROADCAST]: %s",
259			   strerror(errno));
260		return -1;
261	}
262
263	os_memset(&ifr, 0, sizeof(ifr));
264	os_strlcpy(ifr.ifr_ifrn.ifrn_name, drv->common.ifname, IFNAMSIZ);
265	if (setsockopt(drv->dhcp_sock, SOL_SOCKET, SO_BINDTODEVICE,
266		       (char *) &ifr, sizeof(ifr)) < 0) {
267		wpa_printf(MSG_ERROR,
268			   "setsockopt[SOL_SOCKET,SO_BINDTODEVICE]: %s",
269			   strerror(errno));
270		return -1;
271	}
272
273	if (bind(drv->dhcp_sock, (struct sockaddr *) &addr2,
274		 sizeof(struct sockaddr)) == -1) {
275		wpa_printf(MSG_ERROR, "bind: %s", strerror(errno));
276		return -1;
277	}
278
279	return 0;
280#else /* __linux__ */
281	return -1;
282#endif /* __linux__ */
283}
284
285
286static int wired_send_eapol(void *priv, const u8 *addr,
287			    const u8 *data, size_t data_len, int encrypt,
288			    const u8 *own_addr, u32 flags)
289{
290	struct wpa_driver_wired_data *drv = priv;
291	struct ieee8023_hdr *hdr;
292	size_t len;
293	u8 *pos;
294	int res;
295
296	len = sizeof(*hdr) + data_len;
297	hdr = os_zalloc(len);
298	if (hdr == NULL) {
299		wpa_printf(MSG_INFO,
300			   "malloc() failed for wired_send_eapol(len=%lu)",
301			   (unsigned long) len);
302		return -1;
303	}
304
305	os_memcpy(hdr->dest, drv->use_pae_group_addr ? pae_group_addr : addr,
306		  ETH_ALEN);
307	os_memcpy(hdr->src, own_addr, ETH_ALEN);
308	hdr->ethertype = htons(ETH_P_PAE);
309
310	pos = (u8 *) (hdr + 1);
311	os_memcpy(pos, data, data_len);
312
313	res = send(drv->common.sock, (u8 *) hdr, len, 0);
314	os_free(hdr);
315
316	if (res < 0) {
317		wpa_printf(MSG_ERROR,
318			   "wired_send_eapol - packet len: %lu - failed: send: %s",
319			   (unsigned long) len, strerror(errno));
320	}
321
322	return res;
323}
324
325
326static void * wired_driver_hapd_init(struct hostapd_data *hapd,
327				     struct wpa_init_params *params)
328{
329	struct wpa_driver_wired_data *drv;
330
331	drv = os_zalloc(sizeof(struct wpa_driver_wired_data));
332	if (drv == NULL) {
333		wpa_printf(MSG_INFO,
334			   "Could not allocate memory for wired driver data");
335		return NULL;
336	}
337
338	drv->common.ctx = hapd;
339	os_strlcpy(drv->common.ifname, params->ifname,
340		   sizeof(drv->common.ifname));
341	drv->use_pae_group_addr = params->use_pae_group_addr;
342
343	if (wired_init_sockets(drv, params->own_addr)) {
344		os_free(drv);
345		return NULL;
346	}
347
348	return drv;
349}
350
351
352static void wired_driver_hapd_deinit(void *priv)
353{
354	struct wpa_driver_wired_data *drv = priv;
355
356	if (drv->common.sock >= 0) {
357		eloop_unregister_read_sock(drv->common.sock);
358		close(drv->common.sock);
359	}
360
361	if (drv->dhcp_sock >= 0) {
362		eloop_unregister_read_sock(drv->dhcp_sock);
363		close(drv->dhcp_sock);
364	}
365
366	os_free(drv);
367}
368
369
370static void * wpa_driver_wired_init(void *ctx, const char *ifname)
371{
372	struct wpa_driver_wired_data *drv;
373
374	drv = os_zalloc(sizeof(*drv));
375	if (drv == NULL)
376		return NULL;
377
378	if (driver_wired_init_common(&drv->common, ifname, ctx) < 0) {
379		os_free(drv);
380		return NULL;
381	}
382
383	return drv;
384}
385
386
387static void wpa_driver_wired_deinit(void *priv)
388{
389	struct wpa_driver_wired_data *drv = priv;
390
391	driver_wired_deinit_common(&drv->common);
392	os_free(drv);
393}
394
395
396const struct wpa_driver_ops wpa_driver_wired_ops = {
397	.name = "wired",
398	.desc = "Wired Ethernet driver",
399	.hapd_init = wired_driver_hapd_init,
400	.hapd_deinit = wired_driver_hapd_deinit,
401	.hapd_send_eapol = wired_send_eapol,
402	.get_ssid = driver_wired_get_ssid,
403	.get_bssid = driver_wired_get_bssid,
404	.get_capa = driver_wired_get_capa,
405	.init = wpa_driver_wired_init,
406	.deinit = wpa_driver_wired_deinit,
407};
408