xattr.c 79.4 KB
Newer Older
1
/*
2
 * linux/fs/ext4/xattr.c
3 4 5 6
 *
 * Copyright (C) 2001-2003 Andreas Gruenbacher, <agruen@suse.de>
 *
 * Fix by Harrison Xing <harrison@mountainviewdata.com>.
7
 * Ext4 code with a lot of help from Eric Jarman <ejarman@acm.org>.
8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45
 * Extended attributes for symlinks and special files added per
 *  suggestion of Luka Renko <luka.renko@hermes.si>.
 * xattr consolidation Copyright (c) 2004 James Morris <jmorris@redhat.com>,
 *  Red Hat Inc.
 * ea-in-inode support by Alex Tomas <alex@clusterfs.com> aka bzzz
 *  and Andreas Gruenbacher <agruen@suse.de>.
 */

/*
 * Extended attributes are stored directly in inodes (on file systems with
 * inodes bigger than 128 bytes) and on additional disk blocks. The i_file_acl
 * field contains the block number if an inode uses an additional block. All
 * attributes must fit in the inode and one additional block. Blocks that
 * contain the identical set of attributes may be shared among several inodes.
 * Identical blocks are detected by keeping a cache of blocks that have
 * recently been accessed.
 *
 * The attributes in inodes and on blocks have a different header; the entries
 * are stored in the same format:
 *
 *   +------------------+
 *   | header           |
 *   | entry 1          | |
 *   | entry 2          | | growing downwards
 *   | entry 3          | v
 *   | four null bytes  |
 *   | . . .            |
 *   | value 1          | ^
 *   | value 3          | | growing upwards
 *   | value 2          | |
 *   +------------------+
 *
 * The header is followed by multiple entry descriptors. In disk blocks, the
 * entry descriptors are kept sorted. In inodes, they are unsorted. The
 * attribute values are aligned to the end of the block in no specific order.
 *
 * Locking strategy
 * ----------------
46
 * EXT4_I(inode)->i_file_acl is protected by EXT4_I(inode)->xattr_sem.
47 48 49 50 51 52 53 54 55
 * EA blocks are only changed if they are exclusive to an inode, so
 * holding xattr_sem also means that nothing but the EA block's reference
 * count can change. Multiple writers to the same block are synchronized
 * by the buffer lock.
 */

#include <linux/init.h>
#include <linux/fs.h>
#include <linux/slab.h>
J
Jan Kara 已提交
56
#include <linux/mbcache.h>
57
#include <linux/quotaops.h>
58 59
#include "ext4_jbd2.h"
#include "ext4.h"
60 61 62
#include "xattr.h"
#include "acl.h"

63
#ifdef EXT4_XATTR_DEBUG
64 65 66 67 68 69
# define ea_idebug(inode, fmt, ...)					\
	printk(KERN_DEBUG "inode %s:%lu: " fmt "\n",			\
	       inode->i_sb->s_id, inode->i_ino, ##__VA_ARGS__)
# define ea_bdebug(bh, fmt, ...)					\
	printk(KERN_DEBUG "block %pg:%lu: " fmt "\n",			\
	       bh->b_bdev, (unsigned long)bh->b_blocknr, ##__VA_ARGS__)
70
#else
71 72
# define ea_idebug(inode, fmt, ...)	no_printk(fmt, ##__VA_ARGS__)
# define ea_bdebug(bh, fmt, ...)	no_printk(fmt, ##__VA_ARGS__)
73 74
#endif

75 76 77 78 79
static void ext4_xattr_block_cache_insert(struct mb_cache *,
					  struct buffer_head *);
static struct buffer_head *
ext4_xattr_block_cache_find(struct inode *, struct ext4_xattr_header *,
			    struct mb_cache_entry **);
80 81
static __le32 ext4_xattr_hash_entry(char *name, size_t name_len, __le32 *value,
				    size_t value_count);
82
static void ext4_xattr_rehash(struct ext4_xattr_header *);
83

84
static const struct xattr_handler * const ext4_xattr_handler_map[] = {
85
	[EXT4_XATTR_INDEX_USER]		     = &ext4_xattr_user_handler,
T
Theodore Ts'o 已提交
86
#ifdef CONFIG_EXT4_FS_POSIX_ACL
87 88
	[EXT4_XATTR_INDEX_POSIX_ACL_ACCESS]  = &posix_acl_access_xattr_handler,
	[EXT4_XATTR_INDEX_POSIX_ACL_DEFAULT] = &posix_acl_default_xattr_handler,
89
#endif
90
	[EXT4_XATTR_INDEX_TRUSTED]	     = &ext4_xattr_trusted_handler,
T
Theodore Ts'o 已提交
91
#ifdef CONFIG_EXT4_FS_SECURITY
92
	[EXT4_XATTR_INDEX_SECURITY]	     = &ext4_xattr_security_handler,
93 94 95
#endif
};

S
Stephen Hemminger 已提交
96
const struct xattr_handler *ext4_xattr_handlers[] = {
97 98
	&ext4_xattr_user_handler,
	&ext4_xattr_trusted_handler,
T
Theodore Ts'o 已提交
99
#ifdef CONFIG_EXT4_FS_POSIX_ACL
100 101
	&posix_acl_access_xattr_handler,
	&posix_acl_default_xattr_handler,
102
#endif
T
Theodore Ts'o 已提交
103
#ifdef CONFIG_EXT4_FS_SECURITY
104
	&ext4_xattr_security_handler,
105 106 107 108
#endif
	NULL
};

109 110
#define EA_BLOCK_CACHE(inode)	(((struct ext4_sb_info *) \
				inode->i_sb->s_fs_info)->s_ea_block_cache)
111

T
Tahsin Erdogan 已提交
112 113 114
#define EA_INODE_CACHE(inode)	(((struct ext4_sb_info *) \
				inode->i_sb->s_fs_info)->s_ea_inode_cache)

115 116 117 118
static int
ext4_expand_inode_array(struct ext4_xattr_inode_array **ea_inode_array,
			struct inode *inode);

119 120 121 122 123 124 125
#ifdef CONFIG_LOCKDEP
void ext4_xattr_inode_set_class(struct inode *ea_inode)
{
	lockdep_set_subclass(&ea_inode->i_rwsem, 1);
}
#endif

126 127 128 129 130
static __le32 ext4_xattr_block_csum(struct inode *inode,
				    sector_t block_nr,
				    struct ext4_xattr_header *hdr)
{
	struct ext4_sb_info *sbi = EXT4_SB(inode->i_sb);
131 132
	__u32 csum;
	__le64 dsk_block_nr = cpu_to_le64(block_nr);
133 134
	__u32 dummy_csum = 0;
	int offset = offsetof(struct ext4_xattr_header, h_checksum);
135

136 137
	csum = ext4_chksum(sbi, sbi->s_csum_seed, (__u8 *)&dsk_block_nr,
			   sizeof(dsk_block_nr));
138 139 140 141 142
	csum = ext4_chksum(sbi, csum, (__u8 *)hdr, offset);
	csum = ext4_chksum(sbi, csum, (__u8 *)&dummy_csum, sizeof(dummy_csum));
	offset += sizeof(dummy_csum);
	csum = ext4_chksum(sbi, csum, (__u8 *)hdr + offset,
			   EXT4_BLOCK_SIZE(inode->i_sb) - offset);
143

144 145 146 147
	return cpu_to_le32(csum);
}

static int ext4_xattr_block_csum_verify(struct inode *inode,
148
					struct buffer_head *bh)
149
{
150 151
	struct ext4_xattr_header *hdr = BHDR(bh);
	int ret = 1;
152

153 154 155 156 157 158 159
	if (ext4_has_metadata_csum(inode->i_sb)) {
		lock_buffer(bh);
		ret = (hdr->h_checksum == ext4_xattr_block_csum(inode,
							bh->b_blocknr, hdr));
		unlock_buffer(bh);
	}
	return ret;
160 161
}

162 163
static void ext4_xattr_block_csum_set(struct inode *inode,
				      struct buffer_head *bh)
164
{
165 166 167
	if (ext4_has_metadata_csum(inode->i_sb))
		BHDR(bh)->h_checksum = ext4_xattr_block_csum(inode,
						bh->b_blocknr, BHDR(bh));
168 169
}

S
Stephen Hemminger 已提交
170
static inline const struct xattr_handler *
171
ext4_xattr_handler(int name_index)
172
{
S
Stephen Hemminger 已提交
173
	const struct xattr_handler *handler = NULL;
174

175 176
	if (name_index > 0 && name_index < ARRAY_SIZE(ext4_xattr_handler_map))
		handler = ext4_xattr_handler_map[name_index];
177 178 179 180
	return handler;
}

static int
181 182
ext4_xattr_check_entries(struct ext4_xattr_entry *entry, void *end,
			 void *value_start)
183
{
184 185
	struct ext4_xattr_entry *e = entry;

186
	/* Find the end of the names list */
187 188
	while (!IS_LAST_ENTRY(e)) {
		struct ext4_xattr_entry *next = EXT4_XATTR_NEXT(e);
189
		if ((void *)next >= end)
190
			return -EFSCORRUPTED;
191
		e = next;
192
	}
193

194
	/* Check the values */
195
	while (!IS_LAST_ENTRY(entry)) {
A
Andreas Dilger 已提交
196 197
		if (entry->e_value_size != 0 &&
		    entry->e_value_inum == 0) {
198 199 200 201 202 203 204 205 206 207 208 209 210 211 212 213 214 215
			u16 offs = le16_to_cpu(entry->e_value_offs);
			u32 size = le32_to_cpu(entry->e_value_size);
			void *value;

			/*
			 * The value cannot overlap the names, and the value
			 * with padding cannot extend beyond 'end'.  Check both
			 * the padded and unpadded sizes, since the size may
			 * overflow to 0 when adding padding.
			 */
			if (offs > end - value_start)
				return -EFSCORRUPTED;
			value = value_start + offs;
			if (value < (void *)e + sizeof(u32) ||
			    size > end - value ||
			    EXT4_XATTR_SIZE(size) > end - value)
				return -EFSCORRUPTED;
		}
216 217 218
		entry = EXT4_XATTR_NEXT(entry);
	}

219 220 221 222
	return 0;
}

static inline int
223
ext4_xattr_check_block(struct inode *inode, struct buffer_head *bh)
224
{
225 226 227 228 229
	int error;

	if (buffer_verified(bh))
		return 0;

230
	if (BHDR(bh)->h_magic != cpu_to_le32(EXT4_XATTR_MAGIC) ||
231
	    BHDR(bh)->h_blocks != cpu_to_le32(1))
232
		return -EFSCORRUPTED;
233
	if (!ext4_xattr_block_csum_verify(inode, bh))
234
		return -EFSBADCRC;
235 236
	error = ext4_xattr_check_entries(BFIRST(bh), bh->b_data + bh->b_size,
					 bh->b_data);
237 238 239
	if (!error)
		set_buffer_verified(bh);
	return error;
240 241
}

242 243 244 245 246 247
static int
__xattr_check_inode(struct inode *inode, struct ext4_xattr_ibody_header *header,
			 void *end, const char *function, unsigned int line)
{
	int error = -EFSCORRUPTED;

248
	if (end - (void *)header < sizeof(*header) + sizeof(u32) ||
249
	    (header->h_magic != cpu_to_le32(EXT4_XATTR_MAGIC)))
250
		goto errout;
251
	error = ext4_xattr_check_entries(IFIRST(header), end, IFIRST(header));
252 253 254 255 256 257 258 259 260 261
errout:
	if (error)
		__ext4_error_inode(inode, function, line, 0,
				   "corrupted in-inode xattr");
	return error;
}

#define xattr_check_inode(inode, header, end) \
	__xattr_check_inode((inode), (header), (end), __func__, __LINE__)

262
static int
263
ext4_xattr_find_entry(struct ext4_xattr_entry **pentry, int name_index,
264
		      const char *name, int sorted)
265
{
266
	struct ext4_xattr_entry *entry;
267 268 269 270 271 272 273
	size_t name_len;
	int cmp = 1;

	if (name == NULL)
		return -EINVAL;
	name_len = strlen(name);
	entry = *pentry;
274
	for (; !IS_LAST_ENTRY(entry); entry = EXT4_XATTR_NEXT(entry)) {
275 276 277 278 279 280 281 282 283 284 285 286
		cmp = name_index - entry->e_name_index;
		if (!cmp)
			cmp = name_len - entry->e_name_len;
		if (!cmp)
			cmp = memcmp(name, entry->e_name, name_len);
		if (cmp <= 0 && (sorted || cmp == 0))
			break;
	}
	*pentry = entry;
	return cmp ? -ENODATA : 0;
}

T
Tahsin Erdogan 已提交
287 288 289 290 291 292 293 294 295 296 297 298 299 300 301 302 303 304 305 306 307 308 309 310 311 312 313 314
static u32
ext4_xattr_inode_hash(struct ext4_sb_info *sbi, const void *buffer, size_t size)
{
	return ext4_chksum(sbi, sbi->s_csum_seed, buffer, size);
}

static u64 ext4_xattr_inode_get_ref(struct inode *ea_inode)
{
	return ((u64)ea_inode->i_ctime.tv_sec << 32) |
	       ((u32)ea_inode->i_version);
}

static void ext4_xattr_inode_set_ref(struct inode *ea_inode, u64 ref_count)
{
	ea_inode->i_ctime.tv_sec = (u32)(ref_count >> 32);
	ea_inode->i_version = (u32)ref_count;
}

static u32 ext4_xattr_inode_get_hash(struct inode *ea_inode)
{
	return (u32)ea_inode->i_atime.tv_sec;
}

static void ext4_xattr_inode_set_hash(struct inode *ea_inode, u32 hash)
{
	ea_inode->i_atime.tv_sec = hash;
}

A
Andreas Dilger 已提交
315 316 317
/*
 * Read the EA value from an inode.
 */
318
static int ext4_xattr_inode_read(struct inode *ea_inode, void *buf, size_t size)
A
Andreas Dilger 已提交
319
{
320 321 322 323 324 325 326 327 328 329 330 331
	int blocksize = 1 << ea_inode->i_blkbits;
	int bh_count = (size + blocksize - 1) >> ea_inode->i_blkbits;
	int tail_size = (size % blocksize) ?: blocksize;
	struct buffer_head *bhs_inline[8];
	struct buffer_head **bhs = bhs_inline;
	int i, ret;

	if (bh_count > ARRAY_SIZE(bhs_inline)) {
		bhs = kmalloc_array(bh_count, sizeof(*bhs), GFP_NOFS);
		if (!bhs)
			return -ENOMEM;
	}
332

333 334 335 336
	ret = ext4_bread_batch(ea_inode, 0 /* block */, bh_count,
			       true /* wait */, bhs);
	if (ret)
		goto free_bhs;
A
Andreas Dilger 已提交
337

338 339 340 341 342 343 344 345
	for (i = 0; i < bh_count; i++) {
		/* There shouldn't be any holes in ea_inode. */
		if (!bhs[i]) {
			ret = -EFSCORRUPTED;
			goto put_bhs;
		}
		memcpy((char *)buf + blocksize * i, bhs[i]->b_data,
		       i < bh_count - 1 ? blocksize : tail_size);
A
Andreas Dilger 已提交
346
	}
347 348 349 350 351 352 353 354
	ret = 0;
put_bhs:
	for (i = 0; i < bh_count; i++)
		brelse(bhs[i]);
free_bhs:
	if (bhs != bhs_inline)
		kfree(bhs);
	return ret;
A
Andreas Dilger 已提交
355 356
}

357 358
static int ext4_xattr_inode_iget(struct inode *parent, unsigned long ea_ino,
				 struct inode **ea_inode)
A
Andreas Dilger 已提交
359
{
360 361
	struct inode *inode;
	int err;
A
Andreas Dilger 已提交
362

363 364 365
	inode = ext4_iget(parent->i_sb, ea_ino);
	if (IS_ERR(inode)) {
		err = PTR_ERR(inode);
T
Tahsin Erdogan 已提交
366 367 368
		ext4_error(parent->i_sb,
			   "error while reading EA inode %lu err=%d", ea_ino,
			   err);
369
		return err;
A
Andreas Dilger 已提交
370 371
	}

372
	if (is_bad_inode(inode)) {
T
Tahsin Erdogan 已提交
373 374 375
		ext4_error(parent->i_sb,
			   "error while reading EA inode %lu is_bad_inode",
			   ea_ino);
376 377 378 379 380
		err = -EIO;
		goto error;
	}

	if (!(EXT4_I(inode)->i_flags & EXT4_EA_INODE_FL)) {
T
Tahsin Erdogan 已提交
381 382 383
		ext4_error(parent->i_sb,
			   "EA inode %lu does not have EXT4_EA_INODE_FL flag",
			    ea_ino);
384
		err = -EINVAL;
A
Andreas Dilger 已提交
385 386 387
		goto error;
	}

388 389
	*ea_inode = inode;
	return 0;
A
Andreas Dilger 已提交
390
error:
391 392
	iput(inode);
	return err;
A
Andreas Dilger 已提交
393 394
}

T
Tahsin Erdogan 已提交
395
static int
396 397 398
ext4_xattr_inode_verify_hashes(struct inode *ea_inode,
			       struct ext4_xattr_entry *entry, void *buffer,
			       size_t size)
T
Tahsin Erdogan 已提交
399 400 401 402 403 404 405
{
	u32 hash;

	/* Verify stored hash matches calculated hash. */
	hash = ext4_xattr_inode_hash(EXT4_SB(ea_inode->i_sb), buffer, size);
	if (hash != ext4_xattr_inode_get_hash(ea_inode))
		return -EFSCORRUPTED;
406 407 408 409 410 411 412 413 414 415 416

	if (entry) {
		__le32 e_hash, tmp_data;

		/* Verify entry hash. */
		tmp_data = cpu_to_le32(hash);
		e_hash = ext4_xattr_hash_entry(entry->e_name, entry->e_name_len,
					       &tmp_data, 1);
		if (e_hash != entry->e_hash)
			return -EFSCORRUPTED;
	}
T
Tahsin Erdogan 已提交
417 418 419 420 421
	return 0;
}

#define EXT4_XATTR_INODE_GET_PARENT(inode) ((__u32)(inode)->i_mtime.tv_sec)

A
Andreas Dilger 已提交
422
/*
423
 * Read xattr value from the EA inode.
A
Andreas Dilger 已提交
424 425
 */
static int
426 427
ext4_xattr_inode_get(struct inode *inode, struct ext4_xattr_entry *entry,
		     void *buffer, size_t size)
A
Andreas Dilger 已提交
428
{
T
Tahsin Erdogan 已提交
429
	struct mb_cache *ea_inode_cache = EA_INODE_CACHE(inode);
430
	struct inode *ea_inode;
T
Tahsin Erdogan 已提交
431
	int err;
A
Andreas Dilger 已提交
432

433 434
	err = ext4_xattr_inode_iget(inode, le32_to_cpu(entry->e_value_inum),
				    &ea_inode);
T
Tahsin Erdogan 已提交
435 436 437 438
	if (err) {
		ea_inode = NULL;
		goto out;
	}
A
Andreas Dilger 已提交
439

T
Tahsin Erdogan 已提交
440 441 442 443 444 445 446
	if (i_size_read(ea_inode) != size) {
		ext4_warning_inode(ea_inode,
				   "ea_inode file size=%llu entry size=%zu",
				   i_size_read(ea_inode), size);
		err = -EFSCORRUPTED;
		goto out;
	}
A
Andreas Dilger 已提交
447

T
Tahsin Erdogan 已提交
448 449 450 451
	err = ext4_xattr_inode_read(ea_inode, buffer, size);
	if (err)
		goto out;

452
	err = ext4_xattr_inode_verify_hashes(ea_inode, entry, buffer, size);
T
Tahsin Erdogan 已提交
453 454 455 456 457 458 459 460 461 462 463 464 465 466
	/*
	 * Compatibility check for old Lustre ea_inode implementation. Old
	 * version does not have hash validation, but it has a backpointer
	 * from ea_inode to the parent inode.
	 */
	if (err == -EFSCORRUPTED) {
		if (EXT4_XATTR_INODE_GET_PARENT(ea_inode) != inode->i_ino ||
		    ea_inode->i_generation != inode->i_generation) {
			ext4_warning_inode(ea_inode,
					   "EA inode hash validation failed");
			goto out;
		}
		/* Do not add ea_inode to the cache. */
		ea_inode_cache = NULL;
467
		err = 0;
T
Tahsin Erdogan 已提交
468 469 470 471 472 473 474 475 476 477
	} else if (err)
		goto out;

	if (ea_inode_cache)
		mb_cache_entry_create(ea_inode_cache, GFP_NOFS,
				      ext4_xattr_inode_get_hash(ea_inode),
				      ea_inode->i_ino, true /* reusable */);
out:
	iput(ea_inode);
	return err;
A
Andreas Dilger 已提交
478 479
}

480
static int
481
ext4_xattr_block_get(struct inode *inode, int name_index, const char *name,
482 483 484
		     void *buffer, size_t buffer_size)
{
	struct buffer_head *bh = NULL;
485
	struct ext4_xattr_entry *entry;
486 487
	size_t size;
	int error;
488
	struct mb_cache *ea_block_cache = EA_BLOCK_CACHE(inode);
489 490 491 492 493

	ea_idebug(inode, "name=%d.%s, buffer=%p, buffer_size=%ld",
		  name_index, name, buffer, (long)buffer_size);

	error = -ENODATA;
494
	if (!EXT4_I(inode)->i_file_acl)
495
		goto cleanup;
496 497
	ea_idebug(inode, "reading block %llu",
		  (unsigned long long)EXT4_I(inode)->i_file_acl);
498
	bh = sb_bread(inode->i_sb, EXT4_I(inode)->i_file_acl);
499 500 501 502
	if (!bh)
		goto cleanup;
	ea_bdebug(bh, "b_count=%d, refcount=%d",
		atomic_read(&(bh->b_count)), le32_to_cpu(BHDR(bh)->h_refcount));
503
	if (ext4_xattr_check_block(inode, bh)) {
504 505
		EXT4_ERROR_INODE(inode, "bad block %llu",
				 EXT4_I(inode)->i_file_acl);
506
		error = -EFSCORRUPTED;
507 508
		goto cleanup;
	}
509
	ext4_xattr_block_cache_insert(ea_block_cache, bh);
510
	entry = BFIRST(bh);
511
	error = ext4_xattr_find_entry(&entry, name_index, name, 1);
512 513 514 515 516 517 518
	if (error)
		goto cleanup;
	size = le32_to_cpu(entry->e_value_size);
	if (buffer) {
		error = -ERANGE;
		if (size > buffer_size)
			goto cleanup;
A
Andreas Dilger 已提交
519
		if (entry->e_value_inum) {
520 521
			error = ext4_xattr_inode_get(inode, entry, buffer,
						     size);
A
Andreas Dilger 已提交
522 523 524 525 526 527
			if (error)
				goto cleanup;
		} else {
			memcpy(buffer, bh->b_data +
			       le16_to_cpu(entry->e_value_offs), size);
		}
528 529 530 531 532 533 534 535
	}
	error = size;

cleanup:
	brelse(bh);
	return error;
}

T
Tao Ma 已提交
536
int
537
ext4_xattr_ibody_get(struct inode *inode, int name_index, const char *name,
538 539
		     void *buffer, size_t buffer_size)
{
540 541 542 543
	struct ext4_xattr_ibody_header *header;
	struct ext4_xattr_entry *entry;
	struct ext4_inode *raw_inode;
	struct ext4_iloc iloc;
544 545 546 547
	size_t size;
	void *end;
	int error;

548
	if (!ext4_test_inode_state(inode, EXT4_STATE_XATTR))
549
		return -ENODATA;
550
	error = ext4_get_inode_loc(inode, &iloc);
551 552
	if (error)
		return error;
553
	raw_inode = ext4_raw_inode(&iloc);
554
	header = IHDR(inode, raw_inode);
555
	end = (void *)raw_inode + EXT4_SB(inode->i_sb)->s_inode_size;
556
	error = xattr_check_inode(inode, header, end);
557 558
	if (error)
		goto cleanup;
559 560
	entry = IFIRST(header);
	error = ext4_xattr_find_entry(&entry, name_index, name, 0);
561 562 563 564 565 566 567
	if (error)
		goto cleanup;
	size = le32_to_cpu(entry->e_value_size);
	if (buffer) {
		error = -ERANGE;
		if (size > buffer_size)
			goto cleanup;
A
Andreas Dilger 已提交
568
		if (entry->e_value_inum) {
569 570
			error = ext4_xattr_inode_get(inode, entry, buffer,
						     size);
A
Andreas Dilger 已提交
571 572 573 574 575 576
			if (error)
				goto cleanup;
		} else {
			memcpy(buffer, (void *)IFIRST(header) +
			       le16_to_cpu(entry->e_value_offs), size);
		}
577 578 579 580 581 582 583 584 585
	}
	error = size;

cleanup:
	brelse(iloc.bh);
	return error;
}

/*
586
 * ext4_xattr_get()
587 588 589 590 591 592 593 594 595
 *
 * Copy an extended attribute into the buffer
 * provided, or compute the buffer size required.
 * Buffer is NULL to compute the size of the buffer required.
 *
 * Returns a negative error number on failure, or the number of bytes
 * used / required on success.
 */
int
596
ext4_xattr_get(struct inode *inode, int name_index, const char *name,
597 598 599 600
	       void *buffer, size_t buffer_size)
{
	int error;

601 602 603
	if (unlikely(ext4_forced_shutdown(EXT4_SB(inode->i_sb))))
		return -EIO;

604 605 606
	if (strlen(name) > 255)
		return -ERANGE;

607 608
	down_read(&EXT4_I(inode)->xattr_sem);
	error = ext4_xattr_ibody_get(inode, name_index, name, buffer,
609 610
				     buffer_size);
	if (error == -ENODATA)
611
		error = ext4_xattr_block_get(inode, name_index, name, buffer,
612
					     buffer_size);
613
	up_read(&EXT4_I(inode)->xattr_sem);
614 615 616 617
	return error;
}

static int
618
ext4_xattr_list_entries(struct dentry *dentry, struct ext4_xattr_entry *entry,
619 620 621 622
			char *buffer, size_t buffer_size)
{
	size_t rest = buffer_size;

623
	for (; !IS_LAST_ENTRY(entry); entry = EXT4_XATTR_NEXT(entry)) {
S
Stephen Hemminger 已提交
624
		const struct xattr_handler *handler =
625
			ext4_xattr_handler(entry->e_name_index);
626

627 628 629 630 631
		if (handler && (!handler->list || handler->list(dentry))) {
			const char *prefix = handler->prefix ?: handler->name;
			size_t prefix_len = strlen(prefix);
			size_t size = prefix_len + entry->e_name_len + 1;

632 633 634
			if (buffer) {
				if (size > rest)
					return -ERANGE;
635 636 637 638 639
				memcpy(buffer, prefix, prefix_len);
				buffer += prefix_len;
				memcpy(buffer, entry->e_name, entry->e_name_len);
				buffer += entry->e_name_len;
				*buffer++ = 0;
640 641 642 643
			}
			rest -= size;
		}
	}
644
	return buffer_size - rest;  /* total size */
645 646 647
}

static int
648
ext4_xattr_block_list(struct dentry *dentry, char *buffer, size_t buffer_size)
649
{
650
	struct inode *inode = d_inode(dentry);
651 652 653 654 655 656 657
	struct buffer_head *bh = NULL;
	int error;

	ea_idebug(inode, "buffer=%p, buffer_size=%ld",
		  buffer, (long)buffer_size);

	error = 0;
658
	if (!EXT4_I(inode)->i_file_acl)
659
		goto cleanup;
660 661
	ea_idebug(inode, "reading block %llu",
		  (unsigned long long)EXT4_I(inode)->i_file_acl);
662
	bh = sb_bread(inode->i_sb, EXT4_I(inode)->i_file_acl);
663 664 665 666 667
	error = -EIO;
	if (!bh)
		goto cleanup;
	ea_bdebug(bh, "b_count=%d, refcount=%d",
		atomic_read(&(bh->b_count)), le32_to_cpu(BHDR(bh)->h_refcount));
668
	if (ext4_xattr_check_block(inode, bh)) {
669 670
		EXT4_ERROR_INODE(inode, "bad block %llu",
				 EXT4_I(inode)->i_file_acl);
671
		error = -EFSCORRUPTED;
672 673
		goto cleanup;
	}
674
	ext4_xattr_block_cache_insert(EA_BLOCK_CACHE(inode), bh);
675
	error = ext4_xattr_list_entries(dentry, BFIRST(bh), buffer, buffer_size);
676 677 678 679 680 681 682 683

cleanup:
	brelse(bh);

	return error;
}

static int
684
ext4_xattr_ibody_list(struct dentry *dentry, char *buffer, size_t buffer_size)
685
{
686
	struct inode *inode = d_inode(dentry);
687 688 689
	struct ext4_xattr_ibody_header *header;
	struct ext4_inode *raw_inode;
	struct ext4_iloc iloc;
690 691 692
	void *end;
	int error;

693
	if (!ext4_test_inode_state(inode, EXT4_STATE_XATTR))
694
		return 0;
695
	error = ext4_get_inode_loc(inode, &iloc);
696 697
	if (error)
		return error;
698
	raw_inode = ext4_raw_inode(&iloc);
699
	header = IHDR(inode, raw_inode);
700
	end = (void *)raw_inode + EXT4_SB(inode->i_sb)->s_inode_size;
701
	error = xattr_check_inode(inode, header, end);
702 703
	if (error)
		goto cleanup;
704
	error = ext4_xattr_list_entries(dentry, IFIRST(header),
705 706 707 708 709 710 711 712
					buffer, buffer_size);

cleanup:
	brelse(iloc.bh);
	return error;
}

/*
713 714 715
 * Inode operation listxattr()
 *
 * d_inode(dentry)->i_rwsem: don't care
716 717 718 719 720 721 722 723
 *
 * Copy a list of attribute names into the buffer
 * provided, or compute the buffer size required.
 * Buffer is NULL to compute the size of the buffer required.
 *
 * Returns a negative error number on failure, or the number of bytes
 * used / required on success.
 */
724 725
ssize_t
ext4_listxattr(struct dentry *dentry, char *buffer, size_t buffer_size)
726
{
727
	int ret, ret2;
728

729
	down_read(&EXT4_I(d_inode(dentry))->xattr_sem);
730 731 732 733 734 735
	ret = ret2 = ext4_xattr_ibody_list(dentry, buffer, buffer_size);
	if (ret < 0)
		goto errout;
	if (buffer) {
		buffer += ret;
		buffer_size -= ret;
736
	}
737 738 739 740 741
	ret = ext4_xattr_block_list(dentry, buffer, buffer_size);
	if (ret < 0)
		goto errout;
	ret += ret2;
errout:
742
	up_read(&EXT4_I(d_inode(dentry))->xattr_sem);
743
	return ret;
744 745 746
}

/*
747
 * If the EXT4_FEATURE_COMPAT_EXT_ATTR feature of this file system is
748 749
 * not set, set it.
 */
750
static void ext4_xattr_update_super_block(handle_t *handle,
751 752
					  struct super_block *sb)
{
753
	if (ext4_has_feature_xattr(sb))
754 755
		return;

756
	BUFFER_TRACE(EXT4_SB(sb)->s_sbh, "get_write_access");
757
	if (ext4_journal_get_write_access(handle, EXT4_SB(sb)->s_sbh) == 0) {
758
		ext4_set_feature_xattr(sb);
T
Theodore Ts'o 已提交
759
		ext4_handle_dirty_super(handle, sb);
760 761 762
	}
}

763 764 765 766 767 768 769 770 771 772 773 774 775 776 777 778 779 780 781 782 783 784 785 786 787 788 789 790 791 792 793 794 795 796 797 798 799 800 801 802 803 804 805 806 807 808 809 810 811 812 813 814 815 816 817
int ext4_get_inode_usage(struct inode *inode, qsize_t *usage)
{
	struct ext4_iloc iloc = { .bh = NULL };
	struct buffer_head *bh = NULL;
	struct ext4_inode *raw_inode;
	struct ext4_xattr_ibody_header *header;
	struct ext4_xattr_entry *entry;
	qsize_t ea_inode_refs = 0;
	void *end;
	int ret;

	lockdep_assert_held_read(&EXT4_I(inode)->xattr_sem);

	if (ext4_test_inode_state(inode, EXT4_STATE_XATTR)) {
		ret = ext4_get_inode_loc(inode, &iloc);
		if (ret)
			goto out;
		raw_inode = ext4_raw_inode(&iloc);
		header = IHDR(inode, raw_inode);
		end = (void *)raw_inode + EXT4_SB(inode->i_sb)->s_inode_size;
		ret = xattr_check_inode(inode, header, end);
		if (ret)
			goto out;

		for (entry = IFIRST(header); !IS_LAST_ENTRY(entry);
		     entry = EXT4_XATTR_NEXT(entry))
			if (entry->e_value_inum)
				ea_inode_refs++;
	}

	if (EXT4_I(inode)->i_file_acl) {
		bh = sb_bread(inode->i_sb, EXT4_I(inode)->i_file_acl);
		if (!bh) {
			ret = -EIO;
			goto out;
		}

		if (ext4_xattr_check_block(inode, bh)) {
			ret = -EFSCORRUPTED;
			goto out;
		}

		for (entry = BFIRST(bh); !IS_LAST_ENTRY(entry);
		     entry = EXT4_XATTR_NEXT(entry))
			if (entry->e_value_inum)
				ea_inode_refs++;
	}
	*usage = ea_inode_refs + 1;
	ret = 0;
out:
	brelse(iloc.bh);
	brelse(bh);
	return ret;
}

T
Tahsin Erdogan 已提交
818 819 820 821 822 823 824 825 826 827 828 829 830 831 832 833 834 835 836 837 838 839 840 841 842 843 844 845 846
static inline size_t round_up_cluster(struct inode *inode, size_t length)
{
	struct super_block *sb = inode->i_sb;
	size_t cluster_size = 1 << (EXT4_SB(sb)->s_cluster_bits +
				    inode->i_blkbits);
	size_t mask = ~(cluster_size - 1);

	return (length + cluster_size - 1) & mask;
}

static int ext4_xattr_inode_alloc_quota(struct inode *inode, size_t len)
{
	int err;

	err = dquot_alloc_inode(inode);
	if (err)
		return err;
	err = dquot_alloc_space_nodirty(inode, round_up_cluster(inode, len));
	if (err)
		dquot_free_inode(inode);
	return err;
}

static void ext4_xattr_inode_free_quota(struct inode *inode, size_t len)
{
	dquot_free_space_nodirty(inode, round_up_cluster(inode, len));
	dquot_free_inode(inode);
}

847 848 849
int __ext4_xattr_set_credits(struct super_block *sb, struct inode *inode,
			     struct buffer_head *block_bh, size_t value_len,
			     bool is_create)
T
Tahsin Erdogan 已提交
850 851 852 853 854 855 856 857 858 859 860 861 862 863 864 865 866 867 868 869 870 871 872 873 874 875
{
	int credits;
	int blocks;

	/*
	 * 1) Owner inode update
	 * 2) Ref count update on old xattr block
	 * 3) new xattr block
	 * 4) block bitmap update for new xattr block
	 * 5) group descriptor for new xattr block
	 * 6) block bitmap update for old xattr block
	 * 7) group descriptor for old block
	 *
	 * 6 & 7 can happen if we have two racing threads T_a and T_b
	 * which are each trying to set an xattr on inodes I_a and I_b
	 * which were both initially sharing an xattr block.
	 */
	credits = 7;

	/* Quota updates. */
	credits += EXT4_MAXQUOTAS_TRANS_BLOCKS(sb);

	/*
	 * In case of inline data, we may push out the data to a block,
	 * so we need to reserve credits for this eventuality
	 */
876
	if (inode && ext4_has_inline_data(inode))
T
Tahsin Erdogan 已提交
877 878 879 880 881 882 883 884 885 886 887 888 889 890 891 892 893 894 895 896 897
		credits += ext4_writepage_trans_blocks(inode) + 1;

	/* We are done if ea_inode feature is not enabled. */
	if (!ext4_has_feature_ea_inode(sb))
		return credits;

	/* New ea_inode, inode map, block bitmap, group descriptor. */
	credits += 4;

	/* Data blocks. */
	blocks = (value_len + sb->s_blocksize - 1) >> sb->s_blocksize_bits;

	/* Indirection block or one level of extent tree. */
	blocks += 1;

	/* Block bitmap and group descriptor updates for each block. */
	credits += blocks * 2;

	/* Blocks themselves. */
	credits += blocks;

898 899 900 901 902
	if (!is_create) {
		/* Dereference ea_inode holding old xattr value.
		 * Old ea_inode, inode map, block bitmap, group descriptor.
		 */
		credits += 4;
T
Tahsin Erdogan 已提交
903

904 905
		/* Data blocks for old ea_inode. */
		blocks = XATTR_SIZE_MAX >> sb->s_blocksize_bits;
T
Tahsin Erdogan 已提交
906

907 908 909 910
		/* Indirection block or one level of extent tree for old
		 * ea_inode.
		 */
		blocks += 1;
T
Tahsin Erdogan 已提交
911

912 913 914
		/* Block bitmap and group descriptor updates for each block. */
		credits += blocks * 2;
	}
T
Tahsin Erdogan 已提交
915 916 917 918 919 920 921 922 923 924 925 926 927 928 929

	/* We may need to clone the existing xattr block in which case we need
	 * to increment ref counts for existing ea_inodes referenced by it.
	 */
	if (block_bh) {
		struct ext4_xattr_entry *entry = BFIRST(block_bh);

		for (; !IS_LAST_ENTRY(entry); entry = EXT4_XATTR_NEXT(entry))
			if (entry->e_value_inum)
				/* Ref count update on ea_inode. */
				credits += 1;
	}
	return credits;
}

930 931 932 933 934 935 936 937 938 939 940 941 942 943 944 945 946 947 948 949 950 951 952 953 954 955 956 957 958 959 960 961 962 963 964 965 966 967 968 969 970 971 972 973 974 975 976 977 978
static int ext4_xattr_ensure_credits(handle_t *handle, struct inode *inode,
				     int credits, struct buffer_head *bh,
				     bool dirty, bool block_csum)
{
	int error;

	if (!ext4_handle_valid(handle))
		return 0;

	if (handle->h_buffer_credits >= credits)
		return 0;

	error = ext4_journal_extend(handle, credits - handle->h_buffer_credits);
	if (!error)
		return 0;
	if (error < 0) {
		ext4_warning(inode->i_sb, "Extend journal (error %d)", error);
		return error;
	}

	if (bh && dirty) {
		if (block_csum)
			ext4_xattr_block_csum_set(inode, bh);
		error = ext4_handle_dirty_metadata(handle, NULL, bh);
		if (error) {
			ext4_warning(inode->i_sb, "Handle metadata (error %d)",
				     error);
			return error;
		}
	}

	error = ext4_journal_restart(handle, credits);
	if (error) {
		ext4_warning(inode->i_sb, "Restart journal (error %d)", error);
		return error;
	}

	if (bh) {
		error = ext4_journal_get_write_access(handle, bh);
		if (error) {
			ext4_warning(inode->i_sb,
				     "Get write access failed (error %d)",
				     error);
			return error;
		}
	}
	return 0;
}

T
Tahsin Erdogan 已提交
979 980 981 982 983 984 985 986 987 988 989 990 991 992 993 994 995 996 997 998 999 1000 1001 1002 1003 1004 1005 1006 1007 1008 1009 1010
static int ext4_xattr_inode_update_ref(handle_t *handle, struct inode *ea_inode,
				       int ref_change)
{
	struct mb_cache *ea_inode_cache = EA_INODE_CACHE(ea_inode);
	struct ext4_iloc iloc;
	s64 ref_count;
	u32 hash;
	int ret;

	inode_lock(ea_inode);

	ret = ext4_reserve_inode_write(handle, ea_inode, &iloc);
	if (ret) {
		iloc.bh = NULL;
		goto out;
	}

	ref_count = ext4_xattr_inode_get_ref(ea_inode);
	ref_count += ref_change;
	ext4_xattr_inode_set_ref(ea_inode, ref_count);

	if (ref_change > 0) {
		WARN_ONCE(ref_count <= 0, "EA inode %lu ref_count=%lld",
			  ea_inode->i_ino, ref_count);

		if (ref_count == 1) {
			WARN_ONCE(ea_inode->i_nlink, "EA inode %lu i_nlink=%u",
				  ea_inode->i_ino, ea_inode->i_nlink);

			set_nlink(ea_inode, 1);
			ext4_orphan_del(handle, ea_inode);

1011 1012 1013 1014 1015 1016 1017
			if (ea_inode_cache) {
				hash = ext4_xattr_inode_get_hash(ea_inode);
				mb_cache_entry_create(ea_inode_cache,
						      GFP_NOFS, hash,
						      ea_inode->i_ino,
						      true /* reusable */);
			}
T
Tahsin Erdogan 已提交
1018 1019 1020 1021 1022 1023 1024 1025 1026 1027 1028 1029 1030
		}
	} else {
		WARN_ONCE(ref_count < 0, "EA inode %lu ref_count=%lld",
			  ea_inode->i_ino, ref_count);

		if (ref_count == 0) {
			WARN_ONCE(ea_inode->i_nlink != 1,
				  "EA inode %lu i_nlink=%u",
				  ea_inode->i_ino, ea_inode->i_nlink);

			clear_nlink(ea_inode);
			ext4_orphan_add(handle, ea_inode);

1031 1032 1033 1034 1035
			if (ea_inode_cache) {
				hash = ext4_xattr_inode_get_hash(ea_inode);
				mb_cache_entry_delete(ea_inode_cache, hash,
						      ea_inode->i_ino);
			}
T
Tahsin Erdogan 已提交
1036 1037 1038 1039 1040 1041 1042 1043 1044 1045 1046 1047 1048 1049 1050 1051 1052 1053 1054 1055 1056 1057 1058 1059 1060 1061 1062 1063 1064 1065 1066 1067 1068 1069 1070 1071 1072 1073 1074 1075 1076 1077 1078 1079 1080 1081 1082 1083 1084 1085 1086 1087 1088 1089 1090 1091 1092 1093 1094 1095 1096 1097 1098 1099 1100 1101 1102 1103 1104 1105 1106 1107 1108 1109 1110 1111
		}
	}

	ret = ext4_mark_iloc_dirty(handle, ea_inode, &iloc);
	iloc.bh = NULL;
	if (ret)
		ext4_warning_inode(ea_inode,
				   "ext4_mark_iloc_dirty() failed ret=%d", ret);
out:
	brelse(iloc.bh);
	inode_unlock(ea_inode);
	return ret;
}

static int ext4_xattr_inode_inc_ref(handle_t *handle, struct inode *ea_inode)
{
	return ext4_xattr_inode_update_ref(handle, ea_inode, 1);
}

static int ext4_xattr_inode_dec_ref(handle_t *handle, struct inode *ea_inode)
{
	return ext4_xattr_inode_update_ref(handle, ea_inode, -1);
}

static int ext4_xattr_inode_inc_ref_all(handle_t *handle, struct inode *parent,
					struct ext4_xattr_entry *first)
{
	struct inode *ea_inode;
	struct ext4_xattr_entry *entry;
	struct ext4_xattr_entry *failed_entry;
	unsigned int ea_ino;
	int err, saved_err;

	for (entry = first; !IS_LAST_ENTRY(entry);
	     entry = EXT4_XATTR_NEXT(entry)) {
		if (!entry->e_value_inum)
			continue;
		ea_ino = le32_to_cpu(entry->e_value_inum);
		err = ext4_xattr_inode_iget(parent, ea_ino, &ea_inode);
		if (err)
			goto cleanup;
		err = ext4_xattr_inode_inc_ref(handle, ea_inode);
		if (err) {
			ext4_warning_inode(ea_inode, "inc ref error %d", err);
			iput(ea_inode);
			goto cleanup;
		}
		iput(ea_inode);
	}
	return 0;

cleanup:
	saved_err = err;
	failed_entry = entry;

	for (entry = first; entry != failed_entry;
	     entry = EXT4_XATTR_NEXT(entry)) {
		if (!entry->e_value_inum)
			continue;
		ea_ino = le32_to_cpu(entry->e_value_inum);
		err = ext4_xattr_inode_iget(parent, ea_ino, &ea_inode);
		if (err) {
			ext4_warning(parent->i_sb,
				     "cleanup ea_ino %u iget error %d", ea_ino,
				     err);
			continue;
		}
		err = ext4_xattr_inode_dec_ref(handle, ea_inode);
		if (err)
			ext4_warning_inode(ea_inode, "cleanup dec ref error %d",
					   err);
		iput(ea_inode);
	}
	return saved_err;
}

1112
static void
T
Tahsin Erdogan 已提交
1113 1114 1115 1116 1117
ext4_xattr_inode_dec_ref_all(handle_t *handle, struct inode *parent,
			     struct buffer_head *bh,
			     struct ext4_xattr_entry *first, bool block_csum,
			     struct ext4_xattr_inode_array **ea_inode_array,
			     int extra_credits, bool skip_quota)
1118 1119 1120 1121 1122 1123 1124 1125 1126 1127 1128 1129 1130 1131 1132 1133 1134 1135 1136 1137 1138 1139 1140 1141 1142 1143 1144 1145 1146 1147 1148 1149 1150 1151 1152 1153
{
	struct inode *ea_inode;
	struct ext4_xattr_entry *entry;
	bool dirty = false;
	unsigned int ea_ino;
	int err;
	int credits;

	/* One credit for dec ref on ea_inode, one for orphan list addition, */
	credits = 2 + extra_credits;

	for (entry = first; !IS_LAST_ENTRY(entry);
	     entry = EXT4_XATTR_NEXT(entry)) {
		if (!entry->e_value_inum)
			continue;
		ea_ino = le32_to_cpu(entry->e_value_inum);
		err = ext4_xattr_inode_iget(parent, ea_ino, &ea_inode);
		if (err)
			continue;

		err = ext4_expand_inode_array(ea_inode_array, ea_inode);
		if (err) {
			ext4_warning_inode(ea_inode,
					   "Expand inode array err=%d", err);
			iput(ea_inode);
			continue;
		}

		err = ext4_xattr_ensure_credits(handle, parent, credits, bh,
						dirty, block_csum);
		if (err) {
			ext4_warning_inode(ea_inode, "Ensure credits err=%d",
					   err);
			continue;
		}

T
Tahsin Erdogan 已提交
1154 1155 1156 1157 1158 1159 1160 1161 1162 1163
		err = ext4_xattr_inode_dec_ref(handle, ea_inode);
		if (err) {
			ext4_warning_inode(ea_inode, "ea_inode dec ref err=%d",
					   err);
			continue;
		}

		if (!skip_quota)
			ext4_xattr_inode_free_quota(parent,
					      le32_to_cpu(entry->e_value_size));
1164 1165 1166 1167 1168 1169 1170 1171 1172 1173 1174 1175 1176 1177 1178 1179 1180 1181 1182 1183 1184 1185 1186 1187 1188 1189 1190

		/*
		 * Forget about ea_inode within the same transaction that
		 * decrements the ref count. This avoids duplicate decrements in
		 * case the rest of the work spills over to subsequent
		 * transactions.
		 */
		entry->e_value_inum = 0;
		entry->e_value_size = 0;

		dirty = true;
	}

	if (dirty) {
		/*
		 * Note that we are deliberately skipping csum calculation for
		 * the final update because we do not expect any journal
		 * restarts until xattr block is freed.
		 */

		err = ext4_handle_dirty_metadata(handle, NULL, bh);
		if (err)
			ext4_warning_inode(parent,
					   "handle dirty metadata err=%d", err);
	}
}

1191
/*
1192 1193
 * Release the xattr block BH: If the reference count is > 1, decrement it;
 * otherwise free the block.
1194 1195
 */
static void
1196
ext4_xattr_release_block(handle_t *handle, struct inode *inode,
T
Tahsin Erdogan 已提交
1197 1198 1199
			 struct buffer_head *bh,
			 struct ext4_xattr_inode_array **ea_inode_array,
			 int extra_credits)
1200
{
1201
	struct mb_cache *ea_block_cache = EA_BLOCK_CACHE(inode);
1202
	u32 hash, ref;
1203
	int error = 0;
1204

1205
	BUFFER_TRACE(bh, "get_write_access");
1206 1207 1208 1209 1210
	error = ext4_journal_get_write_access(handle, bh);
	if (error)
		goto out;

	lock_buffer(bh);
1211 1212 1213
	hash = le32_to_cpu(BHDR(bh)->h_hash);
	ref = le32_to_cpu(BHDR(bh)->h_refcount);
	if (ref == 1) {
1214
		ea_bdebug(bh, "refcount now=0; freeing");
J
Jan Kara 已提交
1215 1216 1217 1218
		/*
		 * This must happen under buffer lock for
		 * ext4_xattr_block_set() to reliably detect freed block
		 */
1219 1220 1221
		if (ea_block_cache)
			mb_cache_entry_delete(ea_block_cache, hash,
					      bh->b_blocknr);
1222
		get_bh(bh);
1223
		unlock_buffer(bh);
T
Tahsin Erdogan 已提交
1224 1225 1226 1227 1228 1229 1230 1231

		if (ext4_has_feature_ea_inode(inode->i_sb))
			ext4_xattr_inode_dec_ref_all(handle, inode, bh,
						     BFIRST(bh),
						     true /* block_csum */,
						     ea_inode_array,
						     extra_credits,
						     true /* skip_quota */);
1232 1233 1234
		ext4_free_blocks(handle, inode, bh, 0, 1,
				 EXT4_FREE_BLOCKS_METADATA |
				 EXT4_FREE_BLOCKS_FORGET);
1235
	} else {
1236 1237 1238 1239 1240
		ref--;
		BHDR(bh)->h_refcount = cpu_to_le32(ref);
		if (ref == EXT4_XATTR_REFCOUNT_MAX - 1) {
			struct mb_cache_entry *ce;

1241 1242 1243 1244 1245 1246 1247
			if (ea_block_cache) {
				ce = mb_cache_entry_get(ea_block_cache, hash,
							bh->b_blocknr);
				if (ce) {
					ce->e_reusable = 1;
					mb_cache_entry_put(ea_block_cache, ce);
				}
1248 1249 1250
			}
		}

1251
		ext4_xattr_block_csum_set(inode, bh);
1252 1253 1254 1255 1256 1257
		/*
		 * Beware of this ugliness: Releasing of xattr block references
		 * from different inodes can race and so we have to protect
		 * from a race where someone else frees the block (and releases
		 * its journal_head) before we are done dirtying the buffer. In
		 * nojournal mode this race is harmless and we actually cannot
1258
		 * call ext4_handle_dirty_metadata() with locked buffer as
1259 1260 1261 1262
		 * that function can call sync_dirty_buffer() so for that case
		 * we handle the dirtying after unlocking the buffer.
		 */
		if (ext4_handle_valid(handle))
1263
			error = ext4_handle_dirty_metadata(handle, inode, bh);
1264
		unlock_buffer(bh);
1265
		if (!ext4_handle_valid(handle))
1266
			error = ext4_handle_dirty_metadata(handle, inode, bh);
1267
		if (IS_SYNC(inode))
1268
			ext4_handle_sync(handle);
1269
		dquot_free_block(inode, EXT4_C2B(EXT4_SB(inode->i_sb), 1));
1270 1271
		ea_bdebug(bh, "refcount now=%d; releasing",
			  le32_to_cpu(BHDR(bh)->h_refcount));
1272
	}
1273 1274 1275
out:
	ext4_std_error(inode->i_sb, error);
	return;
1276 1277
}

1278 1279 1280 1281 1282 1283 1284 1285
/*
 * Find the available free space for EAs. This also returns the total number of
 * bytes used by EA entries.
 */
static size_t ext4_xattr_free_space(struct ext4_xattr_entry *last,
				    size_t *min_offs, void *base, int *total)
{
	for (; !IS_LAST_ENTRY(last); last = EXT4_XATTR_NEXT(last)) {
A
Andreas Dilger 已提交
1286
		if (!last->e_value_inum && last->e_value_size) {
1287 1288 1289 1290
			size_t offs = le16_to_cpu(last->e_value_offs);
			if (offs < *min_offs)
				*min_offs = offs;
		}
1291 1292
		if (total)
			*total += EXT4_XATTR_LEN(last->e_name_len);
1293 1294 1295 1296
	}
	return (*min_offs - ((void *)last - base) - sizeof(__u32));
}

A
Andreas Dilger 已提交
1297 1298 1299 1300 1301 1302 1303 1304
/*
 * Write the value of the EA in an inode.
 */
static int ext4_xattr_inode_write(handle_t *handle, struct inode *ea_inode,
				  const void *buf, int bufsize)
{
	struct buffer_head *bh = NULL;
	unsigned long block = 0;
T
Tahsin Erdogan 已提交
1305 1306
	int blocksize = ea_inode->i_sb->s_blocksize;
	int max_blocks = (bufsize + blocksize - 1) >> ea_inode->i_blkbits;
A
Andreas Dilger 已提交
1307 1308 1309 1310 1311 1312 1313 1314 1315 1316 1317 1318 1319 1320 1321 1322 1323 1324 1325 1326 1327 1328 1329 1330 1331 1332 1333 1334 1335 1336 1337 1338 1339 1340 1341 1342 1343 1344 1345 1346 1347 1348 1349 1350 1351 1352 1353 1354 1355 1356 1357 1358 1359 1360 1361 1362 1363 1364 1365 1366 1367 1368 1369 1370 1371
	int csize, wsize = 0;
	int ret = 0;
	int retries = 0;

retry:
	while (ret >= 0 && ret < max_blocks) {
		struct ext4_map_blocks map;
		map.m_lblk = block += ret;
		map.m_len = max_blocks -= ret;

		ret = ext4_map_blocks(handle, ea_inode, &map,
				      EXT4_GET_BLOCKS_CREATE);
		if (ret <= 0) {
			ext4_mark_inode_dirty(handle, ea_inode);
			if (ret == -ENOSPC &&
			    ext4_should_retry_alloc(ea_inode->i_sb, &retries)) {
				ret = 0;
				goto retry;
			}
			break;
		}
	}

	if (ret < 0)
		return ret;

	block = 0;
	while (wsize < bufsize) {
		if (bh != NULL)
			brelse(bh);
		csize = (bufsize - wsize) > blocksize ? blocksize :
								bufsize - wsize;
		bh = ext4_getblk(handle, ea_inode, block, 0);
		if (IS_ERR(bh))
			return PTR_ERR(bh);
		ret = ext4_journal_get_write_access(handle, bh);
		if (ret)
			goto out;

		memcpy(bh->b_data, buf, csize);
		set_buffer_uptodate(bh);
		ext4_handle_dirty_metadata(handle, ea_inode, bh);

		buf += csize;
		wsize += csize;
		block += 1;
	}

	inode_lock(ea_inode);
	i_size_write(ea_inode, wsize);
	ext4_update_i_disksize(ea_inode, wsize);
	inode_unlock(ea_inode);

	ext4_mark_inode_dirty(handle, ea_inode);

out:
	brelse(bh);

	return ret;
}

/*
 * Create an inode to store the value of a large EA.
 */
static struct inode *ext4_xattr_inode_create(handle_t *handle,
T
Tahsin Erdogan 已提交
1372
					     struct inode *inode, u32 hash)
A
Andreas Dilger 已提交
1373 1374
{
	struct inode *ea_inode = NULL;
1375
	uid_t owner[2] = { i_uid_read(inode), i_gid_read(inode) };
1376
	int err;
A
Andreas Dilger 已提交
1377 1378 1379 1380 1381 1382

	/*
	 * Let the next inode be the goal, so we try and allocate the EA inode
	 * in the same group, or nearby one.
	 */
	ea_inode = ext4_new_inode(handle, inode->i_sb->s_root->d_inode,
1383
				  S_IFREG | 0600, NULL, inode->i_ino + 1, owner,
1384
				  EXT4_EA_INODE_FL);
A
Andreas Dilger 已提交
1385 1386 1387 1388
	if (!IS_ERR(ea_inode)) {
		ea_inode->i_op = &ext4_file_inode_operations;
		ea_inode->i_fop = &ext4_file_operations;
		ext4_set_aops(ea_inode);
1389
		ext4_xattr_inode_set_class(ea_inode);
A
Andreas Dilger 已提交
1390
		unlock_new_inode(ea_inode);
T
Tahsin Erdogan 已提交
1391 1392 1393 1394 1395
		ext4_xattr_inode_set_ref(ea_inode, 1);
		ext4_xattr_inode_set_hash(ea_inode, hash);
		err = ext4_mark_inode_dirty(handle, ea_inode);
		if (!err)
			err = ext4_inode_attach_jinode(ea_inode);
1396 1397 1398 1399
		if (err) {
			iput(ea_inode);
			return ERR_PTR(err);
		}
T
Tahsin Erdogan 已提交
1400 1401 1402 1403 1404 1405 1406 1407 1408 1409

		/*
		 * Xattr inodes are shared therefore quota charging is performed
		 * at a higher level.
		 */
		dquot_free_inode(ea_inode);
		dquot_drop(ea_inode);
		inode_lock(ea_inode);
		ea_inode->i_flags |= S_NOQUOTA;
		inode_unlock(ea_inode);
A
Andreas Dilger 已提交
1410 1411 1412 1413 1414
	}

	return ea_inode;
}

T
Tahsin Erdogan 已提交
1415 1416 1417
static struct inode *
ext4_xattr_inode_cache_find(struct inode *inode, const void *value,
			    size_t value_len, u32 hash)
A
Andreas Dilger 已提交
1418
{
T
Tahsin Erdogan 已提交
1419 1420 1421 1422 1423
	struct inode *ea_inode;
	struct mb_cache_entry *ce;
	struct mb_cache *ea_inode_cache = EA_INODE_CACHE(inode);
	void *ea_data;

1424 1425 1426
	if (!ea_inode_cache)
		return NULL;

T
Tahsin Erdogan 已提交
1427 1428 1429 1430 1431 1432 1433 1434 1435
	ce = mb_cache_entry_find_first(ea_inode_cache, hash);
	if (!ce)
		return NULL;

	ea_data = ext4_kvmalloc(value_len, GFP_NOFS);
	if (!ea_data) {
		mb_cache_entry_put(ea_inode_cache, ce);
		return NULL;
	}
A
Andreas Dilger 已提交
1436

T
Tahsin Erdogan 已提交
1437 1438 1439 1440 1441 1442 1443
	while (ce) {
		ea_inode = ext4_iget(inode->i_sb, ce->e_value);
		if (!IS_ERR(ea_inode) &&
		    !is_bad_inode(ea_inode) &&
		    (EXT4_I(ea_inode)->i_flags & EXT4_EA_INODE_FL) &&
		    i_size_read(ea_inode) == value_len &&
		    !ext4_xattr_inode_read(ea_inode, ea_data, value_len) &&
1444 1445
		    !ext4_xattr_inode_verify_hashes(ea_inode, NULL, ea_data,
						    value_len) &&
T
Tahsin Erdogan 已提交
1446 1447 1448 1449 1450 1451
		    !memcmp(value, ea_data, value_len)) {
			mb_cache_entry_touch(ea_inode_cache, ce);
			mb_cache_entry_put(ea_inode_cache, ce);
			kvfree(ea_data);
			return ea_inode;
		}
A
Andreas Dilger 已提交
1452

T
Tahsin Erdogan 已提交
1453 1454 1455 1456 1457 1458
		if (!IS_ERR(ea_inode))
			iput(ea_inode);
		ce = mb_cache_entry_find_next(ea_inode_cache, ce);
	}
	kvfree(ea_data);
	return NULL;
A
Andreas Dilger 已提交
1459 1460 1461 1462 1463
}

/*
 * Add value of the EA in an inode.
 */
T
Tahsin Erdogan 已提交
1464 1465 1466
static int ext4_xattr_inode_lookup_create(handle_t *handle, struct inode *inode,
					  const void *value, size_t value_len,
					  struct inode **ret_inode)
A
Andreas Dilger 已提交
1467 1468
{
	struct inode *ea_inode;
T
Tahsin Erdogan 已提交
1469
	u32 hash;
A
Andreas Dilger 已提交
1470 1471
	int err;

T
Tahsin Erdogan 已提交
1472 1473 1474 1475 1476 1477 1478 1479 1480 1481 1482 1483 1484
	hash = ext4_xattr_inode_hash(EXT4_SB(inode->i_sb), value, value_len);
	ea_inode = ext4_xattr_inode_cache_find(inode, value, value_len, hash);
	if (ea_inode) {
		err = ext4_xattr_inode_inc_ref(handle, ea_inode);
		if (err) {
			iput(ea_inode);
			return err;
		}

		*ret_inode = ea_inode;
		return 0;
	}

A
Andreas Dilger 已提交
1485
	/* Create an inode for the EA value */
T
Tahsin Erdogan 已提交
1486
	ea_inode = ext4_xattr_inode_create(handle, inode, hash);
A
Andreas Dilger 已提交
1487 1488 1489 1490
	if (IS_ERR(ea_inode))
		return PTR_ERR(ea_inode);

	err = ext4_xattr_inode_write(handle, ea_inode, value, value_len);
T
Tahsin Erdogan 已提交
1491 1492 1493 1494 1495
	if (err) {
		ext4_xattr_inode_dec_ref(handle, ea_inode);
		iput(ea_inode);
		return err;
	}
A
Andreas Dilger 已提交
1496

1497 1498 1499
	if (EA_INODE_CACHE(inode))
		mb_cache_entry_create(EA_INODE_CACHE(inode), GFP_NOFS, hash,
				      ea_inode->i_ino, true /* reusable */);
A
Andreas Dilger 已提交
1500

T
Tahsin Erdogan 已提交
1501 1502
	*ret_inode = ea_inode;
	return 0;
A
Andreas Dilger 已提交
1503 1504
}

1505 1506 1507 1508 1509 1510
/*
 * Reserve min(block_size/8, 1024) bytes for xattr entries/names if ea_inode
 * feature is enabled.
 */
#define EXT4_XATTR_BLOCK_RESERVE(inode)	min(i_blocksize(inode)/8, 1024U)

A
Andreas Dilger 已提交
1511 1512
static int ext4_xattr_set_entry(struct ext4_xattr_info *i,
				struct ext4_xattr_search *s,
1513 1514
				handle_t *handle, struct inode *inode,
				bool is_block)
1515
{
1516
	struct ext4_xattr_entry *last;
T
Tahsin Erdogan 已提交
1517 1518
	struct ext4_xattr_entry *here = s->here;
	size_t min_offs = s->end - s->base, name_len = strlen(i->name);
A
Andreas Dilger 已提交
1519
	int in_inode = i->in_inode;
T
Tahsin Erdogan 已提交
1520 1521 1522 1523 1524 1525 1526 1527 1528 1529 1530 1531 1532 1533 1534 1535 1536 1537 1538 1539 1540 1541 1542 1543 1544 1545 1546 1547
	struct inode *old_ea_inode = NULL;
	struct inode *new_ea_inode = NULL;
	size_t old_size, new_size;
	int ret;

	/* Space used by old and new values. */
	old_size = (!s->not_found && !here->e_value_inum) ?
			EXT4_XATTR_SIZE(le32_to_cpu(here->e_value_size)) : 0;
	new_size = (i->value && !in_inode) ? EXT4_XATTR_SIZE(i->value_len) : 0;

	/*
	 * Optimization for the simple case when old and new values have the
	 * same padded sizes. Not applicable if external inodes are involved.
	 */
	if (new_size && new_size == old_size) {
		size_t offs = le16_to_cpu(here->e_value_offs);
		void *val = s->base + offs;

		here->e_value_size = cpu_to_le32(i->value_len);
		if (i->value == EXT4_ZERO_XATTR_VALUE) {
			memset(val, 0, new_size);
		} else {
			memcpy(val, i->value, i->value_len);
			/* Clear padding bytes. */
			memset(val + i->value_len, 0, new_size - i->value_len);
		}
		return 0;
	}
A
Andreas Dilger 已提交
1548

1549 1550
	/* Compute min_offs and last. */
	last = s->first;
1551
	for (; !IS_LAST_ENTRY(last); last = EXT4_XATTR_NEXT(last)) {
A
Andreas Dilger 已提交
1552
		if (!last->e_value_inum && last->e_value_size) {
1553 1554 1555 1556 1557
			size_t offs = le16_to_cpu(last->e_value_offs);
			if (offs < min_offs)
				min_offs = offs;
		}
	}
T
Tahsin Erdogan 已提交
1558 1559

	/* Check whether we have enough space. */
1560
	if (i->value) {
T
Tahsin Erdogan 已提交
1561
		size_t free;
A
Andreas Dilger 已提交
1562

T
Tahsin Erdogan 已提交
1563 1564 1565
		free = min_offs - ((void *)last - s->base) - sizeof(__u32);
		if (!s->not_found)
			free += EXT4_XATTR_LEN(name_len) + old_size;
A
Andreas Dilger 已提交
1566

T
Tahsin Erdogan 已提交
1567 1568 1569 1570
		if (free < EXT4_XATTR_LEN(name_len) + new_size) {
			ret = -ENOSPC;
			goto out;
		}
1571 1572 1573 1574 1575 1576 1577

		/*
		 * If storing the value in an external inode is an option,
		 * reserve space for xattr entries/names in the external
		 * attribute block so that a long value does not occupy the
		 * whole space and prevent futher entries being added.
		 */
1578 1579
		if (ext4_has_feature_ea_inode(inode->i_sb) &&
		    new_size && is_block &&
1580 1581 1582 1583 1584
		    (min_offs + old_size - new_size) <
					EXT4_XATTR_BLOCK_RESERVE(inode)) {
			ret = -ENOSPC;
			goto out;
		}
1585 1586
	}

T
Tahsin Erdogan 已提交
1587 1588 1589 1590 1591 1592 1593 1594 1595 1596 1597 1598 1599 1600 1601
	/*
	 * Getting access to old and new ea inodes is subject to failures.
	 * Finish that work before doing any modifications to the xattr data.
	 */
	if (!s->not_found && here->e_value_inum) {
		ret = ext4_xattr_inode_iget(inode,
					    le32_to_cpu(here->e_value_inum),
					    &old_ea_inode);
		if (ret) {
			old_ea_inode = NULL;
			goto out;
		}
	}
	if (i->value && in_inode) {
		WARN_ON_ONCE(!i->value_len);
1602

T
Tahsin Erdogan 已提交
1603 1604 1605 1606 1607 1608 1609 1610 1611 1612 1613
		ret = ext4_xattr_inode_alloc_quota(inode, i->value_len);
		if (ret)
			goto out;

		ret = ext4_xattr_inode_lookup_create(handle, inode, i->value,
						     i->value_len,
						     &new_ea_inode);
		if (ret) {
			new_ea_inode = NULL;
			ext4_xattr_inode_free_quota(inode, i->value_len);
			goto out;
1614
		}
T
Tahsin Erdogan 已提交
1615 1616 1617 1618 1619 1620 1621 1622 1623 1624 1625 1626 1627 1628 1629 1630 1631 1632 1633 1634
	}

	if (old_ea_inode) {
		/* We are ready to release ref count on the old_ea_inode. */
		ret = ext4_xattr_inode_dec_ref(handle, old_ea_inode);
		if (ret) {
			/* Release newly required ref count on new_ea_inode. */
			if (new_ea_inode) {
				int err;

				err = ext4_xattr_inode_dec_ref(handle,
							       new_ea_inode);
				if (err)
					ext4_warning_inode(new_ea_inode,
						  "dec ref new_ea_inode err=%d",
						  err);
				ext4_xattr_inode_free_quota(inode,
							    i->value_len);
			}
			goto out;
A
Andreas Dilger 已提交
1635
		}
T
Tahsin Erdogan 已提交
1636 1637 1638 1639 1640 1641 1642 1643 1644 1645 1646 1647 1648 1649 1650 1651 1652 1653 1654 1655 1656 1657 1658 1659 1660 1661

		ext4_xattr_inode_free_quota(inode,
					    le32_to_cpu(here->e_value_size));
	}

	/* No failures allowed past this point. */

	if (!s->not_found && here->e_value_offs) {
		/* Remove the old value. */
		void *first_val = s->base + min_offs;
		size_t offs = le16_to_cpu(here->e_value_offs);
		void *val = s->base + offs;

		memmove(first_val + old_size, first_val, val - first_val);
		memset(first_val, 0, old_size);
		min_offs += old_size;

		/* Adjust all value offsets. */
		last = s->first;
		while (!IS_LAST_ENTRY(last)) {
			size_t o = le16_to_cpu(last->e_value_offs);

			if (!last->e_value_inum &&
			    last->e_value_size && o < offs)
				last->e_value_offs = cpu_to_le16(o + old_size);
			last = EXT4_XATTR_NEXT(last);
1662 1663 1664
		}
	}

T
Tahsin Erdogan 已提交
1665 1666 1667 1668 1669 1670 1671 1672 1673 1674 1675 1676 1677 1678 1679 1680 1681 1682 1683 1684 1685 1686 1687 1688 1689
	if (!i->value) {
		/* Remove old name. */
		size_t size = EXT4_XATTR_LEN(name_len);

		last = ENTRY((void *)last - size);
		memmove(here, (void *)here + size,
			(void *)last - (void *)here + sizeof(__u32));
		memset(last, 0, size);
	} else if (s->not_found) {
		/* Insert new name. */
		size_t size = EXT4_XATTR_LEN(name_len);
		size_t rest = (void *)last - (void *)here + sizeof(__u32);

		memmove((void *)here + size, here, rest);
		memset(here, 0, size);
		here->e_name_index = i->name_index;
		here->e_name_len = name_len;
		memcpy(here->e_name, i->name, name_len);
	} else {
		/* This is an update, reset value info. */
		here->e_value_inum = 0;
		here->e_value_offs = 0;
		here->e_value_size = 0;
	}

1690
	if (i->value) {
T
Tahsin Erdogan 已提交
1691
		/* Insert new value. */
A
Andreas Dilger 已提交
1692
		if (in_inode) {
T
Tahsin Erdogan 已提交
1693
			here->e_value_inum = cpu_to_le32(new_ea_inode->i_ino);
A
Andreas Dilger 已提交
1694
		} else if (i->value_len) {
T
Tahsin Erdogan 已提交
1695 1696 1697
			void *val = s->base + min_offs - new_size;

			here->e_value_offs = cpu_to_le16(min_offs - new_size);
1698
			if (i->value == EXT4_ZERO_XATTR_VALUE) {
T
Tahsin Erdogan 已提交
1699
				memset(val, 0, new_size);
1700 1701
			} else {
				memcpy(val, i->value, i->value_len);
T
Tahsin Erdogan 已提交
1702 1703 1704
				/* Clear padding bytes. */
				memset(val + i->value_len, 0,
				       new_size - i->value_len);
1705
			}
1706
		}
T
Tahsin Erdogan 已提交
1707
		here->e_value_size = cpu_to_le32(i->value_len);
1708
	}
1709

1710 1711 1712 1713 1714 1715 1716 1717 1718 1719 1720 1721 1722 1723 1724 1725 1726 1727 1728 1729 1730 1731 1732 1733 1734
	if (i->value) {
		__le32 hash = 0;

		/* Entry hash calculation. */
		if (in_inode) {
			__le32 crc32c_hash;

			/*
			 * Feed crc32c hash instead of the raw value for entry
			 * hash calculation. This is to avoid walking
			 * potentially long value buffer again.
			 */
			crc32c_hash = cpu_to_le32(
				       ext4_xattr_inode_get_hash(new_ea_inode));
			hash = ext4_xattr_hash_entry(here->e_name,
						     here->e_name_len,
						     &crc32c_hash, 1);
		} else if (is_block) {
			__le32 *value = s->base + min_offs - new_size;

			hash = ext4_xattr_hash_entry(here->e_name,
						     here->e_name_len, value,
						     new_size >> 2);
		}
		here->e_hash = hash;
1735 1736
	}

1737 1738 1739
	if (is_block)
		ext4_xattr_rehash((struct ext4_xattr_header *)s->base);

T
Tahsin Erdogan 已提交
1740
	ret = 0;
A
Andreas Dilger 已提交
1741
out:
T
Tahsin Erdogan 已提交
1742 1743 1744
	iput(old_ea_inode);
	iput(new_ea_inode);
	return ret;
1745 1746
}

1747 1748
struct ext4_xattr_block_find {
	struct ext4_xattr_search s;
1749 1750 1751 1752
	struct buffer_head *bh;
};

static int
1753 1754
ext4_xattr_block_find(struct inode *inode, struct ext4_xattr_info *i,
		      struct ext4_xattr_block_find *bs)
1755 1756 1757 1758 1759 1760 1761
{
	struct super_block *sb = inode->i_sb;
	int error;

	ea_idebug(inode, "name=%d.%s, value=%p, value_len=%ld",
		  i->name_index, i->name, i->value, (long)i->value_len);

1762
	if (EXT4_I(inode)->i_file_acl) {
1763
		/* The inode already has an extended attribute block. */
1764
		bs->bh = sb_bread(sb, EXT4_I(inode)->i_file_acl);
1765 1766 1767 1768 1769 1770
		error = -EIO;
		if (!bs->bh)
			goto cleanup;
		ea_bdebug(bs->bh, "b_count=%d, refcount=%d",
			atomic_read(&(bs->bh->b_count)),
			le32_to_cpu(BHDR(bs->bh)->h_refcount));
1771
		if (ext4_xattr_check_block(inode, bs->bh)) {
1772 1773
			EXT4_ERROR_INODE(inode, "bad block %llu",
					 EXT4_I(inode)->i_file_acl);
1774
			error = -EFSCORRUPTED;
1775 1776 1777 1778 1779 1780 1781
			goto cleanup;
		}
		/* Find the named attribute. */
		bs->s.base = BHDR(bs->bh);
		bs->s.first = BFIRST(bs->bh);
		bs->s.end = bs->bh->b_data + bs->bh->b_size;
		bs->s.here = bs->s.first;
1782
		error = ext4_xattr_find_entry(&bs->s.here, i->name_index,
1783
					      i->name, 1);
1784 1785 1786 1787 1788 1789 1790 1791 1792 1793 1794
		if (error && error != -ENODATA)
			goto cleanup;
		bs->s.not_found = error;
	}
	error = 0;

cleanup:
	return error;
}

static int
1795 1796 1797
ext4_xattr_block_set(handle_t *handle, struct inode *inode,
		     struct ext4_xattr_info *i,
		     struct ext4_xattr_block_find *bs)
1798 1799 1800
{
	struct super_block *sb = inode->i_sb;
	struct buffer_head *new_bh = NULL;
1801 1802
	struct ext4_xattr_search s_copy = bs->s;
	struct ext4_xattr_search *s = &s_copy;
J
Jan Kara 已提交
1803
	struct mb_cache_entry *ce = NULL;
1804
	int error = 0;
1805
	struct mb_cache *ea_block_cache = EA_BLOCK_CACHE(inode);
T
Tahsin Erdogan 已提交
1806 1807
	struct inode *ea_inode = NULL;
	size_t old_ea_inode_size = 0;
1808

1809
#define header(x) ((struct ext4_xattr_header *)(x))
1810 1811

	if (s->base) {
1812
		BUFFER_TRACE(bs->bh, "get_write_access");
1813 1814 1815 1816 1817
		error = ext4_journal_get_write_access(handle, bs->bh);
		if (error)
			goto cleanup;
		lock_buffer(bs->bh);

1818
		if (header(s->base)->h_refcount == cpu_to_le32(1)) {
J
Jan Kara 已提交
1819 1820 1821 1822 1823 1824 1825
			__u32 hash = le32_to_cpu(BHDR(bs->bh)->h_hash);

			/*
			 * This must happen under buffer lock for
			 * ext4_xattr_block_set() to reliably detect modified
			 * block
			 */
1826 1827 1828
			if (ea_block_cache)
				mb_cache_entry_delete(ea_block_cache, hash,
						      bs->bh->b_blocknr);
1829
			ea_bdebug(bs->bh, "modifying in-place");
1830 1831
			error = ext4_xattr_set_entry(i, s, handle, inode,
						     true /* is_block */);
1832
			ext4_xattr_block_csum_set(inode, bs->bh);
1833
			unlock_buffer(bs->bh);
1834
			if (error == -EFSCORRUPTED)
1835 1836
				goto bad_block;
			if (!error)
1837 1838 1839
				error = ext4_handle_dirty_metadata(handle,
								   inode,
								   bs->bh);
1840 1841 1842 1843 1844 1845
			if (error)
				goto cleanup;
			goto inserted;
		} else {
			int offset = (char *)s->here - bs->bh->b_data;

1846
			unlock_buffer(bs->bh);
1847
			ea_bdebug(bs->bh, "cloning");
1848
			s->base = kmalloc(bs->bh->b_size, GFP_NOFS);
1849 1850 1851 1852 1853 1854 1855 1856
			error = -ENOMEM;
			if (s->base == NULL)
				goto cleanup;
			memcpy(s->base, BHDR(bs->bh), bs->bh->b_size);
			s->first = ENTRY(header(s->base)+1);
			header(s->base)->h_refcount = cpu_to_le32(1);
			s->here = ENTRY(s->base + offset);
			s->end = s->base + bs->bh->b_size;
T
Tahsin Erdogan 已提交
1857 1858 1859 1860 1861 1862 1863 1864 1865 1866 1867 1868 1869 1870 1871 1872 1873 1874

			/*
			 * If existing entry points to an xattr inode, we need
			 * to prevent ext4_xattr_set_entry() from decrementing
			 * ref count on it because the reference belongs to the
			 * original block. In this case, make the entry look
			 * like it has an empty value.
			 */
			if (!s->not_found && s->here->e_value_inum) {
				/*
				 * Defer quota free call for previous inode
				 * until success is guaranteed.
				 */
				old_ea_inode_size = le32_to_cpu(
							s->here->e_value_size);
				s->here->e_value_inum = 0;
				s->here->e_value_size = 0;
			}
1875 1876 1877
		}
	} else {
		/* Allocate a buffer where we construct the new block. */
1878
		s->base = kzalloc(sb->s_blocksize, GFP_NOFS);
1879 1880 1881 1882
		/* assert(header == s->base) */
		error = -ENOMEM;
		if (s->base == NULL)
			goto cleanup;
1883
		header(s->base)->h_magic = cpu_to_le32(EXT4_XATTR_MAGIC);
1884 1885 1886 1887 1888 1889 1890
		header(s->base)->h_blocks = cpu_to_le32(1);
		header(s->base)->h_refcount = cpu_to_le32(1);
		s->first = ENTRY(header(s->base)+1);
		s->here = ENTRY(header(s->base)+1);
		s->end = s->base + sb->s_blocksize;
	}

1891
	error = ext4_xattr_set_entry(i, s, handle, inode, true /* is_block */);
1892
	if (error == -EFSCORRUPTED)
1893 1894 1895
		goto bad_block;
	if (error)
		goto cleanup;
T
Tahsin Erdogan 已提交
1896 1897 1898 1899 1900 1901 1902 1903 1904 1905 1906 1907 1908 1909 1910 1911 1912 1913

	if (i->value && s->here->e_value_inum) {
		unsigned int ea_ino;

		/*
		 * A ref count on ea_inode has been taken as part of the call to
		 * ext4_xattr_set_entry() above. We would like to drop this
		 * extra ref but we have to wait until the xattr block is
		 * initialized and has its own ref count on the ea_inode.
		 */
		ea_ino = le32_to_cpu(s->here->e_value_inum);
		error = ext4_xattr_inode_iget(inode, ea_ino, &ea_inode);
		if (error) {
			ea_inode = NULL;
			goto cleanup;
		}
	}

1914 1915
inserted:
	if (!IS_LAST_ENTRY(s->first)) {
1916 1917
		new_bh = ext4_xattr_block_cache_find(inode, header(s->base),
						     &ce);
1918 1919 1920 1921 1922
		if (new_bh) {
			/* We found an identical block in the cache. */
			if (new_bh == bs->bh)
				ea_bdebug(new_bh, "keeping");
			else {
1923 1924
				u32 ref;

1925 1926
				WARN_ON_ONCE(dquot_initialize_needed(inode));

1927 1928
				/* The old block is released after updating
				   the inode. */
1929 1930
				error = dquot_alloc_block(inode,
						EXT4_C2B(EXT4_SB(sb), 1));
1931
				if (error)
1932
					goto cleanup;
1933
				BUFFER_TRACE(new_bh, "get_write_access");
1934
				error = ext4_journal_get_write_access(handle,
1935 1936 1937 1938
								      new_bh);
				if (error)
					goto cleanup_dquot;
				lock_buffer(new_bh);
J
Jan Kara 已提交
1939 1940
				/*
				 * We have to be careful about races with
1941 1942 1943 1944 1945 1946 1947 1948 1949
				 * freeing, rehashing or adding references to
				 * xattr block. Once we hold buffer lock xattr
				 * block's state is stable so we can check
				 * whether the block got freed / rehashed or
				 * not.  Since we unhash mbcache entry under
				 * buffer lock when freeing / rehashing xattr
				 * block, checking whether entry is still
				 * hashed is reliable. Same rules hold for
				 * e_reusable handling.
J
Jan Kara 已提交
1950
				 */
1951 1952
				if (hlist_bl_unhashed(&ce->e_hash_list) ||
				    !ce->e_reusable) {
J
Jan Kara 已提交
1953 1954 1955 1956 1957 1958 1959 1960 1961
					/*
					 * Undo everything and check mbcache
					 * again.
					 */
					unlock_buffer(new_bh);
					dquot_free_block(inode,
							 EXT4_C2B(EXT4_SB(sb),
								  1));
					brelse(new_bh);
1962
					mb_cache_entry_put(ea_block_cache, ce);
J
Jan Kara 已提交
1963 1964 1965 1966
					ce = NULL;
					new_bh = NULL;
					goto inserted;
				}
1967 1968 1969 1970
				ref = le32_to_cpu(BHDR(new_bh)->h_refcount) + 1;
				BHDR(new_bh)->h_refcount = cpu_to_le32(ref);
				if (ref >= EXT4_XATTR_REFCOUNT_MAX)
					ce->e_reusable = 0;
1971
				ea_bdebug(new_bh, "reusing; refcount now=%d",
1972
					  ref);
1973
				ext4_xattr_block_csum_set(inode, new_bh);
1974
				unlock_buffer(new_bh);
1975 1976 1977
				error = ext4_handle_dirty_metadata(handle,
								   inode,
								   new_bh);
1978 1979 1980
				if (error)
					goto cleanup_dquot;
			}
1981 1982
			mb_cache_entry_touch(ea_block_cache, ce);
			mb_cache_entry_put(ea_block_cache, ce);
1983 1984 1985 1986
			ce = NULL;
		} else if (bs->bh && s->base == bs->bh->b_data) {
			/* We were modifying this block in-place. */
			ea_bdebug(bs->bh, "keeping this block");
1987
			ext4_xattr_block_cache_insert(ea_block_cache, bs->bh);
1988 1989 1990 1991
			new_bh = bs->bh;
			get_bh(new_bh);
		} else {
			/* We need to allocate a new block */
1992 1993
			ext4_fsblk_t goal, block;

1994 1995
			WARN_ON_ONCE(dquot_initialize_needed(inode));

1996
			goal = ext4_group_first_block_no(sb,
1997
						EXT4_I(inode)->i_block_group);
1998 1999

			/* non-extent files can't have physical blocks past 2^32 */
2000
			if (!(ext4_test_inode_flag(inode, EXT4_INODE_EXTENTS)))
2001 2002
				goal = goal & EXT4_MAX_BLOCK_FILE_PHYS;

2003 2004
			block = ext4_new_meta_blocks(handle, inode, goal, 0,
						     NULL, &error);
2005 2006
			if (error)
				goto cleanup;
2007

2008
			if (!(ext4_test_inode_flag(inode, EXT4_INODE_EXTENTS)))
2009 2010
				BUG_ON(block > EXT4_MAX_BLOCK_FILE_PHYS);

2011 2012
			ea_idebug(inode, "creating block %llu",
				  (unsigned long long)block);
2013 2014

			new_bh = sb_getblk(sb, block);
2015
			if (unlikely(!new_bh)) {
2016
				error = -ENOMEM;
2017
getblk_failed:
2018
				ext4_free_blocks(handle, inode, NULL, block, 1,
2019
						 EXT4_FREE_BLOCKS_METADATA);
2020 2021
				goto cleanup;
			}
T
Tahsin Erdogan 已提交
2022 2023 2024 2025 2026 2027 2028 2029 2030 2031 2032 2033 2034 2035 2036 2037
			error = ext4_xattr_inode_inc_ref_all(handle, inode,
						      ENTRY(header(s->base)+1));
			if (error)
				goto getblk_failed;
			if (ea_inode) {
				/* Drop the extra ref on ea_inode. */
				error = ext4_xattr_inode_dec_ref(handle,
								 ea_inode);
				if (error)
					ext4_warning_inode(ea_inode,
							   "dec ref error=%d",
							   error);
				iput(ea_inode);
				ea_inode = NULL;
			}

2038
			lock_buffer(new_bh);
2039
			error = ext4_journal_get_create_access(handle, new_bh);
2040 2041
			if (error) {
				unlock_buffer(new_bh);
2042
				error = -EIO;
2043 2044 2045
				goto getblk_failed;
			}
			memcpy(new_bh->b_data, s->base, new_bh->b_size);
2046
			ext4_xattr_block_csum_set(inode, new_bh);
2047 2048
			set_buffer_uptodate(new_bh);
			unlock_buffer(new_bh);
2049
			ext4_xattr_block_cache_insert(ea_block_cache, new_bh);
2050 2051
			error = ext4_handle_dirty_metadata(handle, inode,
							   new_bh);
2052 2053 2054 2055 2056
			if (error)
				goto cleanup;
		}
	}

T
Tahsin Erdogan 已提交
2057 2058 2059
	if (old_ea_inode_size)
		ext4_xattr_inode_free_quota(inode, old_ea_inode_size);

2060
	/* Update the inode. */
2061
	EXT4_I(inode)->i_file_acl = new_bh ? new_bh->b_blocknr : 0;
2062 2063

	/* Drop the previous xattr block. */
T
Tahsin Erdogan 已提交
2064 2065 2066 2067 2068 2069 2070 2071
	if (bs->bh && bs->bh != new_bh) {
		struct ext4_xattr_inode_array *ea_inode_array = NULL;

		ext4_xattr_release_block(handle, inode, bs->bh,
					 &ea_inode_array,
					 0 /* extra_credits */);
		ext4_xattr_inode_array_free(ea_inode_array);
	}
2072 2073 2074
	error = 0;

cleanup:
T
Tahsin Erdogan 已提交
2075 2076 2077 2078 2079 2080 2081 2082 2083 2084 2085 2086 2087 2088
	if (ea_inode) {
		int error2;

		error2 = ext4_xattr_inode_dec_ref(handle, ea_inode);
		if (error2)
			ext4_warning_inode(ea_inode, "dec ref error=%d",
					   error2);

		/* If there was an error, revert the quota charge. */
		if (error)
			ext4_xattr_inode_free_quota(inode,
						    i_size_read(ea_inode));
		iput(ea_inode);
	}
2089
	if (ce)
2090
		mb_cache_entry_put(ea_block_cache, ce);
2091 2092 2093 2094 2095 2096 2097
	brelse(new_bh);
	if (!(bs->bh && s->base == bs->bh->b_data))
		kfree(s->base);

	return error;

cleanup_dquot:
2098
	dquot_free_block(inode, EXT4_C2B(EXT4_SB(sb), 1));
2099 2100 2101
	goto cleanup;

bad_block:
2102 2103
	EXT4_ERROR_INODE(inode, "bad block %llu",
			 EXT4_I(inode)->i_file_acl);
2104 2105 2106 2107 2108
	goto cleanup;

#undef header
}

T
Tao Ma 已提交
2109 2110
int ext4_xattr_ibody_find(struct inode *inode, struct ext4_xattr_info *i,
			  struct ext4_xattr_ibody_find *is)
2111
{
2112 2113
	struct ext4_xattr_ibody_header *header;
	struct ext4_inode *raw_inode;
2114 2115
	int error;

2116
	if (EXT4_I(inode)->i_extra_isize == 0)
2117
		return 0;
2118
	raw_inode = ext4_raw_inode(&is->iloc);
2119 2120 2121
	header = IHDR(inode, raw_inode);
	is->s.base = is->s.first = IFIRST(header);
	is->s.here = is->s.first;
2122
	is->s.end = (void *)raw_inode + EXT4_SB(inode->i_sb)->s_inode_size;
2123
	if (ext4_test_inode_state(inode, EXT4_STATE_XATTR)) {
2124
		error = xattr_check_inode(inode, header, is->s.end);
2125 2126 2127
		if (error)
			return error;
		/* Find the named attribute. */
2128
		error = ext4_xattr_find_entry(&is->s.here, i->name_index,
2129
					      i->name, 0);
2130 2131 2132 2133 2134 2135 2136
		if (error && error != -ENODATA)
			return error;
		is->s.not_found = error;
	}
	return 0;
}

2137 2138 2139 2140 2141 2142 2143 2144 2145 2146
int ext4_xattr_ibody_inline_set(handle_t *handle, struct inode *inode,
				struct ext4_xattr_info *i,
				struct ext4_xattr_ibody_find *is)
{
	struct ext4_xattr_ibody_header *header;
	struct ext4_xattr_search *s = &is->s;
	int error;

	if (EXT4_I(inode)->i_extra_isize == 0)
		return -ENOSPC;
2147
	error = ext4_xattr_set_entry(i, s, handle, inode, false /* is_block */);
2148 2149 2150 2151 2152 2153 2154 2155 2156 2157 2158
	if (error) {
		if (error == -ENOSPC &&
		    ext4_has_inline_data(inode)) {
			error = ext4_try_to_evict_inline_data(handle, inode,
					EXT4_XATTR_LEN(strlen(i->name) +
					EXT4_XATTR_SIZE(i->value_len)));
			if (error)
				return error;
			error = ext4_xattr_ibody_find(inode, i, is);
			if (error)
				return error;
2159 2160
			error = ext4_xattr_set_entry(i, s, handle, inode,
						     false /* is_block */);
2161 2162 2163 2164 2165 2166 2167 2168 2169 2170 2171 2172 2173 2174 2175
		}
		if (error)
			return error;
	}
	header = IHDR(inode, ext4_raw_inode(&is->iloc));
	if (!IS_LAST_ENTRY(s->first)) {
		header->h_magic = cpu_to_le32(EXT4_XATTR_MAGIC);
		ext4_set_inode_state(inode, EXT4_STATE_XATTR);
	} else {
		header->h_magic = cpu_to_le32(0);
		ext4_clear_inode_state(inode, EXT4_STATE_XATTR);
	}
	return 0;
}

A
Andreas Dilger 已提交
2176
static int ext4_xattr_ibody_set(handle_t *handle, struct inode *inode,
2177 2178
				struct ext4_xattr_info *i,
				struct ext4_xattr_ibody_find *is)
2179
{
2180 2181
	struct ext4_xattr_ibody_header *header;
	struct ext4_xattr_search *s = &is->s;
2182 2183
	int error;

2184
	if (EXT4_I(inode)->i_extra_isize == 0)
2185
		return -ENOSPC;
2186
	error = ext4_xattr_set_entry(i, s, handle, inode, false /* is_block */);
2187 2188
	if (error)
		return error;
2189
	header = IHDR(inode, ext4_raw_inode(&is->iloc));
2190
	if (!IS_LAST_ENTRY(s->first)) {
2191
		header->h_magic = cpu_to_le32(EXT4_XATTR_MAGIC);
2192
		ext4_set_inode_state(inode, EXT4_STATE_XATTR);
2193 2194
	} else {
		header->h_magic = cpu_to_le32(0);
2195
		ext4_clear_inode_state(inode, EXT4_STATE_XATTR);
2196 2197 2198 2199
	}
	return 0;
}

2200 2201 2202 2203 2204
static int ext4_xattr_value_same(struct ext4_xattr_search *s,
				 struct ext4_xattr_info *i)
{
	void *value;

2205 2206 2207
	/* When e_value_inum is set the value is stored externally. */
	if (s->here->e_value_inum)
		return 0;
2208 2209 2210 2211 2212 2213
	if (le32_to_cpu(s->here->e_value_size) != i->value_len)
		return 0;
	value = ((void *)s->base) + le16_to_cpu(s->here->e_value_offs);
	return !memcmp(value, i->value, i->value_len);
}

T
Tahsin Erdogan 已提交
2214 2215 2216 2217 2218 2219 2220 2221 2222 2223 2224 2225 2226 2227 2228 2229
static struct buffer_head *ext4_xattr_get_block(struct inode *inode)
{
	struct buffer_head *bh;
	int error;

	if (!EXT4_I(inode)->i_file_acl)
		return NULL;
	bh = sb_bread(inode->i_sb, EXT4_I(inode)->i_file_acl);
	if (!bh)
		return ERR_PTR(-EIO);
	error = ext4_xattr_check_block(inode, bh);
	if (error)
		return ERR_PTR(error);
	return bh;
}

2230
/*
2231
 * ext4_xattr_set_handle()
2232
 *
2233
 * Create, replace or remove an extended attribute for this inode.  Value
2234 2235 2236 2237 2238 2239 2240 2241 2242
 * is NULL to remove an existing extended attribute, and non-NULL to
 * either replace an existing extended attribute, or create a new extended
 * attribute. The flags XATTR_REPLACE and XATTR_CREATE
 * specify that an extended attribute must exist and must not exist
 * previous to the call, respectively.
 *
 * Returns 0, or a negative error number on failure.
 */
int
2243
ext4_xattr_set_handle(handle_t *handle, struct inode *inode, int name_index,
2244 2245 2246
		      const char *name, const void *value, size_t value_len,
		      int flags)
{
2247
	struct ext4_xattr_info i = {
2248 2249 2250 2251
		.name_index = name_index,
		.name = name,
		.value = value,
		.value_len = value_len,
A
Andreas Dilger 已提交
2252
		.in_inode = 0,
2253
	};
2254
	struct ext4_xattr_ibody_find is = {
2255 2256
		.s = { .not_found = -ENODATA, },
	};
2257
	struct ext4_xattr_block_find bs = {
2258 2259
		.s = { .not_found = -ENODATA, },
	};
2260
	int no_expand;
2261 2262 2263 2264 2265 2266
	int error;

	if (!name)
		return -EINVAL;
	if (strlen(name) > 255)
		return -ERANGE;
2267

2268
	ext4_write_lock_xattr(inode, &no_expand);
K
Kalpak Shah 已提交
2269

2270 2271
	/* Check journal credits under write lock. */
	if (ext4_handle_valid(handle)) {
T
Tahsin Erdogan 已提交
2272
		struct buffer_head *bh;
2273 2274
		int credits;

T
Tahsin Erdogan 已提交
2275 2276 2277 2278 2279 2280
		bh = ext4_xattr_get_block(inode);
		if (IS_ERR(bh)) {
			error = PTR_ERR(bh);
			goto cleanup;
		}

2281 2282 2283
		credits = __ext4_xattr_set_credits(inode->i_sb, inode, bh,
						   value_len,
						   flags & XATTR_CREATE);
T
Tahsin Erdogan 已提交
2284 2285
		brelse(bh);

2286 2287 2288 2289 2290 2291
		if (!ext4_handle_has_enough_credits(handle, credits)) {
			error = -ENOSPC;
			goto cleanup;
		}
	}

2292
	error = ext4_reserve_inode_write(handle, inode, &is.iloc);
2293 2294 2295
	if (error)
		goto cleanup;

2296
	if (ext4_test_inode_state(inode, EXT4_STATE_NEW)) {
2297 2298
		struct ext4_inode *raw_inode = ext4_raw_inode(&is.iloc);
		memset(raw_inode, 0, EXT4_SB(inode->i_sb)->s_inode_size);
2299
		ext4_clear_inode_state(inode, EXT4_STATE_NEW);
2300 2301
	}

2302
	error = ext4_xattr_ibody_find(inode, &i, &is);
2303 2304 2305
	if (error)
		goto cleanup;
	if (is.s.not_found)
2306
		error = ext4_xattr_block_find(inode, &i, &bs);
2307 2308 2309 2310 2311 2312 2313 2314 2315 2316 2317 2318 2319 2320
	if (error)
		goto cleanup;
	if (is.s.not_found && bs.s.not_found) {
		error = -ENODATA;
		if (flags & XATTR_REPLACE)
			goto cleanup;
		error = 0;
		if (!value)
			goto cleanup;
	} else {
		error = -EEXIST;
		if (flags & XATTR_CREATE)
			goto cleanup;
	}
T
Tahsin Erdogan 已提交
2321

2322 2323
	if (!value) {
		if (!is.s.not_found)
A
Andreas Dilger 已提交
2324
			error = ext4_xattr_ibody_set(handle, inode, &i, &is);
2325
		else if (!bs.s.not_found)
2326
			error = ext4_xattr_block_set(handle, inode, &i, &bs);
2327
	} else {
2328 2329 2330 2331 2332 2333 2334
		error = 0;
		/* Xattr value did not change? Save us some work and bail out */
		if (!is.s.not_found && ext4_xattr_value_same(&is.s, &i))
			goto cleanup;
		if (!bs.s.not_found && ext4_xattr_value_same(&bs.s, &i))
			goto cleanup;

2335 2336 2337 2338 2339
		if (ext4_has_feature_ea_inode(inode->i_sb) &&
		    (EXT4_XATTR_SIZE(i.value_len) >
			EXT4_XATTR_MIN_LARGE_EA_SIZE(inode->i_sb->s_blocksize)))
			i.in_inode = 1;
retry_inode:
A
Andreas Dilger 已提交
2340
		error = ext4_xattr_ibody_set(handle, inode, &i, &is);
2341 2342
		if (!error && !bs.s.not_found) {
			i.value = NULL;
2343
			error = ext4_xattr_block_set(handle, inode, &i, &bs);
2344
		} else if (error == -ENOSPC) {
2345 2346 2347 2348 2349
			if (EXT4_I(inode)->i_file_acl && !bs.s.base) {
				error = ext4_xattr_block_find(inode, &i, &bs);
				if (error)
					goto cleanup;
			}
2350
			error = ext4_xattr_block_set(handle, inode, &i, &bs);
2351
			if (!error && !is.s.not_found) {
2352
				i.value = NULL;
A
Andreas Dilger 已提交
2353 2354
				error = ext4_xattr_ibody_set(handle, inode, &i,
							     &is);
2355 2356 2357 2358 2359 2360 2361 2362 2363 2364
			} else if (error == -ENOSPC) {
				/*
				 * Xattr does not fit in the block, store at
				 * external inode if possible.
				 */
				if (ext4_has_feature_ea_inode(inode->i_sb) &&
				    !i.in_inode) {
					i.in_inode = 1;
					goto retry_inode;
				}
2365 2366 2367 2368
			}
		}
	}
	if (!error) {
2369
		ext4_xattr_update_super_block(handle, inode->i_sb);
2370
		inode->i_ctime = current_time(inode);
2371
		if (!value)
2372
			no_expand = 0;
2373
		error = ext4_mark_iloc_dirty(handle, inode, &is.iloc);
2374
		/*
2375
		 * The bh is consumed by ext4_mark_iloc_dirty, even with
2376 2377 2378 2379
		 * error != 0.
		 */
		is.iloc.bh = NULL;
		if (IS_SYNC(inode))
2380
			ext4_handle_sync(handle);
2381 2382 2383 2384 2385
	}

cleanup:
	brelse(is.iloc.bh);
	brelse(bs.bh);
2386
	ext4_write_unlock_xattr(inode, &no_expand);
2387 2388 2389
	return error;
}

2390 2391
int ext4_xattr_set_credits(struct inode *inode, size_t value_len,
			   bool is_create, int *credits)
2392
{
T
Tahsin Erdogan 已提交
2393 2394
	struct buffer_head *bh;
	int err;
2395

T
Tahsin Erdogan 已提交
2396
	*credits = 0;
2397

T
Tahsin Erdogan 已提交
2398 2399
	if (!EXT4_SB(inode->i_sb)->s_journal)
		return 0;
2400

T
Tahsin Erdogan 已提交
2401
	down_read(&EXT4_I(inode)->xattr_sem);
2402

T
Tahsin Erdogan 已提交
2403 2404 2405 2406
	bh = ext4_xattr_get_block(inode);
	if (IS_ERR(bh)) {
		err = PTR_ERR(bh);
	} else {
2407 2408
		*credits = __ext4_xattr_set_credits(inode->i_sb, inode, bh,
						    value_len, is_create);
T
Tahsin Erdogan 已提交
2409 2410
		brelse(bh);
		err = 0;
2411
	}
T
Tahsin Erdogan 已提交
2412 2413 2414

	up_read(&EXT4_I(inode)->xattr_sem);
	return err;
2415 2416
}

2417
/*
2418
 * ext4_xattr_set()
2419
 *
2420
 * Like ext4_xattr_set_handle, but start from an inode. This extended
2421 2422 2423 2424 2425
 * attribute modification is a filesystem transaction by itself.
 *
 * Returns 0, or a negative error number on failure.
 */
int
2426
ext4_xattr_set(struct inode *inode, int name_index, const char *name,
2427 2428 2429
	       const void *value, size_t value_len, int flags)
{
	handle_t *handle;
A
Andreas Dilger 已提交
2430
	struct super_block *sb = inode->i_sb;
2431
	int error, retries = 0;
2432
	int credits;
2433

2434 2435 2436
	error = dquot_initialize(inode);
	if (error)
		return error;
A
Andreas Dilger 已提交
2437

2438
retry:
2439 2440
	error = ext4_xattr_set_credits(inode, value_len, flags & XATTR_CREATE,
				       &credits);
T
Tahsin Erdogan 已提交
2441 2442 2443
	if (error)
		return error;

2444
	handle = ext4_journal_start(inode, EXT4_HT_XATTR, credits);
2445 2446 2447 2448 2449
	if (IS_ERR(handle)) {
		error = PTR_ERR(handle);
	} else {
		int error2;

2450
		error = ext4_xattr_set_handle(handle, inode, name_index, name,
2451
					      value, value_len, flags);
2452
		error2 = ext4_journal_stop(handle);
2453
		if (error == -ENOSPC &&
A
Andreas Dilger 已提交
2454
		    ext4_should_retry_alloc(sb, &retries))
2455 2456 2457 2458 2459 2460 2461 2462
			goto retry;
		if (error == 0)
			error = error2;
	}

	return error;
}

2463 2464 2465 2466 2467 2468
/*
 * Shift the EA entries in the inode to create space for the increased
 * i_extra_isize.
 */
static void ext4_xattr_shift_entries(struct ext4_xattr_entry *entry,
				     int value_offs_shift, void *to,
2469
				     void *from, size_t n)
2470 2471 2472 2473
{
	struct ext4_xattr_entry *last = entry;
	int new_offs;

2474 2475 2476
	/* We always shift xattr headers further thus offsets get lower */
	BUG_ON(value_offs_shift > 0);

2477 2478
	/* Adjust the value offsets of the entries */
	for (; !IS_LAST_ENTRY(last); last = EXT4_XATTR_NEXT(last)) {
A
Andreas Dilger 已提交
2479
		if (!last->e_value_inum && last->e_value_size) {
2480 2481 2482 2483 2484 2485 2486 2487 2488
			new_offs = le16_to_cpu(last->e_value_offs) +
							value_offs_shift;
			last->e_value_offs = cpu_to_le16(new_offs);
		}
	}
	/* Shift the entries by n bytes */
	memmove(to, from, n);
}

J
Jan Kara 已提交
2489 2490 2491 2492 2493 2494 2495 2496 2497 2498
/*
 * Move xattr pointed to by 'entry' from inode into external xattr block
 */
static int ext4_xattr_move_to_block(handle_t *handle, struct inode *inode,
				    struct ext4_inode *raw_inode,
				    struct ext4_xattr_entry *entry)
{
	struct ext4_xattr_ibody_find *is = NULL;
	struct ext4_xattr_block_find *bs = NULL;
	char *buffer = NULL, *b_entry_name = NULL;
2499
	size_t value_size = le32_to_cpu(entry->e_value_size);
J
Jan Kara 已提交
2500 2501 2502 2503
	struct ext4_xattr_info i = {
		.value = NULL,
		.value_len = 0,
		.name_index = entry->e_name_index,
2504
		.in_inode = !!entry->e_value_inum,
J
Jan Kara 已提交
2505 2506 2507 2508 2509 2510 2511 2512 2513 2514 2515 2516 2517 2518 2519 2520 2521 2522 2523
	};
	struct ext4_xattr_ibody_header *header = IHDR(inode, raw_inode);
	int error;

	is = kzalloc(sizeof(struct ext4_xattr_ibody_find), GFP_NOFS);
	bs = kzalloc(sizeof(struct ext4_xattr_block_find), GFP_NOFS);
	buffer = kmalloc(value_size, GFP_NOFS);
	b_entry_name = kmalloc(entry->e_name_len + 1, GFP_NOFS);
	if (!is || !bs || !buffer || !b_entry_name) {
		error = -ENOMEM;
		goto out;
	}

	is->s.not_found = -ENODATA;
	bs->s.not_found = -ENODATA;
	is->iloc.bh = NULL;
	bs->bh = NULL;

	/* Save the entry name and the entry value */
2524
	if (entry->e_value_inum) {
2525
		error = ext4_xattr_inode_get(inode, entry, buffer, value_size);
2526 2527 2528 2529 2530 2531 2532
		if (error)
			goto out;
	} else {
		size_t value_offs = le16_to_cpu(entry->e_value_offs);
		memcpy(buffer, (void *)IFIRST(header) + value_offs, value_size);
	}

J
Jan Kara 已提交
2533 2534 2535 2536 2537 2538 2539 2540 2541 2542 2543 2544 2545
	memcpy(b_entry_name, entry->e_name, entry->e_name_len);
	b_entry_name[entry->e_name_len] = '\0';
	i.name = b_entry_name;

	error = ext4_get_inode_loc(inode, &is->iloc);
	if (error)
		goto out;

	error = ext4_xattr_ibody_find(inode, &i, is);
	if (error)
		goto out;

	/* Remove the chosen entry from the inode */
A
Andreas Dilger 已提交
2546
	error = ext4_xattr_ibody_set(handle, inode, &i, is);
J
Jan Kara 已提交
2547 2548 2549 2550 2551 2552 2553 2554 2555 2556 2557 2558 2559 2560 2561 2562 2563 2564 2565 2566 2567 2568 2569 2570 2571
	if (error)
		goto out;

	i.value = buffer;
	i.value_len = value_size;
	error = ext4_xattr_block_find(inode, &i, bs);
	if (error)
		goto out;

	/* Add entry which was removed from the inode into the block */
	error = ext4_xattr_block_set(handle, inode, &i, bs);
	if (error)
		goto out;
	error = 0;
out:
	kfree(b_entry_name);
	kfree(buffer);
	if (is)
		brelse(is->iloc.bh);
	kfree(is);
	kfree(bs);

	return error;
}

2572 2573 2574 2575 2576 2577 2578 2579 2580 2581 2582 2583 2584 2585 2586 2587 2588 2589 2590 2591 2592
static int ext4_xattr_make_inode_space(handle_t *handle, struct inode *inode,
				       struct ext4_inode *raw_inode,
				       int isize_diff, size_t ifree,
				       size_t bfree, int *total_ino)
{
	struct ext4_xattr_ibody_header *header = IHDR(inode, raw_inode);
	struct ext4_xattr_entry *small_entry;
	struct ext4_xattr_entry *entry;
	struct ext4_xattr_entry *last;
	unsigned int entry_size;	/* EA entry size */
	unsigned int total_size;	/* EA entry size + value size */
	unsigned int min_total_size;
	int error;

	while (isize_diff > ifree) {
		entry = NULL;
		small_entry = NULL;
		min_total_size = ~0U;
		last = IFIRST(header);
		/* Find the entry best suited to be pushed into EA block */
		for (; !IS_LAST_ENTRY(last); last = EXT4_XATTR_NEXT(last)) {
2593 2594 2595 2596
			total_size = EXT4_XATTR_LEN(last->e_name_len);
			if (!last->e_value_inum)
				total_size += EXT4_XATTR_SIZE(
					       le32_to_cpu(last->e_value_size));
2597 2598 2599 2600 2601 2602 2603 2604 2605 2606 2607 2608 2609 2610 2611 2612 2613 2614
			if (total_size <= bfree &&
			    total_size < min_total_size) {
				if (total_size + ifree < isize_diff) {
					small_entry = last;
				} else {
					entry = last;
					min_total_size = total_size;
				}
			}
		}

		if (entry == NULL) {
			if (small_entry == NULL)
				return -ENOSPC;
			entry = small_entry;
		}

		entry_size = EXT4_XATTR_LEN(entry->e_name_len);
2615 2616 2617 2618
		total_size = entry_size;
		if (!entry->e_value_inum)
			total_size += EXT4_XATTR_SIZE(
					      le32_to_cpu(entry->e_value_size));
2619 2620 2621 2622 2623 2624 2625 2626 2627 2628 2629 2630 2631
		error = ext4_xattr_move_to_block(handle, inode, raw_inode,
						 entry);
		if (error)
			return error;

		*total_ino -= entry_size;
		ifree += total_size;
		bfree -= total_size;
	}

	return 0;
}

2632 2633 2634 2635 2636 2637 2638 2639 2640
/*
 * Expand an inode by new_extra_isize bytes when EAs are present.
 * Returns 0 on success or negative error number on failure.
 */
int ext4_expand_extra_isize_ea(struct inode *inode, int new_extra_isize,
			       struct ext4_inode *raw_inode, handle_t *handle)
{
	struct ext4_xattr_ibody_header *header;
	struct buffer_head *bh = NULL;
2641 2642
	size_t min_offs;
	size_t ifree, bfree;
2643
	int total_ino;
2644
	void *base, *end;
2645
	int error = 0, tried_min_extra_isize = 0;
A
Aneesh Kumar K.V 已提交
2646
	int s_min_extra_isize = le16_to_cpu(EXT4_SB(inode->i_sb)->s_es->s_min_extra_isize);
2647
	int isize_diff;	/* How much do we need to grow i_extra_isize */
2648 2649

retry:
2650
	isize_diff = new_extra_isize - EXT4_I(inode)->i_extra_isize;
2651 2652
	if (EXT4_I(inode)->i_extra_isize >= new_extra_isize)
		goto out;
2653 2654 2655 2656 2657 2658 2659 2660

	header = IHDR(inode, raw_inode);

	/*
	 * Check if enough free space is available in the inode to shift the
	 * entries ahead by new_extra_isize.
	 */

2661
	base = IFIRST(header);
2662 2663 2664 2665
	end = (void *)raw_inode + EXT4_SB(inode->i_sb)->s_inode_size;
	min_offs = end - base;
	total_ino = sizeof(struct ext4_xattr_ibody_header);

2666 2667 2668 2669
	error = xattr_check_inode(inode, header, end);
	if (error)
		goto cleanup;

2670
	ifree = ext4_xattr_free_space(base, &min_offs, base, &total_ino);
2671 2672
	if (ifree >= isize_diff)
		goto shift;
2673 2674 2675 2676 2677 2678 2679 2680 2681 2682

	/*
	 * Enough free space isn't available in the inode, check if
	 * EA block can hold new_extra_isize bytes.
	 */
	if (EXT4_I(inode)->i_file_acl) {
		bh = sb_bread(inode->i_sb, EXT4_I(inode)->i_file_acl);
		error = -EIO;
		if (!bh)
			goto cleanup;
2683
		if (ext4_xattr_check_block(inode, bh)) {
2684 2685
			EXT4_ERROR_INODE(inode, "bad block %llu",
					 EXT4_I(inode)->i_file_acl);
2686
			error = -EFSCORRUPTED;
2687 2688 2689 2690 2691
			goto cleanup;
		}
		base = BHDR(bh);
		end = bh->b_data + bh->b_size;
		min_offs = end - base;
2692 2693
		bfree = ext4_xattr_free_space(BFIRST(bh), &min_offs, base,
					      NULL);
2694
		if (bfree + ifree < isize_diff) {
2695 2696 2697 2698 2699 2700
			if (!tried_min_extra_isize && s_min_extra_isize) {
				tried_min_extra_isize++;
				new_extra_isize = s_min_extra_isize;
				brelse(bh);
				goto retry;
			}
2701
			error = -ENOSPC;
2702 2703 2704
			goto cleanup;
		}
	} else {
2705
		bfree = inode->i_sb->s_blocksize;
2706 2707
	}

2708 2709 2710 2711 2712 2713 2714 2715 2716 2717
	error = ext4_xattr_make_inode_space(handle, inode, raw_inode,
					    isize_diff, ifree, bfree,
					    &total_ino);
	if (error) {
		if (error == -ENOSPC && !tried_min_extra_isize &&
		    s_min_extra_isize) {
			tried_min_extra_isize++;
			new_extra_isize = s_min_extra_isize;
			brelse(bh);
			goto retry;
2718
		}
2719
		goto cleanup;
2720
	}
2721 2722
shift:
	/* Adjust the offsets and shift the remaining entries ahead */
2723
	ext4_xattr_shift_entries(IFIRST(header), EXT4_I(inode)->i_extra_isize
2724 2725
			- new_extra_isize, (void *)raw_inode +
			EXT4_GOOD_OLD_INODE_SIZE + new_extra_isize,
2726
			(void *)header, total_ino);
2727
	EXT4_I(inode)->i_extra_isize = new_extra_isize;
2728
	brelse(bh);
2729
out:
2730 2731 2732 2733 2734 2735 2736
	return 0;

cleanup:
	brelse(bh);
	return error;
}

A
Andreas Dilger 已提交
2737 2738
#define EIA_INCR 16 /* must be 2^n */
#define EIA_MASK (EIA_INCR - 1)
T
Tahsin Erdogan 已提交
2739 2740

/* Add the large xattr @inode into @ea_inode_array for deferred iput().
2741
 * If @ea_inode_array is new or full it will be grown and the old
A
Andreas Dilger 已提交
2742 2743 2744
 * contents copied over.
 */
static int
2745 2746
ext4_expand_inode_array(struct ext4_xattr_inode_array **ea_inode_array,
			struct inode *inode)
A
Andreas Dilger 已提交
2747
{
2748
	if (*ea_inode_array == NULL) {
A
Andreas Dilger 已提交
2749 2750
		/*
		 * Start with 15 inodes, so it fits into a power-of-two size.
2751
		 * If *ea_inode_array is NULL, this is essentially offsetof()
A
Andreas Dilger 已提交
2752
		 */
2753 2754 2755
		(*ea_inode_array) =
			kmalloc(offsetof(struct ext4_xattr_inode_array,
					 inodes[EIA_MASK]),
A
Andreas Dilger 已提交
2756
				GFP_NOFS);
2757
		if (*ea_inode_array == NULL)
A
Andreas Dilger 已提交
2758
			return -ENOMEM;
2759 2760
		(*ea_inode_array)->count = 0;
	} else if (((*ea_inode_array)->count & EIA_MASK) == EIA_MASK) {
A
Andreas Dilger 已提交
2761
		/* expand the array once all 15 + n * 16 slots are full */
2762 2763
		struct ext4_xattr_inode_array *new_array = NULL;
		int count = (*ea_inode_array)->count;
A
Andreas Dilger 已提交
2764 2765 2766

		/* if new_array is NULL, this is essentially offsetof() */
		new_array = kmalloc(
2767 2768
				offsetof(struct ext4_xattr_inode_array,
					 inodes[count + EIA_INCR]),
A
Andreas Dilger 已提交
2769 2770 2771
				GFP_NOFS);
		if (new_array == NULL)
			return -ENOMEM;
2772 2773 2774 2775
		memcpy(new_array, *ea_inode_array,
		       offsetof(struct ext4_xattr_inode_array, inodes[count]));
		kfree(*ea_inode_array);
		*ea_inode_array = new_array;
A
Andreas Dilger 已提交
2776
	}
2777
	(*ea_inode_array)->inodes[(*ea_inode_array)->count++] = inode;
A
Andreas Dilger 已提交
2778 2779 2780
	return 0;
}

2781
/*
2782
 * ext4_xattr_delete_inode()
2783
 *
A
Andreas Dilger 已提交
2784
 * Free extended attribute resources associated with this inode. Traverse
T
Tahsin Erdogan 已提交
2785 2786 2787 2788
 * all entries and decrement reference on any xattr inodes associated with this
 * inode. This is called immediately before an inode is freed. We have exclusive
 * access to the inode. If an orphan inode is deleted it will also release its
 * references on xattr block and xattr inodes.
2789
 */
T
Tahsin Erdogan 已提交
2790 2791 2792
int ext4_xattr_delete_inode(handle_t *handle, struct inode *inode,
			    struct ext4_xattr_inode_array **ea_inode_array,
			    int extra_credits)
2793 2794
{
	struct buffer_head *bh = NULL;
A
Andreas Dilger 已提交
2795
	struct ext4_xattr_ibody_header *header;
2796
	struct ext4_iloc iloc = { .bh = NULL };
T
Tahsin Erdogan 已提交
2797
	struct ext4_xattr_entry *entry;
2798 2799 2800 2801 2802 2803 2804 2805 2806 2807
	int error;

	error = ext4_xattr_ensure_credits(handle, inode, extra_credits,
					  NULL /* bh */,
					  false /* dirty */,
					  false /* block_csum */);
	if (error) {
		EXT4_ERROR_INODE(inode, "ensure credits (error %d)", error);
		goto cleanup;
	}
2808

T
Tahsin Erdogan 已提交
2809 2810
	if (ext4_has_feature_ea_inode(inode->i_sb) &&
	    ext4_test_inode_state(inode, EXT4_STATE_XATTR)) {
A
Andreas Dilger 已提交
2811

T
Tahsin Erdogan 已提交
2812 2813 2814 2815 2816
		error = ext4_get_inode_loc(inode, &iloc);
		if (error) {
			EXT4_ERROR_INODE(inode, "inode loc (error %d)", error);
			goto cleanup;
		}
2817

T
Tahsin Erdogan 已提交
2818 2819 2820 2821 2822 2823
		error = ext4_journal_get_write_access(handle, iloc.bh);
		if (error) {
			EXT4_ERROR_INODE(inode, "write access (error %d)",
					 error);
			goto cleanup;
		}
A
Andreas Dilger 已提交
2824

T
Tahsin Erdogan 已提交
2825 2826 2827 2828 2829 2830 2831 2832
		header = IHDR(inode, ext4_raw_inode(&iloc));
		if (header->h_magic == cpu_to_le32(EXT4_XATTR_MAGIC))
			ext4_xattr_inode_dec_ref_all(handle, inode, iloc.bh,
						     IFIRST(header),
						     false /* block_csum */,
						     ea_inode_array,
						     extra_credits,
						     false /* skip_quota */);
2833
	}
A
Andreas Dilger 已提交
2834

T
Tahsin Erdogan 已提交
2835 2836 2837 2838
	if (EXT4_I(inode)->i_file_acl) {
		bh = sb_bread(inode->i_sb, EXT4_I(inode)->i_file_acl);
		if (!bh) {
			EXT4_ERROR_INODE(inode, "block %llu read error",
2839
					 EXT4_I(inode)->i_file_acl);
T
Tahsin Erdogan 已提交
2840 2841 2842 2843 2844 2845 2846
			error = -EIO;
			goto cleanup;
		}
		error = ext4_xattr_check_block(inode, bh);
		if (error) {
			EXT4_ERROR_INODE(inode, "bad block %llu (error %d)",
					 EXT4_I(inode)->i_file_acl, error);
A
Andreas Dilger 已提交
2847 2848 2849
			goto cleanup;
		}

T
Tahsin Erdogan 已提交
2850 2851 2852 2853 2854 2855 2856 2857 2858 2859 2860 2861 2862 2863 2864 2865 2866 2867 2868 2869 2870 2871
		if (ext4_has_feature_ea_inode(inode->i_sb)) {
			for (entry = BFIRST(bh); !IS_LAST_ENTRY(entry);
			     entry = EXT4_XATTR_NEXT(entry))
				if (entry->e_value_inum)
					ext4_xattr_inode_free_quota(inode,
					      le32_to_cpu(entry->e_value_size));

		}

		ext4_xattr_release_block(handle, inode, bh, ea_inode_array,
					 extra_credits);
		/*
		 * Update i_file_acl value in the same transaction that releases
		 * block.
		 */
		EXT4_I(inode)->i_file_acl = 0;
		error = ext4_mark_inode_dirty(handle, inode);
		if (error) {
			EXT4_ERROR_INODE(inode, "mark inode dirty (error %d)",
					 error);
			goto cleanup;
		}
2872
	}
T
Tahsin Erdogan 已提交
2873
	error = 0;
2874
cleanup:
2875
	brelse(iloc.bh);
2876
	brelse(bh);
A
Andreas Dilger 已提交
2877 2878 2879
	return error;
}

2880
void ext4_xattr_inode_array_free(struct ext4_xattr_inode_array *ea_inode_array)
A
Andreas Dilger 已提交
2881
{
T
Tahsin Erdogan 已提交
2882
	int idx;
A
Andreas Dilger 已提交
2883

2884
	if (ea_inode_array == NULL)
A
Andreas Dilger 已提交
2885 2886
		return;

T
Tahsin Erdogan 已提交
2887 2888
	for (idx = 0; idx < ea_inode_array->count; ++idx)
		iput(ea_inode_array->inodes[idx]);
2889
	kfree(ea_inode_array);
2890 2891 2892
}

/*
2893
 * ext4_xattr_block_cache_insert()
2894
 *
2895
 * Create a new entry in the extended attribute block cache, and insert
2896 2897 2898 2899 2900
 * it unless such an entry is already in the cache.
 *
 * Returns 0, or a negative error number on failure.
 */
static void
2901 2902
ext4_xattr_block_cache_insert(struct mb_cache *ea_block_cache,
			      struct buffer_head *bh)
2903
{
2904 2905 2906 2907
	struct ext4_xattr_header *header = BHDR(bh);
	__u32 hash = le32_to_cpu(header->h_hash);
	int reusable = le32_to_cpu(header->h_refcount) <
		       EXT4_XATTR_REFCOUNT_MAX;
2908 2909
	int error;

2910 2911
	if (!ea_block_cache)
		return;
2912
	error = mb_cache_entry_create(ea_block_cache, GFP_NOFS, hash,
2913
				      bh->b_blocknr, reusable);
2914
	if (error) {
J
Jan Kara 已提交
2915
		if (error == -EBUSY)
2916
			ea_bdebug(bh, "already in cache");
J
Jan Kara 已提交
2917
	} else
2918 2919 2920 2921
		ea_bdebug(bh, "inserting [%x]", (int)hash);
}

/*
2922
 * ext4_xattr_cmp()
2923 2924 2925 2926 2927 2928 2929
 *
 * Compare two extended attribute blocks for equality.
 *
 * Returns 0 if the blocks are equal, 1 if they differ, and
 * a negative error number on errors.
 */
static int
2930 2931
ext4_xattr_cmp(struct ext4_xattr_header *header1,
	       struct ext4_xattr_header *header2)
2932
{
2933
	struct ext4_xattr_entry *entry1, *entry2;
2934 2935 2936 2937 2938 2939 2940 2941 2942 2943

	entry1 = ENTRY(header1+1);
	entry2 = ENTRY(header2+1);
	while (!IS_LAST_ENTRY(entry1)) {
		if (IS_LAST_ENTRY(entry2))
			return 1;
		if (entry1->e_hash != entry2->e_hash ||
		    entry1->e_name_index != entry2->e_name_index ||
		    entry1->e_name_len != entry2->e_name_len ||
		    entry1->e_value_size != entry2->e_value_size ||
A
Andreas Dilger 已提交
2944
		    entry1->e_value_inum != entry2->e_value_inum ||
2945 2946
		    memcmp(entry1->e_name, entry2->e_name, entry1->e_name_len))
			return 1;
T
Tahsin Erdogan 已提交
2947 2948
		if (!entry1->e_value_inum &&
		    memcmp((char *)header1 + le16_to_cpu(entry1->e_value_offs),
2949 2950 2951 2952
			   (char *)header2 + le16_to_cpu(entry2->e_value_offs),
			   le32_to_cpu(entry1->e_value_size)))
			return 1;

2953 2954
		entry1 = EXT4_XATTR_NEXT(entry1);
		entry2 = EXT4_XATTR_NEXT(entry2);
2955 2956 2957 2958 2959 2960 2961
	}
	if (!IS_LAST_ENTRY(entry2))
		return 1;
	return 0;
}

/*
2962
 * ext4_xattr_block_cache_find()
2963 2964 2965 2966 2967 2968 2969
 *
 * Find an identical extended attribute block.
 *
 * Returns a pointer to the block found, or NULL if such a block was
 * not found or an error occurred.
 */
static struct buffer_head *
2970 2971 2972
ext4_xattr_block_cache_find(struct inode *inode,
			    struct ext4_xattr_header *header,
			    struct mb_cache_entry **pce)
2973 2974
{
	__u32 hash = le32_to_cpu(header->h_hash);
J
Jan Kara 已提交
2975
	struct mb_cache_entry *ce;
2976
	struct mb_cache *ea_block_cache = EA_BLOCK_CACHE(inode);
2977

2978 2979
	if (!ea_block_cache)
		return NULL;
2980 2981 2982
	if (!header->h_hash)
		return NULL;  /* never share */
	ea_idebug(inode, "looking for cached blocks [%x]", (int)hash);
2983
	ce = mb_cache_entry_find_first(ea_block_cache, hash);
2984 2985 2986
	while (ce) {
		struct buffer_head *bh;

2987
		bh = sb_bread(inode->i_sb, ce->e_value);
2988
		if (!bh) {
2989
			EXT4_ERROR_INODE(inode, "block %lu read error",
2990
					 (unsigned long)ce->e_value);
2991
		} else if (ext4_xattr_cmp(header, BHDR(bh)) == 0) {
2992 2993 2994 2995
			*pce = ce;
			return bh;
		}
		brelse(bh);
2996
		ce = mb_cache_entry_find_next(ea_block_cache, ce);
2997 2998 2999 3000 3001 3002 3003 3004
	}
	return NULL;
}

#define NAME_HASH_SHIFT 5
#define VALUE_HASH_SHIFT 16

/*
3005
 * ext4_xattr_hash_entry()
3006 3007 3008
 *
 * Compute the hash of an extended attribute.
 */
3009 3010
static __le32 ext4_xattr_hash_entry(char *name, size_t name_len, __le32 *value,
				    size_t value_count)
3011 3012 3013
{
	__u32 hash = 0;

3014
	while (name_len--) {
3015 3016 3017 3018
		hash = (hash << NAME_HASH_SHIFT) ^
		       (hash >> (8*sizeof(hash) - NAME_HASH_SHIFT)) ^
		       *name++;
	}
3019 3020 3021 3022
	while (value_count--) {
		hash = (hash << VALUE_HASH_SHIFT) ^
		       (hash >> (8*sizeof(hash) - VALUE_HASH_SHIFT)) ^
		       le32_to_cpu(*value++);
3023
	}
3024
	return cpu_to_le32(hash);
3025 3026 3027 3028 3029 3030 3031 3032
}

#undef NAME_HASH_SHIFT
#undef VALUE_HASH_SHIFT

#define BLOCK_HASH_SHIFT 16

/*
3033
 * ext4_xattr_rehash()
3034 3035 3036
 *
 * Re-compute the extended attribute hash value after an entry has changed.
 */
3037
static void ext4_xattr_rehash(struct ext4_xattr_header *header)
3038
{
3039
	struct ext4_xattr_entry *here;
3040 3041 3042 3043 3044 3045 3046 3047 3048 3049 3050 3051
	__u32 hash = 0;

	here = ENTRY(header+1);
	while (!IS_LAST_ENTRY(here)) {
		if (!here->e_hash) {
			/* Block is not shared if an entry's hash value == 0 */
			hash = 0;
			break;
		}
		hash = (hash << BLOCK_HASH_SHIFT) ^
		       (hash >> (8*sizeof(hash) - BLOCK_HASH_SHIFT)) ^
		       le32_to_cpu(here->e_hash);
3052
		here = EXT4_XATTR_NEXT(here);
3053 3054 3055 3056 3057 3058
	}
	header->h_hash = cpu_to_le32(hash);
}

#undef BLOCK_HASH_SHIFT

3059 3060
#define	HASH_BUCKET_BITS	10

J
Jan Kara 已提交
3061
struct mb_cache *
J
Jan Kara 已提交
3062
ext4_xattr_create_cache(void)
3063
{
J
Jan Kara 已提交
3064
	return mb_cache_create(HASH_BUCKET_BITS);
3065 3066
}

J
Jan Kara 已提交
3067
void ext4_xattr_destroy_cache(struct mb_cache *cache)
3068
{
3069
	if (cache)
J
Jan Kara 已提交
3070
		mb_cache_destroy(cache);
3071
}
3072