11da177e4SLinus Torvalds /* 21da177e4SLinus Torvalds * linux/fs/nfs/callback_xdr.c 31da177e4SLinus Torvalds * 41da177e4SLinus Torvalds * Copyright (C) 2004 Trond Myklebust 51da177e4SLinus Torvalds * 61da177e4SLinus Torvalds * NFSv4 callback encode/decode procedures 71da177e4SLinus Torvalds */ 81da177e4SLinus Torvalds #include <linux/kernel.h> 91da177e4SLinus Torvalds #include <linux/sunrpc/svc.h> 101da177e4SLinus Torvalds #include <linux/nfs4.h> 111da177e4SLinus Torvalds #include <linux/nfs_fs.h> 124ce79717STrond Myklebust #include "nfs4_fs.h" 131da177e4SLinus Torvalds #include "callback.h" 141da177e4SLinus Torvalds 151da177e4SLinus Torvalds #define CB_OP_TAGLEN_MAXSZ (512) 161da177e4SLinus Torvalds #define CB_OP_HDR_RES_MAXSZ (2 + CB_OP_TAGLEN_MAXSZ) 171da177e4SLinus Torvalds #define CB_OP_GETATTR_BITMAP_MAXSZ (4) 181da177e4SLinus Torvalds #define CB_OP_GETATTR_RES_MAXSZ (CB_OP_HDR_RES_MAXSZ + \ 191da177e4SLinus Torvalds CB_OP_GETATTR_BITMAP_MAXSZ + \ 201da177e4SLinus Torvalds 2 + 2 + 3 + 3) 211da177e4SLinus Torvalds #define CB_OP_RECALL_RES_MAXSZ (CB_OP_HDR_RES_MAXSZ) 221da177e4SLinus Torvalds 231da177e4SLinus Torvalds #define NFSDBG_FACILITY NFSDBG_CALLBACK 241da177e4SLinus Torvalds 25e6f684f6SAl Viro typedef __be32 (*callback_process_op_t)(void *, void *); 26e6f684f6SAl Viro typedef __be32 (*callback_decode_arg_t)(struct svc_rqst *, struct xdr_stream *, void *); 27e6f684f6SAl Viro typedef __be32 (*callback_encode_res_t)(struct svc_rqst *, struct xdr_stream *, void *); 281da177e4SLinus Torvalds 291da177e4SLinus Torvalds 301da177e4SLinus Torvalds struct callback_op { 311da177e4SLinus Torvalds callback_process_op_t process_op; 321da177e4SLinus Torvalds callback_decode_arg_t decode_args; 331da177e4SLinus Torvalds callback_encode_res_t encode_res; 341da177e4SLinus Torvalds long res_maxsize; 351da177e4SLinus Torvalds }; 361da177e4SLinus Torvalds 371da177e4SLinus Torvalds static struct callback_op callback_ops[]; 381da177e4SLinus Torvalds 397111c66eSAl Viro static __be32 nfs4_callback_null(struct svc_rqst *rqstp, void *argp, void *resp) 401da177e4SLinus Torvalds { 411da177e4SLinus Torvalds return htonl(NFS4_OK); 421da177e4SLinus Torvalds } 431da177e4SLinus Torvalds 445704fdebSAl Viro static int nfs4_decode_void(struct svc_rqst *rqstp, __be32 *p, void *dummy) 451da177e4SLinus Torvalds { 461da177e4SLinus Torvalds return xdr_argsize_check(rqstp, p); 471da177e4SLinus Torvalds } 481da177e4SLinus Torvalds 495704fdebSAl Viro static int nfs4_encode_void(struct svc_rqst *rqstp, __be32 *p, void *dummy) 501da177e4SLinus Torvalds { 511da177e4SLinus Torvalds return xdr_ressize_check(rqstp, p); 521da177e4SLinus Torvalds } 531da177e4SLinus Torvalds 545704fdebSAl Viro static __be32 *read_buf(struct xdr_stream *xdr, int nbytes) 551da177e4SLinus Torvalds { 565704fdebSAl Viro __be32 *p; 571da177e4SLinus Torvalds 581da177e4SLinus Torvalds p = xdr_inline_decode(xdr, nbytes); 591da177e4SLinus Torvalds if (unlikely(p == NULL)) 601da177e4SLinus Torvalds printk(KERN_WARNING "NFSv4 callback reply buffer overflowed!\n"); 611da177e4SLinus Torvalds return p; 621da177e4SLinus Torvalds } 631da177e4SLinus Torvalds 64e6f684f6SAl Viro static __be32 decode_string(struct xdr_stream *xdr, unsigned int *len, const char **str) 651da177e4SLinus Torvalds { 665704fdebSAl Viro __be32 *p; 671da177e4SLinus Torvalds 681da177e4SLinus Torvalds p = read_buf(xdr, 4); 691da177e4SLinus Torvalds if (unlikely(p == NULL)) 701da177e4SLinus Torvalds return htonl(NFS4ERR_RESOURCE); 711da177e4SLinus Torvalds *len = ntohl(*p); 721da177e4SLinus Torvalds 731da177e4SLinus Torvalds if (*len != 0) { 741da177e4SLinus Torvalds p = read_buf(xdr, *len); 751da177e4SLinus Torvalds if (unlikely(p == NULL)) 761da177e4SLinus Torvalds return htonl(NFS4ERR_RESOURCE); 771da177e4SLinus Torvalds *str = (const char *)p; 781da177e4SLinus Torvalds } else 791da177e4SLinus Torvalds *str = NULL; 801da177e4SLinus Torvalds 811da177e4SLinus Torvalds return 0; 821da177e4SLinus Torvalds } 831da177e4SLinus Torvalds 84e6f684f6SAl Viro static __be32 decode_fh(struct xdr_stream *xdr, struct nfs_fh *fh) 851da177e4SLinus Torvalds { 865704fdebSAl Viro __be32 *p; 871da177e4SLinus Torvalds 881da177e4SLinus Torvalds p = read_buf(xdr, 4); 891da177e4SLinus Torvalds if (unlikely(p == NULL)) 901da177e4SLinus Torvalds return htonl(NFS4ERR_RESOURCE); 911da177e4SLinus Torvalds fh->size = ntohl(*p); 921da177e4SLinus Torvalds if (fh->size > NFS4_FHSIZE) 931da177e4SLinus Torvalds return htonl(NFS4ERR_BADHANDLE); 941da177e4SLinus Torvalds p = read_buf(xdr, fh->size); 951da177e4SLinus Torvalds if (unlikely(p == NULL)) 961da177e4SLinus Torvalds return htonl(NFS4ERR_RESOURCE); 971da177e4SLinus Torvalds memcpy(&fh->data[0], p, fh->size); 981da177e4SLinus Torvalds memset(&fh->data[fh->size], 0, sizeof(fh->data) - fh->size); 991da177e4SLinus Torvalds return 0; 1001da177e4SLinus Torvalds } 1011da177e4SLinus Torvalds 102e6f684f6SAl Viro static __be32 decode_bitmap(struct xdr_stream *xdr, uint32_t *bitmap) 1031da177e4SLinus Torvalds { 1045704fdebSAl Viro __be32 *p; 1051da177e4SLinus Torvalds unsigned int attrlen; 1061da177e4SLinus Torvalds 1071da177e4SLinus Torvalds p = read_buf(xdr, 4); 1081da177e4SLinus Torvalds if (unlikely(p == NULL)) 1091da177e4SLinus Torvalds return htonl(NFS4ERR_RESOURCE); 1101da177e4SLinus Torvalds attrlen = ntohl(*p); 1111da177e4SLinus Torvalds p = read_buf(xdr, attrlen << 2); 1121da177e4SLinus Torvalds if (unlikely(p == NULL)) 1131da177e4SLinus Torvalds return htonl(NFS4ERR_RESOURCE); 1141da177e4SLinus Torvalds if (likely(attrlen > 0)) 1151da177e4SLinus Torvalds bitmap[0] = ntohl(*p++); 1161da177e4SLinus Torvalds if (attrlen > 1) 1171da177e4SLinus Torvalds bitmap[1] = ntohl(*p); 1181da177e4SLinus Torvalds return 0; 1191da177e4SLinus Torvalds } 1201da177e4SLinus Torvalds 121e6f684f6SAl Viro static __be32 decode_stateid(struct xdr_stream *xdr, nfs4_stateid *stateid) 1221da177e4SLinus Torvalds { 1235704fdebSAl Viro __be32 *p; 1241da177e4SLinus Torvalds 1251da177e4SLinus Torvalds p = read_buf(xdr, 16); 1261da177e4SLinus Torvalds if (unlikely(p == NULL)) 1271da177e4SLinus Torvalds return htonl(NFS4ERR_RESOURCE); 1281da177e4SLinus Torvalds memcpy(stateid->data, p, 16); 1291da177e4SLinus Torvalds return 0; 1301da177e4SLinus Torvalds } 1311da177e4SLinus Torvalds 132e6f684f6SAl Viro static __be32 decode_compound_hdr_arg(struct xdr_stream *xdr, struct cb_compound_hdr_arg *hdr) 1331da177e4SLinus Torvalds { 1345704fdebSAl Viro __be32 *p; 1351da177e4SLinus Torvalds unsigned int minor_version; 136e6f684f6SAl Viro __be32 status; 1371da177e4SLinus Torvalds 1381da177e4SLinus Torvalds status = decode_string(xdr, &hdr->taglen, &hdr->tag); 1391da177e4SLinus Torvalds if (unlikely(status != 0)) 1401da177e4SLinus Torvalds return status; 1411da177e4SLinus Torvalds /* We do not like overly long tags! */ 1421da177e4SLinus Torvalds if (hdr->taglen > CB_OP_TAGLEN_MAXSZ-12 || hdr->taglen < 0) { 1431da177e4SLinus Torvalds printk("NFSv4 CALLBACK %s: client sent tag of length %u\n", 1441da177e4SLinus Torvalds __FUNCTION__, hdr->taglen); 1451da177e4SLinus Torvalds return htonl(NFS4ERR_RESOURCE); 1461da177e4SLinus Torvalds } 1471da177e4SLinus Torvalds p = read_buf(xdr, 12); 1481da177e4SLinus Torvalds if (unlikely(p == NULL)) 1491da177e4SLinus Torvalds return htonl(NFS4ERR_RESOURCE); 1501da177e4SLinus Torvalds minor_version = ntohl(*p++); 1511da177e4SLinus Torvalds /* Check minor version is zero. */ 1521da177e4SLinus Torvalds if (minor_version != 0) { 1531da177e4SLinus Torvalds printk(KERN_WARNING "%s: NFSv4 server callback with illegal minor version %u!\n", 1541da177e4SLinus Torvalds __FUNCTION__, minor_version); 1551da177e4SLinus Torvalds return htonl(NFS4ERR_MINOR_VERS_MISMATCH); 1561da177e4SLinus Torvalds } 1571da177e4SLinus Torvalds hdr->callback_ident = ntohl(*p++); 1581da177e4SLinus Torvalds hdr->nops = ntohl(*p); 1591da177e4SLinus Torvalds return 0; 1601da177e4SLinus Torvalds } 1611da177e4SLinus Torvalds 162e6f684f6SAl Viro static __be32 decode_op_hdr(struct xdr_stream *xdr, unsigned int *op) 1631da177e4SLinus Torvalds { 1645704fdebSAl Viro __be32 *p; 1651da177e4SLinus Torvalds p = read_buf(xdr, 4); 1661da177e4SLinus Torvalds if (unlikely(p == NULL)) 1671da177e4SLinus Torvalds return htonl(NFS4ERR_RESOURCE); 1681da177e4SLinus Torvalds *op = ntohl(*p); 1691da177e4SLinus Torvalds return 0; 1701da177e4SLinus Torvalds } 1711da177e4SLinus Torvalds 172e6f684f6SAl Viro static __be32 decode_getattr_args(struct svc_rqst *rqstp, struct xdr_stream *xdr, struct cb_getattrargs *args) 1731da177e4SLinus Torvalds { 174e6f684f6SAl Viro __be32 status; 1751da177e4SLinus Torvalds 1761da177e4SLinus Torvalds status = decode_fh(xdr, &args->fh); 1771da177e4SLinus Torvalds if (unlikely(status != 0)) 1781da177e4SLinus Torvalds goto out; 17927459f09SChuck Lever args->addr = svc_addr_in(rqstp); 1801da177e4SLinus Torvalds status = decode_bitmap(xdr, args->bitmap); 1811da177e4SLinus Torvalds out: 182f9d888fcSBenny Halevy dprintk("%s: exit with status = %d\n", __FUNCTION__, ntohl(status)); 1831da177e4SLinus Torvalds return status; 1841da177e4SLinus Torvalds } 1851da177e4SLinus Torvalds 186e6f684f6SAl Viro static __be32 decode_recall_args(struct svc_rqst *rqstp, struct xdr_stream *xdr, struct cb_recallargs *args) 1871da177e4SLinus Torvalds { 1885704fdebSAl Viro __be32 *p; 189e6f684f6SAl Viro __be32 status; 1901da177e4SLinus Torvalds 19127459f09SChuck Lever args->addr = svc_addr_in(rqstp); 1921da177e4SLinus Torvalds status = decode_stateid(xdr, &args->stateid); 1931da177e4SLinus Torvalds if (unlikely(status != 0)) 1941da177e4SLinus Torvalds goto out; 1951da177e4SLinus Torvalds p = read_buf(xdr, 4); 1961da177e4SLinus Torvalds if (unlikely(p == NULL)) { 1971da177e4SLinus Torvalds status = htonl(NFS4ERR_RESOURCE); 1981da177e4SLinus Torvalds goto out; 1991da177e4SLinus Torvalds } 2001da177e4SLinus Torvalds args->truncate = ntohl(*p); 2011da177e4SLinus Torvalds status = decode_fh(xdr, &args->fh); 2021da177e4SLinus Torvalds out: 203f9d888fcSBenny Halevy dprintk("%s: exit with status = %d\n", __FUNCTION__, ntohl(status)); 2043873bc50SAlexey Dobriyan return status; 2051da177e4SLinus Torvalds } 2061da177e4SLinus Torvalds 207e6f684f6SAl Viro static __be32 encode_string(struct xdr_stream *xdr, unsigned int len, const char *str) 2081da177e4SLinus Torvalds { 2095704fdebSAl Viro __be32 *p; 2101da177e4SLinus Torvalds 2111da177e4SLinus Torvalds p = xdr_reserve_space(xdr, 4 + len); 2121da177e4SLinus Torvalds if (unlikely(p == NULL)) 2131da177e4SLinus Torvalds return htonl(NFS4ERR_RESOURCE); 2141da177e4SLinus Torvalds xdr_encode_opaque(p, str, len); 2151da177e4SLinus Torvalds return 0; 2161da177e4SLinus Torvalds } 2171da177e4SLinus Torvalds 2181da177e4SLinus Torvalds #define CB_SUPPORTED_ATTR0 (FATTR4_WORD0_CHANGE|FATTR4_WORD0_SIZE) 2191da177e4SLinus Torvalds #define CB_SUPPORTED_ATTR1 (FATTR4_WORD1_TIME_METADATA|FATTR4_WORD1_TIME_MODIFY) 2205704fdebSAl Viro static __be32 encode_attr_bitmap(struct xdr_stream *xdr, const uint32_t *bitmap, __be32 **savep) 2211da177e4SLinus Torvalds { 2225704fdebSAl Viro __be32 bm[2]; 2235704fdebSAl Viro __be32 *p; 2241da177e4SLinus Torvalds 2251da177e4SLinus Torvalds bm[0] = htonl(bitmap[0] & CB_SUPPORTED_ATTR0); 2261da177e4SLinus Torvalds bm[1] = htonl(bitmap[1] & CB_SUPPORTED_ATTR1); 2271da177e4SLinus Torvalds if (bm[1] != 0) { 2281da177e4SLinus Torvalds p = xdr_reserve_space(xdr, 16); 2291da177e4SLinus Torvalds if (unlikely(p == NULL)) 2301da177e4SLinus Torvalds return htonl(NFS4ERR_RESOURCE); 2311da177e4SLinus Torvalds *p++ = htonl(2); 2321da177e4SLinus Torvalds *p++ = bm[0]; 2331da177e4SLinus Torvalds *p++ = bm[1]; 2341da177e4SLinus Torvalds } else if (bm[0] != 0) { 2351da177e4SLinus Torvalds p = xdr_reserve_space(xdr, 12); 2361da177e4SLinus Torvalds if (unlikely(p == NULL)) 2371da177e4SLinus Torvalds return htonl(NFS4ERR_RESOURCE); 2381da177e4SLinus Torvalds *p++ = htonl(1); 2391da177e4SLinus Torvalds *p++ = bm[0]; 2401da177e4SLinus Torvalds } else { 2411da177e4SLinus Torvalds p = xdr_reserve_space(xdr, 8); 2421da177e4SLinus Torvalds if (unlikely(p == NULL)) 2431da177e4SLinus Torvalds return htonl(NFS4ERR_RESOURCE); 2441da177e4SLinus Torvalds *p++ = htonl(0); 2451da177e4SLinus Torvalds } 2461da177e4SLinus Torvalds *savep = p; 2471da177e4SLinus Torvalds return 0; 2481da177e4SLinus Torvalds } 2491da177e4SLinus Torvalds 250e6f684f6SAl Viro static __be32 encode_attr_change(struct xdr_stream *xdr, const uint32_t *bitmap, uint64_t change) 2511da177e4SLinus Torvalds { 2525704fdebSAl Viro __be32 *p; 2531da177e4SLinus Torvalds 2541da177e4SLinus Torvalds if (!(bitmap[0] & FATTR4_WORD0_CHANGE)) 2551da177e4SLinus Torvalds return 0; 2561da177e4SLinus Torvalds p = xdr_reserve_space(xdr, 8); 2571da177e4SLinus Torvalds if (unlikely(p == 0)) 2581da177e4SLinus Torvalds return htonl(NFS4ERR_RESOURCE); 2591da177e4SLinus Torvalds p = xdr_encode_hyper(p, change); 2601da177e4SLinus Torvalds return 0; 2611da177e4SLinus Torvalds } 2621da177e4SLinus Torvalds 263e6f684f6SAl Viro static __be32 encode_attr_size(struct xdr_stream *xdr, const uint32_t *bitmap, uint64_t size) 2641da177e4SLinus Torvalds { 2655704fdebSAl Viro __be32 *p; 2661da177e4SLinus Torvalds 2671da177e4SLinus Torvalds if (!(bitmap[0] & FATTR4_WORD0_SIZE)) 2681da177e4SLinus Torvalds return 0; 2691da177e4SLinus Torvalds p = xdr_reserve_space(xdr, 8); 2701da177e4SLinus Torvalds if (unlikely(p == 0)) 2711da177e4SLinus Torvalds return htonl(NFS4ERR_RESOURCE); 2721da177e4SLinus Torvalds p = xdr_encode_hyper(p, size); 2731da177e4SLinus Torvalds return 0; 2741da177e4SLinus Torvalds } 2751da177e4SLinus Torvalds 276e6f684f6SAl Viro static __be32 encode_attr_time(struct xdr_stream *xdr, const struct timespec *time) 2771da177e4SLinus Torvalds { 2785704fdebSAl Viro __be32 *p; 2791da177e4SLinus Torvalds 2801da177e4SLinus Torvalds p = xdr_reserve_space(xdr, 12); 2811da177e4SLinus Torvalds if (unlikely(p == 0)) 2821da177e4SLinus Torvalds return htonl(NFS4ERR_RESOURCE); 2831da177e4SLinus Torvalds p = xdr_encode_hyper(p, time->tv_sec); 2841da177e4SLinus Torvalds *p = htonl(time->tv_nsec); 2851da177e4SLinus Torvalds return 0; 2861da177e4SLinus Torvalds } 2871da177e4SLinus Torvalds 288e6f684f6SAl Viro static __be32 encode_attr_ctime(struct xdr_stream *xdr, const uint32_t *bitmap, const struct timespec *time) 2891da177e4SLinus Torvalds { 2901da177e4SLinus Torvalds if (!(bitmap[1] & FATTR4_WORD1_TIME_METADATA)) 2911da177e4SLinus Torvalds return 0; 2921da177e4SLinus Torvalds return encode_attr_time(xdr,time); 2931da177e4SLinus Torvalds } 2941da177e4SLinus Torvalds 295e6f684f6SAl Viro static __be32 encode_attr_mtime(struct xdr_stream *xdr, const uint32_t *bitmap, const struct timespec *time) 2961da177e4SLinus Torvalds { 2971da177e4SLinus Torvalds if (!(bitmap[1] & FATTR4_WORD1_TIME_MODIFY)) 2981da177e4SLinus Torvalds return 0; 2991da177e4SLinus Torvalds return encode_attr_time(xdr,time); 3001da177e4SLinus Torvalds } 3011da177e4SLinus Torvalds 302e6f684f6SAl Viro static __be32 encode_compound_hdr_res(struct xdr_stream *xdr, struct cb_compound_hdr_res *hdr) 3031da177e4SLinus Torvalds { 304e6f684f6SAl Viro __be32 status; 3051da177e4SLinus Torvalds 3061da177e4SLinus Torvalds hdr->status = xdr_reserve_space(xdr, 4); 3071da177e4SLinus Torvalds if (unlikely(hdr->status == NULL)) 3081da177e4SLinus Torvalds return htonl(NFS4ERR_RESOURCE); 3091da177e4SLinus Torvalds status = encode_string(xdr, hdr->taglen, hdr->tag); 3101da177e4SLinus Torvalds if (unlikely(status != 0)) 3111da177e4SLinus Torvalds return status; 3121da177e4SLinus Torvalds hdr->nops = xdr_reserve_space(xdr, 4); 3131da177e4SLinus Torvalds if (unlikely(hdr->nops == NULL)) 3141da177e4SLinus Torvalds return htonl(NFS4ERR_RESOURCE); 3151da177e4SLinus Torvalds return 0; 3161da177e4SLinus Torvalds } 3171da177e4SLinus Torvalds 318e6f684f6SAl Viro static __be32 encode_op_hdr(struct xdr_stream *xdr, uint32_t op, __be32 res) 3191da177e4SLinus Torvalds { 3205704fdebSAl Viro __be32 *p; 3211da177e4SLinus Torvalds 3221da177e4SLinus Torvalds p = xdr_reserve_space(xdr, 8); 3231da177e4SLinus Torvalds if (unlikely(p == NULL)) 3241da177e4SLinus Torvalds return htonl(NFS4ERR_RESOURCE); 3251da177e4SLinus Torvalds *p++ = htonl(op); 3261da177e4SLinus Torvalds *p = res; 3271da177e4SLinus Torvalds return 0; 3281da177e4SLinus Torvalds } 3291da177e4SLinus Torvalds 330e6f684f6SAl Viro static __be32 encode_getattr_res(struct svc_rqst *rqstp, struct xdr_stream *xdr, const struct cb_getattrres *res) 3311da177e4SLinus Torvalds { 3325704fdebSAl Viro __be32 *savep = NULL; 333e6f684f6SAl Viro __be32 status = res->status; 3341da177e4SLinus Torvalds 3351da177e4SLinus Torvalds if (unlikely(status != 0)) 3361da177e4SLinus Torvalds goto out; 3371da177e4SLinus Torvalds status = encode_attr_bitmap(xdr, res->bitmap, &savep); 3381da177e4SLinus Torvalds if (unlikely(status != 0)) 3391da177e4SLinus Torvalds goto out; 3401da177e4SLinus Torvalds status = encode_attr_change(xdr, res->bitmap, res->change_attr); 3411da177e4SLinus Torvalds if (unlikely(status != 0)) 3421da177e4SLinus Torvalds goto out; 3431da177e4SLinus Torvalds status = encode_attr_size(xdr, res->bitmap, res->size); 3441da177e4SLinus Torvalds if (unlikely(status != 0)) 3451da177e4SLinus Torvalds goto out; 3461da177e4SLinus Torvalds status = encode_attr_ctime(xdr, res->bitmap, &res->ctime); 3471da177e4SLinus Torvalds if (unlikely(status != 0)) 3481da177e4SLinus Torvalds goto out; 3491da177e4SLinus Torvalds status = encode_attr_mtime(xdr, res->bitmap, &res->mtime); 3501da177e4SLinus Torvalds *savep = htonl((unsigned int)((char *)xdr->p - (char *)(savep+1))); 3511da177e4SLinus Torvalds out: 352f9d888fcSBenny Halevy dprintk("%s: exit with status = %d\n", __FUNCTION__, ntohl(status)); 3531da177e4SLinus Torvalds return status; 3541da177e4SLinus Torvalds } 3551da177e4SLinus Torvalds 356e6f684f6SAl Viro static __be32 process_op(struct svc_rqst *rqstp, 3571da177e4SLinus Torvalds struct xdr_stream *xdr_in, void *argp, 3581da177e4SLinus Torvalds struct xdr_stream *xdr_out, void *resp) 3591da177e4SLinus Torvalds { 360a162a6b8STrond Myklebust struct callback_op *op = &callback_ops[0]; 361a162a6b8STrond Myklebust unsigned int op_nr = OP_CB_ILLEGAL; 362e6f684f6SAl Viro __be32 status = 0; 3631da177e4SLinus Torvalds long maxlen; 364e6f684f6SAl Viro __be32 res; 3651da177e4SLinus Torvalds 3661da177e4SLinus Torvalds dprintk("%s: start\n", __FUNCTION__); 3671da177e4SLinus Torvalds status = decode_op_hdr(xdr_in, &op_nr); 368a162a6b8STrond Myklebust if (likely(status == 0)) { 369a162a6b8STrond Myklebust switch (op_nr) { 370a162a6b8STrond Myklebust case OP_CB_GETATTR: 371a162a6b8STrond Myklebust case OP_CB_RECALL: 372a162a6b8STrond Myklebust op = &callback_ops[op_nr]; 373a162a6b8STrond Myklebust break; 374a162a6b8STrond Myklebust default: 3751da177e4SLinus Torvalds op_nr = OP_CB_ILLEGAL; 3761da177e4SLinus Torvalds op = &callback_ops[0]; 3771da177e4SLinus Torvalds status = htonl(NFS4ERR_OP_ILLEGAL); 378a162a6b8STrond Myklebust } 379a162a6b8STrond Myklebust } 3801da177e4SLinus Torvalds 3811da177e4SLinus Torvalds maxlen = xdr_out->end - xdr_out->p; 3821da177e4SLinus Torvalds if (maxlen > 0 && maxlen < PAGE_SIZE) { 3831da177e4SLinus Torvalds if (likely(status == 0 && op->decode_args != NULL)) 3841da177e4SLinus Torvalds status = op->decode_args(rqstp, xdr_in, argp); 3851da177e4SLinus Torvalds if (likely(status == 0 && op->process_op != NULL)) 3861da177e4SLinus Torvalds status = op->process_op(argp, resp); 3871da177e4SLinus Torvalds } else 3881da177e4SLinus Torvalds status = htonl(NFS4ERR_RESOURCE); 3891da177e4SLinus Torvalds 3901da177e4SLinus Torvalds res = encode_op_hdr(xdr_out, op_nr, status); 3911da177e4SLinus Torvalds if (status == 0) 3921da177e4SLinus Torvalds status = res; 3931da177e4SLinus Torvalds if (op->encode_res != NULL && status == 0) 3941da177e4SLinus Torvalds status = op->encode_res(rqstp, xdr_out, resp); 395f9d888fcSBenny Halevy dprintk("%s: done, status = %d\n", __FUNCTION__, ntohl(status)); 3961da177e4SLinus Torvalds return status; 3971da177e4SLinus Torvalds } 3981da177e4SLinus Torvalds 3991da177e4SLinus Torvalds /* 4001da177e4SLinus Torvalds * Decode, process and encode a COMPOUND 4011da177e4SLinus Torvalds */ 4027111c66eSAl Viro static __be32 nfs4_callback_compound(struct svc_rqst *rqstp, void *argp, void *resp) 4031da177e4SLinus Torvalds { 4041da177e4SLinus Torvalds struct cb_compound_hdr_arg hdr_arg; 4051da177e4SLinus Torvalds struct cb_compound_hdr_res hdr_res; 4061da177e4SLinus Torvalds struct xdr_stream xdr_in, xdr_out; 4075704fdebSAl Viro __be32 *p; 408e6f684f6SAl Viro __be32 status; 4091da177e4SLinus Torvalds unsigned int nops = 1; 4101da177e4SLinus Torvalds 4111da177e4SLinus Torvalds dprintk("%s: start\n", __FUNCTION__); 4121da177e4SLinus Torvalds 4131da177e4SLinus Torvalds xdr_init_decode(&xdr_in, &rqstp->rq_arg, rqstp->rq_arg.head[0].iov_base); 4141da177e4SLinus Torvalds 4155704fdebSAl Viro p = (__be32*)((char *)rqstp->rq_res.head[0].iov_base + rqstp->rq_res.head[0].iov_len); 4161da177e4SLinus Torvalds xdr_init_encode(&xdr_out, &rqstp->rq_res, p); 4171da177e4SLinus Torvalds 4181da177e4SLinus Torvalds decode_compound_hdr_arg(&xdr_in, &hdr_arg); 4191da177e4SLinus Torvalds hdr_res.taglen = hdr_arg.taglen; 4201da177e4SLinus Torvalds hdr_res.tag = hdr_arg.tag; 421a162a6b8STrond Myklebust hdr_res.nops = NULL; 4221da177e4SLinus Torvalds encode_compound_hdr_res(&xdr_out, &hdr_res); 4231da177e4SLinus Torvalds 4241da177e4SLinus Torvalds for (;;) { 4251da177e4SLinus Torvalds status = process_op(rqstp, &xdr_in, argp, &xdr_out, resp); 4261da177e4SLinus Torvalds if (status != 0) 4271da177e4SLinus Torvalds break; 4281da177e4SLinus Torvalds if (nops == hdr_arg.nops) 4291da177e4SLinus Torvalds break; 4301da177e4SLinus Torvalds nops++; 4311da177e4SLinus Torvalds } 4321da177e4SLinus Torvalds *hdr_res.status = status; 4331da177e4SLinus Torvalds *hdr_res.nops = htonl(nops); 434f9d888fcSBenny Halevy dprintk("%s: done, status = %u\n", __FUNCTION__, ntohl(status)); 4351da177e4SLinus Torvalds return rpc_success; 4361da177e4SLinus Torvalds } 4371da177e4SLinus Torvalds 4381da177e4SLinus Torvalds /* 4391da177e4SLinus Torvalds * Define NFS4 callback COMPOUND ops. 4401da177e4SLinus Torvalds */ 4411da177e4SLinus Torvalds static struct callback_op callback_ops[] = { 4421da177e4SLinus Torvalds [0] = { 4431da177e4SLinus Torvalds .res_maxsize = CB_OP_HDR_RES_MAXSZ, 4441da177e4SLinus Torvalds }, 4451da177e4SLinus Torvalds [OP_CB_GETATTR] = { 4461da177e4SLinus Torvalds .process_op = (callback_process_op_t)nfs4_callback_getattr, 4471da177e4SLinus Torvalds .decode_args = (callback_decode_arg_t)decode_getattr_args, 4481da177e4SLinus Torvalds .encode_res = (callback_encode_res_t)encode_getattr_res, 4491da177e4SLinus Torvalds .res_maxsize = CB_OP_GETATTR_RES_MAXSZ, 4501da177e4SLinus Torvalds }, 4511da177e4SLinus Torvalds [OP_CB_RECALL] = { 4521da177e4SLinus Torvalds .process_op = (callback_process_op_t)nfs4_callback_recall, 4531da177e4SLinus Torvalds .decode_args = (callback_decode_arg_t)decode_recall_args, 4541da177e4SLinus Torvalds .res_maxsize = CB_OP_RECALL_RES_MAXSZ, 4551da177e4SLinus Torvalds } 4561da177e4SLinus Torvalds }; 4571da177e4SLinus Torvalds 4581da177e4SLinus Torvalds /* 4591da177e4SLinus Torvalds * Define NFS4 callback procedures 4601da177e4SLinus Torvalds */ 4611da177e4SLinus Torvalds static struct svc_procedure nfs4_callback_procedures1[] = { 4621da177e4SLinus Torvalds [CB_NULL] = { 4631da177e4SLinus Torvalds .pc_func = nfs4_callback_null, 4641da177e4SLinus Torvalds .pc_decode = (kxdrproc_t)nfs4_decode_void, 4651da177e4SLinus Torvalds .pc_encode = (kxdrproc_t)nfs4_encode_void, 4661da177e4SLinus Torvalds .pc_xdrressize = 1, 4671da177e4SLinus Torvalds }, 4681da177e4SLinus Torvalds [CB_COMPOUND] = { 4691da177e4SLinus Torvalds .pc_func = nfs4_callback_compound, 4701da177e4SLinus Torvalds .pc_encode = (kxdrproc_t)nfs4_encode_void, 4711da177e4SLinus Torvalds .pc_argsize = 256, 4721da177e4SLinus Torvalds .pc_ressize = 256, 4731da177e4SLinus Torvalds .pc_xdrressize = NFS4_CALLBACK_BUFSIZE, 4741da177e4SLinus Torvalds } 4751da177e4SLinus Torvalds }; 4761da177e4SLinus Torvalds 4771da177e4SLinus Torvalds struct svc_version nfs4_callback_version1 = { 4781da177e4SLinus Torvalds .vs_vers = 1, 4791da177e4SLinus Torvalds .vs_nproc = ARRAY_SIZE(nfs4_callback_procedures1), 4801da177e4SLinus Torvalds .vs_proc = nfs4_callback_procedures1, 4811da177e4SLinus Torvalds .vs_xdrsize = NFS4_CALLBACK_XDRSIZE, 4821da177e4SLinus Torvalds .vs_dispatch = NULL, 4831da177e4SLinus Torvalds }; 4841da177e4SLinus Torvalds 485