diff options
author | Benny Halevy <bhalevy@panasas.com> | 2011-05-22 12:53:48 -0400 |
---|---|---|
committer | Boaz Harrosh <bharrosh@panasas.com> | 2011-05-29 13:55:00 -0400 |
commit | ac7db7264ac3314cae09893bc838fcb7e83267a4 (patch) | |
tree | 7586470df26218daa8d771760615ae0d76e6788a /fs | |
parent | adb58535e604a564495a7d50dfb0afa0ddc21bcb (diff) |
pnfs: encode_layoutcommit
Add a layout driver method to encode the layout type specific
opaque part of layout commit in-line in the xdr stream.
Currently, the pnfs-objects layout driver uses it to encode metadata hints
to the MDS and the blocks layout driver to commit provisionally allocated
extents to the file.
Signed-off-by: Benny Halevy <bhalevy@panasas.com>
Diffstat (limited to 'fs')
-rw-r--r-- | fs/nfs/nfs4xdr.c | 16 | ||||
-rw-r--r-- | fs/nfs/pnfs.h | 4 |
2 files changed, 17 insertions, 3 deletions
diff --git a/fs/nfs/nfs4xdr.c b/fs/nfs/nfs4xdr.c index d464badc0067..d869a5e5464b 100644 --- a/fs/nfs/nfs4xdr.c +++ b/fs/nfs/nfs4xdr.c | |||
@@ -1875,6 +1875,7 @@ encode_layoutget(struct xdr_stream *xdr, | |||
1875 | 1875 | ||
1876 | static int | 1876 | static int |
1877 | encode_layoutcommit(struct xdr_stream *xdr, | 1877 | encode_layoutcommit(struct xdr_stream *xdr, |
1878 | struct inode *inode, | ||
1878 | const struct nfs4_layoutcommit_args *args, | 1879 | const struct nfs4_layoutcommit_args *args, |
1879 | struct compound_hdr *hdr) | 1880 | struct compound_hdr *hdr) |
1880 | { | 1881 | { |
@@ -1883,7 +1884,7 @@ encode_layoutcommit(struct xdr_stream *xdr, | |||
1883 | dprintk("%s: lbw: %llu type: %d\n", __func__, args->lastbytewritten, | 1884 | dprintk("%s: lbw: %llu type: %d\n", __func__, args->lastbytewritten, |
1884 | NFS_SERVER(args->inode)->pnfs_curr_ld->id); | 1885 | NFS_SERVER(args->inode)->pnfs_curr_ld->id); |
1885 | 1886 | ||
1886 | p = reserve_space(xdr, 48 + NFS4_STATEID_SIZE); | 1887 | p = reserve_space(xdr, 44 + NFS4_STATEID_SIZE); |
1887 | *p++ = cpu_to_be32(OP_LAYOUTCOMMIT); | 1888 | *p++ = cpu_to_be32(OP_LAYOUTCOMMIT); |
1888 | /* Only whole file layouts */ | 1889 | /* Only whole file layouts */ |
1889 | p = xdr_encode_hyper(p, 0); /* offset */ | 1890 | p = xdr_encode_hyper(p, 0); /* offset */ |
@@ -1894,7 +1895,14 @@ encode_layoutcommit(struct xdr_stream *xdr, | |||
1894 | p = xdr_encode_hyper(p, args->lastbytewritten); | 1895 | p = xdr_encode_hyper(p, args->lastbytewritten); |
1895 | *p++ = cpu_to_be32(0); /* Never send time_modify_changed */ | 1896 | *p++ = cpu_to_be32(0); /* Never send time_modify_changed */ |
1896 | *p++ = cpu_to_be32(NFS_SERVER(args->inode)->pnfs_curr_ld->id);/* type */ | 1897 | *p++ = cpu_to_be32(NFS_SERVER(args->inode)->pnfs_curr_ld->id);/* type */ |
1897 | *p++ = cpu_to_be32(0); /* no file layout payload */ | 1898 | |
1899 | if (NFS_SERVER(inode)->pnfs_curr_ld->encode_layoutcommit) | ||
1900 | NFS_SERVER(inode)->pnfs_curr_ld->encode_layoutcommit( | ||
1901 | NFS_I(inode)->layout, xdr, args); | ||
1902 | else { | ||
1903 | p = reserve_space(xdr, 4); | ||
1904 | *p = cpu_to_be32(0); /* no layout-type payload */ | ||
1905 | } | ||
1898 | 1906 | ||
1899 | hdr->nops++; | 1907 | hdr->nops++; |
1900 | hdr->replen += decode_layoutcommit_maxsz; | 1908 | hdr->replen += decode_layoutcommit_maxsz; |
@@ -2751,6 +2759,8 @@ static void nfs4_xdr_enc_layoutcommit(struct rpc_rqst *req, | |||
2751 | struct xdr_stream *xdr, | 2759 | struct xdr_stream *xdr, |
2752 | struct nfs4_layoutcommit_args *args) | 2760 | struct nfs4_layoutcommit_args *args) |
2753 | { | 2761 | { |
2762 | struct nfs4_layoutcommit_data *data = | ||
2763 | container_of(args, struct nfs4_layoutcommit_data, args); | ||
2754 | struct compound_hdr hdr = { | 2764 | struct compound_hdr hdr = { |
2755 | .minorversion = nfs4_xdr_minorversion(&args->seq_args), | 2765 | .minorversion = nfs4_xdr_minorversion(&args->seq_args), |
2756 | }; | 2766 | }; |
@@ -2758,7 +2768,7 @@ static void nfs4_xdr_enc_layoutcommit(struct rpc_rqst *req, | |||
2758 | encode_compound_hdr(xdr, req, &hdr); | 2768 | encode_compound_hdr(xdr, req, &hdr); |
2759 | encode_sequence(xdr, &args->seq_args, &hdr); | 2769 | encode_sequence(xdr, &args->seq_args, &hdr); |
2760 | encode_putfh(xdr, NFS_FH(args->inode), &hdr); | 2770 | encode_putfh(xdr, NFS_FH(args->inode), &hdr); |
2761 | encode_layoutcommit(xdr, args, &hdr); | 2771 | encode_layoutcommit(xdr, data->args.inode, args, &hdr); |
2762 | encode_getfattr(xdr, args->bitmask, &hdr); | 2772 | encode_getfattr(xdr, args->bitmask, &hdr); |
2763 | encode_nops(&hdr); | 2773 | encode_nops(&hdr); |
2764 | } | 2774 | } |
diff --git a/fs/nfs/pnfs.h b/fs/nfs/pnfs.h index 1b6b207a8806..3fda97146777 100644 --- a/fs/nfs/pnfs.h +++ b/fs/nfs/pnfs.h | |||
@@ -108,6 +108,10 @@ struct pnfs_layoutdriver_type { | |||
108 | void (*encode_layoutreturn) (struct pnfs_layout_hdr *layoutid, | 108 | void (*encode_layoutreturn) (struct pnfs_layout_hdr *layoutid, |
109 | struct xdr_stream *xdr, | 109 | struct xdr_stream *xdr, |
110 | const struct nfs4_layoutreturn_args *args); | 110 | const struct nfs4_layoutreturn_args *args); |
111 | |||
112 | void (*encode_layoutcommit) (struct pnfs_layout_hdr *layoutid, | ||
113 | struct xdr_stream *xdr, | ||
114 | const struct nfs4_layoutcommit_args *args); | ||
111 | }; | 115 | }; |
112 | 116 | ||
113 | struct pnfs_layout_hdr { | 117 | struct pnfs_layout_hdr { |