svn commit: r335567 - in head/sys/fs: nfs nfsclient

Rick Macklem rmacklem at FreeBSD.org
Fri Jun 22 21:25:29 UTC 2018


Author: rmacklem
Date: Fri Jun 22 21:25:27 2018
New Revision: 335567
URL: https://svnweb.freebsd.org/changeset/base/335567

Log:
  Change the NFSv4.1 pNFS client so that it returns the DS error in layoutreturn.
  
  When the NFSv4.1 pNFS client gets an error for a DS I/O operation using a
  Flexible File layout, it returns the layout with an error.
  This patch changes the code slightly, so that it returns the layout for all
  errors except EACCES and lets the MDS decide what to do based on the error.
  It also makes a couple of changes to nfscl_layoutrecall() to ensure that
  the first layoutreturn(s) will have the error in the reply.
  Plus, the patch adds a wakeup() so that the "nfscl" thread won't wait 1sec
  before doing the LayoutReturn.
  Tested against the pNFS service.
  This patch should not affect non-pNFS use of the client.
  The unused "dsp" argument will be used by a future patch that disables the
  connection to the DS when possible.
  
  MFC after:	2 weeks

Modified:
  head/sys/fs/nfs/nfs_var.h
  head/sys/fs/nfsclient/nfs_clrpcops.c
  head/sys/fs/nfsclient/nfs_clstate.c

Modified: head/sys/fs/nfs/nfs_var.h
==============================================================================
--- head/sys/fs/nfs/nfs_var.h	Fri Jun 22 20:58:51 2018	(r335566)
+++ head/sys/fs/nfs/nfs_var.h	Fri Jun 22 21:25:27 2018	(r335567)
@@ -601,7 +601,8 @@ int nfscl_layout(struct nfsmount *, vnode_t, u_int8_t 
     NFSPROC_T *);
 struct nfscllayout *nfscl_getlayout(struct nfsclclient *, uint8_t *, int,
     uint64_t, struct nfsclflayout **, int *);
-void nfscl_dserr(uint32_t, struct nfscldevinfo *, struct nfscllayout *);
+void nfscl_dserr(uint32_t, uint32_t, struct nfscldevinfo *,
+    struct nfscllayout *, struct nfsclds *);
 void nfscl_rellayout(struct nfscllayout *, int);
 struct nfscldevinfo *nfscl_getdevinfo(struct nfsclclient *, uint8_t *,
     struct nfscldevinfo *);

Modified: head/sys/fs/nfsclient/nfs_clrpcops.c
==============================================================================
--- head/sys/fs/nfsclient/nfs_clrpcops.c	Fri Jun 22 20:58:51 2018	(r335566)
+++ head/sys/fs/nfsclient/nfs_clrpcops.c	Fri Jun 22 21:25:27 2018	(r335567)
@@ -6040,10 +6040,11 @@ nfscl_dofflayoutio(vnode_t vp, struct uio *uiop, int *
 					    *dspp, fhp, dp->nfsdi_vers,
 					    dp->nfsdi_minorvers, tcred, p);
 				NFSCL_DEBUG(4, "commitds=%d\n", error);
-				if (nfsds_failerr(error)) {
+				if (error != 0 && error != EACCES) {
 					NFSCL_DEBUG(4,
 					    "DS layreterr for commit\n");
-					nfscl_dserr(NFSV4OP_COMMIT, dp, lyp);
+					nfscl_dserr(NFSV4OP_COMMIT, error, dp,
+					    lyp, *dspp);
 				}
 			}
 			NFSCL_DEBUG(4, "aft nfsio_commitds=%d\n", error);
@@ -6064,9 +6065,10 @@ nfscl_dofflayoutio(vnode_t vp, struct uio *uiop, int *
 			    off, xfer, fhp, 1, dp->nfsdi_vers,
 			    dp->nfsdi_minorvers, tcred, p);
 			NFSCL_DEBUG(4, "readds=%d\n", error);
-			if (nfsds_failerr(error)) {
+			if (error != 0 && error != EACCES) {
 				NFSCL_DEBUG(4, "DS layreterr for read\n");
-				nfscl_dserr(NFSV4OP_READ, dp, lyp);
+				nfscl_dserr(NFSV4OP_READ, error, dp, lyp,
+				    *dspp);
 			}
 		} else {
 			if (flp->nfsfl_mirrorcnt == 1) {
@@ -6099,10 +6101,11 @@ nfscl_dofflayoutio(vnode_t vp, struct uio *uiop, int *
 					    xfer, fhp, m, dp->nfsdi_vers,
 					    dp->nfsdi_minorvers, tcred, p);
 				NFSCL_DEBUG(4, "nfsio_writedsmir=%d\n", error);
-				if (nfsds_failerr(error)) {
+				if (error != 0 && error != EACCES) {
 					NFSCL_DEBUG(4,
 					    "DS layreterr for write\n");
-					nfscl_dserr(NFSV4OP_WRITE, dp, lyp);
+					nfscl_dserr(NFSV4OP_WRITE, error, dp,
+					    lyp, *dspp);
 				}
 			}
 		}

Modified: head/sys/fs/nfsclient/nfs_clstate.c
==============================================================================
--- head/sys/fs/nfsclient/nfs_clstate.c	Fri Jun 22 20:58:51 2018	(r335566)
+++ head/sys/fs/nfsclient/nfs_clstate.c	Fri Jun 22 21:25:27 2018	(r335567)
@@ -4973,11 +4973,13 @@ nfscl_retoncloselayout(vnode_t vp, struct nfsclclient 
  * Mark the layout to be recalled and with an error.
  */
 void
-nfscl_dserr(uint32_t op, struct nfscldevinfo *dp, struct nfscllayout *lyp)
+nfscl_dserr(uint32_t op, uint32_t stat, struct nfscldevinfo *dp,
+    struct nfscllayout *lyp, __unused struct nfsclds *dsp)
 {
 	struct nfsclrecalllayout *recallp;
 	uint32_t iomode;
 
+	/* Set up the return of the layout. */
 	recallp = malloc(sizeof(*recallp), M_NFSLAYRECALL, M_WAITOK);
 	iomode = 0;
 	NFSLOCKCLSTATE();
@@ -4987,10 +4989,10 @@ nfscl_dserr(uint32_t op, struct nfscldevinfo *dp, stru
 		if (!LIST_EMPTY(&lyp->nfsly_flayrw))
 			iomode |= NFSLAYOUTIOMODE_RW;
 		(void)nfscl_layoutrecall(NFSLAYOUTRETURN_FILE, lyp, iomode,
-		    0, UINT64_MAX, lyp->nfsly_stateid.seqid, NFSERR_IO, op,
+		    0, UINT64_MAX, lyp->nfsly_stateid.seqid, stat, op,
 		    dp->nfsdi_deviceid, recallp);
 		NFSUNLOCKCLSTATE();
-		NFSCL_DEBUG(4, "retoncls recall iomode=%d\n", iomode);
+		NFSCL_DEBUG(4, "nfscl_dserr recall iomode=%d\n", iomode);
 	} else {
 		NFSUNLOCKCLSTATE();
 		free(recallp, M_NFSLAYRECALL);
@@ -5247,6 +5249,19 @@ nfscl_layoutrecall(int recalltype, struct nfscllayout 
 			LIST_INSERT_BEFORE(rp, recallp, nfsrecly_list);
 			break;
 		}
+
+		/*
+		 * Put any error return on all the file returns that will
+		 * preceed this one.
+		 */
+		if (rp->nfsrecly_recalltype == NFSLAYOUTRETURN_FILE &&
+		   stat != 0 && rp->nfsrecly_stat == 0) {
+			rp->nfsrecly_stat = stat;
+			rp->nfsrecly_op = op;
+			if (devid != NULL)
+				NFSBCOPY(devid, rp->nfsrecly_devid,
+				    NFSX_V4DEVICEID);
+		}
 	}
 	if (rp == NULL) {
 		if (orp == NULL)
@@ -5256,6 +5271,7 @@ nfscl_layoutrecall(int recalltype, struct nfscllayout 
 			LIST_INSERT_AFTER(orp, recallp, nfsrecly_list);
 	}
 	lyp->nfsly_flags |= NFSLY_RECALL;
+	wakeup(lyp->nfsly_clp);
 	return (0);
 }
 


More information about the svn-src-head mailing list