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