Anna Schumaker | 1c6dcbe | 2014-09-26 13:58:48 -0400 | [diff] [blame] | 1 | /* |
| 2 | * Copyright (c) 2014 Anna Schumaker <Anna.Schumaker@Netapp.com> |
| 3 | */ |
| 4 | #include <linux/fs.h> |
| 5 | #include <linux/sunrpc/sched.h> |
| 6 | #include <linux/nfs.h> |
| 7 | #include <linux/nfs3.h> |
| 8 | #include <linux/nfs4.h> |
| 9 | #include <linux/nfs_xdr.h> |
| 10 | #include <linux/nfs_fs.h> |
| 11 | #include "nfs4_fs.h" |
| 12 | #include "nfs42.h" |
Peng Tao | 1b4a4bd | 2015-06-23 19:51:56 +0800 | [diff] [blame] | 13 | #include "iostat.h" |
| 14 | #include "pnfs.h" |
Anna Schumaker | efc6f4a | 2017-01-09 15:14:33 -0500 | [diff] [blame] | 15 | #include "nfs4session.h" |
Peng Tao | 1b4a4bd | 2015-06-23 19:51:56 +0800 | [diff] [blame] | 16 | #include "internal.h" |
| 17 | |
Anna Schumaker | 291e1b9 | 2015-11-16 14:51:07 -0500 | [diff] [blame] | 18 | #define NFSDBG_FACILITY NFSDBG_PROC |
Anna Schumaker | 1c6dcbe | 2014-09-26 13:58:48 -0400 | [diff] [blame] | 19 | |
Anna Schumaker | f4ac167 | 2014-11-25 13:18:15 -0500 | [diff] [blame] | 20 | static int _nfs42_proc_fallocate(struct rpc_message *msg, struct file *filep, |
Christoph Hellwig | 4bdf87e | 2016-02-17 15:48:28 +0100 | [diff] [blame] | 21 | struct nfs_lock_context *lock, loff_t offset, loff_t len) |
Anna Schumaker | f4ac167 | 2014-11-25 13:18:15 -0500 | [diff] [blame] | 22 | { |
| 23 | struct inode *inode = file_inode(filep); |
Anna Schumaker | 9a51940 | 2015-03-16 14:06:23 -0400 | [diff] [blame] | 24 | struct nfs_server *server = NFS_SERVER(inode); |
Anna Schumaker | f4ac167 | 2014-11-25 13:18:15 -0500 | [diff] [blame] | 25 | struct nfs42_falloc_args args = { |
| 26 | .falloc_fh = NFS_FH(inode), |
| 27 | .falloc_offset = offset, |
| 28 | .falloc_length = len, |
Anna Schumaker | 9a51940 | 2015-03-16 14:06:23 -0400 | [diff] [blame] | 29 | .falloc_bitmask = server->cache_consistency_bitmask, |
Anna Schumaker | f4ac167 | 2014-11-25 13:18:15 -0500 | [diff] [blame] | 30 | }; |
Anna Schumaker | 9a51940 | 2015-03-16 14:06:23 -0400 | [diff] [blame] | 31 | struct nfs42_falloc_res res = { |
| 32 | .falloc_server = server, |
| 33 | }; |
Anna Schumaker | f4ac167 | 2014-11-25 13:18:15 -0500 | [diff] [blame] | 34 | int status; |
| 35 | |
| 36 | msg->rpc_argp = &args; |
| 37 | msg->rpc_resp = &res; |
| 38 | |
Christoph Hellwig | 4bdf87e | 2016-02-17 15:48:28 +0100 | [diff] [blame] | 39 | status = nfs4_set_rw_stateid(&args.falloc_stateid, lock->open_context, |
| 40 | lock, FMODE_WRITE); |
Anna Schumaker | f4ac167 | 2014-11-25 13:18:15 -0500 | [diff] [blame] | 41 | if (status) |
| 42 | return status; |
| 43 | |
Anna Schumaker | 9a51940 | 2015-03-16 14:06:23 -0400 | [diff] [blame] | 44 | res.falloc_fattr = nfs_alloc_fattr(); |
| 45 | if (!res.falloc_fattr) |
| 46 | return -ENOMEM; |
| 47 | |
| 48 | status = nfs4_call_sync(server->client, server, msg, |
| 49 | &args.seq_args, &res.seq_res, 0); |
| 50 | if (status == 0) |
| 51 | status = nfs_post_op_update_inode(inode, res.falloc_fattr); |
| 52 | |
| 53 | kfree(res.falloc_fattr); |
| 54 | return status; |
Anna Schumaker | f4ac167 | 2014-11-25 13:18:15 -0500 | [diff] [blame] | 55 | } |
| 56 | |
| 57 | static int nfs42_proc_fallocate(struct rpc_message *msg, struct file *filep, |
| 58 | loff_t offset, loff_t len) |
| 59 | { |
| 60 | struct nfs_server *server = NFS_SERVER(file_inode(filep)); |
| 61 | struct nfs4_exception exception = { }; |
Christoph Hellwig | 4bdf87e | 2016-02-17 15:48:28 +0100 | [diff] [blame] | 62 | struct nfs_lock_context *lock; |
Anna Schumaker | f4ac167 | 2014-11-25 13:18:15 -0500 | [diff] [blame] | 63 | int err; |
| 64 | |
Christoph Hellwig | 4bdf87e | 2016-02-17 15:48:28 +0100 | [diff] [blame] | 65 | lock = nfs_get_lock_context(nfs_file_open_context(filep)); |
| 66 | if (IS_ERR(lock)) |
| 67 | return PTR_ERR(lock); |
| 68 | |
| 69 | exception.inode = file_inode(filep); |
| 70 | exception.state = lock->open_context->state; |
| 71 | |
Anna Schumaker | f4ac167 | 2014-11-25 13:18:15 -0500 | [diff] [blame] | 72 | do { |
Christoph Hellwig | 4bdf87e | 2016-02-17 15:48:28 +0100 | [diff] [blame] | 73 | err = _nfs42_proc_fallocate(msg, filep, lock, offset, len); |
| 74 | if (err == -ENOTSUPP) { |
| 75 | err = -EOPNOTSUPP; |
| 76 | break; |
| 77 | } |
Anna Schumaker | f4ac167 | 2014-11-25 13:18:15 -0500 | [diff] [blame] | 78 | err = nfs4_handle_exception(server, err, &exception); |
| 79 | } while (exception.retry); |
| 80 | |
Christoph Hellwig | 4bdf87e | 2016-02-17 15:48:28 +0100 | [diff] [blame] | 81 | nfs_put_lock_context(lock); |
Anna Schumaker | f4ac167 | 2014-11-25 13:18:15 -0500 | [diff] [blame] | 82 | return err; |
| 83 | } |
| 84 | |
| 85 | int nfs42_proc_allocate(struct file *filep, loff_t offset, loff_t len) |
| 86 | { |
| 87 | struct rpc_message msg = { |
| 88 | .rpc_proc = &nfs4_procedures[NFSPROC4_CLNT_ALLOCATE], |
| 89 | }; |
| 90 | struct inode *inode = file_inode(filep); |
| 91 | int err; |
| 92 | |
| 93 | if (!nfs_server_capable(inode, NFS_CAP_ALLOCATE)) |
| 94 | return -EOPNOTSUPP; |
| 95 | |
Al Viro | 5955102 | 2016-01-22 15:40:57 -0500 | [diff] [blame] | 96 | inode_lock(inode); |
Anna Schumaker | f830f7d | 2015-03-16 14:06:24 -0400 | [diff] [blame] | 97 | |
Anna Schumaker | f4ac167 | 2014-11-25 13:18:15 -0500 | [diff] [blame] | 98 | err = nfs42_proc_fallocate(&msg, filep, offset, len); |
| 99 | if (err == -EOPNOTSUPP) |
| 100 | NFS_SERVER(inode)->caps &= ~NFS_CAP_ALLOCATE; |
Anna Schumaker | f830f7d | 2015-03-16 14:06:24 -0400 | [diff] [blame] | 101 | |
Al Viro | 5955102 | 2016-01-22 15:40:57 -0500 | [diff] [blame] | 102 | inode_unlock(inode); |
Anna Schumaker | f4ac167 | 2014-11-25 13:18:15 -0500 | [diff] [blame] | 103 | return err; |
| 104 | } |
| 105 | |
Anna Schumaker | 624bd5b | 2014-11-25 13:18:16 -0500 | [diff] [blame] | 106 | int nfs42_proc_deallocate(struct file *filep, loff_t offset, loff_t len) |
| 107 | { |
| 108 | struct rpc_message msg = { |
| 109 | .rpc_proc = &nfs4_procedures[NFSPROC4_CLNT_DEALLOCATE], |
| 110 | }; |
| 111 | struct inode *inode = file_inode(filep); |
| 112 | int err; |
| 113 | |
| 114 | if (!nfs_server_capable(inode, NFS_CAP_DEALLOCATE)) |
| 115 | return -EOPNOTSUPP; |
| 116 | |
Al Viro | 5955102 | 2016-01-22 15:40:57 -0500 | [diff] [blame] | 117 | inode_lock(inode); |
Trond Myklebust | 1e564d3 | 2016-06-25 17:50:53 -0400 | [diff] [blame] | 118 | err = nfs_sync_inode(inode); |
| 119 | if (err) |
| 120 | goto out_unlock; |
Anna Schumaker | f830f7d | 2015-03-16 14:06:24 -0400 | [diff] [blame] | 121 | |
Anna Schumaker | 624bd5b | 2014-11-25 13:18:16 -0500 | [diff] [blame] | 122 | err = nfs42_proc_fallocate(&msg, filep, offset, len); |
Anna Schumaker | 9a51940 | 2015-03-16 14:06:23 -0400 | [diff] [blame] | 123 | if (err == 0) |
| 124 | truncate_pagecache_range(inode, offset, (offset + len) -1); |
Anna Schumaker | 624bd5b | 2014-11-25 13:18:16 -0500 | [diff] [blame] | 125 | if (err == -EOPNOTSUPP) |
| 126 | NFS_SERVER(inode)->caps &= ~NFS_CAP_DEALLOCATE; |
Trond Myklebust | 1e564d3 | 2016-06-25 17:50:53 -0400 | [diff] [blame] | 127 | out_unlock: |
Al Viro | 5955102 | 2016-01-22 15:40:57 -0500 | [diff] [blame] | 128 | inode_unlock(inode); |
Anna Schumaker | 624bd5b | 2014-11-25 13:18:16 -0500 | [diff] [blame] | 129 | return err; |
| 130 | } |
| 131 | |
Trond Myklebust | 9d8cacb | 2017-02-17 18:42:32 -0500 | [diff] [blame] | 132 | static ssize_t _nfs42_proc_copy(struct file *src, |
Anna Schumaker | 2e72448 | 2013-05-21 16:53:03 -0400 | [diff] [blame] | 133 | struct nfs_lock_context *src_lock, |
Trond Myklebust | 9d8cacb | 2017-02-17 18:42:32 -0500 | [diff] [blame] | 134 | struct file *dst, |
Anna Schumaker | 2e72448 | 2013-05-21 16:53:03 -0400 | [diff] [blame] | 135 | struct nfs_lock_context *dst_lock, |
Trond Myklebust | 9d8cacb | 2017-02-17 18:42:32 -0500 | [diff] [blame] | 136 | struct nfs42_copy_args *args, |
| 137 | struct nfs42_copy_res *res) |
Anna Schumaker | 2e72448 | 2013-05-21 16:53:03 -0400 | [diff] [blame] | 138 | { |
Anna Schumaker | 2e72448 | 2013-05-21 16:53:03 -0400 | [diff] [blame] | 139 | struct rpc_message msg = { |
| 140 | .rpc_proc = &nfs4_procedures[NFSPROC4_CLNT_COPY], |
Trond Myklebust | 9d8cacb | 2017-02-17 18:42:32 -0500 | [diff] [blame] | 141 | .rpc_argp = args, |
| 142 | .rpc_resp = res, |
Anna Schumaker | 2e72448 | 2013-05-21 16:53:03 -0400 | [diff] [blame] | 143 | }; |
| 144 | struct inode *dst_inode = file_inode(dst); |
| 145 | struct nfs_server *server = NFS_SERVER(dst_inode); |
Trond Myklebust | 9d8cacb | 2017-02-17 18:42:32 -0500 | [diff] [blame] | 146 | loff_t pos_src = args->src_pos; |
| 147 | loff_t pos_dst = args->dst_pos; |
| 148 | size_t count = args->count; |
Olga Kornievskaia | 1ee48bd | 2017-07-06 09:43:02 -0400 | [diff] [blame] | 149 | ssize_t status; |
Anna Schumaker | 2e72448 | 2013-05-21 16:53:03 -0400 | [diff] [blame] | 150 | |
Trond Myklebust | 9d8cacb | 2017-02-17 18:42:32 -0500 | [diff] [blame] | 151 | status = nfs4_set_rw_stateid(&args->src_stateid, src_lock->open_context, |
Anna Schumaker | 2e72448 | 2013-05-21 16:53:03 -0400 | [diff] [blame] | 152 | src_lock, FMODE_READ); |
| 153 | if (status) |
| 154 | return status; |
| 155 | |
Trond Myklebust | 837bb1d | 2016-06-25 18:12:03 -0400 | [diff] [blame] | 156 | status = nfs_filemap_write_and_wait_range(file_inode(src)->i_mapping, |
| 157 | pos_src, pos_src + (loff_t)count - 1); |
| 158 | if (status) |
| 159 | return status; |
| 160 | |
Trond Myklebust | 9d8cacb | 2017-02-17 18:42:32 -0500 | [diff] [blame] | 161 | status = nfs4_set_rw_stateid(&args->dst_stateid, dst_lock->open_context, |
Anna Schumaker | 2e72448 | 2013-05-21 16:53:03 -0400 | [diff] [blame] | 162 | dst_lock, FMODE_WRITE); |
| 163 | if (status) |
| 164 | return status; |
| 165 | |
Trond Myklebust | 837bb1d | 2016-06-25 18:12:03 -0400 | [diff] [blame] | 166 | status = nfs_sync_inode(dst_inode); |
| 167 | if (status) |
| 168 | return status; |
| 169 | |
Olga Kornievskaia | e092693 | 2017-05-08 18:02:24 -0400 | [diff] [blame] | 170 | res->commit_res.verf = kzalloc(sizeof(struct nfs_writeverf), GFP_NOFS); |
| 171 | if (!res->commit_res.verf) |
| 172 | return -ENOMEM; |
Anna Schumaker | 2e72448 | 2013-05-21 16:53:03 -0400 | [diff] [blame] | 173 | status = nfs4_call_sync(server->client, server, &msg, |
Trond Myklebust | 9d8cacb | 2017-02-17 18:42:32 -0500 | [diff] [blame] | 174 | &args->seq_args, &res->seq_res, 0); |
Anna Schumaker | 2e72448 | 2013-05-21 16:53:03 -0400 | [diff] [blame] | 175 | if (status == -ENOTSUPP) |
| 176 | server->caps &= ~NFS_CAP_COPY; |
| 177 | if (status) |
Olga Kornievskaia | e092693 | 2017-05-08 18:02:24 -0400 | [diff] [blame] | 178 | goto out; |
Anna Schumaker | 2e72448 | 2013-05-21 16:53:03 -0400 | [diff] [blame] | 179 | |
Olga Kornievskaia | 6d3b5d8 | 2017-05-16 12:00:15 -0400 | [diff] [blame] | 180 | if (nfs_write_verifier_cmp(&res->write_res.verifier.verifier, |
Olga Kornievskaia | e092693 | 2017-05-08 18:02:24 -0400 | [diff] [blame] | 181 | &res->commit_res.verf->verifier)) { |
| 182 | status = -EAGAIN; |
| 183 | goto out; |
Anna Schumaker | 2e72448 | 2013-05-21 16:53:03 -0400 | [diff] [blame] | 184 | } |
| 185 | |
| 186 | truncate_pagecache_range(dst_inode, pos_dst, |
Trond Myklebust | 9d8cacb | 2017-02-17 18:42:32 -0500 | [diff] [blame] | 187 | pos_dst + res->write_res.count); |
Anna Schumaker | 2e72448 | 2013-05-21 16:53:03 -0400 | [diff] [blame] | 188 | |
Olga Kornievskaia | e092693 | 2017-05-08 18:02:24 -0400 | [diff] [blame] | 189 | status = res->write_res.count; |
| 190 | out: |
| 191 | kfree(res->commit_res.verf); |
| 192 | return status; |
Anna Schumaker | 2e72448 | 2013-05-21 16:53:03 -0400 | [diff] [blame] | 193 | } |
| 194 | |
| 195 | ssize_t nfs42_proc_copy(struct file *src, loff_t pos_src, |
| 196 | struct file *dst, loff_t pos_dst, |
| 197 | size_t count) |
| 198 | { |
| 199 | struct nfs_server *server = NFS_SERVER(file_inode(dst)); |
| 200 | struct nfs_lock_context *src_lock; |
| 201 | struct nfs_lock_context *dst_lock; |
Trond Myklebust | 9d8cacb | 2017-02-17 18:42:32 -0500 | [diff] [blame] | 202 | struct nfs42_copy_args args = { |
| 203 | .src_fh = NFS_FH(file_inode(src)), |
| 204 | .src_pos = pos_src, |
| 205 | .dst_fh = NFS_FH(file_inode(dst)), |
| 206 | .dst_pos = pos_dst, |
| 207 | .count = count, |
| 208 | }; |
| 209 | struct nfs42_copy_res res; |
| 210 | struct nfs4_exception src_exception = { |
| 211 | .inode = file_inode(src), |
| 212 | .stateid = &args.src_stateid, |
| 213 | }; |
| 214 | struct nfs4_exception dst_exception = { |
| 215 | .inode = file_inode(dst), |
| 216 | .stateid = &args.dst_stateid, |
| 217 | }; |
Anna Schumaker | 2e72448 | 2013-05-21 16:53:03 -0400 | [diff] [blame] | 218 | ssize_t err, err2; |
| 219 | |
| 220 | if (!nfs_server_capable(file_inode(dst), NFS_CAP_COPY)) |
| 221 | return -EOPNOTSUPP; |
| 222 | |
| 223 | src_lock = nfs_get_lock_context(nfs_file_open_context(src)); |
| 224 | if (IS_ERR(src_lock)) |
| 225 | return PTR_ERR(src_lock); |
| 226 | |
Anna Schumaker | 2e72448 | 2013-05-21 16:53:03 -0400 | [diff] [blame] | 227 | src_exception.state = src_lock->open_context->state; |
| 228 | |
| 229 | dst_lock = nfs_get_lock_context(nfs_file_open_context(dst)); |
| 230 | if (IS_ERR(dst_lock)) { |
| 231 | err = PTR_ERR(dst_lock); |
| 232 | goto out_put_src_lock; |
| 233 | } |
| 234 | |
Anna Schumaker | 2e72448 | 2013-05-21 16:53:03 -0400 | [diff] [blame] | 235 | dst_exception.state = dst_lock->open_context->state; |
| 236 | |
| 237 | do { |
Linus Torvalds | ea8ea73 | 2016-05-26 10:33:33 -0700 | [diff] [blame] | 238 | inode_lock(file_inode(dst)); |
Trond Myklebust | 9d8cacb | 2017-02-17 18:42:32 -0500 | [diff] [blame] | 239 | err = _nfs42_proc_copy(src, src_lock, |
| 240 | dst, dst_lock, |
| 241 | &args, &res); |
Linus Torvalds | ea8ea73 | 2016-05-26 10:33:33 -0700 | [diff] [blame] | 242 | inode_unlock(file_inode(dst)); |
Anna Schumaker | 2e72448 | 2013-05-21 16:53:03 -0400 | [diff] [blame] | 243 | |
Trond Myklebust | 9d8cacb | 2017-02-17 18:42:32 -0500 | [diff] [blame] | 244 | if (err >= 0) |
| 245 | break; |
Anna Schumaker | 2e72448 | 2013-05-21 16:53:03 -0400 | [diff] [blame] | 246 | if (err == -ENOTSUPP) { |
| 247 | err = -EOPNOTSUPP; |
| 248 | break; |
Olga Kornievskaia | e092693 | 2017-05-08 18:02:24 -0400 | [diff] [blame] | 249 | } if (err == -EAGAIN) { |
| 250 | dst_exception.retry = 1; |
| 251 | continue; |
Anna Schumaker | 2e72448 | 2013-05-21 16:53:03 -0400 | [diff] [blame] | 252 | } |
| 253 | |
| 254 | err2 = nfs4_handle_exception(server, err, &src_exception); |
| 255 | err = nfs4_handle_exception(server, err, &dst_exception); |
| 256 | if (!err) |
| 257 | err = err2; |
| 258 | } while (src_exception.retry || dst_exception.retry); |
| 259 | |
| 260 | nfs_put_lock_context(dst_lock); |
| 261 | out_put_src_lock: |
| 262 | nfs_put_lock_context(src_lock); |
| 263 | return err; |
| 264 | } |
| 265 | |
Christoph Hellwig | 4bdf87e | 2016-02-17 15:48:28 +0100 | [diff] [blame] | 266 | static loff_t _nfs42_proc_llseek(struct file *filep, |
| 267 | struct nfs_lock_context *lock, loff_t offset, int whence) |
Anna Schumaker | 1c6dcbe | 2014-09-26 13:58:48 -0400 | [diff] [blame] | 268 | { |
| 269 | struct inode *inode = file_inode(filep); |
| 270 | struct nfs42_seek_args args = { |
| 271 | .sa_fh = NFS_FH(inode), |
| 272 | .sa_offset = offset, |
| 273 | .sa_what = (whence == SEEK_HOLE) ? |
| 274 | NFS4_CONTENT_HOLE : NFS4_CONTENT_DATA, |
| 275 | }; |
| 276 | struct nfs42_seek_res res; |
| 277 | struct rpc_message msg = { |
| 278 | .rpc_proc = &nfs4_procedures[NFSPROC4_CLNT_SEEK], |
| 279 | .rpc_argp = &args, |
| 280 | .rpc_resp = &res, |
| 281 | }; |
| 282 | struct nfs_server *server = NFS_SERVER(inode); |
| 283 | int status; |
| 284 | |
Anna Schumaker | 878ffa9 | 2014-10-23 14:00:54 -0400 | [diff] [blame] | 285 | if (!nfs_server_capable(inode, NFS_CAP_SEEK)) |
Anna Schumaker | 1c6dcbe | 2014-09-26 13:58:48 -0400 | [diff] [blame] | 286 | return -ENOTSUPP; |
| 287 | |
Christoph Hellwig | 4bdf87e | 2016-02-17 15:48:28 +0100 | [diff] [blame] | 288 | status = nfs4_set_rw_stateid(&args.sa_stateid, lock->open_context, |
| 289 | lock, FMODE_READ); |
Anna Schumaker | 1c6dcbe | 2014-09-26 13:58:48 -0400 | [diff] [blame] | 290 | if (status) |
| 291 | return status; |
| 292 | |
Trond Myklebust | e95fc4a | 2016-06-25 17:57:39 -0400 | [diff] [blame] | 293 | status = nfs_filemap_write_and_wait_range(inode->i_mapping, |
| 294 | offset, LLONG_MAX); |
| 295 | if (status) |
| 296 | return status; |
| 297 | |
Anna Schumaker | 1c6dcbe | 2014-09-26 13:58:48 -0400 | [diff] [blame] | 298 | status = nfs4_call_sync(server->client, server, &msg, |
| 299 | &args.seq_args, &res.seq_res, 0); |
| 300 | if (status == -ENOTSUPP) |
| 301 | server->caps &= ~NFS_CAP_SEEK; |
| 302 | if (status) |
| 303 | return status; |
| 304 | |
| 305 | return vfs_setpos(filep, res.sr_offset, inode->i_sb->s_maxbytes); |
| 306 | } |
Trond Myklebust | be3a5d2 | 2015-06-23 19:51:55 +0800 | [diff] [blame] | 307 | |
J. Bruce Fields | bdcc2cd | 2015-07-23 11:08:43 -0400 | [diff] [blame] | 308 | loff_t nfs42_proc_llseek(struct file *filep, loff_t offset, int whence) |
| 309 | { |
| 310 | struct nfs_server *server = NFS_SERVER(file_inode(filep)); |
| 311 | struct nfs4_exception exception = { }; |
Christoph Hellwig | 4bdf87e | 2016-02-17 15:48:28 +0100 | [diff] [blame] | 312 | struct nfs_lock_context *lock; |
J. Bruce Fields | 306a554 | 2015-09-16 17:21:27 -0400 | [diff] [blame] | 313 | loff_t err; |
J. Bruce Fields | bdcc2cd | 2015-07-23 11:08:43 -0400 | [diff] [blame] | 314 | |
Christoph Hellwig | 4bdf87e | 2016-02-17 15:48:28 +0100 | [diff] [blame] | 315 | lock = nfs_get_lock_context(nfs_file_open_context(filep)); |
| 316 | if (IS_ERR(lock)) |
| 317 | return PTR_ERR(lock); |
| 318 | |
| 319 | exception.inode = file_inode(filep); |
| 320 | exception.state = lock->open_context->state; |
| 321 | |
J. Bruce Fields | bdcc2cd | 2015-07-23 11:08:43 -0400 | [diff] [blame] | 322 | do { |
Christoph Hellwig | 4bdf87e | 2016-02-17 15:48:28 +0100 | [diff] [blame] | 323 | err = _nfs42_proc_llseek(filep, lock, offset, whence); |
J. Bruce Fields | 306a554 | 2015-09-16 17:21:27 -0400 | [diff] [blame] | 324 | if (err >= 0) |
| 325 | break; |
Christoph Hellwig | 4bdf87e | 2016-02-17 15:48:28 +0100 | [diff] [blame] | 326 | if (err == -ENOTSUPP) { |
| 327 | err = -EOPNOTSUPP; |
| 328 | break; |
| 329 | } |
J. Bruce Fields | bdcc2cd | 2015-07-23 11:08:43 -0400 | [diff] [blame] | 330 | err = nfs4_handle_exception(server, err, &exception); |
| 331 | } while (exception.retry); |
| 332 | |
Christoph Hellwig | 4bdf87e | 2016-02-17 15:48:28 +0100 | [diff] [blame] | 333 | nfs_put_lock_context(lock); |
J. Bruce Fields | bdcc2cd | 2015-07-23 11:08:43 -0400 | [diff] [blame] | 334 | return err; |
| 335 | } |
| 336 | |
| 337 | |
Peng Tao | 1b4a4bd | 2015-06-23 19:51:56 +0800 | [diff] [blame] | 338 | static void |
| 339 | nfs42_layoutstat_prepare(struct rpc_task *task, void *calldata) |
| 340 | { |
| 341 | struct nfs42_layoutstat_data *data = calldata; |
Trond Myklebust | 9a0fe86 | 2016-08-19 15:33:12 -0400 | [diff] [blame] | 342 | struct inode *inode = data->inode; |
| 343 | struct nfs_server *server = NFS_SERVER(inode); |
| 344 | struct pnfs_layout_hdr *lo; |
Peng Tao | 1b4a4bd | 2015-06-23 19:51:56 +0800 | [diff] [blame] | 345 | |
Trond Myklebust | 9a0fe86 | 2016-08-19 15:33:12 -0400 | [diff] [blame] | 346 | spin_lock(&inode->i_lock); |
| 347 | lo = NFS_I(inode)->layout; |
| 348 | if (!pnfs_layout_is_valid(lo)) { |
| 349 | spin_unlock(&inode->i_lock); |
| 350 | rpc_exit(task, 0); |
| 351 | return; |
| 352 | } |
| 353 | nfs4_stateid_copy(&data->args.stateid, &lo->plh_stateid); |
| 354 | spin_unlock(&inode->i_lock); |
Anna Schumaker | 6de7e12 | 2017-01-09 16:51:52 -0500 | [diff] [blame] | 355 | nfs4_setup_sequence(server->nfs_client, &data->args.seq_args, |
| 356 | &data->res.seq_res, task); |
Peng Tao | 1b4a4bd | 2015-06-23 19:51:56 +0800 | [diff] [blame] | 357 | } |
| 358 | |
| 359 | static void |
| 360 | nfs42_layoutstat_done(struct rpc_task *task, void *calldata) |
| 361 | { |
| 362 | struct nfs42_layoutstat_data *data = calldata; |
Peng Tao | 68d264c | 2015-12-06 20:55:09 -0500 | [diff] [blame] | 363 | struct inode *inode = data->inode; |
| 364 | struct pnfs_layout_hdr *lo; |
Peng Tao | 1b4a4bd | 2015-06-23 19:51:56 +0800 | [diff] [blame] | 365 | |
| 366 | if (!nfs4_sequence_done(task, &data->res.seq_res)) |
| 367 | return; |
| 368 | |
Trond Myklebust | 6c5a0d8 | 2015-06-27 11:45:46 -0400 | [diff] [blame] | 369 | switch (task->tk_status) { |
| 370 | case 0: |
| 371 | break; |
Peng Tao | 68d264c | 2015-12-06 20:55:09 -0500 | [diff] [blame] | 372 | case -NFS4ERR_EXPIRED: |
Trond Myklebust | 206b3bb | 2016-08-05 12:16:19 -0400 | [diff] [blame] | 373 | case -NFS4ERR_ADMIN_REVOKED: |
| 374 | case -NFS4ERR_DELEG_REVOKED: |
Peng Tao | 68d264c | 2015-12-06 20:55:09 -0500 | [diff] [blame] | 375 | case -NFS4ERR_STALE_STATEID: |
Peng Tao | 68d264c | 2015-12-06 20:55:09 -0500 | [diff] [blame] | 376 | case -NFS4ERR_BAD_STATEID: |
| 377 | spin_lock(&inode->i_lock); |
| 378 | lo = NFS_I(inode)->layout; |
Trond Myklebust | 9a0fe86 | 2016-08-19 15:33:12 -0400 | [diff] [blame] | 379 | if (pnfs_layout_is_valid(lo) && |
| 380 | nfs4_stateid_match(&data->args.stateid, |
Peng Tao | 68d264c | 2015-12-06 20:55:09 -0500 | [diff] [blame] | 381 | &lo->plh_stateid)) { |
| 382 | LIST_HEAD(head); |
| 383 | |
| 384 | /* |
| 385 | * Mark the bad layout state as invalid, then retry |
| 386 | * with the current stateid. |
| 387 | */ |
Trond Myklebust | 5f46be0 | 2016-07-22 11:25:27 -0400 | [diff] [blame] | 388 | pnfs_mark_layout_stateid_invalid(lo, &head); |
Peng Tao | 68d264c | 2015-12-06 20:55:09 -0500 | [diff] [blame] | 389 | spin_unlock(&inode->i_lock); |
| 390 | pnfs_free_lseg_list(&head); |
Trond Myklebust | 1f18b82 | 2017-04-29 10:10:17 -0400 | [diff] [blame] | 391 | nfs_commit_inode(inode, 0); |
Peng Tao | 68d264c | 2015-12-06 20:55:09 -0500 | [diff] [blame] | 392 | } else |
| 393 | spin_unlock(&inode->i_lock); |
| 394 | break; |
Trond Myklebust | 9a0fe86 | 2016-08-19 15:33:12 -0400 | [diff] [blame] | 395 | case -NFS4ERR_OLD_STATEID: |
| 396 | spin_lock(&inode->i_lock); |
| 397 | lo = NFS_I(inode)->layout; |
| 398 | if (pnfs_layout_is_valid(lo) && |
| 399 | nfs4_stateid_match_other(&data->args.stateid, |
| 400 | &lo->plh_stateid)) { |
| 401 | /* Do we need to delay before resending? */ |
| 402 | if (!nfs4_stateid_is_newer(&lo->plh_stateid, |
| 403 | &data->args.stateid)) |
| 404 | rpc_delay(task, HZ); |
| 405 | rpc_restart_call_prepare(task); |
| 406 | } |
| 407 | spin_unlock(&inode->i_lock); |
| 408 | break; |
Trond Myklebust | 6c5a0d8 | 2015-06-27 11:45:46 -0400 | [diff] [blame] | 409 | case -ENOTSUPP: |
| 410 | case -EOPNOTSUPP: |
Peng Tao | 68d264c | 2015-12-06 20:55:09 -0500 | [diff] [blame] | 411 | NFS_SERVER(inode)->caps &= ~NFS_CAP_LAYOUTSTATS; |
Trond Myklebust | 6c5a0d8 | 2015-06-27 11:45:46 -0400 | [diff] [blame] | 412 | } |
Peng Tao | 1b4a4bd | 2015-06-23 19:51:56 +0800 | [diff] [blame] | 413 | } |
| 414 | |
| 415 | static void |
| 416 | nfs42_layoutstat_release(void *calldata) |
| 417 | { |
| 418 | struct nfs42_layoutstat_data *data = calldata; |
Trond Myklebust | 422c93c | 2016-10-06 17:53:20 -0400 | [diff] [blame] | 419 | struct nfs42_layoutstat_devinfo *devinfo = data->args.devinfo; |
| 420 | int i; |
Peng Tao | 8733408 | 2015-06-23 19:51:57 +0800 | [diff] [blame] | 421 | |
Trond Myklebust | 422c93c | 2016-10-06 17:53:20 -0400 | [diff] [blame] | 422 | for (i = 0; i < data->args.num_dev; i++) { |
| 423 | if (devinfo[i].ld_private.ops && devinfo[i].ld_private.ops->free) |
| 424 | devinfo[i].ld_private.ops->free(&devinfo[i].ld_private); |
| 425 | } |
Peng Tao | 1b4a4bd | 2015-06-23 19:51:56 +0800 | [diff] [blame] | 426 | |
| 427 | pnfs_put_layout_hdr(NFS_I(data->args.inode)->layout); |
Peng Tao | 1bfe3b2 | 2015-06-23 19:52:03 +0800 | [diff] [blame] | 428 | smp_mb__before_atomic(); |
| 429 | clear_bit(NFS_INO_LAYOUTSTATS, &NFS_I(data->args.inode)->flags); |
| 430 | smp_mb__after_atomic(); |
Peng Tao | 1b4a4bd | 2015-06-23 19:51:56 +0800 | [diff] [blame] | 431 | nfs_iput_and_deactive(data->inode); |
| 432 | kfree(data->args.devinfo); |
| 433 | kfree(data); |
| 434 | } |
| 435 | |
Trond Myklebust | be3a5d2 | 2015-06-23 19:51:55 +0800 | [diff] [blame] | 436 | static const struct rpc_call_ops nfs42_layoutstat_ops = { |
Peng Tao | 1b4a4bd | 2015-06-23 19:51:56 +0800 | [diff] [blame] | 437 | .rpc_call_prepare = nfs42_layoutstat_prepare, |
| 438 | .rpc_call_done = nfs42_layoutstat_done, |
| 439 | .rpc_release = nfs42_layoutstat_release, |
Trond Myklebust | be3a5d2 | 2015-06-23 19:51:55 +0800 | [diff] [blame] | 440 | }; |
| 441 | |
| 442 | int nfs42_proc_layoutstats_generic(struct nfs_server *server, |
| 443 | struct nfs42_layoutstat_data *data) |
| 444 | { |
| 445 | struct rpc_message msg = { |
| 446 | .rpc_proc = &nfs4_procedures[NFSPROC4_CLNT_LAYOUTSTATS], |
| 447 | .rpc_argp = &data->args, |
| 448 | .rpc_resp = &data->res, |
| 449 | }; |
| 450 | struct rpc_task_setup task_setup = { |
| 451 | .rpc_client = server->client, |
| 452 | .rpc_message = &msg, |
| 453 | .callback_ops = &nfs42_layoutstat_ops, |
| 454 | .callback_data = data, |
| 455 | .flags = RPC_TASK_ASYNC, |
| 456 | }; |
| 457 | struct rpc_task *task; |
| 458 | |
Peng Tao | 1b4a4bd | 2015-06-23 19:51:56 +0800 | [diff] [blame] | 459 | data->inode = nfs_igrab_and_active(data->args.inode); |
| 460 | if (!data->inode) { |
| 461 | nfs42_layoutstat_release(data); |
| 462 | return -EAGAIN; |
| 463 | } |
Trond Myklebust | be3a5d2 | 2015-06-23 19:51:55 +0800 | [diff] [blame] | 464 | nfs4_init_sequence(&data->args.seq_args, &data->res.seq_res, 0); |
| 465 | task = rpc_run_task(&task_setup); |
| 466 | if (IS_ERR(task)) |
| 467 | return PTR_ERR(task); |
Jeff Layton | 3f807e5 | 2016-10-04 00:07:43 -0400 | [diff] [blame] | 468 | rpc_put_task(task); |
Trond Myklebust | be3a5d2 | 2015-06-23 19:51:55 +0800 | [diff] [blame] | 469 | return 0; |
| 470 | } |
Peng Tao | e5341f3 | 2015-09-26 02:24:35 +0800 | [diff] [blame] | 471 | |
| 472 | static int _nfs42_proc_clone(struct rpc_message *msg, struct file *src_f, |
Christoph Hellwig | 4bdf87e | 2016-02-17 15:48:28 +0100 | [diff] [blame] | 473 | struct file *dst_f, struct nfs_lock_context *src_lock, |
| 474 | struct nfs_lock_context *dst_lock, loff_t src_offset, |
| 475 | loff_t dst_offset, loff_t count) |
Peng Tao | e5341f3 | 2015-09-26 02:24:35 +0800 | [diff] [blame] | 476 | { |
| 477 | struct inode *src_inode = file_inode(src_f); |
| 478 | struct inode *dst_inode = file_inode(dst_f); |
| 479 | struct nfs_server *server = NFS_SERVER(dst_inode); |
| 480 | struct nfs42_clone_args args = { |
| 481 | .src_fh = NFS_FH(src_inode), |
| 482 | .dst_fh = NFS_FH(dst_inode), |
| 483 | .src_offset = src_offset, |
| 484 | .dst_offset = dst_offset, |
Christoph Hellwig | 9494b2c | 2015-11-13 09:38:45 +0100 | [diff] [blame] | 485 | .count = count, |
Peng Tao | e5341f3 | 2015-09-26 02:24:35 +0800 | [diff] [blame] | 486 | .dst_bitmask = server->cache_consistency_bitmask, |
| 487 | }; |
| 488 | struct nfs42_clone_res res = { |
| 489 | .server = server, |
| 490 | }; |
| 491 | int status; |
| 492 | |
| 493 | msg->rpc_argp = &args; |
| 494 | msg->rpc_resp = &res; |
| 495 | |
Christoph Hellwig | 4bdf87e | 2016-02-17 15:48:28 +0100 | [diff] [blame] | 496 | status = nfs4_set_rw_stateid(&args.src_stateid, src_lock->open_context, |
| 497 | src_lock, FMODE_READ); |
Peng Tao | e5341f3 | 2015-09-26 02:24:35 +0800 | [diff] [blame] | 498 | if (status) |
| 499 | return status; |
| 500 | |
Christoph Hellwig | 4bdf87e | 2016-02-17 15:48:28 +0100 | [diff] [blame] | 501 | status = nfs4_set_rw_stateid(&args.dst_stateid, dst_lock->open_context, |
| 502 | dst_lock, FMODE_WRITE); |
Peng Tao | e5341f3 | 2015-09-26 02:24:35 +0800 | [diff] [blame] | 503 | if (status) |
| 504 | return status; |
| 505 | |
| 506 | res.dst_fattr = nfs_alloc_fattr(); |
| 507 | if (!res.dst_fattr) |
| 508 | return -ENOMEM; |
| 509 | |
| 510 | status = nfs4_call_sync(server->client, server, msg, |
| 511 | &args.seq_args, &res.seq_res, 0); |
| 512 | if (status == 0) |
| 513 | status = nfs_post_op_update_inode(dst_inode, res.dst_fattr); |
| 514 | |
| 515 | kfree(res.dst_fattr); |
| 516 | return status; |
| 517 | } |
| 518 | |
| 519 | int nfs42_proc_clone(struct file *src_f, struct file *dst_f, |
| 520 | loff_t src_offset, loff_t dst_offset, loff_t count) |
| 521 | { |
| 522 | struct rpc_message msg = { |
| 523 | .rpc_proc = &nfs4_procedures[NFSPROC4_CLNT_CLONE], |
| 524 | }; |
| 525 | struct inode *inode = file_inode(src_f); |
| 526 | struct nfs_server *server = NFS_SERVER(file_inode(src_f)); |
Christoph Hellwig | 4bdf87e | 2016-02-17 15:48:28 +0100 | [diff] [blame] | 527 | struct nfs_lock_context *src_lock; |
| 528 | struct nfs_lock_context *dst_lock; |
| 529 | struct nfs4_exception src_exception = { }; |
| 530 | struct nfs4_exception dst_exception = { }; |
| 531 | int err, err2; |
Peng Tao | e5341f3 | 2015-09-26 02:24:35 +0800 | [diff] [blame] | 532 | |
| 533 | if (!nfs_server_capable(inode, NFS_CAP_CLONE)) |
| 534 | return -EOPNOTSUPP; |
| 535 | |
Christoph Hellwig | 4bdf87e | 2016-02-17 15:48:28 +0100 | [diff] [blame] | 536 | src_lock = nfs_get_lock_context(nfs_file_open_context(src_f)); |
| 537 | if (IS_ERR(src_lock)) |
| 538 | return PTR_ERR(src_lock); |
| 539 | |
| 540 | src_exception.inode = file_inode(src_f); |
| 541 | src_exception.state = src_lock->open_context->state; |
| 542 | |
| 543 | dst_lock = nfs_get_lock_context(nfs_file_open_context(dst_f)); |
| 544 | if (IS_ERR(dst_lock)) { |
| 545 | err = PTR_ERR(dst_lock); |
| 546 | goto out_put_src_lock; |
| 547 | } |
| 548 | |
| 549 | dst_exception.inode = file_inode(dst_f); |
| 550 | dst_exception.state = dst_lock->open_context->state; |
| 551 | |
Peng Tao | e5341f3 | 2015-09-26 02:24:35 +0800 | [diff] [blame] | 552 | do { |
Christoph Hellwig | 4bdf87e | 2016-02-17 15:48:28 +0100 | [diff] [blame] | 553 | err = _nfs42_proc_clone(&msg, src_f, dst_f, src_lock, dst_lock, |
| 554 | src_offset, dst_offset, count); |
Peng Tao | e5341f3 | 2015-09-26 02:24:35 +0800 | [diff] [blame] | 555 | if (err == -ENOTSUPP || err == -EOPNOTSUPP) { |
| 556 | NFS_SERVER(inode)->caps &= ~NFS_CAP_CLONE; |
Christoph Hellwig | 4bdf87e | 2016-02-17 15:48:28 +0100 | [diff] [blame] | 557 | err = -EOPNOTSUPP; |
| 558 | break; |
Peng Tao | e5341f3 | 2015-09-26 02:24:35 +0800 | [diff] [blame] | 559 | } |
Peng Tao | e5341f3 | 2015-09-26 02:24:35 +0800 | [diff] [blame] | 560 | |
Christoph Hellwig | 4bdf87e | 2016-02-17 15:48:28 +0100 | [diff] [blame] | 561 | err2 = nfs4_handle_exception(server, err, &src_exception); |
| 562 | err = nfs4_handle_exception(server, err, &dst_exception); |
| 563 | if (!err) |
| 564 | err = err2; |
| 565 | } while (src_exception.retry || dst_exception.retry); |
| 566 | |
| 567 | nfs_put_lock_context(dst_lock); |
| 568 | out_put_src_lock: |
| 569 | nfs_put_lock_context(src_lock); |
Peng Tao | e5341f3 | 2015-09-26 02:24:35 +0800 | [diff] [blame] | 570 | return err; |
Peng Tao | e5341f3 | 2015-09-26 02:24:35 +0800 | [diff] [blame] | 571 | } |