bsd/nfs/nfs_socket.c

19  * distributed on an 'AS IS' basis, WITHOUT WARRANTY OF ANY KIND, EITHER
116 int nfsrv_sock_max_rec_queue_length = 128; /* max # RPC records queued on (UDP) socket */
207  * describes for TCP. The cwnd size is chopped in half on a retransmit timeout
232 		/* no more addresses on current server, go to first address of next server */
237 			/* no more servers on current location, go to first server of next location */
291 		/* mounting root export on server */
574  * Set common socket options on an nfs_socket.
587 	int on = 1, proto;
595 		sock_setsockopt(nso->nso_so, SOL_SOCKET, SO_KEEPALIVE, &on, sizeof(on));
599 			sock_setsockopt(nso->nso_so, IPPROTO_TCP, TCP_NODELAY, &on, sizeof(on));
607 	sock_setsockopt(nso->nso_so, SOL_SOCKET, SO_NOADDRERR, &on, sizeof(on));
609 	sock_setsockopt(nso->nso_so, SOL_SOCKET, SO_UPCALLCLOSEWAIT, &on, sizeof(on));
790 					if (error) { /* we got an error on the socket */
1272 			/* Make sure we can agree on a security flavor. */
1355 			/* If we negotiated NFSv4, set nm_nfsport if we ended up on the standard NFS port */
1493  * - set R_MUSTRESEND for all outstanding requests on mount point
1725 				/* async RPCs on GSS mounts need to be rebuilt and resent. */
1897  * a list of connected sockets to handle callback requests on.
1899  * put on a list so that the callback request handling code can match
1927 	int error, on = 1;
1955 	sock_setsockopt(so, SOL_SOCKET, SO_REUSEADDR, &on, sizeof(on));
1974 		log(LOG_INFO, "nfs callback setup: error %d on IPv4 listen\n", error);
1978 	/* receive timeout shouldn't matter.  If timeout on send, we'll want to drop the socket */
1987 	sock_setsockopt(so, IPPROTO_TCP, TCP_NODELAY, &on, sizeof(on));
1988 	sock_setsockopt(so, SOL_SOCKET, SO_NOADDRERR, &on, sizeof(on));
1989 	sock_setsockopt(so, SOL_SOCKET, SO_UPCALLCLOSEWAIT, &on, sizeof(on));
2000 	sock_setsockopt(so6, SOL_SOCKET, SO_REUSEADDR, &on, sizeof(on));
2001 	sock_setsockopt(so6, IPPROTO_IPV6, IPV6_V6ONLY, &on, sizeof(on));
2028 		log(LOG_INFO, "nfs callback setup: error %d on IPv6 listen\n", error);
2032 	/* receive timeout shouldn't matter.  If timeout on send, we'll want to drop the socket */
2041 	sock_setsockopt(so6, IPPROTO_TCP, TCP_NODELAY, &on, sizeof(on));
2042 	sock_setsockopt(so6, SOL_SOCKET, SO_NOADDRERR, &on, sizeof(on));
2043 	sock_setsockopt(so6, SOL_SOCKET, SO_UPCALLCLOSEWAIT, &on, sizeof(on));
2067  * reference on the callback socket.  Last reference dropped
2158 	int error, on = 1, ip;
2188 	/* receive timeout shouldn't matter.  If timeout on send, we'll want to drop the socket */
2197 	sock_setsockopt(newso, IPPROTO_TCP, TCP_NODELAY, &on, sizeof(on));
2198 	sock_setsockopt(newso, SOL_SOCKET, SO_REUSEADDR, &on, sizeof(on));
2199 	sock_setsockopt(newso, SOL_SOCKET, SO_NOADDRERR, &on, sizeof(on));
2200 	sock_setsockopt(newso, SOL_SOCKET, SO_UPCALLCLOSEWAIT, &on, sizeof(on));
2532 		/* drop the callback reference on the mount */
2695 			log(LOG_ERR, "impossible RPC record length (%d) on callback", nrrsp->nrrs_reclen);
2895 			/* if we can't send this out yet, wait on the cwnd queue */
3028 		/* if send timed out, reconnect if on TCP */
3056 	 * EADDRNOTAVAIL may occur on network transitions.
3108 		/* make sure we're on the current socket */
3140 	/* make sure we're on the current socket */
3285 		 * Update rtt using a gain of 0.125 on the mean
3286 		 * and a gain of 0.25 on the deviation.
3309 		/* signal anyone waiting on this request */
3522 		/* still on an async I/O queue? */
3776 		 * request based on a new sequence number.
4493  * Mark expired requests on soft mounts as terminated.
4564 		 * Put a reasonable limit on the maximum timeout,
4643 				/* don't terminate nointr requests on timeout */
4712  * Test for a termination condition pending on the process.
4713  * This is used to determine if we need to bail on a mount.
4732 		thd = NULL; /* don't check for signal on R_NOINTR */
4751 	 * on remote filesystems, then bail now.
4862 	int error = 0, on = 1, try, sendat = 2, soproto, recv, optlen, restoreto = 0;
4902 			on = 4; /* don't wait too long for the socket to connect */
4903 			sock_setsockopt(newso, IPPROTO_TCP, TCP_CONNECTIONTIMEOUT, &on, sizeof(on));
4909 		    ((error = sock_setsockopt(newso, SOL_SOCKET, SO_NOADDRERR, &on, sizeof(on)))))
5158 #define	NFS_SQUISH_MOBILE_ONLY		0x0001		/* Squish mounts only on mobile machines */
5160 #define NFS_SQUISH_SOFT			0x0004		/* Treat all soft mounts as though they were on a mobile machine */
5162 #define NFS_SQUISH_SHUTDOWN		0x1000		/* Squish all mounts on shutdown. Currently not implemented */
5189  * NFS mounts default to "rw,hard" - but frequently on mobile clients
5211  * Note this routine is racey, but its effects on setting the
5214  * volumes on mobile machines; this is a reasonable trade off between
5542 		error = EPIPE;  /* zap TCP sockets if they time out on send */
5595 		 * If there are already records on the queue, defer soreceive()
5643 			/* already have max # RPC records queued on this socket */
5700  * Try and extract an RPC request from the mbuf data list received on a
6060 	/* if there's work to do on this socket, make sure it's queued up */