bsd/nfs/nfs_socket.c

19  * distributed on an 'AS IS' basis, WITHOUT WARRANTY OF ANY KIND, EITHER
118 int nfsrv_sock_max_rec_queue_length = 128; /* max # RPC records queued on (UDP) socket */
209  * describes for TCP. The cwnd size is chopped in half on a retransmit timeout
234 		/* no more addresses on current server, go to first address of next server */
239 			/* no more servers on current location, go to first server of next location */
293 		/* mounting root export on server */
578  * Set common socket options on an nfs_socket.
591 	int on = 1, proto;
599 		sock_setsockopt(nso->nso_so, SOL_SOCKET, SO_KEEPALIVE, &on, sizeof(on));
603 			sock_setsockopt(nso->nso_so, IPPROTO_TCP, TCP_NODELAY, &on, sizeof(on));
611 	sock_setsockopt(nso->nso_so, SOL_SOCKET, SO_NOADDRERR, &on, sizeof(on));
613 	sock_setsockopt(nso->nso_so, SOL_SOCKET, SO_UPCALLCLOSEWAIT, &on, sizeof(on));
772  * Assumes:				nso->nso_lock is held on entry and return.
813 			if (error) { /* we got an error on the socket */
830  * nfs_connect_search_ping:	Send a null proc on the nso socket.
938  * nfs_connect_search_check:	Check on the status of search and wait for replies if needed.
985 	/* check each active socket on the list and try to push it along */
1385 			/* Make sure we can agree on a security flavor. */
1468 			/* If we negotiated NFSv4, set nm_nfsport if we ended up on the standard NFS port */
1606  * - set R_MUSTRESEND for all outstanding requests on mount point
1857 				/* async RPCs on GSS mounts need to be rebuilt and resent. */
2029  * a list of connected sockets to handle callback requests on.
2031  * put on a list so that the callback request handling code can match
2059 	int error, on = 1;
2087 	sock_setsockopt(so, SOL_SOCKET, SO_REUSEADDR, &on, sizeof(on));
2106 		log(LOG_INFO, "nfs callback setup: error %d on IPv4 listen\n", error);
2110 	/* receive timeout shouldn't matter.  If timeout on send, we'll want to drop the socket */
2119 	sock_setsockopt(so, IPPROTO_TCP, TCP_NODELAY, &on, sizeof(on));
2120 	sock_setsockopt(so, SOL_SOCKET, SO_NOADDRERR, &on, sizeof(on));
2121 	sock_setsockopt(so, SOL_SOCKET, SO_UPCALLCLOSEWAIT, &on, sizeof(on));
2132 	sock_setsockopt(so6, SOL_SOCKET, SO_REUSEADDR, &on, sizeof(on));
2133 	sock_setsockopt(so6, IPPROTO_IPV6, IPV6_V6ONLY, &on, sizeof(on));
2160 		log(LOG_INFO, "nfs callback setup: error %d on IPv6 listen\n", error);
2164 	/* receive timeout shouldn't matter.  If timeout on send, we'll want to drop the socket */
2173 	sock_setsockopt(so6, IPPROTO_TCP, TCP_NODELAY, &on, sizeof(on));
2174 	sock_setsockopt(so6, SOL_SOCKET, SO_NOADDRERR, &on, sizeof(on));
2175 	sock_setsockopt(so6, SOL_SOCKET, SO_UPCALLCLOSEWAIT, &on, sizeof(on));
2199  * reference on the callback socket.  Last reference dropped
2290 	int error, on = 1, ip;
2320 	/* receive timeout shouldn't matter.  If timeout on send, we'll want to drop the socket */
2329 	sock_setsockopt(newso, IPPROTO_TCP, TCP_NODELAY, &on, sizeof(on));
2330 	sock_setsockopt(newso, SOL_SOCKET, SO_REUSEADDR, &on, sizeof(on));
2331 	sock_setsockopt(newso, SOL_SOCKET, SO_NOADDRERR, &on, sizeof(on));
2332 	sock_setsockopt(newso, SOL_SOCKET, SO_UPCALLCLOSEWAIT, &on, sizeof(on));
2664 		/* drop the callback reference on the mount */
2827 			log(LOG_ERR, "impossible RPC record length (%d) on callback", nrrsp->nrrs_reclen);
3027 			/* if we can't send this out yet, wait on the cwnd queue */
3160 		/* if send timed out, reconnect if on TCP */
3188 	 * EADDRNOTAVAIL may occur on network transitions.
3240 		/* make sure we're on the current socket */
3272 	/* make sure we're on the current socket */
3417 		 * Update rtt using a gain of 0.125 on the mean
3418 		 * and a gain of 0.25 on the deviation.
3441 		/* signal anyone waiting on this request */
3654 		/* still on an async I/O queue? */
3908 		 * request based on a new sequence number.
4625  * Mark expired requests on soft mounts as terminated.
4696 		 * Put a reasonable limit on the maximum timeout,
4775 				/* don't terminate nointr requests on timeout */
4844  * Test for a termination condition pending on the process.
4845  * This is used to determine if we need to bail on a mount.
4864 		thd = NULL; /* don't check for signal on R_NOINTR */
4883 	 * on remote filesystems, then bail now.
4995 	int error = 0, on = 1, try, sendat = 2, soproto, recv, optlen, restoreto = 0;
5035 			on = 4; /* don't wait too long for the socket to connect */
5036 			sock_setsockopt(newso, IPPROTO_TCP, TCP_CONNECTIONTIMEOUT, &on, sizeof(on));
5042 		    ((error = sock_setsockopt(newso, SOL_SOCKET, SO_NOADDRERR, &on, sizeof(on)))))
5291 #define	NFS_SQUISH_MOBILE_ONLY		0x0001		/* Squish mounts only on mobile machines */
5293 #define NFS_SQUISH_SOFT			0x0004		/* Treat all soft mounts as though they were on a mobile machine */
5295 #define NFS_SQUISH_SHUTDOWN		0x1000		/* Squish all mounts on shutdown. Currently not implemented */
5322  * NFS mounts default to "rw,hard" - but frequently on mobile clients
5344  * Note this routine is racey, but its effects on setting the
5347  * volumes on mobile machines; this is a reasonable trade off between
5676 		error = EPIPE;  /* zap TCP sockets if they time out on send */
5729 		 * If there are already records on the queue, defer soreceive()
5777 			/* already have max # RPC records queued on this socket */
5834  * Try and extract an RPC request from the mbuf data list received on a
6194 	/* if there's work to do on this socket, make sure it's queued up */