• Home
  • Line#
  • Scopes#
  • Navigate#
  • Raw
  • Download
1 // SPDX-License-Identifier: GPL-2.0
2 /*
3  * Copyright (c) 2014 Anna Schumaker <Anna.Schumaker@Netapp.com>
4  */
5 #ifndef __LINUX_FS_NFS_NFS4_2XDR_H
6 #define __LINUX_FS_NFS_NFS4_2XDR_H
7 
8 #include "nfs42.h"
9 
10 #define encode_fallocate_maxsz		(encode_stateid_maxsz + \
11 					 2 /* offset */ + \
12 					 2 /* length */)
13 #define NFS42_WRITE_RES_SIZE		(1 /* wr_callback_id size */ +\
14 					 XDR_QUADLEN(NFS4_STATEID_SIZE) + \
15 					 2 /* wr_count */ + \
16 					 1 /* wr_committed */ + \
17 					 XDR_QUADLEN(NFS4_VERIFIER_SIZE))
18 #define encode_allocate_maxsz		(op_encode_hdr_maxsz + \
19 					 encode_fallocate_maxsz)
20 #define decode_allocate_maxsz		(op_decode_hdr_maxsz)
21 #define encode_copy_maxsz		(op_encode_hdr_maxsz +          \
22 					 XDR_QUADLEN(NFS4_STATEID_SIZE) + \
23 					 XDR_QUADLEN(NFS4_STATEID_SIZE) + \
24 					 2 + 2 + 2 + 1 + 1 + 1)
25 #define decode_copy_maxsz		(op_decode_hdr_maxsz + \
26 					 NFS42_WRITE_RES_SIZE + \
27 					 1 /* cr_consecutive */ + \
28 					 1 /* cr_synchronous */)
29 #define encode_offload_cancel_maxsz	(op_encode_hdr_maxsz + \
30 					 XDR_QUADLEN(NFS4_STATEID_SIZE))
31 #define decode_offload_cancel_maxsz	(op_decode_hdr_maxsz)
32 #define encode_deallocate_maxsz		(op_encode_hdr_maxsz + \
33 					 encode_fallocate_maxsz)
34 #define decode_deallocate_maxsz		(op_decode_hdr_maxsz)
35 #define encode_seek_maxsz		(op_encode_hdr_maxsz + \
36 					 encode_stateid_maxsz + \
37 					 2 /* offset */ + \
38 					 1 /* whence */)
39 #define decode_seek_maxsz		(op_decode_hdr_maxsz + \
40 					 1 /* eof */ + \
41 					 1 /* whence */ + \
42 					 2 /* offset */ + \
43 					 2 /* length */)
44 #define encode_io_info_maxsz		4
45 #define encode_layoutstats_maxsz	(op_decode_hdr_maxsz + \
46 					2 /* offset */ + \
47 					2 /* length */ + \
48 					encode_stateid_maxsz + \
49 					encode_io_info_maxsz + \
50 					encode_io_info_maxsz + \
51 					1 /* opaque devaddr4 length */ + \
52 					XDR_QUADLEN(PNFS_LAYOUTSTATS_MAXSIZE))
53 #define decode_layoutstats_maxsz	(op_decode_hdr_maxsz)
54 #define encode_device_error_maxsz	(XDR_QUADLEN(NFS4_DEVICEID4_SIZE) + \
55 					1 /* status */ + 1 /* opnum */)
56 #define encode_layouterror_maxsz	(op_decode_hdr_maxsz + \
57 					2 /* offset */ + \
58 					2 /* length */ + \
59 					encode_stateid_maxsz + \
60 					1 /* Array size */ + \
61 					encode_device_error_maxsz)
62 #define decode_layouterror_maxsz	(op_decode_hdr_maxsz)
63 #define encode_clone_maxsz		(encode_stateid_maxsz + \
64 					encode_stateid_maxsz + \
65 					2 /* src offset */ + \
66 					2 /* dst offset */ + \
67 					2 /* count */)
68 #define decode_clone_maxsz		(op_decode_hdr_maxsz)
69 
70 #define NFS4_enc_allocate_sz		(compound_encode_hdr_maxsz + \
71 					 encode_sequence_maxsz + \
72 					 encode_putfh_maxsz + \
73 					 encode_allocate_maxsz + \
74 					 encode_getattr_maxsz)
75 #define NFS4_dec_allocate_sz		(compound_decode_hdr_maxsz + \
76 					 decode_sequence_maxsz + \
77 					 decode_putfh_maxsz + \
78 					 decode_allocate_maxsz + \
79 					 decode_getattr_maxsz)
80 #define NFS4_enc_copy_sz		(compound_encode_hdr_maxsz + \
81 					 encode_sequence_maxsz + \
82 					 encode_putfh_maxsz + \
83 					 encode_savefh_maxsz + \
84 					 encode_putfh_maxsz + \
85 					 encode_copy_maxsz + \
86 					 encode_commit_maxsz)
87 #define NFS4_dec_copy_sz		(compound_decode_hdr_maxsz + \
88 					 decode_sequence_maxsz + \
89 					 decode_putfh_maxsz + \
90 					 decode_savefh_maxsz + \
91 					 decode_putfh_maxsz + \
92 					 decode_copy_maxsz + \
93 					 decode_commit_maxsz)
94 #define NFS4_enc_offload_cancel_sz	(compound_encode_hdr_maxsz + \
95 					 encode_sequence_maxsz + \
96 					 encode_putfh_maxsz + \
97 					 encode_offload_cancel_maxsz)
98 #define NFS4_dec_offload_cancel_sz	(compound_decode_hdr_maxsz + \
99 					 decode_sequence_maxsz + \
100 					 decode_putfh_maxsz + \
101 					 decode_offload_cancel_maxsz)
102 #define NFS4_enc_deallocate_sz		(compound_encode_hdr_maxsz + \
103 					 encode_sequence_maxsz + \
104 					 encode_putfh_maxsz + \
105 					 encode_deallocate_maxsz + \
106 					 encode_getattr_maxsz)
107 #define NFS4_dec_deallocate_sz		(compound_decode_hdr_maxsz + \
108 					 decode_sequence_maxsz + \
109 					 decode_putfh_maxsz + \
110 					 decode_deallocate_maxsz + \
111 					 decode_getattr_maxsz)
112 #define NFS4_enc_seek_sz		(compound_encode_hdr_maxsz + \
113 					 encode_sequence_maxsz + \
114 					 encode_putfh_maxsz + \
115 					 encode_seek_maxsz)
116 #define NFS4_dec_seek_sz		(compound_decode_hdr_maxsz + \
117 					 decode_sequence_maxsz + \
118 					 decode_putfh_maxsz + \
119 					 decode_seek_maxsz)
120 #define NFS4_enc_layoutstats_sz		(compound_encode_hdr_maxsz + \
121 					 encode_sequence_maxsz + \
122 					 encode_putfh_maxsz + \
123 					 PNFS_LAYOUTSTATS_MAXDEV * encode_layoutstats_maxsz)
124 #define NFS4_dec_layoutstats_sz		(compound_decode_hdr_maxsz + \
125 					 decode_sequence_maxsz + \
126 					 decode_putfh_maxsz + \
127 					 PNFS_LAYOUTSTATS_MAXDEV * decode_layoutstats_maxsz)
128 #define NFS4_enc_layouterror_sz		(compound_encode_hdr_maxsz + \
129 					 encode_sequence_maxsz + \
130 					 encode_putfh_maxsz + \
131 					 NFS42_LAYOUTERROR_MAX * \
132 					 encode_layouterror_maxsz)
133 #define NFS4_dec_layouterror_sz		(compound_decode_hdr_maxsz + \
134 					 decode_sequence_maxsz + \
135 					 decode_putfh_maxsz + \
136 					 NFS42_LAYOUTERROR_MAX * \
137 					 decode_layouterror_maxsz)
138 #define NFS4_enc_clone_sz		(compound_encode_hdr_maxsz + \
139 					 encode_sequence_maxsz + \
140 					 encode_putfh_maxsz + \
141 					 encode_savefh_maxsz + \
142 					 encode_putfh_maxsz + \
143 					 encode_clone_maxsz + \
144 					 encode_getattr_maxsz)
145 #define NFS4_dec_clone_sz		(compound_decode_hdr_maxsz + \
146 					 decode_sequence_maxsz + \
147 					 decode_putfh_maxsz + \
148 					 decode_savefh_maxsz + \
149 					 decode_putfh_maxsz + \
150 					 decode_clone_maxsz + \
151 					 decode_getattr_maxsz)
152 
encode_fallocate(struct xdr_stream * xdr,const struct nfs42_falloc_args * args)153 static void encode_fallocate(struct xdr_stream *xdr,
154 			     const struct nfs42_falloc_args *args)
155 {
156 	encode_nfs4_stateid(xdr, &args->falloc_stateid);
157 	encode_uint64(xdr, args->falloc_offset);
158 	encode_uint64(xdr, args->falloc_length);
159 }
160 
encode_allocate(struct xdr_stream * xdr,const struct nfs42_falloc_args * args,struct compound_hdr * hdr)161 static void encode_allocate(struct xdr_stream *xdr,
162 			    const struct nfs42_falloc_args *args,
163 			    struct compound_hdr *hdr)
164 {
165 	encode_op_hdr(xdr, OP_ALLOCATE, decode_allocate_maxsz, hdr);
166 	encode_fallocate(xdr, args);
167 }
168 
encode_copy(struct xdr_stream * xdr,const struct nfs42_copy_args * args,struct compound_hdr * hdr)169 static void encode_copy(struct xdr_stream *xdr,
170 			const struct nfs42_copy_args *args,
171 			struct compound_hdr *hdr)
172 {
173 	encode_op_hdr(xdr, OP_COPY, decode_copy_maxsz, hdr);
174 	encode_nfs4_stateid(xdr, &args->src_stateid);
175 	encode_nfs4_stateid(xdr, &args->dst_stateid);
176 
177 	encode_uint64(xdr, args->src_pos);
178 	encode_uint64(xdr, args->dst_pos);
179 	encode_uint64(xdr, args->count);
180 
181 	encode_uint32(xdr, 1); /* consecutive = true */
182 	encode_uint32(xdr, args->sync);
183 	encode_uint32(xdr, 0); /* src server list */
184 }
185 
encode_offload_cancel(struct xdr_stream * xdr,const struct nfs42_offload_status_args * args,struct compound_hdr * hdr)186 static void encode_offload_cancel(struct xdr_stream *xdr,
187 				  const struct nfs42_offload_status_args *args,
188 				  struct compound_hdr *hdr)
189 {
190 	encode_op_hdr(xdr, OP_OFFLOAD_CANCEL, decode_offload_cancel_maxsz, hdr);
191 	encode_nfs4_stateid(xdr, &args->osa_stateid);
192 }
193 
encode_deallocate(struct xdr_stream * xdr,const struct nfs42_falloc_args * args,struct compound_hdr * hdr)194 static void encode_deallocate(struct xdr_stream *xdr,
195 			      const struct nfs42_falloc_args *args,
196 			      struct compound_hdr *hdr)
197 {
198 	encode_op_hdr(xdr, OP_DEALLOCATE, decode_deallocate_maxsz, hdr);
199 	encode_fallocate(xdr, args);
200 }
201 
encode_seek(struct xdr_stream * xdr,const struct nfs42_seek_args * args,struct compound_hdr * hdr)202 static void encode_seek(struct xdr_stream *xdr,
203 			const struct nfs42_seek_args *args,
204 			struct compound_hdr *hdr)
205 {
206 	encode_op_hdr(xdr, OP_SEEK, decode_seek_maxsz, hdr);
207 	encode_nfs4_stateid(xdr, &args->sa_stateid);
208 	encode_uint64(xdr, args->sa_offset);
209 	encode_uint32(xdr, args->sa_what);
210 }
211 
encode_layoutstats(struct xdr_stream * xdr,const struct nfs42_layoutstat_args * args,struct nfs42_layoutstat_devinfo * devinfo,struct compound_hdr * hdr)212 static void encode_layoutstats(struct xdr_stream *xdr,
213 			       const struct nfs42_layoutstat_args *args,
214 			       struct nfs42_layoutstat_devinfo *devinfo,
215 			       struct compound_hdr *hdr)
216 {
217 	__be32 *p;
218 
219 	encode_op_hdr(xdr, OP_LAYOUTSTATS, decode_layoutstats_maxsz, hdr);
220 	p = reserve_space(xdr, 8 + 8);
221 	p = xdr_encode_hyper(p, devinfo->offset);
222 	p = xdr_encode_hyper(p, devinfo->length);
223 	encode_nfs4_stateid(xdr, &args->stateid);
224 	p = reserve_space(xdr, 4*8 + NFS4_DEVICEID4_SIZE + 4);
225 	p = xdr_encode_hyper(p, devinfo->read_count);
226 	p = xdr_encode_hyper(p, devinfo->read_bytes);
227 	p = xdr_encode_hyper(p, devinfo->write_count);
228 	p = xdr_encode_hyper(p, devinfo->write_bytes);
229 	p = xdr_encode_opaque_fixed(p, devinfo->dev_id.data,
230 			NFS4_DEVICEID4_SIZE);
231 	/* Encode layoutupdate4 */
232 	*p++ = cpu_to_be32(devinfo->layout_type);
233 	if (devinfo->ld_private.ops)
234 		devinfo->ld_private.ops->encode(xdr, args,
235 				&devinfo->ld_private);
236 	else
237 		encode_uint32(xdr, 0);
238 }
239 
encode_clone(struct xdr_stream * xdr,const struct nfs42_clone_args * args,struct compound_hdr * hdr)240 static void encode_clone(struct xdr_stream *xdr,
241 			 const struct nfs42_clone_args *args,
242 			 struct compound_hdr *hdr)
243 {
244 	__be32 *p;
245 
246 	encode_op_hdr(xdr, OP_CLONE, decode_clone_maxsz, hdr);
247 	encode_nfs4_stateid(xdr, &args->src_stateid);
248 	encode_nfs4_stateid(xdr, &args->dst_stateid);
249 	p = reserve_space(xdr, 3*8);
250 	p = xdr_encode_hyper(p, args->src_offset);
251 	p = xdr_encode_hyper(p, args->dst_offset);
252 	xdr_encode_hyper(p, args->count);
253 }
254 
encode_device_error(struct xdr_stream * xdr,const struct nfs42_device_error * error)255 static void encode_device_error(struct xdr_stream *xdr,
256 				const struct nfs42_device_error *error)
257 {
258 	__be32 *p;
259 
260 	p = reserve_space(xdr, NFS4_DEVICEID4_SIZE + 2*4);
261 	p = xdr_encode_opaque_fixed(p, error->dev_id.data,
262 			NFS4_DEVICEID4_SIZE);
263 	*p++ = cpu_to_be32(error->status);
264 	*p = cpu_to_be32(error->opnum);
265 }
266 
encode_layouterror(struct xdr_stream * xdr,const struct nfs42_layout_error * args,struct compound_hdr * hdr)267 static void encode_layouterror(struct xdr_stream *xdr,
268 			       const struct nfs42_layout_error *args,
269 			       struct compound_hdr *hdr)
270 {
271 	__be32 *p;
272 
273 	encode_op_hdr(xdr, OP_LAYOUTERROR, decode_layouterror_maxsz, hdr);
274 	p = reserve_space(xdr, 8 + 8);
275 	p = xdr_encode_hyper(p, args->offset);
276 	p = xdr_encode_hyper(p, args->length);
277 	encode_nfs4_stateid(xdr, &args->stateid);
278 	p = reserve_space(xdr, 4);
279 	*p = cpu_to_be32(1);
280 	encode_device_error(xdr, &args->errors[0]);
281 }
282 
283 /*
284  * Encode ALLOCATE request
285  */
nfs4_xdr_enc_allocate(struct rpc_rqst * req,struct xdr_stream * xdr,const void * data)286 static void nfs4_xdr_enc_allocate(struct rpc_rqst *req,
287 				  struct xdr_stream *xdr,
288 				  const void *data)
289 {
290 	const struct nfs42_falloc_args *args = data;
291 	struct compound_hdr hdr = {
292 		.minorversion = nfs4_xdr_minorversion(&args->seq_args),
293 	};
294 
295 	encode_compound_hdr(xdr, req, &hdr);
296 	encode_sequence(xdr, &args->seq_args, &hdr);
297 	encode_putfh(xdr, args->falloc_fh, &hdr);
298 	encode_allocate(xdr, args, &hdr);
299 	encode_getfattr(xdr, args->falloc_bitmask, &hdr);
300 	encode_nops(&hdr);
301 }
302 
encode_copy_commit(struct xdr_stream * xdr,const struct nfs42_copy_args * args,struct compound_hdr * hdr)303 static void encode_copy_commit(struct xdr_stream *xdr,
304 			  const struct nfs42_copy_args *args,
305 			  struct compound_hdr *hdr)
306 {
307 	__be32 *p;
308 
309 	encode_op_hdr(xdr, OP_COMMIT, decode_commit_maxsz, hdr);
310 	p = reserve_space(xdr, 12);
311 	p = xdr_encode_hyper(p, args->dst_pos);
312 	*p = cpu_to_be32(args->count);
313 }
314 
315 /*
316  * Encode COPY request
317  */
nfs4_xdr_enc_copy(struct rpc_rqst * req,struct xdr_stream * xdr,const void * data)318 static void nfs4_xdr_enc_copy(struct rpc_rqst *req,
319 			      struct xdr_stream *xdr,
320 			      const void *data)
321 {
322 	const struct nfs42_copy_args *args = data;
323 	struct compound_hdr hdr = {
324 		.minorversion = nfs4_xdr_minorversion(&args->seq_args),
325 	};
326 
327 	encode_compound_hdr(xdr, req, &hdr);
328 	encode_sequence(xdr, &args->seq_args, &hdr);
329 	encode_putfh(xdr, args->src_fh, &hdr);
330 	encode_savefh(xdr, &hdr);
331 	encode_putfh(xdr, args->dst_fh, &hdr);
332 	encode_copy(xdr, args, &hdr);
333 	if (args->sync)
334 		encode_copy_commit(xdr, args, &hdr);
335 	encode_nops(&hdr);
336 }
337 
338 /*
339  * Encode OFFLOAD_CANEL request
340  */
nfs4_xdr_enc_offload_cancel(struct rpc_rqst * req,struct xdr_stream * xdr,const void * data)341 static void nfs4_xdr_enc_offload_cancel(struct rpc_rqst *req,
342 					struct xdr_stream *xdr,
343 					const void *data)
344 {
345 	const struct nfs42_offload_status_args *args = data;
346 	struct compound_hdr hdr = {
347 		.minorversion = nfs4_xdr_minorversion(&args->osa_seq_args),
348 	};
349 
350 	encode_compound_hdr(xdr, req, &hdr);
351 	encode_sequence(xdr, &args->osa_seq_args, &hdr);
352 	encode_putfh(xdr, args->osa_src_fh, &hdr);
353 	encode_offload_cancel(xdr, args, &hdr);
354 	encode_nops(&hdr);
355 }
356 
357 /*
358  * Encode DEALLOCATE request
359  */
nfs4_xdr_enc_deallocate(struct rpc_rqst * req,struct xdr_stream * xdr,const void * data)360 static void nfs4_xdr_enc_deallocate(struct rpc_rqst *req,
361 				    struct xdr_stream *xdr,
362 				    const void *data)
363 {
364 	const struct nfs42_falloc_args *args = data;
365 	struct compound_hdr hdr = {
366 		.minorversion = nfs4_xdr_minorversion(&args->seq_args),
367 	};
368 
369 	encode_compound_hdr(xdr, req, &hdr);
370 	encode_sequence(xdr, &args->seq_args, &hdr);
371 	encode_putfh(xdr, args->falloc_fh, &hdr);
372 	encode_deallocate(xdr, args, &hdr);
373 	encode_getfattr(xdr, args->falloc_bitmask, &hdr);
374 	encode_nops(&hdr);
375 }
376 
377 /*
378  * Encode SEEK request
379  */
nfs4_xdr_enc_seek(struct rpc_rqst * req,struct xdr_stream * xdr,const void * data)380 static void nfs4_xdr_enc_seek(struct rpc_rqst *req,
381 			      struct xdr_stream *xdr,
382 			      const void *data)
383 {
384 	const struct nfs42_seek_args *args = data;
385 	struct compound_hdr hdr = {
386 		.minorversion = nfs4_xdr_minorversion(&args->seq_args),
387 	};
388 
389 	encode_compound_hdr(xdr, req, &hdr);
390 	encode_sequence(xdr, &args->seq_args, &hdr);
391 	encode_putfh(xdr, args->sa_fh, &hdr);
392 	encode_seek(xdr, args, &hdr);
393 	encode_nops(&hdr);
394 }
395 
396 /*
397  * Encode LAYOUTSTATS request
398  */
nfs4_xdr_enc_layoutstats(struct rpc_rqst * req,struct xdr_stream * xdr,const void * data)399 static void nfs4_xdr_enc_layoutstats(struct rpc_rqst *req,
400 				     struct xdr_stream *xdr,
401 				     const void *data)
402 {
403 	const struct nfs42_layoutstat_args *args = data;
404 	int i;
405 
406 	struct compound_hdr hdr = {
407 		.minorversion = nfs4_xdr_minorversion(&args->seq_args),
408 	};
409 
410 	encode_compound_hdr(xdr, req, &hdr);
411 	encode_sequence(xdr, &args->seq_args, &hdr);
412 	encode_putfh(xdr, args->fh, &hdr);
413 	WARN_ON(args->num_dev > PNFS_LAYOUTSTATS_MAXDEV);
414 	for (i = 0; i < args->num_dev; i++)
415 		encode_layoutstats(xdr, args, &args->devinfo[i], &hdr);
416 	encode_nops(&hdr);
417 }
418 
419 /*
420  * Encode CLONE request
421  */
nfs4_xdr_enc_clone(struct rpc_rqst * req,struct xdr_stream * xdr,const void * data)422 static void nfs4_xdr_enc_clone(struct rpc_rqst *req,
423 			       struct xdr_stream *xdr,
424 			       const void *data)
425 {
426 	const struct nfs42_clone_args *args = data;
427 	struct compound_hdr hdr = {
428 		.minorversion = nfs4_xdr_minorversion(&args->seq_args),
429 	};
430 
431 	encode_compound_hdr(xdr, req, &hdr);
432 	encode_sequence(xdr, &args->seq_args, &hdr);
433 	encode_putfh(xdr, args->src_fh, &hdr);
434 	encode_savefh(xdr, &hdr);
435 	encode_putfh(xdr, args->dst_fh, &hdr);
436 	encode_clone(xdr, args, &hdr);
437 	encode_getfattr(xdr, args->dst_bitmask, &hdr);
438 	encode_nops(&hdr);
439 }
440 
441 /*
442  * Encode LAYOUTERROR request
443  */
nfs4_xdr_enc_layouterror(struct rpc_rqst * req,struct xdr_stream * xdr,const void * data)444 static void nfs4_xdr_enc_layouterror(struct rpc_rqst *req,
445 				     struct xdr_stream *xdr,
446 				     const void *data)
447 {
448 	const struct nfs42_layouterror_args *args = data;
449 	struct compound_hdr hdr = {
450 		.minorversion = nfs4_xdr_minorversion(&args->seq_args),
451 	};
452 	int i;
453 
454 	encode_compound_hdr(xdr, req, &hdr);
455 	encode_sequence(xdr, &args->seq_args, &hdr);
456 	encode_putfh(xdr, NFS_FH(args->inode), &hdr);
457 	for (i = 0; i < args->num_errors; i++)
458 		encode_layouterror(xdr, &args->errors[i], &hdr);
459 	encode_nops(&hdr);
460 }
461 
decode_allocate(struct xdr_stream * xdr,struct nfs42_falloc_res * res)462 static int decode_allocate(struct xdr_stream *xdr, struct nfs42_falloc_res *res)
463 {
464 	return decode_op_hdr(xdr, OP_ALLOCATE);
465 }
466 
decode_write_response(struct xdr_stream * xdr,struct nfs42_write_res * res)467 static int decode_write_response(struct xdr_stream *xdr,
468 				 struct nfs42_write_res *res)
469 {
470 	__be32 *p;
471 	int status, count;
472 
473 	p = xdr_inline_decode(xdr, 4);
474 	if (unlikely(!p))
475 		return -EIO;
476 	count = be32_to_cpup(p);
477 	if (count > 1)
478 		return -EREMOTEIO;
479 	else if (count == 1) {
480 		status = decode_opaque_fixed(xdr, &res->stateid,
481 				NFS4_STATEID_SIZE);
482 		if (unlikely(status))
483 			return -EIO;
484 	}
485 	p = xdr_inline_decode(xdr, 8 + 4);
486 	if (unlikely(!p))
487 		return -EIO;
488 	p = xdr_decode_hyper(p, &res->count);
489 	res->verifier.committed = be32_to_cpup(p);
490 	return decode_verifier(xdr, &res->verifier.verifier);
491 }
492 
decode_copy_requirements(struct xdr_stream * xdr,struct nfs42_copy_res * res)493 static int decode_copy_requirements(struct xdr_stream *xdr,
494 				    struct nfs42_copy_res *res) {
495 	__be32 *p;
496 
497 	p = xdr_inline_decode(xdr, 4 + 4);
498 	if (unlikely(!p))
499 		return -EIO;
500 
501 	res->consecutive = be32_to_cpup(p++);
502 	res->synchronous = be32_to_cpup(p++);
503 	return 0;
504 }
505 
decode_copy(struct xdr_stream * xdr,struct nfs42_copy_res * res)506 static int decode_copy(struct xdr_stream *xdr, struct nfs42_copy_res *res)
507 {
508 	int status;
509 
510 	status = decode_op_hdr(xdr, OP_COPY);
511 	if (status == NFS4ERR_OFFLOAD_NO_REQS) {
512 		status = decode_copy_requirements(xdr, res);
513 		if (status)
514 			return status;
515 		return NFS4ERR_OFFLOAD_NO_REQS;
516 	} else if (status)
517 		return status;
518 
519 	status = decode_write_response(xdr, &res->write_res);
520 	if (status)
521 		return status;
522 
523 	return decode_copy_requirements(xdr, res);
524 }
525 
decode_offload_cancel(struct xdr_stream * xdr,struct nfs42_offload_status_res * res)526 static int decode_offload_cancel(struct xdr_stream *xdr,
527 				 struct nfs42_offload_status_res *res)
528 {
529 	return decode_op_hdr(xdr, OP_OFFLOAD_CANCEL);
530 }
531 
decode_deallocate(struct xdr_stream * xdr,struct nfs42_falloc_res * res)532 static int decode_deallocate(struct xdr_stream *xdr, struct nfs42_falloc_res *res)
533 {
534 	return decode_op_hdr(xdr, OP_DEALLOCATE);
535 }
536 
decode_seek(struct xdr_stream * xdr,struct nfs42_seek_res * res)537 static int decode_seek(struct xdr_stream *xdr, struct nfs42_seek_res *res)
538 {
539 	int status;
540 	__be32 *p;
541 
542 	status = decode_op_hdr(xdr, OP_SEEK);
543 	if (status)
544 		return status;
545 
546 	p = xdr_inline_decode(xdr, 4 + 8);
547 	if (unlikely(!p))
548 		return -EIO;
549 
550 	res->sr_eof = be32_to_cpup(p++);
551 	p = xdr_decode_hyper(p, &res->sr_offset);
552 	return 0;
553 }
554 
decode_layoutstats(struct xdr_stream * xdr)555 static int decode_layoutstats(struct xdr_stream *xdr)
556 {
557 	return decode_op_hdr(xdr, OP_LAYOUTSTATS);
558 }
559 
decode_clone(struct xdr_stream * xdr)560 static int decode_clone(struct xdr_stream *xdr)
561 {
562 	return decode_op_hdr(xdr, OP_CLONE);
563 }
564 
decode_layouterror(struct xdr_stream * xdr)565 static int decode_layouterror(struct xdr_stream *xdr)
566 {
567 	return decode_op_hdr(xdr, OP_LAYOUTERROR);
568 }
569 
570 /*
571  * Decode ALLOCATE request
572  */
nfs4_xdr_dec_allocate(struct rpc_rqst * rqstp,struct xdr_stream * xdr,void * data)573 static int nfs4_xdr_dec_allocate(struct rpc_rqst *rqstp,
574 				 struct xdr_stream *xdr,
575 				 void *data)
576 {
577 	struct nfs42_falloc_res *res = data;
578 	struct compound_hdr hdr;
579 	int status;
580 
581 	status = decode_compound_hdr(xdr, &hdr);
582 	if (status)
583 		goto out;
584 	status = decode_sequence(xdr, &res->seq_res, rqstp);
585 	if (status)
586 		goto out;
587 	status = decode_putfh(xdr);
588 	if (status)
589 		goto out;
590 	status = decode_allocate(xdr, res);
591 	if (status)
592 		goto out;
593 	decode_getfattr(xdr, res->falloc_fattr, res->falloc_server);
594 out:
595 	return status;
596 }
597 
598 /*
599  * Decode COPY response
600  */
nfs4_xdr_dec_copy(struct rpc_rqst * rqstp,struct xdr_stream * xdr,void * data)601 static int nfs4_xdr_dec_copy(struct rpc_rqst *rqstp,
602 			     struct xdr_stream *xdr,
603 			     void *data)
604 {
605 	struct nfs42_copy_res *res = data;
606 	struct compound_hdr hdr;
607 	int status;
608 
609 	status = decode_compound_hdr(xdr, &hdr);
610 	if (status)
611 		goto out;
612 	status = decode_sequence(xdr, &res->seq_res, rqstp);
613 	if (status)
614 		goto out;
615 	status = decode_putfh(xdr);
616 	if (status)
617 		goto out;
618 	status = decode_savefh(xdr);
619 	if (status)
620 		goto out;
621 	status = decode_putfh(xdr);
622 	if (status)
623 		goto out;
624 	status = decode_copy(xdr, res);
625 	if (status)
626 		goto out;
627 	if (res->commit_res.verf)
628 		status = decode_commit(xdr, &res->commit_res);
629 out:
630 	return status;
631 }
632 
633 /*
634  * Decode OFFLOAD_CANCEL response
635  */
nfs4_xdr_dec_offload_cancel(struct rpc_rqst * rqstp,struct xdr_stream * xdr,void * data)636 static int nfs4_xdr_dec_offload_cancel(struct rpc_rqst *rqstp,
637 				       struct xdr_stream *xdr,
638 				       void *data)
639 {
640 	struct nfs42_offload_status_res *res = data;
641 	struct compound_hdr hdr;
642 	int status;
643 
644 	status = decode_compound_hdr(xdr, &hdr);
645 	if (status)
646 		goto out;
647 	status = decode_sequence(xdr, &res->osr_seq_res, rqstp);
648 	if (status)
649 		goto out;
650 	status = decode_putfh(xdr);
651 	if (status)
652 		goto out;
653 	status = decode_offload_cancel(xdr, res);
654 
655 out:
656 	return status;
657 }
658 
659 /*
660  * Decode DEALLOCATE request
661  */
nfs4_xdr_dec_deallocate(struct rpc_rqst * rqstp,struct xdr_stream * xdr,void * data)662 static int nfs4_xdr_dec_deallocate(struct rpc_rqst *rqstp,
663 				   struct xdr_stream *xdr,
664 				   void *data)
665 {
666 	struct nfs42_falloc_res *res = data;
667 	struct compound_hdr hdr;
668 	int status;
669 
670 	status = decode_compound_hdr(xdr, &hdr);
671 	if (status)
672 		goto out;
673 	status = decode_sequence(xdr, &res->seq_res, rqstp);
674 	if (status)
675 		goto out;
676 	status = decode_putfh(xdr);
677 	if (status)
678 		goto out;
679 	status = decode_deallocate(xdr, res);
680 	if (status)
681 		goto out;
682 	decode_getfattr(xdr, res->falloc_fattr, res->falloc_server);
683 out:
684 	return status;
685 }
686 
687 /*
688  * Decode SEEK request
689  */
nfs4_xdr_dec_seek(struct rpc_rqst * rqstp,struct xdr_stream * xdr,void * data)690 static int nfs4_xdr_dec_seek(struct rpc_rqst *rqstp,
691 			     struct xdr_stream *xdr,
692 			     void *data)
693 {
694 	struct nfs42_seek_res *res = data;
695 	struct compound_hdr hdr;
696 	int status;
697 
698 	status = decode_compound_hdr(xdr, &hdr);
699 	if (status)
700 		goto out;
701 	status = decode_sequence(xdr, &res->seq_res, rqstp);
702 	if (status)
703 		goto out;
704 	status = decode_putfh(xdr);
705 	if (status)
706 		goto out;
707 	status = decode_seek(xdr, res);
708 out:
709 	return status;
710 }
711 
712 /*
713  * Decode LAYOUTSTATS request
714  */
nfs4_xdr_dec_layoutstats(struct rpc_rqst * rqstp,struct xdr_stream * xdr,void * data)715 static int nfs4_xdr_dec_layoutstats(struct rpc_rqst *rqstp,
716 				    struct xdr_stream *xdr,
717 				    void *data)
718 {
719 	struct nfs42_layoutstat_res *res = data;
720 	struct compound_hdr hdr;
721 	int status, i;
722 
723 	status = decode_compound_hdr(xdr, &hdr);
724 	if (status)
725 		goto out;
726 	status = decode_sequence(xdr, &res->seq_res, rqstp);
727 	if (status)
728 		goto out;
729 	status = decode_putfh(xdr);
730 	if (status)
731 		goto out;
732 	WARN_ON(res->num_dev > PNFS_LAYOUTSTATS_MAXDEV);
733 	for (i = 0; i < res->num_dev; i++) {
734 		status = decode_layoutstats(xdr);
735 		if (status)
736 			goto out;
737 	}
738 out:
739 	res->rpc_status = status;
740 	return status;
741 }
742 
743 /*
744  * Decode CLONE request
745  */
nfs4_xdr_dec_clone(struct rpc_rqst * rqstp,struct xdr_stream * xdr,void * data)746 static int nfs4_xdr_dec_clone(struct rpc_rqst *rqstp,
747 			      struct xdr_stream *xdr,
748 			      void *data)
749 {
750 	struct nfs42_clone_res *res = data;
751 	struct compound_hdr hdr;
752 	int status;
753 
754 	status = decode_compound_hdr(xdr, &hdr);
755 	if (status)
756 		goto out;
757 	status = decode_sequence(xdr, &res->seq_res, rqstp);
758 	if (status)
759 		goto out;
760 	status = decode_putfh(xdr);
761 	if (status)
762 		goto out;
763 	status = decode_savefh(xdr);
764 	if (status)
765 		goto out;
766 	status = decode_putfh(xdr);
767 	if (status)
768 		goto out;
769 	status = decode_clone(xdr);
770 	if (status)
771 		goto out;
772 	status = decode_getfattr(xdr, res->dst_fattr, res->server);
773 
774 out:
775 	res->rpc_status = status;
776 	return status;
777 }
778 
779 /*
780  * Decode LAYOUTERROR request
781  */
nfs4_xdr_dec_layouterror(struct rpc_rqst * rqstp,struct xdr_stream * xdr,void * data)782 static int nfs4_xdr_dec_layouterror(struct rpc_rqst *rqstp,
783 				    struct xdr_stream *xdr,
784 				    void *data)
785 {
786 	struct nfs42_layouterror_res *res = data;
787 	struct compound_hdr hdr;
788 	int status, i;
789 
790 	status = decode_compound_hdr(xdr, &hdr);
791 	if (status)
792 		goto out;
793 	status = decode_sequence(xdr, &res->seq_res, rqstp);
794 	if (status)
795 		goto out;
796 	status = decode_putfh(xdr);
797 
798 	for (i = 0; i < res->num_errors && status == 0; i++)
799 		status = decode_layouterror(xdr);
800 out:
801 	res->rpc_status = status;
802 	return status;
803 }
804 
805 #endif /* __LINUX_FS_NFS_NFS4_2XDR_H */
806