Annotation of src/sys/netinet/raw_ip.c, Revision 1.19
1.19 ! mycroft 1: /* $NetBSD: raw_ip.c,v 1.18 1995/05/31 21:50:44 mycroft Exp $ */
1.14 cgd 2:
1.1 cgd 3: /*
1.13 mycroft 4: * Copyright (c) 1982, 1986, 1988, 1993
5: * The Regents of the University of California. All rights reserved.
1.1 cgd 6: *
7: * Redistribution and use in source and binary forms, with or without
8: * modification, are permitted provided that the following conditions
9: * are met:
10: * 1. Redistributions of source code must retain the above copyright
11: * notice, this list of conditions and the following disclaimer.
12: * 2. Redistributions in binary form must reproduce the above copyright
13: * notice, this list of conditions and the following disclaimer in the
14: * documentation and/or other materials provided with the distribution.
15: * 3. All advertising materials mentioning features or use of this software
16: * must display the following acknowledgement:
17: * This product includes software developed by the University of
18: * California, Berkeley and its contributors.
19: * 4. Neither the name of the University nor the names of its contributors
20: * may be used to endorse or promote products derived from this software
21: * without specific prior written permission.
22: *
23: * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
24: * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
25: * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
26: * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
27: * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
28: * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
29: * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
30: * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
31: * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
32: * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
33: * SUCH DAMAGE.
34: *
1.14 cgd 35: * @(#)raw_ip.c 8.2 (Berkeley) 1/4/94
1.1 cgd 36: */
37:
1.7 mycroft 38: #include <sys/param.h>
39: #include <sys/malloc.h>
40: #include <sys/mbuf.h>
41: #include <sys/socket.h>
42: #include <sys/protosw.h>
43: #include <sys/socketvar.h>
44: #include <sys/errno.h>
1.13 mycroft 45: #include <sys/systm.h>
1.1 cgd 46:
1.7 mycroft 47: #include <net/if.h>
48: #include <net/route.h>
1.1 cgd 49:
1.7 mycroft 50: #include <netinet/in.h>
51: #include <netinet/in_systm.h>
52: #include <netinet/ip.h>
53: #include <netinet/ip_var.h>
1.13 mycroft 54: #include <netinet/ip_mroute.h>
1.7 mycroft 55: #include <netinet/in_pcb.h>
1.13 mycroft 56:
57: struct inpcb rawinpcb;
58:
59: /*
60: * Nominal space allocated to a raw ip socket.
61: */
62: #define RIPSNDQ 8192
63: #define RIPRCVQ 8192
1.1 cgd 64:
65: /*
66: * Raw interface to IP protocol.
67: */
1.13 mycroft 68:
69: /*
70: * Initialize raw connection block q.
71: */
72: void
73: rip_init()
74: {
75:
76: rawinpcb.inp_next = rawinpcb.inp_prev = &rawinpcb;
77: }
78:
1.1 cgd 79: struct sockaddr_in ripsrc = { sizeof(ripsrc), AF_INET };
80: /*
81: * Setup generic address and protocol structures
82: * for raw_input routine, then pass them along with
83: * mbuf chain.
84: */
1.9 mycroft 85: void
1.1 cgd 86: rip_input(m)
87: struct mbuf *m;
88: {
89: register struct ip *ip = mtod(m, struct ip *);
1.13 mycroft 90: register struct inpcb *inp;
91: struct socket *last = 0;
1.1 cgd 92:
93: ripsrc.sin_addr = ip->ip_src;
1.13 mycroft 94: for (inp = rawinpcb.inp_next; inp != &rawinpcb; inp = inp->inp_next) {
95: if (inp->inp_ip.ip_p && inp->inp_ip.ip_p != ip->ip_p)
96: continue;
97: if (inp->inp_laddr.s_addr &&
1.16 glass 98: inp->inp_laddr.s_addr != ip->ip_dst.s_addr)
1.13 mycroft 99: continue;
100: if (inp->inp_faddr.s_addr &&
1.16 glass 101: inp->inp_faddr.s_addr != ip->ip_src.s_addr)
1.13 mycroft 102: continue;
103: if (last) {
104: struct mbuf *n;
105: if (n = m_copy(m, 0, (int)M_COPYALL)) {
106: if (sbappendaddr(&last->so_rcv,
1.19 ! mycroft 107: sintosa(&ripsrc), n,
! 108: (struct mbuf *)0) == 0)
1.13 mycroft 109: /* should notify about lost packet */
110: m_freem(n);
111: else
112: sorwakeup(last);
113: }
114: }
115: last = inp->inp_socket;
116: }
117: if (last) {
1.19 ! mycroft 118: if (sbappendaddr(&last->so_rcv, sintosa(&ripsrc), m,
! 119: (struct mbuf *)0) == 0)
1.13 mycroft 120: m_freem(m);
121: else
122: sorwakeup(last);
123: } else {
124: m_freem(m);
1.1 cgd 125: ipstat.ips_noproto++;
126: ipstat.ips_delivered--;
127: }
128: }
129:
130: /*
131: * Generate IP header and pass packet to ip_output.
132: * Tack on options user may have setup with control call.
133: */
1.9 mycroft 134: int
1.13 mycroft 135: rip_output(m, so, dst)
1.1 cgd 136: register struct mbuf *m;
137: struct socket *so;
1.13 mycroft 138: u_long dst;
1.1 cgd 139: {
140: register struct ip *ip;
1.13 mycroft 141: register struct inpcb *inp = sotoinpcb(so);
1.10 mycroft 142: struct mbuf *opts;
1.13 mycroft 143: int flags = (so->so_options & SO_DONTROUTE) | IP_ALLOWBROADCAST;
1.1 cgd 144:
145: /*
146: * If the user handed us a complete IP packet, use it.
147: * Otherwise, allocate an mbuf for a header and fill it in.
148: */
1.13 mycroft 149: if ((inp->inp_flags & INP_HDRINCL) == 0) {
1.1 cgd 150: M_PREPEND(m, sizeof(struct ip), M_WAIT);
151: ip = mtod(m, struct ip *);
152: ip->ip_tos = 0;
153: ip->ip_off = 0;
1.13 mycroft 154: ip->ip_p = inp->inp_ip.ip_p;
1.1 cgd 155: ip->ip_len = m->m_pkthdr.len;
1.13 mycroft 156: ip->ip_src = inp->inp_laddr;
157: ip->ip_dst.s_addr = dst;
1.1 cgd 158: ip->ip_ttl = MAXTTL;
1.13 mycroft 159: opts = inp->inp_options;
160: } else {
161: ip = mtod(m, struct ip *);
162: if (ip->ip_id == 0)
163: ip->ip_id = htons(ip_id++);
164: opts = NULL;
165: /* XXX prevent ip_output from overwriting header fields */
166: flags |= IP_RAWOUTPUT;
167: ipstat.ips_rawout++;
1.1 cgd 168: }
1.13 mycroft 169: return (ip_output(m, opts, &inp->inp_route, flags, inp->inp_moptions));
1.1 cgd 170: }
171:
172: /*
173: * Raw IP socket option processing.
174: */
1.9 mycroft 175: int
1.1 cgd 176: rip_ctloutput(op, so, level, optname, m)
177: int op;
178: struct socket *so;
179: int level, optname;
180: struct mbuf **m;
181: {
1.13 mycroft 182: register struct inpcb *inp = sotoinpcb(so);
183: register int error;
1.1 cgd 184:
1.15 mycroft 185: if (level != IPPROTO_IP) {
186: if (m != 0 && *m != 0)
187: (void)m_free(*m);
1.13 mycroft 188: return (EINVAL);
1.15 mycroft 189: }
1.1 cgd 190:
1.13 mycroft 191: switch (optname) {
1.1 cgd 192:
1.13 mycroft 193: case IP_HDRINCL:
194: if (op == PRCO_SETOPT || op == PRCO_GETOPT) {
195: if (m == 0 || *m == 0 || (*m)->m_len < sizeof (int))
196: return (EINVAL);
197: if (op == PRCO_SETOPT) {
198: if (*mtod(*m, int *))
199: inp->inp_flags |= INP_HDRINCL;
200: else
201: inp->inp_flags &= ~INP_HDRINCL;
202: (void)m_free(*m);
203: } else {
204: (*m)->m_len = sizeof (int);
205: *mtod(*m, int *) = inp->inp_flags & INP_HDRINCL;
206: }
207: return (0);
208: }
209: break;
1.1 cgd 210:
1.18 mycroft 211: case MRT_INIT:
212: case MRT_DONE:
213: case MRT_ADD_VIF:
214: case MRT_DEL_VIF:
215: case MRT_ADD_MFC:
216: case MRT_DEL_MFC:
217: case MRT_VERSION:
218: case MRT_ASSERT:
1.6 hpeyerl 219: #ifdef MROUTING
1.18 mycroft 220: switch (op) {
221: case PRCO_SETOPT:
222: error = ip_mrouter_set(optname, so, m);
223: break;
224: case PRCO_GETOPT:
225: error = ip_mrouter_get(optname, so, m);
226: break;
227: default:
1.13 mycroft 228: error = EINVAL;
1.18 mycroft 229: break;
230: }
1.13 mycroft 231: return (error);
1.6 hpeyerl 232: #else
1.13 mycroft 233: if (op == PRCO_SETOPT && *m)
1.18 mycroft 234: m_free(*m);
1.13 mycroft 235: return (EOPNOTSUPP);
1.6 hpeyerl 236: #endif
1.1 cgd 237: }
1.13 mycroft 238: return (ip_ctloutput(op, so, level, optname, m));
1.1 cgd 239: }
240:
1.13 mycroft 241: u_long rip_sendspace = RIPSNDQ;
242: u_long rip_recvspace = RIPRCVQ;
243:
1.1 cgd 244: /*ARGSUSED*/
1.9 mycroft 245: int
1.2 cgd 246: rip_usrreq(so, req, m, nam, control)
1.1 cgd 247: register struct socket *so;
248: int req;
1.2 cgd 249: struct mbuf *m, *nam, *control;
1.1 cgd 250: {
251: register int error = 0;
1.13 mycroft 252: register struct inpcb *inp = sotoinpcb(so);
253: #ifdef MROUTING
1.6 hpeyerl 254: extern struct socket *ip_mrouter;
255: #endif
1.1 cgd 256: switch (req) {
257:
258: case PRU_ATTACH:
1.13 mycroft 259: if (inp)
1.1 cgd 260: panic("rip_attach");
1.13 mycroft 261: if ((so->so_state & SS_PRIV) == 0) {
262: error = EACCES;
263: break;
264: }
265: if ((error = soreserve(so, rip_sendspace, rip_recvspace)) ||
266: (error = in_pcballoc(so, &rawinpcb)))
267: break;
268: inp = (struct inpcb *)so->so_pcb;
1.17 cgd 269: inp->inp_ip.ip_p = (long)nam;
1.1 cgd 270: break;
271:
1.13 mycroft 272: case PRU_DISCONNECT:
273: if ((so->so_state & SS_ISCONNECTED) == 0) {
274: error = ENOTCONN;
275: break;
276: }
277: /* FALLTHROUGH */
278: case PRU_ABORT:
279: soisdisconnected(so);
280: /* FALLTHROUGH */
1.1 cgd 281: case PRU_DETACH:
1.13 mycroft 282: if (inp == 0)
1.1 cgd 283: panic("rip_detach");
1.13 mycroft 284: #ifdef MROUTING
1.6 hpeyerl 285: if (so == ip_mrouter)
286: ip_mrouter_done();
287: #endif
1.13 mycroft 288: in_pcbdetach(inp);
1.1 cgd 289: break;
290:
291: case PRU_BIND:
292: {
293: struct sockaddr_in *addr = mtod(nam, struct sockaddr_in *);
294:
1.13 mycroft 295: if (nam->m_len != sizeof(*addr)) {
296: error = EINVAL;
297: break;
298: }
1.1 cgd 299: if ((ifnet == 0) ||
300: ((addr->sin_family != AF_INET) &&
301: (addr->sin_family != AF_IMPLINK)) ||
302: (addr->sin_addr.s_addr &&
1.19 ! mycroft 303: ifa_ifwithaddr(sintosa(addr)) == 0)) {
1.13 mycroft 304: error = EADDRNOTAVAIL;
305: break;
306: }
307: inp->inp_laddr = addr->sin_addr;
308: break;
1.1 cgd 309: }
310: case PRU_CONNECT:
311: {
312: struct sockaddr_in *addr = mtod(nam, struct sockaddr_in *);
313:
1.13 mycroft 314: if (nam->m_len != sizeof(*addr)) {
315: error = EINVAL;
316: break;
317: }
318: if (ifnet == 0) {
319: error = EADDRNOTAVAIL;
320: break;
321: }
1.1 cgd 322: if ((addr->sin_family != AF_INET) &&
1.13 mycroft 323: (addr->sin_family != AF_IMPLINK)) {
324: error = EAFNOSUPPORT;
325: break;
326: }
327: inp->inp_faddr = addr->sin_addr;
1.1 cgd 328: soisconnected(so);
1.13 mycroft 329: break;
330: }
331:
332: case PRU_CONNECT2:
333: error = EOPNOTSUPP;
334: break;
335:
336: /*
337: * Mark the connection as being incapable of further input.
338: */
339: case PRU_SHUTDOWN:
340: socantsendmore(so);
341: break;
342:
343: /*
344: * Ship a packet out. The appropriate raw output
345: * routine handles any massaging necessary.
346: */
347: case PRU_SEND:
348: {
1.17 cgd 349: register u_int32_t dst;
1.13 mycroft 350:
351: if (so->so_state & SS_ISCONNECTED) {
352: if (nam) {
353: error = EISCONN;
354: break;
355: }
356: dst = inp->inp_faddr.s_addr;
357: } else {
358: if (nam == NULL) {
359: error = ENOTCONN;
360: break;
361: }
362: dst = mtod(nam, struct sockaddr_in *)->sin_addr.s_addr;
363: }
364: error = rip_output(m, so, dst);
365: m = NULL;
366: break;
367: }
368:
369: case PRU_SENSE:
370: /*
371: * stat: don't bother with a blocksize.
372: */
1.1 cgd 373: return (0);
1.13 mycroft 374:
375: /*
376: * Not supported.
377: */
378: case PRU_RCVOOB:
379: case PRU_RCVD:
380: case PRU_LISTEN:
381: case PRU_ACCEPT:
382: case PRU_SENDOOB:
383: error = EOPNOTSUPP;
384: break;
385:
386: case PRU_SOCKADDR:
387: in_setsockaddr(inp, nam);
388: break;
389:
390: case PRU_PEERADDR:
391: in_setpeeraddr(inp, nam);
392: break;
393:
394: default:
395: panic("rip_usrreq");
1.1 cgd 396: }
1.13 mycroft 397: if (m != NULL)
398: m_freem(m);
1.1 cgd 399: return (error);
400: }
CVSweb <webmaster@jp.NetBSD.org>