in_pcb.c revision 1.45 1 1.45 lukem /* $NetBSD: in_pcb.c,v 1.45 1998/01/07 22:51:23 lukem Exp $ */
2 1.11 cgd
3 1.1 cgd /*
4 1.44 thorpej * Copyright (c) 1982, 1986, 1991, 1993, 1995
5 1.10 mycroft * The Regents of the University of California. All rights reserved.
6 1.1 cgd *
7 1.1 cgd * Redistribution and use in source and binary forms, with or without
8 1.1 cgd * modification, are permitted provided that the following conditions
9 1.1 cgd * are met:
10 1.1 cgd * 1. Redistributions of source code must retain the above copyright
11 1.1 cgd * notice, this list of conditions and the following disclaimer.
12 1.1 cgd * 2. Redistributions in binary form must reproduce the above copyright
13 1.1 cgd * notice, this list of conditions and the following disclaimer in the
14 1.1 cgd * documentation and/or other materials provided with the distribution.
15 1.1 cgd * 3. All advertising materials mentioning features or use of this software
16 1.1 cgd * must display the following acknowledgement:
17 1.1 cgd * This product includes software developed by the University of
18 1.1 cgd * California, Berkeley and its contributors.
19 1.1 cgd * 4. Neither the name of the University nor the names of its contributors
20 1.1 cgd * may be used to endorse or promote products derived from this software
21 1.1 cgd * without specific prior written permission.
22 1.1 cgd *
23 1.1 cgd * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
24 1.1 cgd * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
25 1.1 cgd * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
26 1.1 cgd * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
27 1.1 cgd * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
28 1.1 cgd * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
29 1.1 cgd * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
30 1.1 cgd * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
31 1.1 cgd * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
32 1.1 cgd * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
33 1.1 cgd * SUCH DAMAGE.
34 1.1 cgd *
35 1.44 thorpej * @(#)in_pcb.c 8.4 (Berkeley) 5/24/95
36 1.1 cgd */
37 1.1 cgd
38 1.7 mycroft #include <sys/param.h>
39 1.7 mycroft #include <sys/systm.h>
40 1.7 mycroft #include <sys/malloc.h>
41 1.7 mycroft #include <sys/mbuf.h>
42 1.7 mycroft #include <sys/protosw.h>
43 1.7 mycroft #include <sys/socket.h>
44 1.7 mycroft #include <sys/socketvar.h>
45 1.7 mycroft #include <sys/ioctl.h>
46 1.10 mycroft #include <sys/errno.h>
47 1.10 mycroft #include <sys/time.h>
48 1.10 mycroft #include <sys/proc.h>
49 1.1 cgd
50 1.7 mycroft #include <net/if.h>
51 1.7 mycroft #include <net/route.h>
52 1.1 cgd
53 1.7 mycroft #include <netinet/in.h>
54 1.7 mycroft #include <netinet/in_systm.h>
55 1.7 mycroft #include <netinet/ip.h>
56 1.7 mycroft #include <netinet/in_pcb.h>
57 1.7 mycroft #include <netinet/in_var.h>
58 1.7 mycroft #include <netinet/ip_var.h>
59 1.1 cgd
60 1.1 cgd struct in_addr zeroin_addr;
61 1.1 cgd
62 1.33 mycroft #define INPCBHASH_BIND(table, laddr, lport) \
63 1.33 mycroft &(table)->inpt_bindhashtbl[ \
64 1.33 mycroft ((ntohl((laddr).s_addr) + ntohs(lport))) & (table)->inpt_bindhash]
65 1.33 mycroft #define INPCBHASH_CONNECT(table, faddr, fport, laddr, lport) \
66 1.33 mycroft &(table)->inpt_connecthashtbl[ \
67 1.33 mycroft ((ntohl((faddr).s_addr) + ntohs(fport)) + \
68 1.33 mycroft (ntohl((laddr).s_addr) + ntohs(lport))) & (table)->inpt_connecthash]
69 1.33 mycroft
70 1.33 mycroft struct inpcb *
71 1.33 mycroft in_pcblookup_port __P((struct inpcbtable *,
72 1.33 mycroft struct in_addr, u_int, int));
73 1.24 mycroft
74 1.43 lukem int anonportmin = IPPORT_ANONMIN;
75 1.43 lukem int anonportmax = IPPORT_ANONMAX;
76 1.43 lukem
77 1.18 mycroft void
78 1.33 mycroft in_pcbinit(table, bindhashsize, connecthashsize)
79 1.18 mycroft struct inpcbtable *table;
80 1.33 mycroft int bindhashsize, connecthashsize;
81 1.18 mycroft {
82 1.18 mycroft
83 1.21 cgd CIRCLEQ_INIT(&table->inpt_queue);
84 1.33 mycroft table->inpt_bindhashtbl =
85 1.33 mycroft hashinit(bindhashsize, M_PCB, &table->inpt_bindhash);
86 1.33 mycroft table->inpt_connecthashtbl =
87 1.33 mycroft hashinit(connecthashsize, M_PCB, &table->inpt_connecthash);
88 1.43 lukem table->inpt_lastport = (u_int16_t)anonportmin;
89 1.18 mycroft }
90 1.18 mycroft
91 1.10 mycroft int
92 1.25 christos in_pcballoc(so, v)
93 1.1 cgd struct socket *so;
94 1.25 christos void *v;
95 1.1 cgd {
96 1.25 christos struct inpcbtable *table = v;
97 1.1 cgd register struct inpcb *inp;
98 1.24 mycroft int s;
99 1.1 cgd
100 1.10 mycroft MALLOC(inp, struct inpcb *, sizeof(*inp), M_PCB, M_WAITOK);
101 1.10 mycroft if (inp == NULL)
102 1.1 cgd return (ENOBUFS);
103 1.10 mycroft bzero((caddr_t)inp, sizeof(*inp));
104 1.18 mycroft inp->inp_table = table;
105 1.1 cgd inp->inp_socket = so;
106 1.39 matt inp->inp_errormtu = -1;
107 1.33 mycroft so->so_pcb = inp;
108 1.24 mycroft s = splnet();
109 1.21 cgd CIRCLEQ_INSERT_HEAD(&table->inpt_queue, inp, inp_queue);
110 1.33 mycroft in_pcbstate(inp, INP_ATTACHED);
111 1.24 mycroft splx(s);
112 1.1 cgd return (0);
113 1.1 cgd }
114 1.8 mycroft
115 1.10 mycroft int
116 1.28 mycroft in_pcbbind(v, nam, p)
117 1.28 mycroft void *v;
118 1.1 cgd struct mbuf *nam;
119 1.28 mycroft struct proc *p;
120 1.1 cgd {
121 1.25 christos register struct inpcb *inp = v;
122 1.1 cgd register struct socket *so = inp->inp_socket;
123 1.18 mycroft register struct inpcbtable *table = inp->inp_table;
124 1.1 cgd register struct sockaddr_in *sin;
125 1.13 cgd u_int16_t lport = 0;
126 1.10 mycroft int wild = 0, reuseport = (so->so_options & SO_REUSEPORT);
127 1.41 mrg #ifndef IPNOPRIVPORTS
128 1.10 mycroft int error;
129 1.41 mrg #endif
130 1.1 cgd
131 1.18 mycroft if (in_ifaddr.tqh_first == 0)
132 1.1 cgd return (EADDRNOTAVAIL);
133 1.32 mycroft if (inp->inp_lport || !in_nullhost(inp->inp_laddr))
134 1.1 cgd return (EINVAL);
135 1.10 mycroft if ((so->so_options & (SO_REUSEADDR|SO_REUSEPORT)) == 0 &&
136 1.4 deraadt ((so->so_proto->pr_flags & PR_CONNREQUIRED) == 0 ||
137 1.4 deraadt (so->so_options & SO_ACCEPTCONN) == 0))
138 1.4 deraadt wild = INPLOOKUP_WILDCARD;
139 1.28 mycroft if (nam == 0)
140 1.28 mycroft goto noname;
141 1.28 mycroft sin = mtod(nam, struct sockaddr_in *);
142 1.28 mycroft if (nam->m_len != sizeof (*sin))
143 1.28 mycroft return (EINVAL);
144 1.10 mycroft #ifdef notdef
145 1.28 mycroft /*
146 1.28 mycroft * We should check the family, but old programs
147 1.28 mycroft * incorrectly fail to initialize it.
148 1.28 mycroft */
149 1.28 mycroft if (sin->sin_family != AF_INET)
150 1.28 mycroft return (EAFNOSUPPORT);
151 1.28 mycroft #endif
152 1.28 mycroft lport = sin->sin_port;
153 1.28 mycroft if (IN_MULTICAST(sin->sin_addr.s_addr)) {
154 1.10 mycroft /*
155 1.28 mycroft * Treat SO_REUSEADDR as SO_REUSEPORT for multicast;
156 1.28 mycroft * allow complete duplication of binding if
157 1.28 mycroft * SO_REUSEPORT is set, or if SO_REUSEADDR is set
158 1.28 mycroft * and a multicast address is bound on both
159 1.28 mycroft * new and duplicated sockets.
160 1.10 mycroft */
161 1.28 mycroft if (so->so_options & SO_REUSEADDR)
162 1.28 mycroft reuseport = SO_REUSEADDR|SO_REUSEPORT;
163 1.32 mycroft } else if (!in_nullhost(sin->sin_addr)) {
164 1.28 mycroft sin->sin_port = 0; /* yech... */
165 1.28 mycroft if (ifa_ifwithaddr(sintosa(sin)) == 0)
166 1.28 mycroft return (EADDRNOTAVAIL);
167 1.28 mycroft }
168 1.28 mycroft if (lport) {
169 1.28 mycroft struct inpcb *t;
170 1.31 perry #ifndef IPNOPRIVPORTS
171 1.28 mycroft /* GROSS */
172 1.28 mycroft if (ntohs(lport) < IPPORT_RESERVED &&
173 1.28 mycroft (p == 0 || (error = suser(p->p_ucred, &p->p_acflag))))
174 1.28 mycroft return (EACCES);
175 1.31 perry #endif
176 1.33 mycroft t = in_pcblookup_port(table, sin->sin_addr, lport, wild);
177 1.28 mycroft if (t && (reuseport & t->inp_socket->so_options) == 0)
178 1.28 mycroft return (EADDRINUSE);
179 1.1 cgd }
180 1.28 mycroft inp->inp_laddr = sin->sin_addr;
181 1.45 lukem
182 1.28 mycroft noname:
183 1.36 mycroft if (lport == 0) {
184 1.45 lukem int cnt
185 1.45 lukem u_int16_t min, max;
186 1.45 lukem u_int16_t *lastport;
187 1.45 lukem
188 1.45 lukem if (inp->inp_flags & INP_LOWPORT) {
189 1.45 lukem #ifndef IPNOPRIVPORTS
190 1.45 lukem if (p == 0 || (error = suser(p->p_ucred, &p->p_acflag)))
191 1.45 lukem return (EACCES);
192 1.45 lukem #endif
193 1.45 lukem min = IPPORT_RESERVEDMIN;
194 1.45 lukem max = IPPORT_RESERVEDMAX;
195 1.45 lukem lastport = &table->inpt_lastlow;
196 1.45 lukem } else {
197 1.45 lukem min = anonportmin;
198 1.45 lukem max = anonportmax;
199 1.45 lukem lastport = &table->inpt_lastport;
200 1.45 lukem }
201 1.45 lukem if (min > max) { /* sanity check */
202 1.45 lukem u_int16_t swp;
203 1.45 lukem
204 1.45 lukem swp = min;
205 1.45 lukem min = max;
206 1.45 lukem max = swp;
207 1.45 lukem }
208 1.43 lukem
209 1.45 lukem lport = *lastport + 1;
210 1.45 lukem for (cnt = max - min + 1; cnt; cnt--, lport++) {
211 1.45 lukem if (lport < min || lport > max)
212 1.45 lukem lport = min;
213 1.36 mycroft if (!in_pcblookup_port(table, inp->inp_laddr,
214 1.36 mycroft htons(lport), wild))
215 1.36 mycroft goto found;
216 1.42 lukem }
217 1.40 thorpej if (!in_nullhost(inp->inp_laddr))
218 1.40 thorpej inp->inp_laddr.s_addr = INADDR_ANY;
219 1.36 mycroft return (EAGAIN);
220 1.36 mycroft found:
221 1.45 lukem inp->inp_flags |= INP_ANONPORT;
222 1.45 lukem *lastport = lport;
223 1.36 mycroft lport = htons(lport);
224 1.36 mycroft }
225 1.1 cgd inp->inp_lport = lport;
226 1.33 mycroft in_pcbstate(inp, INP_BOUND);
227 1.1 cgd return (0);
228 1.1 cgd }
229 1.1 cgd
230 1.1 cgd /*
231 1.1 cgd * Connect from a socket to a specified address.
232 1.1 cgd * Both address and port must be specified in argument sin.
233 1.1 cgd * If don't have a local address for this socket yet,
234 1.1 cgd * then pick one.
235 1.1 cgd */
236 1.10 mycroft int
237 1.25 christos in_pcbconnect(v, nam)
238 1.25 christos register void *v;
239 1.1 cgd struct mbuf *nam;
240 1.1 cgd {
241 1.25 christos register struct inpcb *inp = v;
242 1.1 cgd struct in_ifaddr *ia;
243 1.25 christos struct sockaddr_in *ifaddr = NULL;
244 1.1 cgd register struct sockaddr_in *sin = mtod(nam, struct sockaddr_in *);
245 1.40 thorpej int error;
246 1.1 cgd
247 1.1 cgd if (nam->m_len != sizeof (*sin))
248 1.1 cgd return (EINVAL);
249 1.1 cgd if (sin->sin_family != AF_INET)
250 1.1 cgd return (EAFNOSUPPORT);
251 1.1 cgd if (sin->sin_port == 0)
252 1.1 cgd return (EADDRNOTAVAIL);
253 1.18 mycroft if (in_ifaddr.tqh_first != 0) {
254 1.1 cgd /*
255 1.1 cgd * If the destination address is INADDR_ANY,
256 1.1 cgd * use the primary local address.
257 1.1 cgd * If the supplied address is INADDR_BROADCAST,
258 1.1 cgd * and the primary interface supports broadcast,
259 1.1 cgd * choose the broadcast address for that interface.
260 1.1 cgd */
261 1.32 mycroft if (in_nullhost(sin->sin_addr))
262 1.18 mycroft sin->sin_addr = in_ifaddr.tqh_first->ia_addr.sin_addr;
263 1.14 mycroft else if (sin->sin_addr.s_addr == INADDR_BROADCAST &&
264 1.18 mycroft (in_ifaddr.tqh_first->ia_ifp->if_flags & IFF_BROADCAST))
265 1.18 mycroft sin->sin_addr = in_ifaddr.tqh_first->ia_broadaddr.sin_addr;
266 1.1 cgd }
267 1.32 mycroft /*
268 1.32 mycroft * If we haven't bound which network number to use as ours,
269 1.32 mycroft * we will use the number of the outgoing interface.
270 1.32 mycroft * This depends on having done a routing lookup, which
271 1.32 mycroft * we will probably have to do anyway, so we might
272 1.32 mycroft * as well do it now. On the other hand if we are
273 1.32 mycroft * sending to multiple destinations we may have already
274 1.32 mycroft * done the lookup, so see if we can use the route
275 1.32 mycroft * from before. In any case, we only
276 1.32 mycroft * chose a port number once, even if sending to multiple
277 1.32 mycroft * destinations.
278 1.32 mycroft */
279 1.32 mycroft if (in_nullhost(inp->inp_laddr)) {
280 1.1 cgd register struct route *ro;
281 1.1 cgd
282 1.1 cgd ia = (struct in_ifaddr *)0;
283 1.10 mycroft /*
284 1.1 cgd * If route is known or can be allocated now,
285 1.1 cgd * our src addr is taken from the i/f, else punt.
286 1.1 cgd */
287 1.1 cgd ro = &inp->inp_route;
288 1.1 cgd if (ro->ro_rt &&
289 1.32 mycroft (!in_hosteq(satosin(&ro->ro_dst)->sin_addr,
290 1.32 mycroft sin->sin_addr) ||
291 1.1 cgd inp->inp_socket->so_options & SO_DONTROUTE)) {
292 1.1 cgd RTFREE(ro->ro_rt);
293 1.1 cgd ro->ro_rt = (struct rtentry *)0;
294 1.1 cgd }
295 1.1 cgd if ((inp->inp_socket->so_options & SO_DONTROUTE) == 0 && /*XXX*/
296 1.1 cgd (ro->ro_rt == (struct rtentry *)0 ||
297 1.1 cgd ro->ro_rt->rt_ifp == (struct ifnet *)0)) {
298 1.1 cgd /* No route yet, so try to acquire one */
299 1.1 cgd ro->ro_dst.sa_family = AF_INET;
300 1.1 cgd ro->ro_dst.sa_len = sizeof(struct sockaddr_in);
301 1.15 mycroft satosin(&ro->ro_dst)->sin_addr = sin->sin_addr;
302 1.1 cgd rtalloc(ro);
303 1.1 cgd }
304 1.1 cgd /*
305 1.1 cgd * If we found a route, use the address
306 1.1 cgd * corresponding to the outgoing interface
307 1.1 cgd * unless it is the loopback (in case a route
308 1.1 cgd * to our address on another net goes to loopback).
309 1.1 cgd */
310 1.10 mycroft if (ro->ro_rt && !(ro->ro_rt->rt_ifp->if_flags & IFF_LOOPBACK))
311 1.10 mycroft ia = ifatoia(ro->ro_rt->rt_ifa);
312 1.1 cgd if (ia == 0) {
313 1.13 cgd u_int16_t fport = sin->sin_port;
314 1.1 cgd
315 1.1 cgd sin->sin_port = 0;
316 1.27 mrg ia = ifatoia(ifa_ifwithladdr(sintosa(sin)));
317 1.1 cgd sin->sin_port = fport;
318 1.1 cgd if (ia == 0)
319 1.18 mycroft ia = in_ifaddr.tqh_first;
320 1.1 cgd if (ia == 0)
321 1.1 cgd return (EADDRNOTAVAIL);
322 1.1 cgd }
323 1.6 hpeyerl /*
324 1.6 hpeyerl * If the destination address is multicast and an outgoing
325 1.6 hpeyerl * interface has been set as a multicast option, use the
326 1.6 hpeyerl * address of that interface as our source address.
327 1.6 hpeyerl */
328 1.14 mycroft if (IN_MULTICAST(sin->sin_addr.s_addr) &&
329 1.6 hpeyerl inp->inp_moptions != NULL) {
330 1.6 hpeyerl struct ip_moptions *imo;
331 1.6 hpeyerl struct ifnet *ifp;
332 1.8 mycroft
333 1.6 hpeyerl imo = inp->inp_moptions;
334 1.6 hpeyerl if (imo->imo_multicast_ifp != NULL) {
335 1.6 hpeyerl ifp = imo->imo_multicast_ifp;
336 1.18 mycroft for (ia = in_ifaddr.tqh_first; ia != 0;
337 1.18 mycroft ia = ia->ia_list.tqe_next)
338 1.6 hpeyerl if (ia->ia_ifp == ifp)
339 1.6 hpeyerl break;
340 1.6 hpeyerl if (ia == 0)
341 1.6 hpeyerl return (EADDRNOTAVAIL);
342 1.6 hpeyerl }
343 1.6 hpeyerl }
344 1.15 mycroft ifaddr = satosin(&ia->ia_addr);
345 1.1 cgd }
346 1.33 mycroft if (in_pcblookup_connect(inp->inp_table, sin->sin_addr, sin->sin_port,
347 1.32 mycroft !in_nullhost(inp->inp_laddr) ? inp->inp_laddr : ifaddr->sin_addr,
348 1.24 mycroft inp->inp_lport) != 0)
349 1.1 cgd return (EADDRINUSE);
350 1.32 mycroft if (in_nullhost(inp->inp_laddr)) {
351 1.40 thorpej if (inp->inp_lport == 0) {
352 1.40 thorpej error = in_pcbbind(inp, (struct mbuf *)0,
353 1.28 mycroft (struct proc *)0);
354 1.40 thorpej /*
355 1.40 thorpej * This used to ignore the return value
356 1.40 thorpej * completely, but we need to check for
357 1.40 thorpej * ephemeral port shortage.
358 1.40 thorpej * XXX Should we check for other errors, too?
359 1.40 thorpej */
360 1.40 thorpej if (error == EAGAIN)
361 1.40 thorpej return (error);
362 1.40 thorpej }
363 1.1 cgd inp->inp_laddr = ifaddr->sin_addr;
364 1.1 cgd }
365 1.1 cgd inp->inp_faddr = sin->sin_addr;
366 1.1 cgd inp->inp_fport = sin->sin_port;
367 1.33 mycroft in_pcbstate(inp, INP_CONNECTED);
368 1.1 cgd return (0);
369 1.1 cgd }
370 1.1 cgd
371 1.25 christos void
372 1.25 christos in_pcbdisconnect(v)
373 1.25 christos void *v;
374 1.1 cgd {
375 1.25 christos struct inpcb *inp = v;
376 1.1 cgd
377 1.32 mycroft inp->inp_faddr = zeroin_addr;
378 1.1 cgd inp->inp_fport = 0;
379 1.33 mycroft in_pcbstate(inp, INP_BOUND);
380 1.1 cgd if (inp->inp_socket->so_state & SS_NOFDREF)
381 1.1 cgd in_pcbdetach(inp);
382 1.1 cgd }
383 1.1 cgd
384 1.25 christos void
385 1.25 christos in_pcbdetach(v)
386 1.25 christos void *v;
387 1.1 cgd {
388 1.25 christos struct inpcb *inp = v;
389 1.1 cgd struct socket *so = inp->inp_socket;
390 1.24 mycroft int s;
391 1.1 cgd
392 1.1 cgd so->so_pcb = 0;
393 1.1 cgd sofree(so);
394 1.1 cgd if (inp->inp_options)
395 1.1 cgd (void)m_free(inp->inp_options);
396 1.1 cgd if (inp->inp_route.ro_rt)
397 1.1 cgd rtfree(inp->inp_route.ro_rt);
398 1.6 hpeyerl ip_freemoptions(inp->inp_moptions);
399 1.24 mycroft s = splnet();
400 1.33 mycroft in_pcbstate(inp, INP_ATTACHED);
401 1.21 cgd CIRCLEQ_REMOVE(&inp->inp_table->inpt_queue, inp, inp_queue);
402 1.24 mycroft splx(s);
403 1.10 mycroft FREE(inp, M_PCB);
404 1.1 cgd }
405 1.1 cgd
406 1.25 christos void
407 1.1 cgd in_setsockaddr(inp, nam)
408 1.1 cgd register struct inpcb *inp;
409 1.1 cgd struct mbuf *nam;
410 1.1 cgd {
411 1.1 cgd register struct sockaddr_in *sin;
412 1.10 mycroft
413 1.1 cgd nam->m_len = sizeof (*sin);
414 1.1 cgd sin = mtod(nam, struct sockaddr_in *);
415 1.1 cgd bzero((caddr_t)sin, sizeof (*sin));
416 1.1 cgd sin->sin_family = AF_INET;
417 1.1 cgd sin->sin_len = sizeof(*sin);
418 1.1 cgd sin->sin_port = inp->inp_lport;
419 1.1 cgd sin->sin_addr = inp->inp_laddr;
420 1.1 cgd }
421 1.1 cgd
422 1.25 christos void
423 1.1 cgd in_setpeeraddr(inp, nam)
424 1.1 cgd struct inpcb *inp;
425 1.1 cgd struct mbuf *nam;
426 1.1 cgd {
427 1.1 cgd register struct sockaddr_in *sin;
428 1.10 mycroft
429 1.1 cgd nam->m_len = sizeof (*sin);
430 1.1 cgd sin = mtod(nam, struct sockaddr_in *);
431 1.1 cgd bzero((caddr_t)sin, sizeof (*sin));
432 1.1 cgd sin->sin_family = AF_INET;
433 1.1 cgd sin->sin_len = sizeof(*sin);
434 1.1 cgd sin->sin_port = inp->inp_fport;
435 1.1 cgd sin->sin_addr = inp->inp_faddr;
436 1.1 cgd }
437 1.1 cgd
438 1.1 cgd /*
439 1.1 cgd * Pass some notification to all connections of a protocol
440 1.1 cgd * associated with address dst. The local address and/or port numbers
441 1.1 cgd * may be specified to limit the search. The "usual action" will be
442 1.1 cgd * taken, depending on the ctlinput cmd. The caller must filter any
443 1.1 cgd * cmds that are uninteresting (e.g., no error in the map).
444 1.1 cgd * Call the protocol specific routine (if any) to report
445 1.1 cgd * any errors for each matching socket.
446 1.1 cgd *
447 1.22 mycroft * Must be called at splsoftnet.
448 1.1 cgd */
449 1.37 thorpej int
450 1.32 mycroft in_pcbnotify(table, faddr, fport_arg, laddr, lport_arg, errno, notify)
451 1.18 mycroft struct inpcbtable *table;
452 1.32 mycroft struct in_addr faddr, laddr;
453 1.10 mycroft u_int fport_arg, lport_arg;
454 1.19 mycroft int errno;
455 1.10 mycroft void (*notify) __P((struct inpcb *, int));
456 1.1 cgd {
457 1.33 mycroft struct inpcbhead *head;
458 1.33 mycroft register struct inpcb *inp, *ninp;
459 1.13 cgd u_int16_t fport = fport_arg, lport = lport_arg;
460 1.37 thorpej int nmatch;
461 1.1 cgd
462 1.33 mycroft if (in_nullhost(faddr) || notify == 0)
463 1.37 thorpej return (0);
464 1.1 cgd
465 1.37 thorpej nmatch = 0;
466 1.33 mycroft head = INPCBHASH_CONNECT(table, faddr, fport, laddr, lport);
467 1.33 mycroft for (inp = head->lh_first; inp != NULL; inp = ninp) {
468 1.33 mycroft ninp = inp->inp_hash.le_next;
469 1.33 mycroft if (in_hosteq(inp->inp_faddr, faddr) &&
470 1.33 mycroft inp->inp_fport == fport &&
471 1.33 mycroft inp->inp_lport == lport &&
472 1.37 thorpej in_hosteq(inp->inp_laddr, laddr)) {
473 1.33 mycroft (*notify)(inp, errno);
474 1.37 thorpej nmatch++;
475 1.37 thorpej }
476 1.1 cgd }
477 1.37 thorpej return (nmatch);
478 1.18 mycroft }
479 1.18 mycroft
480 1.20 mycroft void
481 1.32 mycroft in_pcbnotifyall(table, faddr, errno, notify)
482 1.18 mycroft struct inpcbtable *table;
483 1.32 mycroft struct in_addr faddr;
484 1.19 mycroft int errno;
485 1.18 mycroft void (*notify) __P((struct inpcb *, int));
486 1.18 mycroft {
487 1.33 mycroft register struct inpcb *inp, *ninp;
488 1.18 mycroft
489 1.33 mycroft if (in_nullhost(faddr) || notify == 0)
490 1.18 mycroft return;
491 1.18 mycroft
492 1.21 cgd for (inp = table->inpt_queue.cqh_first;
493 1.33 mycroft inp != (struct inpcb *)&table->inpt_queue;
494 1.33 mycroft inp = ninp) {
495 1.33 mycroft ninp = inp->inp_queue.cqe_next;
496 1.33 mycroft if (in_hosteq(inp->inp_faddr, faddr))
497 1.33 mycroft (*notify)(inp, errno);
498 1.1 cgd }
499 1.1 cgd }
500 1.1 cgd
501 1.1 cgd /*
502 1.1 cgd * Check for alternatives when higher level complains
503 1.1 cgd * about service problems. For now, invalidate cached
504 1.1 cgd * routing information. If the route was created dynamically
505 1.1 cgd * (by a redirect), time to try a default gateway again.
506 1.1 cgd */
507 1.25 christos void
508 1.1 cgd in_losing(inp)
509 1.1 cgd struct inpcb *inp;
510 1.1 cgd {
511 1.1 cgd register struct rtentry *rt;
512 1.10 mycroft struct rt_addrinfo info;
513 1.1 cgd
514 1.1 cgd if ((rt = inp->inp_route.ro_rt)) {
515 1.10 mycroft inp->inp_route.ro_rt = 0;
516 1.10 mycroft bzero((caddr_t)&info, sizeof(info));
517 1.17 mycroft info.rti_info[RTAX_DST] = &inp->inp_route.ro_dst;
518 1.10 mycroft info.rti_info[RTAX_GATEWAY] = rt->rt_gateway;
519 1.10 mycroft info.rti_info[RTAX_NETMASK] = rt_mask(rt);
520 1.10 mycroft rt_missmsg(RTM_LOSING, &info, rt->rt_flags, 0);
521 1.1 cgd if (rt->rt_flags & RTF_DYNAMIC)
522 1.1 cgd (void) rtrequest(RTM_DELETE, rt_key(rt),
523 1.10 mycroft rt->rt_gateway, rt_mask(rt), rt->rt_flags,
524 1.1 cgd (struct rtentry **)0);
525 1.10 mycroft else
526 1.1 cgd /*
527 1.1 cgd * A new route can be allocated
528 1.1 cgd * the next time output is attempted.
529 1.1 cgd */
530 1.10 mycroft rtfree(rt);
531 1.1 cgd }
532 1.1 cgd }
533 1.1 cgd
534 1.1 cgd /*
535 1.1 cgd * After a routing change, flush old routing
536 1.1 cgd * and allocate a (hopefully) better one.
537 1.1 cgd */
538 1.10 mycroft void
539 1.10 mycroft in_rtchange(inp, errno)
540 1.1 cgd register struct inpcb *inp;
541 1.10 mycroft int errno;
542 1.1 cgd {
543 1.32 mycroft
544 1.1 cgd if (inp->inp_route.ro_rt) {
545 1.1 cgd rtfree(inp->inp_route.ro_rt);
546 1.1 cgd inp->inp_route.ro_rt = 0;
547 1.1 cgd /*
548 1.1 cgd * A new route can be allocated the next time
549 1.1 cgd * output is attempted.
550 1.1 cgd */
551 1.1 cgd }
552 1.32 mycroft /* SHOULD NOTIFY HIGHER-LEVEL PROTOCOLS */
553 1.1 cgd }
554 1.1 cgd
555 1.1 cgd struct inpcb *
556 1.33 mycroft in_pcblookup_port(table, laddr, lport_arg, flags)
557 1.18 mycroft struct inpcbtable *table;
558 1.33 mycroft struct in_addr laddr;
559 1.33 mycroft u_int lport_arg;
560 1.1 cgd int flags;
561 1.1 cgd {
562 1.1 cgd register struct inpcb *inp, *match = 0;
563 1.1 cgd int matchwild = 3, wildcard;
564 1.33 mycroft u_int16_t lport = lport_arg;
565 1.1 cgd
566 1.21 cgd for (inp = table->inpt_queue.cqh_first;
567 1.21 cgd inp != (struct inpcb *)&table->inpt_queue;
568 1.21 cgd inp = inp->inp_queue.cqe_next) {
569 1.1 cgd if (inp->inp_lport != lport)
570 1.1 cgd continue;
571 1.1 cgd wildcard = 0;
572 1.33 mycroft if (!in_nullhost(inp->inp_faddr))
573 1.33 mycroft wildcard++;
574 1.32 mycroft if (in_nullhost(inp->inp_laddr)) {
575 1.32 mycroft if (!in_nullhost(laddr))
576 1.1 cgd wildcard++;
577 1.1 cgd } else {
578 1.32 mycroft if (in_nullhost(laddr))
579 1.1 cgd wildcard++;
580 1.32 mycroft else {
581 1.32 mycroft if (!in_hosteq(inp->inp_laddr, laddr))
582 1.32 mycroft continue;
583 1.32 mycroft }
584 1.1 cgd }
585 1.1 cgd if (wildcard && (flags & INPLOOKUP_WILDCARD) == 0)
586 1.1 cgd continue;
587 1.1 cgd if (wildcard < matchwild) {
588 1.1 cgd match = inp;
589 1.1 cgd matchwild = wildcard;
590 1.1 cgd if (matchwild == 0)
591 1.1 cgd break;
592 1.1 cgd }
593 1.1 cgd }
594 1.1 cgd return (match);
595 1.24 mycroft }
596 1.24 mycroft
597 1.24 mycroft #ifdef DIAGNOSTIC
598 1.24 mycroft int in_pcbnotifymiss = 0;
599 1.24 mycroft #endif
600 1.24 mycroft
601 1.24 mycroft struct inpcb *
602 1.33 mycroft in_pcblookup_connect(table, faddr, fport_arg, laddr, lport_arg)
603 1.24 mycroft struct inpcbtable *table;
604 1.24 mycroft struct in_addr faddr, laddr;
605 1.24 mycroft u_int fport_arg, lport_arg;
606 1.24 mycroft {
607 1.24 mycroft struct inpcbhead *head;
608 1.24 mycroft register struct inpcb *inp;
609 1.24 mycroft u_int16_t fport = fport_arg, lport = lport_arg;
610 1.24 mycroft
611 1.33 mycroft head = INPCBHASH_CONNECT(table, faddr, fport, laddr, lport);
612 1.24 mycroft for (inp = head->lh_first; inp != NULL; inp = inp->inp_hash.le_next) {
613 1.33 mycroft if (in_hosteq(inp->inp_faddr, faddr) &&
614 1.33 mycroft inp->inp_fport == fport &&
615 1.33 mycroft inp->inp_lport == lport &&
616 1.33 mycroft in_hosteq(inp->inp_laddr, laddr))
617 1.33 mycroft goto out;
618 1.24 mycroft }
619 1.24 mycroft #ifdef DIAGNOSTIC
620 1.33 mycroft if (in_pcbnotifymiss) {
621 1.35 christos printf("in_pcblookup_connect: faddr=%08x fport=%d laddr=%08x lport=%d\n",
622 1.24 mycroft ntohl(faddr.s_addr), ntohs(fport),
623 1.24 mycroft ntohl(laddr.s_addr), ntohs(lport));
624 1.24 mycroft }
625 1.24 mycroft #endif
626 1.33 mycroft return (0);
627 1.33 mycroft
628 1.33 mycroft out:
629 1.33 mycroft /* Move this PCB to the head of hash chain. */
630 1.33 mycroft if (inp != head->lh_first) {
631 1.33 mycroft LIST_REMOVE(inp, inp_hash);
632 1.33 mycroft LIST_INSERT_HEAD(head, inp, inp_hash);
633 1.33 mycroft }
634 1.33 mycroft return (inp);
635 1.33 mycroft }
636 1.33 mycroft
637 1.33 mycroft struct inpcb *
638 1.33 mycroft in_pcblookup_bind(table, laddr, lport_arg)
639 1.33 mycroft struct inpcbtable *table;
640 1.33 mycroft struct in_addr laddr;
641 1.33 mycroft u_int lport_arg;
642 1.33 mycroft {
643 1.33 mycroft struct inpcbhead *head;
644 1.33 mycroft register struct inpcb *inp;
645 1.33 mycroft u_int16_t lport = lport_arg;
646 1.33 mycroft
647 1.33 mycroft head = INPCBHASH_BIND(table, laddr, lport);
648 1.33 mycroft for (inp = head->lh_first; inp != NULL; inp = inp->inp_hash.le_next) {
649 1.33 mycroft if (inp->inp_lport == lport &&
650 1.33 mycroft in_hosteq(inp->inp_laddr, laddr))
651 1.33 mycroft goto out;
652 1.33 mycroft }
653 1.33 mycroft head = INPCBHASH_BIND(table, zeroin_addr, lport);
654 1.33 mycroft for (inp = head->lh_first; inp != NULL; inp = inp->inp_hash.le_next) {
655 1.33 mycroft if (inp->inp_lport == lport &&
656 1.33 mycroft in_hosteq(inp->inp_laddr, zeroin_addr))
657 1.33 mycroft goto out;
658 1.33 mycroft }
659 1.33 mycroft #ifdef DIAGNOSTIC
660 1.33 mycroft if (in_pcbnotifymiss) {
661 1.35 christos printf("in_pcblookup_bind: laddr=%08x lport=%d\n",
662 1.33 mycroft ntohl(laddr.s_addr), ntohs(lport));
663 1.33 mycroft }
664 1.33 mycroft #endif
665 1.33 mycroft return (0);
666 1.33 mycroft
667 1.33 mycroft out:
668 1.33 mycroft /* Move this PCB to the head of hash chain. */
669 1.33 mycroft if (inp != head->lh_first) {
670 1.33 mycroft LIST_REMOVE(inp, inp_hash);
671 1.33 mycroft LIST_INSERT_HEAD(head, inp, inp_hash);
672 1.33 mycroft }
673 1.24 mycroft return (inp);
674 1.33 mycroft }
675 1.33 mycroft
676 1.33 mycroft void
677 1.33 mycroft in_pcbstate(inp, state)
678 1.33 mycroft struct inpcb *inp;
679 1.33 mycroft int state;
680 1.33 mycroft {
681 1.33 mycroft
682 1.33 mycroft if (inp->inp_state > INP_ATTACHED)
683 1.33 mycroft LIST_REMOVE(inp, inp_hash);
684 1.33 mycroft
685 1.33 mycroft switch (state) {
686 1.33 mycroft case INP_BOUND:
687 1.33 mycroft LIST_INSERT_HEAD(INPCBHASH_BIND(inp->inp_table,
688 1.33 mycroft inp->inp_laddr, inp->inp_lport), inp, inp_hash);
689 1.33 mycroft break;
690 1.33 mycroft case INP_CONNECTED:
691 1.33 mycroft LIST_INSERT_HEAD(INPCBHASH_CONNECT(inp->inp_table,
692 1.33 mycroft inp->inp_faddr, inp->inp_fport,
693 1.33 mycroft inp->inp_laddr, inp->inp_lport), inp, inp_hash);
694 1.33 mycroft break;
695 1.33 mycroft }
696 1.33 mycroft
697 1.33 mycroft inp->inp_state = state;
698 1.38 thorpej }
699 1.38 thorpej
700 1.38 thorpej struct rtentry *
701 1.38 thorpej in_pcbrtentry(inp)
702 1.38 thorpej struct inpcb *inp;
703 1.38 thorpej {
704 1.38 thorpej struct route *ro;
705 1.38 thorpej
706 1.38 thorpej ro = &inp->inp_route;
707 1.38 thorpej
708 1.38 thorpej if (ro->ro_rt == NULL) {
709 1.38 thorpej /*
710 1.38 thorpej * No route yet, so try to acquire one.
711 1.38 thorpej */
712 1.38 thorpej if (!in_nullhost(inp->inp_faddr)) {
713 1.38 thorpej ro->ro_dst.sa_family = AF_INET;
714 1.38 thorpej ro->ro_dst.sa_len = sizeof(ro->ro_dst);
715 1.38 thorpej satosin(&ro->ro_dst)->sin_addr = inp->inp_faddr;
716 1.38 thorpej rtalloc(ro);
717 1.38 thorpej }
718 1.38 thorpej }
719 1.38 thorpej return (ro->ro_rt);
720 1.1 cgd }
721