bsd/nfs/nfs_bio.c

345 	struct nfsmount *nmp = VTONMP(vp);
349 	if (!nmp)
353 	bp = nfs_buf_incore(VTONFS(vp), (daddr64_t)(offset / nmp->nm_biosize));
646 	struct nfsmount *nmp = VTONMP(vp);
661 	if (!nmp) {
668 	} else if (bufsize < (uint32_t)nmp->nm_biosize) {
670 		bufsize = nmp->nm_biosize;
1288 	struct nfsmount *nmp;
1293 	nmp = NFSTONMP(np);
1294 	if (!nmp)
1296 	if (!ISSET(bp->nb_flags, NB_STALEWVERF) && (bp->nb_verf == nmp->nm_verf))
1498 	struct nfsmount *nmp;
1521 		if ((nmp = NFSTONMP(np)) && (nmp->nm_vers == NFS_VER2) &&
1539 	struct nfsmount *nmp;
1548 	nmp = NFSTONMP(np);
1549 	if (!nmp) {
1555 	nfsvers = nmp->nm_vers;
1556 	nmrsize = nmp->nm_rsize;
1594 		if (nmp->nm_vers >= NFS_VER4)
1595 			cb.rcb_args[2] = nmp->nm_stategenid;
1597 		error = nmp->nm_funcs->nf_read_rpc_async(np, boff + offset, len, thd, cred, &cb, &req);
1647 	struct nfsmount *nmp;
1671 	nmp = NFSTONMP(np);
1672 	if (!nmp) {
1682 	nfsvers = nmp->nm_vers;
1691 	error = nmp->nm_funcs->nf_read_rpc_async_finish(np, req, auio, &rlen, &eof);
1700 	if ((nmp->nm_vers >= NFS_VER4) && nfs_mount_state_error_should_restart(error) && !ISSET(bp->nb_flags, NB_ERROR)) {
1701 		lck_mtx_lock(&nmp->nm_lock);
1702 		if ((error != NFSERR_OLD_STATEID) && (error != NFSERR_GRACE) && (cb.rcb_args[2] == nmp->nm_stategenid)) {
1704 				error, NBOFF(bp)+offset, cb.rcb_args[2], nmp->nm_stategenid);
1705 			nfs_need_recover(nmp, error);
1707 		lck_mtx_unlock(&nmp->nm_lock);
1737 				tsleep(&nmp->nm_state, (PZERO-1), "nfsgrace", 2*hz);
1739 			if (!(error = nfs_mount_state_wait_for_recovery(nmp))) {
1775 		if (nmp->nm_vers >= NFS_VER4)
1776 			cb.rcb_args[2] = nmp->nm_stategenid;
1777 		error = nmp->nm_funcs->nf_read_rpc_async(np, NBOFF(bp) + offset, length, thd, cred, &cb, &rreq);
1840 	struct nfsmount *nmp = NFSTONMP(np);
1845 	if (!nmp)
1847 	if (nmp->nm_readahead <= 0)
1852 	for (nra = 0; (nra < nmp->nm_readahead) && (*rabnp <= lastrabn); nra++, *rabnp = *rabnp + 1) {
1854 		if ((*rabnp * nmp->nm_biosize) >= (off_t)np->n_size) {
1859 		error = nfs_buf_get(np, *rabnp, nmp->nm_biosize, thd, NBLK_READ|NBLK_NOWAIT, &bp);
1899 	struct nfsmount *nmp = VTONMP(vp);
1910 	nfsvers = nmp->nm_vers;
1911 	biosize = nmp->nm_biosize;
1980 	if (nmp->nm_readahead > 0) {
1989 			maxrabn += nmp->nm_readahead;
2051 		lastrabn = MIN(maxrabn, lbn + nmp->nm_readahead);
2236 nfs_async_write_start(struct nfsmount *nmp)
2238 	int error = 0, slpflag = NMFLAG(nmp, INTR) ? PCATCH : 0;
2243 	lck_mtx_lock(&nmp->nm_lock);
2244 	while ((nfs_max_async_writes > 0) && (nmp->nm_asyncwrites >= nfs_max_async_writes)) {
2245 		if ((error = nfs_sigintr(nmp, NULL, current_thread(), 1)))
2247 		msleep(&nmp->nm_asyncwrites, &nmp->nm_lock, slpflag|(PZERO-1), "nfsasyncwrites", &ts);
2251 		nmp->nm_asyncwrites++;
2252 	lck_mtx_unlock(&nmp->nm_lock);
2256 nfs_async_write_done(struct nfsmount *nmp)
2258 	if (nmp->nm_asyncwrites <= 0)
2260 	lck_mtx_lock(&nmp->nm_lock);
2261 	if (nmp->nm_asyncwrites-- >= nfs_max_async_writes)
2262 		wakeup(&nmp->nm_asyncwrites);
2263 	lck_mtx_unlock(&nmp->nm_lock);
2348 		struct nfsmount *nmp = NFSTONMP(np);
2349 		if (!nmp) {
2356 		error = nmp->nm_funcs->nf_commit_rpc(np, NBOFF(bp) + bp->nb_dirtyoff,
2605 	struct nfsmount *nmp = NFSTONMP(np);
2666 		error = nmp->nm_funcs->nf_commit_rpc(np, NBOFF(bp), bp->nb_bufsize, cred, wverf);
2688 	struct nfsmount *nmp;
2698 	nmp = NFSTONMP(np);
2699 	if (!nmp) {
2705 	nfsvers = nmp->nm_vers;
2706 	nmwsize = nmp->nm_wsize;
2743 		if (nmp->nm_vers >= NFS_VER4)
2744 			cb.rcb_args[2] = nmp->nm_stategenid;
2745 		if (async && ((error = nfs_async_write_start(nmp))))
2748 		error = nmp->nm_funcs->nf_write_rpc_async(np, auio, len, thd, cred,
2752 				nfs_async_write_done(nmp);
2809 	struct nfsmount *nmp;
2827 	nmp = NFSTONMP(np);
2828 	if (!nmp) {
2837 	nfsvers = nmp->nm_vers;
2843 	error = nmp->nm_funcs->nf_write_rpc_async_finish(np, req, &committed, &rlen, &wverf);
2852 	if ((nmp->nm_vers >= NFS_VER4) && nfs_mount_state_error_should_restart(error) && !ISSET(bp->nb_flags, NB_ERROR)) {
2853 		lck_mtx_lock(&nmp->nm_lock);
2854 		if ((error != NFSERR_OLD_STATEID) && (error != NFSERR_GRACE) && (cb.rcb_args[2] == nmp->nm_stategenid)) {
2856 				error, NBOFF(bp)+offset, cb.rcb_args[2], nmp->nm_stategenid);
2857 			nfs_need_recover(nmp, error);
2859 		lck_mtx_unlock(&nmp->nm_lock);
2889 				tsleep(&nmp->nm_state, (PZERO-1), "nfsgrace", 2*hz);
2891 			if (!(error = nfs_mount_state_wait_for_recovery(nmp))) {
2941 		if (nmp->nm_vers >= NFS_VER4)
2942 			cb.rcb_args[2] = nmp->nm_stategenid;
2945 		error = nmp->nm_funcs->nf_write_rpc_async(np, auio, length, thd, cred,
2970 		nfs_async_write_done(nmp);
3009 	struct nfsmount *nmp;
3039 	nmp = NFSTONMP(np);
3040 	if (!nmp) {
3044 	if (nmp->nm_vers == NFS_VER2) {
3053 	wverf = nmp->nm_verf;
3164 		retv = nmp->nm_funcs->nf_commit_rpc(np, off, count, wcred, wverf);
3170 			retv = nmp->nm_funcs->nf_commit_rpc(np, toff, count, bp->nb_wcred, wverf);
3248 	struct nfsmount *nmp = NFSTONMP(np);
3254 	if (!nmp) {
3258 	nfsvers = nmp->nm_vers;
3259 	if (NMFLAG(nmp, INTR))
3621 	struct nfsmount *nmp = VTONMP(vp);
3628 	if (nmp && !NMFLAG(nmp, INTR))
3744 	struct nfsmount *nmp;
3748 	FSDBG_TOP(552, nmp, 0, 0, 0);
3750 	if (((nmp = req->r_nmp)) == NULL)
3753 	niod = nmp->nm_niod;
3761 			niod->niod_nmp = nmp;
3777 		TAILQ_INSERT_TAIL(&nmp->nm_iodq, req, r_achain);
3780 	if (!nmp->nm_niod) {
3782 			nmp->nm_niod = niod;
3787 			TAILQ_INSERT_TAIL(&nfsiodmounts, nmp, nm_iodlink);
3800 	FSDBG_BOT(552, nmp, 0, 0, 0);
3809 	struct nfsmount *nmp = req->r_nmp;
3811 	if (!nmp)
3814 	lck_mtx_lock(&nmp->nm_lock);
3816 		TAILQ_INSERT_TAIL(&nmp->nm_resendq, req, r_rchain);
3819 	nfs_mount_sock_thread_wake(nmp);
3820 	lck_mtx_unlock(&nmp->nm_lock);
3833 	struct nfsmount *nmp = NFSTONMP(np);
3836 	if (!nmp)
3839 	if (nmp->nm_vers < NFS_VER4)