]> git.proxmox.com Git - mirror_ubuntu-zesty-kernel.git/blame - fs/ceph/export.c
ceph: fix mds cluster availability check
[mirror_ubuntu-zesty-kernel.git] / fs / ceph / export.c
CommitLineData
3d14c5d2 1#include <linux/ceph/ceph_debug.h>
a8e63b7d
SW
2
3#include <linux/exportfs.h>
5a0e3ad6 4#include <linux/slab.h>
a8e63b7d
SW
5#include <asm/unaligned.h>
6
7#include "super.h"
3d14c5d2 8#include "mds_client.h"
a8e63b7d 9
a8e63b7d
SW
10/*
11 * Basic fh
12 */
13struct ceph_nfs_fh {
14 u64 ino;
15} __attribute__ ((packed));
16
17/*
4f32b42d 18 * Larger fh that includes parent ino.
a8e63b7d
SW
19 */
20struct ceph_nfs_confh {
21 u64 ino, parent_ino;
a8e63b7d
SW
22} __attribute__ ((packed));
23
c862868b
SW
24static int ceph_encode_fh(struct inode *inode, u32 *rawfh, int *max_len,
25 struct inode *parent_inode)
a8e63b7d 26{
92923dcb 27 int type;
a8e63b7d
SW
28 struct ceph_nfs_fh *fh = (void *)rawfh;
29 struct ceph_nfs_confh *cfh = (void *)rawfh;
92923dcb
AK
30 int connected_handle_length = sizeof(*cfh)/4;
31 int handle_length = sizeof(*fh)/4;
a8e63b7d
SW
32
33 /* don't re-export snaps */
34 if (ceph_snap(inode) != CEPH_NOSNAP)
35 return -EINVAL;
36
4f32b42d
YZ
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 }
f6af75da 44
4f32b42d
YZ
45 if (parent_inode) {
46 dout("encode_fh %llx with parent %llx\n",
47 ceph_ino(inode), ceph_ino(parent_inode));
c862868b 48 cfh->ino = ceph_ino(inode);
4f32b42d 49 cfh->parent_ino = ceph_ino(parent_inode);
92923dcb 50 *max_len = connected_handle_length;
4f32b42d 51 type = FILEID_INO32_GEN_PARENT;
a8e63b7d 52 } else {
4f32b42d
YZ
53 dout("encode_fh %llx\n", ceph_ino(inode));
54 fh->ino = ceph_ino(inode);
bba0cd0e 55 *max_len = handle_length;
4f32b42d 56 type = FILEID_INO32_GEN;
a8e63b7d
SW
57 }
58 return type;
59}
60
4f32b42d 61static struct dentry *__fh_to_dentry(struct super_block *sb, u64 ino)
a8e63b7d 62{
3c454cf2 63 struct ceph_mds_client *mdsc = ceph_sb_to_client(sb)->mdsc;
a8e63b7d 64 struct inode *inode;
a8e63b7d
SW
65 struct ceph_vino vino;
66 int err;
67
4f32b42d 68 vino.ino = ino;
a8e63b7d
SW
69 vino.snap = CEPH_NOSNAP;
70 inode = ceph_find_inode(sb, vino);
3c454cf2
SW
71 if (!inode) {
72 struct ceph_mds_request *req;
315f2408 73 int mask;
3c454cf2
SW
74
75 req = ceph_mdsc_create_request(mdsc, CEPH_MDS_OP_LOOKUPINO,
76 USE_ANY_MDS);
77 if (IS_ERR(req))
78 return ERR_CAST(req);
79
315f2408
YZ
80 mask = CEPH_STAT_CAP_INODE;
81 if (ceph_security_xattr_wanted(d_inode(sb->s_root)))
82 mask |= CEPH_CAP_XATTR_SHARED;
83 req->r_args.getattr.mask = cpu_to_le32(mask);
84
3c454cf2
SW
85 req->r_ino1 = vino;
86 req->r_num_caps = 1;
87 err = ceph_mdsc_do_request(mdsc, NULL, req);
45e3d3ee
SW
88 inode = req->r_target_inode;
89 if (inode)
70b666c3 90 ihold(inode);
3c454cf2 91 ceph_mdsc_put_request(req);
3c454cf2
SW
92 if (!inode)
93 return ERR_PTR(-ESTALE);
94 }
a8e63b7d 95
ad5cb123 96 return d_obtain_alias(inode);
a8e63b7d
SW
97}
98
99/*
4f32b42d 100 * convert regular fh to dentry
a8e63b7d 101 */
4f32b42d
YZ
102static struct dentry *ceph_fh_to_dentry(struct super_block *sb,
103 struct fid *fid,
104 int fh_len, int fh_type)
a8e63b7d 105{
4f32b42d 106 struct ceph_nfs_fh *fh = (void *)fid->raw;
a8e63b7d 107
4f32b42d
YZ
108 if (fh_type != FILEID_INO32_GEN &&
109 fh_type != FILEID_INO32_GEN_PARENT)
110 return NULL;
111 if (fh_len < sizeof(*fh) / 4)
112 return NULL;
a8e63b7d 113
4f32b42d
YZ
114 dout("fh_to_dentry %llx\n", fh->ino);
115 return __fh_to_dentry(sb, fh->ino);
a8e63b7d
SW
116}
117
9017c2ec
YZ
118static struct dentry *__get_parent(struct super_block *sb,
119 struct dentry *child, u64 ino)
120{
121 struct ceph_mds_client *mdsc = ceph_sb_to_client(sb)->mdsc;
122 struct ceph_mds_request *req;
123 struct inode *inode;
315f2408 124 int mask;
9017c2ec
YZ
125 int err;
126
127 req = ceph_mdsc_create_request(mdsc, CEPH_MDS_OP_LOOKUPPARENT,
128 USE_ANY_MDS);
129 if (IS_ERR(req))
130 return ERR_CAST(req);
131
132 if (child) {
2b0143b5
DH
133 req->r_inode = d_inode(child);
134 ihold(d_inode(child));
9017c2ec
YZ
135 } else {
136 req->r_ino1 = (struct ceph_vino) {
137 .ino = ino,
138 .snap = CEPH_NOSNAP,
139 };
140 }
315f2408
YZ
141
142 mask = CEPH_STAT_CAP_INODE;
143 if (ceph_security_xattr_wanted(d_inode(sb->s_root)))
144 mask |= CEPH_CAP_XATTR_SHARED;
145 req->r_args.getattr.mask = cpu_to_le32(mask);
146
9017c2ec
YZ
147 req->r_num_caps = 1;
148 err = ceph_mdsc_do_request(mdsc, NULL, req);
149 inode = req->r_target_inode;
150 if (inode)
151 ihold(inode);
152 ceph_mdsc_put_request(req);
153 if (!inode)
154 return ERR_PTR(-ENOENT);
155
ad5cb123 156 return d_obtain_alias(inode);
9017c2ec
YZ
157}
158
e84be11c 159static struct dentry *ceph_get_parent(struct dentry *child)
9017c2ec
YZ
160{
161 /* don't re-export snaps */
2b0143b5 162 if (ceph_snap(d_inode(child)) != CEPH_NOSNAP)
9017c2ec
YZ
163 return ERR_PTR(-EINVAL);
164
165 dout("get_parent %p ino %llx.%llx\n",
2b0143b5 166 child, ceph_vinop(d_inode(child)));
9017c2ec
YZ
167 return __get_parent(child->d_sb, child, 0);
168}
169
a8e63b7d 170/*
8996f4f2 171 * convert regular fh to parent
a8e63b7d
SW
172 */
173static struct dentry *ceph_fh_to_parent(struct super_block *sb,
8996f4f2 174 struct fid *fid,
a8e63b7d
SW
175 int fh_len, int fh_type)
176{
177 struct ceph_nfs_confh *cfh = (void *)fid->raw;
a8e63b7d 178 struct dentry *dentry;
a8e63b7d 179
8996f4f2
YZ
180 if (fh_type != FILEID_INO32_GEN_PARENT)
181 return NULL;
35c2a7f4 182 if (fh_len < sizeof(*cfh) / 4)
8996f4f2 183 return NULL;
a8e63b7d 184
8996f4f2
YZ
185 dout("fh_to_parent %llx\n", cfh->parent_ino);
186 dentry = __get_parent(sb, NULL, cfh->ino);
b42b90d1 187 if (unlikely(dentry == ERR_PTR(-ENOENT)))
8996f4f2 188 dentry = __fh_to_dentry(sb, cfh->parent_ino);
a8e63b7d
SW
189 return dentry;
190}
191
19913b4e
YZ
192static int ceph_get_name(struct dentry *parent, char *name,
193 struct dentry *child)
194{
195 struct ceph_mds_client *mdsc;
196 struct ceph_mds_request *req;
197 int err;
198
2b0143b5 199 mdsc = ceph_inode_to_client(d_inode(child))->mdsc;
19913b4e
YZ
200 req = ceph_mdsc_create_request(mdsc, CEPH_MDS_OP_LOOKUPNAME,
201 USE_ANY_MDS);
202 if (IS_ERR(req))
203 return PTR_ERR(req);
204
5955102c 205 inode_lock(d_inode(parent));
19913b4e 206
2b0143b5
DH
207 req->r_inode = d_inode(child);
208 ihold(d_inode(child));
209 req->r_ino2 = ceph_vino(d_inode(parent));
210 req->r_locked_dir = d_inode(parent);
19913b4e
YZ
211 req->r_num_caps = 2;
212 err = ceph_mdsc_do_request(mdsc, NULL, req);
213
5955102c 214 inode_unlock(d_inode(parent));
19913b4e
YZ
215
216 if (!err) {
217 struct ceph_mds_reply_info_parsed *rinfo = &req->r_reply_info;
218 memcpy(name, rinfo->dname, rinfo->dname_len);
219 name[rinfo->dname_len] = 0;
220 dout("get_name %p ino %llx.%llx name %s\n",
2b0143b5 221 child, ceph_vinop(d_inode(child)), name);
19913b4e
YZ
222 } else {
223 dout("get_name %p ino %llx.%llx err %d\n",
2b0143b5 224 child, ceph_vinop(d_inode(child)), err);
19913b4e
YZ
225 }
226
227 ceph_mdsc_put_request(req);
228 return err;
229}
230
a8e63b7d
SW
231const struct export_operations ceph_export_ops = {
232 .encode_fh = ceph_encode_fh,
233 .fh_to_dentry = ceph_fh_to_dentry,
234 .fh_to_parent = ceph_fh_to_parent,
9017c2ec 235 .get_parent = ceph_get_parent,
19913b4e 236 .get_name = ceph_get_name,
a8e63b7d 237};