Loading...
1#include <linux/ceph/ceph_debug.h>
2
3#include <linux/exportfs.h>
4#include <linux/slab.h>
5#include <asm/unaligned.h>
6
7#include "super.h"
8#include "mds_client.h"
9
10/*
11 * Basic fh
12 */
13struct ceph_nfs_fh {
14 u64 ino;
15} __attribute__ ((packed));
16
17/*
18 * Larger fh that includes parent ino.
19 */
20struct ceph_nfs_confh {
21 u64 ino, parent_ino;
22} __attribute__ ((packed));
23
24static int ceph_encode_fh(struct inode *inode, u32 *rawfh, int *max_len,
25 struct inode *parent_inode)
26{
27 int type;
28 struct ceph_nfs_fh *fh = (void *)rawfh;
29 struct ceph_nfs_confh *cfh = (void *)rawfh;
30 int connected_handle_length = sizeof(*cfh)/4;
31 int handle_length = sizeof(*fh)/4;
32
33 /* don't re-export snaps */
34 if (ceph_snap(inode) != CEPH_NOSNAP)
35 return -EINVAL;
36
37 if (parent_inode && (*max_len < connected_handle_length)) {
38 *max_len = connected_handle_length;
39 return FILEID_INVALID;
40 } else if (*max_len < handle_length) {
41 *max_len = handle_length;
42 return FILEID_INVALID;
43 }
44
45 if (parent_inode) {
46 dout("encode_fh %llx with parent %llx\n",
47 ceph_ino(inode), ceph_ino(parent_inode));
48 cfh->ino = ceph_ino(inode);
49 cfh->parent_ino = ceph_ino(parent_inode);
50 *max_len = connected_handle_length;
51 type = FILEID_INO32_GEN_PARENT;
52 } else {
53 dout("encode_fh %llx\n", ceph_ino(inode));
54 fh->ino = ceph_ino(inode);
55 *max_len = handle_length;
56 type = FILEID_INO32_GEN;
57 }
58 return type;
59}
60
61static struct dentry *__fh_to_dentry(struct super_block *sb, u64 ino)
62{
63 struct ceph_mds_client *mdsc = ceph_sb_to_client(sb)->mdsc;
64 struct inode *inode;
65 struct dentry *dentry;
66 struct ceph_vino vino;
67 int err;
68
69 vino.ino = ino;
70 vino.snap = CEPH_NOSNAP;
71 inode = ceph_find_inode(sb, vino);
72 if (!inode) {
73 struct ceph_mds_request *req;
74 int mask;
75
76 req = ceph_mdsc_create_request(mdsc, CEPH_MDS_OP_LOOKUPINO,
77 USE_ANY_MDS);
78 if (IS_ERR(req))
79 return ERR_CAST(req);
80
81 mask = CEPH_STAT_CAP_INODE;
82 if (ceph_security_xattr_wanted(d_inode(sb->s_root)))
83 mask |= CEPH_CAP_XATTR_SHARED;
84 req->r_args.getattr.mask = cpu_to_le32(mask);
85
86 req->r_ino1 = vino;
87 req->r_num_caps = 1;
88 err = ceph_mdsc_do_request(mdsc, NULL, req);
89 inode = req->r_target_inode;
90 if (inode)
91 ihold(inode);
92 ceph_mdsc_put_request(req);
93 if (!inode)
94 return ERR_PTR(-ESTALE);
95 }
96
97 dentry = d_obtain_alias(inode);
98 if (IS_ERR(dentry)) {
99 iput(inode);
100 return dentry;
101 }
102 err = ceph_init_dentry(dentry);
103 if (err < 0) {
104 dput(dentry);
105 return ERR_PTR(err);
106 }
107 dout("__fh_to_dentry %llx %p dentry %p\n", ino, inode, dentry);
108 return dentry;
109}
110
111/*
112 * convert regular fh to dentry
113 */
114static struct dentry *ceph_fh_to_dentry(struct super_block *sb,
115 struct fid *fid,
116 int fh_len, int fh_type)
117{
118 struct ceph_nfs_fh *fh = (void *)fid->raw;
119
120 if (fh_type != FILEID_INO32_GEN &&
121 fh_type != FILEID_INO32_GEN_PARENT)
122 return NULL;
123 if (fh_len < sizeof(*fh) / 4)
124 return NULL;
125
126 dout("fh_to_dentry %llx\n", fh->ino);
127 return __fh_to_dentry(sb, fh->ino);
128}
129
130static struct dentry *__get_parent(struct super_block *sb,
131 struct dentry *child, u64 ino)
132{
133 struct ceph_mds_client *mdsc = ceph_sb_to_client(sb)->mdsc;
134 struct ceph_mds_request *req;
135 struct inode *inode;
136 struct dentry *dentry;
137 int mask;
138 int err;
139
140 req = ceph_mdsc_create_request(mdsc, CEPH_MDS_OP_LOOKUPPARENT,
141 USE_ANY_MDS);
142 if (IS_ERR(req))
143 return ERR_CAST(req);
144
145 if (child) {
146 req->r_inode = d_inode(child);
147 ihold(d_inode(child));
148 } else {
149 req->r_ino1 = (struct ceph_vino) {
150 .ino = ino,
151 .snap = CEPH_NOSNAP,
152 };
153 }
154
155 mask = CEPH_STAT_CAP_INODE;
156 if (ceph_security_xattr_wanted(d_inode(sb->s_root)))
157 mask |= CEPH_CAP_XATTR_SHARED;
158 req->r_args.getattr.mask = cpu_to_le32(mask);
159
160 req->r_num_caps = 1;
161 err = ceph_mdsc_do_request(mdsc, NULL, req);
162 inode = req->r_target_inode;
163 if (inode)
164 ihold(inode);
165 ceph_mdsc_put_request(req);
166 if (!inode)
167 return ERR_PTR(-ENOENT);
168
169 dentry = d_obtain_alias(inode);
170 if (IS_ERR(dentry)) {
171 iput(inode);
172 return dentry;
173 }
174 err = ceph_init_dentry(dentry);
175 if (err < 0) {
176 dput(dentry);
177 return ERR_PTR(err);
178 }
179 dout("__get_parent ino %llx parent %p ino %llx.%llx\n",
180 child ? ceph_ino(d_inode(child)) : ino,
181 dentry, ceph_vinop(inode));
182 return dentry;
183}
184
185static struct dentry *ceph_get_parent(struct dentry *child)
186{
187 /* don't re-export snaps */
188 if (ceph_snap(d_inode(child)) != CEPH_NOSNAP)
189 return ERR_PTR(-EINVAL);
190
191 dout("get_parent %p ino %llx.%llx\n",
192 child, ceph_vinop(d_inode(child)));
193 return __get_parent(child->d_sb, child, 0);
194}
195
196/*
197 * convert regular fh to parent
198 */
199static struct dentry *ceph_fh_to_parent(struct super_block *sb,
200 struct fid *fid,
201 int fh_len, int fh_type)
202{
203 struct ceph_nfs_confh *cfh = (void *)fid->raw;
204 struct dentry *dentry;
205
206 if (fh_type != FILEID_INO32_GEN_PARENT)
207 return NULL;
208 if (fh_len < sizeof(*cfh) / 4)
209 return NULL;
210
211 dout("fh_to_parent %llx\n", cfh->parent_ino);
212 dentry = __get_parent(sb, NULL, cfh->ino);
213 if (IS_ERR(dentry) && PTR_ERR(dentry) == -ENOENT)
214 dentry = __fh_to_dentry(sb, cfh->parent_ino);
215 return dentry;
216}
217
218static int ceph_get_name(struct dentry *parent, char *name,
219 struct dentry *child)
220{
221 struct ceph_mds_client *mdsc;
222 struct ceph_mds_request *req;
223 int err;
224
225 mdsc = ceph_inode_to_client(d_inode(child))->mdsc;
226 req = ceph_mdsc_create_request(mdsc, CEPH_MDS_OP_LOOKUPNAME,
227 USE_ANY_MDS);
228 if (IS_ERR(req))
229 return PTR_ERR(req);
230
231 inode_lock(d_inode(parent));
232
233 req->r_inode = d_inode(child);
234 ihold(d_inode(child));
235 req->r_ino2 = ceph_vino(d_inode(parent));
236 req->r_locked_dir = d_inode(parent);
237 req->r_num_caps = 2;
238 err = ceph_mdsc_do_request(mdsc, NULL, req);
239
240 inode_unlock(d_inode(parent));
241
242 if (!err) {
243 struct ceph_mds_reply_info_parsed *rinfo = &req->r_reply_info;
244 memcpy(name, rinfo->dname, rinfo->dname_len);
245 name[rinfo->dname_len] = 0;
246 dout("get_name %p ino %llx.%llx name %s\n",
247 child, ceph_vinop(d_inode(child)), name);
248 } else {
249 dout("get_name %p ino %llx.%llx err %d\n",
250 child, ceph_vinop(d_inode(child)), err);
251 }
252
253 ceph_mdsc_put_request(req);
254 return err;
255}
256
257const struct export_operations ceph_export_ops = {
258 .encode_fh = ceph_encode_fh,
259 .fh_to_dentry = ceph_fh_to_dentry,
260 .fh_to_parent = ceph_fh_to_parent,
261 .get_parent = ceph_get_parent,
262 .get_name = ceph_get_name,
263};
1#include <linux/ceph/ceph_debug.h>
2
3#include <linux/exportfs.h>
4#include <linux/slab.h>
5#include <asm/unaligned.h>
6
7#include "super.h"
8#include "mds_client.h"
9
10/*
11 * NFS export support
12 *
13 * NFS re-export of a ceph mount is, at present, only semireliable.
14 * The basic issue is that the Ceph architectures doesn't lend itself
15 * well to generating filehandles that will remain valid forever.
16 *
17 * So, we do our best. If you're lucky, your inode will be in the
18 * client's cache. If it's not, and you have a connectable fh, then
19 * the MDS server may be able to find it for you. Otherwise, you get
20 * ESTALE.
21 *
22 * There are ways to this more reliable, but in the non-connectable fh
23 * case, we won't every work perfectly, and in the connectable case,
24 * some changes are needed on the MDS side to work better.
25 */
26
27/*
28 * Basic fh
29 */
30struct ceph_nfs_fh {
31 u64 ino;
32} __attribute__ ((packed));
33
34/*
35 * Larger 'connectable' fh that includes parent ino and name hash.
36 * Use this whenever possible, as it works more reliably.
37 */
38struct ceph_nfs_confh {
39 u64 ino, parent_ino;
40 u32 parent_name_hash;
41} __attribute__ ((packed));
42
43static int ceph_encode_fh(struct dentry *dentry, u32 *rawfh, int *max_len,
44 int connectable)
45{
46 int type;
47 struct ceph_nfs_fh *fh = (void *)rawfh;
48 struct ceph_nfs_confh *cfh = (void *)rawfh;
49 struct dentry *parent;
50 struct inode *inode = dentry->d_inode;
51 int connected_handle_length = sizeof(*cfh)/4;
52 int handle_length = sizeof(*fh)/4;
53
54 /* don't re-export snaps */
55 if (ceph_snap(inode) != CEPH_NOSNAP)
56 return -EINVAL;
57
58 spin_lock(&dentry->d_lock);
59 parent = dget(dentry->d_parent);
60 spin_unlock(&dentry->d_lock);
61
62 if (*max_len >= connected_handle_length) {
63 dout("encode_fh %p connectable\n", dentry);
64 cfh->ino = ceph_ino(dentry->d_inode);
65 cfh->parent_ino = ceph_ino(parent->d_inode);
66 cfh->parent_name_hash = ceph_dentry_hash(parent->d_inode,
67 dentry);
68 *max_len = connected_handle_length;
69 type = 2;
70 } else if (*max_len >= handle_length) {
71 if (connectable) {
72 *max_len = connected_handle_length;
73 type = 255;
74 } else {
75 dout("encode_fh %p\n", dentry);
76 fh->ino = ceph_ino(dentry->d_inode);
77 *max_len = handle_length;
78 type = 1;
79 }
80 } else {
81 *max_len = handle_length;
82 type = 255;
83 }
84 dput(parent);
85 return type;
86}
87
88/*
89 * convert regular fh to dentry
90 *
91 * FIXME: we should try harder by querying the mds for the ino.
92 */
93static struct dentry *__fh_to_dentry(struct super_block *sb,
94 struct ceph_nfs_fh *fh)
95{
96 struct ceph_mds_client *mdsc = ceph_sb_to_client(sb)->mdsc;
97 struct inode *inode;
98 struct dentry *dentry;
99 struct ceph_vino vino;
100 int err;
101
102 dout("__fh_to_dentry %llx\n", fh->ino);
103 vino.ino = fh->ino;
104 vino.snap = CEPH_NOSNAP;
105 inode = ceph_find_inode(sb, vino);
106 if (!inode) {
107 struct ceph_mds_request *req;
108
109 req = ceph_mdsc_create_request(mdsc, CEPH_MDS_OP_LOOKUPINO,
110 USE_ANY_MDS);
111 if (IS_ERR(req))
112 return ERR_CAST(req);
113
114 req->r_ino1 = vino;
115 req->r_num_caps = 1;
116 err = ceph_mdsc_do_request(mdsc, NULL, req);
117 inode = req->r_target_inode;
118 if (inode)
119 ihold(inode);
120 ceph_mdsc_put_request(req);
121 if (!inode)
122 return ERR_PTR(-ESTALE);
123 }
124
125 dentry = d_obtain_alias(inode);
126 if (IS_ERR(dentry)) {
127 pr_err("fh_to_dentry %llx -- inode %p but ENOMEM\n",
128 fh->ino, inode);
129 iput(inode);
130 return dentry;
131 }
132 err = ceph_init_dentry(dentry);
133 if (err < 0) {
134 iput(inode);
135 return ERR_PTR(err);
136 }
137 dout("__fh_to_dentry %llx %p dentry %p\n", fh->ino, inode, dentry);
138 return dentry;
139}
140
141/*
142 * convert connectable fh to dentry
143 */
144static struct dentry *__cfh_to_dentry(struct super_block *sb,
145 struct ceph_nfs_confh *cfh)
146{
147 struct ceph_mds_client *mdsc = ceph_sb_to_client(sb)->mdsc;
148 struct inode *inode;
149 struct dentry *dentry;
150 struct ceph_vino vino;
151 int err;
152
153 dout("__cfh_to_dentry %llx (%llx/%x)\n",
154 cfh->ino, cfh->parent_ino, cfh->parent_name_hash);
155
156 vino.ino = cfh->ino;
157 vino.snap = CEPH_NOSNAP;
158 inode = ceph_find_inode(sb, vino);
159 if (!inode) {
160 struct ceph_mds_request *req;
161
162 req = ceph_mdsc_create_request(mdsc, CEPH_MDS_OP_LOOKUPHASH,
163 USE_ANY_MDS);
164 if (IS_ERR(req))
165 return ERR_CAST(req);
166
167 req->r_ino1 = vino;
168 req->r_ino2.ino = cfh->parent_ino;
169 req->r_ino2.snap = CEPH_NOSNAP;
170 req->r_path2 = kmalloc(16, GFP_NOFS);
171 snprintf(req->r_path2, 16, "%d", cfh->parent_name_hash);
172 req->r_num_caps = 1;
173 err = ceph_mdsc_do_request(mdsc, NULL, req);
174 inode = req->r_target_inode;
175 if (inode)
176 ihold(inode);
177 ceph_mdsc_put_request(req);
178 if (!inode)
179 return ERR_PTR(err ? err : -ESTALE);
180 }
181
182 dentry = d_obtain_alias(inode);
183 if (IS_ERR(dentry)) {
184 pr_err("cfh_to_dentry %llx -- inode %p but ENOMEM\n",
185 cfh->ino, inode);
186 iput(inode);
187 return dentry;
188 }
189 err = ceph_init_dentry(dentry);
190 if (err < 0) {
191 iput(inode);
192 return ERR_PTR(err);
193 }
194 dout("__cfh_to_dentry %llx %p dentry %p\n", cfh->ino, inode, dentry);
195 return dentry;
196}
197
198static struct dentry *ceph_fh_to_dentry(struct super_block *sb, struct fid *fid,
199 int fh_len, int fh_type)
200{
201 if (fh_type == 1)
202 return __fh_to_dentry(sb, (struct ceph_nfs_fh *)fid->raw);
203 else
204 return __cfh_to_dentry(sb, (struct ceph_nfs_confh *)fid->raw);
205}
206
207/*
208 * get parent, if possible.
209 *
210 * FIXME: we could do better by querying the mds to discover the
211 * parent.
212 */
213static struct dentry *ceph_fh_to_parent(struct super_block *sb,
214 struct fid *fid,
215 int fh_len, int fh_type)
216{
217 struct ceph_nfs_confh *cfh = (void *)fid->raw;
218 struct ceph_vino vino;
219 struct inode *inode;
220 struct dentry *dentry;
221 int err;
222
223 if (fh_type == 1)
224 return ERR_PTR(-ESTALE);
225
226 pr_debug("fh_to_parent %llx/%d\n", cfh->parent_ino,
227 cfh->parent_name_hash);
228
229 vino.ino = cfh->ino;
230 vino.snap = CEPH_NOSNAP;
231 inode = ceph_find_inode(sb, vino);
232 if (!inode)
233 return ERR_PTR(-ESTALE);
234
235 dentry = d_obtain_alias(inode);
236 if (IS_ERR(dentry)) {
237 pr_err("fh_to_parent %llx -- inode %p but ENOMEM\n",
238 cfh->ino, inode);
239 iput(inode);
240 return dentry;
241 }
242 err = ceph_init_dentry(dentry);
243 if (err < 0) {
244 iput(inode);
245 return ERR_PTR(err);
246 }
247 dout("fh_to_parent %llx %p dentry %p\n", cfh->ino, inode, dentry);
248 return dentry;
249}
250
251const struct export_operations ceph_export_ops = {
252 .encode_fh = ceph_encode_fh,
253 .fh_to_dentry = ceph_fh_to_dentry,
254 .fh_to_parent = ceph_fh_to_parent,
255};