xref: /openbmc/linux/fs/ceph/xattr.c (revision bddfa3cc18fcd9c9313a1030b19d3b0ea2639310)
1355da1ebSSage Weil #include "ceph_debug.h"
2355da1ebSSage Weil #include "super.h"
3355da1ebSSage Weil #include "decode.h"
4355da1ebSSage Weil 
5355da1ebSSage Weil #include <linux/xattr.h>
65a0e3ad6STejun Heo #include <linux/slab.h>
7355da1ebSSage Weil 
8355da1ebSSage Weil static bool ceph_is_valid_xattr(const char *name)
9355da1ebSSage Weil {
10355da1ebSSage Weil 	return !strncmp(name, XATTR_SECURITY_PREFIX,
11355da1ebSSage Weil 			XATTR_SECURITY_PREFIX_LEN) ||
12355da1ebSSage Weil 	       !strncmp(name, XATTR_TRUSTED_PREFIX, XATTR_TRUSTED_PREFIX_LEN) ||
13355da1ebSSage Weil 	       !strncmp(name, XATTR_USER_PREFIX, XATTR_USER_PREFIX_LEN);
14355da1ebSSage Weil }
15355da1ebSSage Weil 
16355da1ebSSage Weil /*
17355da1ebSSage Weil  * These define virtual xattrs exposing the recursive directory
18355da1ebSSage Weil  * statistics and layout metadata.
19355da1ebSSage Weil  */
20355da1ebSSage Weil struct ceph_vxattr_cb {
21355da1ebSSage Weil 	bool readonly;
22355da1ebSSage Weil 	char *name;
23355da1ebSSage Weil 	size_t (*getxattr_cb)(struct ceph_inode_info *ci, char *val,
24355da1ebSSage Weil 			      size_t size);
25355da1ebSSage Weil };
26355da1ebSSage Weil 
27355da1ebSSage Weil /* directories */
28355da1ebSSage Weil 
29355da1ebSSage Weil static size_t ceph_vxattrcb_entries(struct ceph_inode_info *ci, char *val,
30355da1ebSSage Weil 					size_t size)
31355da1ebSSage Weil {
32355da1ebSSage Weil 	return snprintf(val, size, "%lld", ci->i_files + ci->i_subdirs);
33355da1ebSSage Weil }
34355da1ebSSage Weil 
35355da1ebSSage Weil static size_t ceph_vxattrcb_files(struct ceph_inode_info *ci, char *val,
36355da1ebSSage Weil 				      size_t size)
37355da1ebSSage Weil {
38355da1ebSSage Weil 	return snprintf(val, size, "%lld", ci->i_files);
39355da1ebSSage Weil }
40355da1ebSSage Weil 
41355da1ebSSage Weil static size_t ceph_vxattrcb_subdirs(struct ceph_inode_info *ci, char *val,
42355da1ebSSage Weil 					size_t size)
43355da1ebSSage Weil {
44355da1ebSSage Weil 	return snprintf(val, size, "%lld", ci->i_subdirs);
45355da1ebSSage Weil }
46355da1ebSSage Weil 
47355da1ebSSage Weil static size_t ceph_vxattrcb_rentries(struct ceph_inode_info *ci, char *val,
48355da1ebSSage Weil 					 size_t size)
49355da1ebSSage Weil {
50355da1ebSSage Weil 	return snprintf(val, size, "%lld", ci->i_rfiles + ci->i_rsubdirs);
51355da1ebSSage Weil }
52355da1ebSSage Weil 
53355da1ebSSage Weil static size_t ceph_vxattrcb_rfiles(struct ceph_inode_info *ci, char *val,
54355da1ebSSage Weil 				       size_t size)
55355da1ebSSage Weil {
56355da1ebSSage Weil 	return snprintf(val, size, "%lld", ci->i_rfiles);
57355da1ebSSage Weil }
58355da1ebSSage Weil 
59355da1ebSSage Weil static size_t ceph_vxattrcb_rsubdirs(struct ceph_inode_info *ci, char *val,
60355da1ebSSage Weil 					 size_t size)
61355da1ebSSage Weil {
62355da1ebSSage Weil 	return snprintf(val, size, "%lld", ci->i_rsubdirs);
63355da1ebSSage Weil }
64355da1ebSSage Weil 
65355da1ebSSage Weil static size_t ceph_vxattrcb_rbytes(struct ceph_inode_info *ci, char *val,
66355da1ebSSage Weil 				       size_t size)
67355da1ebSSage Weil {
68355da1ebSSage Weil 	return snprintf(val, size, "%lld", ci->i_rbytes);
69355da1ebSSage Weil }
70355da1ebSSage Weil 
71355da1ebSSage Weil static size_t ceph_vxattrcb_rctime(struct ceph_inode_info *ci, char *val,
72355da1ebSSage Weil 				       size_t size)
73355da1ebSSage Weil {
74355da1ebSSage Weil 	return snprintf(val, size, "%ld.%ld", (long)ci->i_rctime.tv_sec,
75355da1ebSSage Weil 			(long)ci->i_rctime.tv_nsec);
76355da1ebSSage Weil }
77355da1ebSSage Weil 
78355da1ebSSage Weil static struct ceph_vxattr_cb ceph_dir_vxattrs[] = {
79355da1ebSSage Weil 	{ true, "user.ceph.dir.entries", ceph_vxattrcb_entries},
80355da1ebSSage Weil 	{ true, "user.ceph.dir.files", ceph_vxattrcb_files},
81355da1ebSSage Weil 	{ true, "user.ceph.dir.subdirs", ceph_vxattrcb_subdirs},
82355da1ebSSage Weil 	{ true, "user.ceph.dir.rentries", ceph_vxattrcb_rentries},
83355da1ebSSage Weil 	{ true, "user.ceph.dir.rfiles", ceph_vxattrcb_rfiles},
84355da1ebSSage Weil 	{ true, "user.ceph.dir.rsubdirs", ceph_vxattrcb_rsubdirs},
85355da1ebSSage Weil 	{ true, "user.ceph.dir.rbytes", ceph_vxattrcb_rbytes},
86355da1ebSSage Weil 	{ true, "user.ceph.dir.rctime", ceph_vxattrcb_rctime},
87355da1ebSSage Weil 	{ true, NULL, NULL }
88355da1ebSSage Weil };
89355da1ebSSage Weil 
90355da1ebSSage Weil /* files */
91355da1ebSSage Weil 
92355da1ebSSage Weil static size_t ceph_vxattrcb_layout(struct ceph_inode_info *ci, char *val,
93355da1ebSSage Weil 				   size_t size)
94355da1ebSSage Weil {
95b195befdSSage Weil 	int ret;
96b195befdSSage Weil 
97b195befdSSage Weil 	ret = snprintf(val, size,
98355da1ebSSage Weil 		"chunk_bytes=%lld\nstripe_count=%lld\nobject_size=%lld\n",
99355da1ebSSage Weil 		(unsigned long long)ceph_file_layout_su(ci->i_layout),
100355da1ebSSage Weil 		(unsigned long long)ceph_file_layout_stripe_count(ci->i_layout),
101355da1ebSSage Weil 		(unsigned long long)ceph_file_layout_object_size(ci->i_layout));
102b195befdSSage Weil 	if (ceph_file_layout_pg_preferred(ci->i_layout))
103b195befdSSage Weil 		ret += snprintf(val + ret, size, "preferred_osd=%lld\n",
104b195befdSSage Weil 			    (unsigned long long)ceph_file_layout_pg_preferred(
105b195befdSSage Weil 				    ci->i_layout));
106b195befdSSage Weil 	return ret;
107355da1ebSSage Weil }
108355da1ebSSage Weil 
109355da1ebSSage Weil static struct ceph_vxattr_cb ceph_file_vxattrs[] = {
110355da1ebSSage Weil 	{ true, "user.ceph.layout", ceph_vxattrcb_layout},
111355da1ebSSage Weil 	{ NULL, NULL }
112355da1ebSSage Weil };
113355da1ebSSage Weil 
114355da1ebSSage Weil static struct ceph_vxattr_cb *ceph_inode_vxattrs(struct inode *inode)
115355da1ebSSage Weil {
116355da1ebSSage Weil 	if (S_ISDIR(inode->i_mode))
117355da1ebSSage Weil 		return ceph_dir_vxattrs;
118355da1ebSSage Weil 	else if (S_ISREG(inode->i_mode))
119355da1ebSSage Weil 		return ceph_file_vxattrs;
120355da1ebSSage Weil 	return NULL;
121355da1ebSSage Weil }
122355da1ebSSage Weil 
123355da1ebSSage Weil static struct ceph_vxattr_cb *ceph_match_vxattr(struct ceph_vxattr_cb *vxattr,
124355da1ebSSage Weil 						const char *name)
125355da1ebSSage Weil {
126355da1ebSSage Weil 	do {
127355da1ebSSage Weil 		if (strcmp(vxattr->name, name) == 0)
128355da1ebSSage Weil 			return vxattr;
129355da1ebSSage Weil 		vxattr++;
130355da1ebSSage Weil 	} while (vxattr->name);
131355da1ebSSage Weil 	return NULL;
132355da1ebSSage Weil }
133355da1ebSSage Weil 
134355da1ebSSage Weil static int __set_xattr(struct ceph_inode_info *ci,
135355da1ebSSage Weil 			   const char *name, int name_len,
136355da1ebSSage Weil 			   const char *val, int val_len,
137355da1ebSSage Weil 			   int dirty,
138355da1ebSSage Weil 			   int should_free_name, int should_free_val,
139355da1ebSSage Weil 			   struct ceph_inode_xattr **newxattr)
140355da1ebSSage Weil {
141355da1ebSSage Weil 	struct rb_node **p;
142355da1ebSSage Weil 	struct rb_node *parent = NULL;
143355da1ebSSage Weil 	struct ceph_inode_xattr *xattr = NULL;
144355da1ebSSage Weil 	int c;
145355da1ebSSage Weil 	int new = 0;
146355da1ebSSage Weil 
147355da1ebSSage Weil 	p = &ci->i_xattrs.index.rb_node;
148355da1ebSSage Weil 	while (*p) {
149355da1ebSSage Weil 		parent = *p;
150355da1ebSSage Weil 		xattr = rb_entry(parent, struct ceph_inode_xattr, node);
151355da1ebSSage Weil 		c = strncmp(name, xattr->name, min(name_len, xattr->name_len));
152355da1ebSSage Weil 		if (c < 0)
153355da1ebSSage Weil 			p = &(*p)->rb_left;
154355da1ebSSage Weil 		else if (c > 0)
155355da1ebSSage Weil 			p = &(*p)->rb_right;
156355da1ebSSage Weil 		else {
157355da1ebSSage Weil 			if (name_len == xattr->name_len)
158355da1ebSSage Weil 				break;
159355da1ebSSage Weil 			else if (name_len < xattr->name_len)
160355da1ebSSage Weil 				p = &(*p)->rb_left;
161355da1ebSSage Weil 			else
162355da1ebSSage Weil 				p = &(*p)->rb_right;
163355da1ebSSage Weil 		}
164355da1ebSSage Weil 		xattr = NULL;
165355da1ebSSage Weil 	}
166355da1ebSSage Weil 
167355da1ebSSage Weil 	if (!xattr) {
168355da1ebSSage Weil 		new = 1;
169355da1ebSSage Weil 		xattr = *newxattr;
170355da1ebSSage Weil 		xattr->name = name;
171355da1ebSSage Weil 		xattr->name_len = name_len;
172355da1ebSSage Weil 		xattr->should_free_name = should_free_name;
173355da1ebSSage Weil 
174355da1ebSSage Weil 		ci->i_xattrs.count++;
175355da1ebSSage Weil 		dout("__set_xattr count=%d\n", ci->i_xattrs.count);
176355da1ebSSage Weil 	} else {
177355da1ebSSage Weil 		kfree(*newxattr);
178355da1ebSSage Weil 		*newxattr = NULL;
179355da1ebSSage Weil 		if (xattr->should_free_val)
180355da1ebSSage Weil 			kfree((void *)xattr->val);
181355da1ebSSage Weil 
182355da1ebSSage Weil 		if (should_free_name) {
183355da1ebSSage Weil 			kfree((void *)name);
184355da1ebSSage Weil 			name = xattr->name;
185355da1ebSSage Weil 		}
186355da1ebSSage Weil 		ci->i_xattrs.names_size -= xattr->name_len;
187355da1ebSSage Weil 		ci->i_xattrs.vals_size -= xattr->val_len;
188355da1ebSSage Weil 	}
189355da1ebSSage Weil 	ci->i_xattrs.names_size += name_len;
190355da1ebSSage Weil 	ci->i_xattrs.vals_size += val_len;
191355da1ebSSage Weil 	if (val)
192355da1ebSSage Weil 		xattr->val = val;
193355da1ebSSage Weil 	else
194355da1ebSSage Weil 		xattr->val = "";
195355da1ebSSage Weil 
196355da1ebSSage Weil 	xattr->val_len = val_len;
197355da1ebSSage Weil 	xattr->dirty = dirty;
198355da1ebSSage Weil 	xattr->should_free_val = (val && should_free_val);
199355da1ebSSage Weil 
200355da1ebSSage Weil 	if (new) {
201355da1ebSSage Weil 		rb_link_node(&xattr->node, parent, p);
202355da1ebSSage Weil 		rb_insert_color(&xattr->node, &ci->i_xattrs.index);
203355da1ebSSage Weil 		dout("__set_xattr_val p=%p\n", p);
204355da1ebSSage Weil 	}
205355da1ebSSage Weil 
206355da1ebSSage Weil 	dout("__set_xattr_val added %llx.%llx xattr %p %s=%.*s\n",
207355da1ebSSage Weil 	     ceph_vinop(&ci->vfs_inode), xattr, name, val_len, val);
208355da1ebSSage Weil 
209355da1ebSSage Weil 	return 0;
210355da1ebSSage Weil }
211355da1ebSSage Weil 
212355da1ebSSage Weil static struct ceph_inode_xattr *__get_xattr(struct ceph_inode_info *ci,
213355da1ebSSage Weil 			   const char *name)
214355da1ebSSage Weil {
215355da1ebSSage Weil 	struct rb_node **p;
216355da1ebSSage Weil 	struct rb_node *parent = NULL;
217355da1ebSSage Weil 	struct ceph_inode_xattr *xattr = NULL;
218355da1ebSSage Weil 	int c;
219355da1ebSSage Weil 
220355da1ebSSage Weil 	p = &ci->i_xattrs.index.rb_node;
221355da1ebSSage Weil 	while (*p) {
222355da1ebSSage Weil 		parent = *p;
223355da1ebSSage Weil 		xattr = rb_entry(parent, struct ceph_inode_xattr, node);
224355da1ebSSage Weil 		c = strncmp(name, xattr->name, xattr->name_len);
225355da1ebSSage Weil 		if (c < 0)
226355da1ebSSage Weil 			p = &(*p)->rb_left;
227355da1ebSSage Weil 		else if (c > 0)
228355da1ebSSage Weil 			p = &(*p)->rb_right;
229355da1ebSSage Weil 		else {
230355da1ebSSage Weil 			dout("__get_xattr %s: found %.*s\n", name,
231355da1ebSSage Weil 			     xattr->val_len, xattr->val);
232355da1ebSSage Weil 			return xattr;
233355da1ebSSage Weil 		}
234355da1ebSSage Weil 	}
235355da1ebSSage Weil 
236355da1ebSSage Weil 	dout("__get_xattr %s: not found\n", name);
237355da1ebSSage Weil 
238355da1ebSSage Weil 	return NULL;
239355da1ebSSage Weil }
240355da1ebSSage Weil 
241355da1ebSSage Weil static void __free_xattr(struct ceph_inode_xattr *xattr)
242355da1ebSSage Weil {
243355da1ebSSage Weil 	BUG_ON(!xattr);
244355da1ebSSage Weil 
245355da1ebSSage Weil 	if (xattr->should_free_name)
246355da1ebSSage Weil 		kfree((void *)xattr->name);
247355da1ebSSage Weil 	if (xattr->should_free_val)
248355da1ebSSage Weil 		kfree((void *)xattr->val);
249355da1ebSSage Weil 
250355da1ebSSage Weil 	kfree(xattr);
251355da1ebSSage Weil }
252355da1ebSSage Weil 
253355da1ebSSage Weil static int __remove_xattr(struct ceph_inode_info *ci,
254355da1ebSSage Weil 			  struct ceph_inode_xattr *xattr)
255355da1ebSSage Weil {
256355da1ebSSage Weil 	if (!xattr)
257355da1ebSSage Weil 		return -EOPNOTSUPP;
258355da1ebSSage Weil 
259355da1ebSSage Weil 	rb_erase(&xattr->node, &ci->i_xattrs.index);
260355da1ebSSage Weil 
261355da1ebSSage Weil 	if (xattr->should_free_name)
262355da1ebSSage Weil 		kfree((void *)xattr->name);
263355da1ebSSage Weil 	if (xattr->should_free_val)
264355da1ebSSage Weil 		kfree((void *)xattr->val);
265355da1ebSSage Weil 
266355da1ebSSage Weil 	ci->i_xattrs.names_size -= xattr->name_len;
267355da1ebSSage Weil 	ci->i_xattrs.vals_size -= xattr->val_len;
268355da1ebSSage Weil 	ci->i_xattrs.count--;
269355da1ebSSage Weil 	kfree(xattr);
270355da1ebSSage Weil 
271355da1ebSSage Weil 	return 0;
272355da1ebSSage Weil }
273355da1ebSSage Weil 
274355da1ebSSage Weil static int __remove_xattr_by_name(struct ceph_inode_info *ci,
275355da1ebSSage Weil 			   const char *name)
276355da1ebSSage Weil {
277355da1ebSSage Weil 	struct rb_node **p;
278355da1ebSSage Weil 	struct ceph_inode_xattr *xattr;
279355da1ebSSage Weil 	int err;
280355da1ebSSage Weil 
281355da1ebSSage Weil 	p = &ci->i_xattrs.index.rb_node;
282355da1ebSSage Weil 	xattr = __get_xattr(ci, name);
283355da1ebSSage Weil 	err = __remove_xattr(ci, xattr);
284355da1ebSSage Weil 	return err;
285355da1ebSSage Weil }
286355da1ebSSage Weil 
287355da1ebSSage Weil static char *__copy_xattr_names(struct ceph_inode_info *ci,
288355da1ebSSage Weil 				char *dest)
289355da1ebSSage Weil {
290355da1ebSSage Weil 	struct rb_node *p;
291355da1ebSSage Weil 	struct ceph_inode_xattr *xattr = NULL;
292355da1ebSSage Weil 
293355da1ebSSage Weil 	p = rb_first(&ci->i_xattrs.index);
294355da1ebSSage Weil 	dout("__copy_xattr_names count=%d\n", ci->i_xattrs.count);
295355da1ebSSage Weil 
296355da1ebSSage Weil 	while (p) {
297355da1ebSSage Weil 		xattr = rb_entry(p, struct ceph_inode_xattr, node);
298355da1ebSSage Weil 		memcpy(dest, xattr->name, xattr->name_len);
299355da1ebSSage Weil 		dest[xattr->name_len] = '\0';
300355da1ebSSage Weil 
301355da1ebSSage Weil 		dout("dest=%s %p (%s) (%d/%d)\n", dest, xattr, xattr->name,
302355da1ebSSage Weil 		     xattr->name_len, ci->i_xattrs.names_size);
303355da1ebSSage Weil 
304355da1ebSSage Weil 		dest += xattr->name_len + 1;
305355da1ebSSage Weil 		p = rb_next(p);
306355da1ebSSage Weil 	}
307355da1ebSSage Weil 
308355da1ebSSage Weil 	return dest;
309355da1ebSSage Weil }
310355da1ebSSage Weil 
311355da1ebSSage Weil void __ceph_destroy_xattrs(struct ceph_inode_info *ci)
312355da1ebSSage Weil {
313355da1ebSSage Weil 	struct rb_node *p, *tmp;
314355da1ebSSage Weil 	struct ceph_inode_xattr *xattr = NULL;
315355da1ebSSage Weil 
316355da1ebSSage Weil 	p = rb_first(&ci->i_xattrs.index);
317355da1ebSSage Weil 
318355da1ebSSage Weil 	dout("__ceph_destroy_xattrs p=%p\n", p);
319355da1ebSSage Weil 
320355da1ebSSage Weil 	while (p) {
321355da1ebSSage Weil 		xattr = rb_entry(p, struct ceph_inode_xattr, node);
322355da1ebSSage Weil 		tmp = p;
323355da1ebSSage Weil 		p = rb_next(tmp);
324355da1ebSSage Weil 		dout("__ceph_destroy_xattrs next p=%p (%.*s)\n", p,
325355da1ebSSage Weil 		     xattr->name_len, xattr->name);
326355da1ebSSage Weil 		rb_erase(tmp, &ci->i_xattrs.index);
327355da1ebSSage Weil 
328355da1ebSSage Weil 		__free_xattr(xattr);
329355da1ebSSage Weil 	}
330355da1ebSSage Weil 
331355da1ebSSage Weil 	ci->i_xattrs.names_size = 0;
332355da1ebSSage Weil 	ci->i_xattrs.vals_size = 0;
333355da1ebSSage Weil 	ci->i_xattrs.index_version = 0;
334355da1ebSSage Weil 	ci->i_xattrs.count = 0;
335355da1ebSSage Weil 	ci->i_xattrs.index = RB_ROOT;
336355da1ebSSage Weil }
337355da1ebSSage Weil 
338355da1ebSSage Weil static int __build_xattrs(struct inode *inode)
339355da1ebSSage Weil {
340355da1ebSSage Weil 	u32 namelen;
341355da1ebSSage Weil 	u32 numattr = 0;
342355da1ebSSage Weil 	void *p, *end;
343355da1ebSSage Weil 	u32 len;
344355da1ebSSage Weil 	const char *name, *val;
345355da1ebSSage Weil 	struct ceph_inode_info *ci = ceph_inode(inode);
346355da1ebSSage Weil 	int xattr_version;
347355da1ebSSage Weil 	struct ceph_inode_xattr **xattrs = NULL;
34863ff78b2SSage Weil 	int err = 0;
349355da1ebSSage Weil 	int i;
350355da1ebSSage Weil 
351355da1ebSSage Weil 	dout("__build_xattrs() len=%d\n",
352355da1ebSSage Weil 	     ci->i_xattrs.blob ? (int)ci->i_xattrs.blob->vec.iov_len : 0);
353355da1ebSSage Weil 
354355da1ebSSage Weil 	if (ci->i_xattrs.index_version >= ci->i_xattrs.version)
355355da1ebSSage Weil 		return 0; /* already built */
356355da1ebSSage Weil 
357355da1ebSSage Weil 	__ceph_destroy_xattrs(ci);
358355da1ebSSage Weil 
359355da1ebSSage Weil start:
360355da1ebSSage Weil 	/* updated internal xattr rb tree */
361355da1ebSSage Weil 	if (ci->i_xattrs.blob && ci->i_xattrs.blob->vec.iov_len > 4) {
362355da1ebSSage Weil 		p = ci->i_xattrs.blob->vec.iov_base;
363355da1ebSSage Weil 		end = p + ci->i_xattrs.blob->vec.iov_len;
364355da1ebSSage Weil 		ceph_decode_32_safe(&p, end, numattr, bad);
365355da1ebSSage Weil 		xattr_version = ci->i_xattrs.version;
366355da1ebSSage Weil 		spin_unlock(&inode->i_lock);
367355da1ebSSage Weil 
368355da1ebSSage Weil 		xattrs = kcalloc(numattr, sizeof(struct ceph_xattr *),
369355da1ebSSage Weil 				 GFP_NOFS);
370355da1ebSSage Weil 		err = -ENOMEM;
371355da1ebSSage Weil 		if (!xattrs)
372355da1ebSSage Weil 			goto bad_lock;
373355da1ebSSage Weil 		memset(xattrs, 0, numattr*sizeof(struct ceph_xattr *));
374355da1ebSSage Weil 		for (i = 0; i < numattr; i++) {
375355da1ebSSage Weil 			xattrs[i] = kmalloc(sizeof(struct ceph_inode_xattr),
376355da1ebSSage Weil 					    GFP_NOFS);
377355da1ebSSage Weil 			if (!xattrs[i])
378355da1ebSSage Weil 				goto bad_lock;
379355da1ebSSage Weil 		}
380355da1ebSSage Weil 
381355da1ebSSage Weil 		spin_lock(&inode->i_lock);
382355da1ebSSage Weil 		if (ci->i_xattrs.version != xattr_version) {
383355da1ebSSage Weil 			/* lost a race, retry */
384355da1ebSSage Weil 			for (i = 0; i < numattr; i++)
385355da1ebSSage Weil 				kfree(xattrs[i]);
386355da1ebSSage Weil 			kfree(xattrs);
387355da1ebSSage Weil 			goto start;
388355da1ebSSage Weil 		}
389355da1ebSSage Weil 		err = -EIO;
390355da1ebSSage Weil 		while (numattr--) {
391355da1ebSSage Weil 			ceph_decode_32_safe(&p, end, len, bad);
392355da1ebSSage Weil 			namelen = len;
393355da1ebSSage Weil 			name = p;
394355da1ebSSage Weil 			p += len;
395355da1ebSSage Weil 			ceph_decode_32_safe(&p, end, len, bad);
396355da1ebSSage Weil 			val = p;
397355da1ebSSage Weil 			p += len;
398355da1ebSSage Weil 
399355da1ebSSage Weil 			err = __set_xattr(ci, name, namelen, val, len,
400355da1ebSSage Weil 					  0, 0, 0, &xattrs[numattr]);
401355da1ebSSage Weil 
402355da1ebSSage Weil 			if (err < 0)
403355da1ebSSage Weil 				goto bad;
404355da1ebSSage Weil 		}
405355da1ebSSage Weil 		kfree(xattrs);
406355da1ebSSage Weil 	}
407355da1ebSSage Weil 	ci->i_xattrs.index_version = ci->i_xattrs.version;
408355da1ebSSage Weil 	ci->i_xattrs.dirty = false;
409355da1ebSSage Weil 
410355da1ebSSage Weil 	return err;
411355da1ebSSage Weil bad_lock:
412355da1ebSSage Weil 	spin_lock(&inode->i_lock);
413355da1ebSSage Weil bad:
414355da1ebSSage Weil 	if (xattrs) {
415355da1ebSSage Weil 		for (i = 0; i < numattr; i++)
416355da1ebSSage Weil 			kfree(xattrs[i]);
417355da1ebSSage Weil 		kfree(xattrs);
418355da1ebSSage Weil 	}
419355da1ebSSage Weil 	ci->i_xattrs.names_size = 0;
420355da1ebSSage Weil 	return err;
421355da1ebSSage Weil }
422355da1ebSSage Weil 
423355da1ebSSage Weil static int __get_required_blob_size(struct ceph_inode_info *ci, int name_size,
424355da1ebSSage Weil 				    int val_size)
425355da1ebSSage Weil {
426355da1ebSSage Weil 	/*
427355da1ebSSage Weil 	 * 4 bytes for the length, and additional 4 bytes per each xattr name,
428355da1ebSSage Weil 	 * 4 bytes per each value
429355da1ebSSage Weil 	 */
430355da1ebSSage Weil 	int size = 4 + ci->i_xattrs.count*(4 + 4) +
431355da1ebSSage Weil 			     ci->i_xattrs.names_size +
432355da1ebSSage Weil 			     ci->i_xattrs.vals_size;
433355da1ebSSage Weil 	dout("__get_required_blob_size c=%d names.size=%d vals.size=%d\n",
434355da1ebSSage Weil 	     ci->i_xattrs.count, ci->i_xattrs.names_size,
435355da1ebSSage Weil 	     ci->i_xattrs.vals_size);
436355da1ebSSage Weil 
437355da1ebSSage Weil 	if (name_size)
438355da1ebSSage Weil 		size += 4 + 4 + name_size + val_size;
439355da1ebSSage Weil 
440355da1ebSSage Weil 	return size;
441355da1ebSSage Weil }
442355da1ebSSage Weil 
443355da1ebSSage Weil /*
444355da1ebSSage Weil  * If there are dirty xattrs, reencode xattrs into the prealloc_blob
445355da1ebSSage Weil  * and swap into place.
446355da1ebSSage Weil  */
447355da1ebSSage Weil void __ceph_build_xattrs_blob(struct ceph_inode_info *ci)
448355da1ebSSage Weil {
449355da1ebSSage Weil 	struct rb_node *p;
450355da1ebSSage Weil 	struct ceph_inode_xattr *xattr = NULL;
451355da1ebSSage Weil 	void *dest;
452355da1ebSSage Weil 
453355da1ebSSage Weil 	dout("__build_xattrs_blob %p\n", &ci->vfs_inode);
454355da1ebSSage Weil 	if (ci->i_xattrs.dirty) {
455355da1ebSSage Weil 		int need = __get_required_blob_size(ci, 0, 0);
456355da1ebSSage Weil 
457355da1ebSSage Weil 		BUG_ON(need > ci->i_xattrs.prealloc_blob->alloc_len);
458355da1ebSSage Weil 
459355da1ebSSage Weil 		p = rb_first(&ci->i_xattrs.index);
460355da1ebSSage Weil 		dest = ci->i_xattrs.prealloc_blob->vec.iov_base;
461355da1ebSSage Weil 
462355da1ebSSage Weil 		ceph_encode_32(&dest, ci->i_xattrs.count);
463355da1ebSSage Weil 		while (p) {
464355da1ebSSage Weil 			xattr = rb_entry(p, struct ceph_inode_xattr, node);
465355da1ebSSage Weil 
466355da1ebSSage Weil 			ceph_encode_32(&dest, xattr->name_len);
467355da1ebSSage Weil 			memcpy(dest, xattr->name, xattr->name_len);
468355da1ebSSage Weil 			dest += xattr->name_len;
469355da1ebSSage Weil 			ceph_encode_32(&dest, xattr->val_len);
470355da1ebSSage Weil 			memcpy(dest, xattr->val, xattr->val_len);
471355da1ebSSage Weil 			dest += xattr->val_len;
472355da1ebSSage Weil 
473355da1ebSSage Weil 			p = rb_next(p);
474355da1ebSSage Weil 		}
475355da1ebSSage Weil 
476355da1ebSSage Weil 		/* adjust buffer len; it may be larger than we need */
477355da1ebSSage Weil 		ci->i_xattrs.prealloc_blob->vec.iov_len =
478355da1ebSSage Weil 			dest - ci->i_xattrs.prealloc_blob->vec.iov_base;
479355da1ebSSage Weil 
480b6c1d5b8SSage Weil 		if (ci->i_xattrs.blob)
481355da1ebSSage Weil 			ceph_buffer_put(ci->i_xattrs.blob);
482355da1ebSSage Weil 		ci->i_xattrs.blob = ci->i_xattrs.prealloc_blob;
483355da1ebSSage Weil 		ci->i_xattrs.prealloc_blob = NULL;
484355da1ebSSage Weil 		ci->i_xattrs.dirty = false;
485355da1ebSSage Weil 	}
486355da1ebSSage Weil }
487355da1ebSSage Weil 
488355da1ebSSage Weil ssize_t ceph_getxattr(struct dentry *dentry, const char *name, void *value,
489355da1ebSSage Weil 		      size_t size)
490355da1ebSSage Weil {
491355da1ebSSage Weil 	struct inode *inode = dentry->d_inode;
492355da1ebSSage Weil 	struct ceph_inode_info *ci = ceph_inode(inode);
493355da1ebSSage Weil 	struct ceph_vxattr_cb *vxattrs = ceph_inode_vxattrs(inode);
494355da1ebSSage Weil 	int err;
495355da1ebSSage Weil 	struct ceph_inode_xattr *xattr;
496355da1ebSSage Weil 	struct ceph_vxattr_cb *vxattr = NULL;
497355da1ebSSage Weil 
498355da1ebSSage Weil 	if (!ceph_is_valid_xattr(name))
499355da1ebSSage Weil 		return -ENODATA;
500355da1ebSSage Weil 
501355da1ebSSage Weil 	/* let's see if a virtual xattr was requested */
502355da1ebSSage Weil 	if (vxattrs)
503355da1ebSSage Weil 		vxattr = ceph_match_vxattr(vxattrs, name);
504355da1ebSSage Weil 
505355da1ebSSage Weil 	spin_lock(&inode->i_lock);
506355da1ebSSage Weil 	dout("getxattr %p ver=%lld index_ver=%lld\n", inode,
507355da1ebSSage Weil 	     ci->i_xattrs.version, ci->i_xattrs.index_version);
508355da1ebSSage Weil 
509355da1ebSSage Weil 	if (__ceph_caps_issued_mask(ci, CEPH_CAP_XATTR_SHARED, 1) &&
510355da1ebSSage Weil 	    (ci->i_xattrs.index_version >= ci->i_xattrs.version)) {
511355da1ebSSage Weil 		goto get_xattr;
512355da1ebSSage Weil 	} else {
513355da1ebSSage Weil 		spin_unlock(&inode->i_lock);
514355da1ebSSage Weil 		/* get xattrs from mds (if we don't already have them) */
515355da1ebSSage Weil 		err = ceph_do_getattr(inode, CEPH_STAT_CAP_XATTR);
516355da1ebSSage Weil 		if (err)
517355da1ebSSage Weil 			return err;
518355da1ebSSage Weil 	}
519355da1ebSSage Weil 
520355da1ebSSage Weil 	spin_lock(&inode->i_lock);
521355da1ebSSage Weil 
522355da1ebSSage Weil 	if (vxattr && vxattr->readonly) {
523355da1ebSSage Weil 		err = vxattr->getxattr_cb(ci, value, size);
524355da1ebSSage Weil 		goto out;
525355da1ebSSage Weil 	}
526355da1ebSSage Weil 
527355da1ebSSage Weil 	err = __build_xattrs(inode);
528355da1ebSSage Weil 	if (err < 0)
529355da1ebSSage Weil 		goto out;
530355da1ebSSage Weil 
531355da1ebSSage Weil get_xattr:
532355da1ebSSage Weil 	err = -ENODATA;  /* == ENOATTR */
533355da1ebSSage Weil 	xattr = __get_xattr(ci, name);
534355da1ebSSage Weil 	if (!xattr) {
535355da1ebSSage Weil 		if (vxattr)
536355da1ebSSage Weil 			err = vxattr->getxattr_cb(ci, value, size);
537355da1ebSSage Weil 		goto out;
538355da1ebSSage Weil 	}
539355da1ebSSage Weil 
540355da1ebSSage Weil 	err = -ERANGE;
541355da1ebSSage Weil 	if (size && size < xattr->val_len)
542355da1ebSSage Weil 		goto out;
543355da1ebSSage Weil 
544355da1ebSSage Weil 	err = xattr->val_len;
545355da1ebSSage Weil 	if (size == 0)
546355da1ebSSage Weil 		goto out;
547355da1ebSSage Weil 
548355da1ebSSage Weil 	memcpy(value, xattr->val, xattr->val_len);
549355da1ebSSage Weil 
550355da1ebSSage Weil out:
551355da1ebSSage Weil 	spin_unlock(&inode->i_lock);
552355da1ebSSage Weil 	return err;
553355da1ebSSage Weil }
554355da1ebSSage Weil 
555355da1ebSSage Weil ssize_t ceph_listxattr(struct dentry *dentry, char *names, size_t size)
556355da1ebSSage Weil {
557355da1ebSSage Weil 	struct inode *inode = dentry->d_inode;
558355da1ebSSage Weil 	struct ceph_inode_info *ci = ceph_inode(inode);
559355da1ebSSage Weil 	struct ceph_vxattr_cb *vxattrs = ceph_inode_vxattrs(inode);
560355da1ebSSage Weil 	u32 vir_namelen = 0;
561355da1ebSSage Weil 	u32 namelen;
562355da1ebSSage Weil 	int err;
563355da1ebSSage Weil 	u32 len;
564355da1ebSSage Weil 	int i;
565355da1ebSSage Weil 
566355da1ebSSage Weil 	spin_lock(&inode->i_lock);
567355da1ebSSage Weil 	dout("listxattr %p ver=%lld index_ver=%lld\n", inode,
568355da1ebSSage Weil 	     ci->i_xattrs.version, ci->i_xattrs.index_version);
569355da1ebSSage Weil 
570355da1ebSSage Weil 	if (__ceph_caps_issued_mask(ci, CEPH_CAP_XATTR_SHARED, 1) &&
571*bddfa3ccSHenry C Chang 	    (ci->i_xattrs.index_version >= ci->i_xattrs.version)) {
572355da1ebSSage Weil 		goto list_xattr;
573355da1ebSSage Weil 	} else {
574355da1ebSSage Weil 		spin_unlock(&inode->i_lock);
575355da1ebSSage Weil 		err = ceph_do_getattr(inode, CEPH_STAT_CAP_XATTR);
576355da1ebSSage Weil 		if (err)
577355da1ebSSage Weil 			return err;
578355da1ebSSage Weil 	}
579355da1ebSSage Weil 
580355da1ebSSage Weil 	spin_lock(&inode->i_lock);
581355da1ebSSage Weil 
582355da1ebSSage Weil 	err = __build_xattrs(inode);
583355da1ebSSage Weil 	if (err < 0)
584355da1ebSSage Weil 		goto out;
585355da1ebSSage Weil 
586355da1ebSSage Weil list_xattr:
587355da1ebSSage Weil 	vir_namelen = 0;
588355da1ebSSage Weil 	/* include virtual dir xattrs */
589355da1ebSSage Weil 	if (vxattrs)
590355da1ebSSage Weil 		for (i = 0; vxattrs[i].name; i++)
591355da1ebSSage Weil 			vir_namelen += strlen(vxattrs[i].name) + 1;
592355da1ebSSage Weil 	/* adding 1 byte per each variable due to the null termination */
593355da1ebSSage Weil 	namelen = vir_namelen + ci->i_xattrs.names_size + ci->i_xattrs.count;
594355da1ebSSage Weil 	err = -ERANGE;
595355da1ebSSage Weil 	if (size && namelen > size)
596355da1ebSSage Weil 		goto out;
597355da1ebSSage Weil 
598355da1ebSSage Weil 	err = namelen;
599355da1ebSSage Weil 	if (size == 0)
600355da1ebSSage Weil 		goto out;
601355da1ebSSage Weil 
602355da1ebSSage Weil 	names = __copy_xattr_names(ci, names);
603355da1ebSSage Weil 
604355da1ebSSage Weil 	/* virtual xattr names, too */
605355da1ebSSage Weil 	if (vxattrs)
606355da1ebSSage Weil 		for (i = 0; vxattrs[i].name; i++) {
607355da1ebSSage Weil 			len = sprintf(names, "%s", vxattrs[i].name);
608355da1ebSSage Weil 			names += len + 1;
609355da1ebSSage Weil 		}
610355da1ebSSage Weil 
611355da1ebSSage Weil out:
612355da1ebSSage Weil 	spin_unlock(&inode->i_lock);
613355da1ebSSage Weil 	return err;
614355da1ebSSage Weil }
615355da1ebSSage Weil 
616355da1ebSSage Weil static int ceph_sync_setxattr(struct dentry *dentry, const char *name,
617355da1ebSSage Weil 			      const char *value, size_t size, int flags)
618355da1ebSSage Weil {
619640ef79dSCheng Renquan 	struct ceph_client *client = ceph_sb_to_client(dentry->d_sb);
620355da1ebSSage Weil 	struct inode *inode = dentry->d_inode;
621355da1ebSSage Weil 	struct ceph_inode_info *ci = ceph_inode(inode);
622355da1ebSSage Weil 	struct inode *parent_inode = dentry->d_parent->d_inode;
623355da1ebSSage Weil 	struct ceph_mds_request *req;
624355da1ebSSage Weil 	struct ceph_mds_client *mdsc = &client->mdsc;
625355da1ebSSage Weil 	int err;
626355da1ebSSage Weil 	int i, nr_pages;
627355da1ebSSage Weil 	struct page **pages = NULL;
628355da1ebSSage Weil 	void *kaddr;
629355da1ebSSage Weil 
630355da1ebSSage Weil 	/* copy value into some pages */
631355da1ebSSage Weil 	nr_pages = calc_pages_for(0, size);
632355da1ebSSage Weil 	if (nr_pages) {
633355da1ebSSage Weil 		pages = kmalloc(sizeof(pages[0])*nr_pages, GFP_NOFS);
634355da1ebSSage Weil 		if (!pages)
635355da1ebSSage Weil 			return -ENOMEM;
636355da1ebSSage Weil 		err = -ENOMEM;
637355da1ebSSage Weil 		for (i = 0; i < nr_pages; i++) {
63831459fe4SYehuda Sadeh 			pages[i] = __page_cache_alloc(GFP_NOFS);
639355da1ebSSage Weil 			if (!pages[i]) {
640355da1ebSSage Weil 				nr_pages = i;
641355da1ebSSage Weil 				goto out;
642355da1ebSSage Weil 			}
643355da1ebSSage Weil 			kaddr = kmap(pages[i]);
644355da1ebSSage Weil 			memcpy(kaddr, value + i*PAGE_CACHE_SIZE,
645355da1ebSSage Weil 			       min(PAGE_CACHE_SIZE, size-i*PAGE_CACHE_SIZE));
646355da1ebSSage Weil 		}
647355da1ebSSage Weil 	}
648355da1ebSSage Weil 
649355da1ebSSage Weil 	dout("setxattr value=%.*s\n", (int)size, value);
650355da1ebSSage Weil 
651355da1ebSSage Weil 	/* do request */
652355da1ebSSage Weil 	req = ceph_mdsc_create_request(mdsc, CEPH_MDS_OP_SETXATTR,
653355da1ebSSage Weil 				       USE_AUTH_MDS);
65460d87733SJulia Lawall 	if (IS_ERR(req)) {
65560d87733SJulia Lawall 		err = PTR_ERR(req);
65660d87733SJulia Lawall 		goto out;
65760d87733SJulia Lawall 	}
658355da1ebSSage Weil 	req->r_inode = igrab(inode);
659355da1ebSSage Weil 	req->r_inode_drop = CEPH_CAP_XATTR_SHARED;
660355da1ebSSage Weil 	req->r_num_caps = 1;
661355da1ebSSage Weil 	req->r_args.setxattr.flags = cpu_to_le32(flags);
662355da1ebSSage Weil 	req->r_path2 = kstrdup(name, GFP_NOFS);
663355da1ebSSage Weil 
664355da1ebSSage Weil 	req->r_pages = pages;
665355da1ebSSage Weil 	req->r_num_pages = nr_pages;
666355da1ebSSage Weil 	req->r_data_len = size;
667355da1ebSSage Weil 
668355da1ebSSage Weil 	dout("xattr.ver (before): %lld\n", ci->i_xattrs.version);
669355da1ebSSage Weil 	err = ceph_mdsc_do_request(mdsc, parent_inode, req);
670355da1ebSSage Weil 	ceph_mdsc_put_request(req);
671355da1ebSSage Weil 	dout("xattr.ver (after): %lld\n", ci->i_xattrs.version);
672355da1ebSSage Weil 
673355da1ebSSage Weil out:
674355da1ebSSage Weil 	if (pages) {
675355da1ebSSage Weil 		for (i = 0; i < nr_pages; i++)
676355da1ebSSage Weil 			__free_page(pages[i]);
677355da1ebSSage Weil 		kfree(pages);
678355da1ebSSage Weil 	}
679355da1ebSSage Weil 	return err;
680355da1ebSSage Weil }
681355da1ebSSage Weil 
682355da1ebSSage Weil int ceph_setxattr(struct dentry *dentry, const char *name,
683355da1ebSSage Weil 		  const void *value, size_t size, int flags)
684355da1ebSSage Weil {
685355da1ebSSage Weil 	struct inode *inode = dentry->d_inode;
686355da1ebSSage Weil 	struct ceph_inode_info *ci = ceph_inode(inode);
687355da1ebSSage Weil 	struct ceph_vxattr_cb *vxattrs = ceph_inode_vxattrs(inode);
688355da1ebSSage Weil 	int err;
689355da1ebSSage Weil 	int name_len = strlen(name);
690355da1ebSSage Weil 	int val_len = size;
691355da1ebSSage Weil 	char *newname = NULL;
692355da1ebSSage Weil 	char *newval = NULL;
693355da1ebSSage Weil 	struct ceph_inode_xattr *xattr = NULL;
694355da1ebSSage Weil 	int issued;
695355da1ebSSage Weil 	int required_blob_size;
696355da1ebSSage Weil 
697355da1ebSSage Weil 	if (ceph_snap(inode) != CEPH_NOSNAP)
698355da1ebSSage Weil 		return -EROFS;
699355da1ebSSage Weil 
700355da1ebSSage Weil 	if (!ceph_is_valid_xattr(name))
701355da1ebSSage Weil 		return -EOPNOTSUPP;
702355da1ebSSage Weil 
703355da1ebSSage Weil 	if (vxattrs) {
704355da1ebSSage Weil 		struct ceph_vxattr_cb *vxattr =
705355da1ebSSage Weil 			ceph_match_vxattr(vxattrs, name);
706355da1ebSSage Weil 		if (vxattr && vxattr->readonly)
707355da1ebSSage Weil 			return -EOPNOTSUPP;
708355da1ebSSage Weil 	}
709355da1ebSSage Weil 
710355da1ebSSage Weil 	/* preallocate memory for xattr name, value, index node */
711355da1ebSSage Weil 	err = -ENOMEM;
712355da1ebSSage Weil 	newname = kmalloc(name_len + 1, GFP_NOFS);
713355da1ebSSage Weil 	if (!newname)
714355da1ebSSage Weil 		goto out;
715355da1ebSSage Weil 	memcpy(newname, name, name_len + 1);
716355da1ebSSage Weil 
717355da1ebSSage Weil 	if (val_len) {
718355da1ebSSage Weil 		newval = kmalloc(val_len + 1, GFP_NOFS);
719355da1ebSSage Weil 		if (!newval)
720355da1ebSSage Weil 			goto out;
721355da1ebSSage Weil 		memcpy(newval, value, val_len);
722355da1ebSSage Weil 		newval[val_len] = '\0';
723355da1ebSSage Weil 	}
724355da1ebSSage Weil 
725355da1ebSSage Weil 	xattr = kmalloc(sizeof(struct ceph_inode_xattr), GFP_NOFS);
726355da1ebSSage Weil 	if (!xattr)
727355da1ebSSage Weil 		goto out;
728355da1ebSSage Weil 
729355da1ebSSage Weil 	spin_lock(&inode->i_lock);
730355da1ebSSage Weil retry:
731355da1ebSSage Weil 	issued = __ceph_caps_issued(ci, NULL);
732355da1ebSSage Weil 	if (!(issued & CEPH_CAP_XATTR_EXCL))
733355da1ebSSage Weil 		goto do_sync;
734355da1ebSSage Weil 	__build_xattrs(inode);
735355da1ebSSage Weil 
736355da1ebSSage Weil 	required_blob_size = __get_required_blob_size(ci, name_len, val_len);
737355da1ebSSage Weil 
738355da1ebSSage Weil 	if (!ci->i_xattrs.prealloc_blob ||
739355da1ebSSage Weil 	    required_blob_size > ci->i_xattrs.prealloc_blob->alloc_len) {
740355da1ebSSage Weil 		struct ceph_buffer *blob = NULL;
741355da1ebSSage Weil 
742355da1ebSSage Weil 		spin_unlock(&inode->i_lock);
743355da1ebSSage Weil 		dout(" preaallocating new blob size=%d\n", required_blob_size);
744b6c1d5b8SSage Weil 		blob = ceph_buffer_new(required_blob_size, GFP_NOFS);
745355da1ebSSage Weil 		if (!blob)
746355da1ebSSage Weil 			goto out;
747355da1ebSSage Weil 		spin_lock(&inode->i_lock);
748b6c1d5b8SSage Weil 		if (ci->i_xattrs.prealloc_blob)
749355da1ebSSage Weil 			ceph_buffer_put(ci->i_xattrs.prealloc_blob);
750355da1ebSSage Weil 		ci->i_xattrs.prealloc_blob = blob;
751355da1ebSSage Weil 		goto retry;
752355da1ebSSage Weil 	}
753355da1ebSSage Weil 
754355da1ebSSage Weil 	dout("setxattr %p issued %s\n", inode, ceph_cap_string(issued));
755355da1ebSSage Weil 	err = __set_xattr(ci, newname, name_len, newval,
756355da1ebSSage Weil 			  val_len, 1, 1, 1, &xattr);
757355da1ebSSage Weil 	__ceph_mark_dirty_caps(ci, CEPH_CAP_XATTR_EXCL);
758355da1ebSSage Weil 	ci->i_xattrs.dirty = true;
759355da1ebSSage Weil 	inode->i_ctime = CURRENT_TIME;
760355da1ebSSage Weil 	spin_unlock(&inode->i_lock);
761355da1ebSSage Weil 
762355da1ebSSage Weil 	return err;
763355da1ebSSage Weil 
764355da1ebSSage Weil do_sync:
765355da1ebSSage Weil 	spin_unlock(&inode->i_lock);
766355da1ebSSage Weil 	err = ceph_sync_setxattr(dentry, name, value, size, flags);
767355da1ebSSage Weil out:
768355da1ebSSage Weil 	kfree(newname);
769355da1ebSSage Weil 	kfree(newval);
770355da1ebSSage Weil 	kfree(xattr);
771355da1ebSSage Weil 	return err;
772355da1ebSSage Weil }
773355da1ebSSage Weil 
774355da1ebSSage Weil static int ceph_send_removexattr(struct dentry *dentry, const char *name)
775355da1ebSSage Weil {
776640ef79dSCheng Renquan 	struct ceph_client *client = ceph_sb_to_client(dentry->d_sb);
777355da1ebSSage Weil 	struct ceph_mds_client *mdsc = &client->mdsc;
778355da1ebSSage Weil 	struct inode *inode = dentry->d_inode;
779355da1ebSSage Weil 	struct inode *parent_inode = dentry->d_parent->d_inode;
780355da1ebSSage Weil 	struct ceph_mds_request *req;
781355da1ebSSage Weil 	int err;
782355da1ebSSage Weil 
783355da1ebSSage Weil 	req = ceph_mdsc_create_request(mdsc, CEPH_MDS_OP_RMXATTR,
784355da1ebSSage Weil 				       USE_AUTH_MDS);
785355da1ebSSage Weil 	if (IS_ERR(req))
786355da1ebSSage Weil 		return PTR_ERR(req);
787355da1ebSSage Weil 	req->r_inode = igrab(inode);
788355da1ebSSage Weil 	req->r_inode_drop = CEPH_CAP_XATTR_SHARED;
789355da1ebSSage Weil 	req->r_num_caps = 1;
790355da1ebSSage Weil 	req->r_path2 = kstrdup(name, GFP_NOFS);
791355da1ebSSage Weil 
792355da1ebSSage Weil 	err = ceph_mdsc_do_request(mdsc, parent_inode, req);
793355da1ebSSage Weil 	ceph_mdsc_put_request(req);
794355da1ebSSage Weil 	return err;
795355da1ebSSage Weil }
796355da1ebSSage Weil 
797355da1ebSSage Weil int ceph_removexattr(struct dentry *dentry, const char *name)
798355da1ebSSage Weil {
799355da1ebSSage Weil 	struct inode *inode = dentry->d_inode;
800355da1ebSSage Weil 	struct ceph_inode_info *ci = ceph_inode(inode);
801355da1ebSSage Weil 	struct ceph_vxattr_cb *vxattrs = ceph_inode_vxattrs(inode);
802355da1ebSSage Weil 	int issued;
803355da1ebSSage Weil 	int err;
804355da1ebSSage Weil 
805355da1ebSSage Weil 	if (ceph_snap(inode) != CEPH_NOSNAP)
806355da1ebSSage Weil 		return -EROFS;
807355da1ebSSage Weil 
808355da1ebSSage Weil 	if (!ceph_is_valid_xattr(name))
809355da1ebSSage Weil 		return -EOPNOTSUPP;
810355da1ebSSage Weil 
811355da1ebSSage Weil 	if (vxattrs) {
812355da1ebSSage Weil 		struct ceph_vxattr_cb *vxattr =
813355da1ebSSage Weil 			ceph_match_vxattr(vxattrs, name);
814355da1ebSSage Weil 		if (vxattr && vxattr->readonly)
815355da1ebSSage Weil 			return -EOPNOTSUPP;
816355da1ebSSage Weil 	}
817355da1ebSSage Weil 
818355da1ebSSage Weil 	spin_lock(&inode->i_lock);
819355da1ebSSage Weil 	__build_xattrs(inode);
820355da1ebSSage Weil 	issued = __ceph_caps_issued(ci, NULL);
821355da1ebSSage Weil 	dout("removexattr %p issued %s\n", inode, ceph_cap_string(issued));
822355da1ebSSage Weil 
823355da1ebSSage Weil 	if (!(issued & CEPH_CAP_XATTR_EXCL))
824355da1ebSSage Weil 		goto do_sync;
825355da1ebSSage Weil 
826355da1ebSSage Weil 	err = __remove_xattr_by_name(ceph_inode(inode), name);
827355da1ebSSage Weil 	__ceph_mark_dirty_caps(ci, CEPH_CAP_XATTR_EXCL);
828355da1ebSSage Weil 	ci->i_xattrs.dirty = true;
829355da1ebSSage Weil 	inode->i_ctime = CURRENT_TIME;
830355da1ebSSage Weil 
831355da1ebSSage Weil 	spin_unlock(&inode->i_lock);
832355da1ebSSage Weil 
833355da1ebSSage Weil 	return err;
834355da1ebSSage Weil do_sync:
835355da1ebSSage Weil 	spin_unlock(&inode->i_lock);
836355da1ebSSage Weil 	err = ceph_send_removexattr(dentry, name);
837355da1ebSSage Weil 	return err;
838355da1ebSSage Weil }
839355da1ebSSage Weil 
840