bsd/nfs/nfs_socket.c

2073 	struct nfs_callback_socket *ncbsp;
2102 	while ((ncbsp = TAILQ_FIRST(&cb_socks))) {
2103 		TAILQ_REMOVE(&cb_socks, ncbsp, ncbs_link);
2104 		sock_shutdown(ncbsp->ncbs_so, SHUT_RDWR);
2105 		sock_close(ncbsp->ncbs_so);
2106 		nfs_rpc_record_state_cleanup(&ncbsp->ncbs_rrs);
2107 		FREE(ncbsp, M_TEMP);
2119 	struct nfs_callback_socket *ncbsp, *nextncbsp;
2130 	TAILQ_FOREACH_SAFE(ncbsp, &nfs4_cb_socks, ncbs_link, nextncbsp) {
2131 		if (!(ncbsp->ncbs_flags & NCBSOCK_DEAD) &&
2132 		     (now.tv_sec < (ncbsp->ncbs_stamp + NFS4_CB_IDLE_MAX)))
2134 		TAILQ_REMOVE(&nfs4_cb_socks, ncbsp, ncbs_link);
2136 		sock_shutdown(ncbsp->ncbs_so, SHUT_RDWR);
2137 		sock_close(ncbsp->ncbs_so);
2138 		nfs_rpc_record_state_cleanup(&ncbsp->ncbs_rrs);
2139 		FREE(ncbsp, M_TEMP);
2155 	struct nfs_callback_socket *ncbsp;
2168 	MALLOC(ncbsp, struct nfs_callback_socket *, sizeof(struct nfs_callback_socket), M_TEMP, M_WAITOK);
2169 	if (!ncbsp) {
2173 	bzero(ncbsp, sizeof(*ncbsp));
2174 	ncbsp->ncbs_saddr.ss_len = (ip == 4) ? sizeof(struct sockaddr_in) : sizeof(struct sockaddr_in6);
2175 	nfs_rpc_record_state_init(&ncbsp->ncbs_rrs);
2178 	error = sock_accept(so, (struct sockaddr*)&ncbsp->ncbs_saddr,
2179 			ncbsp->ncbs_saddr.ss_len, MSG_DONTWAIT,
2180 			nfs4_cb_rcv, ncbsp, &newso);
2183 		FREE(ncbsp, M_TEMP);
2202 	ncbsp->ncbs_so = newso;
2204 	ncbsp->ncbs_stamp = now.tv_sec;
2209 	TAILQ_INSERT_HEAD(&nfs4_cb_socks, ncbsp, ncbs_link);
2216 		if (nfs_sockaddr_cmp((struct sockaddr*)&ncbsp->ncbs_saddr, nmp->nm_saddr) == 0)
2220 		ncbsp->ncbs_flags |= NCBSOCK_DEAD;
2244 	struct nfs_callback_socket *ncbsp = arg;
2251 	while (ncbsp->ncbs_flags & NCBSOCK_UPCALL) {
2253 		ncbsp->ncbs_flags |= NCBSOCK_UPCALLWANT;
2254 		msleep(ncbsp, nfs_global_mutex, PSOCK, "cbupcall", &ts);
2256 	ncbsp->ncbs_flags |= NCBSOCK_UPCALL;
2261 		error = nfs_rpc_record_read(so, &ncbsp->ncbs_rrs, MSG_DONTWAIT, &recv, &m);
2263 			error = nfs4_cb_handler(ncbsp, m);
2273 		ncbsp->ncbs_stamp = 0;
2274 		ncbsp->ncbs_flags |= NCBSOCK_DEAD;
2277 		ncbsp->ncbs_stamp = now.tv_sec;
2281 	ncbsp->ncbs_flags &= ~NCBSOCK_UPCALL;
2283 	wakeup(ncbsp);
2290 nfs4_cb_handler(struct nfs_callback_socket *ncbsp, mbuf_t mreq)
2292 	socket_t so = ncbsp->ncbs_so;
2388 			if (nfs_sockaddr_cmp((struct sockaddr*)&ncbsp->ncbs_saddr, nmp->nm_saddr) == 0)