Blame view
fs/nfs/nfs42xdr.c
39.7 KB
b24413180 License cleanup: ... |
1 |
// SPDX-License-Identifier: GPL-2.0 |
1c6dcbe5c NFS: Implement SEEK |
2 3 4 5 6 |
/* * Copyright (c) 2014 Anna Schumaker <Anna.Schumaker@Netapp.com> */ #ifndef __LINUX_FS_NFS_NFS4_2XDR_H #define __LINUX_FS_NFS_NFS4_2XDR_H |
be3a5d233 NFSv.2/pnfs Add a... |
7 |
#include "nfs42.h" |
f4ac1674f nfs: Add ALLOCATE... |
8 9 10 |
#define encode_fallocate_maxsz (encode_stateid_maxsz + \ 2 /* offset */ + \ 2 /* length */) |
2e72448b0 NFS: Add COPY nfs... |
11 12 13 14 15 |
#define NFS42_WRITE_RES_SIZE (1 /* wr_callback_id size */ +\ XDR_QUADLEN(NFS4_STATEID_SIZE) + \ 2 /* wr_count */ + \ 1 /* wr_committed */ + \ XDR_QUADLEN(NFS4_VERIFIER_SIZE)) |
f4ac1674f nfs: Add ALLOCATE... |
16 17 18 |
#define encode_allocate_maxsz (op_encode_hdr_maxsz + \ encode_fallocate_maxsz) #define decode_allocate_maxsz (op_decode_hdr_maxsz) |
2e72448b0 NFS: Add COPY nfs... |
19 20 21 |
#define encode_copy_maxsz (op_encode_hdr_maxsz + \ XDR_QUADLEN(NFS4_STATEID_SIZE) + \ XDR_QUADLEN(NFS4_STATEID_SIZE) + \ |
1d38f3f0d NFS: add ca_sourc... |
22 23 24 25 |
2 + 2 + 2 + 1 + 1 + 1 +\ 1 + /* One cnr_source_server */\ 1 + /* nl4_type */ \ 1 + XDR_QUADLEN(NFS4_OPAQUE_LIMIT)) |
2e72448b0 NFS: Add COPY nfs... |
26 27 28 29 |
#define decode_copy_maxsz (op_decode_hdr_maxsz + \ NFS42_WRITE_RES_SIZE + \ 1 /* cr_consecutive */ + \ 1 /* cr_synchronous */) |
cb95deea0 NFS OFFLOAD_CANCE... |
30 31 32 |
#define encode_offload_cancel_maxsz (op_encode_hdr_maxsz + \ XDR_QUADLEN(NFS4_STATEID_SIZE)) #define decode_offload_cancel_maxsz (op_decode_hdr_maxsz) |
0491567b5 NFS: add COPY_NOT... |
33 34 35 36 37 38 39 40 41 42 |
#define encode_copy_notify_maxsz (op_encode_hdr_maxsz + \ XDR_QUADLEN(NFS4_STATEID_SIZE) + \ 1 + /* nl4_type */ \ 1 + XDR_QUADLEN(NFS4_OPAQUE_LIMIT)) #define decode_copy_notify_maxsz (op_decode_hdr_maxsz + \ 3 + /* cnr_lease_time */\ XDR_QUADLEN(NFS4_STATEID_SIZE) + \ 1 + /* Support 1 cnr_source_server */\ 1 + /* nl4_type */ \ 1 + XDR_QUADLEN(NFS4_OPAQUE_LIMIT)) |
624bd5b7b nfs: Add DEALLOCA... |
43 44 45 |
#define encode_deallocate_maxsz (op_encode_hdr_maxsz + \ encode_fallocate_maxsz) #define decode_deallocate_maxsz (op_decode_hdr_maxsz) |
c56755261 NFS: Add READ_PLU... |
46 47 48 49 50 51 52 53 |
#define encode_read_plus_maxsz (op_encode_hdr_maxsz + \ encode_stateid_maxsz + 3) #define NFS42_READ_PLUS_SEGMENT_SIZE (1 /* data_content4 */ + \ 2 /* data_info4.di_offset */ + \ 2 /* data_info4.di_length */) #define decode_read_plus_maxsz (op_decode_hdr_maxsz + \ 1 /* rpr_eof */ + \ 1 /* rpr_contents count */ + \ |
c05eafad6 NFS: Add READ_PLU... |
54 |
2 * NFS42_READ_PLUS_SEGMENT_SIZE) |
1c6dcbe5c NFS: Implement SEEK |
55 56 57 58 59 60 61 62 63 |
#define encode_seek_maxsz (op_encode_hdr_maxsz + \ encode_stateid_maxsz + \ 2 /* offset */ + \ 1 /* whence */) #define decode_seek_maxsz (op_decode_hdr_maxsz + \ 1 /* eof */ + \ 1 /* whence */ + \ 2 /* offset */ + \ 2 /* length */) |
be3a5d233 NFSv.2/pnfs Add a... |
64 65 66 67 68 69 70 71 72 73 |
#define encode_io_info_maxsz 4 #define encode_layoutstats_maxsz (op_decode_hdr_maxsz + \ 2 /* offset */ + \ 2 /* length */ + \ encode_stateid_maxsz + \ encode_io_info_maxsz + \ encode_io_info_maxsz + \ 1 /* opaque devaddr4 length */ + \ XDR_QUADLEN(PNFS_LAYOUTSTATS_MAXSIZE)) #define decode_layoutstats_maxsz (op_decode_hdr_maxsz) |
3eb86093e NFSv4.2: Add clie... |
74 75 76 77 78 79 80 81 82 |
#define encode_device_error_maxsz (XDR_QUADLEN(NFS4_DEVICEID4_SIZE) + \ 1 /* status */ + 1 /* opnum */) #define encode_layouterror_maxsz (op_decode_hdr_maxsz + \ 2 /* offset */ + \ 2 /* length */ + \ encode_stateid_maxsz + \ 1 /* Array size */ + \ encode_device_error_maxsz) #define decode_layouterror_maxsz (op_decode_hdr_maxsz) |
36022770d nfs42: add CLONE ... |
83 84 85 86 87 88 |
#define encode_clone_maxsz (encode_stateid_maxsz + \ encode_stateid_maxsz + \ 2 /* src offset */ + \ 2 /* dst offset */ + \ 2 /* count */) #define decode_clone_maxsz (op_decode_hdr_maxsz) |
1c6dcbe5c NFS: Implement SEEK |
89 |
|
f4ac1674f nfs: Add ALLOCATE... |
90 |
#define NFS4_enc_allocate_sz (compound_encode_hdr_maxsz + \ |
1a3466aed NFS: Add missing ... |
91 |
encode_sequence_maxsz + \ |
f4ac1674f nfs: Add ALLOCATE... |
92 |
encode_putfh_maxsz + \ |
9a51940bf NFS: Don't zap ca... |
93 94 |
encode_allocate_maxsz + \ encode_getattr_maxsz) |
f4ac1674f nfs: Add ALLOCATE... |
95 |
#define NFS4_dec_allocate_sz (compound_decode_hdr_maxsz + \ |
1a3466aed NFS: Add missing ... |
96 |
decode_sequence_maxsz + \ |
f4ac1674f nfs: Add ALLOCATE... |
97 |
decode_putfh_maxsz + \ |
9a51940bf NFS: Don't zap ca... |
98 99 |
decode_allocate_maxsz + \ decode_getattr_maxsz) |
2e72448b0 NFS: Add COPY nfs... |
100 |
#define NFS4_enc_copy_sz (compound_encode_hdr_maxsz + \ |
1a3466aed NFS: Add missing ... |
101 |
encode_sequence_maxsz + \ |
2e72448b0 NFS: Add COPY nfs... |
102 103 104 |
encode_putfh_maxsz + \ encode_savefh_maxsz + \ encode_putfh_maxsz + \ |
e09269344 NFS append COMMIT... |
105 106 |
encode_copy_maxsz + \ encode_commit_maxsz) |
2e72448b0 NFS: Add COPY nfs... |
107 |
#define NFS4_dec_copy_sz (compound_decode_hdr_maxsz + \ |
1a3466aed NFS: Add missing ... |
108 |
decode_sequence_maxsz + \ |
2e72448b0 NFS: Add COPY nfs... |
109 110 111 |
decode_putfh_maxsz + \ decode_savefh_maxsz + \ decode_putfh_maxsz + \ |
e09269344 NFS append COMMIT... |
112 113 |
decode_copy_maxsz + \ decode_commit_maxsz) |
cb95deea0 NFS OFFLOAD_CANCE... |
114 |
#define NFS4_enc_offload_cancel_sz (compound_encode_hdr_maxsz + \ |
1a3466aed NFS: Add missing ... |
115 |
encode_sequence_maxsz + \ |
cb95deea0 NFS OFFLOAD_CANCE... |
116 117 118 |
encode_putfh_maxsz + \ encode_offload_cancel_maxsz) #define NFS4_dec_offload_cancel_sz (compound_decode_hdr_maxsz + \ |
1a3466aed NFS: Add missing ... |
119 |
decode_sequence_maxsz + \ |
cb95deea0 NFS OFFLOAD_CANCE... |
120 121 |
decode_putfh_maxsz + \ decode_offload_cancel_maxsz) |
0491567b5 NFS: add COPY_NOT... |
122 123 124 125 126 127 |
#define NFS4_enc_copy_notify_sz (compound_encode_hdr_maxsz + \ encode_putfh_maxsz + \ encode_copy_notify_maxsz) #define NFS4_dec_copy_notify_sz (compound_decode_hdr_maxsz + \ decode_putfh_maxsz + \ decode_copy_notify_maxsz) |
624bd5b7b nfs: Add DEALLOCA... |
128 |
#define NFS4_enc_deallocate_sz (compound_encode_hdr_maxsz + \ |
1a3466aed NFS: Add missing ... |
129 |
encode_sequence_maxsz + \ |
624bd5b7b nfs: Add DEALLOCA... |
130 |
encode_putfh_maxsz + \ |
9a51940bf NFS: Don't zap ca... |
131 132 |
encode_deallocate_maxsz + \ encode_getattr_maxsz) |
624bd5b7b nfs: Add DEALLOCA... |
133 |
#define NFS4_dec_deallocate_sz (compound_decode_hdr_maxsz + \ |
1a3466aed NFS: Add missing ... |
134 |
decode_sequence_maxsz + \ |
624bd5b7b nfs: Add DEALLOCA... |
135 |
decode_putfh_maxsz + \ |
9a51940bf NFS: Don't zap ca... |
136 137 |
decode_deallocate_maxsz + \ decode_getattr_maxsz) |
c56755261 NFS: Add READ_PLU... |
138 139 140 141 142 143 144 145 |
#define NFS4_enc_read_plus_sz (compound_encode_hdr_maxsz + \ encode_sequence_maxsz + \ encode_putfh_maxsz + \ encode_read_plus_maxsz) #define NFS4_dec_read_plus_sz (compound_decode_hdr_maxsz + \ decode_sequence_maxsz + \ decode_putfh_maxsz + \ decode_read_plus_maxsz) |
1c6dcbe5c NFS: Implement SEEK |
146 |
#define NFS4_enc_seek_sz (compound_encode_hdr_maxsz + \ |
1a3466aed NFS: Add missing ... |
147 |
encode_sequence_maxsz + \ |
1c6dcbe5c NFS: Implement SEEK |
148 149 150 |
encode_putfh_maxsz + \ encode_seek_maxsz) #define NFS4_dec_seek_sz (compound_decode_hdr_maxsz + \ |
1a3466aed NFS: Add missing ... |
151 |
decode_sequence_maxsz + \ |
1c6dcbe5c NFS: Implement SEEK |
152 153 |
decode_putfh_maxsz + \ decode_seek_maxsz) |
be3a5d233 NFSv.2/pnfs Add a... |
154 155 156 157 158 159 160 161 |
#define NFS4_enc_layoutstats_sz (compound_encode_hdr_maxsz + \ encode_sequence_maxsz + \ encode_putfh_maxsz + \ PNFS_LAYOUTSTATS_MAXDEV * encode_layoutstats_maxsz) #define NFS4_dec_layoutstats_sz (compound_decode_hdr_maxsz + \ decode_sequence_maxsz + \ decode_putfh_maxsz + \ PNFS_LAYOUTSTATS_MAXDEV * decode_layoutstats_maxsz) |
3eb86093e NFSv4.2: Add clie... |
162 163 164 165 166 167 168 169 170 171 |
#define NFS4_enc_layouterror_sz (compound_encode_hdr_maxsz + \ encode_sequence_maxsz + \ encode_putfh_maxsz + \ NFS42_LAYOUTERROR_MAX * \ encode_layouterror_maxsz) #define NFS4_dec_layouterror_sz (compound_decode_hdr_maxsz + \ decode_sequence_maxsz + \ decode_putfh_maxsz + \ NFS42_LAYOUTERROR_MAX * \ decode_layouterror_maxsz) |
36022770d nfs42: add CLONE ... |
172 173 174 175 176 177 178 179 180 181 182 183 184 185 |
#define NFS4_enc_clone_sz (compound_encode_hdr_maxsz + \ encode_sequence_maxsz + \ encode_putfh_maxsz + \ encode_savefh_maxsz + \ encode_putfh_maxsz + \ encode_clone_maxsz + \ encode_getattr_maxsz) #define NFS4_dec_clone_sz (compound_decode_hdr_maxsz + \ decode_sequence_maxsz + \ decode_putfh_maxsz + \ decode_savefh_maxsz + \ decode_putfh_maxsz + \ decode_clone_maxsz + \ decode_getattr_maxsz) |
1c6dcbe5c NFS: Implement SEEK |
186 |
|
04a5da690 NFSv4.2: define l... |
187 188 189 190 191 192 193 194 195 196 |
/* Not limited by NFS itself, limited by the generic xattr code */ #define nfs4_xattr_name_maxsz XDR_QUADLEN(XATTR_NAME_MAX) #define encode_getxattr_maxsz (op_encode_hdr_maxsz + 1 + \ nfs4_xattr_name_maxsz) #define decode_getxattr_maxsz (op_decode_hdr_maxsz + 1 + 1) #define encode_setxattr_maxsz (op_encode_hdr_maxsz + \ 1 + nfs4_xattr_name_maxsz + 1) #define decode_setxattr_maxsz (op_decode_hdr_maxsz + decode_change_info_maxsz) #define encode_listxattrs_maxsz (op_encode_hdr_maxsz + 2 + 1) |
6c2190b3f NFS: Fix listxatt... |
197 |
#define decode_listxattrs_maxsz (op_decode_hdr_maxsz + 2 + 1 + 1 + 1) |
04a5da690 NFSv4.2: define l... |
198 199 200 201 202 203 204 205 206 207 208 209 210 211 212 213 214 215 216 217 218 219 220 221 222 223 224 225 226 227 228 229 230 231 232 233 234 235 236 237 238 239 240 241 242 243 244 245 246 247 248 249 250 251 252 253 254 255 256 257 |
#define encode_removexattr_maxsz (op_encode_hdr_maxsz + 1 + \ nfs4_xattr_name_maxsz) #define decode_removexattr_maxsz (op_decode_hdr_maxsz + \ decode_change_info_maxsz) #define NFS4_enc_getxattr_sz (compound_encode_hdr_maxsz + \ encode_sequence_maxsz + \ encode_putfh_maxsz + \ encode_getxattr_maxsz) #define NFS4_dec_getxattr_sz (compound_decode_hdr_maxsz + \ decode_sequence_maxsz + \ decode_putfh_maxsz + \ decode_getxattr_maxsz) #define NFS4_enc_setxattr_sz (compound_encode_hdr_maxsz + \ encode_sequence_maxsz + \ encode_putfh_maxsz + \ encode_setxattr_maxsz) #define NFS4_dec_setxattr_sz (compound_decode_hdr_maxsz + \ decode_sequence_maxsz + \ decode_putfh_maxsz + \ decode_setxattr_maxsz) #define NFS4_enc_listxattrs_sz (compound_encode_hdr_maxsz + \ encode_sequence_maxsz + \ encode_putfh_maxsz + \ encode_listxattrs_maxsz) #define NFS4_dec_listxattrs_sz (compound_decode_hdr_maxsz + \ decode_sequence_maxsz + \ decode_putfh_maxsz + \ decode_listxattrs_maxsz) #define NFS4_enc_removexattr_sz (compound_encode_hdr_maxsz + \ encode_sequence_maxsz + \ encode_putfh_maxsz + \ encode_removexattr_maxsz) #define NFS4_dec_removexattr_sz (compound_decode_hdr_maxsz + \ decode_sequence_maxsz + \ decode_putfh_maxsz + \ decode_removexattr_maxsz) /* * These values specify the maximum amount of data that is not * associated with the extended attribute name or extended * attribute list in the SETXATTR, GETXATTR and LISTXATTR * respectively. */ const u32 nfs42_maxsetxattr_overhead = ((RPC_MAX_HEADER_WITH_AUTH + compound_encode_hdr_maxsz + encode_sequence_maxsz + encode_putfh_maxsz + 1 + nfs4_xattr_name_maxsz) * XDR_UNIT); const u32 nfs42_maxgetxattr_overhead = ((RPC_MAX_HEADER_WITH_AUTH + compound_decode_hdr_maxsz + decode_sequence_maxsz + decode_putfh_maxsz + 1) * XDR_UNIT); const u32 nfs42_maxlistxattrs_overhead = ((RPC_MAX_HEADER_WITH_AUTH + compound_decode_hdr_maxsz + decode_sequence_maxsz + decode_putfh_maxsz + 3) * XDR_UNIT); |
04a5da690 NFSv4.2: define l... |
258 |
|
f4ac1674f nfs: Add ALLOCATE... |
259 |
static void encode_fallocate(struct xdr_stream *xdr, |
0096d39b9 nfs: fix encoder ... |
260 |
const struct nfs42_falloc_args *args) |
f4ac1674f nfs: Add ALLOCATE... |
261 262 263 264 265 266 267 |
{ encode_nfs4_stateid(xdr, &args->falloc_stateid); encode_uint64(xdr, args->falloc_offset); encode_uint64(xdr, args->falloc_length); } static void encode_allocate(struct xdr_stream *xdr, |
0096d39b9 nfs: fix encoder ... |
268 |
const struct nfs42_falloc_args *args, |
f4ac1674f nfs: Add ALLOCATE... |
269 270 271 272 273 |
struct compound_hdr *hdr) { encode_op_hdr(xdr, OP_ALLOCATE, decode_allocate_maxsz, hdr); encode_fallocate(xdr, args); } |
0491567b5 NFS: add COPY_NOT... |
274 275 276 277 278 279 280 281 282 283 284 285 286 287 288 289 290 291 292 |
static void encode_nl4_server(struct xdr_stream *xdr, const struct nl4_server *ns) { encode_uint32(xdr, ns->nl4_type); switch (ns->nl4_type) { case NL4_NAME: case NL4_URL: encode_string(xdr, ns->u.nl4_str_sz, ns->u.nl4_str); break; case NL4_NETADDR: encode_string(xdr, ns->u.nl4_addr.netid_len, ns->u.nl4_addr.netid); encode_string(xdr, ns->u.nl4_addr.addr_len, ns->u.nl4_addr.addr); break; default: WARN_ON_ONCE(1); } } |
2e72448b0 NFS: Add COPY nfs... |
293 |
static void encode_copy(struct xdr_stream *xdr, |
0096d39b9 nfs: fix encoder ... |
294 |
const struct nfs42_copy_args *args, |
2e72448b0 NFS: Add COPY nfs... |
295 296 297 298 299 300 301 302 303 304 305 |
struct compound_hdr *hdr) { encode_op_hdr(xdr, OP_COPY, decode_copy_maxsz, hdr); encode_nfs4_stateid(xdr, &args->src_stateid); encode_nfs4_stateid(xdr, &args->dst_stateid); encode_uint64(xdr, args->src_pos); encode_uint64(xdr, args->dst_pos); encode_uint64(xdr, args->count); encode_uint32(xdr, 1); /* consecutive = true */ |
62164f317 NFS add support f... |
306 |
encode_uint32(xdr, args->sync); |
1d38f3f0d NFS: add ca_sourc... |
307 308 309 310 311 312 |
if (args->cp_src == NULL) { /* intra-ssc */ encode_uint32(xdr, 0); /* no src server list */ return; } encode_uint32(xdr, 1); /* supporting 1 server */ encode_nl4_server(xdr, args->cp_src); |
2e72448b0 NFS: Add COPY nfs... |
313 |
} |
cb95deea0 NFS OFFLOAD_CANCE... |
314 315 316 317 318 319 320 |
static void encode_offload_cancel(struct xdr_stream *xdr, const struct nfs42_offload_status_args *args, struct compound_hdr *hdr) { encode_op_hdr(xdr, OP_OFFLOAD_CANCEL, decode_offload_cancel_maxsz, hdr); encode_nfs4_stateid(xdr, &args->osa_stateid); } |
0491567b5 NFS: add COPY_NOT... |
321 322 323 324 325 326 327 328 |
static void encode_copy_notify(struct xdr_stream *xdr, const struct nfs42_copy_notify_args *args, struct compound_hdr *hdr) { encode_op_hdr(xdr, OP_COPY_NOTIFY, decode_copy_notify_maxsz, hdr); encode_nfs4_stateid(xdr, &args->cna_src_stateid); encode_nl4_server(xdr, &args->cna_dst); } |
624bd5b7b nfs: Add DEALLOCA... |
329 |
static void encode_deallocate(struct xdr_stream *xdr, |
0096d39b9 nfs: fix encoder ... |
330 |
const struct nfs42_falloc_args *args, |
624bd5b7b nfs: Add DEALLOCA... |
331 332 333 334 335 |
struct compound_hdr *hdr) { encode_op_hdr(xdr, OP_DEALLOCATE, decode_deallocate_maxsz, hdr); encode_fallocate(xdr, args); } |
c56755261 NFS: Add READ_PLU... |
336 337 338 339 340 341 342 343 344 |
static void encode_read_plus(struct xdr_stream *xdr, const struct nfs_pgio_args *args, struct compound_hdr *hdr) { encode_op_hdr(xdr, OP_READ_PLUS, decode_read_plus_maxsz, hdr); encode_nfs4_stateid(xdr, &args->stateid); encode_uint64(xdr, args->offset); encode_uint32(xdr, args->count); } |
1c6dcbe5c NFS: Implement SEEK |
345 |
static void encode_seek(struct xdr_stream *xdr, |
0096d39b9 nfs: fix encoder ... |
346 |
const struct nfs42_seek_args *args, |
1c6dcbe5c NFS: Implement SEEK |
347 348 349 350 351 352 353 |
struct compound_hdr *hdr) { encode_op_hdr(xdr, OP_SEEK, decode_seek_maxsz, hdr); encode_nfs4_stateid(xdr, &args->sa_stateid); encode_uint64(xdr, args->sa_offset); encode_uint32(xdr, args->sa_what); } |
be3a5d233 NFSv.2/pnfs Add a... |
354 |
static void encode_layoutstats(struct xdr_stream *xdr, |
0096d39b9 nfs: fix encoder ... |
355 |
const struct nfs42_layoutstat_args *args, |
be3a5d233 NFSv.2/pnfs Add a... |
356 357 358 359 360 361 362 363 364 365 366 367 368 369 370 371 372 373 374 |
struct nfs42_layoutstat_devinfo *devinfo, struct compound_hdr *hdr) { __be32 *p; encode_op_hdr(xdr, OP_LAYOUTSTATS, decode_layoutstats_maxsz, hdr); p = reserve_space(xdr, 8 + 8); p = xdr_encode_hyper(p, devinfo->offset); p = xdr_encode_hyper(p, devinfo->length); encode_nfs4_stateid(xdr, &args->stateid); p = reserve_space(xdr, 4*8 + NFS4_DEVICEID4_SIZE + 4); p = xdr_encode_hyper(p, devinfo->read_count); p = xdr_encode_hyper(p, devinfo->read_bytes); p = xdr_encode_hyper(p, devinfo->write_count); p = xdr_encode_hyper(p, devinfo->write_bytes); p = xdr_encode_opaque_fixed(p, devinfo->dev_id.data, NFS4_DEVICEID4_SIZE); /* Encode layoutupdate4 */ *p++ = cpu_to_be32(devinfo->layout_type); |
422c93c88 pNFS/flexfiles: M... |
375 376 377 |
if (devinfo->ld_private.ops) devinfo->ld_private.ops->encode(xdr, args, &devinfo->ld_private); |
be3a5d233 NFSv.2/pnfs Add a... |
378 379 380 |
else encode_uint32(xdr, 0); } |
36022770d nfs42: add CLONE ... |
381 |
static void encode_clone(struct xdr_stream *xdr, |
0096d39b9 nfs: fix encoder ... |
382 |
const struct nfs42_clone_args *args, |
36022770d nfs42: add CLONE ... |
383 384 385 386 387 388 389 390 391 392 393 394 |
struct compound_hdr *hdr) { __be32 *p; encode_op_hdr(xdr, OP_CLONE, decode_clone_maxsz, hdr); encode_nfs4_stateid(xdr, &args->src_stateid); encode_nfs4_stateid(xdr, &args->dst_stateid); p = reserve_space(xdr, 3*8); p = xdr_encode_hyper(p, args->src_offset); p = xdr_encode_hyper(p, args->dst_offset); xdr_encode_hyper(p, args->count); } |
3eb86093e NFSv4.2: Add clie... |
395 396 397 398 399 400 401 402 403 404 405 406 407 408 409 410 411 412 413 414 415 416 417 418 419 420 421 |
static void encode_device_error(struct xdr_stream *xdr, const struct nfs42_device_error *error) { __be32 *p; p = reserve_space(xdr, NFS4_DEVICEID4_SIZE + 2*4); p = xdr_encode_opaque_fixed(p, error->dev_id.data, NFS4_DEVICEID4_SIZE); *p++ = cpu_to_be32(error->status); *p = cpu_to_be32(error->opnum); } static void encode_layouterror(struct xdr_stream *xdr, const struct nfs42_layout_error *args, struct compound_hdr *hdr) { __be32 *p; encode_op_hdr(xdr, OP_LAYOUTERROR, decode_layouterror_maxsz, hdr); p = reserve_space(xdr, 8 + 8); p = xdr_encode_hyper(p, args->offset); p = xdr_encode_hyper(p, args->length); encode_nfs4_stateid(xdr, &args->stateid); p = reserve_space(xdr, 4); *p = cpu_to_be32(1); encode_device_error(xdr, &args->errors[0]); } |
3e1f02123 NFSv4.2: add clie... |
422 423 424 425 426 427 428 429 430 431 432 433 434 435 436 437 438 439 440 441 442 443 444 445 446 447 448 449 450 451 452 453 454 455 456 457 458 459 460 461 462 463 464 465 466 467 468 469 470 471 472 473 474 475 476 477 478 479 480 481 482 483 484 485 486 487 488 489 490 491 492 493 494 495 496 497 498 499 500 501 502 503 504 505 506 507 508 509 510 511 512 513 514 515 516 517 518 519 |
static void encode_setxattr(struct xdr_stream *xdr, const struct nfs42_setxattrargs *arg, struct compound_hdr *hdr) { __be32 *p; BUILD_BUG_ON(XATTR_CREATE != SETXATTR4_CREATE); BUILD_BUG_ON(XATTR_REPLACE != SETXATTR4_REPLACE); encode_op_hdr(xdr, OP_SETXATTR, decode_setxattr_maxsz, hdr); p = reserve_space(xdr, 4); *p = cpu_to_be32(arg->xattr_flags); encode_string(xdr, strlen(arg->xattr_name), arg->xattr_name); p = reserve_space(xdr, 4); *p = cpu_to_be32(arg->xattr_len); if (arg->xattr_len) xdr_write_pages(xdr, arg->xattr_pages, 0, arg->xattr_len); } static int decode_setxattr(struct xdr_stream *xdr, struct nfs4_change_info *cinfo) { int status; status = decode_op_hdr(xdr, OP_SETXATTR); if (status) goto out; status = decode_change_info(xdr, cinfo); out: return status; } static void encode_getxattr(struct xdr_stream *xdr, const char *name, struct compound_hdr *hdr) { encode_op_hdr(xdr, OP_GETXATTR, decode_getxattr_maxsz, hdr); encode_string(xdr, strlen(name), name); } static int decode_getxattr(struct xdr_stream *xdr, struct nfs42_getxattrres *res, struct rpc_rqst *req) { int status; __be32 *p; u32 len, rdlen; status = decode_op_hdr(xdr, OP_GETXATTR); if (status) return status; p = xdr_inline_decode(xdr, 4); if (unlikely(!p)) return -EIO; len = be32_to_cpup(p); if (len > req->rq_rcv_buf.page_len) return -ERANGE; res->xattr_len = len; if (len > 0) { rdlen = xdr_read_pages(xdr, len); if (rdlen < len) return -EIO; } return 0; } static void encode_removexattr(struct xdr_stream *xdr, const char *name, struct compound_hdr *hdr) { encode_op_hdr(xdr, OP_REMOVEXATTR, decode_removexattr_maxsz, hdr); encode_string(xdr, strlen(name), name); } static int decode_removexattr(struct xdr_stream *xdr, struct nfs4_change_info *cinfo) { int status; status = decode_op_hdr(xdr, OP_REMOVEXATTR); if (status) goto out; status = decode_change_info(xdr, cinfo); out: return status; } static void encode_listxattrs(struct xdr_stream *xdr, const struct nfs42_listxattrsargs *arg, struct compound_hdr *hdr) { __be32 *p; |
6c2190b3f NFS: Fix listxatt... |
520 |
encode_op_hdr(xdr, OP_LISTXATTRS, decode_listxattrs_maxsz, hdr); |
3e1f02123 NFSv4.2: add clie... |
521 522 523 524 525 526 527 528 529 530 531 532 533 534 535 536 537 538 539 540 541 542 543 544 545 546 547 548 549 550 551 552 553 554 555 556 557 558 559 560 561 562 563 564 565 566 567 568 569 570 571 572 573 574 575 576 577 578 579 580 581 582 583 584 585 586 587 588 589 590 591 592 593 594 595 596 597 598 599 600 601 602 603 604 605 606 607 608 609 610 611 612 613 614 615 616 617 618 619 620 621 622 623 |
p = reserve_space(xdr, 12); if (unlikely(!p)) return; p = xdr_encode_hyper(p, arg->cookie); /* * RFC 8276 says to specify the full max length of the LISTXATTRS * XDR reply. Count is set to the XDR length of the names array * plus the EOF marker. So, add the cookie and the names count. */ *p = cpu_to_be32(arg->count + 8 + 4); } static int decode_listxattrs(struct xdr_stream *xdr, struct nfs42_listxattrsres *res) { int status; __be32 *p; u32 count, len, ulen; size_t left, copied; char *buf; status = decode_op_hdr(xdr, OP_LISTXATTRS); if (status) { /* * Special case: for LISTXATTRS, NFS4ERR_TOOSMALL * should be translated to ERANGE. */ if (status == -ETOOSMALL) status = -ERANGE; goto out; } p = xdr_inline_decode(xdr, 8); if (unlikely(!p)) return -EIO; xdr_decode_hyper(p, &res->cookie); p = xdr_inline_decode(xdr, 4); if (unlikely(!p)) return -EIO; left = res->xattr_len; buf = res->xattr_buf; count = be32_to_cpup(p); copied = 0; /* * We have asked for enough room to encode the maximum number * of possible attribute names, so everything should fit. * * But, don't rely on that assumption. Just decode entries * until they don't fit anymore, just in case the server did * something odd. */ while (count--) { p = xdr_inline_decode(xdr, 4); if (unlikely(!p)) return -EIO; len = be32_to_cpup(p); if (len > (XATTR_NAME_MAX - XATTR_USER_PREFIX_LEN)) { status = -ERANGE; goto out; } p = xdr_inline_decode(xdr, len); if (unlikely(!p)) return -EIO; ulen = len + XATTR_USER_PREFIX_LEN + 1; if (buf) { if (ulen > left) { status = -ERANGE; goto out; } memcpy(buf, XATTR_USER_PREFIX, XATTR_USER_PREFIX_LEN); memcpy(buf + XATTR_USER_PREFIX_LEN, p, len); buf[ulen - 1] = 0; buf += ulen; left -= ulen; } copied += ulen; } p = xdr_inline_decode(xdr, 4); if (unlikely(!p)) return -EIO; res->eof = be32_to_cpup(p); res->copied = copied; out: if (status == -ERANGE && res->xattr_len == XATTR_LIST_MAX) status = -E2BIG; return status; } |
1c6dcbe5c NFS: Implement SEEK |
624 |
/* |
f4ac1674f nfs: Add ALLOCATE... |
625 626 627 628 |
* Encode ALLOCATE request */ static void nfs4_xdr_enc_allocate(struct rpc_rqst *req, struct xdr_stream *xdr, |
0096d39b9 nfs: fix encoder ... |
629 |
const void *data) |
f4ac1674f nfs: Add ALLOCATE... |
630 |
{ |
0096d39b9 nfs: fix encoder ... |
631 |
const struct nfs42_falloc_args *args = data; |
f4ac1674f nfs: Add ALLOCATE... |
632 633 634 635 636 637 638 639 |
struct compound_hdr hdr = { .minorversion = nfs4_xdr_minorversion(&args->seq_args), }; encode_compound_hdr(xdr, req, &hdr); encode_sequence(xdr, &args->seq_args, &hdr); encode_putfh(xdr, args->falloc_fh, &hdr); encode_allocate(xdr, args, &hdr); |
9a51940bf NFS: Don't zap ca... |
640 |
encode_getfattr(xdr, args->falloc_bitmask, &hdr); |
f4ac1674f nfs: Add ALLOCATE... |
641 642 |
encode_nops(&hdr); } |
e09269344 NFS append COMMIT... |
643 |
static void encode_copy_commit(struct xdr_stream *xdr, |
0096d39b9 nfs: fix encoder ... |
644 |
const struct nfs42_copy_args *args, |
e09269344 NFS append COMMIT... |
645 646 647 648 649 650 651 652 653 |
struct compound_hdr *hdr) { __be32 *p; encode_op_hdr(xdr, OP_COMMIT, decode_commit_maxsz, hdr); p = reserve_space(xdr, 12); p = xdr_encode_hyper(p, args->dst_pos); *p = cpu_to_be32(args->count); } |
f4ac1674f nfs: Add ALLOCATE... |
654 |
/* |
2e72448b0 NFS: Add COPY nfs... |
655 656 657 658 |
* Encode COPY request */ static void nfs4_xdr_enc_copy(struct rpc_rqst *req, struct xdr_stream *xdr, |
0096d39b9 nfs: fix encoder ... |
659 |
const void *data) |
2e72448b0 NFS: Add COPY nfs... |
660 |
{ |
0096d39b9 nfs: fix encoder ... |
661 |
const struct nfs42_copy_args *args = data; |
2e72448b0 NFS: Add COPY nfs... |
662 663 664 665 666 667 668 669 670 671 |
struct compound_hdr hdr = { .minorversion = nfs4_xdr_minorversion(&args->seq_args), }; encode_compound_hdr(xdr, req, &hdr); encode_sequence(xdr, &args->seq_args, &hdr); encode_putfh(xdr, args->src_fh, &hdr); encode_savefh(xdr, &hdr); encode_putfh(xdr, args->dst_fh, &hdr); encode_copy(xdr, args, &hdr); |
62164f317 NFS add support f... |
672 673 |
if (args->sync) encode_copy_commit(xdr, args, &hdr); |
2e72448b0 NFS: Add COPY nfs... |
674 675 676 677 |
encode_nops(&hdr); } /* |
cb95deea0 NFS OFFLOAD_CANCE... |
678 679 680 681 682 683 684 685 686 687 688 689 690 691 692 693 694 695 696 |
* Encode OFFLOAD_CANEL request */ static void nfs4_xdr_enc_offload_cancel(struct rpc_rqst *req, struct xdr_stream *xdr, const void *data) { const struct nfs42_offload_status_args *args = data; struct compound_hdr hdr = { .minorversion = nfs4_xdr_minorversion(&args->osa_seq_args), }; encode_compound_hdr(xdr, req, &hdr); encode_sequence(xdr, &args->osa_seq_args, &hdr); encode_putfh(xdr, args->osa_src_fh, &hdr); encode_offload_cancel(xdr, args, &hdr); encode_nops(&hdr); } /* |
0491567b5 NFS: add COPY_NOT... |
697 698 699 700 701 702 703 704 705 706 707 708 709 710 711 712 713 714 715 |
* Encode COPY_NOTIFY request */ static void nfs4_xdr_enc_copy_notify(struct rpc_rqst *req, struct xdr_stream *xdr, const void *data) { const struct nfs42_copy_notify_args *args = data; struct compound_hdr hdr = { .minorversion = nfs4_xdr_minorversion(&args->cna_seq_args), }; encode_compound_hdr(xdr, req, &hdr); encode_sequence(xdr, &args->cna_seq_args, &hdr); encode_putfh(xdr, args->cna_src_fh, &hdr); encode_copy_notify(xdr, args, &hdr); encode_nops(&hdr); } /* |
624bd5b7b nfs: Add DEALLOCA... |
716 717 718 719 |
* Encode DEALLOCATE request */ static void nfs4_xdr_enc_deallocate(struct rpc_rqst *req, struct xdr_stream *xdr, |
0096d39b9 nfs: fix encoder ... |
720 |
const void *data) |
624bd5b7b nfs: Add DEALLOCA... |
721 |
{ |
0096d39b9 nfs: fix encoder ... |
722 |
const struct nfs42_falloc_args *args = data; |
624bd5b7b nfs: Add DEALLOCA... |
723 724 725 726 727 728 729 730 |
struct compound_hdr hdr = { .minorversion = nfs4_xdr_minorversion(&args->seq_args), }; encode_compound_hdr(xdr, req, &hdr); encode_sequence(xdr, &args->seq_args, &hdr); encode_putfh(xdr, args->falloc_fh, &hdr); encode_deallocate(xdr, args, &hdr); |
9a51940bf NFS: Don't zap ca... |
731 |
encode_getfattr(xdr, args->falloc_bitmask, &hdr); |
624bd5b7b nfs: Add DEALLOCA... |
732 733 734 735 |
encode_nops(&hdr); } /* |
c56755261 NFS: Add READ_PLU... |
736 737 738 739 740 741 742 743 744 745 746 747 748 749 750 751 752 753 754 755 756 757 |
* Encode READ_PLUS request */ static void nfs4_xdr_enc_read_plus(struct rpc_rqst *req, struct xdr_stream *xdr, const void *data) { const struct nfs_pgio_args *args = data; struct compound_hdr hdr = { .minorversion = nfs4_xdr_minorversion(&args->seq_args), }; encode_compound_hdr(xdr, req, &hdr); encode_sequence(xdr, &args->seq_args, &hdr); encode_putfh(xdr, args->fh, &hdr); encode_read_plus(xdr, args, &hdr); rpc_prepare_reply_pages(req, args->pages, args->pgbase, args->count, hdr.replen); encode_nops(&hdr); } /* |
1c6dcbe5c NFS: Implement SEEK |
758 759 760 761 |
* Encode SEEK request */ static void nfs4_xdr_enc_seek(struct rpc_rqst *req, struct xdr_stream *xdr, |
0096d39b9 nfs: fix encoder ... |
762 |
const void *data) |
1c6dcbe5c NFS: Implement SEEK |
763 |
{ |
0096d39b9 nfs: fix encoder ... |
764 |
const struct nfs42_seek_args *args = data; |
1c6dcbe5c NFS: Implement SEEK |
765 766 767 768 769 770 771 772 773 774 |
struct compound_hdr hdr = { .minorversion = nfs4_xdr_minorversion(&args->seq_args), }; encode_compound_hdr(xdr, req, &hdr); encode_sequence(xdr, &args->seq_args, &hdr); encode_putfh(xdr, args->sa_fh, &hdr); encode_seek(xdr, args, &hdr); encode_nops(&hdr); } |
be3a5d233 NFSv.2/pnfs Add a... |
775 776 777 778 779 |
/* * Encode LAYOUTSTATS request */ static void nfs4_xdr_enc_layoutstats(struct rpc_rqst *req, struct xdr_stream *xdr, |
0096d39b9 nfs: fix encoder ... |
780 |
const void *data) |
be3a5d233 NFSv.2/pnfs Add a... |
781 |
{ |
0096d39b9 nfs: fix encoder ... |
782 |
const struct nfs42_layoutstat_args *args = data; |
be3a5d233 NFSv.2/pnfs Add a... |
783 784 785 786 787 788 789 790 791 792 793 794 795 796 |
int i; struct compound_hdr hdr = { .minorversion = nfs4_xdr_minorversion(&args->seq_args), }; encode_compound_hdr(xdr, req, &hdr); encode_sequence(xdr, &args->seq_args, &hdr); encode_putfh(xdr, args->fh, &hdr); WARN_ON(args->num_dev > PNFS_LAYOUTSTATS_MAXDEV); for (i = 0; i < args->num_dev; i++) encode_layoutstats(xdr, args, &args->devinfo[i], &hdr); encode_nops(&hdr); } |
36022770d nfs42: add CLONE ... |
797 798 799 800 801 |
/* * Encode CLONE request */ static void nfs4_xdr_enc_clone(struct rpc_rqst *req, struct xdr_stream *xdr, |
0096d39b9 nfs: fix encoder ... |
802 |
const void *data) |
36022770d nfs42: add CLONE ... |
803 |
{ |
0096d39b9 nfs: fix encoder ... |
804 |
const struct nfs42_clone_args *args = data; |
36022770d nfs42: add CLONE ... |
805 806 807 808 809 810 811 812 813 814 815 816 817 |
struct compound_hdr hdr = { .minorversion = nfs4_xdr_minorversion(&args->seq_args), }; encode_compound_hdr(xdr, req, &hdr); encode_sequence(xdr, &args->seq_args, &hdr); encode_putfh(xdr, args->src_fh, &hdr); encode_savefh(xdr, &hdr); encode_putfh(xdr, args->dst_fh, &hdr); encode_clone(xdr, args, &hdr); encode_getfattr(xdr, args->dst_bitmask, &hdr); encode_nops(&hdr); } |
3eb86093e NFSv4.2: Add clie... |
818 819 820 821 822 823 824 825 826 827 828 829 830 831 832 833 834 835 836 837 |
/* * Encode LAYOUTERROR request */ static void nfs4_xdr_enc_layouterror(struct rpc_rqst *req, struct xdr_stream *xdr, const void *data) { const struct nfs42_layouterror_args *args = data; struct compound_hdr hdr = { .minorversion = nfs4_xdr_minorversion(&args->seq_args), }; int i; encode_compound_hdr(xdr, req, &hdr); encode_sequence(xdr, &args->seq_args, &hdr); encode_putfh(xdr, NFS_FH(args->inode), &hdr); for (i = 0; i < args->num_errors; i++) encode_layouterror(xdr, &args->errors[i], &hdr); encode_nops(&hdr); } |
f4ac1674f nfs: Add ALLOCATE... |
838 839 840 841 |
static int decode_allocate(struct xdr_stream *xdr, struct nfs42_falloc_res *res) { return decode_op_hdr(xdr, OP_ALLOCATE); } |
2e72448b0 NFS: Add COPY nfs... |
842 843 844 845 |
static int decode_write_response(struct xdr_stream *xdr, struct nfs42_write_res *res) { __be32 *p; |
67aa7444c NFS COPY xdr hand... |
846 |
int status, count; |
2e72448b0 NFS: Add COPY nfs... |
847 |
|
67aa7444c NFS COPY xdr hand... |
848 |
p = xdr_inline_decode(xdr, 4); |
2e72448b0 NFS: Add COPY nfs... |
849 |
if (unlikely(!p)) |
eb72f484a NFS: Remove print... |
850 |
return -EIO; |
67aa7444c NFS COPY xdr hand... |
851 852 |
count = be32_to_cpup(p); if (count > 1) |
6fdf339b0 NFSv4.2: Fix warn... |
853 |
return -EREMOTEIO; |
67aa7444c NFS COPY xdr hand... |
854 855 856 857 |
else if (count == 1) { status = decode_opaque_fixed(xdr, &res->stateid, NFS4_STATEID_SIZE); if (unlikely(status)) |
eb72f484a NFS: Remove print... |
858 |
return -EIO; |
6fdf339b0 NFSv4.2: Fix warn... |
859 |
} |
67aa7444c NFS COPY xdr hand... |
860 861 |
p = xdr_inline_decode(xdr, 8 + 4); if (unlikely(!p)) |
eb72f484a NFS: Remove print... |
862 |
return -EIO; |
2e72448b0 NFS: Add COPY nfs... |
863 864 865 |
p = xdr_decode_hyper(p, &res->count); res->verifier.committed = be32_to_cpup(p); return decode_verifier(xdr, &res->verifier.verifier); |
2e72448b0 NFS: Add COPY nfs... |
866 |
} |
0491567b5 NFS: add COPY_NOT... |
867 868 869 870 871 872 873 874 875 876 877 878 879 880 881 882 883 884 885 886 887 888 889 890 891 892 893 894 895 896 897 898 899 900 901 902 903 904 905 906 907 908 909 910 911 912 913 914 915 916 917 |
static int decode_nl4_server(struct xdr_stream *xdr, struct nl4_server *ns) { struct nfs42_netaddr *naddr; uint32_t dummy; char *dummy_str; __be32 *p; int status; /* nl_type */ p = xdr_inline_decode(xdr, 4); if (unlikely(!p)) return -EIO; ns->nl4_type = be32_to_cpup(p); switch (ns->nl4_type) { case NL4_NAME: case NL4_URL: status = decode_opaque_inline(xdr, &dummy, &dummy_str); if (unlikely(status)) return status; if (unlikely(dummy > NFS4_OPAQUE_LIMIT)) return -EIO; memcpy(&ns->u.nl4_str, dummy_str, dummy); ns->u.nl4_str_sz = dummy; break; case NL4_NETADDR: naddr = &ns->u.nl4_addr; /* netid string */ status = decode_opaque_inline(xdr, &dummy, &dummy_str); if (unlikely(status)) return status; if (unlikely(dummy > RPCBIND_MAXNETIDLEN)) return -EIO; naddr->netid_len = dummy; memcpy(naddr->netid, dummy_str, naddr->netid_len); /* uaddr string */ status = decode_opaque_inline(xdr, &dummy, &dummy_str); if (unlikely(status)) return status; if (unlikely(dummy > RPCBIND_MAXUADDRLEN)) return -EIO; naddr->addr_len = dummy; memcpy(naddr->addr, dummy_str, naddr->addr_len); break; default: WARN_ON_ONCE(1); return -EIO; } return 0; } |
2e72448b0 NFS: Add COPY nfs... |
918 919 920 921 922 923 |
static int decode_copy_requirements(struct xdr_stream *xdr, struct nfs42_copy_res *res) { __be32 *p; p = xdr_inline_decode(xdr, 4 + 4); if (unlikely(!p)) |
eb72f484a NFS: Remove print... |
924 |
return -EIO; |
2e72448b0 NFS: Add COPY nfs... |
925 926 927 928 |
res->consecutive = be32_to_cpup(p++); res->synchronous = be32_to_cpup(p++); return 0; |
2e72448b0 NFS: Add COPY nfs... |
929 930 931 932 933 934 935 936 937 938 939 940 941 942 943 944 945 946 947 948 949 |
} static int decode_copy(struct xdr_stream *xdr, struct nfs42_copy_res *res) { int status; status = decode_op_hdr(xdr, OP_COPY); if (status == NFS4ERR_OFFLOAD_NO_REQS) { status = decode_copy_requirements(xdr, res); if (status) return status; return NFS4ERR_OFFLOAD_NO_REQS; } else if (status) return status; status = decode_write_response(xdr, &res->write_res); if (status) return status; return decode_copy_requirements(xdr, res); } |
cb95deea0 NFS OFFLOAD_CANCE... |
950 951 952 953 954 |
static int decode_offload_cancel(struct xdr_stream *xdr, struct nfs42_offload_status_res *res) { return decode_op_hdr(xdr, OP_OFFLOAD_CANCEL); } |
0491567b5 NFS: add COPY_NOT... |
955 956 957 958 959 960 961 962 963 964 965 966 967 968 969 970 971 972 973 974 975 976 977 978 979 980 981 982 983 984 985 986 987 988 989 990 |
static int decode_copy_notify(struct xdr_stream *xdr, struct nfs42_copy_notify_res *res) { __be32 *p; int status, count; status = decode_op_hdr(xdr, OP_COPY_NOTIFY); if (status) return status; /* cnr_lease_time */ p = xdr_inline_decode(xdr, 12); if (unlikely(!p)) return -EIO; p = xdr_decode_hyper(p, &res->cnr_lease_time.seconds); res->cnr_lease_time.nseconds = be32_to_cpup(p); status = decode_opaque_fixed(xdr, &res->cnr_stateid, NFS4_STATEID_SIZE); if (unlikely(status)) return -EIO; /* number of source addresses */ p = xdr_inline_decode(xdr, 4); if (unlikely(!p)) return -EIO; count = be32_to_cpup(p); if (count > 1) pr_warn("NFS: %s: nsvr %d > Supported. Use first servers ", __func__, count); status = decode_nl4_server(xdr, &res->cnr_src); if (unlikely(status)) return -EIO; return 0; } |
624bd5b7b nfs: Add DEALLOCA... |
991 992 993 994 |
static int decode_deallocate(struct xdr_stream *xdr, struct nfs42_falloc_res *res) { return decode_op_hdr(xdr, OP_DEALLOCATE); } |
8bcfa178f NFSv4.2: Don't er... |
995 996 |
static int decode_read_plus_data(struct xdr_stream *xdr, struct nfs_pgio_res *res) |
c56755261 NFS: Add READ_PLU... |
997 998 999 1000 1001 1002 |
{ uint32_t count, recvd; uint64_t offset; __be32 *p; p = xdr_inline_decode(xdr, 8 + 4); |
8bcfa178f NFSv4.2: Don't er... |
1003 1004 |
if (!p) return 1; |
c56755261 NFS: Add READ_PLU... |
1005 1006 1007 |
p = xdr_decode_hyper(p, &offset); count = be32_to_cpup(p); |
bff049a3b NFS: Decode a ful... |
1008 |
recvd = xdr_align_data(xdr, res->count, count); |
c56755261 NFS: Add READ_PLU... |
1009 |
res->count += recvd; |
8bcfa178f NFSv4.2: Don't er... |
1010 |
if (count > recvd) |
c56755261 NFS: Add READ_PLU... |
1011 |
return 1; |
c56755261 NFS: Add READ_PLU... |
1012 1013 |
return 0; } |
c05eafad6 NFS: Add READ_PLU... |
1014 1015 1016 1017 1018 1019 1020 |
static int decode_read_plus_hole(struct xdr_stream *xdr, struct nfs_pgio_res *res, uint32_t *eof) { uint64_t offset, length, recvd; __be32 *p; p = xdr_inline_decode(xdr, 8 + 8); |
8bcfa178f NFSv4.2: Don't er... |
1021 1022 |
if (!p) return 1; |
c05eafad6 NFS: Add READ_PLU... |
1023 1024 1025 |
p = xdr_decode_hyper(p, &offset); p = xdr_decode_hyper(p, &length); |
bff049a3b NFS: Decode a ful... |
1026 |
recvd = xdr_expand_hole(xdr, res->count, length); |
c05eafad6 NFS: Add READ_PLU... |
1027 |
res->count += recvd; |
8bcfa178f NFSv4.2: Don't er... |
1028 |
if (recvd < length) |
c05eafad6 NFS: Add READ_PLU... |
1029 |
return 1; |
c05eafad6 NFS: Add READ_PLU... |
1030 1031 |
return 0; } |
c56755261 NFS: Add READ_PLU... |
1032 1033 1034 |
static int decode_read_plus(struct xdr_stream *xdr, struct nfs_pgio_res *res) { uint32_t eof, segments, type; |
bff049a3b NFS: Decode a ful... |
1035 |
int status, i; |
c56755261 NFS: Add READ_PLU... |
1036 1037 1038 1039 1040 1041 1042 1043 1044 1045 1046 1047 1048 1049 |
__be32 *p; status = decode_op_hdr(xdr, OP_READ_PLUS); if (status) return status; p = xdr_inline_decode(xdr, 4 + 4); if (unlikely(!p)) return -EIO; eof = be32_to_cpup(p++); segments = be32_to_cpup(p++); if (segments == 0) goto out; |
bff049a3b NFS: Decode a ful... |
1050 1051 |
for (i = 0; i < segments; i++) { p = xdr_inline_decode(xdr, 4); |
8bcfa178f NFSv4.2: Don't er... |
1052 1053 |
if (!p) goto early_out; |
c56755261 NFS: Add READ_PLU... |
1054 |
|
bff049a3b NFS: Decode a ful... |
1055 1056 |
type = be32_to_cpup(p++); if (type == NFS4_CONTENT_DATA) |
8bcfa178f NFSv4.2: Don't er... |
1057 |
status = decode_read_plus_data(xdr, res); |
bff049a3b NFS: Decode a ful... |
1058 1059 1060 1061 |
else if (type == NFS4_CONTENT_HOLE) status = decode_read_plus_hole(xdr, res, &eof); else return -EINVAL; |
c56755261 NFS: Add READ_PLU... |
1062 |
|
bff049a3b NFS: Decode a ful... |
1063 1064 1065 |
if (status < 0) return status; if (status > 0) |
8bcfa178f NFSv4.2: Don't er... |
1066 |
goto early_out; |
bff049a3b NFS: Decode a ful... |
1067 |
} |
c56755261 NFS: Add READ_PLU... |
1068 1069 1070 1071 |
out: res->eof = eof; return 0; |
8bcfa178f NFSv4.2: Don't er... |
1072 1073 1074 1075 1076 |
early_out: if (unlikely(!i)) return -EIO; res->eof = 0; return 0; |
c56755261 NFS: Add READ_PLU... |
1077 |
} |
1c6dcbe5c NFS: Implement SEEK |
1078 1079 1080 1081 1082 1083 1084 1085 1086 1087 1088 |
static int decode_seek(struct xdr_stream *xdr, struct nfs42_seek_res *res) { int status; __be32 *p; status = decode_op_hdr(xdr, OP_SEEK); if (status) return status; p = xdr_inline_decode(xdr, 4 + 8); if (unlikely(!p)) |
eb72f484a NFS: Remove print... |
1089 |
return -EIO; |
1c6dcbe5c NFS: Implement SEEK |
1090 1091 1092 1093 |
res->sr_eof = be32_to_cpup(p++); p = xdr_decode_hyper(p, &res->sr_offset); return 0; |
1c6dcbe5c NFS: Implement SEEK |
1094 |
} |
19cf63351 nfs42: decode_lay... |
1095 |
static int decode_layoutstats(struct xdr_stream *xdr) |
be3a5d233 NFSv.2/pnfs Add a... |
1096 |
{ |
da2e81275 NFSv4.2: Fix up a... |
1097 |
return decode_op_hdr(xdr, OP_LAYOUTSTATS); |
be3a5d233 NFSv.2/pnfs Add a... |
1098 |
} |
36022770d nfs42: add CLONE ... |
1099 1100 1101 1102 |
static int decode_clone(struct xdr_stream *xdr) { return decode_op_hdr(xdr, OP_CLONE); } |
3eb86093e NFSv4.2: Add clie... |
1103 1104 1105 1106 |
static int decode_layouterror(struct xdr_stream *xdr) { return decode_op_hdr(xdr, OP_LAYOUTERROR); } |
1c6dcbe5c NFS: Implement SEEK |
1107 |
/* |
f4ac1674f nfs: Add ALLOCATE... |
1108 1109 1110 1111 |
* Decode ALLOCATE request */ static int nfs4_xdr_dec_allocate(struct rpc_rqst *rqstp, struct xdr_stream *xdr, |
18d9cff40 nfs: fix decoder ... |
1112 |
void *data) |
f4ac1674f nfs: Add ALLOCATE... |
1113 |
{ |
18d9cff40 nfs: fix decoder ... |
1114 |
struct nfs42_falloc_res *res = data; |
f4ac1674f nfs: Add ALLOCATE... |
1115 1116 1117 1118 1119 1120 1121 1122 1123 1124 1125 1126 1127 |
struct compound_hdr hdr; int status; status = decode_compound_hdr(xdr, &hdr); if (status) goto out; status = decode_sequence(xdr, &res->seq_res, rqstp); if (status) goto out; status = decode_putfh(xdr); if (status) goto out; status = decode_allocate(xdr, res); |
9a51940bf NFS: Don't zap ca... |
1128 1129 1130 |
if (status) goto out; decode_getfattr(xdr, res->falloc_fattr, res->falloc_server); |
f4ac1674f nfs: Add ALLOCATE... |
1131 1132 1133 1134 1135 |
out: return status; } /* |
2e72448b0 NFS: Add COPY nfs... |
1136 1137 1138 1139 |
* Decode COPY response */ static int nfs4_xdr_dec_copy(struct rpc_rqst *rqstp, struct xdr_stream *xdr, |
18d9cff40 nfs: fix decoder ... |
1140 |
void *data) |
2e72448b0 NFS: Add COPY nfs... |
1141 |
{ |
18d9cff40 nfs: fix decoder ... |
1142 |
struct nfs42_copy_res *res = data; |
2e72448b0 NFS: Add COPY nfs... |
1143 1144 1145 1146 1147 1148 1149 1150 1151 1152 1153 1154 1155 1156 1157 1158 1159 1160 1161 |
struct compound_hdr hdr; int status; status = decode_compound_hdr(xdr, &hdr); if (status) goto out; status = decode_sequence(xdr, &res->seq_res, rqstp); if (status) goto out; status = decode_putfh(xdr); if (status) goto out; status = decode_savefh(xdr); if (status) goto out; status = decode_putfh(xdr); if (status) goto out; status = decode_copy(xdr, res); |
e09269344 NFS append COMMIT... |
1162 1163 |
if (status) goto out; |
62164f317 NFS add support f... |
1164 1165 |
if (res->commit_res.verf) status = decode_commit(xdr, &res->commit_res); |
2e72448b0 NFS: Add COPY nfs... |
1166 1167 1168 1169 1170 |
out: return status; } /* |
cb95deea0 NFS OFFLOAD_CANCE... |
1171 1172 1173 1174 1175 1176 1177 1178 1179 1180 1181 1182 1183 1184 1185 1186 1187 1188 1189 1190 1191 1192 1193 1194 1195 1196 |
* Decode OFFLOAD_CANCEL response */ static int nfs4_xdr_dec_offload_cancel(struct rpc_rqst *rqstp, struct xdr_stream *xdr, void *data) { struct nfs42_offload_status_res *res = data; struct compound_hdr hdr; int status; status = decode_compound_hdr(xdr, &hdr); if (status) goto out; status = decode_sequence(xdr, &res->osr_seq_res, rqstp); if (status) goto out; status = decode_putfh(xdr); if (status) goto out; status = decode_offload_cancel(xdr, res); out: return status; } /* |
0491567b5 NFS: add COPY_NOT... |
1197 1198 1199 1200 1201 1202 1203 1204 1205 1206 1207 1208 1209 1210 1211 1212 1213 1214 1215 1216 1217 1218 1219 1220 1221 1222 |
* Decode COPY_NOTIFY response */ static int nfs4_xdr_dec_copy_notify(struct rpc_rqst *rqstp, struct xdr_stream *xdr, void *data) { struct nfs42_copy_notify_res *res = data; struct compound_hdr hdr; int status; status = decode_compound_hdr(xdr, &hdr); if (status) goto out; status = decode_sequence(xdr, &res->cnr_seq_res, rqstp); if (status) goto out; status = decode_putfh(xdr); if (status) goto out; status = decode_copy_notify(xdr, res); out: return status; } /* |
624bd5b7b nfs: Add DEALLOCA... |
1223 1224 1225 1226 |
* Decode DEALLOCATE request */ static int nfs4_xdr_dec_deallocate(struct rpc_rqst *rqstp, struct xdr_stream *xdr, |
18d9cff40 nfs: fix decoder ... |
1227 |
void *data) |
624bd5b7b nfs: Add DEALLOCA... |
1228 |
{ |
18d9cff40 nfs: fix decoder ... |
1229 |
struct nfs42_falloc_res *res = data; |
624bd5b7b nfs: Add DEALLOCA... |
1230 1231 1232 1233 1234 1235 1236 1237 1238 1239 1240 1241 1242 |
struct compound_hdr hdr; int status; status = decode_compound_hdr(xdr, &hdr); if (status) goto out; status = decode_sequence(xdr, &res->seq_res, rqstp); if (status) goto out; status = decode_putfh(xdr); if (status) goto out; status = decode_deallocate(xdr, res); |
9a51940bf NFS: Don't zap ca... |
1243 1244 1245 |
if (status) goto out; decode_getfattr(xdr, res->falloc_fattr, res->falloc_server); |
624bd5b7b nfs: Add DEALLOCA... |
1246 1247 1248 1249 1250 |
out: return status; } /* |
c56755261 NFS: Add READ_PLU... |
1251 1252 1253 1254 1255 1256 1257 1258 1259 1260 1261 1262 1263 1264 1265 1266 1267 1268 1269 1270 1271 1272 1273 1274 1275 1276 1277 |
* Decode READ_PLUS request */ static int nfs4_xdr_dec_read_plus(struct rpc_rqst *rqstp, struct xdr_stream *xdr, void *data) { struct nfs_pgio_res *res = data; struct compound_hdr hdr; int status; status = decode_compound_hdr(xdr, &hdr); if (status) goto out; status = decode_sequence(xdr, &res->seq_res, rqstp); if (status) goto out; status = decode_putfh(xdr); if (status) goto out; status = decode_read_plus(xdr, res); if (!status) status = res->count; out: return status; } /* |
1c6dcbe5c NFS: Implement SEEK |
1278 1279 1280 1281 |
* Decode SEEK request */ static int nfs4_xdr_dec_seek(struct rpc_rqst *rqstp, struct xdr_stream *xdr, |
18d9cff40 nfs: fix decoder ... |
1282 |
void *data) |
1c6dcbe5c NFS: Implement SEEK |
1283 |
{ |
18d9cff40 nfs: fix decoder ... |
1284 |
struct nfs42_seek_res *res = data; |
1c6dcbe5c NFS: Implement SEEK |
1285 1286 1287 1288 1289 1290 1291 1292 1293 1294 1295 1296 1297 1298 1299 1300 |
struct compound_hdr hdr; int status; status = decode_compound_hdr(xdr, &hdr); if (status) goto out; status = decode_sequence(xdr, &res->seq_res, rqstp); if (status) goto out; status = decode_putfh(xdr); if (status) goto out; status = decode_seek(xdr, res); out: return status; } |
be3a5d233 NFSv.2/pnfs Add a... |
1301 1302 1303 1304 1305 1306 |
/* * Decode LAYOUTSTATS request */ static int nfs4_xdr_dec_layoutstats(struct rpc_rqst *rqstp, struct xdr_stream *xdr, |
18d9cff40 nfs: fix decoder ... |
1307 |
void *data) |
be3a5d233 NFSv.2/pnfs Add a... |
1308 |
{ |
18d9cff40 nfs: fix decoder ... |
1309 |
struct nfs42_layoutstat_res *res = data; |
be3a5d233 NFSv.2/pnfs Add a... |
1310 1311 1312 1313 1314 1315 1316 1317 1318 1319 1320 1321 1322 1323 |
struct compound_hdr hdr; int status, i; status = decode_compound_hdr(xdr, &hdr); if (status) goto out; status = decode_sequence(xdr, &res->seq_res, rqstp); if (status) goto out; status = decode_putfh(xdr); if (status) goto out; WARN_ON(res->num_dev > PNFS_LAYOUTSTATS_MAXDEV); for (i = 0; i < res->num_dev; i++) { |
19cf63351 nfs42: decode_lay... |
1324 |
status = decode_layoutstats(xdr); |
be3a5d233 NFSv.2/pnfs Add a... |
1325 1326 1327 1328 1329 1330 1331 |
if (status) goto out; } out: res->rpc_status = status; return status; } |
36022770d nfs42: add CLONE ... |
1332 1333 1334 1335 1336 |
/* * Decode CLONE request */ static int nfs4_xdr_dec_clone(struct rpc_rqst *rqstp, struct xdr_stream *xdr, |
18d9cff40 nfs: fix decoder ... |
1337 |
void *data) |
36022770d nfs42: add CLONE ... |
1338 |
{ |
18d9cff40 nfs: fix decoder ... |
1339 |
struct nfs42_clone_res *res = data; |
36022770d nfs42: add CLONE ... |
1340 1341 1342 1343 1344 1345 1346 1347 1348 1349 1350 1351 1352 1353 1354 1355 1356 1357 1358 1359 1360 1361 1362 1363 1364 1365 1366 |
struct compound_hdr hdr; int status; status = decode_compound_hdr(xdr, &hdr); if (status) goto out; status = decode_sequence(xdr, &res->seq_res, rqstp); if (status) goto out; status = decode_putfh(xdr); if (status) goto out; status = decode_savefh(xdr); if (status) goto out; status = decode_putfh(xdr); if (status) goto out; status = decode_clone(xdr); if (status) goto out; status = decode_getfattr(xdr, res->dst_fattr, res->server); out: res->rpc_status = status; return status; } |
3eb86093e NFSv4.2: Add clie... |
1367 1368 1369 1370 1371 1372 1373 1374 1375 1376 1377 1378 1379 1380 1381 1382 1383 1384 1385 1386 1387 1388 1389 1390 1391 |
/* * Decode LAYOUTERROR request */ static int nfs4_xdr_dec_layouterror(struct rpc_rqst *rqstp, struct xdr_stream *xdr, void *data) { struct nfs42_layouterror_res *res = data; struct compound_hdr hdr; int status, i; status = decode_compound_hdr(xdr, &hdr); if (status) goto out; status = decode_sequence(xdr, &res->seq_res, rqstp); if (status) goto out; status = decode_putfh(xdr); for (i = 0; i < res->num_errors && status == 0; i++) status = decode_layouterror(xdr); out: res->rpc_status = status; return status; } |
3e1f02123 NFSv4.2: add clie... |
1392 1393 1394 1395 1396 1397 1398 1399 1400 1401 1402 1403 1404 1405 1406 1407 1408 1409 1410 1411 1412 1413 1414 1415 1416 1417 1418 1419 1420 1421 1422 1423 1424 1425 1426 1427 1428 1429 1430 1431 1432 1433 1434 1435 1436 1437 1438 1439 1440 1441 1442 1443 1444 1445 1446 1447 1448 1449 1450 1451 1452 1453 1454 1455 1456 1457 1458 1459 1460 1461 1462 1463 1464 1465 1466 1467 1468 1469 1470 1471 1472 1473 1474 1475 1476 1477 1478 1479 1480 1481 1482 1483 1484 1485 1486 1487 1488 |
#ifdef CONFIG_NFS_V4_2 static void nfs4_xdr_enc_setxattr(struct rpc_rqst *req, struct xdr_stream *xdr, const void *data) { const struct nfs42_setxattrargs *args = data; struct compound_hdr hdr = { .minorversion = nfs4_xdr_minorversion(&args->seq_args), }; encode_compound_hdr(xdr, req, &hdr); encode_sequence(xdr, &args->seq_args, &hdr); encode_putfh(xdr, args->fh, &hdr); encode_setxattr(xdr, args, &hdr); encode_nops(&hdr); } static int nfs4_xdr_dec_setxattr(struct rpc_rqst *req, struct xdr_stream *xdr, void *data) { struct nfs42_setxattrres *res = data; struct compound_hdr hdr; int status; status = decode_compound_hdr(xdr, &hdr); if (status) goto out; status = decode_sequence(xdr, &res->seq_res, req); if (status) goto out; status = decode_putfh(xdr); if (status) goto out; status = decode_setxattr(xdr, &res->cinfo); out: return status; } static void nfs4_xdr_enc_getxattr(struct rpc_rqst *req, struct xdr_stream *xdr, const void *data) { const struct nfs42_getxattrargs *args = data; struct compound_hdr hdr = { .minorversion = nfs4_xdr_minorversion(&args->seq_args), }; size_t plen; encode_compound_hdr(xdr, req, &hdr); encode_sequence(xdr, &args->seq_args, &hdr); encode_putfh(xdr, args->fh, &hdr); encode_getxattr(xdr, args->xattr_name, &hdr); plen = args->xattr_len ? args->xattr_len : XATTR_SIZE_MAX; rpc_prepare_reply_pages(req, args->xattr_pages, 0, plen, hdr.replen); req->rq_rcv_buf.flags |= XDRBUF_SPARSE_PAGES; encode_nops(&hdr); } static int nfs4_xdr_dec_getxattr(struct rpc_rqst *rqstp, struct xdr_stream *xdr, void *data) { struct nfs42_getxattrres *res = data; struct compound_hdr hdr; int status; status = decode_compound_hdr(xdr, &hdr); if (status) goto out; status = decode_sequence(xdr, &res->seq_res, rqstp); if (status) goto out; status = decode_putfh(xdr); if (status) goto out; status = decode_getxattr(xdr, res, rqstp); out: return status; } static void nfs4_xdr_enc_listxattrs(struct rpc_rqst *req, struct xdr_stream *xdr, const void *data) { const struct nfs42_listxattrsargs *args = data; struct compound_hdr hdr = { .minorversion = nfs4_xdr_minorversion(&args->seq_args), }; encode_compound_hdr(xdr, req, &hdr); encode_sequence(xdr, &args->seq_args, &hdr); encode_putfh(xdr, args->fh, &hdr); encode_listxattrs(xdr, args, &hdr); rpc_prepare_reply_pages(req, args->xattr_pages, 0, args->count, hdr.replen); |
3e1f02123 NFSv4.2: add clie... |
1489 1490 1491 1492 1493 1494 1495 1496 1497 1498 1499 1500 1501 1502 1503 1504 1505 1506 1507 1508 1509 1510 1511 1512 1513 1514 1515 1516 1517 1518 1519 1520 1521 1522 1523 1524 1525 1526 1527 1528 1529 1530 1531 1532 1533 1534 1535 1536 1537 1538 1539 1540 1541 1542 1543 1544 1545 1546 1547 1548 1549 1550 1551 1552 |
encode_nops(&hdr); } static int nfs4_xdr_dec_listxattrs(struct rpc_rqst *rqstp, struct xdr_stream *xdr, void *data) { struct nfs42_listxattrsres *res = data; struct compound_hdr hdr; int status; xdr_set_scratch_buffer(xdr, page_address(res->scratch), PAGE_SIZE); status = decode_compound_hdr(xdr, &hdr); if (status) goto out; status = decode_sequence(xdr, &res->seq_res, rqstp); if (status) goto out; status = decode_putfh(xdr); if (status) goto out; status = decode_listxattrs(xdr, res); out: return status; } static void nfs4_xdr_enc_removexattr(struct rpc_rqst *req, struct xdr_stream *xdr, const void *data) { const struct nfs42_removexattrargs *args = data; struct compound_hdr hdr = { .minorversion = nfs4_xdr_minorversion(&args->seq_args), }; encode_compound_hdr(xdr, req, &hdr); encode_sequence(xdr, &args->seq_args, &hdr); encode_putfh(xdr, args->fh, &hdr); encode_removexattr(xdr, args->xattr_name, &hdr); encode_nops(&hdr); } static int nfs4_xdr_dec_removexattr(struct rpc_rqst *req, struct xdr_stream *xdr, void *data) { struct nfs42_removexattrres *res = data; struct compound_hdr hdr; int status; status = decode_compound_hdr(xdr, &hdr); if (status) goto out; status = decode_sequence(xdr, &res->seq_res, req); if (status) goto out; status = decode_putfh(xdr); if (status) goto out; status = decode_removexattr(xdr, &res->cinfo); out: return status; } #endif |
1c6dcbe5c NFS: Implement SEEK |
1553 |
#endif /* __LINUX_FS_NFS_NFS4_2XDR_H */ |