file-item.c 21.9 KB
Newer Older
C
Chris Mason 已提交
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18
/*
 * Copyright (C) 2007 Oracle.  All rights reserved.
 *
 * This program is free software; you can redistribute it and/or
 * modify it under the terms of the GNU General Public
 * License v2 as published by the Free Software Foundation.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
 * General Public License for more details.
 *
 * You should have received a copy of the GNU General Public
 * License along with this program; if not, write to the
 * Free Software Foundation, Inc., 59 Temple Place - Suite 330,
 * Boston, MA 021110-1307, USA.
 */

19
#include <linux/bio.h>
20
#include <linux/slab.h>
21 22
#include <linux/pagemap.h>
#include <linux/highmem.h>
C
Chris Mason 已提交
23
#include "ctree.h"
C
Chris Mason 已提交
24
#include "disk-io.h"
25
#include "transaction.h"
C
Chris Mason 已提交
26
#include "print-tree.h"
C
Chris Mason 已提交
27

C
Chris Mason 已提交
28
#define MAX_CSUM_ITEMS(r, size) ((((BTRFS_LEAF_DATA_SIZE(r) - \
29 30
				   sizeof(struct btrfs_item) * 2) / \
				  size) - 1))
Y
Yan Zheng 已提交
31 32 33 34 35 36

#define MAX_ORDERED_SUM_BYTES(r) ((PAGE_SIZE - \
				   sizeof(struct btrfs_ordered_sum)) / \
				   sizeof(struct btrfs_sector_sum) * \
				   (r)->sectorsize - (r)->sectorsize)

C
Chris Mason 已提交
37
int btrfs_insert_file_extent(struct btrfs_trans_handle *trans,
S
Sage Weil 已提交
38 39 40
			     struct btrfs_root *root,
			     u64 objectid, u64 pos,
			     u64 disk_offset, u64 disk_num_bytes,
C
Chris Mason 已提交
41 42
			     u64 num_bytes, u64 offset, u64 ram_bytes,
			     u8 compression, u8 encryption, u16 other_encoding)
43
{
C
Chris Mason 已提交
44 45 46
	int ret = 0;
	struct btrfs_file_extent_item *item;
	struct btrfs_key file_key;
47
	struct btrfs_path *path;
48
	struct extent_buffer *leaf;
C
Chris Mason 已提交
49

50 51
	path = btrfs_alloc_path();
	BUG_ON(!path);
C
Chris Mason 已提交
52
	file_key.objectid = objectid;
C
Chris Mason 已提交
53
	file_key.offset = pos;
C
Chris Mason 已提交
54 55
	btrfs_set_key_type(&file_key, BTRFS_EXTENT_DATA_KEY);

56
	path->leave_spinning = 1;
57
	ret = btrfs_insert_empty_item(trans, root, path, &file_key,
C
Chris Mason 已提交
58
				      sizeof(*item));
59 60
	if (ret < 0)
		goto out;
C
Chris Mason 已提交
61
	BUG_ON(ret);
62 63
	leaf = path->nodes[0];
	item = btrfs_item_ptr(leaf, path->slots[0],
C
Chris Mason 已提交
64
			      struct btrfs_file_extent_item);
S
Sage Weil 已提交
65
	btrfs_set_file_extent_disk_bytenr(leaf, item, disk_offset);
66
	btrfs_set_file_extent_disk_num_bytes(leaf, item, disk_num_bytes);
S
Sage Weil 已提交
67
	btrfs_set_file_extent_offset(leaf, item, offset);
68
	btrfs_set_file_extent_num_bytes(leaf, item, num_bytes);
C
Chris Mason 已提交
69
	btrfs_set_file_extent_ram_bytes(leaf, item, ram_bytes);
70 71
	btrfs_set_file_extent_generation(leaf, item, trans->transid);
	btrfs_set_file_extent_type(leaf, item, BTRFS_FILE_EXTENT_REG);
C
Chris Mason 已提交
72 73 74 75
	btrfs_set_file_extent_compression(leaf, item, compression);
	btrfs_set_file_extent_encryption(leaf, item, encryption);
	btrfs_set_file_extent_other_encoding(leaf, item, other_encoding);

76
	btrfs_mark_buffer_dirty(leaf);
77
out:
78
	btrfs_free_path(path);
79
	return ret;
80
}
C
Chris Mason 已提交
81

C
Chris Mason 已提交
82 83 84
struct btrfs_csum_item *btrfs_lookup_csum(struct btrfs_trans_handle *trans,
					  struct btrfs_root *root,
					  struct btrfs_path *path,
85
					  u64 bytenr, int cow)
86 87 88 89 90
{
	int ret;
	struct btrfs_key file_key;
	struct btrfs_key found_key;
	struct btrfs_csum_item *item;
91
	struct extent_buffer *leaf;
92
	u64 csum_offset = 0;
93 94
	u16 csum_size =
		btrfs_super_csum_size(&root->fs_info->super_copy);
95
	int csums_in_item;
96

97 98 99
	file_key.objectid = BTRFS_EXTENT_CSUM_OBJECTID;
	file_key.offset = bytenr;
	btrfs_set_key_type(&file_key, BTRFS_EXTENT_CSUM_KEY);
C
Chris Mason 已提交
100
	ret = btrfs_search_slot(trans, root, &file_key, path, 0, cow);
101 102
	if (ret < 0)
		goto fail;
103
	leaf = path->nodes[0];
104 105
	if (ret > 0) {
		ret = 1;
106
		if (path->slots[0] == 0)
107 108
			goto fail;
		path->slots[0]--;
109
		btrfs_item_key_to_cpu(leaf, &found_key, path->slots[0]);
110
		if (btrfs_key_type(&found_key) != BTRFS_EXTENT_CSUM_KEY)
111
			goto fail;
112 113

		csum_offset = (bytenr - found_key.offset) >>
114
				root->fs_info->sb->s_blocksize_bits;
115
		csums_in_item = btrfs_item_size_nr(leaf, path->slots[0]);
116
		csums_in_item /= csum_size;
117 118 119

		if (csum_offset >= csums_in_item) {
			ret = -EFBIG;
120 121 122 123
			goto fail;
		}
	}
	item = btrfs_item_ptr(leaf, path->slots[0], struct btrfs_csum_item);
124
	item = (struct btrfs_csum_item *)((unsigned char *)item +
125
					  csum_offset * csum_size);
126 127 128
	return item;
fail:
	if (ret > 0)
C
Chris Mason 已提交
129
		ret = -ENOENT;
130 131 132 133
	return ERR_PTR(ret);
}


C
Chris Mason 已提交
134 135 136
int btrfs_lookup_file_extent(struct btrfs_trans_handle *trans,
			     struct btrfs_root *root,
			     struct btrfs_path *path, u64 objectid,
C
Chris Mason 已提交
137
			     u64 offset, int mod)
C
Chris Mason 已提交
138 139 140 141 142 143 144
{
	int ret;
	struct btrfs_key file_key;
	int ins_len = mod < 0 ? -1 : 0;
	int cow = mod != 0;

	file_key.objectid = objectid;
145
	file_key.offset = offset;
C
Chris Mason 已提交
146 147 148 149
	btrfs_set_key_type(&file_key, BTRFS_EXTENT_DATA_KEY);
	ret = btrfs_search_slot(trans, root, &file_key, path, ins_len, cow);
	return ret;
}
C
Chris Mason 已提交
150

151

152
int btrfs_lookup_bio_sums(struct btrfs_root *root, struct inode *inode,
153
			  struct bio *bio, u32 *dst)
154 155 156 157 158 159 160
{
	u32 sum;
	struct bio_vec *bvec = bio->bi_io_vec;
	int bio_index = 0;
	u64 offset;
	u64 item_start_offset = 0;
	u64 item_last_offset = 0;
161
	u64 disk_bytenr;
162
	u32 diff;
163 164
	u16 csum_size =
		btrfs_super_csum_size(&root->fs_info->super_copy);
165 166 167 168 169 170
	int ret;
	struct btrfs_path *path;
	struct btrfs_csum_item *item = NULL;
	struct extent_io_tree *io_tree = &BTRFS_I(inode)->io_tree;

	path = btrfs_alloc_path();
171 172
	if (bio->bi_size > PAGE_CACHE_SIZE * 8)
		path->reada = 2;
173 174 175

	WARN_ON(bio->bi_vcnt <= 0);

176
	disk_bytenr = (u64)bio->bi_sector << 9;
C
Chris Mason 已提交
177
	while (bio_index < bio->bi_vcnt) {
178
		offset = page_offset(bvec->bv_page) + bvec->bv_offset;
179
		ret = btrfs_find_ordered_sum(inode, offset, disk_bytenr, &sum);
180 181 182
		if (ret == 0)
			goto found;

183 184
		if (!item || disk_bytenr < item_start_offset ||
		    disk_bytenr >= item_last_offset) {
185 186 187 188 189
			struct btrfs_key found_key;
			u32 item_size;

			if (item)
				btrfs_release_path(root, path);
190 191
			item = btrfs_lookup_csum(NULL, root->fs_info->csum_root,
						 path, disk_bytenr, 0);
192 193 194 195 196
			if (IS_ERR(item)) {
				ret = PTR_ERR(item);
				if (ret == -ENOENT || ret == -EFBIG)
					ret = 0;
				sum = 0;
197 198 199 200 201 202
				if (BTRFS_I(inode)->root->root_key.objectid ==
				    BTRFS_DATA_RELOC_TREE_OBJECTID) {
					set_extent_bits(io_tree, offset,
						offset + bvec->bv_len - 1,
						EXTENT_NODATASUM, GFP_NOFS);
				} else {
C
Chris Mason 已提交
203 204 205
					printk(KERN_INFO "btrfs no csum found "
					       "for inode %lu start %llu\n",
					       inode->i_ino,
206 207
					       (unsigned long long)offset);
				}
208
				item = NULL;
209
				btrfs_release_path(root, path);
210 211 212 213 214 215 216 217 218
				goto found;
			}
			btrfs_item_key_to_cpu(path->nodes[0], &found_key,
					      path->slots[0]);

			item_start_offset = found_key.offset;
			item_size = btrfs_item_size_nr(path->nodes[0],
						       path->slots[0]);
			item_last_offset = item_start_offset +
219
				(item_size / csum_size) *
220 221 222 223 224 225 226 227
				root->sectorsize;
			item = btrfs_item_ptr(path->nodes[0], path->slots[0],
					      struct btrfs_csum_item);
		}
		/*
		 * this byte range must be able to fit inside
		 * a single leaf so it will also fit inside a u32
		 */
228
		diff = disk_bytenr - item_start_offset;
229
		diff = diff / root->sectorsize;
230
		diff = diff * csum_size;
231 232

		read_extent_buffer(path->nodes[0], &sum,
233
				   ((unsigned long)item) + diff,
234
				   csum_size);
235
found:
236 237 238 239 240
		if (dst)
			*dst++ = sum;
		else
			set_state_private(io_tree, offset, sum);
		disk_bytenr += bvec->bv_len;
241 242 243 244 245 246 247
		bio_index++;
		bvec++;
	}
	btrfs_free_path(path);
	return 0;
}

248 249 250 251 252 253 254 255 256 257 258 259 260 261 262 263 264 265 266 267 268 269
int btrfs_lookup_csums_range(struct btrfs_root *root, u64 start, u64 end,
			     struct list_head *list)
{
	struct btrfs_key key;
	struct btrfs_path *path;
	struct extent_buffer *leaf;
	struct btrfs_ordered_sum *sums;
	struct btrfs_sector_sum *sector_sum;
	struct btrfs_csum_item *item;
	unsigned long offset;
	int ret;
	size_t size;
	u64 csum_end;
	u16 csum_size = btrfs_super_csum_size(&root->fs_info->super_copy);

	path = btrfs_alloc_path();
	BUG_ON(!path);

	key.objectid = BTRFS_EXTENT_CSUM_OBJECTID;
	key.offset = start;
	key.type = BTRFS_EXTENT_CSUM_KEY;

Y
Yan Zheng 已提交
270
	ret = btrfs_search_slot(NULL, root, &key, path, 0, 0);
271 272 273 274 275 276 277 278 279 280 281 282 283 284 285 286 287 288
	if (ret < 0)
		goto fail;
	if (ret > 0 && path->slots[0] > 0) {
		leaf = path->nodes[0];
		btrfs_item_key_to_cpu(leaf, &key, path->slots[0] - 1);
		if (key.objectid == BTRFS_EXTENT_CSUM_OBJECTID &&
		    key.type == BTRFS_EXTENT_CSUM_KEY) {
			offset = (start - key.offset) >>
				 root->fs_info->sb->s_blocksize_bits;
			if (offset * csum_size <
			    btrfs_item_size_nr(leaf, path->slots[0] - 1))
				path->slots[0]--;
		}
	}

	while (start <= end) {
		leaf = path->nodes[0];
		if (path->slots[0] >= btrfs_header_nritems(leaf)) {
Y
Yan Zheng 已提交
289
			ret = btrfs_next_leaf(root, path);
290 291 292 293 294 295 296 297 298 299 300 301 302 303 304 305 306 307 308 309 310
			if (ret < 0)
				goto fail;
			if (ret > 0)
				break;
			leaf = path->nodes[0];
		}

		btrfs_item_key_to_cpu(leaf, &key, path->slots[0]);
		if (key.objectid != BTRFS_EXTENT_CSUM_OBJECTID ||
		    key.type != BTRFS_EXTENT_CSUM_KEY)
			break;

		btrfs_item_key_to_cpu(leaf, &key, path->slots[0]);
		if (key.offset > end)
			break;

		if (key.offset > start)
			start = key.offset;

		size = btrfs_item_size_nr(leaf, path->slots[0]);
		csum_end = key.offset + (size / csum_size) * root->sectorsize;
311 312 313 314
		if (csum_end <= start) {
			path->slots[0]++;
			continue;
		}
315

Y
Yan Zheng 已提交
316
		csum_end = min(csum_end, end + 1);
317 318
		item = btrfs_item_ptr(path->nodes[0], path->slots[0],
				      struct btrfs_csum_item);
Y
Yan Zheng 已提交
319 320 321 322 323 324
		while (start < csum_end) {
			size = min_t(size_t, csum_end - start,
					MAX_ORDERED_SUM_BYTES(root));
			sums = kzalloc(btrfs_ordered_sum_size(root, size),
					GFP_NOFS);
			BUG_ON(!sums);
325

Y
Yan Zheng 已提交
326 327 328 329 330 331 332 333 334 335 336 337 338 339 340 341 342 343 344 345 346 347
			sector_sum = sums->sums;
			sums->bytenr = start;
			sums->len = size;

			offset = (start - key.offset) >>
				root->fs_info->sb->s_blocksize_bits;
			offset *= csum_size;

			while (size > 0) {
				read_extent_buffer(path->nodes[0],
						&sector_sum->sum,
						((unsigned long)item) +
						offset, csum_size);
				sector_sum->bytenr = start;

				size -= root->sectorsize;
				start += root->sectorsize;
				offset += csum_size;
				sector_sum++;
			}
			list_add_tail(&sums->list, list);
		}
348 349 350 351 352 353 354 355
		path->slots[0]++;
	}
	ret = 0;
fail:
	btrfs_free_path(path);
	return ret;
}

356
int btrfs_csum_one_bio(struct btrfs_root *root, struct inode *inode,
357
		       struct bio *bio, u64 file_start, int contig)
358
{
359 360
	struct btrfs_ordered_sum *sums;
	struct btrfs_sector_sum *sector_sum;
361
	struct btrfs_ordered_extent *ordered;
362 363 364
	char *data;
	struct bio_vec *bvec = bio->bi_io_vec;
	int bio_index = 0;
365 366 367
	unsigned long total_bytes = 0;
	unsigned long this_sum_bytes = 0;
	u64 offset;
368
	u64 disk_bytenr;
369

370 371
	WARN_ON(bio->bi_vcnt <= 0);
	sums = kzalloc(btrfs_ordered_sum_size(root, bio->bi_size), GFP_NOFS);
372 373
	if (!sums)
		return -ENOMEM;
374

375
	sector_sum = sums->sums;
376
	disk_bytenr = (u64)bio->bi_sector << 9;
377 378
	sums->len = bio->bi_size;
	INIT_LIST_HEAD(&sums->list);
379 380 381 382 383 384 385

	if (contig)
		offset = file_start;
	else
		offset = page_offset(bvec->bv_page) + bvec->bv_offset;

	ordered = btrfs_lookup_ordered_extent(inode, offset);
386
	BUG_ON(!ordered);
387
	sums->bytenr = ordered->start;
388

C
Chris Mason 已提交
389
	while (bio_index < bio->bi_vcnt) {
390 391 392 393 394
		if (!contig)
			offset = page_offset(bvec->bv_page) + bvec->bv_offset;

		if (!contig && (offset >= ordered->file_offset + ordered->len ||
		    offset < ordered->file_offset)) {
395 396 397 398 399 400 401 402 403 404 405
			unsigned long bytes_left;
			sums->len = this_sum_bytes;
			this_sum_bytes = 0;
			btrfs_add_ordered_sum(inode, ordered, sums);
			btrfs_put_ordered_extent(ordered);

			bytes_left = bio->bi_size - total_bytes;

			sums = kzalloc(btrfs_ordered_sum_size(root, bytes_left),
				       GFP_NOFS);
			BUG_ON(!sums);
406
			sector_sum = sums->sums;
407
			sums->len = bytes_left;
408
			ordered = btrfs_lookup_ordered_extent(inode, offset);
409
			BUG_ON(!ordered);
410
			sums->bytenr = ordered->start;
411 412
		}

413
		data = kmap_atomic(bvec->bv_page, KM_USER0);
414 415 416 417 418
		sector_sum->sum = ~(u32)0;
		sector_sum->sum = btrfs_csum_data(root,
						  data + bvec->bv_offset,
						  sector_sum->sum,
						  bvec->bv_len);
419
		kunmap_atomic(data, KM_USER0);
420 421
		btrfs_csum_final(sector_sum->sum,
				 (char *)&sector_sum->sum);
422
		sector_sum->bytenr = disk_bytenr;
423

424
		sector_sum++;
425
		bio_index++;
426 427
		total_bytes += bvec->bv_len;
		this_sum_bytes += bvec->bv_len;
428 429
		disk_bytenr += bvec->bv_len;
		offset += bvec->bv_len;
430 431
		bvec++;
	}
432
	this_sum_bytes = 0;
433 434
	btrfs_add_ordered_sum(inode, ordered, sums);
	btrfs_put_ordered_extent(ordered);
435 436 437
	return 0;
}

438 439 440 441 442 443 444 445 446 447 448 449 450 451 452 453 454 455 456 457 458 459 460 461 462 463 464 465 466 467 468 469 470 471 472 473 474 475 476 477 478 479 480 481 482 483 484 485 486 487 488 489 490 491 492 493 494 495 496 497 498 499 500 501 502 503 504 505 506 507 508 509 510 511 512 513 514 515 516 517 518 519 520 521 522
/*
 * helper function for csum removal, this expects the
 * key to describe the csum pointed to by the path, and it expects
 * the csum to overlap the range [bytenr, len]
 *
 * The csum should not be entirely contained in the range and the
 * range should not be entirely contained in the csum.
 *
 * This calls btrfs_truncate_item with the correct args based on the
 * overlap, and fixes up the key as required.
 */
static noinline int truncate_one_csum(struct btrfs_trans_handle *trans,
				      struct btrfs_root *root,
				      struct btrfs_path *path,
				      struct btrfs_key *key,
				      u64 bytenr, u64 len)
{
	struct extent_buffer *leaf;
	u16 csum_size =
		btrfs_super_csum_size(&root->fs_info->super_copy);
	u64 csum_end;
	u64 end_byte = bytenr + len;
	u32 blocksize_bits = root->fs_info->sb->s_blocksize_bits;
	int ret;

	leaf = path->nodes[0];
	csum_end = btrfs_item_size_nr(leaf, path->slots[0]) / csum_size;
	csum_end <<= root->fs_info->sb->s_blocksize_bits;
	csum_end += key->offset;

	if (key->offset < bytenr && csum_end <= end_byte) {
		/*
		 *         [ bytenr - len ]
		 *         [   ]
		 *   [csum     ]
		 *   A simple truncate off the end of the item
		 */
		u32 new_size = (bytenr - key->offset) >> blocksize_bits;
		new_size *= csum_size;
		ret = btrfs_truncate_item(trans, root, path, new_size, 1);
		BUG_ON(ret);
	} else if (key->offset >= bytenr && csum_end > end_byte &&
		   end_byte > key->offset) {
		/*
		 *         [ bytenr - len ]
		 *                 [ ]
		 *                 [csum     ]
		 * we need to truncate from the beginning of the csum
		 */
		u32 new_size = (csum_end - end_byte) >> blocksize_bits;
		new_size *= csum_size;

		ret = btrfs_truncate_item(trans, root, path, new_size, 0);
		BUG_ON(ret);

		key->offset = end_byte;
		ret = btrfs_set_item_key_safe(trans, root, path, key);
		BUG_ON(ret);
	} else {
		BUG();
	}
	return 0;
}

/*
 * deletes the csum items from the csum tree for a given
 * range of bytes.
 */
int btrfs_del_csums(struct btrfs_trans_handle *trans,
		    struct btrfs_root *root, u64 bytenr, u64 len)
{
	struct btrfs_path *path;
	struct btrfs_key key;
	u64 end_byte = bytenr + len;
	u64 csum_end;
	struct extent_buffer *leaf;
	int ret;
	u16 csum_size =
		btrfs_super_csum_size(&root->fs_info->super_copy);
	int blocksize_bits = root->fs_info->sb->s_blocksize_bits;

	root = root->fs_info->csum_root;

	path = btrfs_alloc_path();

C
Chris Mason 已提交
523
	while (1) {
524 525 526 527
		key.objectid = BTRFS_EXTENT_CSUM_OBJECTID;
		key.offset = end_byte - 1;
		key.type = BTRFS_EXTENT_CSUM_KEY;

528
		path->leave_spinning = 1;
529 530 531 532 533 534 535 536 537 538 539 540 541 542 543 544 545 546 547 548 549 550 551 552 553 554 555 556 557
		ret = btrfs_search_slot(trans, root, &key, path, -1, 1);
		if (ret > 0) {
			if (path->slots[0] == 0)
				goto out;
			path->slots[0]--;
		}
		leaf = path->nodes[0];
		btrfs_item_key_to_cpu(leaf, &key, path->slots[0]);

		if (key.objectid != BTRFS_EXTENT_CSUM_OBJECTID ||
		    key.type != BTRFS_EXTENT_CSUM_KEY) {
			break;
		}

		if (key.offset >= end_byte)
			break;

		csum_end = btrfs_item_size_nr(leaf, path->slots[0]) / csum_size;
		csum_end <<= blocksize_bits;
		csum_end += key.offset;

		/* this csum ends before we start, we're done */
		if (csum_end <= bytenr)
			break;

		/* delete the entire item, it is inside our range */
		if (key.offset >= bytenr && csum_end <= end_byte) {
			ret = btrfs_del_item(trans, root, path);
			BUG_ON(ret);
558 559
			if (key.offset == bytenr)
				break;
560 561 562 563 564 565 566 567 568 569 570 571 572 573 574 575 576 577 578 579 580 581 582 583 584 585 586 587 588 589 590 591 592 593 594 595 596 597 598 599 600 601 602 603 604 605
		} else if (key.offset < bytenr && csum_end > end_byte) {
			unsigned long offset;
			unsigned long shift_len;
			unsigned long item_offset;
			/*
			 *        [ bytenr - len ]
			 *     [csum                ]
			 *
			 * Our bytes are in the middle of the csum,
			 * we need to split this item and insert a new one.
			 *
			 * But we can't drop the path because the
			 * csum could change, get removed, extended etc.
			 *
			 * The trick here is the max size of a csum item leaves
			 * enough room in the tree block for a single
			 * item header.  So, we split the item in place,
			 * adding a new header pointing to the existing
			 * bytes.  Then we loop around again and we have
			 * a nicely formed csum item that we can neatly
			 * truncate.
			 */
			offset = (bytenr - key.offset) >> blocksize_bits;
			offset *= csum_size;

			shift_len = (len >> blocksize_bits) * csum_size;

			item_offset = btrfs_item_ptr_offset(leaf,
							    path->slots[0]);

			memset_extent_buffer(leaf, 0, item_offset + offset,
					     shift_len);
			key.offset = bytenr;

			/*
			 * btrfs_split_item returns -EAGAIN when the
			 * item changed size or key
			 */
			ret = btrfs_split_item(trans, root, path, &key, offset);
			BUG_ON(ret && ret != -EAGAIN);

			key.offset = end_byte - 1;
		} else {
			ret = truncate_one_csum(trans, root, path,
						&key, bytenr, len);
			BUG_ON(ret);
606 607
			if (key.offset < bytenr)
				break;
608 609 610 611 612 613 614 615
		}
		btrfs_release_path(root, path);
	}
out:
	btrfs_free_path(path);
	return 0;
}

616
int btrfs_csum_file_blocks(struct btrfs_trans_handle *trans,
617
			   struct btrfs_root *root,
618
			   struct btrfs_ordered_sum *sums)
C
Chris Mason 已提交
619
{
620
	u64 bytenr;
C
Chris Mason 已提交
621 622
	int ret;
	struct btrfs_key file_key;
623
	struct btrfs_key found_key;
624
	u64 next_offset;
625
	u64 total_bytes = 0;
626
	int found_next;
627
	struct btrfs_path *path;
C
Chris Mason 已提交
628
	struct btrfs_csum_item *item;
629
	struct btrfs_csum_item *item_end;
630
	struct extent_buffer *leaf = NULL;
631
	u64 csum_offset;
632
	struct btrfs_sector_sum *sector_sum;
633 634
	u32 nritems;
	u32 ins_size;
635 636 637 638
	char *eb_map;
	char *eb_token;
	unsigned long map_len;
	unsigned long map_start;
639 640
	u16 csum_size =
		btrfs_super_csum_size(&root->fs_info->super_copy);
641

642 643
	path = btrfs_alloc_path();
	BUG_ON(!path);
644
	sector_sum = sums->sums;
645 646 647
again:
	next_offset = (u64)-1;
	found_next = 0;
648 649 650 651
	file_key.objectid = BTRFS_EXTENT_CSUM_OBJECTID;
	file_key.offset = sector_sum->bytenr;
	bytenr = sector_sum->bytenr;
	btrfs_set_key_type(&file_key, BTRFS_EXTENT_CSUM_KEY);
652

653
	item = btrfs_lookup_csum(trans, root, path, sector_sum->bytenr, 1);
654 655
	if (!IS_ERR(item)) {
		leaf = path->nodes[0];
656
		ret = 0;
657
		goto found;
658
	}
659 660 661 662
	ret = PTR_ERR(item);
	if (ret == -EFBIG) {
		u32 item_size;
		/* we found one, but it isn't big enough yet */
663 664
		leaf = path->nodes[0];
		item_size = btrfs_item_size_nr(leaf, path->slots[0]);
665 666
		if ((item_size / csum_size) >=
		    MAX_CSUM_ITEMS(root, csum_size)) {
667 668 669 670
			/* already at max size, make a new one */
			goto insert;
		}
	} else {
671
		int slot = path->slots[0] + 1;
672
		/* we didn't find a csum item, insert one */
673 674 675
		nritems = btrfs_header_nritems(path->nodes[0]);
		if (path->slots[0] >= nritems - 1) {
			ret = btrfs_next_leaf(root, path);
Y
Yan 已提交
676
			if (ret == 1)
677
				found_next = 1;
Y
Yan 已提交
678
			if (ret != 0)
679
				goto insert;
Y
Yan 已提交
680
			slot = 0;
681 682
		}
		btrfs_item_key_to_cpu(path->nodes[0], &found_key, slot);
683 684
		if (found_key.objectid != BTRFS_EXTENT_CSUM_OBJECTID ||
		    found_key.type != BTRFS_EXTENT_CSUM_KEY) {
685 686 687 688 689
			found_next = 1;
			goto insert;
		}
		next_offset = found_key.offset;
		found_next = 1;
690 691 692 693 694 695 696 697
		goto insert;
	}

	/*
	 * at this point, we know the tree has an item, but it isn't big
	 * enough yet to put our csum in.  Grow it
	 */
	btrfs_release_path(root, path);
698
	ret = btrfs_search_slot(trans, root, &file_key, path,
699
				csum_size, 1);
700
	if (ret < 0)
701
		goto fail_unlock;
702 703 704 705 706

	if (ret > 0) {
		if (path->slots[0] == 0)
			goto insert;
		path->slots[0]--;
707
	}
708

709 710
	leaf = path->nodes[0];
	btrfs_item_key_to_cpu(leaf, &found_key, path->slots[0]);
711
	csum_offset = (bytenr - found_key.offset) >>
712
			root->fs_info->sb->s_blocksize_bits;
713

714 715
	if (btrfs_key_type(&found_key) != BTRFS_EXTENT_CSUM_KEY ||
	    found_key.objectid != BTRFS_EXTENT_CSUM_OBJECTID ||
716
	    csum_offset >= MAX_CSUM_ITEMS(root, csum_size)) {
717 718
		goto insert;
	}
719

720
	if (csum_offset >= btrfs_item_size_nr(leaf, path->slots[0]) /
721 722
	    csum_size) {
		u32 diff = (csum_offset + 1) * csum_size;
723 724 725 726 727 728 729 730

		/*
		 * is the item big enough already?  we dropped our lock
		 * before and need to recheck
		 */
		if (diff < btrfs_item_size_nr(leaf, path->slots[0]))
			goto csum;

731
		diff = diff - btrfs_item_size_nr(leaf, path->slots[0]);
C
Chris Mason 已提交
732
		if (diff != csum_size)
C
Chris Mason 已提交
733
			goto insert;
734

735
		ret = btrfs_extend_item(trans, root, path, diff);
736 737 738 739 740
		BUG_ON(ret);
		goto csum;
	}

insert:
741
	btrfs_release_path(root, path);
742
	csum_offset = 0;
743
	if (found_next) {
744 745 746 747
		u64 tmp = total_bytes + root->sectorsize;
		u64 next_sector = sector_sum->bytenr;
		struct btrfs_sector_sum *next = sector_sum + 1;

C
Chris Mason 已提交
748
		while (tmp < sums->len) {
749 750 751 752 753 754 755
			if (next_sector + root->sectorsize != next->bytenr)
				break;
			tmp += root->sectorsize;
			next_sector = next->bytenr;
			next++;
		}
		tmp = min(tmp, next_offset - file_key.offset);
756 757
		tmp >>= root->fs_info->sb->s_blocksize_bits;
		tmp = max((u64)1, tmp);
758 759
		tmp = min(tmp, (u64)MAX_CSUM_ITEMS(root, csum_size));
		ins_size = csum_size * tmp;
760
	} else {
761
		ins_size = csum_size;
762
	}
763
	path->leave_spinning = 1;
764
	ret = btrfs_insert_empty_item(trans, root, path, &file_key,
765
				      ins_size);
766
	path->leave_spinning = 0;
767
	if (ret < 0)
768
		goto fail_unlock;
769 770
	if (ret != 0) {
		WARN_ON(1);
771
		goto fail_unlock;
772
	}
773
csum:
774 775
	leaf = path->nodes[0];
	item = btrfs_item_ptr(leaf, path->slots[0], struct btrfs_csum_item);
C
Chris Mason 已提交
776
	ret = 0;
777
	item = (struct btrfs_csum_item *)((unsigned char *)item +
778
					  csum_offset * csum_size);
C
Chris Mason 已提交
779
found:
780 781 782
	item_end = btrfs_item_ptr(leaf, path->slots[0], struct btrfs_csum_item);
	item_end = (struct btrfs_csum_item *)((unsigned char *)item_end +
				      btrfs_item_size_nr(leaf, path->slots[0]));
783
	eb_token = NULL;
784
next_sector:
785

786
	if (!eb_token ||
787
	   (unsigned long)item + csum_size >= map_start + map_len) {
788 789 790
		int err;

		if (eb_token)
791
			unmap_extent_buffer(leaf, eb_token, KM_USER1);
792 793
		eb_token = NULL;
		err = map_private_extent_buffer(leaf, (unsigned long)item,
794
						csum_size,
795
						&eb_token, &eb_map,
796
						&map_start, &map_len, KM_USER1);
797 798 799 800 801
		if (err)
			eb_token = NULL;
	}
	if (eb_token) {
		memcpy(eb_token + ((unsigned long)item & (PAGE_CACHE_SIZE - 1)),
802
		       &sector_sum->sum, csum_size);
803
	} else {
804
		write_extent_buffer(leaf, &sector_sum->sum,
805
				    (unsigned long)item, csum_size);
806
	}
807

808 809 810
	total_bytes += root->sectorsize;
	sector_sum++;
	if (total_bytes < sums->len) {
811
		item = (struct btrfs_csum_item *)((char *)item +
812
						  csum_size);
813 814 815
		if (item < item_end && bytenr + PAGE_CACHE_SIZE ==
		    sector_sum->bytenr) {
			bytenr = sector_sum->bytenr;
816
			goto next_sector;
817
		}
818
	}
819
	if (eb_token) {
820
		unmap_extent_buffer(leaf, eb_token, KM_USER1);
821 822
		eb_token = NULL;
	}
823
	btrfs_mark_buffer_dirty(path->nodes[0]);
824
	if (total_bytes < sums->len) {
825
		btrfs_release_path(root, path);
826
		cond_resched();
827 828
		goto again;
	}
829
out:
830
	btrfs_free_path(path);
C
Chris Mason 已提交
831
	return ret;
832 833 834

fail_unlock:
	goto out;
C
Chris Mason 已提交
835
}