|  | /* | 
|  | * Copyright (c) 2014 Anna Schumaker <Anna.Schumaker@Netapp.com> | 
|  | */ | 
|  | #ifndef __LINUX_FS_NFS_NFS4_2XDR_H | 
|  | #define __LINUX_FS_NFS_NFS4_2XDR_H | 
|  |  | 
|  | #include "nfs42.h" | 
|  |  | 
|  | #define encode_fallocate_maxsz		(encode_stateid_maxsz + \ | 
|  | 2 /* offset */ + \ | 
|  | 2 /* length */) | 
|  | #define encode_allocate_maxsz		(op_encode_hdr_maxsz + \ | 
|  | encode_fallocate_maxsz) | 
|  | #define decode_allocate_maxsz		(op_decode_hdr_maxsz) | 
|  | #define encode_deallocate_maxsz		(op_encode_hdr_maxsz + \ | 
|  | encode_fallocate_maxsz) | 
|  | #define decode_deallocate_maxsz		(op_decode_hdr_maxsz) | 
|  | #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 */) | 
|  | #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) | 
|  | #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) | 
|  |  | 
|  | #define NFS4_enc_allocate_sz		(compound_encode_hdr_maxsz + \ | 
|  | encode_putfh_maxsz + \ | 
|  | encode_allocate_maxsz + \ | 
|  | encode_getattr_maxsz) | 
|  | #define NFS4_dec_allocate_sz		(compound_decode_hdr_maxsz + \ | 
|  | decode_putfh_maxsz + \ | 
|  | decode_allocate_maxsz + \ | 
|  | decode_getattr_maxsz) | 
|  | #define NFS4_enc_deallocate_sz		(compound_encode_hdr_maxsz + \ | 
|  | encode_putfh_maxsz + \ | 
|  | encode_deallocate_maxsz + \ | 
|  | encode_getattr_maxsz) | 
|  | #define NFS4_dec_deallocate_sz		(compound_decode_hdr_maxsz + \ | 
|  | decode_putfh_maxsz + \ | 
|  | decode_deallocate_maxsz + \ | 
|  | decode_getattr_maxsz) | 
|  | #define NFS4_enc_seek_sz		(compound_encode_hdr_maxsz + \ | 
|  | encode_putfh_maxsz + \ | 
|  | encode_seek_maxsz) | 
|  | #define NFS4_dec_seek_sz		(compound_decode_hdr_maxsz + \ | 
|  | decode_putfh_maxsz + \ | 
|  | decode_seek_maxsz) | 
|  | #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) | 
|  | #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) | 
|  |  | 
|  | static void encode_fallocate(struct xdr_stream *xdr, | 
|  | struct nfs42_falloc_args *args) | 
|  | { | 
|  | 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, | 
|  | struct nfs42_falloc_args *args, | 
|  | struct compound_hdr *hdr) | 
|  | { | 
|  | encode_op_hdr(xdr, OP_ALLOCATE, decode_allocate_maxsz, hdr); | 
|  | encode_fallocate(xdr, args); | 
|  | } | 
|  |  | 
|  | static void encode_deallocate(struct xdr_stream *xdr, | 
|  | struct nfs42_falloc_args *args, | 
|  | struct compound_hdr *hdr) | 
|  | { | 
|  | encode_op_hdr(xdr, OP_DEALLOCATE, decode_deallocate_maxsz, hdr); | 
|  | encode_fallocate(xdr, args); | 
|  | } | 
|  |  | 
|  | static void encode_seek(struct xdr_stream *xdr, | 
|  | struct nfs42_seek_args *args, | 
|  | 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); | 
|  | } | 
|  |  | 
|  | static void encode_layoutstats(struct xdr_stream *xdr, | 
|  | struct nfs42_layoutstat_args *args, | 
|  | 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); | 
|  | if (devinfo->layoutstats_encode != NULL) | 
|  | devinfo->layoutstats_encode(xdr, args, devinfo); | 
|  | else | 
|  | encode_uint32(xdr, 0); | 
|  | } | 
|  |  | 
|  | static void encode_clone(struct xdr_stream *xdr, | 
|  | struct nfs42_clone_args *args, | 
|  | 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); | 
|  | } | 
|  |  | 
|  | /* | 
|  | * Encode ALLOCATE request | 
|  | */ | 
|  | static void nfs4_xdr_enc_allocate(struct rpc_rqst *req, | 
|  | struct xdr_stream *xdr, | 
|  | struct nfs42_falloc_args *args) | 
|  | { | 
|  | 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); | 
|  | encode_getfattr(xdr, args->falloc_bitmask, &hdr); | 
|  | encode_nops(&hdr); | 
|  | } | 
|  |  | 
|  | /* | 
|  | * Encode DEALLOCATE request | 
|  | */ | 
|  | static void nfs4_xdr_enc_deallocate(struct rpc_rqst *req, | 
|  | struct xdr_stream *xdr, | 
|  | struct nfs42_falloc_args *args) | 
|  | { | 
|  | 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); | 
|  | encode_getfattr(xdr, args->falloc_bitmask, &hdr); | 
|  | encode_nops(&hdr); | 
|  | } | 
|  |  | 
|  | /* | 
|  | * Encode SEEK request | 
|  | */ | 
|  | static void nfs4_xdr_enc_seek(struct rpc_rqst *req, | 
|  | struct xdr_stream *xdr, | 
|  | struct nfs42_seek_args *args) | 
|  | { | 
|  | 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); | 
|  | } | 
|  |  | 
|  | /* | 
|  | * Encode LAYOUTSTATS request | 
|  | */ | 
|  | static void nfs4_xdr_enc_layoutstats(struct rpc_rqst *req, | 
|  | struct xdr_stream *xdr, | 
|  | struct nfs42_layoutstat_args *args) | 
|  | { | 
|  | 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); | 
|  | } | 
|  |  | 
|  | /* | 
|  | * Encode CLONE request | 
|  | */ | 
|  | static void nfs4_xdr_enc_clone(struct rpc_rqst *req, | 
|  | struct xdr_stream *xdr, | 
|  | struct nfs42_clone_args *args) | 
|  | { | 
|  | 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); | 
|  | } | 
|  |  | 
|  | static int decode_allocate(struct xdr_stream *xdr, struct nfs42_falloc_res *res) | 
|  | { | 
|  | return decode_op_hdr(xdr, OP_ALLOCATE); | 
|  | } | 
|  |  | 
|  | static int decode_deallocate(struct xdr_stream *xdr, struct nfs42_falloc_res *res) | 
|  | { | 
|  | return decode_op_hdr(xdr, OP_DEALLOCATE); | 
|  | } | 
|  |  | 
|  | 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)) | 
|  | goto out_overflow; | 
|  |  | 
|  | res->sr_eof = be32_to_cpup(p++); | 
|  | p = xdr_decode_hyper(p, &res->sr_offset); | 
|  | return 0; | 
|  |  | 
|  | out_overflow: | 
|  | print_overflow_msg(__func__, xdr); | 
|  | return -EIO; | 
|  | } | 
|  |  | 
|  | static int decode_layoutstats(struct xdr_stream *xdr) | 
|  | { | 
|  | return decode_op_hdr(xdr, OP_LAYOUTSTATS); | 
|  | } | 
|  |  | 
|  | static int decode_clone(struct xdr_stream *xdr) | 
|  | { | 
|  | return decode_op_hdr(xdr, OP_CLONE); | 
|  | } | 
|  |  | 
|  | /* | 
|  | * Decode ALLOCATE request | 
|  | */ | 
|  | static int nfs4_xdr_dec_allocate(struct rpc_rqst *rqstp, | 
|  | struct xdr_stream *xdr, | 
|  | struct nfs42_falloc_res *res) | 
|  | { | 
|  | 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); | 
|  | if (status) | 
|  | goto out; | 
|  | decode_getfattr(xdr, res->falloc_fattr, res->falloc_server); | 
|  | out: | 
|  | return status; | 
|  | } | 
|  |  | 
|  | /* | 
|  | * Decode DEALLOCATE request | 
|  | */ | 
|  | static int nfs4_xdr_dec_deallocate(struct rpc_rqst *rqstp, | 
|  | struct xdr_stream *xdr, | 
|  | struct nfs42_falloc_res *res) | 
|  | { | 
|  | 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); | 
|  | if (status) | 
|  | goto out; | 
|  | decode_getfattr(xdr, res->falloc_fattr, res->falloc_server); | 
|  | out: | 
|  | return status; | 
|  | } | 
|  |  | 
|  | /* | 
|  | * Decode SEEK request | 
|  | */ | 
|  | static int nfs4_xdr_dec_seek(struct rpc_rqst *rqstp, | 
|  | struct xdr_stream *xdr, | 
|  | struct nfs42_seek_res *res) | 
|  | { | 
|  | 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; | 
|  | } | 
|  |  | 
|  | /* | 
|  | * Decode LAYOUTSTATS request | 
|  | */ | 
|  | static int nfs4_xdr_dec_layoutstats(struct rpc_rqst *rqstp, | 
|  | struct xdr_stream *xdr, | 
|  | struct nfs42_layoutstat_res *res) | 
|  | { | 
|  | 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++) { | 
|  | status = decode_layoutstats(xdr); | 
|  | if (status) | 
|  | goto out; | 
|  | } | 
|  | out: | 
|  | res->rpc_status = status; | 
|  | return status; | 
|  | } | 
|  |  | 
|  | /* | 
|  | * Decode CLONE request | 
|  | */ | 
|  | static int nfs4_xdr_dec_clone(struct rpc_rqst *rqstp, | 
|  | struct xdr_stream *xdr, | 
|  | struct nfs42_clone_res *res) | 
|  | { | 
|  | 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; | 
|  | decode_getfattr(xdr, res->dst_fattr, res->server); | 
|  | out: | 
|  | res->rpc_status = status; | 
|  | return status; | 
|  | } | 
|  |  | 
|  | #endif /* __LINUX_FS_NFS_NFS4_2XDR_H */ |