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