ofnet.c revision 1.13 1 /* $NetBSD: ofnet.c,v 1.13 1998/02/24 05:44:39 mycroft Exp $ */
2
3 /*
4 * Copyright (C) 1995, 1996 Wolfgang Solfrank.
5 * Copyright (C) 1995, 1996 TooLs GmbH.
6 * All rights reserved.
7 *
8 * Redistribution and use in source and binary forms, with or without
9 * modification, are permitted provided that the following conditions
10 * are met:
11 * 1. Redistributions of source code must retain the above copyright
12 * notice, this list of conditions and the following disclaimer.
13 * 2. Redistributions in binary form must reproduce the above copyright
14 * notice, this list of conditions and the following disclaimer in the
15 * documentation and/or other materials provided with the distribution.
16 * 3. All advertising materials mentioning features or use of this software
17 * must display the following acknowledgement:
18 * This product includes software developed by TooLs GmbH.
19 * 4. The name of TooLs GmbH may not be used to endorse or promote products
20 * derived from this software without specific prior written permission.
21 *
22 * THIS SOFTWARE IS PROVIDED BY TOOLS GMBH ``AS IS'' AND ANY EXPRESS OR
23 * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
24 * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
25 * IN NO EVENT SHALL TOOLS GMBH BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
26 * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO,
27 * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS;
28 * OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY,
29 * WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR
30 * OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF
31 * ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
32 */
33 #include "ofnet.h"
34 #include "bpfilter.h"
35
36 #include <sys/param.h>
37 #include <sys/device.h>
38 #include <sys/ioctl.h>
39 #include <sys/mbuf.h>
40 #include <sys/socket.h>
41 #include <sys/syslog.h>
42
43 #include <net/if.h>
44 #include <net/if_ether.h>
45
46 #ifdef INET
47 #include <netinet/in.h>
48 #include <netinet/if_inarp.h>
49 #endif
50
51 #if NBPFILTER > 0
52 #include <net/bpf.h>
53 #include <net/bpfdesc.h>
54 #endif
55
56 #include <dev/ofw/openfirm.h>
57
58 #if NIPKDB_OFN > 0
59 #include <ipkdb/ipkdb.h>
60 #include <machine/ipkdb.h>
61
62 struct cfattach ipkdb_ofn_ca = {
63 0, ipkdb_probe, ipkdb_attach
64 };
65
66 static struct ipkdb_if *kifp;
67 static struct ofnet_softc *ipkdb_of;
68
69 static int ipkdbprobe __P((struct cfdata *, void *));
70 #endif
71
72 struct ofnet_softc {
73 struct device sc_dev;
74 int sc_phandle;
75 int sc_ihandle;
76 struct ethercom sc_ethercom;
77 };
78
79 static int ofnet_match __P((struct device *, struct cfdata *, void *));
80 static void ofnet_attach __P((struct device *, struct device *, void *));
81
82 struct cfattach ofnet_ca = {
83 sizeof(struct ofnet_softc), ofnet_match, ofnet_attach
84 };
85
86 static void ofnet_read __P((struct ofnet_softc *));
87 static void ofnet_timer __P((struct ofnet_softc *));
88 static void ofnet_init __P((struct ofnet_softc *));
89 static void ofnet_stop __P((struct ofnet_softc *));
90
91 static void ofnet_start __P((struct ifnet *));
92 static int ofnet_ioctl __P((struct ifnet *, u_long, caddr_t));
93 static void ofnet_watchdog __P((struct ifnet *));
94
95 static int
96 ofnet_match(parent, match, aux)
97 struct device *parent;
98 struct cfdata *match;
99 void *aux;
100 {
101 struct ofbus_attach_args *oba = aux;
102 char type[32];
103 int l;
104
105 #if NIPKDB_OFN > 0
106 if (!parent)
107 return ipkdbprobe(match, aux);
108 #endif
109 if (strcmp(oba->oba_busname, "ofw"))
110 return (0);
111 if ((l = OF_getprop(oba->oba_phandle, "device_type", type,
112 sizeof type - 1)) < 0)
113 return 0;
114 if (l >= sizeof type)
115 return 0;
116 type[l] = 0;
117 if (strcmp(type, "network"))
118 return 0;
119 return 1;
120 }
121
122 static void
123 ofnet_attach(parent, self, aux)
124 struct device *parent, *self;
125 void *aux;
126 {
127 struct ofnet_softc *of = (void *)self;
128 struct ifnet *ifp = &of->sc_ethercom.ec_if;
129 struct ofbus_attach_args *oba = aux;
130 char path[256];
131 int l;
132 u_int8_t myaddr[ETHER_ADDR_LEN];
133
134 of->sc_phandle = oba->oba_phandle;
135 #if NIPKDB_OFN > 0
136 if (kifp &&
137 kifp->unit - 1 == of->sc_dev.dv_unit &&
138 OF_instance_to_package(kifp->port) == oba->oba_phandle) {
139 ipkdb_of = of;
140 of->sc_ihandle = kifp->port;
141 } else
142 #endif
143 if ((l = OF_package_to_path(oba->oba_phandle, path,
144 sizeof path - 1)) < 0 ||
145 l >= sizeof path ||
146 (path[l] = 0, !(of->sc_ihandle = OF_open(path))))
147 panic("ofnet_attach: unable to open");
148 if (OF_getprop(oba->oba_phandle, "mac-address", myaddr,
149 sizeof myaddr) < 0)
150 panic("ofnet_attach: no mac-address");
151 printf(": address %s\n", ether_sprintf(myaddr));
152
153 bcopy(of->sc_dev.dv_xname, ifp->if_xname, IFNAMSIZ);
154 ifp->if_softc = of;
155 ifp->if_start = ofnet_start;
156 ifp->if_ioctl = ofnet_ioctl;
157 ifp->if_watchdog = ofnet_watchdog;
158 ifp->if_flags = IFF_BROADCAST | IFF_SIMPLEX | IFF_NOTRAILERS;
159
160 if_attach(ifp);
161 ether_ifattach(ifp, myaddr);
162
163 #if NBPFILTER > 0
164 bpfattach(&ifp->if_bpf, ifp, DLT_EN10MB, sizeof(struct ether_header));
165 #endif
166
167 dk_establish(0, self); /* XXX */
168 }
169
170 static char buf[ETHERMTU + sizeof(struct ether_header)];
171
172 static void
173 ofnet_read(of)
174 struct ofnet_softc *of;
175 {
176 struct ifnet *ifp = &of->sc_ethercom.ec_if;
177 struct ether_header *eh;
178 struct mbuf *m, **mp, *head;
179 int l, len;
180 char *bufp;
181
182 #if NIPKDB_OFN > 0
183 ipkdbrint(kifp, ifp);
184 #endif
185 while (1) {
186 if ((len = OF_read(of->sc_ihandle, buf, sizeof buf)) < 0) {
187 if (len == -2 || len == 0)
188 return;
189 ifp->if_ierrors++;
190 continue;
191 }
192 if (len < sizeof(struct ether_header)) {
193 ifp->if_ierrors++;
194 continue;
195 }
196 bufp = buf;
197
198 /* Allocate a header mbuf */
199 MGETHDR(m, M_DONTWAIT, MT_DATA);
200 if (m == 0) {
201 ifp->if_ierrors++;
202 continue;
203 }
204 m->m_pkthdr.rcvif = ifp;
205 m->m_pkthdr.len = len;
206 l = MHLEN;
207 head = 0;
208 mp = &head;
209
210 while (len > 0) {
211 if (head) {
212 MGET(m, M_DONTWAIT, MT_DATA);
213 if (m == 0) {
214 ifp->if_ierrors++;
215 m_freem(head);
216 head = 0;
217 break;
218 }
219 l = MLEN;
220 }
221 if (len >= MINCLSIZE) {
222 MCLGET(m, M_DONTWAIT);
223 if ((m->m_flags & M_EXT) == 0) {
224 ifp->if_ierrors++;
225 m_free(m);
226 m_freem(head);
227 head = 0;
228 break;
229 }
230 l = MCLBYTES;
231 }
232
233 /*
234 * Make sure the data after the Ethernet header
235 * is aligned.
236 *
237 * XXX Assumes the device is an ethernet, but
238 * XXX then so does other code in this driver.
239 */
240 if (head == NULL) {
241 caddr_t newdata = (caddr_t)ALIGN(m->m_data +
242 sizeof(struct ether_header)) -
243 sizeof(struct ether_header);
244 l -= newdata - m->m_data;
245 m->m_data = newdata;
246 }
247
248 m->m_len = l = min(len, l);
249 bcopy(bufp, mtod(m, char *), l);
250 bufp += l;
251 len -= l;
252 *mp = m;
253 mp = &m->m_next;
254 }
255 if (head == 0)
256 continue;
257 eh = mtod(head, struct ether_header *);
258
259 #if NBPFILTER > 0
260 if (ifp->if_bpf)
261 bpf_mtap(ifp->if_bpf, m);
262 #endif
263 m_adj(head, sizeof(struct ether_header));
264 ifp->if_ipackets++;
265 ether_input(ifp, eh, head);
266 }
267 }
268
269 static void
270 ofnet_timer(of)
271 struct ofnet_softc *of;
272 {
273 ofnet_read(of);
274 timeout(ofnet_timer, of, 1);
275 }
276
277 static void
278 ofnet_init(of)
279 struct ofnet_softc *of;
280 {
281 struct ifnet *ifp = &of->sc_ethercom.ec_if;
282
283 if (ifp->if_flags & IFF_RUNNING)
284 return;
285
286 ifp->if_flags |= IFF_RUNNING;
287 /* Start reading from interface */
288 ofnet_timer(of);
289 /* Attempt to start output */
290 ofnet_start(ifp);
291 }
292
293 static void
294 ofnet_stop(of)
295 struct ofnet_softc *of;
296 {
297 untimeout(ofnet_timer, of);
298 of->sc_ethercom.ec_if.if_flags &= ~IFF_RUNNING;
299 }
300
301 static void
302 ofnet_start(ifp)
303 struct ifnet *ifp;
304 {
305 struct ofnet_softc *of = ifp->if_softc;
306 struct mbuf *m, *m0;
307 char *bufp;
308 int len;
309
310 if (!(ifp->if_flags & IFF_RUNNING))
311 return;
312
313 for (;;) {
314 /* First try reading any packets */
315 ofnet_read(of);
316
317 /* Now get the first packet on the queue */
318 IF_DEQUEUE(&ifp->if_snd, m0);
319 if (!m0)
320 return;
321
322 if (!(m0->m_flags & M_PKTHDR))
323 panic("ofnet_start: no header mbuf");
324 len = m0->m_pkthdr.len;
325
326 #if NBPFILTER > 0
327 if (ifp->if_bpf)
328 bpf_mtap(ifp->if_bpf, m0);
329 #endif
330
331 if (len > ETHERMTU + sizeof(struct ether_header)) {
332 /* packet too large, toss it */
333 ifp->if_oerrors++;
334 m_freem(m0);
335 continue;
336 }
337
338 for (bufp = buf; m = m0;) {
339 bcopy(mtod(m, char *), bufp, m->m_len);
340 bufp += m->m_len;
341 MFREE(m, m0);
342 }
343 if (OF_write(of->sc_ihandle, buf, bufp - buf) != bufp - buf)
344 ifp->if_oerrors++;
345 else
346 ifp->if_opackets++;
347 }
348 }
349
350 static int
351 ofnet_ioctl(ifp, cmd, data)
352 struct ifnet *ifp;
353 u_long cmd;
354 caddr_t data;
355 {
356 struct ofnet_softc *of = ifp->if_softc;
357 struct ifaddr *ifa = (struct ifaddr *)data;
358 struct ifreq *ifr = (struct ifreq *)data;
359 int error = 0;
360
361 switch (cmd) {
362 case SIOCSIFADDR:
363 ifp->if_flags |= IFF_UP;
364
365 switch (ifa->ifa_addr->sa_family) {
366 #ifdef INET
367 case AF_INET:
368 arp_ifinit(ifp, ifa);
369 break;
370 #endif
371 default:
372 break;
373 }
374 ofnet_init(of);
375 break;
376 case SIOCSIFFLAGS:
377 if ((ifp->if_flags & IFF_UP) == 0 &&
378 (ifp->if_flags & IFF_RUNNING) != 0) {
379 /* If interface is down, but running, stop it. */
380 ofnet_stop(of);
381 } else if ((ifp->if_flags & IFF_UP) != 0 &&
382 (ifp->if_flags & IFF_RUNNING) == 0) {
383 /* If interface is up, but not running, start it. */
384 ofnet_init(of);
385 } else {
386 /* Other flags are ignored. */
387 }
388 break;
389 default:
390 error = EINVAL;
391 break;
392 }
393 return error;
394 }
395
396 static void
397 ofnet_watchdog(ifp)
398 struct ifnet *ifp;
399 {
400 struct ofnet_softc *of = ifp->if_softc;
401
402 log(LOG_ERR, "%s: device timeout\n", of->sc_dev.dv_xname);
403 ifp->if_oerrors++;
404 ofnet_stop(of);
405 ofnet_init(of);
406 }
407
408 #if NIPKDB_OFN > 0
409 static void
410 ipkdbofstart(kip)
411 struct ipkdb_if *kip;
412 {
413 int unit = kip->unit - 1;
414
415 if (ipkdb_of)
416 ipkdbattach(kip, &ipkdb_of->sc_ethercom);
417 }
418
419 static void
420 ipkdbofleave(kip)
421 struct ipkdb_if *kip;
422 {
423 }
424
425 static int
426 ipkdbofrcv(kip, buf, poll)
427 struct ipkdb_if *kip;
428 u_char *buf;
429 int poll;
430 {
431 int l;
432
433 do {
434 l = OF_read(kip->port, buf, ETHERMTU);
435 if (l < 0)
436 l = 0;
437 } while (!poll && !l);
438 return l;
439 }
440
441 static void
442 ipkdbofsend(kip, buf, l)
443 struct ipkdb_if *kip;
444 u_char *buf;
445 int l;
446 {
447 OF_write(kip->port, buf, l);
448 }
449
450 static int
451 ipkdbprobe(match, aux)
452 struct cfdata *match;
453 void *aux;
454 {
455 struct ipkdb_if *kip = aux;
456 static char name[256];
457 int len;
458 int phandle;
459
460 kip->unit = match->cf_unit + 1;
461
462 if (!(kip->port = OF_open("net")))
463 return -1;
464 if ((len = OF_instance_to_path(kip->port, name, sizeof name - 1)) < 0 ||
465 len >= sizeof name)
466 return -1;
467 name[len] = 0;
468 if ((phandle = OF_instance_to_package(kip->port)) == -1)
469 return -1;
470 if (OF_getprop(phandle, "mac-address", kip->myenetaddr,
471 sizeof kip->myenetaddr) < 0)
472 return -1;
473
474 kip->flags |= IPKDB_MYHW;
475 kip->name = name;
476 kip->start = ipkdbofstart;
477 kip->leave = ipkdbofleave;
478 kip->receive = ipkdbofrcv;
479 kip->send = ipkdbofsend;
480
481 kifp = kip;
482
483 return 0;
484 }
485 #endif
486