bsd/nfs/nfs_bio.c

1545 	struct nfsreq *req;
1596 		req = NULL;
1597 		error = nmp->nm_funcs->nf_read_rpc_async(np, boff + offset, len, thd, cred, &cb, &req);
1604 		nfs_buf_read_rpc_finish(req);
1645 nfs_buf_read_rpc_finish(struct nfsreq *req)
1661 	np = req->r_np;
1662 	thd = req->r_thread;
1663 	cred = req->r_cred;
1666 	cb = req->r_callback;
1669 		nfs_request_ref(req, 0);
1678 		nfs_request_async_cancel(req);
1691 	error = nmp->nm_funcs->nf_read_rpc_async_finish(np, req, auio, &rlen, &eof);
1695 			nfs_request_rele(req);
1718 					if (req->r_nmrep.nmc_mhead) {
1719 						mbuf_freem(req->r_nmrep.nmc_mhead);
1720 						req->r_nmrep.nmc_mhead = NULL;
1722 					req->r_error = 0;
1724 					lck_mtx_lock(&req->r_mtx);
1725 					req->r_resendtime = now.tv_sec + 2;
1726 					req->r_xid = 0;                 // get a new XID
1727 					req->r_flags |= R_RESTART;
1728 					req->r_start = 0;
1729 					nfs_asyncio_resend(req);
1730 					lck_mtx_unlock(&req->r_mtx);
1783 				req = rreq;
1787 			nfs_request_rele(req);
1801 		nfs_request_rele(req);
2693 	struct nfsreq *req;
2747 		req = NULL;
2749 				iomode, &cb, &req);
2759 		nfs_buf_write_rpc_finish(req);
2799 nfs_buf_write_rpc_finish(struct nfsreq *req)
2817 	np = req->r_np;
2818 	thd = req->r_thread;
2819 	cred = req->r_cred;
2822 	cb = req->r_callback;
2825 		nfs_request_ref(req, 0);
2834 		nfs_request_async_cancel(req);
2843 	error = nmp->nm_funcs->nf_write_rpc_async_finish(np, req, &committed, &rlen, &wverf);
2847 			nfs_request_rele(req);
2870 					if (req->r_nmrep.nmc_mhead) {
2871 						mbuf_freem(req->r_nmrep.nmc_mhead);
2872 						req->r_nmrep.nmc_mhead = NULL;
2874 					req->r_error = 0;
2876 					lck_mtx_lock(&req->r_mtx);
2877 					req->r_resendtime = now.tv_sec + 2;
2878 					req->r_xid = 0;                 // get a new XID
2879 					req->r_flags |= R_RESTART;
2880 					req->r_start = 0;
2881 					nfs_asyncio_resend(req);
2882 					lck_mtx_unlock(&req->r_mtx);
2952 				req = wreq;
2956 			nfs_request_rele(req);
2971 		nfs_request_rele(req);
3742 nfs_asyncio_finish(struct nfsreq *req)
3750 	if (((nmp = req->r_nmp)) == NULL)
3776 	if (req->r_achain.tqe_next == NFSREQNOLIST)
3777 		TAILQ_INSERT_TAIL(&nmp->nm_iodq, req, r_achain);
3807 nfs_asyncio_resend(struct nfsreq *req)
3809 	struct nfsmount *nmp = req->r_nmp;
3813 	nfs_gss_clnt_rpcdone(req);
3815 	if (!(req->r_flags & R_RESENDQ)) {
3816 		TAILQ_INSERT_TAIL(&nmp->nm_resendq, req, r_rchain);
3817 		req->r_flags |= R_RESENDQ;