bsd/nfs/nfs_socket.c

1559 			if (!rq->r_error && !rq->r_nmrep.nmc_mhead && !(rq->r_flags & R_MUSTRESEND)) {
1560 				rq->r_flags |= R_MUSTRESEND;
1563 				if ((rq->r_flags & (R_ASYNC|R_ASYNCWAIT|R_SENDING)) == R_ASYNC)
1630 			if (!rq->r_error && !rq->r_nmrep.nmc_mhead && !(rq->r_flags & R_MUSTRESEND)) {
1631 				rq->r_flags |= R_MUSTRESEND;
1634 				if ((rq->r_flags & (R_ASYNC|R_ASYNCWAIT|R_SENDING)) == R_ASYNC)
1712 				dofinish = req->r_callback.rcb_func && !(req->r_flags & R_WAITSENT);
1713 				req->r_flags &= ~R_RESENDQ;
1721 			if ((req->r_flags & R_RESTART) || nfs_request_using_gss(req)) {
1722 				req->r_flags &= ~R_RESTART;
1735 					req->r_flags, req->r_rtt));
1744 				if (req->r_flags & R_RESENDQ)
1745 					req->r_flags &= ~R_RESENDQ;
1749 				dofinish = error && req->r_callback.rcb_func && !(req->r_flags & R_WAITSENT);
1758 				req->r_procnum, req->r_xid, req->r_flags, req->r_rtt));
1763 				req->r_flags |= R_SENDING;
1768 					if (req->r_flags & R_RESENDQ)
1769 						req->r_flags &= ~R_RESENDQ;
1777 			if (req->r_flags & R_RESENDQ)
1778 				req->r_flags &= ~R_RESENDQ;
1780 			dofinish = req->r_callback.rcb_func && !(req->r_flags & R_WAITSENT);
2786 		req->r_flags &= ~R_SENDING;
2796 		req->r_flags &= ~R_SENDING;
2807 	if (((req->r_flags & R_SETUP) && !(nmp->nm_sockflags & NMSOCK_SETUP)) ||
2808 	    ((req->r_flags & R_RECOVER) && !(nmp->nm_sockflags & NMSOCK_READY))) {
2813 		req->r_flags &= ~R_SENDING;
2822 	    !((nmp->nm_sockflags & NMSOCK_SETUP) && (req->r_flags & R_SETUP))) {
2823 		if (NMFLAG(nmp, INTR) && !(req->r_flags & R_NOINTR))
2829 			req->r_flags &= ~R_SENDING;
2830 			req->r_flags |= R_MUSTRESEND;
2837 		req->r_flags &= ~R_MUSTRESEND;
2853 					req->r_flags |= R_SOFTTERM;
2869 			req->r_flags &= ~R_SENDING;
2882 		req->r_flags &= ~R_SENDING;
2883 		req->r_flags |= R_MUSTRESEND;
2890 	rexmit = (req->r_flags & R_SENT);
2894 		if (!(req->r_flags & R_CWND) && (nmp->nm_sent >= nmp->nm_cwnd)) {
2899 			req->r_flags &= ~R_SENDING;
2900 			req->r_flags |= R_MUSTRESEND;
2927 			req->r_flags |= R_CWND;
2934 			req->r_flags &= ~R_TIMING;
2942 	req->r_flags &= ~R_MUSTRESEND;
2952 		req->r_flags &= ~R_SENDING;
2953 		req->r_flags |= R_MUSTRESEND;
2975 	req->r_flags &= ~R_SENDING;
2982 		req->r_flags &= ~R_RESENDERR;
2985 		req->r_flags |= R_SENT;
2986 		if (req->r_flags & R_WAITSENT) {
2987 			req->r_flags &= ~R_WAITSENT;
2996 	req->r_flags |= R_MUSTRESEND;
2998 		req->r_flags |= R_RESENDERR;
3272 			if (req->r_flags & R_CWND) {
3274 				req->r_flags &= ~R_CWND;
3288 		if (req->r_flags & R_TIMING) {
3340 	if (req->r_nmp && NMFLAG(req->r_nmp, INTR) && req->r_thread && !(req->r_flags & R_NOINTR))
3352 		if (req->r_flags & R_MUSTRESEND) {
3354 				req->r_procnum, req->r_xid, req->r_flags, req->r_rtt));
3355 			req->r_flags |= R_SENDING;
3365 				req->r_flags &= ~R_SENDING;
3372 				req->r_procnum, req->r_xid, req->r_flags, req->r_rtt, error));
3441 		req->r_flags = R_ALLOCATED;
3470 		req->r_flags |= R_NOINTR;
3477 		req->r_flags |= R_TIMING;
3498 	req->r_flags |= R_INITTED;
3516 	if (!req || !(req->r_flags & R_INITTED))
3518 	req->r_flags &= ~R_INITTED;
3533 		if (req->r_flags & R_CWND) {
3535 			req->r_flags &= ~R_CWND;
3548 			if (req->r_flags & R_RESENDQ)
3549 				req->r_flags &= ~R_RESENDQ;
3555 		if (req->r_flags & R_JBTPRINTFMSG) {
3556 			req->r_flags &= ~R_JBTPRINTFMSG;
3562 	while (req->r_flags & R_RESENDQ)
3585 	if (req->r_flags & R_ALLOCATED)
3667 	req->r_flags |= R_SENDING;
3748 	if ((req->r_flags & R_CWND) && nmp) {
3752 		req->r_flags &= ~R_CWND;
3785 			req->r_flags |= R_RESTART;
3800 		if ((req->r_flags & R_TPRINTFMSG) ||
3847 			req->r_flags |= R_RESTART;
3895 			int delay, slpflag = (NMFLAG(nmp, INTR) && !(req->r_flags & R_NOINTR)) ? PCATCH : 0;
3911 				if (!(req->r_flags & R_JBTPRINTFMSG)) {
3912 					req->r_flags |= R_JBTPRINTFMSG;
3920 			if (NMFLAG(nmp, SOFT) && (req->r_delay == 30) && !(req->r_flags & R_NOINTR)) {
3941 			req->r_flags |= R_RESTART;
3947 		if (req->r_flags & R_JBTPRINTFMSG) {
3948 			req->r_flags &= ~R_JBTPRINTFMSG;
4032 			req->r_flags |= R_RESTART;
4091 	if (req->r_flags & R_JBTPRINTFMSG) {
4092 		req->r_flags &= ~R_JBTPRINTFMSG;
4162 	req->r_flags |= (flags & R_OPTMASK);
4169 		req->r_flags &= ~R_RESTART;
4179 	} while (req->r_flags & R_RESTART);
4209 	req->r_flags |= (flags & R_OPTMASK);
4221 		req->r_flags &= ~R_RESTART;
4230 	} while (req->r_flags & R_RESTART);
4262 	req->r_flags |= (flags & R_OPTMASK);
4263 	req->r_flags |= R_ASYNC;
4270 		req->r_flags |= R_WAITSENT;
4275 		if (!error && !(req->r_flags & R_SENT) && req->r_callback.rcb_func) {
4277 			int slpflag = (req->r_nmp && NMFLAG(req->r_nmp, INTR) && req->r_thread && !(req->r_flags & R_NOINTR)) ? PCATCH : 0;
4279 			while (!(req->r_flags & R_SENT)) {
4280 				if ((req->r_flags & R_RESENDQ) && ((nmp = req->r_nmp))) {
4290 						if (req->r_flags & R_RESENDQ)
4291 							req->r_flags &= ~R_RESENDQ;
4293 						req->r_flags |= R_SENDING;
4309 		sent = req->r_flags & R_SENT;
4335 		req->r_flags |= R_ASYNCWAIT;
4336 	while (req->r_flags & R_RESENDQ) {  /* wait until the request is off the resend queue */
4348 				if (req->r_flags & R_RESENDQ)
4349 					req->r_flags &= ~R_RESENDQ;
4366 	while (!error && (req->r_flags & R_RESTART)) {
4374 		req->r_flags &= ~R_RESTART;
4411 	req->r_flags |= R_SOFTTERM;
4413 	if (!(req->r_flags & R_CWND) || !nmp)
4416 	req->r_flags &= ~R_CWND;
4528 				finish_asyncio = !(req->r_flags & R_WAITSENT);
4540 		    ((req->r_rexmit > 2) || (req->r_flags & R_RESENDERR)) &&
4545 			req->r_flags |= R_TPRINTFMSG;
4553 				finish_asyncio = ((req->r_callback.rcb_func != NULL) && !(req->r_flags & R_WAITSENT));
4569 		else if ((req->r_flags & (R_SETUP|R_RECOVER)) ||
4581 			if (req->r_flags & R_RESENDERR) {
4626 		if ((NMFLAG(nmp, SOFT) ||  (req->r_flags & (R_SETUP|R_RECOVER))) &&
4638 				req->r_flags |= R_TPRINTFMSG;
4642 			if (req->r_flags & R_NOINTR) {
4648 				req->r_procnum, req->r_xid, req->r_flags, req->r_rtt,
4651 			finish_asyncio = ((req->r_callback.rcb_func != NULL) && !(req->r_flags & R_WAITSENT));
4660 		if ((nmp->nm_sotype == SOCK_STREAM) && !(req->r_flags & R_MUSTRESEND)) {
4672 		if ((req->r_flags & R_MUSTRESEND) && (req->r_rtt == -1)) {
4677 			req->r_procnum, req->r_xid, req->r_flags, req->r_rtt));
4678 		req->r_flags |= R_MUSTRESEND;
4681 		if ((req->r_flags & (R_ASYNC|R_ASYNCWAIT|R_SENDING)) == R_ASYNC)
4729 	if (req && (req->r_flags & R_SOFTTERM))
4731 	if (req && (req->r_flags & R_NOINTR))
4804 	if (NMFLAG(nmp, INTR) && req->r_thread && !(req->r_flags & R_NOINTR))