nfs: add a helper to set NFS_ODIRECT_RESCHED_WRITES to direct writes

Peng Tao · Tom Haynes · commit 012fa16dca0d · 2015-02-03T11:06:51.000-08:00
To allow pnfs LD to ask direct writes to be resend.

Signed-off-by: Peng Tao &lt;tao.peng@primarydata.com&gt;
diff --git a/fs/nfs/direct.c b/fs/nfs/direct.c
@@ -116,6 +116,12 @@ static inline int put_dreq(struct nfs_direct_req *dreq)
 	return atomic_dec_and_test(&dreq->io_count);
 }
 
+void nfs_direct_set_resched_writes(struct nfs_direct_req *dreq)
+{
+	dreq->flags = NFS_ODIRECT_RESCHED_WRITES;
+}
+EXPORT_SYMBOL_GPL(nfs_direct_set_resched_writes);
+
 static void
 nfs_direct_good_bytes(struct nfs_direct_req *dreq, struct nfs_pgio_header *hdr)
 {
diff --git a/fs/nfs/internal.h b/fs/nfs/internal.h
@@ -502,6 +502,7 @@ static inline void nfs_inode_dio_wait(struct inode *inode)
 	inode_dio_wait(inode);
 }
 extern ssize_t nfs_dreq_bytes_left(struct nfs_direct_req *dreq);
+extern void nfs_direct_set_resched_writes(struct nfs_direct_req *dreq);
 
 /* nfs4proc.c */
 extern void __nfs4_read_done_cb(struct nfs_pgio_header *);

Original file line number	Diff line number	Diff line change
`@@ -116,6 +116,12 @@ static inline int put_dreq(struct nfs_direct_req *dreq)`
`116`	`116`	`return atomic_dec_and_test(&dreq->io_count);`
`117`	`117`	`}`
`118`	`118`
	`119`	`+void nfs_direct_set_resched_writes(struct nfs_direct_req *dreq)`
	`120`	`+{`
	`121`	`+ dreq->flags = NFS_ODIRECT_RESCHED_WRITES;`
	`122`	`+}`
	`123`	`+EXPORT_SYMBOL_GPL(nfs_direct_set_resched_writes);`
	`124`	`+`
`119`	`125`	`static void`
`120`	`126`	`nfs_direct_good_bytes(struct nfs_direct_req dreq, struct nfs_pgio_header hdr)`
`121`	`127`	`{`
Original file line number	Diff line number	Diff line change
`@@ -502,6 +502,7 @@ static inline void nfs_inode_dio_wait(struct inode *inode)`
`502`	`502`	`inode_dio_wait(inode);`
`503`	`503`	`}`
`504`	`504`	`extern ssize_t nfs_dreq_bytes_left(struct nfs_direct_req *dreq);`
	`505`	`+extern void nfs_direct_set_resched_writes(struct nfs_direct_req *dreq);`
`505`	`506`
`506`	`507`	`/* nfs4proc.c */`
`507`	`508`	`extern void __nfs4_read_done_cb(struct nfs_pgio_header *);`