Make all network interrupt service routines MPSAFE part 1/3.
[dragonfly.git] / sys / netproto / ipx / ipx_outputfl.c
1 /*
2  * Copyright (c) 1995, Mike Mitchell
3  * Copyright (c) 1984, 1985, 1986, 1987, 1993
4  *      The Regents of the University of California.  All rights reserved.
5  *
6  * Redistribution and use in source and binary forms, with or without
7  * modification, are permitted provided that the following conditions
8  * are met:
9  * 1. Redistributions of source code must retain the above copyright
10  *    notice, this list of conditions and the following disclaimer.
11  * 2. Redistributions in binary form must reproduce the above copyright
12  *    notice, this list of conditions and the following disclaimer in the
13  *    documentation and/or other materials provided with the distribution.
14  * 3. All advertising materials mentioning features or use of this software
15  *    must display the following acknowledgement:
16  *      This product includes software developed by the University of
17  *      California, Berkeley and its contributors.
18  * 4. Neither the name of the University nor the names of its contributors
19  *    may be used to endorse or promote products derived from this software
20  *    without specific prior written permission.
21  *
22  * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
23  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
24  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
25  * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
26  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
27  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
28  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
29  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
30  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
31  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
32  * SUCH DAMAGE.
33  *
34  *      @(#)ipx_outputfl.c
35  *
36  * $FreeBSD: src/sys/netipx/ipx_outputfl.c,v 1.14.2.1 2000/05/01 01:10:24 bp Exp $
37  * $DragonFly: src/sys/netproto/ipx/ipx_outputfl.c,v 1.7 2005/11/28 17:13:46 dillon Exp $
38  */
39
40 #include <sys/param.h>
41 #include <sys/systm.h>
42 #include <sys/mbuf.h>
43 #include <sys/socket.h>
44
45 #include <net/if.h>
46 #include <net/route.h>
47
48 #include "ipx.h"
49 #include "ipx_if.h"
50 #include "ipx_var.h"
51
52 static int ipx_copy_output = 0;
53
54 int
55 ipx_outputfl(m0, ro, flags)
56         struct mbuf *m0;
57         struct route *ro;
58         int flags;
59 {
60         struct ipx *ipx = mtod(m0, struct ipx *);
61         struct ifnet *ifp = NULL;
62         int error = 0;
63         struct sockaddr_ipx *dst;
64         struct route ipxroute;
65
66         /*
67          * Route packet.
68          */
69         if (ro == NULL) {
70                 ro = &ipxroute;
71                 bzero((caddr_t)ro, sizeof(*ro));
72         }
73         dst = (struct sockaddr_ipx *)&ro->ro_dst;
74         if (ro->ro_rt == NULL) {
75                 dst->sipx_family = AF_IPX;
76                 dst->sipx_len = sizeof(*dst);
77                 dst->sipx_addr = ipx->ipx_dna;
78                 dst->sipx_addr.x_port = 0;
79                 /*
80                  * If routing to interface only,
81                  * short circuit routing lookup.
82                  */
83                 if (flags & IPX_ROUTETOIF) {
84                         struct ipx_ifaddr *ia = ipx_iaonnetof(&ipx->ipx_dna);
85
86                         if (ia == NULL) {
87                                 ipxstat.ipxs_noroute++;
88                                 error = ENETUNREACH;
89                                 goto bad;
90                         }
91                         ifp = ia->ia_ifp;
92                         goto gotif;
93                 }
94                 rtalloc(ro);
95         } else if ((ro->ro_rt->rt_flags & RTF_UP) == 0) {
96                 /*
97                  * The old route has gone away; try for a new one.
98                  */
99                 rtfree(ro->ro_rt);
100                 ro->ro_rt = NULL;
101                 rtalloc(ro);
102         }
103         if (ro->ro_rt == NULL || (ifp = ro->ro_rt->rt_ifp) == NULL) {
104                 ipxstat.ipxs_noroute++;
105                 error = ENETUNREACH;
106                 goto bad;
107         }
108         ro->ro_rt->rt_use++;
109         if (ro->ro_rt->rt_flags & (RTF_GATEWAY|RTF_HOST))
110                 dst = (struct sockaddr_ipx *)ro->ro_rt->rt_gateway;
111 gotif:
112         /*
113          * Look for multicast addresses and
114          * and verify user is allowed to send
115          * such a packet.
116          */
117         if (dst->sipx_addr.x_host.c_host[0]&1) {
118                 if ((ifp->if_flags & (IFF_BROADCAST | IFF_LOOPBACK)) == 0) {
119                         error = EADDRNOTAVAIL;
120                         goto bad;
121                 }
122                 if ((flags & IPX_ALLOWBROADCAST) == 0) {
123                         error = EACCES;
124                         goto bad;
125                 }
126                 m0->m_flags |= M_BCAST;
127         }
128
129         if (htons(ipx->ipx_len) <= ifp->if_mtu) {
130                 ipxstat.ipxs_localout++;
131                 if (ipx_copy_output) {
132                         ipx_watch_output(m0, ifp);
133                 }
134                 lwkt_serialize_enter(ifp->if_serializer);
135                 error = (*ifp->if_output)(ifp, m0,
136                                         (struct sockaddr *)dst, ro->ro_rt);
137                 lwkt_serialize_exit(ifp->if_serializer);
138                 goto done;
139         } else {
140                 ipxstat.ipxs_mtutoosmall++;
141                 error = EMSGSIZE;
142         }
143 bad:
144         if (ipx_copy_output) {
145                 ipx_watch_output(m0, ifp);
146         }
147         m_freem(m0);
148 done:
149         if (ro == &ipxroute && (flags & IPX_ROUTETOIF) == 0 &&
150             ro->ro_rt != NULL) {
151                 RTFREE(ro->ro_rt);
152                 ro->ro_rt = NULL;
153         }
154         return (error);
155 }
156
157 /*
158  * This will broadcast the type 20 (Netbios) packet to all the interfaces
159  * that have ipx configured and isn't in the list yet.
160  */
161 int
162 ipx_output_type20(m)
163         struct mbuf *m;
164 {
165         struct ipx *ipx;
166         union ipx_net *nbnet;
167         struct ipx_ifaddr *ia, *tia = NULL;
168         int error = 0;
169         struct mbuf *m1;
170         int i;
171         struct ifnet *ifp;
172         struct sockaddr_ipx dst;
173
174         /*
175          * We have to get to the 32 bytes after the ipx header also, so
176          * that we can fill in the network address of the receiving
177          * interface.
178          */
179         if ((m->m_flags & M_EXT || m->m_len < (sizeof(struct ipx) + 32)) &&
180             (m = m_pullup(m, sizeof(struct ipx) + 32)) == NULL) {
181                 ipxstat.ipxs_toosmall++;
182                 return (0);
183         }
184         ipx = mtod(m, struct ipx *);
185         nbnet = (union ipx_net *)(ipx + 1);
186
187         if (ipx->ipx_tc >= 8)
188                 goto bad;
189         /*
190          * Now see if we have already seen this.
191          */
192         for (ia = ipx_ifaddr; ia != NULL; ia = ia->ia_next)
193                 if(ia->ia_ifa.ifa_ifp == m->m_pkthdr.rcvif) {
194                         if(tia == NULL)
195                                 tia = ia;
196
197                         for (i=0;i<ipx->ipx_tc;i++,nbnet++)
198                                 if(ipx_neteqnn(ia->ia_addr.sipx_addr.x_net,
199                                                         *nbnet))
200                                         goto bad;
201                 }
202         /*
203          * Don't route the packet if the interface where it come from
204          * does not have an IPX address.
205          */
206         if(tia == NULL)
207                 goto bad;
208
209         /*
210          * Add our receiving interface to the list.
211          */
212         nbnet = (union ipx_net *)(ipx + 1);
213         nbnet += ipx->ipx_tc;
214         *nbnet = tia->ia_addr.sipx_addr.x_net;
215
216         /*
217          * Increment the hop count.
218          */
219         ipx->ipx_tc++;
220         ipxstat.ipxs_forward++;
221
222         /*
223          * Send to all directly connected ifaces not in list and
224          * not to the one it came from.
225          */
226         m->m_flags &= ~M_BCAST;
227         bzero(&dst, sizeof(dst));
228         dst.sipx_family = AF_IPX;
229         dst.sipx_len = 12;
230         dst.sipx_addr.x_host = ipx_broadhost;
231
232         for (ia = ipx_ifaddr; ia != NULL; ia = ia->ia_next)
233                 if(ia->ia_ifa.ifa_ifp != m->m_pkthdr.rcvif) {
234                         nbnet = (union ipx_net *)(ipx + 1);
235                         for (i=0;i<ipx->ipx_tc;i++,nbnet++)
236                                 if(ipx_neteqnn(ia->ia_addr.sipx_addr.x_net,
237                                                         *nbnet))
238                                         goto skip_this;
239
240                         /*
241                          * Insert the net address of the dest net and
242                          * calculate the new checksum if needed.
243                          */
244                         ifp = ia->ia_ifa.ifa_ifp;
245                         dst.sipx_addr.x_net = ia->ia_addr.sipx_addr.x_net;
246                         ipx->ipx_dna.x_net = dst.sipx_addr.x_net;
247                         if(ipx->ipx_sum != 0xffff)
248                                 ipx->ipx_sum = ipx_cksum(m, ntohs(ipx->ipx_len));
249
250                         m1 = m_copym(m, 0, M_COPYALL, MB_DONTWAIT);
251                         if(m1) {
252                                 lwkt_serialize_enter(ifp->if_serializer);
253                                 error = (*ifp->if_output)(ifp, m1,
254                                         (struct sockaddr *)&dst, NULL);
255                                 lwkt_serialize_exit(ifp->if_serializer);
256                                 /* XXX ipxstat.ipxs_localout++; */
257                         }
258 skip_this: ;
259                 }
260
261 bad:
262         m_freem(m);
263         return (error);
264 }