ordered-data.c 21.8 KB
Newer Older
C
Chris Mason 已提交
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20
/*
 * 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.
 */

#include <linux/gfp.h>
#include <linux/slab.h>
21
#include <linux/blkdev.h>
22 23
#include <linux/writeback.h>
#include <linux/pagevec.h>
C
Chris Mason 已提交
24 25 26
#include "ctree.h"
#include "transaction.h"
#include "btrfs_inode.h"
27
#include "extent_io.h"
C
Chris Mason 已提交
28

29
static u64 entry_end(struct btrfs_ordered_extent *entry)
C
Chris Mason 已提交
30
{
31 32 33
	if (entry->file_offset + entry->len < entry->file_offset)
		return (u64)-1;
	return entry->file_offset + entry->len;
C
Chris Mason 已提交
34 35
}

C
Chris Mason 已提交
36 37 38
/* returns NULL if the insertion worked, or it returns the node it did find
 * in the tree
 */
39 40
static struct rb_node *tree_insert(struct rb_root *root, u64 file_offset,
				   struct rb_node *node)
C
Chris Mason 已提交
41
{
C
Chris Mason 已提交
42 43
	struct rb_node **p = &root->rb_node;
	struct rb_node *parent = NULL;
44
	struct btrfs_ordered_extent *entry;
C
Chris Mason 已提交
45

C
Chris Mason 已提交
46
	while (*p) {
C
Chris Mason 已提交
47
		parent = *p;
48
		entry = rb_entry(parent, struct btrfs_ordered_extent, rb_node);
C
Chris Mason 已提交
49

50
		if (file_offset < entry->file_offset)
C
Chris Mason 已提交
51
			p = &(*p)->rb_left;
52
		else if (file_offset >= entry_end(entry))
C
Chris Mason 已提交
53 54 55 56 57 58 59 60 61 62
			p = &(*p)->rb_right;
		else
			return parent;
	}

	rb_link_node(node, parent, p);
	rb_insert_color(node, root);
	return NULL;
}

C
Chris Mason 已提交
63 64 65 66
/*
 * look for a given offset in the tree, and if it can't be found return the
 * first lesser offset
 */
67 68
static struct rb_node *__tree_search(struct rb_root *root, u64 file_offset,
				     struct rb_node **prev_ret)
C
Chris Mason 已提交
69
{
C
Chris Mason 已提交
70
	struct rb_node *n = root->rb_node;
C
Chris Mason 已提交
71
	struct rb_node *prev = NULL;
72 73 74
	struct rb_node *test;
	struct btrfs_ordered_extent *entry;
	struct btrfs_ordered_extent *prev_entry = NULL;
C
Chris Mason 已提交
75

C
Chris Mason 已提交
76
	while (n) {
77
		entry = rb_entry(n, struct btrfs_ordered_extent, rb_node);
C
Chris Mason 已提交
78 79 80
		prev = n;
		prev_entry = entry;

81
		if (file_offset < entry->file_offset)
C
Chris Mason 已提交
82
			n = n->rb_left;
83
		else if (file_offset >= entry_end(entry))
C
Chris Mason 已提交
84 85 86 87 88 89 90
			n = n->rb_right;
		else
			return n;
	}
	if (!prev_ret)
		return NULL;

C
Chris Mason 已提交
91
	while (prev && file_offset >= entry_end(prev_entry)) {
92 93 94 95 96 97 98 99 100 101 102 103 104
		test = rb_next(prev);
		if (!test)
			break;
		prev_entry = rb_entry(test, struct btrfs_ordered_extent,
				      rb_node);
		if (file_offset < entry_end(prev_entry))
			break;

		prev = test;
	}
	if (prev)
		prev_entry = rb_entry(prev, struct btrfs_ordered_extent,
				      rb_node);
C
Chris Mason 已提交
105
	while (prev && file_offset < entry_end(prev_entry)) {
106 107 108 109 110 111
		test = rb_prev(prev);
		if (!test)
			break;
		prev_entry = rb_entry(test, struct btrfs_ordered_extent,
				      rb_node);
		prev = test;
C
Chris Mason 已提交
112 113 114 115 116
	}
	*prev_ret = prev;
	return NULL;
}

C
Chris Mason 已提交
117 118 119
/*
 * helper to check if a given offset is inside a given entry
 */
120 121 122 123 124 125 126 127
static int offset_in_entry(struct btrfs_ordered_extent *entry, u64 file_offset)
{
	if (file_offset < entry->file_offset ||
	    entry->file_offset + entry->len <= file_offset)
		return 0;
	return 1;
}

C
Chris Mason 已提交
128 129 130 131
/*
 * look find the first ordered struct that has this offset, otherwise
 * the first one less than this offset
 */
132 133
static inline struct rb_node *tree_search(struct btrfs_ordered_inode_tree *tree,
					  u64 file_offset)
C
Chris Mason 已提交
134
{
135
	struct rb_root *root = &tree->tree;
C
Chris Mason 已提交
136 137
	struct rb_node *prev;
	struct rb_node *ret;
138 139 140 141 142 143 144 145 146
	struct btrfs_ordered_extent *entry;

	if (tree->last) {
		entry = rb_entry(tree->last, struct btrfs_ordered_extent,
				 rb_node);
		if (offset_in_entry(entry, file_offset))
			return tree->last;
	}
	ret = __tree_search(root, file_offset, &prev);
C
Chris Mason 已提交
147
	if (!ret)
148 149 150
		ret = prev;
	if (ret)
		tree->last = ret;
C
Chris Mason 已提交
151 152 153
	return ret;
}

154 155 156 157 158 159 160 161 162 163 164
/* allocate and add a new ordered_extent into the per-inode tree.
 * file_offset is the logical offset in the file
 *
 * start is the disk block number of an extent already reserved in the
 * extent allocation tree
 *
 * len is the length of the extent
 *
 * The tree is given a single reference on the ordered extent that was
 * inserted.
 */
165
int btrfs_add_ordered_extent(struct inode *inode, u64 file_offset,
Y
Yan Zheng 已提交
166
			     u64 start, u64 len, u64 disk_len, int type)
C
Chris Mason 已提交
167 168
{
	struct btrfs_ordered_inode_tree *tree;
169 170
	struct rb_node *node;
	struct btrfs_ordered_extent *entry;
C
Chris Mason 已提交
171

172 173
	tree = &BTRFS_I(inode)->ordered_tree;
	entry = kzalloc(sizeof(*entry), GFP_NOFS);
C
Chris Mason 已提交
174 175 176
	if (!entry)
		return -ENOMEM;

177 178 179
	entry->file_offset = file_offset;
	entry->start = start;
	entry->len = len;
C
Chris Mason 已提交
180
	entry->disk_len = disk_len;
181
	entry->bytes_left = len;
182
	entry->inode = inode;
Y
Yan Zheng 已提交
183
	if (type != BTRFS_ORDERED_IO_DONE && type != BTRFS_ORDERED_COMPLETE)
Y
Yan Zheng 已提交
184
		set_bit(type, &entry->flags);
185

186 187 188 189
	/* one ref for the tree */
	atomic_set(&entry->refs, 1);
	init_waitqueue_head(&entry->wait);
	INIT_LIST_HEAD(&entry->list);
190
	INIT_LIST_HEAD(&entry->root_extent_list);
C
Chris Mason 已提交
191

192
	spin_lock(&tree->lock);
193 194
	node = tree_insert(&tree->tree, file_offset,
			   &entry->rb_node);
C
Chris Mason 已提交
195
	BUG_ON(node);
196
	spin_unlock(&tree->lock);
C
Chris Mason 已提交
197

198 199 200 201 202
	spin_lock(&BTRFS_I(inode)->root->fs_info->ordered_extent_lock);
	list_add_tail(&entry->root_extent_list,
		      &BTRFS_I(inode)->root->fs_info->ordered_extents);
	spin_unlock(&BTRFS_I(inode)->root->fs_info->ordered_extent_lock);

203
	BUG_ON(node);
C
Chris Mason 已提交
204 205 206
	return 0;
}

207 208
/*
 * Add a struct btrfs_ordered_sum into the list of checksums to be inserted
209 210
 * when an ordered extent is finished.  If the list covers more than one
 * ordered extent, it is split across multiples.
211
 */
212 213 214
int btrfs_add_ordered_sum(struct inode *inode,
			  struct btrfs_ordered_extent *entry,
			  struct btrfs_ordered_sum *sum)
C
Chris Mason 已提交
215
{
216
	struct btrfs_ordered_inode_tree *tree;
C
Chris Mason 已提交
217

218
	tree = &BTRFS_I(inode)->ordered_tree;
219
	spin_lock(&tree->lock);
220
	list_add_tail(&sum->list, &entry->list);
221
	spin_unlock(&tree->lock);
222
	return 0;
C
Chris Mason 已提交
223 224
}

225 226 227 228 229 230 231 232 233
/*
 * this is used to account for finished IO across a given range
 * of the file.  The IO should not span ordered extents.  If
 * a given ordered_extent is completely done, 1 is returned, otherwise
 * 0.
 *
 * test_and_set_bit on a flag in the struct btrfs_ordered_extent is used
 * to make sure this function only returns 1 once for a given ordered extent.
 */
234 235
int btrfs_dec_test_ordered_pending(struct inode *inode,
				   u64 file_offset, u64 io_size)
C
Chris Mason 已提交
236
{
237
	struct btrfs_ordered_inode_tree *tree;
C
Chris Mason 已提交
238
	struct rb_node *node;
239 240 241 242
	struct btrfs_ordered_extent *entry;
	int ret;

	tree = &BTRFS_I(inode)->ordered_tree;
243
	spin_lock(&tree->lock);
244
	node = tree_search(tree, file_offset);
C
Chris Mason 已提交
245
	if (!node) {
246 247
		ret = 1;
		goto out;
C
Chris Mason 已提交
248 249
	}

250 251 252 253
	entry = rb_entry(node, struct btrfs_ordered_extent, rb_node);
	if (!offset_in_entry(entry, file_offset)) {
		ret = 1;
		goto out;
C
Chris Mason 已提交
254
	}
255

256 257 258 259 260 261 262
	if (io_size > entry->bytes_left) {
		printk(KERN_CRIT "bad ordered accounting left %llu size %llu\n",
		       (unsigned long long)entry->bytes_left,
		       (unsigned long long)io_size);
	}
	entry->bytes_left -= io_size;
	if (entry->bytes_left == 0)
263
		ret = test_and_set_bit(BTRFS_ORDERED_IO_DONE, &entry->flags);
264 265
	else
		ret = 1;
266
out:
267
	spin_unlock(&tree->lock);
268 269
	return ret == 0;
}
C
Chris Mason 已提交
270

271 272 273 274
/*
 * used to drop a reference on an ordered extent.  This will free
 * the extent if the last reference is dropped
 */
275 276
int btrfs_put_ordered_extent(struct btrfs_ordered_extent *entry)
{
277 278 279 280
	struct list_head *cur;
	struct btrfs_ordered_sum *sum;

	if (atomic_dec_and_test(&entry->refs)) {
C
Chris Mason 已提交
281
		while (!list_empty(&entry->list)) {
282 283 284 285 286
			cur = entry->list.next;
			sum = list_entry(cur, struct btrfs_ordered_sum, list);
			list_del(&sum->list);
			kfree(sum);
		}
287
		kfree(entry);
288
	}
289
	return 0;
C
Chris Mason 已提交
290
}
291

292 293
/*
 * remove an ordered extent from the tree.  No references are dropped
294
 * and you must wake_up entry->wait.  You must hold the tree lock
295
 * while you call this function.
296
 */
297
static int __btrfs_remove_ordered_extent(struct inode *inode,
298
				struct btrfs_ordered_extent *entry)
299
{
300
	struct btrfs_ordered_inode_tree *tree;
301 302
	struct rb_node *node;

303 304
	tree = &BTRFS_I(inode)->ordered_tree;
	node = &entry->rb_node;
305
	rb_erase(node, &tree->tree);
306 307
	tree->last = NULL;
	set_bit(BTRFS_ORDERED_COMPLETE, &entry->flags);
308

309 310 311 312 313 314
	spin_lock(&BTRFS_I(inode)->accounting_lock);
	BTRFS_I(inode)->outstanding_extents--;
	spin_unlock(&BTRFS_I(inode)->accounting_lock);
	btrfs_unreserve_metadata_for_delalloc(BTRFS_I(inode)->root,
					      inode, 1);

315 316
	spin_lock(&BTRFS_I(inode)->root->fs_info->ordered_extent_lock);
	list_del_init(&entry->root_extent_list);
317 318 319 320 321 322 323 324 325 326

	/*
	 * we have no more ordered extents for this inode and
	 * no dirty pages.  We can safely remove it from the
	 * list of ordered extents
	 */
	if (RB_EMPTY_ROOT(&tree->tree) &&
	    !mapping_tagged(inode->i_mapping, PAGECACHE_TAG_DIRTY)) {
		list_del_init(&BTRFS_I(inode)->ordered_operations);
	}
327 328
	spin_unlock(&BTRFS_I(inode)->root->fs_info->ordered_extent_lock);

329 330 331 332 333 334 335 336 337 338 339 340 341 342
	return 0;
}

/*
 * remove an ordered extent from the tree.  No references are dropped
 * but any waiters are woken.
 */
int btrfs_remove_ordered_extent(struct inode *inode,
				struct btrfs_ordered_extent *entry)
{
	struct btrfs_ordered_inode_tree *tree;
	int ret;

	tree = &BTRFS_I(inode)->ordered_tree;
343
	spin_lock(&tree->lock);
344
	ret = __btrfs_remove_ordered_extent(inode, entry);
345
	spin_unlock(&tree->lock);
346
	wake_up(&entry->wait);
347 348

	return ret;
349 350
}

C
Chris Mason 已提交
351 352 353 354
/*
 * wait for all the ordered extents in a root.  This is done when balancing
 * space between drives.
 */
Y
Yan, Zheng 已提交
355 356
int btrfs_wait_ordered_extents(struct btrfs_root *root,
			       int nocow_only, int delay_iput)
357 358 359 360 361 362 363 364 365 366
{
	struct list_head splice;
	struct list_head *cur;
	struct btrfs_ordered_extent *ordered;
	struct inode *inode;

	INIT_LIST_HEAD(&splice);

	spin_lock(&root->fs_info->ordered_extent_lock);
	list_splice_init(&root->fs_info->ordered_extents, &splice);
367
	while (!list_empty(&splice)) {
368 369 370
		cur = splice.next;
		ordered = list_entry(cur, struct btrfs_ordered_extent,
				     root_extent_list);
371
		if (nocow_only &&
Y
Yan Zheng 已提交
372 373
		    !test_bit(BTRFS_ORDERED_NOCOW, &ordered->flags) &&
		    !test_bit(BTRFS_ORDERED_PREALLOC, &ordered->flags)) {
374 375
			list_move(&ordered->root_extent_list,
				  &root->fs_info->ordered_extents);
376 377 378 379
			cond_resched_lock(&root->fs_info->ordered_extent_lock);
			continue;
		}

380 381 382 383
		list_del_init(&ordered->root_extent_list);
		atomic_inc(&ordered->refs);

		/*
384
		 * the inode may be getting freed (in sys_unlink path).
385
		 */
386 387
		inode = igrab(ordered->inode);

388 389
		spin_unlock(&root->fs_info->ordered_extent_lock);

390 391 392
		if (inode) {
			btrfs_start_ordered_extent(inode, ordered, 1);
			btrfs_put_ordered_extent(ordered);
Y
Yan, Zheng 已提交
393 394 395 396
			if (delay_iput)
				btrfs_add_delayed_iput(inode);
			else
				iput(inode);
397 398 399
		} else {
			btrfs_put_ordered_extent(ordered);
		}
400 401 402 403 404 405 406

		spin_lock(&root->fs_info->ordered_extent_lock);
	}
	spin_unlock(&root->fs_info->ordered_extent_lock);
	return 0;
}

407 408 409 410 411 412 413 414 415 416 417 418 419 420 421 422 423 424 425 426 427 428 429 430 431 432 433 434 435 436 437 438 439 440 441 442 443 444 445 446 447 448 449 450 451 452 453
/*
 * this is used during transaction commit to write all the inodes
 * added to the ordered operation list.  These files must be fully on
 * disk before the transaction commits.
 *
 * we have two modes here, one is to just start the IO via filemap_flush
 * and the other is to wait for all the io.  When we wait, we have an
 * extra check to make sure the ordered operation list really is empty
 * before we return
 */
int btrfs_run_ordered_operations(struct btrfs_root *root, int wait)
{
	struct btrfs_inode *btrfs_inode;
	struct inode *inode;
	struct list_head splice;

	INIT_LIST_HEAD(&splice);

	mutex_lock(&root->fs_info->ordered_operations_mutex);
	spin_lock(&root->fs_info->ordered_extent_lock);
again:
	list_splice_init(&root->fs_info->ordered_operations, &splice);

	while (!list_empty(&splice)) {
		btrfs_inode = list_entry(splice.next, struct btrfs_inode,
				   ordered_operations);

		inode = &btrfs_inode->vfs_inode;

		list_del_init(&btrfs_inode->ordered_operations);

		/*
		 * the inode may be getting freed (in sys_unlink path).
		 */
		inode = igrab(inode);

		if (!wait && inode) {
			list_add_tail(&BTRFS_I(inode)->ordered_operations,
			      &root->fs_info->ordered_operations);
		}
		spin_unlock(&root->fs_info->ordered_extent_lock);

		if (inode) {
			if (wait)
				btrfs_wait_ordered_range(inode, 0, (u64)-1);
			else
				filemap_flush(inode->i_mapping);
Y
Yan, Zheng 已提交
454
			btrfs_add_delayed_iput(inode);
455 456 457 458 459 460 461 462 463 464 465 466 467 468
		}

		cond_resched();
		spin_lock(&root->fs_info->ordered_extent_lock);
	}
	if (wait && !list_empty(&root->fs_info->ordered_operations))
		goto again;

	spin_unlock(&root->fs_info->ordered_extent_lock);
	mutex_unlock(&root->fs_info->ordered_operations_mutex);

	return 0;
}

469 470 471 472 473 474 475 476 477 478
/*
 * Used to start IO or wait for a given ordered extent to finish.
 *
 * If wait is one, this effectively waits on page writeback for all the pages
 * in the extent, and it waits on the io completion code to insert
 * metadata into the btree corresponding to the extent
 */
void btrfs_start_ordered_extent(struct inode *inode,
				       struct btrfs_ordered_extent *entry,
				       int wait)
479 480 481
{
	u64 start = entry->file_offset;
	u64 end = start + entry->len - 1;
482

483 484 485 486 487
	/*
	 * pages in the range can be dirty, clean or writeback.  We
	 * start IO on any dirty ones so the wait doesn't stall waiting
	 * for pdflush to find them
	 */
488
	filemap_fdatawrite_range(inode->i_mapping, start, end);
C
Chris Mason 已提交
489
	if (wait) {
490 491
		wait_event(entry->wait, test_bit(BTRFS_ORDERED_COMPLETE,
						 &entry->flags));
C
Chris Mason 已提交
492
	}
493
}
494

495 496 497
/*
 * Used to wait on ordered extents across a large range of bytes.
 */
498
int btrfs_wait_ordered_range(struct inode *inode, u64 start, u64 len)
499 500
{
	u64 end;
501 502
	u64 orig_end;
	u64 wait_end;
503
	struct btrfs_ordered_extent *ordered;
504
	int found;
505 506

	if (start + len < start) {
507
		orig_end = INT_LIMIT(loff_t);
508 509
	} else {
		orig_end = start + len - 1;
510 511
		if (orig_end > INT_LIMIT(loff_t))
			orig_end = INT_LIMIT(loff_t);
512
	}
513
	wait_end = orig_end;
C
Chris Mason 已提交
514
again:
515 516 517
	/* start IO across the range first to instantiate any delalloc
	 * extents
	 */
518
	filemap_fdatawrite_range(inode->i_mapping, start, orig_end);
519

520 521 522 523
	/* The compression code will leave pages locked but return from
	 * writepage without setting the page writeback.  Starting again
	 * with WB_SYNC_ALL will end up waiting for the IO to actually start.
	 */
524
	filemap_fdatawrite_range(inode->i_mapping, start, orig_end);
525

526
	filemap_fdatawait_range(inode->i_mapping, start, orig_end);
527

528
	end = orig_end;
529
	found = 0;
C
Chris Mason 已提交
530
	while (1) {
531
		ordered = btrfs_lookup_first_ordered_extent(inode, end);
C
Chris Mason 已提交
532
		if (!ordered)
533
			break;
534
		if (ordered->file_offset > orig_end) {
535 536 537 538 539 540 541
			btrfs_put_ordered_extent(ordered);
			break;
		}
		if (ordered->file_offset + ordered->len < start) {
			btrfs_put_ordered_extent(ordered);
			break;
		}
542
		found++;
543
		btrfs_start_ordered_extent(inode, ordered, 1);
544 545
		end = ordered->file_offset;
		btrfs_put_ordered_extent(ordered);
546
		if (end == 0 || end == start)
547 548 549
			break;
		end--;
	}
550 551
	if (found || test_range_bit(&BTRFS_I(inode)->io_tree, start, orig_end,
			   EXTENT_DELALLOC, 0, NULL)) {
552
		schedule_timeout(1);
C
Chris Mason 已提交
553 554
		goto again;
	}
555
	return 0;
556 557
}

558 559 560 561
/*
 * find an ordered extent corresponding to file_offset.  return NULL if
 * nothing is found, otherwise take a reference on the extent and return it
 */
562 563 564 565 566 567 568 569
struct btrfs_ordered_extent *btrfs_lookup_ordered_extent(struct inode *inode,
							 u64 file_offset)
{
	struct btrfs_ordered_inode_tree *tree;
	struct rb_node *node;
	struct btrfs_ordered_extent *entry = NULL;

	tree = &BTRFS_I(inode)->ordered_tree;
570
	spin_lock(&tree->lock);
571 572 573 574 575 576 577 578 579 580
	node = tree_search(tree, file_offset);
	if (!node)
		goto out;

	entry = rb_entry(node, struct btrfs_ordered_extent, rb_node);
	if (!offset_in_entry(entry, file_offset))
		entry = NULL;
	if (entry)
		atomic_inc(&entry->refs);
out:
581
	spin_unlock(&tree->lock);
582 583 584
	return entry;
}

585 586 587 588
/*
 * lookup and return any extent before 'file_offset'.  NULL is returned
 * if none is found
 */
589
struct btrfs_ordered_extent *
C
Chris Mason 已提交
590
btrfs_lookup_first_ordered_extent(struct inode *inode, u64 file_offset)
591 592 593 594 595 596
{
	struct btrfs_ordered_inode_tree *tree;
	struct rb_node *node;
	struct btrfs_ordered_extent *entry = NULL;

	tree = &BTRFS_I(inode)->ordered_tree;
597
	spin_lock(&tree->lock);
598 599 600 601 602 603 604
	node = tree_search(tree, file_offset);
	if (!node)
		goto out;

	entry = rb_entry(node, struct btrfs_ordered_extent, rb_node);
	atomic_inc(&entry->refs);
out:
605
	spin_unlock(&tree->lock);
606
	return entry;
607
}
608

609 610 611 612
/*
 * After an extent is done, call this to conditionally update the on disk
 * i_size.  i_size is updated to cover any fully written part of the file.
 */
613
int btrfs_ordered_update_i_size(struct inode *inode, u64 offset,
614 615 616 617 618 619 620
				struct btrfs_ordered_extent *ordered)
{
	struct btrfs_ordered_inode_tree *tree = &BTRFS_I(inode)->ordered_tree;
	struct extent_io_tree *io_tree = &BTRFS_I(inode)->io_tree;
	u64 disk_i_size;
	u64 new_i_size;
	u64 i_size_test;
621
	u64 i_size = i_size_read(inode);
622
	struct rb_node *node;
623
	struct rb_node *prev = NULL;
624
	struct btrfs_ordered_extent *test;
625 626 627 628
	int ret = 1;

	if (ordered)
		offset = entry_end(ordered);
629 630
	else
		offset = ALIGN(offset, BTRFS_I(inode)->root->sectorsize);
631

632
	spin_lock(&tree->lock);
633 634
	disk_i_size = BTRFS_I(inode)->disk_i_size;

635 636 637 638 639 640 641
	/* truncate file */
	if (disk_i_size > i_size) {
		BTRFS_I(inode)->disk_i_size = i_size;
		ret = 0;
		goto out;
	}

642 643 644 645
	/*
	 * if the disk i_size is already at the inode->i_size, or
	 * this ordered extent is inside the disk i_size, we're done
	 */
646
	if (disk_i_size == i_size || offset <= disk_i_size) {
647 648 649 650 651 652 653
		goto out;
	}

	/*
	 * we can't update the disk_isize if there are delalloc bytes
	 * between disk_i_size and  this ordered extent
	 */
654
	if (test_range_bit(io_tree, disk_i_size, offset - 1,
655
			   EXTENT_DELALLOC, 0, NULL)) {
656 657 658 659 660 661 662
		goto out;
	}
	/*
	 * walk backward from this ordered extent to disk_i_size.
	 * if we find an ordered extent then we can't update disk i_size
	 * yet
	 */
663 664 665 666 667 668 669 670 671 672 673 674 675 676 677 678
	if (ordered) {
		node = rb_prev(&ordered->rb_node);
	} else {
		prev = tree_search(tree, offset);
		/*
		 * we insert file extents without involving ordered struct,
		 * so there should be no ordered struct cover this offset
		 */
		if (prev) {
			test = rb_entry(prev, struct btrfs_ordered_extent,
					rb_node);
			BUG_ON(offset_in_entry(test, offset));
		}
		node = prev;
	}
	while (node) {
679 680 681
		test = rb_entry(node, struct btrfs_ordered_extent, rb_node);
		if (test->file_offset + test->len <= disk_i_size)
			break;
682
		if (test->file_offset >= i_size)
683 684 685
			break;
		if (test->file_offset >= disk_i_size)
			goto out;
686
		node = rb_prev(node);
687
	}
688
	new_i_size = min_t(u64, offset, i_size);
689 690 691 692 693 694 695

	/*
	 * at this point, we know we can safely update i_size to at least
	 * the offset from this ordered extent.  But, we need to
	 * walk forward and see if ios from higher up in the file have
	 * finished.
	 */
696 697 698 699 700 701 702 703
	if (ordered) {
		node = rb_next(&ordered->rb_node);
	} else {
		if (prev)
			node = rb_next(prev);
		else
			node = rb_first(&tree->tree);
	}
704 705 706 707 708 709 710
	i_size_test = 0;
	if (node) {
		/*
		 * do we have an area where IO might have finished
		 * between our ordered extent and the next one.
		 */
		test = rb_entry(node, struct btrfs_ordered_extent, rb_node);
711
		if (test->file_offset > offset)
Y
Yan Zheng 已提交
712
			i_size_test = test->file_offset;
713
	} else {
714
		i_size_test = i_size;
715 716 717 718 719 720 721 722
	}

	/*
	 * i_size_test is the end of a region after this ordered
	 * extent where there are no ordered extents.  As long as there
	 * are no delalloc bytes in this area, it is safe to update
	 * disk_i_size to the end of the region.
	 */
723 724 725 726
	if (i_size_test > offset &&
	    !test_range_bit(io_tree, offset, i_size_test - 1,
			    EXTENT_DELALLOC, 0, NULL)) {
		new_i_size = min_t(u64, i_size_test, i_size);
727 728
	}
	BTRFS_I(inode)->disk_i_size = new_i_size;
729
	ret = 0;
730
out:
731 732 733 734 735 736 737
	/*
	 * we need to remove the ordered extent with the tree lock held
	 * so that other people calling this function don't find our fully
	 * processed ordered entry and skip updating the i_size
	 */
	if (ordered)
		__btrfs_remove_ordered_extent(inode, ordered);
738
	spin_unlock(&tree->lock);
739 740 741
	if (ordered)
		wake_up(&ordered->wait);
	return ret;
742
}
743

744 745 746 747 748
/*
 * search the ordered extents for one corresponding to 'offset' and
 * try to find a checksum.  This is used because we allow pages to
 * be reclaimed before their checksum is actually put into the btree
 */
749 750
int btrfs_find_ordered_sum(struct inode *inode, u64 offset, u64 disk_bytenr,
			   u32 *sum)
751 752 753 754 755
{
	struct btrfs_ordered_sum *ordered_sum;
	struct btrfs_sector_sum *sector_sums;
	struct btrfs_ordered_extent *ordered;
	struct btrfs_ordered_inode_tree *tree = &BTRFS_I(inode)->ordered_tree;
756 757 758
	unsigned long num_sectors;
	unsigned long i;
	u32 sectorsize = BTRFS_I(inode)->root->sectorsize;
759 760 761 762 763 764
	int ret = 1;

	ordered = btrfs_lookup_ordered_extent(inode, offset);
	if (!ordered)
		return 1;

765
	spin_lock(&tree->lock);
Q
Qinghuang Feng 已提交
766
	list_for_each_entry_reverse(ordered_sum, &ordered->list, list) {
767
		if (disk_bytenr >= ordered_sum->bytenr) {
768
			num_sectors = ordered_sum->len / sectorsize;
769
			sector_sums = ordered_sum->sums;
770
			for (i = 0; i < num_sectors; i++) {
771
				if (sector_sums[i].bytenr == disk_bytenr) {
772 773 774 775 776
					*sum = sector_sums[i].sum;
					ret = 0;
					goto out;
				}
			}
777 778 779
		}
	}
out:
780
	spin_unlock(&tree->lock);
781
	btrfs_put_ordered_extent(ordered);
782 783 784
	return ret;
}

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 818 819 820 821 822 823 824 825 826 827 828 829 830
/*
 * add a given inode to the list of inodes that must be fully on
 * disk before a transaction commit finishes.
 *
 * This basically gives us the ext3 style data=ordered mode, and it is mostly
 * used to make sure renamed files are fully on disk.
 *
 * It is a noop if the inode is already fully on disk.
 *
 * If trans is not null, we'll do a friendly check for a transaction that
 * is already flushing things and force the IO down ourselves.
 */
int btrfs_add_ordered_operation(struct btrfs_trans_handle *trans,
				struct btrfs_root *root,
				struct inode *inode)
{
	u64 last_mod;

	last_mod = max(BTRFS_I(inode)->generation, BTRFS_I(inode)->last_trans);

	/*
	 * if this file hasn't been changed since the last transaction
	 * commit, we can safely return without doing anything
	 */
	if (last_mod < root->fs_info->last_trans_committed)
		return 0;

	/*
	 * the transaction is already committing.  Just start the IO and
	 * don't bother with all of this list nonsense
	 */
	if (trans && root->fs_info->running_transaction->blocked) {
		btrfs_wait_ordered_range(inode, 0, (u64)-1);
		return 0;
	}

	spin_lock(&root->fs_info->ordered_extent_lock);
	if (list_empty(&BTRFS_I(inode)->ordered_operations)) {
		list_add_tail(&BTRFS_I(inode)->ordered_operations,
			      &root->fs_info->ordered_operations);
	}
	spin_unlock(&root->fs_info->ordered_extent_lock);

	return 0;
}