tcp_usrreq.c revision 1.20 1 1.20 christos /* $NetBSD: tcp_usrreq.c,v 1.20 1996/02/13 23:44:16 christos Exp $ */
2 1.10 cgd
3 1.1 cgd /*
4 1.9 mycroft * Copyright (c) 1982, 1986, 1988, 1993
5 1.9 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.10 cgd * @(#)tcp_usrreq.c 8.2 (Berkeley) 1/3/94
36 1.1 cgd */
37 1.1 cgd
38 1.5 mycroft #include <sys/param.h>
39 1.5 mycroft #include <sys/systm.h>
40 1.13 glass #include <sys/kernel.h>
41 1.5 mycroft #include <sys/malloc.h>
42 1.5 mycroft #include <sys/mbuf.h>
43 1.5 mycroft #include <sys/socket.h>
44 1.5 mycroft #include <sys/socketvar.h>
45 1.5 mycroft #include <sys/protosw.h>
46 1.5 mycroft #include <sys/errno.h>
47 1.5 mycroft #include <sys/stat.h>
48 1.20 christos #include <sys/proc.h>
49 1.20 christos #include <sys/ucred.h>
50 1.20 christos #include <vm/vm.h>
51 1.20 christos #include <sys/sysctl.h>
52 1.1 cgd
53 1.5 mycroft #include <net/if.h>
54 1.5 mycroft #include <net/route.h>
55 1.1 cgd
56 1.5 mycroft #include <netinet/in.h>
57 1.5 mycroft #include <netinet/in_systm.h>
58 1.14 cgd #include <netinet/in_var.h>
59 1.5 mycroft #include <netinet/ip.h>
60 1.5 mycroft #include <netinet/in_pcb.h>
61 1.5 mycroft #include <netinet/ip_var.h>
62 1.5 mycroft #include <netinet/tcp.h>
63 1.5 mycroft #include <netinet/tcp_fsm.h>
64 1.5 mycroft #include <netinet/tcp_seq.h>
65 1.5 mycroft #include <netinet/tcp_timer.h>
66 1.5 mycroft #include <netinet/tcp_var.h>
67 1.5 mycroft #include <netinet/tcpip.h>
68 1.5 mycroft #include <netinet/tcp_debug.h>
69 1.1 cgd
70 1.1 cgd /*
71 1.1 cgd * TCP protocol interface to socket abstraction.
72 1.1 cgd */
73 1.1 cgd extern char *tcpstates[];
74 1.1 cgd
75 1.1 cgd /*
76 1.1 cgd * Process a TCP user request for TCP tb. If this is a send request
77 1.1 cgd * then m is the mbuf chain of send data. If this is a timer expiration
78 1.1 cgd * (called from the software clock routine), then timertype tells which timer.
79 1.1 cgd */
80 1.1 cgd /*ARGSUSED*/
81 1.6 mycroft int
82 1.1 cgd tcp_usrreq(so, req, m, nam, control)
83 1.1 cgd struct socket *so;
84 1.1 cgd int req;
85 1.1 cgd struct mbuf *m, *nam, *control;
86 1.1 cgd {
87 1.1 cgd register struct inpcb *inp;
88 1.20 christos register struct tcpcb *tp = NULL;
89 1.1 cgd int s;
90 1.1 cgd int error = 0;
91 1.1 cgd int ostate;
92 1.1 cgd
93 1.1 cgd if (req == PRU_CONTROL)
94 1.14 cgd return (in_control(so, (long)m, (caddr_t)nam,
95 1.1 cgd (struct ifnet *)control));
96 1.1 cgd if (control && control->m_len) {
97 1.1 cgd m_freem(control);
98 1.1 cgd if (m)
99 1.1 cgd m_freem(m);
100 1.1 cgd return (EINVAL);
101 1.1 cgd }
102 1.1 cgd
103 1.16 mycroft s = splsoftnet();
104 1.1 cgd inp = sotoinpcb(so);
105 1.1 cgd /*
106 1.1 cgd * When a TCP is attached to a socket, then there will be
107 1.1 cgd * a (struct inpcb) pointed at by the socket, and this
108 1.1 cgd * structure will point at a subsidary (struct tcpcb).
109 1.1 cgd */
110 1.1 cgd if (inp == 0 && req != PRU_ATTACH) {
111 1.1 cgd splx(s);
112 1.1 cgd return (EINVAL); /* XXX */
113 1.1 cgd }
114 1.1 cgd if (inp) {
115 1.1 cgd tp = intotcpcb(inp);
116 1.1 cgd /* WHAT IF TP IS 0? */
117 1.1 cgd #ifdef KPROF
118 1.1 cgd tcp_acounts[tp->t_state][req]++;
119 1.1 cgd #endif
120 1.1 cgd ostate = tp->t_state;
121 1.1 cgd } else
122 1.1 cgd ostate = 0;
123 1.1 cgd switch (req) {
124 1.1 cgd
125 1.1 cgd /*
126 1.1 cgd * TCP attaches to socket via PRU_ATTACH, reserving space,
127 1.1 cgd * and an internet control block.
128 1.1 cgd */
129 1.1 cgd case PRU_ATTACH:
130 1.1 cgd if (inp) {
131 1.1 cgd error = EISCONN;
132 1.1 cgd break;
133 1.1 cgd }
134 1.1 cgd error = tcp_attach(so);
135 1.1 cgd if (error)
136 1.1 cgd break;
137 1.1 cgd if ((so->so_options & SO_LINGER) && so->so_linger == 0)
138 1.13 glass so->so_linger = TCP_LINGERTIME * hz;
139 1.1 cgd tp = sototcpcb(so);
140 1.1 cgd break;
141 1.1 cgd
142 1.1 cgd /*
143 1.1 cgd * PRU_DETACH detaches the TCP protocol from the socket.
144 1.1 cgd * If the protocol state is non-embryonic, then can't
145 1.1 cgd * do this directly: have to initiate a PRU_DISCONNECT,
146 1.1 cgd * which may finish later; embryonic TCB's can just
147 1.1 cgd * be discarded here.
148 1.1 cgd */
149 1.1 cgd case PRU_DETACH:
150 1.1 cgd if (tp->t_state > TCPS_LISTEN)
151 1.1 cgd tp = tcp_disconnect(tp);
152 1.1 cgd else
153 1.1 cgd tp = tcp_close(tp);
154 1.1 cgd break;
155 1.1 cgd
156 1.1 cgd /*
157 1.1 cgd * Give the socket an address.
158 1.1 cgd */
159 1.1 cgd case PRU_BIND:
160 1.1 cgd error = in_pcbbind(inp, nam);
161 1.1 cgd if (error)
162 1.1 cgd break;
163 1.1 cgd break;
164 1.1 cgd
165 1.1 cgd /*
166 1.1 cgd * Prepare to accept connections.
167 1.1 cgd */
168 1.1 cgd case PRU_LISTEN:
169 1.1 cgd if (inp->inp_lport == 0)
170 1.1 cgd error = in_pcbbind(inp, (struct mbuf *)0);
171 1.1 cgd if (error == 0)
172 1.1 cgd tp->t_state = TCPS_LISTEN;
173 1.1 cgd break;
174 1.1 cgd
175 1.1 cgd /*
176 1.1 cgd * Initiate connection to peer.
177 1.1 cgd * Create a template for use in transmissions on this connection.
178 1.1 cgd * Enter SYN_SENT state, and mark socket as connecting.
179 1.1 cgd * Start keep-alive timer, and seed output sequence space.
180 1.1 cgd * Send initial segment on connection.
181 1.1 cgd */
182 1.1 cgd case PRU_CONNECT:
183 1.1 cgd if (inp->inp_lport == 0) {
184 1.1 cgd error = in_pcbbind(inp, (struct mbuf *)0);
185 1.1 cgd if (error)
186 1.1 cgd break;
187 1.1 cgd }
188 1.1 cgd error = in_pcbconnect(inp, nam);
189 1.1 cgd if (error)
190 1.1 cgd break;
191 1.1 cgd tp->t_template = tcp_template(tp);
192 1.1 cgd if (tp->t_template == 0) {
193 1.1 cgd in_pcbdisconnect(inp);
194 1.1 cgd error = ENOBUFS;
195 1.1 cgd break;
196 1.1 cgd }
197 1.9 mycroft /* Compute window scaling to request. */
198 1.9 mycroft while (tp->request_r_scale < TCP_MAX_WINSHIFT &&
199 1.9 mycroft (TCP_MAXWIN << tp->request_r_scale) < so->so_rcv.sb_hiwat)
200 1.9 mycroft tp->request_r_scale++;
201 1.1 cgd soisconnecting(so);
202 1.1 cgd tcpstat.tcps_connattempt++;
203 1.1 cgd tp->t_state = TCPS_SYN_SENT;
204 1.1 cgd tp->t_timer[TCPT_KEEP] = TCPTV_KEEP_INIT;
205 1.1 cgd tp->iss = tcp_iss; tcp_iss += TCP_ISSINCR/2;
206 1.1 cgd tcp_sendseqinit(tp);
207 1.1 cgd error = tcp_output(tp);
208 1.1 cgd break;
209 1.1 cgd
210 1.1 cgd /*
211 1.1 cgd * Create a TCP connection between two sockets.
212 1.1 cgd */
213 1.1 cgd case PRU_CONNECT2:
214 1.1 cgd error = EOPNOTSUPP;
215 1.1 cgd break;
216 1.1 cgd
217 1.1 cgd /*
218 1.1 cgd * Initiate disconnect from peer.
219 1.1 cgd * If connection never passed embryonic stage, just drop;
220 1.1 cgd * else if don't need to let data drain, then can just drop anyways,
221 1.1 cgd * else have to begin TCP shutdown process: mark socket disconnecting,
222 1.1 cgd * drain unread data, state switch to reflect user close, and
223 1.1 cgd * send segment (e.g. FIN) to peer. Socket will be really disconnected
224 1.1 cgd * when peer sends FIN and acks ours.
225 1.1 cgd *
226 1.1 cgd * SHOULD IMPLEMENT LATER PRU_CONNECT VIA REALLOC TCPCB.
227 1.1 cgd */
228 1.1 cgd case PRU_DISCONNECT:
229 1.1 cgd tp = tcp_disconnect(tp);
230 1.1 cgd break;
231 1.1 cgd
232 1.1 cgd /*
233 1.1 cgd * Accept a connection. Essentially all the work is
234 1.1 cgd * done at higher levels; just return the address
235 1.1 cgd * of the peer, storing through addr.
236 1.1 cgd */
237 1.8 mycroft case PRU_ACCEPT:
238 1.8 mycroft in_setpeeraddr(inp, nam);
239 1.1 cgd break;
240 1.1 cgd
241 1.1 cgd /*
242 1.1 cgd * Mark the connection as being incapable of further output.
243 1.1 cgd */
244 1.1 cgd case PRU_SHUTDOWN:
245 1.1 cgd socantsendmore(so);
246 1.1 cgd tp = tcp_usrclosed(tp);
247 1.1 cgd if (tp)
248 1.1 cgd error = tcp_output(tp);
249 1.1 cgd break;
250 1.1 cgd
251 1.1 cgd /*
252 1.1 cgd * After a receive, possibly send window update to peer.
253 1.1 cgd */
254 1.1 cgd case PRU_RCVD:
255 1.1 cgd (void) tcp_output(tp);
256 1.1 cgd break;
257 1.1 cgd
258 1.1 cgd /*
259 1.1 cgd * Do a send by putting data in output queue and updating urgent
260 1.1 cgd * marker if URG set. Possibly send more data.
261 1.1 cgd */
262 1.1 cgd case PRU_SEND:
263 1.1 cgd sbappend(&so->so_snd, m);
264 1.1 cgd error = tcp_output(tp);
265 1.1 cgd break;
266 1.1 cgd
267 1.1 cgd /*
268 1.1 cgd * Abort the TCP.
269 1.1 cgd */
270 1.1 cgd case PRU_ABORT:
271 1.1 cgd tp = tcp_drop(tp, ECONNABORTED);
272 1.1 cgd break;
273 1.1 cgd
274 1.1 cgd case PRU_SENSE:
275 1.1 cgd ((struct stat *) m)->st_blksize = so->so_snd.sb_hiwat;
276 1.1 cgd (void) splx(s);
277 1.1 cgd return (0);
278 1.1 cgd
279 1.1 cgd case PRU_RCVOOB:
280 1.1 cgd if ((so->so_oobmark == 0 &&
281 1.1 cgd (so->so_state & SS_RCVATMARK) == 0) ||
282 1.1 cgd so->so_options & SO_OOBINLINE ||
283 1.1 cgd tp->t_oobflags & TCPOOB_HADDATA) {
284 1.1 cgd error = EINVAL;
285 1.1 cgd break;
286 1.1 cgd }
287 1.1 cgd if ((tp->t_oobflags & TCPOOB_HAVEDATA) == 0) {
288 1.1 cgd error = EWOULDBLOCK;
289 1.1 cgd break;
290 1.1 cgd }
291 1.1 cgd m->m_len = 1;
292 1.1 cgd *mtod(m, caddr_t) = tp->t_iobc;
293 1.14 cgd if (((long)nam & MSG_PEEK) == 0)
294 1.1 cgd tp->t_oobflags ^= (TCPOOB_HAVEDATA | TCPOOB_HADDATA);
295 1.1 cgd break;
296 1.1 cgd
297 1.1 cgd case PRU_SENDOOB:
298 1.1 cgd if (sbspace(&so->so_snd) < -512) {
299 1.1 cgd m_freem(m);
300 1.1 cgd error = ENOBUFS;
301 1.1 cgd break;
302 1.1 cgd }
303 1.1 cgd /*
304 1.1 cgd * According to RFC961 (Assigned Protocols),
305 1.1 cgd * the urgent pointer points to the last octet
306 1.1 cgd * of urgent data. We continue, however,
307 1.1 cgd * to consider it to indicate the first octet
308 1.1 cgd * of data past the urgent section.
309 1.1 cgd * Otherwise, snd_up should be one lower.
310 1.1 cgd */
311 1.1 cgd sbappend(&so->so_snd, m);
312 1.1 cgd tp->snd_up = tp->snd_una + so->so_snd.sb_cc;
313 1.1 cgd tp->t_force = 1;
314 1.1 cgd error = tcp_output(tp);
315 1.1 cgd tp->t_force = 0;
316 1.1 cgd break;
317 1.1 cgd
318 1.1 cgd case PRU_SOCKADDR:
319 1.1 cgd in_setsockaddr(inp, nam);
320 1.1 cgd break;
321 1.1 cgd
322 1.1 cgd case PRU_PEERADDR:
323 1.1 cgd in_setpeeraddr(inp, nam);
324 1.1 cgd break;
325 1.1 cgd
326 1.1 cgd /*
327 1.1 cgd * TCP slow timer went off; going through this
328 1.1 cgd * routine for tracing's sake.
329 1.1 cgd */
330 1.1 cgd case PRU_SLOWTIMO:
331 1.14 cgd tp = tcp_timers(tp, (long)nam);
332 1.14 cgd req |= (long)nam << 8; /* for debug's sake */
333 1.1 cgd break;
334 1.1 cgd
335 1.1 cgd default:
336 1.1 cgd panic("tcp_usrreq");
337 1.1 cgd }
338 1.1 cgd if (tp && (so->so_options & SO_DEBUG))
339 1.1 cgd tcp_trace(TA_USER, ostate, tp, (struct tcpiphdr *)0, req);
340 1.1 cgd splx(s);
341 1.1 cgd return (error);
342 1.1 cgd }
343 1.1 cgd
344 1.6 mycroft int
345 1.1 cgd tcp_ctloutput(op, so, level, optname, mp)
346 1.1 cgd int op;
347 1.1 cgd struct socket *so;
348 1.1 cgd int level, optname;
349 1.1 cgd struct mbuf **mp;
350 1.1 cgd {
351 1.9 mycroft int error = 0, s;
352 1.9 mycroft struct inpcb *inp;
353 1.9 mycroft register struct tcpcb *tp;
354 1.1 cgd register struct mbuf *m;
355 1.9 mycroft register int i;
356 1.1 cgd
357 1.16 mycroft s = splsoftnet();
358 1.9 mycroft inp = sotoinpcb(so);
359 1.9 mycroft if (inp == NULL) {
360 1.9 mycroft splx(s);
361 1.9 mycroft if (op == PRCO_SETOPT && *mp)
362 1.9 mycroft (void) m_free(*mp);
363 1.9 mycroft return (ECONNRESET);
364 1.9 mycroft }
365 1.9 mycroft if (level != IPPROTO_TCP) {
366 1.9 mycroft error = ip_ctloutput(op, so, level, optname, mp);
367 1.9 mycroft splx(s);
368 1.9 mycroft return (error);
369 1.9 mycroft }
370 1.9 mycroft tp = intotcpcb(inp);
371 1.1 cgd
372 1.1 cgd switch (op) {
373 1.1 cgd
374 1.1 cgd case PRCO_SETOPT:
375 1.1 cgd m = *mp;
376 1.1 cgd switch (optname) {
377 1.1 cgd
378 1.1 cgd case TCP_NODELAY:
379 1.1 cgd if (m == NULL || m->m_len < sizeof (int))
380 1.1 cgd error = EINVAL;
381 1.1 cgd else if (*mtod(m, int *))
382 1.1 cgd tp->t_flags |= TF_NODELAY;
383 1.1 cgd else
384 1.1 cgd tp->t_flags &= ~TF_NODELAY;
385 1.1 cgd break;
386 1.1 cgd
387 1.9 mycroft case TCP_MAXSEG:
388 1.9 mycroft if (m && (i = *mtod(m, int *)) > 0 && i <= tp->t_maxseg)
389 1.9 mycroft tp->t_maxseg = i;
390 1.9 mycroft else
391 1.9 mycroft error = EINVAL;
392 1.9 mycroft break;
393 1.9 mycroft
394 1.1 cgd default:
395 1.9 mycroft error = ENOPROTOOPT;
396 1.1 cgd break;
397 1.1 cgd }
398 1.1 cgd if (m)
399 1.1 cgd (void) m_free(m);
400 1.1 cgd break;
401 1.1 cgd
402 1.1 cgd case PRCO_GETOPT:
403 1.1 cgd *mp = m = m_get(M_WAIT, MT_SOOPTS);
404 1.1 cgd m->m_len = sizeof(int);
405 1.1 cgd
406 1.1 cgd switch (optname) {
407 1.1 cgd case TCP_NODELAY:
408 1.1 cgd *mtod(m, int *) = tp->t_flags & TF_NODELAY;
409 1.1 cgd break;
410 1.1 cgd case TCP_MAXSEG:
411 1.1 cgd *mtod(m, int *) = tp->t_maxseg;
412 1.1 cgd break;
413 1.1 cgd default:
414 1.9 mycroft error = ENOPROTOOPT;
415 1.1 cgd break;
416 1.1 cgd }
417 1.1 cgd break;
418 1.1 cgd }
419 1.9 mycroft splx(s);
420 1.1 cgd return (error);
421 1.1 cgd }
422 1.1 cgd
423 1.11 mycroft #ifndef TCP_SENDSPACE
424 1.11 mycroft #define TCP_SENDSPACE 1024*16;
425 1.11 mycroft #endif
426 1.11 mycroft u_long tcp_sendspace = TCP_SENDSPACE;
427 1.11 mycroft #ifndef TCP_RECVSPACE
428 1.11 mycroft #define TCP_RECVSPACE 1024*16;
429 1.11 mycroft #endif
430 1.11 mycroft u_long tcp_recvspace = TCP_RECVSPACE;
431 1.1 cgd
432 1.1 cgd /*
433 1.1 cgd * Attach TCP protocol to socket, allocating
434 1.1 cgd * internet protocol control block, tcp control block,
435 1.1 cgd * bufer space, and entering LISTEN state if to accept connections.
436 1.1 cgd */
437 1.6 mycroft int
438 1.1 cgd tcp_attach(so)
439 1.1 cgd struct socket *so;
440 1.1 cgd {
441 1.1 cgd register struct tcpcb *tp;
442 1.1 cgd struct inpcb *inp;
443 1.1 cgd int error;
444 1.1 cgd
445 1.1 cgd if (so->so_snd.sb_hiwat == 0 || so->so_rcv.sb_hiwat == 0) {
446 1.1 cgd error = soreserve(so, tcp_sendspace, tcp_recvspace);
447 1.1 cgd if (error)
448 1.1 cgd return (error);
449 1.1 cgd }
450 1.15 mycroft error = in_pcballoc(so, &tcbtable);
451 1.1 cgd if (error)
452 1.1 cgd return (error);
453 1.1 cgd inp = sotoinpcb(so);
454 1.1 cgd tp = tcp_newtcpcb(inp);
455 1.1 cgd if (tp == 0) {
456 1.1 cgd int nofd = so->so_state & SS_NOFDREF; /* XXX */
457 1.1 cgd
458 1.1 cgd so->so_state &= ~SS_NOFDREF; /* don't free the socket yet */
459 1.1 cgd in_pcbdetach(inp);
460 1.1 cgd so->so_state |= nofd;
461 1.1 cgd return (ENOBUFS);
462 1.1 cgd }
463 1.1 cgd tp->t_state = TCPS_CLOSED;
464 1.1 cgd return (0);
465 1.1 cgd }
466 1.1 cgd
467 1.1 cgd /*
468 1.1 cgd * Initiate (or continue) disconnect.
469 1.1 cgd * If embryonic state, just send reset (once).
470 1.1 cgd * If in ``let data drain'' option and linger null, just drop.
471 1.1 cgd * Otherwise (hard), mark socket disconnecting and drop
472 1.1 cgd * current input data; switch states based on user close, and
473 1.1 cgd * send segment to peer (with FIN).
474 1.1 cgd */
475 1.1 cgd struct tcpcb *
476 1.1 cgd tcp_disconnect(tp)
477 1.1 cgd register struct tcpcb *tp;
478 1.1 cgd {
479 1.1 cgd struct socket *so = tp->t_inpcb->inp_socket;
480 1.1 cgd
481 1.12 mycroft if (TCPS_HAVEESTABLISHED(tp->t_state) == 0)
482 1.1 cgd tp = tcp_close(tp);
483 1.1 cgd else if ((so->so_options & SO_LINGER) && so->so_linger == 0)
484 1.1 cgd tp = tcp_drop(tp, 0);
485 1.1 cgd else {
486 1.1 cgd soisdisconnecting(so);
487 1.1 cgd sbflush(&so->so_rcv);
488 1.1 cgd tp = tcp_usrclosed(tp);
489 1.1 cgd if (tp)
490 1.1 cgd (void) tcp_output(tp);
491 1.1 cgd }
492 1.1 cgd return (tp);
493 1.1 cgd }
494 1.1 cgd
495 1.1 cgd /*
496 1.1 cgd * User issued close, and wish to trail through shutdown states:
497 1.1 cgd * if never received SYN, just forget it. If got a SYN from peer,
498 1.1 cgd * but haven't sent FIN, then go to FIN_WAIT_1 state to send peer a FIN.
499 1.1 cgd * If already got a FIN from peer, then almost done; go to LAST_ACK
500 1.1 cgd * state. In all other cases, have already sent FIN to peer (e.g.
501 1.1 cgd * after PRU_SHUTDOWN), and just have to play tedious game waiting
502 1.1 cgd * for peer to send FIN or not respond to keep-alives, etc.
503 1.1 cgd * We can let the user exit from the close as soon as the FIN is acked.
504 1.1 cgd */
505 1.1 cgd struct tcpcb *
506 1.1 cgd tcp_usrclosed(tp)
507 1.1 cgd register struct tcpcb *tp;
508 1.1 cgd {
509 1.1 cgd
510 1.1 cgd switch (tp->t_state) {
511 1.1 cgd
512 1.1 cgd case TCPS_CLOSED:
513 1.1 cgd case TCPS_LISTEN:
514 1.1 cgd case TCPS_SYN_SENT:
515 1.1 cgd tp->t_state = TCPS_CLOSED;
516 1.1 cgd tp = tcp_close(tp);
517 1.1 cgd break;
518 1.1 cgd
519 1.1 cgd case TCPS_SYN_RECEIVED:
520 1.1 cgd case TCPS_ESTABLISHED:
521 1.1 cgd tp->t_state = TCPS_FIN_WAIT_1;
522 1.1 cgd break;
523 1.1 cgd
524 1.1 cgd case TCPS_CLOSE_WAIT:
525 1.1 cgd tp->t_state = TCPS_LAST_ACK;
526 1.1 cgd break;
527 1.1 cgd }
528 1.18 mycroft if (tp && tp->t_state >= TCPS_FIN_WAIT_2) {
529 1.1 cgd soisdisconnected(tp->t_inpcb->inp_socket);
530 1.19 mycroft /*
531 1.19 mycroft * If we are in FIN_WAIT_2, we arrived here because the
532 1.19 mycroft * application did a shutdown of the send side. Like the
533 1.19 mycroft * case of a transition from FIN_WAIT_1 to FIN_WAIT_2 after
534 1.19 mycroft * a full close, we start a timer to make sure sockets are
535 1.19 mycroft * not left in FIN_WAIT_2 forever.
536 1.19 mycroft */
537 1.18 mycroft if (tp->t_state == TCPS_FIN_WAIT_2)
538 1.18 mycroft tp->t_timer[TCPT_2MSL] = tcp_maxidle;
539 1.18 mycroft }
540 1.1 cgd return (tp);
541 1.17 thorpej }
542 1.17 thorpej
543 1.17 thorpej /*
544 1.17 thorpej * Sysctl for tcp variables.
545 1.17 thorpej */
546 1.17 thorpej int
547 1.17 thorpej tcp_sysctl(name, namelen, oldp, oldlenp, newp, newlen)
548 1.17 thorpej int *name;
549 1.17 thorpej u_int namelen;
550 1.17 thorpej void *oldp;
551 1.17 thorpej size_t *oldlenp;
552 1.17 thorpej void *newp;
553 1.17 thorpej size_t newlen;
554 1.17 thorpej {
555 1.17 thorpej
556 1.17 thorpej /* All sysctl names at this level are terminal. */
557 1.17 thorpej if (namelen != 1)
558 1.17 thorpej return (ENOTDIR);
559 1.17 thorpej
560 1.17 thorpej switch (name[0]) {
561 1.17 thorpej case TCPCTL_RFC1323:
562 1.17 thorpej return (sysctl_int(oldp, oldlenp, newp, newlen,
563 1.17 thorpej &tcp_do_rfc1323));
564 1.17 thorpej
565 1.17 thorpej default:
566 1.17 thorpej return (ENOPROTOOPT);
567 1.17 thorpej }
568 1.17 thorpej /* NOTREACHED */
569 1.1 cgd }
570