super.c 78.8 KB
Newer Older
1
#include <linux/module.h>
C
Chris Mason 已提交
2
#include <linux/buffer_head.h>
3 4 5 6 7 8 9 10
#include <linux/fs.h>
#include <linux/pagemap.h>
#include <linux/highmem.h>
#include <linux/time.h>
#include <linux/init.h>
#include <linux/string.h>
#include <linux/smp_lock.h>
#include <linux/backing-dev.h>
C
Chris Mason 已提交
11
#include <linux/mpage.h>
C
Chris Mason 已提交
12 13
#include <linux/swap.h>
#include <linux/writeback.h>
C
Chris Mason 已提交
14
#include <linux/statfs.h>
15
#include "ctree.h"
C
Chris Mason 已提交
16
#include "disk-io.h"
17
#include "transaction.h"
C
Chris Mason 已提交
18
#include "btrfs_inode.h"
C
Chris Mason 已提交
19
#include "ioctl.h"
C
Chris Mason 已提交
20
#include "print-tree.h"
21

C
Chris Mason 已提交
22 23 24 25 26
struct btrfs_iget_args {
	u64 ino;
	struct btrfs_root *root;
};

27
#define BTRFS_SUPER_MAGIC 0x9123682E
C
Chris Mason 已提交
28 29

static struct inode_operations btrfs_dir_inode_operations;
C
Chris Mason 已提交
30
static struct inode_operations btrfs_symlink_inode_operations;
31
static struct inode_operations btrfs_dir_ro_inode_operations;
C
Chris Mason 已提交
32 33
static struct super_operations btrfs_super_ops;
static struct file_operations btrfs_dir_file_operations;
C
Chris Mason 已提交
34 35
static struct inode_operations btrfs_file_inode_operations;
static struct address_space_operations btrfs_aops;
C
Chris Mason 已提交
36
static struct address_space_operations btrfs_symlink_aops;
C
Chris Mason 已提交
37
static struct file_operations btrfs_file_operations;
C
Chris Mason 已提交
38

C
Chris Mason 已提交
39 40 41 42 43 44 45
static int drop_extents(struct btrfs_trans_handle *trans,
			  struct btrfs_root *root,
			  struct inode *inode,
			  u64 start, u64 end, u64 *hint_block);
static int btrfs_get_block(struct inode *inode, sector_t iblock,
			   struct buffer_head *result, int create);

C
Chris Mason 已提交
46
static void btrfs_read_locked_inode(struct inode *inode)
47
{
48
	struct btrfs_path *path;
C
Chris Mason 已提交
49
	struct btrfs_inode_item *inode_item;
50 51
	struct btrfs_root *root = BTRFS_I(inode)->root;
	struct btrfs_key location;
52 53
	struct btrfs_block_group_cache *alloc_group;
	u64 alloc_group_block;
C
Chris Mason 已提交
54
	int ret;
C
Chris Mason 已提交
55

56 57 58
	path = btrfs_alloc_path();
	BUG_ON(!path);
	btrfs_init_path(path);
C
Chris Mason 已提交
59 60
	mutex_lock(&root->fs_info->fs_mutex);

61 62
	memcpy(&location, &BTRFS_I(inode)->location, sizeof(location));
	ret = btrfs_lookup_inode(NULL, root, path, &location, 0);
C
Chris Mason 已提交
63
	if (ret) {
C
Chris Mason 已提交
64
		btrfs_free_path(path);
65
		goto make_bad;
C
Chris Mason 已提交
66
	}
67 68
	inode_item = btrfs_item_ptr(btrfs_buffer_leaf(path->nodes[0]),
				  path->slots[0],
C
Chris Mason 已提交
69
				  struct btrfs_inode_item);
70

C
Chris Mason 已提交
71 72 73 74 75 76 77 78 79 80 81 82 83
	inode->i_mode = btrfs_inode_mode(inode_item);
	inode->i_nlink = btrfs_inode_nlink(inode_item);
	inode->i_uid = btrfs_inode_uid(inode_item);
	inode->i_gid = btrfs_inode_gid(inode_item);
	inode->i_size = btrfs_inode_size(inode_item);
	inode->i_atime.tv_sec = btrfs_timespec_sec(&inode_item->atime);
	inode->i_atime.tv_nsec = btrfs_timespec_nsec(&inode_item->atime);
	inode->i_mtime.tv_sec = btrfs_timespec_sec(&inode_item->mtime);
	inode->i_mtime.tv_nsec = btrfs_timespec_nsec(&inode_item->mtime);
	inode->i_ctime.tv_sec = btrfs_timespec_sec(&inode_item->ctime);
	inode->i_ctime.tv_nsec = btrfs_timespec_nsec(&inode_item->ctime);
	inode->i_blocks = btrfs_inode_nblocks(inode_item);
	inode->i_generation = btrfs_inode_generation(inode_item);
84 85 86 87 88 89
	alloc_group_block = btrfs_inode_block_group(inode_item);
	ret = radix_tree_gang_lookup(&root->fs_info->block_group_radix,
				     (void **)&alloc_group,
				     alloc_group_block, 1);
	BUG_ON(!ret);
	BTRFS_I(inode)->block_group = alloc_group;
90 91 92 93

	btrfs_free_path(path);
	inode_item = NULL;

C
Chris Mason 已提交
94
	mutex_unlock(&root->fs_info->fs_mutex);
C
Chris Mason 已提交
95

C
Chris Mason 已提交
96 97 98 99 100 101 102 103
	switch (inode->i_mode & S_IFMT) {
#if 0
	default:
		init_special_inode(inode, inode->i_mode,
				   btrfs_inode_rdev(inode_item));
		break;
#endif
	case S_IFREG:
C
Chris Mason 已提交
104 105 106
		inode->i_mapping->a_ops = &btrfs_aops;
		inode->i_fop = &btrfs_file_operations;
		inode->i_op = &btrfs_file_inode_operations;
C
Chris Mason 已提交
107 108 109
		break;
	case S_IFDIR:
		inode->i_fop = &btrfs_dir_file_operations;
110 111 112 113
		if (root == root->fs_info->tree_root)
			inode->i_op = &btrfs_dir_ro_inode_operations;
		else
			inode->i_op = &btrfs_dir_inode_operations;
C
Chris Mason 已提交
114 115
		break;
	case S_IFLNK:
C
Chris Mason 已提交
116 117
		inode->i_op = &btrfs_symlink_inode_operations;
		inode->i_mapping->a_ops = &btrfs_symlink_aops;
C
Chris Mason 已提交
118
		break;
119
	}
C
Chris Mason 已提交
120
	return;
121 122 123 124 125 126

make_bad:
	btrfs_release_path(root, path);
	btrfs_free_path(path);
	mutex_unlock(&root->fs_info->fs_mutex);
	make_bad_inode(inode);
127 128
}

129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144
static void fill_inode_item(struct btrfs_inode_item *item,
			    struct inode *inode)
{
	btrfs_set_inode_uid(item, inode->i_uid);
	btrfs_set_inode_gid(item, inode->i_gid);
	btrfs_set_inode_size(item, inode->i_size);
	btrfs_set_inode_mode(item, inode->i_mode);
	btrfs_set_inode_nlink(item, inode->i_nlink);
	btrfs_set_timespec_sec(&item->atime, inode->i_atime.tv_sec);
	btrfs_set_timespec_nsec(&item->atime, inode->i_atime.tv_nsec);
	btrfs_set_timespec_sec(&item->mtime, inode->i_mtime.tv_sec);
	btrfs_set_timespec_nsec(&item->mtime, inode->i_mtime.tv_nsec);
	btrfs_set_timespec_sec(&item->ctime, inode->i_ctime.tv_sec);
	btrfs_set_timespec_nsec(&item->ctime, inode->i_ctime.tv_nsec);
	btrfs_set_inode_nblocks(item, inode->i_blocks);
	btrfs_set_inode_generation(item, inode->i_generation);
145 146
	btrfs_set_inode_block_group(item,
				    BTRFS_I(inode)->block_group->key.objectid);
147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181
}

static int btrfs_update_inode(struct btrfs_trans_handle *trans,
			      struct btrfs_root *root,
			      struct inode *inode)
{
	struct btrfs_inode_item *inode_item;
	struct btrfs_path *path;
	int ret;

	path = btrfs_alloc_path();
	BUG_ON(!path);
	btrfs_init_path(path);
	ret = btrfs_lookup_inode(trans, root, path,
				 &BTRFS_I(inode)->location, 1);
	if (ret) {
		if (ret > 0)
			ret = -ENOENT;
		goto failed;
	}

	inode_item = btrfs_item_ptr(btrfs_buffer_leaf(path->nodes[0]),
				  path->slots[0],
				  struct btrfs_inode_item);

	fill_inode_item(inode_item, inode);
	btrfs_mark_buffer_dirty(path->nodes[0]);
	ret = 0;
failed:
	btrfs_release_path(root, path);
	btrfs_free_path(path);
	return ret;
}


C
Chris Mason 已提交
182 183 184 185
static int btrfs_unlink_trans(struct btrfs_trans_handle *trans,
			      struct btrfs_root *root,
			      struct inode *dir,
			      struct dentry *dentry)
C
Chris Mason 已提交
186
{
187
	struct btrfs_path *path;
C
Chris Mason 已提交
188 189
	const char *name = dentry->d_name.name;
	int name_len = dentry->d_name.len;
190
	int ret = 0;
C
Chris Mason 已提交
191 192 193
	u64 objectid;
	struct btrfs_dir_item *di;

194 195 196
	path = btrfs_alloc_path();
	BUG_ON(!path);
	btrfs_init_path(path);
197
	di = btrfs_lookup_dir_item(trans, root, path, dir->i_ino,
C
Chris Mason 已提交
198
				    name, name_len, -1);
199 200
	if (IS_ERR(di)) {
		ret = PTR_ERR(di);
C
Chris Mason 已提交
201
		goto err;
202 203
	}
	if (!di) {
C
Chris Mason 已提交
204 205 206
		ret = -ENOENT;
		goto err;
	}
207
	objectid = btrfs_disk_key_objectid(&di->location);
208 209 210
	ret = btrfs_delete_one_dir_name(trans, root, path, di);
	BUG_ON(ret);
	btrfs_release_path(root, path);
C
Chris Mason 已提交
211

212 213 214 215 216 217 218 219 220 221 222
	di = btrfs_lookup_dir_index_item(trans, root, path, dir->i_ino,
					 objectid, name, name_len, -1);
	if (IS_ERR(di)) {
		ret = PTR_ERR(di);
		goto err;
	}
	if (!di) {
		ret = -ENOENT;
		goto err;
	}
	ret = btrfs_delete_one_dir_name(trans, root, path, di);
223 224
	BUG_ON(ret);

C
Chris Mason 已提交
225 226
	dentry->d_inode->i_ctime = dir->i_ctime;
err:
227
	btrfs_free_path(path);
228
	if (!ret) {
229
		dir->i_size -= name_len * 2;
230 231 232
		btrfs_update_inode(trans, root, dir);
		drop_nlink(dentry->d_inode);
		btrfs_update_inode(trans, root, dentry->d_inode);
C
Chris Mason 已提交
233
		dir->i_sb->s_dirt = 1;
234
	}
C
Chris Mason 已提交
235 236 237
	return ret;
}

C
Chris Mason 已提交
238 239 240 241 242 243
static int btrfs_unlink(struct inode *dir, struct dentry *dentry)
{
	struct btrfs_root *root;
	struct btrfs_trans_handle *trans;
	int ret;

244
	root = BTRFS_I(dir)->root;
C
Chris Mason 已提交
245 246
	mutex_lock(&root->fs_info->fs_mutex);
	trans = btrfs_start_transaction(root, 1);
247
	btrfs_set_trans_block_group(trans, dir);
C
Chris Mason 已提交
248 249 250
	ret = btrfs_unlink_trans(trans, root, dir, dentry);
	btrfs_end_transaction(trans, root);
	mutex_unlock(&root->fs_info->fs_mutex);
C
Chris Mason 已提交
251
	btrfs_btree_balance_dirty(root);
C
Chris Mason 已提交
252 253 254 255 256 257 258 259
	return ret;
}

static int btrfs_rmdir(struct inode *dir, struct dentry *dentry)
{
	struct inode *inode = dentry->d_inode;
	int err;
	int ret;
260
	struct btrfs_root *root = BTRFS_I(dir)->root;
261
	struct btrfs_path *path;
C
Chris Mason 已提交
262 263
	struct btrfs_key key;
	struct btrfs_trans_handle *trans;
264 265
	struct btrfs_key found_key;
	int found_type;
C
Chris Mason 已提交
266
	struct btrfs_leaf *leaf;
267
	char *goodnames = "..";
C
Chris Mason 已提交
268

269 270 271
	path = btrfs_alloc_path();
	BUG_ON(!path);
	btrfs_init_path(path);
C
Chris Mason 已提交
272 273
	mutex_lock(&root->fs_info->fs_mutex);
	trans = btrfs_start_transaction(root, 1);
274
	btrfs_set_trans_block_group(trans, dir);
C
Chris Mason 已提交
275 276
	key.objectid = inode->i_ino;
	key.offset = (u64)-1;
277 278 279 280 281 282 283 284 285 286 287 288 289 290 291 292 293 294 295 296 297 298 299 300 301 302 303 304 305 306
	key.flags = (u32)-1;
	while(1) {
		ret = btrfs_search_slot(trans, root, &key, path, -1, 1);
		if (ret < 0) {
			err = ret;
			goto out;
		}
		BUG_ON(ret == 0);
		if (path->slots[0] == 0) {
			err = -ENOENT;
			goto out;
		}
		path->slots[0]--;
		leaf = btrfs_buffer_leaf(path->nodes[0]);
		btrfs_disk_key_to_cpu(&found_key,
				      &leaf->items[path->slots[0]].key);
		found_type = btrfs_key_type(&found_key);
		if (found_key.objectid != inode->i_ino) {
			err = -ENOENT;
			goto out;
		}
		if ((found_type != BTRFS_DIR_ITEM_KEY &&
		     found_type != BTRFS_DIR_INDEX_KEY) ||
	            (!btrfs_match_dir_item_name(root, path, goodnames, 2) &&
	            !btrfs_match_dir_item_name(root, path, goodnames, 1))) {
			err = -ENOTEMPTY;
			goto out;
		}
		ret = btrfs_del_item(trans, root, path);
		BUG_ON(ret);
C
Chris Mason 已提交
307

308 309 310
		if (found_type == BTRFS_DIR_ITEM_KEY && found_key.offset == 1)
			break;
		btrfs_release_path(root, path);
C
Chris Mason 已提交
311
	}
312
	ret = 0;
313
	btrfs_release_path(root, path);
C
Chris Mason 已提交
314 315 316 317 318 319 320

	/* now the directory is empty */
	err = btrfs_unlink_trans(trans, root, dir, dentry);
	if (!err) {
		inode->i_size = 0;
	}
out:
C
Chris Mason 已提交
321 322
	btrfs_release_path(root, path);
	btrfs_free_path(path);
C
Chris Mason 已提交
323 324
	mutex_unlock(&root->fs_info->fs_mutex);
	ret = btrfs_end_transaction(trans, root);
C
Chris Mason 已提交
325
	btrfs_btree_balance_dirty(root);
C
Chris Mason 已提交
326 327 328 329 330
	if (ret && !err)
		err = ret;
	return err;
}

C
Chris Mason 已提交
331 332 333 334
static int btrfs_free_inode(struct btrfs_trans_handle *trans,
			    struct btrfs_root *root,
			    struct inode *inode)
{
335
	struct btrfs_path *path;
C
Chris Mason 已提交
336
	int ret;
337

C
Chris Mason 已提交
338
	clear_inode(inode);
339 340 341 342

	path = btrfs_alloc_path();
	BUG_ON(!path);
	btrfs_init_path(path);
343 344
	ret = btrfs_lookup_inode(trans, root, path,
				 &BTRFS_I(inode)->location, -1);
C
Chris Mason 已提交
345
	BUG_ON(ret);
346
	ret = btrfs_del_item(trans, root, path);
C
Chris Mason 已提交
347
	BUG_ON(ret);
348
	btrfs_free_path(path);
C
Chris Mason 已提交
349 350 351
	return ret;
}

352 353 354 355 356 357 358 359 360 361 362 363 364 365 366 367 368 369 370 371 372 373 374 375 376 377 378 379 380
static void reada_truncate(struct btrfs_root *root, struct btrfs_path *path,
			   u64 objectid)
{
	struct btrfs_node *node;
	int i;
	int nritems;
	u64 item_objectid;
	u64 blocknr;
	int slot;
	int ret;

	if (!path->nodes[1])
		return;
	node = btrfs_buffer_node(path->nodes[1]);
	slot = path->slots[1];
	if (slot == 0)
		return;
	nritems = btrfs_header_nritems(&node->header);
	for (i = slot - 1; i >= 0; i--) {
		item_objectid = btrfs_disk_key_objectid(&node->ptrs[i].key);
		if (item_objectid != objectid)
			break;
		blocknr = btrfs_node_blockptr(node, i);
		ret = readahead_tree_block(root, blocknr);
		if (ret)
			break;
	}
}

C
Chris Mason 已提交
381 382 383 384 385
static int btrfs_truncate_in_trans(struct btrfs_trans_handle *trans,
				   struct btrfs_root *root,
				   struct inode *inode)
{
	int ret;
386
	struct btrfs_path *path;
C
Chris Mason 已提交
387 388
	struct btrfs_key key;
	struct btrfs_disk_key *found_key;
C
Chris Mason 已提交
389
	u32 found_type;
C
Chris Mason 已提交
390
	struct btrfs_leaf *leaf;
C
Chris Mason 已提交
391
	struct btrfs_file_extent_item *fi;
C
Chris Mason 已提交
392 393
	u64 extent_start = 0;
	u64 extent_num_blocks = 0;
C
Chris Mason 已提交
394
	u64 item_end = 0;
C
Chris Mason 已提交
395
	int found_extent;
C
Chris Mason 已提交
396
	int del_item;
C
Chris Mason 已提交
397

398 399
	path = btrfs_alloc_path();
	BUG_ON(!path);
C
Chris Mason 已提交
400 401 402
	/* FIXME, add redo link to tree so we don't leak on crash */
	key.objectid = inode->i_ino;
	key.offset = (u64)-1;
C
Chris Mason 已提交
403
	key.flags = (u32)-1;
C
Chris Mason 已提交
404
	while(1) {
405
		btrfs_init_path(path);
C
Chris Mason 已提交
406
		fi = NULL;
407
		ret = btrfs_search_slot(trans, root, &key, path, -1, 1);
C
Chris Mason 已提交
408 409 410 411
		if (ret < 0) {
			goto error;
		}
		if (ret > 0) {
412 413
			BUG_ON(path->slots[0] == 0);
			path->slots[0]--;
C
Chris Mason 已提交
414
		}
415
		reada_truncate(root, path, inode->i_ino);
416 417
		leaf = btrfs_buffer_leaf(path->nodes[0]);
		found_key = &leaf->items[path->slots[0]].key;
C
Chris Mason 已提交
418
		found_type = btrfs_disk_key_type(found_key);
C
Chris Mason 已提交
419 420
		if (btrfs_disk_key_objectid(found_key) != inode->i_ino)
			break;
C
Chris Mason 已提交
421 422 423 424
		if (found_type != BTRFS_CSUM_ITEM_KEY &&
		    found_type != BTRFS_DIR_ITEM_KEY &&
		    found_type != BTRFS_DIR_INDEX_KEY &&
		    found_type != BTRFS_EXTENT_DATA_KEY)
C
Chris Mason 已提交
425
			break;
C
Chris Mason 已提交
426 427
		item_end = btrfs_disk_key_offset(found_key);
		if (found_type == BTRFS_EXTENT_DATA_KEY) {
428 429
			fi = btrfs_item_ptr(btrfs_buffer_leaf(path->nodes[0]),
					    path->slots[0],
C
Chris Mason 已提交
430
					    struct btrfs_file_extent_item);
431 432
			if (btrfs_file_extent_type(fi) !=
			    BTRFS_FILE_EXTENT_INLINE) {
C
Chris Mason 已提交
433 434 435 436 437 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
				item_end += btrfs_file_extent_num_blocks(fi) <<
						inode->i_blkbits;
			}
		}
		if (found_type == BTRFS_CSUM_ITEM_KEY) {
			ret = btrfs_csum_truncate(trans, root, path,
						  inode->i_size);
			BUG_ON(ret);
		}
		if (item_end < inode->i_size) {
			if (found_type) {
				btrfs_set_key_type(&key, found_type - 1);
				continue;
			}
			break;
		}
		if (btrfs_disk_key_offset(found_key) >= inode->i_size)
			del_item = 1;
		else
			del_item = 0;
		found_extent = 0;

		if (found_type == BTRFS_EXTENT_DATA_KEY &&
			   btrfs_file_extent_type(fi) !=
			   BTRFS_FILE_EXTENT_INLINE) {
			u64 num_dec;
			if (!del_item) {
				u64 orig_num_blocks =
					btrfs_file_extent_num_blocks(fi);
				extent_num_blocks = inode->i_size -
					btrfs_disk_key_offset(found_key) +
					root->blocksize - 1;
				extent_num_blocks >>= inode->i_blkbits;
				btrfs_set_file_extent_num_blocks(fi,
							 extent_num_blocks);
				inode->i_blocks -= (orig_num_blocks -
					extent_num_blocks) << 3;
				mark_buffer_dirty(path->nodes[0]);
			} else {
472 473 474 475 476
				extent_start =
					btrfs_file_extent_disk_blocknr(fi);
				extent_num_blocks =
					btrfs_file_extent_disk_num_blocks(fi);
				/* FIXME blocksize != 4096 */
C
Chris Mason 已提交
477 478 479 480 481
				num_dec = btrfs_file_extent_num_blocks(fi) << 3;
				if (extent_start != 0) {
					found_extent = 1;
					inode->i_blocks -= num_dec;
				}
482
			}
C
Chris Mason 已提交
483
		}
C
Chris Mason 已提交
484 485 486 487 488 489
		if (del_item) {
			ret = btrfs_del_item(trans, root, path);
			BUG_ON(ret);
		} else {
			break;
		}
490
		btrfs_release_path(root, path);
C
Chris Mason 已提交
491 492 493 494 495
		if (found_extent) {
			ret = btrfs_free_extent(trans, root, extent_start,
						extent_num_blocks, 0);
			BUG_ON(ret);
		}
C
Chris Mason 已提交
496 497 498
	}
	ret = 0;
error:
499 500
	btrfs_release_path(root, path);
	btrfs_free_path(path);
C
Chris Mason 已提交
501
	inode->i_sb->s_dirt = 1;
C
Chris Mason 已提交
502 503 504
	return ret;
}

C
Chris Mason 已提交
505 506 507 508 509 510 511 512 513 514 515 516 517 518 519 520 521 522 523 524 525 526 527 528 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 558 559 560 561 562 563 564 565 566
static int btrfs_truncate_page(struct address_space *mapping, loff_t from)
{
	struct inode *inode = mapping->host;
	unsigned blocksize = 1 << inode->i_blkbits;
	pgoff_t index = from >> PAGE_CACHE_SHIFT;
	unsigned offset = from & (PAGE_CACHE_SIZE-1);
	struct page *page;
	char *kaddr;
	int ret = 0;
	struct btrfs_root *root = BTRFS_I(inode)->root;
	u64 alloc_hint;
	struct btrfs_key ins;
	struct btrfs_trans_handle *trans;

	if ((offset & (blocksize - 1)) == 0)
		goto out;

	ret = -ENOMEM;
	page = grab_cache_page(mapping, index);
	if (!page)
		goto out;

	if (!PageUptodate(page)) {
		ret = mpage_readpage(page, btrfs_get_block);
		lock_page(page);
		if (!PageUptodate(page)) {
			ret = -EIO;
			goto out;
		}
	}
	mutex_lock(&root->fs_info->fs_mutex);
	trans = btrfs_start_transaction(root, 1);
	btrfs_set_trans_block_group(trans, inode);

	ret = drop_extents(trans, root, inode, page->index << PAGE_CACHE_SHIFT,
			   (page->index + 1) << PAGE_CACHE_SHIFT, &alloc_hint);
	BUG_ON(ret);
	ret = btrfs_alloc_extent(trans, root, inode->i_ino, 1,
				 alloc_hint, (u64)-1, &ins, 1);
	BUG_ON(ret);
	ret = btrfs_insert_file_extent(trans, root, inode->i_ino,
				       page->index << PAGE_CACHE_SHIFT,
				       ins.objectid, 1, 1);
	BUG_ON(ret);
	SetPageChecked(page);
	kaddr = kmap(page);
	memset(kaddr + offset, 0, PAGE_CACHE_SIZE - offset);
	flush_dcache_page(page);
	btrfs_csum_file_block(trans, root, inode->i_ino,
			      page->index << PAGE_CACHE_SHIFT,
			      kaddr, PAGE_CACHE_SIZE);
	kunmap(page);
	btrfs_end_transaction(trans, root);
	mutex_unlock(&root->fs_info->fs_mutex);

	set_page_dirty(page);
	unlock_page(page);
	page_cache_release(page);
out:
	return ret;
}

C
Chris Mason 已提交
567 568 569 570 571 572 573 574 575 576 577 578 579 580 581 582 583
static int btrfs_setattr(struct dentry *dentry, struct iattr *attr)
{
	struct inode *inode = dentry->d_inode;
	int err;

	err = inode_change_ok(inode, attr);
	if (err)
		return err;

	if (S_ISREG(inode->i_mode) &&
	    attr->ia_valid & ATTR_SIZE && attr->ia_size > inode->i_size) {
		struct btrfs_trans_handle *trans;
		struct btrfs_root *root = BTRFS_I(inode)->root;
		u64 mask = root->blocksize - 1;
		u64 pos = (inode->i_size + mask) & ~mask;
		u64 hole_size;

C
Chris Mason 已提交
584
		if (attr->ia_size <= pos)
C
Chris Mason 已提交
585
			goto out;
C
Chris Mason 已提交
586 587 588

		btrfs_truncate_page(inode->i_mapping, inode->i_size);

C
Chris Mason 已提交
589 590 591 592 593 594 595 596 597 598 599 600
		hole_size = (attr->ia_size - pos + mask) & ~mask;
		hole_size >>= inode->i_blkbits;

		mutex_lock(&root->fs_info->fs_mutex);
		trans = btrfs_start_transaction(root, 1);
		btrfs_set_trans_block_group(trans, inode);
		err = btrfs_insert_file_extent(trans, root, inode->i_ino,
					       pos, 0, 0, hole_size);
		BUG_ON(err);
		btrfs_end_transaction(trans, root);
		mutex_unlock(&root->fs_info->fs_mutex);
	}
C
Chris Mason 已提交
601
out:
C
Chris Mason 已提交
602 603 604 605
	err = inode_setattr(inode, attr);

	return err;
}
C
Chris Mason 已提交
606 607 608
static void btrfs_delete_inode(struct inode *inode)
{
	struct btrfs_trans_handle *trans;
609
	struct btrfs_root *root = BTRFS_I(inode)->root;
C
Chris Mason 已提交
610 611
	int ret;

C
Chris Mason 已提交
612 613 614 615 616 617 618
	truncate_inode_pages(&inode->i_data, 0);
	if (is_bad_inode(inode)) {
		goto no_delete;
	}
	inode->i_size = 0;
	mutex_lock(&root->fs_info->fs_mutex);
	trans = btrfs_start_transaction(root, 1);
619
	btrfs_set_trans_block_group(trans, inode);
C
Chris Mason 已提交
620 621
	ret = btrfs_truncate_in_trans(trans, root, inode);
	BUG_ON(ret);
C
Chris Mason 已提交
622 623 624
	btrfs_free_inode(trans, root, inode);
	btrfs_end_transaction(trans, root);
	mutex_unlock(&root->fs_info->fs_mutex);
C
Chris Mason 已提交
625
	btrfs_btree_balance_dirty(root);
C
Chris Mason 已提交
626 627 628 629 630
	return;
no_delete:
	clear_inode(inode);
}

C
Chris Mason 已提交
631
static int btrfs_inode_by_name(struct inode *dir, struct dentry *dentry,
632
			       struct btrfs_key *location)
C
Chris Mason 已提交
633 634 635 636
{
	const char *name = dentry->d_name.name;
	int namelen = dentry->d_name.len;
	struct btrfs_dir_item *di;
637
	struct btrfs_path *path;
638
	struct btrfs_root *root = BTRFS_I(dir)->root;
C
Chris Mason 已提交
639 640
	int ret;

641 642 643
	path = btrfs_alloc_path();
	BUG_ON(!path);
	btrfs_init_path(path);
644
	di = btrfs_lookup_dir_item(NULL, root, path, dir->i_ino, name,
C
Chris Mason 已提交
645
				    namelen, 0);
646
	if (!di || IS_ERR(di)) {
647
		location->objectid = 0;
C
Chris Mason 已提交
648
		ret = 0;
C
Chris Mason 已提交
649 650
		goto out;
	}
651
	btrfs_disk_key_to_cpu(location, &di->location);
C
Chris Mason 已提交
652
out:
653 654
	btrfs_release_path(root, path);
	btrfs_free_path(path);
C
Chris Mason 已提交
655 656 657
	return ret;
}

C
Chris Mason 已提交
658
static int fixup_tree_root_location(struct btrfs_root *root,
659 660 661 662 663 664 665 666 667 668 669 670 671 672 673
			     struct btrfs_key *location,
			     struct btrfs_root **sub_root)
{
	struct btrfs_path *path;
	struct btrfs_root_item *ri;

	if (btrfs_key_type(location) != BTRFS_ROOT_ITEM_KEY)
		return 0;
	if (location->objectid == BTRFS_ROOT_TREE_OBJECTID)
		return 0;

	path = btrfs_alloc_path();
	BUG_ON(!path);
	mutex_lock(&root->fs_info->fs_mutex);

674 675 676 677 678
	*sub_root = btrfs_read_fs_root(root->fs_info, location);
	if (IS_ERR(*sub_root))
		return PTR_ERR(*sub_root);

	ri = &(*sub_root)->root_item;
679 680 681 682
	location->objectid = btrfs_root_dirid(ri);
	location->flags = 0;
	btrfs_set_key_type(location, BTRFS_INODE_ITEM_KEY);
	location->offset = 0;
683

684 685
	btrfs_free_path(path);
	mutex_unlock(&root->fs_info->fs_mutex);
686
	return 0;
687 688
}

C
Chris Mason 已提交
689
static int btrfs_init_locked_inode(struct inode *inode, void *p)
C
Chris Mason 已提交
690 691 692 693 694 695 696
{
	struct btrfs_iget_args *args = p;
	inode->i_ino = args->ino;
	BTRFS_I(inode)->root = args->root;
	return 0;
}

C
Chris Mason 已提交
697
static int btrfs_find_actor(struct inode *inode, void *opaque)
C
Chris Mason 已提交
698 699 700 701 702 703
{
	struct btrfs_iget_args *args = opaque;
	return (args->ino == inode->i_ino &&
		args->root == BTRFS_I(inode)->root);
}

C
Chris Mason 已提交
704 705
static struct inode *btrfs_iget_locked(struct super_block *s, u64 objectid,
				       struct btrfs_root *root)
C
Chris Mason 已提交
706 707 708 709 710 711 712 713 714 715 716
{
	struct inode *inode;
	struct btrfs_iget_args args;
	args.ino = objectid;
	args.root = root;

	inode = iget5_locked(s, objectid, btrfs_find_actor,
			     btrfs_init_locked_inode,
			     (void *)&args);
	return inode;
}
717

C
Chris Mason 已提交
718 719 720 721
static struct dentry *btrfs_lookup(struct inode *dir, struct dentry *dentry,
				   struct nameidata *nd)
{
	struct inode * inode;
722 723 724 725
	struct btrfs_inode *bi = BTRFS_I(dir);
	struct btrfs_root *root = bi->root;
	struct btrfs_root *sub_root = root;
	struct btrfs_key location;
C
Chris Mason 已提交
726 727 728 729
	int ret;

	if (dentry->d_name.len > BTRFS_NAME_LEN)
		return ERR_PTR(-ENAMETOOLONG);
C
Chris Mason 已提交
730
	mutex_lock(&root->fs_info->fs_mutex);
731
	ret = btrfs_inode_by_name(dir, dentry, &location);
C
Chris Mason 已提交
732
	mutex_unlock(&root->fs_info->fs_mutex);
C
Chris Mason 已提交
733 734 735
	if (ret < 0)
		return ERR_PTR(ret);
	inode = NULL;
736 737 738 739 740 741
	if (location.objectid) {
		ret = fixup_tree_root_location(root, &location, &sub_root);
		if (ret < 0)
			return ERR_PTR(ret);
		if (ret > 0)
			return ERR_PTR(-ENOENT);
C
Chris Mason 已提交
742 743
		inode = btrfs_iget_locked(dir->i_sb, location.objectid,
					  sub_root);
C
Chris Mason 已提交
744 745
		if (!inode)
			return ERR_PTR(-EACCES);
746
		if (inode->i_state & I_NEW) {
747
			if (sub_root != root) {
C
Chris Mason 已提交
748
printk("adding new root for inode %lu root %p (found %p)\n", inode->i_ino, sub_root, BTRFS_I(inode)->root);
749 750 751
				igrab(inode);
				sub_root->inode = inode;
			}
752 753 754 755 756 757
			BTRFS_I(inode)->root = sub_root;
			memcpy(&BTRFS_I(inode)->location, &location,
			       sizeof(location));
			btrfs_read_locked_inode(inode);
			unlock_new_inode(inode);
		}
C
Chris Mason 已提交
758 759 760 761
	}
	return d_splice_alias(inode, dentry);
}

762 763
static void reada_leaves(struct btrfs_root *root, struct btrfs_path *path,
			 u64 objectid)
C
Chris Mason 已提交
764 765 766
{
	struct btrfs_node *node;
	int i;
767
	u32 nritems;
C
Chris Mason 已提交
768 769 770
	u64 item_objectid;
	u64 blocknr;
	int slot;
771
	int ret;
C
Chris Mason 已提交
772 773 774 775 776 777

	if (!path->nodes[1])
		return;
	node = btrfs_buffer_node(path->nodes[1]);
	slot = path->slots[1];
	nritems = btrfs_header_nritems(&node->header);
778
	for (i = slot + 1; i < nritems; i++) {
C
Chris Mason 已提交
779 780 781 782
		item_objectid = btrfs_disk_key_objectid(&node->ptrs[i].key);
		if (item_objectid != objectid)
			break;
		blocknr = btrfs_node_blockptr(node, i);
783 784 785
		ret = readahead_tree_block(root, blocknr);
		if (ret)
			break;
C
Chris Mason 已提交
786 787 788
	}
}

C
Chris Mason 已提交
789 790 791
static int btrfs_readdir(struct file *filp, void *dirent, filldir_t filldir)
{
	struct inode *inode = filp->f_path.dentry->d_inode;
792
	struct btrfs_root *root = BTRFS_I(inode)->root;
C
Chris Mason 已提交
793 794 795
	struct btrfs_item *item;
	struct btrfs_dir_item *di;
	struct btrfs_key key;
796
	struct btrfs_path *path;
C
Chris Mason 已提交
797 798 799 800 801 802
	int ret;
	u32 nritems;
	struct btrfs_leaf *leaf;
	int slot;
	int advance;
	unsigned char d_type = DT_UNKNOWN;
803
	int over = 0;
804 805 806 807
	u32 di_cur;
	u32 di_total;
	u32 di_len;
	int key_type = BTRFS_DIR_INDEX_KEY;
808 809 810 811

	/* FIXME, use a real flag for deciding about the key type */
	if (root->fs_info->tree_root == root)
		key_type = BTRFS_DIR_ITEM_KEY;
C
Chris Mason 已提交
812
	mutex_lock(&root->fs_info->fs_mutex);
C
Chris Mason 已提交
813 814
	key.objectid = inode->i_ino;
	key.flags = 0;
815
	btrfs_set_key_type(&key, key_type);
C
Chris Mason 已提交
816
	key.offset = filp->f_pos;
817 818 819
	path = btrfs_alloc_path();
	btrfs_init_path(path);
	ret = btrfs_search_slot(NULL, root, &key, path, 0, 0);
C
Chris Mason 已提交
820
	if (ret < 0)
C
Chris Mason 已提交
821
		goto err;
822
	advance = 0;
823
	reada_leaves(root, path, inode->i_ino);
C
Chris Mason 已提交
824
	while(1) {
825
		leaf = btrfs_buffer_leaf(path->nodes[0]);
C
Chris Mason 已提交
826
		nritems = btrfs_header_nritems(&leaf->header);
827
		slot = path->slots[0];
C
Chris Mason 已提交
828 829
		if (advance || slot >= nritems) {
			if (slot >= nritems -1) {
830
				reada_leaves(root, path, inode->i_ino);
831
				ret = btrfs_next_leaf(root, path);
C
Chris Mason 已提交
832 833
				if (ret)
					break;
834
				leaf = btrfs_buffer_leaf(path->nodes[0]);
C
Chris Mason 已提交
835
				nritems = btrfs_header_nritems(&leaf->header);
836
				slot = path->slots[0];
C
Chris Mason 已提交
837 838
			} else {
				slot++;
839
				path->slots[0]++;
C
Chris Mason 已提交
840 841 842 843 844 845
			}
		}
		advance = 1;
		item = leaf->items + slot;
		if (btrfs_disk_key_objectid(&item->key) != key.objectid)
			break;
846
		if (btrfs_disk_key_type(&item->key) != key_type)
847
			break;
848 849
		if (btrfs_disk_key_offset(&item->key) < filp->f_pos)
			continue;
850
		filp->f_pos = btrfs_disk_key_offset(&item->key);
C
Chris Mason 已提交
851
		advance = 1;
C
Chris Mason 已提交
852
		di = btrfs_item_ptr(leaf, slot, struct btrfs_dir_item);
853 854 855 856 857 858 859 860 861 862 863 864 865 866
		di_cur = 0;
		di_total = btrfs_item_size(leaf->items + slot);
		while(di_cur < di_total) {
			over = filldir(dirent, (const char *)(di + 1),
				       btrfs_dir_name_len(di),
				       btrfs_disk_key_offset(&item->key),
				       btrfs_disk_key_objectid(&di->location),
				       d_type);
			if (over)
				goto nopos;
			di_len = btrfs_dir_name_len(di) + sizeof(*di);
			di_cur += di_len;
			di = (struct btrfs_dir_item *)((char *)di + di_len);
		}
C
Chris Mason 已提交
867
	}
868 869
	filp->f_pos++;
nopos:
C
Chris Mason 已提交
870 871
	ret = 0;
err:
872 873
	btrfs_release_path(root, path);
	btrfs_free_path(path);
C
Chris Mason 已提交
874
	mutex_unlock(&root->fs_info->fs_mutex);
C
Chris Mason 已提交
875 876 877 878 879 880 881 882 883 884 885 886 887 888
	return ret;
}

static void btrfs_put_super (struct super_block * sb)
{
	struct btrfs_root *root = btrfs_sb(sb);
	int ret;

	ret = close_ctree(root);
	if (ret) {
		printk("close ctree returns %d\n", ret);
	}
	sb->s_fs_info = NULL;
}
889 890 891 892

static int btrfs_fill_super(struct super_block * sb, void * data, int silent)
{
	struct inode * inode;
C
Chris Mason 已提交
893 894
	struct dentry * root_dentry;
	struct btrfs_super_block *disk_super;
895
	struct btrfs_root *tree_root;
896
	struct btrfs_inode *bi;
897 898 899

	sb->s_maxbytes = MAX_LFS_FILESIZE;
	sb->s_magic = BTRFS_SUPER_MAGIC;
C
Chris Mason 已提交
900
	sb->s_op = &btrfs_super_ops;
901
	sb->s_time_gran = 1;
C
Chris Mason 已提交
902

903
	tree_root = open_ctree(sb);
904

905
	if (!tree_root) {
C
Chris Mason 已提交
906 907 908
		printk("btrfs: open_ctree failed\n");
		return -EIO;
	}
909 910
	sb->s_fs_info = tree_root;
	disk_super = tree_root->fs_info->disk_super;
C
Chris Mason 已提交
911 912 913 914
	printk("read in super total blocks %Lu root %Lu\n",
	       btrfs_super_total_blocks(disk_super),
	       btrfs_super_root_dir(disk_super));

C
Chris Mason 已提交
915 916
	inode = btrfs_iget_locked(sb, btrfs_super_root_dir(disk_super),
				  tree_root);
917 918 919 920
	bi = BTRFS_I(inode);
	bi->location.objectid = inode->i_ino;
	bi->location.offset = 0;
	bi->location.flags = 0;
921
	bi->root = tree_root;
922 923
	btrfs_set_key_type(&bi->location, BTRFS_INODE_ITEM_KEY);

924 925
	if (!inode)
		return -ENOMEM;
C
Chris Mason 已提交
926 927 928 929
	if (inode->i_state & I_NEW) {
		btrfs_read_locked_inode(inode);
		unlock_new_inode(inode);
	}
930

C
Chris Mason 已提交
931 932
	root_dentry = d_alloc_root(inode);
	if (!root_dentry) {
933 934 935
		iput(inode);
		return -ENOMEM;
	}
C
Chris Mason 已提交
936 937
	sb->s_root = root_dentry;

938 939 940
	return 0;
}

C
Chris Mason 已提交
941 942
static int btrfs_write_inode(struct inode *inode, int wait)
{
943
	struct btrfs_root *root = BTRFS_I(inode)->root;
C
Chris Mason 已提交
944
	struct btrfs_trans_handle *trans;
C
Chris Mason 已提交
945 946 947 948 949
	int ret = 0;

	if (wait) {
		mutex_lock(&root->fs_info->fs_mutex);
		trans = btrfs_start_transaction(root, 1);
950
		btrfs_set_trans_block_group(trans, inode);
C
Chris Mason 已提交
951 952 953 954 955 956 957 958 959 960
		ret = btrfs_commit_transaction(trans, root);
		mutex_unlock(&root->fs_info->fs_mutex);
	}
	return ret;
}

static void btrfs_dirty_inode(struct inode *inode)
{
	struct btrfs_root *root = BTRFS_I(inode)->root;
	struct btrfs_trans_handle *trans;
C
Chris Mason 已提交
961 962 963

	mutex_lock(&root->fs_info->fs_mutex);
	trans = btrfs_start_transaction(root, 1);
964
	btrfs_set_trans_block_group(trans, inode);
C
Chris Mason 已提交
965 966
	btrfs_update_inode(trans, root, inode);
	btrfs_end_transaction(trans, root);
C
Chris Mason 已提交
967
	mutex_unlock(&root->fs_info->fs_mutex);
C
Chris Mason 已提交
968
	btrfs_btree_balance_dirty(root);
C
Chris Mason 已提交
969 970
}

971
static struct inode *btrfs_new_inode(struct btrfs_trans_handle *trans,
C
Chris Mason 已提交
972
				     struct btrfs_root *root,
973 974 975
				     u64 objectid,
				     struct btrfs_block_group_cache *group,
				     int mode)
976 977 978
{
	struct inode *inode;
	struct btrfs_inode_item inode_item;
C
Chris Mason 已提交
979
	struct btrfs_key *location;
980
	int ret;
981
	int owner;
982

C
Chris Mason 已提交
983
	inode = new_inode(root->fs_info->sb);
984 985 986
	if (!inode)
		return ERR_PTR(-ENOMEM);

C
Chris Mason 已提交
987
	BTRFS_I(inode)->root = root;
988 989 990 991 992
	if (mode & S_IFDIR)
		owner = 0;
	else
		owner = 1;
	group = btrfs_find_block_group(root, group, 0, 0, owner);
993
	BTRFS_I(inode)->block_group = group;
994 995 996 997 998 999

	inode->i_uid = current->fsuid;
	inode->i_gid = current->fsgid;
	inode->i_mode = mode;
	inode->i_ino = objectid;
	inode->i_blocks = 0;
C
Chris Mason 已提交
1000
	inode->i_mtime = inode->i_atime = inode->i_ctime = CURRENT_TIME;
1001
	fill_inode_item(&inode_item, inode);
C
Chris Mason 已提交
1002 1003 1004 1005 1006
	location = &BTRFS_I(inode)->location;
	location->objectid = objectid;
	location->flags = 0;
	location->offset = 0;
	btrfs_set_key_type(location, BTRFS_INODE_ITEM_KEY);
1007 1008 1009 1010 1011 1012 1013 1014 1015 1016 1017 1018

	ret = btrfs_insert_inode(trans, root, objectid, &inode_item);
	BUG_ON(ret);

	insert_inode_hash(inode);
	return inode;
}

static int btrfs_add_link(struct btrfs_trans_handle *trans,
			    struct dentry *dentry, struct inode *inode)
{
	int ret;
1019 1020 1021 1022 1023 1024 1025 1026
	struct btrfs_key key;
	struct btrfs_root *root = BTRFS_I(dentry->d_parent->d_inode)->root;
	key.objectid = inode->i_ino;
	key.flags = 0;
	btrfs_set_key_type(&key, BTRFS_INODE_ITEM_KEY);
	key.offset = 0;

	ret = btrfs_insert_dir_item(trans, root,
1027 1028
				    dentry->d_name.name, dentry->d_name.len,
				    dentry->d_parent->d_inode->i_ino,
1029
				    &key, 0);
C
Chris Mason 已提交
1030
	if (ret == 0) {
1031
		dentry->d_parent->d_inode->i_size += dentry->d_name.len * 2;
1032
		ret = btrfs_update_inode(trans, root,
C
Chris Mason 已提交
1033 1034
					 dentry->d_parent->d_inode);
	}
1035 1036 1037 1038 1039 1040 1041 1042 1043 1044 1045
	return ret;
}

static int btrfs_add_nondir(struct btrfs_trans_handle *trans,
			    struct dentry *dentry, struct inode *inode)
{
	int err = btrfs_add_link(trans, dentry, inode);
	if (!err) {
		d_instantiate(dentry, inode);
		return 0;
	}
C
Chris Mason 已提交
1046 1047
	if (err > 0)
		err = -EEXIST;
1048 1049 1050 1051 1052 1053 1054
	return err;
}

static int btrfs_create(struct inode *dir, struct dentry *dentry,
			int mode, struct nameidata *nd)
{
	struct btrfs_trans_handle *trans;
1055
	struct btrfs_root *root = BTRFS_I(dir)->root;
1056 1057
	struct inode *inode;
	int err;
C
Chris Mason 已提交
1058
	int drop_inode = 0;
C
Chris Mason 已提交
1059
	u64 objectid;
1060

C
Chris Mason 已提交
1061
	mutex_lock(&root->fs_info->fs_mutex);
1062
	trans = btrfs_start_transaction(root, 1);
1063
	btrfs_set_trans_block_group(trans, dir);
C
Chris Mason 已提交
1064 1065 1066 1067 1068 1069 1070

	err = btrfs_find_free_objectid(trans, root, dir->i_ino, &objectid);
	if (err) {
		err = -ENOSPC;
		goto out_unlock;
	}

1071 1072
	inode = btrfs_new_inode(trans, root, objectid,
				BTRFS_I(dir)->block_group, mode);
1073 1074
	err = PTR_ERR(inode);
	if (IS_ERR(inode))
C
Chris Mason 已提交
1075
		goto out_unlock;
1076 1077

	btrfs_set_trans_block_group(trans, inode);
1078
	err = btrfs_add_nondir(trans, dentry, inode);
C
Chris Mason 已提交
1079 1080
	if (err)
		drop_inode = 1;
C
Chris Mason 已提交
1081 1082 1083 1084 1085
	else {
		inode->i_mapping->a_ops = &btrfs_aops;
		inode->i_fop = &btrfs_file_operations;
		inode->i_op = &btrfs_file_inode_operations;
	}
1086
	dir->i_sb->s_dirt = 1;
1087 1088
	btrfs_update_inode_block_group(trans, inode);
	btrfs_update_inode_block_group(trans, dir);
C
Chris Mason 已提交
1089
out_unlock:
C
Chris Mason 已提交
1090
	btrfs_end_transaction(trans, root);
C
Chris Mason 已提交
1091
	mutex_unlock(&root->fs_info->fs_mutex);
C
Chris Mason 已提交
1092

C
Chris Mason 已提交
1093 1094 1095 1096
	if (drop_inode) {
		inode_dec_link_count(inode);
		iput(inode);
	}
C
Chris Mason 已提交
1097
	btrfs_btree_balance_dirty(root);
1098 1099 1100
	return err;
}

C
Chris Mason 已提交
1101 1102 1103 1104 1105 1106 1107 1108 1109 1110 1111 1112 1113 1114 1115 1116 1117 1118 1119 1120 1121 1122 1123 1124 1125 1126 1127 1128 1129 1130 1131 1132 1133 1134 1135
static int btrfs_link(struct dentry *old_dentry, struct inode *dir,
		      struct dentry *dentry)
{
	struct btrfs_trans_handle *trans;
	struct btrfs_root *root = BTRFS_I(dir)->root;
	struct inode *inode = old_dentry->d_inode;
	int err;
	int drop_inode = 0;

	if (inode->i_nlink == 0)
		return -ENOENT;

	inc_nlink(inode);
	mutex_lock(&root->fs_info->fs_mutex);
	trans = btrfs_start_transaction(root, 1);
	btrfs_set_trans_block_group(trans, dir);
	atomic_inc(&inode->i_count);
	err = btrfs_add_nondir(trans, dentry, inode);
	if (err)
		drop_inode = 1;
	dir->i_sb->s_dirt = 1;
	btrfs_update_inode_block_group(trans, dir);
	btrfs_update_inode(trans, root, inode);

	btrfs_end_transaction(trans, root);
	mutex_unlock(&root->fs_info->fs_mutex);

	if (drop_inode) {
		inode_dec_link_count(inode);
		iput(inode);
	}
	btrfs_btree_balance_dirty(root);
	return err;
}

C
Chris Mason 已提交
1136
static int btrfs_make_empty_dir(struct btrfs_trans_handle *trans,
C
Chris Mason 已提交
1137 1138
				struct btrfs_root *root,
				u64 objectid, u64 dirid)
C
Chris Mason 已提交
1139 1140 1141
{
	int ret;
	char buf[2];
1142 1143
	struct btrfs_key key;

C
Chris Mason 已提交
1144 1145 1146
	buf[0] = '.';
	buf[1] = '.';

C
Chris Mason 已提交
1147
	key.objectid = objectid;
1148 1149 1150 1151
	key.offset = 0;
	key.flags = 0;
	btrfs_set_key_type(&key, BTRFS_INODE_ITEM_KEY);

C
Chris Mason 已提交
1152
	ret = btrfs_insert_dir_item(trans, root, buf, 1, objectid,
1153
				    &key, 1);
C
Chris Mason 已提交
1154 1155
	if (ret)
		goto error;
C
Chris Mason 已提交
1156 1157
	key.objectid = dirid;
	ret = btrfs_insert_dir_item(trans, root, buf, 2, objectid,
1158
				    &key, 1);
C
Chris Mason 已提交
1159 1160
	if (ret)
		goto error;
C
Chris Mason 已提交
1161 1162 1163 1164 1165 1166 1167 1168
error:
	return ret;
}

static int btrfs_mkdir(struct inode *dir, struct dentry *dentry, int mode)
{
	struct inode *inode;
	struct btrfs_trans_handle *trans;
1169
	struct btrfs_root *root = BTRFS_I(dir)->root;
C
Chris Mason 已提交
1170 1171
	int err = 0;
	int drop_on_err = 0;
C
Chris Mason 已提交
1172
	u64 objectid;
C
Chris Mason 已提交
1173 1174 1175

	mutex_lock(&root->fs_info->fs_mutex);
	trans = btrfs_start_transaction(root, 1);
1176
	btrfs_set_trans_block_group(trans, dir);
C
Chris Mason 已提交
1177 1178 1179 1180
	if (IS_ERR(trans)) {
		err = PTR_ERR(trans);
		goto out_unlock;
	}
C
Chris Mason 已提交
1181 1182 1183 1184 1185 1186 1187

	err = btrfs_find_free_objectid(trans, root, dir->i_ino, &objectid);
	if (err) {
		err = -ENOSPC;
		goto out_unlock;
	}

1188 1189
	inode = btrfs_new_inode(trans, root, objectid,
				BTRFS_I(dir)->block_group, S_IFDIR | mode);
C
Chris Mason 已提交
1190 1191 1192 1193 1194 1195 1196
	if (IS_ERR(inode)) {
		err = PTR_ERR(inode);
		goto out_fail;
	}
	drop_on_err = 1;
	inode->i_op = &btrfs_dir_inode_operations;
	inode->i_fop = &btrfs_dir_file_operations;
1197
	btrfs_set_trans_block_group(trans, inode);
C
Chris Mason 已提交
1198

C
Chris Mason 已提交
1199 1200 1201 1202 1203 1204
	err = btrfs_make_empty_dir(trans, root, inode->i_ino, dir->i_ino);
	if (err)
		goto out_fail;

	inode->i_size = 6;
	err = btrfs_update_inode(trans, root, inode);
C
Chris Mason 已提交
1205 1206 1207 1208 1209 1210 1211
	if (err)
		goto out_fail;
	err = btrfs_add_link(trans, dentry, inode);
	if (err)
		goto out_fail;
	d_instantiate(dentry, inode);
	drop_on_err = 0;
C
Chris Mason 已提交
1212
	dir->i_sb->s_dirt = 1;
1213 1214
	btrfs_update_inode_block_group(trans, inode);
	btrfs_update_inode_block_group(trans, dir);
C
Chris Mason 已提交
1215 1216 1217 1218 1219 1220 1221

out_fail:
	btrfs_end_transaction(trans, root);
out_unlock:
	mutex_unlock(&root->fs_info->fs_mutex);
	if (drop_on_err)
		iput(inode);
C
Chris Mason 已提交
1222
	btrfs_btree_balance_dirty(root);
C
Chris Mason 已提交
1223 1224 1225
	return err;
}

C
Chris Mason 已提交
1226 1227 1228 1229 1230 1231 1232 1233 1234 1235 1236 1237 1238 1239 1240 1241 1242 1243 1244 1245
static int btrfs_sync_file(struct file *file,
			   struct dentry *dentry, int datasync)
{
	struct inode *inode = dentry->d_inode;
	struct btrfs_root *root = BTRFS_I(inode)->root;
	int ret;
	struct btrfs_trans_handle *trans;

	mutex_lock(&root->fs_info->fs_mutex);
	trans = btrfs_start_transaction(root, 1);
	if (!trans) {
		ret = -ENOMEM;
		goto out;
	}
	ret = btrfs_commit_transaction(trans, root);
	mutex_unlock(&root->fs_info->fs_mutex);
out:
	return ret > 0 ? EIO : ret;
}

1246 1247 1248 1249 1250
static int btrfs_sync_fs(struct super_block *sb, int wait)
{
	struct btrfs_trans_handle *trans;
	struct btrfs_root *root;
	int ret;
1251
	root = btrfs_sb(sb);
1252

1253
	sb->s_dirt = 0;
C
Chris Mason 已提交
1254
	if (!wait) {
C
Chris Mason 已提交
1255
		filemap_flush(root->fs_info->btree_inode->i_mapping);
C
Chris Mason 已提交
1256 1257 1258
		return 0;
	}
	mutex_lock(&root->fs_info->fs_mutex);
1259 1260 1261 1262 1263
	trans = btrfs_start_transaction(root, 1);
	ret = btrfs_commit_transaction(trans, root);
	sb->s_dirt = 0;
	BUG_ON(ret);
printk("btrfs sync_fs\n");
C
Chris Mason 已提交
1264
	mutex_unlock(&root->fs_info->fs_mutex);
1265 1266 1267
	return 0;
}

C
Chris Mason 已提交
1268
static int btrfs_get_block_lock(struct inode *inode, sector_t iblock,
C
Chris Mason 已提交
1269 1270 1271 1272 1273 1274 1275 1276
			   struct buffer_head *result, int create)
{
	int ret;
	int err = 0;
	u64 blocknr;
	u64 extent_start = 0;
	u64 extent_end = 0;
	u64 objectid = inode->i_ino;
1277
	u32 found_type;
C
Chris Mason 已提交
1278
	u64 alloc_hint = 0;
1279
	struct btrfs_path *path;
1280
	struct btrfs_root *root = BTRFS_I(inode)->root;
C
Chris Mason 已提交
1281 1282 1283
	struct btrfs_file_extent_item *item;
	struct btrfs_leaf *leaf;
	struct btrfs_disk_key *found_key;
C
Chris Mason 已提交
1284
	struct btrfs_trans_handle *trans = NULL;
C
Chris Mason 已提交
1285

1286 1287 1288
	path = btrfs_alloc_path();
	BUG_ON(!path);
	btrfs_init_path(path);
1289 1290
	if (create) {
		WARN_ON(1);
C
Chris Mason 已提交
1291 1292 1293 1294 1295 1296 1297 1298 1299 1300 1301
		/* this almost but not quite works */
		trans = btrfs_start_transaction(root, 1);
		if (!trans) {
			err = -ENOMEM;
			goto out;
		}
		ret = drop_extents(trans, root, inode,
				   iblock << inode->i_blkbits,
				   (iblock + 1) << inode->i_blkbits,
				   &alloc_hint);
		BUG_ON(ret);
1302
	}
C
Chris Mason 已提交
1303

1304
	ret = btrfs_lookup_file_extent(NULL, root, path,
C
Chris Mason 已提交
1305
				       inode->i_ino,
1306
				       iblock << inode->i_blkbits, 0);
C
Chris Mason 已提交
1307 1308 1309 1310 1311 1312
	if (ret < 0) {
		err = ret;
		goto out;
	}

	if (ret != 0) {
1313 1314
		if (path->slots[0] == 0) {
			btrfs_release_path(root, path);
C
Chris Mason 已提交
1315
			goto not_found;
C
Chris Mason 已提交
1316
		}
1317
		path->slots[0]--;
C
Chris Mason 已提交
1318 1319
	}

1320
	item = btrfs_item_ptr(btrfs_buffer_leaf(path->nodes[0]), path->slots[0],
C
Chris Mason 已提交
1321
			      struct btrfs_file_extent_item);
1322
	leaf = btrfs_buffer_leaf(path->nodes[0]);
C
Chris Mason 已提交
1323 1324 1325 1326
	blocknr = btrfs_file_extent_disk_blocknr(item);
	blocknr += btrfs_file_extent_offset(item);

	/* are we inside the extent that was found? */
1327
	found_key = &leaf->items[path->slots[0]].key;
1328
	found_type = btrfs_disk_key_type(found_key);
C
Chris Mason 已提交
1329
	if (btrfs_disk_key_objectid(found_key) != objectid ||
1330
	    found_type != BTRFS_EXTENT_DATA_KEY) {
C
Chris Mason 已提交
1331 1332
		extent_end = 0;
		extent_start = 0;
C
Chris Mason 已提交
1333
		goto not_found;
C
Chris Mason 已提交
1334
	}
1335 1336 1337 1338 1339
	found_type = btrfs_file_extent_type(item);
	extent_start = btrfs_disk_key_offset(&leaf->items[path->slots[0]].key);
	if (found_type == BTRFS_FILE_EXTENT_REG) {
		extent_start = extent_start >> inode->i_blkbits;
		extent_end = extent_start + btrfs_file_extent_num_blocks(item);
C
Chris Mason 已提交
1340
		err = 0;
C
Chris Mason 已提交
1341
		if (btrfs_file_extent_disk_blocknr(item) == 0)
C
Chris Mason 已提交
1342
			goto out;
1343 1344 1345 1346 1347 1348 1349 1350 1351 1352 1353 1354 1355 1356
		if (iblock >= extent_start && iblock < extent_end) {
			btrfs_map_bh_to_logical(root, result, blocknr +
						iblock - extent_start);
			goto out;
		}
	} else if (found_type == BTRFS_FILE_EXTENT_INLINE) {
		char *ptr;
		char *map;
		u32 size;
		size = btrfs_file_extent_inline_len(leaf->items +
						    path->slots[0]);
		extent_end = (extent_start + size) >> inode->i_blkbits;
		extent_start >>= inode->i_blkbits;
		if (iblock < extent_start || iblock > extent_end) {
C
Chris Mason 已提交
1357
			goto not_found;
1358 1359 1360 1361 1362 1363 1364 1365 1366 1367
		}
		ptr = btrfs_file_extent_inline_start(item);
		map = kmap(result->b_page);
		memcpy(map, ptr, size);
		memset(map + size, 0, PAGE_CACHE_SIZE - size);
		flush_dcache_page(result->b_page);
		kunmap(result->b_page);
		set_buffer_uptodate(result);
		SetPageChecked(result->b_page);
		btrfs_map_bh_to_logical(root, result, 0);
C
Chris Mason 已提交
1368
	}
C
Chris Mason 已提交
1369 1370 1371 1372 1373 1374 1375 1376 1377 1378 1379 1380 1381 1382 1383
not_found:
	if (create) {
		struct btrfs_key ins;
		ret = btrfs_alloc_extent(trans, root, inode->i_ino,
					 1, alloc_hint, (u64)-1,
					 &ins, 1);
		BUG_ON(ret);
		ret = btrfs_insert_file_extent(trans, root, inode->i_ino,
					       iblock << inode->i_blkbits,
					       ins.objectid, ins.offset,
					       ins.offset);
		BUG_ON(ret);
		SetPageChecked(result->b_page);
		btrfs_map_bh_to_logical(root, result, ins.objectid);
	}
C
Chris Mason 已提交
1384
out:
C
Chris Mason 已提交
1385 1386
	if (trans)
		err = btrfs_end_transaction(trans, root);
1387
	btrfs_free_path(path);
C
Chris Mason 已提交
1388 1389 1390 1391 1392 1393 1394
	return err;
}

static int btrfs_get_block(struct inode *inode, sector_t iblock,
			   struct buffer_head *result, int create)
{
	int err;
1395
	struct btrfs_root *root = BTRFS_I(inode)->root;
C
Chris Mason 已提交
1396
	mutex_lock(&root->fs_info->fs_mutex);
1397
	err = btrfs_get_block_lock(inode, iblock, result, create);
C
Chris Mason 已提交
1398 1399 1400 1401 1402 1403 1404
	mutex_unlock(&root->fs_info->fs_mutex);
	return err;
}

static int btrfs_prepare_write(struct file *file, struct page *page,
			       unsigned from, unsigned to)
{
C
Chris Mason 已提交
1405
	return block_prepare_write(page, from, to, btrfs_get_block);
C
Chris Mason 已提交
1406 1407
}

C
Chris Mason 已提交
1408 1409 1410 1411 1412
static void btrfs_write_super(struct super_block *sb)
{
	btrfs_sync_fs(sb, 1);
}

C
Chris Mason 已提交
1413 1414 1415 1416 1417
static int btrfs_readpage(struct file *file, struct page *page)
{
	return mpage_readpage(page, btrfs_get_block);
}

1418 1419 1420 1421 1422 1423 1424 1425 1426 1427 1428 1429 1430 1431 1432 1433 1434 1435 1436 1437 1438 1439 1440 1441 1442 1443 1444 1445 1446 1447 1448 1449 1450 1451 1452 1453 1454 1455 1456 1457 1458 1459 1460 1461 1462 1463 1464 1465 1466 1467 1468 1469 1470 1471 1472 1473 1474 1475 1476 1477 1478 1479 1480 1481
/*
 * While block_write_full_page is writing back the dirty buffers under
 * the page lock, whoever dirtied the buffers may decide to clean them
 * again at any time.  We handle that by only looking at the buffer
 * state inside lock_buffer().
 *
 * If block_write_full_page() is called for regular writeback
 * (wbc->sync_mode == WB_SYNC_NONE) then it will redirty a page which has a
 * locked buffer.   This only can happen if someone has written the buffer
 * directly, with submit_bh().  At the address_space level PageWriteback
 * prevents this contention from occurring.
 */
static int __btrfs_write_full_page(struct inode *inode, struct page *page,
				   struct writeback_control *wbc)
{
	int err;
	sector_t block;
	sector_t last_block;
	struct buffer_head *bh, *head;
	const unsigned blocksize = 1 << inode->i_blkbits;
	int nr_underway = 0;

	BUG_ON(!PageLocked(page));

	last_block = (i_size_read(inode) - 1) >> inode->i_blkbits;

	if (!page_has_buffers(page)) {
		create_empty_buffers(page, blocksize,
					(1 << BH_Dirty)|(1 << BH_Uptodate));
	}

	/*
	 * Be very careful.  We have no exclusion from __set_page_dirty_buffers
	 * here, and the (potentially unmapped) buffers may become dirty at
	 * any time.  If a buffer becomes dirty here after we've inspected it
	 * then we just miss that fact, and the page stays dirty.
	 *
	 * Buffers outside i_size may be dirtied by __set_page_dirty_buffers;
	 * handle that here by just cleaning them.
	 */

	block = (sector_t)page->index << (PAGE_CACHE_SHIFT - inode->i_blkbits);
	head = page_buffers(page);
	bh = head;

	/*
	 * Get all the dirty buffers mapped to disk addresses and
	 * handle any aliases from the underlying blockdev's mapping.
	 */
	do {
		if (block > last_block) {
			/*
			 * mapped buffers outside i_size will occur, because
			 * this page can be outside i_size when there is a
			 * truncate in progress.
			 */
			/*
			 * The buffer was zeroed by block_write_full_page()
			 */
			clear_buffer_dirty(bh);
			set_buffer_uptodate(bh);
		} else if (!buffer_mapped(bh) && buffer_dirty(bh)) {
			WARN_ON(bh->b_size != blocksize);
			err = btrfs_get_block(inode, block, bh, 0);
C
Chris Mason 已提交
1482 1483
			if (err) {
printk("writepage going to recovery err %d\n", err);
1484
				goto recover;
C
Chris Mason 已提交
1485
			}
1486 1487 1488 1489 1490 1491 1492 1493 1494 1495 1496 1497 1498 1499 1500 1501 1502 1503 1504 1505 1506 1507 1508 1509 1510 1511 1512 1513 1514 1515 1516 1517 1518 1519 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 1548 1549 1550 1551 1552 1553 1554 1555 1556 1557 1558 1559 1560 1561 1562 1563 1564 1565 1566 1567 1568 1569 1570 1571 1572 1573 1574 1575 1576 1577 1578 1579 1580 1581 1582 1583 1584 1585 1586 1587 1588 1589 1590 1591 1592 1593 1594 1595 1596
			if (buffer_new(bh)) {
				/* blockdev mappings never come here */
				clear_buffer_new(bh);
			}
		}
		bh = bh->b_this_page;
		block++;
	} while (bh != head);

	do {
		if (!buffer_mapped(bh))
			continue;
		/*
		 * If it's a fully non-blocking write attempt and we cannot
		 * lock the buffer then redirty the page.  Note that this can
		 * potentially cause a busy-wait loop from pdflush and kswapd
		 * activity, but those code paths have their own higher-level
		 * throttling.
		 */
		if (wbc->sync_mode != WB_SYNC_NONE || !wbc->nonblocking) {
			lock_buffer(bh);
		} else if (test_set_buffer_locked(bh)) {
			redirty_page_for_writepage(wbc, page);
			continue;
		}
		if (test_clear_buffer_dirty(bh) && bh->b_blocknr != 0) {
			mark_buffer_async_write(bh);
		} else {
			unlock_buffer(bh);
		}
	} while ((bh = bh->b_this_page) != head);

	/*
	 * The page and its buffers are protected by PageWriteback(), so we can
	 * drop the bh refcounts early.
	 */
	BUG_ON(PageWriteback(page));
	set_page_writeback(page);

	do {
		struct buffer_head *next = bh->b_this_page;
		if (buffer_async_write(bh)) {
			submit_bh(WRITE, bh);
			nr_underway++;
		}
		bh = next;
	} while (bh != head);
	unlock_page(page);

	err = 0;
done:
	if (nr_underway == 0) {
		/*
		 * The page was marked dirty, but the buffers were
		 * clean.  Someone wrote them back by hand with
		 * ll_rw_block/submit_bh.  A rare case.
		 */
		int uptodate = 1;
		do {
			if (!buffer_uptodate(bh)) {
				uptodate = 0;
				break;
			}
			bh = bh->b_this_page;
		} while (bh != head);
		if (uptodate)
			SetPageUptodate(page);
		end_page_writeback(page);
	}
	return err;

recover:
	/*
	 * ENOSPC, or some other error.  We may already have added some
	 * blocks to the file, so we need to write these out to avoid
	 * exposing stale data.
	 * The page is currently locked and not marked for writeback
	 */
	bh = head;
	/* Recovery: lock and submit the mapped buffers */
	do {
		if (buffer_mapped(bh) && buffer_dirty(bh)) {
			lock_buffer(bh);
			mark_buffer_async_write(bh);
		} else {
			/*
			 * The buffer may have been set dirty during
			 * attachment to a dirty page.
			 */
			clear_buffer_dirty(bh);
		}
	} while ((bh = bh->b_this_page) != head);
	SetPageError(page);
	BUG_ON(PageWriteback(page));
	set_page_writeback(page);
	do {
		struct buffer_head *next = bh->b_this_page;
		if (buffer_async_write(bh)) {
			clear_buffer_dirty(bh);
			submit_bh(WRITE, bh);
			nr_underway++;
		}
		bh = next;
	} while (bh != head);
	unlock_page(page);
	goto done;
}

/*
 * The generic ->writepage function for buffer-backed address_spaces
 */
C
Chris Mason 已提交
1597 1598
static int btrfs_writepage(struct page *page, struct writeback_control *wbc)
{
1599 1600 1601 1602 1603 1604 1605 1606 1607 1608 1609 1610 1611 1612 1613 1614 1615 1616 1617 1618 1619 1620 1621 1622 1623 1624 1625 1626 1627 1628 1629 1630 1631 1632 1633
	struct inode * const inode = page->mapping->host;
	loff_t i_size = i_size_read(inode);
	const pgoff_t end_index = i_size >> PAGE_CACHE_SHIFT;
	unsigned offset;
	void *kaddr;

	/* Is the page fully inside i_size? */
	if (page->index < end_index)
		return __btrfs_write_full_page(inode, page, wbc);

	/* Is the page fully outside i_size? (truncate in progress) */
	offset = i_size & (PAGE_CACHE_SIZE-1);
	if (page->index >= end_index+1 || !offset) {
		/*
		 * The page may have dirty, unmapped buffers.  For example,
		 * they may have been added in ext3_writepage().  Make them
		 * freeable here, so the page does not leak.
		 */
		block_invalidatepage(page, 0);
		unlock_page(page);
		return 0; /* don't care */
	}

	/*
	 * The page straddles i_size.  It must be zeroed out on each and every
	 * writepage invokation because it may be mmapped.  "A file is mapped
	 * in multiples of the page size.  For a file that is not a multiple of
	 * the  page size, the remaining memory is zeroed when mapped, and
	 * writes to that region are not written out to the file."
	 */
	kaddr = kmap_atomic(page, KM_USER0);
	memset(kaddr + offset, 0, PAGE_CACHE_SIZE - offset);
	flush_dcache_page(page);
	kunmap_atomic(kaddr, KM_USER0);
	return __btrfs_write_full_page(inode, page, wbc);
C
Chris Mason 已提交
1634
}
C
Chris Mason 已提交
1635

C
Chris Mason 已提交
1636 1637
static void btrfs_truncate(struct inode *inode)
{
1638
	struct btrfs_root *root = BTRFS_I(inode)->root;
C
Chris Mason 已提交
1639 1640 1641 1642 1643 1644 1645 1646
	int ret;
	struct btrfs_trans_handle *trans;

	if (!S_ISREG(inode->i_mode))
		return;
	if (IS_APPEND(inode) || IS_IMMUTABLE(inode))
		return;

C
Chris Mason 已提交
1647
	btrfs_truncate_page(inode->i_mapping, inode->i_size);
C
Chris Mason 已提交
1648 1649 1650

	mutex_lock(&root->fs_info->fs_mutex);
	trans = btrfs_start_transaction(root, 1);
1651
	btrfs_set_trans_block_group(trans, inode);
C
Chris Mason 已提交
1652 1653

	/* FIXME, add redo link to tree so we don't leak on crash */
C
Chris Mason 已提交
1654 1655
	ret = btrfs_truncate_in_trans(trans, root, inode);
	BUG_ON(ret);
C
Chris Mason 已提交
1656
	btrfs_update_inode(trans, root, inode);
C
Chris Mason 已提交
1657 1658 1659
	ret = btrfs_end_transaction(trans, root);
	BUG_ON(ret);
	mutex_unlock(&root->fs_info->fs_mutex);
C
Chris Mason 已提交
1660
	btrfs_btree_balance_dirty(root);
C
Chris Mason 已提交
1661 1662
}

1663 1664 1665 1666 1667 1668 1669 1670 1671
static int btrfs_commit_write(struct file *file, struct page *page,
			      unsigned from, unsigned to)
{
	struct inode *inode = page->mapping->host;
	struct buffer_head *bh;
	loff_t pos = ((loff_t)page->index << PAGE_CACHE_SHIFT) + to;

	SetPageUptodate(page);
	bh = page_buffers(page);
C
Chris Mason 已提交
1672
	set_buffer_uptodate(bh);
1673 1674 1675 1676 1677 1678 1679 1680 1681 1682
	if (buffer_mapped(bh) && bh->b_blocknr != 0) {
		set_page_dirty(page);
	}
	if (pos > inode->i_size) {
		i_size_write(inode, pos);
		mark_inode_dirty(inode);
	}
	return 0;
}

C
Chris Mason 已提交
1683 1684 1685 1686 1687 1688 1689 1690 1691 1692 1693 1694 1695 1696 1697 1698 1699 1700 1701 1702 1703 1704 1705 1706 1707 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 1735 1736
static int btrfs_copy_from_user(loff_t pos, int num_pages, int write_bytes,
				struct page **prepared_pages,
				const char __user * buf)
{
	long page_fault = 0;
	int i;
	int offset = pos & (PAGE_CACHE_SIZE - 1);

	for (i = 0; i < num_pages && write_bytes > 0; i++, offset = 0) {
		size_t count = min_t(size_t,
				     PAGE_CACHE_SIZE - offset, write_bytes);
		struct page *page = prepared_pages[i];
		fault_in_pages_readable(buf, count);

		/* Copy data from userspace to the current page */
		kmap(page);
		page_fault = __copy_from_user(page_address(page) + offset,
					      buf, count);
		/* Flush processor's dcache for this page */
		flush_dcache_page(page);
		kunmap(page);
		buf += count;
		write_bytes -= count;

		if (page_fault)
			break;
	}
	return page_fault ? -EFAULT : 0;
}

static void btrfs_drop_pages(struct page **pages, size_t num_pages)
{
	size_t i;
	for (i = 0; i < num_pages; i++) {
		if (!pages[i])
			break;
		unlock_page(pages[i]);
		mark_page_accessed(pages[i]);
		page_cache_release(pages[i]);
	}
}
static int dirty_and_release_pages(struct btrfs_trans_handle *trans,
				   struct btrfs_root *root,
				   struct file *file,
				   struct page **pages,
				   size_t num_pages,
				   loff_t pos,
				   size_t write_bytes)
{
	int i;
	int offset;
	int err = 0;
	int ret;
	int this_write;
C
Chris Mason 已提交
1737
	struct inode *inode = file->f_path.dentry->d_inode;
1738 1739
	struct buffer_head *bh;
	struct btrfs_file_extent_item *ei;
C
Chris Mason 已提交
1740 1741 1742 1743

	for (i = 0; i < num_pages; i++) {
		offset = pos & (PAGE_CACHE_SIZE -1);
		this_write = min(PAGE_CACHE_SIZE - offset, write_bytes);
C
Chris Mason 已提交
1744 1745 1746 1747
		/* FIXME, one block at a time */

		mutex_lock(&root->fs_info->fs_mutex);
		trans = btrfs_start_transaction(root, 1);
1748
		btrfs_set_trans_block_group(trans, inode);
1749 1750 1751 1752 1753 1754 1755 1756 1757 1758 1759 1760 1761 1762 1763 1764 1765 1766 1767 1768 1769 1770 1771 1772 1773 1774

		bh = page_buffers(pages[i]);
		if (buffer_mapped(bh) && bh->b_blocknr == 0) {
			struct btrfs_key key;
			struct btrfs_path *path;
			char *ptr;
			u32 datasize;

			path = btrfs_alloc_path();
			BUG_ON(!path);
			key.objectid = inode->i_ino;
			key.offset = pages[i]->index << PAGE_CACHE_SHIFT;
			key.flags = 0;
			btrfs_set_key_type(&key, BTRFS_EXTENT_DATA_KEY);
			BUG_ON(write_bytes >= PAGE_CACHE_SIZE);
			datasize = offset +
				btrfs_file_extent_calc_inline_size(write_bytes);
			ret = btrfs_insert_empty_item(trans, root, path, &key,
						      datasize);
			BUG_ON(ret);
			ei = btrfs_item_ptr(btrfs_buffer_leaf(path->nodes[0]),
			       path->slots[0], struct btrfs_file_extent_item);
			btrfs_set_file_extent_generation(ei, trans->transid);
			btrfs_set_file_extent_type(ei,
						   BTRFS_FILE_EXTENT_INLINE);
			ptr = btrfs_file_extent_inline_start(ei);
1775 1776
			btrfs_memcpy(root, path->nodes[0]->b_data,
				     ptr, bh->b_data, offset + write_bytes);
1777 1778
			mark_buffer_dirty(path->nodes[0]);
			btrfs_free_path(path);
C
Chris Mason 已提交
1779
		} else if (buffer_mapped(bh)) {
1780
			btrfs_csum_file_block(trans, root, inode->i_ino,
C
Chris Mason 已提交
1781 1782
				      pages[i]->index << PAGE_CACHE_SHIFT,
				      kmap(pages[i]), PAGE_CACHE_SIZE);
1783 1784
			kunmap(pages[i]);
		}
C
Chris Mason 已提交
1785
		SetPageChecked(pages[i]);
1786
		// btrfs_update_inode_block_group(trans, inode);
C
Chris Mason 已提交
1787 1788 1789 1790
		ret = btrfs_end_transaction(trans, root);
		BUG_ON(ret);
		mutex_unlock(&root->fs_info->fs_mutex);

1791
		ret = btrfs_commit_write(file, pages[i], offset,
C
Chris Mason 已提交
1792 1793 1794 1795 1796 1797 1798 1799 1800 1801 1802 1803 1804
					 offset + this_write);
		pos += this_write;
		if (ret) {
			err = ret;
			goto failed;
		}
		WARN_ON(this_write > write_bytes);
		write_bytes -= this_write;
	}
failed:
	return err;
}

C
Chris Mason 已提交
1805 1806 1807
static int drop_extents(struct btrfs_trans_handle *trans,
			  struct btrfs_root *root,
			  struct inode *inode,
1808
			  u64 start, u64 end, u64 *hint_block)
C
Chris Mason 已提交
1809 1810 1811 1812 1813 1814
{
	int ret;
	struct btrfs_key key;
	struct btrfs_leaf *leaf;
	int slot;
	struct btrfs_file_extent_item *extent;
1815
	u64 extent_end = 0;
C
Chris Mason 已提交
1816 1817 1818 1819 1820
	int keep;
	struct btrfs_file_extent_item old;
	struct btrfs_path *path;
	u64 search_start = start;
	int bookend;
1821 1822 1823 1824
	int found_type;
	int found_extent;
	int found_inline;

C
Chris Mason 已提交
1825 1826 1827
	path = btrfs_alloc_path();
	if (!path)
		return -ENOMEM;
1828 1829 1830 1831 1832
	while(1) {
		btrfs_release_path(root, path);
		ret = btrfs_lookup_file_extent(trans, root, path, inode->i_ino,
					       search_start, -1);
		if (ret < 0)
1833
			goto out;
1834 1835
		if (ret > 0) {
			if (path->slots[0] == 0) {
1836
				ret = 0;
1837 1838 1839
				goto out;
			}
			path->slots[0]--;
1840
		}
C
Chris Mason 已提交
1841 1842
		keep = 0;
		bookend = 0;
1843 1844 1845
		found_extent = 0;
		found_inline = 0;
		extent = NULL;
C
Chris Mason 已提交
1846 1847 1848 1849 1850 1851 1852
		leaf = btrfs_buffer_leaf(path->nodes[0]);
		slot = path->slots[0];
		btrfs_disk_key_to_cpu(&key, &leaf->items[slot].key);
		if (key.offset >= end || key.objectid != inode->i_ino) {
			ret = 0;
			goto out;
		}
1853 1854 1855 1856 1857 1858 1859 1860 1861 1862 1863 1864 1865 1866 1867 1868 1869 1870 1871 1872
		if (btrfs_key_type(&key) != BTRFS_EXTENT_DATA_KEY) {
			ret = 0;
			goto out;
		}
		extent = btrfs_item_ptr(leaf, slot,
					struct btrfs_file_extent_item);
		found_type = btrfs_file_extent_type(extent);
		if (found_type == BTRFS_FILE_EXTENT_REG) {
			extent_end = key.offset +
				(btrfs_file_extent_num_blocks(extent) <<
				 inode->i_blkbits);
			found_extent = 1;
		} else if (found_type == BTRFS_FILE_EXTENT_INLINE) {
			found_inline = 1;
			extent_end = key.offset +
			     btrfs_file_extent_inline_len(leaf->items + slot);
		}

		if (!found_extent && !found_inline) {
			ret = 0;
1873
			goto out;
1874 1875 1876 1877
		}

		if (search_start >= extent_end) {
			ret = 0;
1878
			goto out;
1879 1880
		}

C
Chris Mason 已提交
1881 1882 1883 1884 1885
		if (found_inline) {
			u64 mask = root->blocksize - 1;
			search_start = (extent_end + mask) & ~mask;
		} else
			search_start = extent_end;
C
Chris Mason 已提交
1886 1887

		if (end < extent_end && end >= key.offset) {
1888
			if (found_extent) {
C
Chris Mason 已提交
1889 1890 1891 1892
				u64 disk_blocknr =
					btrfs_file_extent_disk_blocknr(extent);
				u64 disk_num_blocks =
				      btrfs_file_extent_disk_num_blocks(extent);
1893
				memcpy(&old, extent, sizeof(old));
C
Chris Mason 已提交
1894 1895 1896 1897 1898
				if (disk_blocknr != 0) {
					ret = btrfs_inc_extent_ref(trans, root,
					         disk_blocknr, disk_num_blocks);
					BUG_ON(ret);
				}
1899 1900
			}
			WARN_ON(found_inline);
C
Chris Mason 已提交
1901 1902 1903 1904 1905
			bookend = 1;
		}

		if (start > key.offset) {
			u64 new_num;
1906
			u64 old_num;
C
Chris Mason 已提交
1907 1908 1909
			/* truncate existing extent */
			keep = 1;
			WARN_ON(start & (root->blocksize - 1));
1910 1911 1912 1913
			if (found_extent) {
				new_num = (start - key.offset) >>
					inode->i_blkbits;
				old_num = btrfs_file_extent_num_blocks(extent);
1914 1915
				*hint_block =
					btrfs_file_extent_disk_blocknr(extent);
C
Chris Mason 已提交
1916 1917 1918 1919
				if (btrfs_file_extent_disk_blocknr(extent)) {
					inode->i_blocks -=
						(old_num - new_num) << 3;
				}
1920 1921 1922 1923 1924 1925
				btrfs_set_file_extent_num_blocks(extent,
								 new_num);
				mark_buffer_dirty(path->nodes[0]);
			} else {
				WARN_ON(1);
			}
C
Chris Mason 已提交
1926 1927
		}
		if (!keep) {
1928 1929 1930 1931 1932 1933 1934 1935 1936 1937
			u64 disk_blocknr = 0;
			u64 disk_num_blocks = 0;
			u64 extent_num_blocks = 0;
			if (found_extent) {
				disk_blocknr =
				      btrfs_file_extent_disk_blocknr(extent);
				disk_num_blocks =
				      btrfs_file_extent_disk_num_blocks(extent);
				extent_num_blocks =
				      btrfs_file_extent_num_blocks(extent);
1938 1939
				*hint_block =
					btrfs_file_extent_disk_blocknr(extent);
1940
			}
C
Chris Mason 已提交
1941 1942 1943
			ret = btrfs_del_item(trans, root, path);
			BUG_ON(ret);
			btrfs_release_path(root, path);
1944
			extent = NULL;
C
Chris Mason 已提交
1945
			if (found_extent && disk_blocknr != 0) {
1946
				inode->i_blocks -= extent_num_blocks << 3;
1947 1948 1949 1950
				ret = btrfs_free_extent(trans, root,
							disk_blocknr,
							disk_num_blocks, 0);
			}
C
Chris Mason 已提交
1951 1952 1953 1954 1955 1956 1957

			BUG_ON(ret);
			if (!bookend && search_start >= end) {
				ret = 0;
				goto out;
			}
			if (!bookend)
1958
				continue;
C
Chris Mason 已提交
1959
		}
1960
		if (bookend && found_extent) {
C
Chris Mason 已提交
1961 1962 1963 1964 1965 1966 1967 1968 1969 1970 1971 1972 1973 1974 1975 1976 1977 1978 1979 1980 1981 1982 1983 1984
			/* create bookend */
			struct btrfs_key ins;
			ins.objectid = inode->i_ino;
			ins.offset = end;
			ins.flags = 0;
			btrfs_set_key_type(&ins, BTRFS_EXTENT_DATA_KEY);

			btrfs_release_path(root, path);
			ret = btrfs_insert_empty_item(trans, root, path, &ins,
						      sizeof(*extent));
			BUG_ON(ret);
			extent = btrfs_item_ptr(
				    btrfs_buffer_leaf(path->nodes[0]),
				    path->slots[0],
				    struct btrfs_file_extent_item);
			btrfs_set_file_extent_disk_blocknr(extent,
				    btrfs_file_extent_disk_blocknr(&old));
			btrfs_set_file_extent_disk_num_blocks(extent,
				    btrfs_file_extent_disk_num_blocks(&old));

			btrfs_set_file_extent_offset(extent,
				    btrfs_file_extent_offset(&old) +
				    ((end - key.offset) >> inode->i_blkbits));
			WARN_ON(btrfs_file_extent_num_blocks(&old) <
C
Chris Mason 已提交
1985
				(extent_end - end) >> inode->i_blkbits);
C
Chris Mason 已提交
1986
			btrfs_set_file_extent_num_blocks(extent,
C
Chris Mason 已提交
1987
				    (extent_end - end) >> inode->i_blkbits);
C
Chris Mason 已提交
1988

1989 1990
			btrfs_set_file_extent_type(extent,
						   BTRFS_FILE_EXTENT_REG);
C
Chris Mason 已提交
1991 1992 1993
			btrfs_set_file_extent_generation(extent,
				    btrfs_file_extent_generation(&old));
			btrfs_mark_buffer_dirty(path->nodes[0]);
C
Chris Mason 已提交
1994 1995 1996 1997
			if (btrfs_file_extent_disk_blocknr(&old) != 0) {
				inode->i_blocks +=
				      btrfs_file_extent_num_blocks(extent) << 3;
			}
C
Chris Mason 已提交
1998
			ret = 0;
1999
			goto out;
C
Chris Mason 已提交
2000 2001 2002 2003 2004 2005 2006 2007
		}
	}
out:
	btrfs_free_path(path);
	return ret;
}

static int prepare_pages(struct btrfs_root *root,
C
Chris Mason 已提交
2008 2009 2010 2011
			 struct file *file,
			 struct page **pages,
			 size_t num_pages,
			 loff_t pos,
2012 2013
			 unsigned long first_index,
			 unsigned long last_index,
2014 2015
			 size_t write_bytes,
			 u64 alloc_extent_start)
C
Chris Mason 已提交
2016 2017 2018 2019 2020 2021 2022
{
	int i;
	unsigned long index = pos >> PAGE_CACHE_SHIFT;
	struct inode *inode = file->f_path.dentry->d_inode;
	int offset;
	int err = 0;
	int this_write;
2023 2024
	struct buffer_head *bh;
	struct buffer_head *head;
C
Chris Mason 已提交
2025 2026 2027 2028 2029 2030 2031 2032 2033 2034
	loff_t isize = i_size_read(inode);

	memset(pages, 0, num_pages * sizeof(struct page *));

	for (i = 0; i < num_pages; i++) {
		pages[i] = grab_cache_page(inode->i_mapping, index + i);
		if (!pages[i]) {
			err = -ENOMEM;
			goto failed_release;
		}
C
Chris Mason 已提交
2035 2036
		cancel_dirty_page(pages[i], PAGE_CACHE_SIZE);
		wait_on_page_writeback(pages[i]);
C
Chris Mason 已提交
2037 2038
		offset = pos & (PAGE_CACHE_SIZE -1);
		this_write = min(PAGE_CACHE_SIZE - offset, write_bytes);
C
Chris Mason 已提交
2039 2040 2041 2042 2043
		if (!page_has_buffers(pages[i])) {
			create_empty_buffers(pages[i],
					     root->fs_info->sb->s_blocksize,
					     (1 << BH_Uptodate));
		}
2044 2045 2046 2047 2048 2049 2050 2051 2052
		head = page_buffers(pages[i]);
		bh = head;
		do {
			err = btrfs_map_bh_to_logical(root, bh,
						      alloc_extent_start);
			BUG_ON(err);
			if (err)
				goto failed_truncate;
			bh = bh->b_this_page;
2053 2054
			if (alloc_extent_start)
				alloc_extent_start++;
2055
		} while (bh != head);
C
Chris Mason 已提交
2056 2057 2058 2059 2060 2061 2062 2063 2064 2065 2066 2067 2068 2069 2070 2071 2072 2073 2074 2075 2076 2077 2078 2079 2080
		pos += this_write;
		WARN_ON(this_write > write_bytes);
		write_bytes -= this_write;
	}
	return 0;

failed_release:
	btrfs_drop_pages(pages, num_pages);
	return err;

failed_truncate:
	btrfs_drop_pages(pages, num_pages);
	if (pos > isize)
		vmtruncate(inode, isize);
	return err;
}

static ssize_t btrfs_file_write(struct file *file, const char __user *buf,
				size_t count, loff_t *ppos)
{
	loff_t pos;
	size_t num_written = 0;
	int err = 0;
	int ret = 0;
	struct inode *inode = file->f_path.dentry->d_inode;
2081
	struct btrfs_root *root = BTRFS_I(inode)->root;
C
Chris Mason 已提交
2082
	struct page *pages[8];
C
Chris Mason 已提交
2083
	struct page *pinned[2];
2084 2085
	unsigned long first_index;
	unsigned long last_index;
2086 2087 2088
	u64 start_pos;
	u64 num_blocks;
	u64 alloc_extent_start;
2089
	u64 hint_block;
2090
	struct btrfs_trans_handle *trans;
C
Chris Mason 已提交
2091
	struct btrfs_key ins;
C
Chris Mason 已提交
2092 2093
	pinned[0] = NULL;
	pinned[1] = NULL;
C
Chris Mason 已提交
2094 2095 2096 2097 2098 2099 2100 2101 2102 2103 2104 2105 2106 2107
	if (file->f_flags & O_DIRECT)
		return -EINVAL;
	pos = *ppos;
	vfs_check_frozen(inode->i_sb, SB_FREEZE_WRITE);
	current->backing_dev_info = inode->i_mapping->backing_dev_info;
	err = generic_write_checks(file, &pos, &count, S_ISBLK(inode->i_mode));
	if (err)
		goto out;
	if (count == 0)
		goto out;
	err = remove_suid(file->f_path.dentry);
	if (err)
		goto out;
	file_update_time(file);
2108 2109 2110 2111 2112

	start_pos = pos & ~((u64)PAGE_CACHE_SIZE - 1);
	num_blocks = (count + pos - start_pos + root->blocksize - 1) >>
			inode->i_blkbits;

C
Chris Mason 已提交
2113
	mutex_lock(&inode->i_mutex);
2114 2115
	first_index = pos >> PAGE_CACHE_SHIFT;
	last_index = (pos + count) >> PAGE_CACHE_SHIFT;
2116

C
Chris Mason 已提交
2117
	if ((pos & (PAGE_CACHE_SIZE - 1))) {
2118 2119 2120 2121
		pinned[0] = grab_cache_page(inode->i_mapping, first_index);
		if (!PageUptodate(pinned[0])) {
			ret = mpage_readpage(pinned[0], btrfs_get_block);
			BUG_ON(ret);
C
Chris Mason 已提交
2122
			wait_on_page_locked(pinned[0]);
2123 2124 2125 2126
		} else {
			unlock_page(pinned[0]);
		}
	}
C
Chris Mason 已提交
2127
	if ((pos + count) & (PAGE_CACHE_SIZE - 1)) {
2128 2129 2130 2131
		pinned[1] = grab_cache_page(inode->i_mapping, last_index);
		if (!PageUptodate(pinned[1])) {
			ret = mpage_readpage(pinned[1], btrfs_get_block);
			BUG_ON(ret);
C
Chris Mason 已提交
2132
			wait_on_page_locked(pinned[1]);
2133 2134 2135 2136 2137
		} else {
			unlock_page(pinned[1]);
		}
	}

2138 2139 2140 2141
	mutex_lock(&root->fs_info->fs_mutex);
	trans = btrfs_start_transaction(root, 1);
	if (!trans) {
		err = -ENOMEM;
C
Chris Mason 已提交
2142
		mutex_unlock(&root->fs_info->fs_mutex);
2143 2144
		goto out_unlock;
	}
2145
	btrfs_set_trans_block_group(trans, inode);
2146 2147
	/* FIXME blocksize != 4096 */
	inode->i_blocks += num_blocks << 3;
2148
	hint_block = 0;
C
Chris Mason 已提交
2149
	if (start_pos < inode->i_size) {
2150
		/* FIXME blocksize != pagesize */
C
Chris Mason 已提交
2151 2152 2153
		ret = drop_extents(trans, root, inode,
				   start_pos,
				   (pos + count + root->blocksize -1) &
2154
				   ~((u64)root->blocksize - 1), &hint_block);
2155
		BUG_ON(ret);
C
Chris Mason 已提交
2156
	}
C
Chris Mason 已提交
2157 2158 2159 2160 2161 2162 2163 2164 2165 2166 2167 2168 2169 2170 2171
	if (inode->i_size < start_pos) {
		u64 last_pos_in_file;
		u64 hole_size;
		u64 mask = root->blocksize - 1;
		last_pos_in_file = (inode->i_size + mask) & ~mask;
		hole_size = (start_pos - last_pos_in_file + mask) & ~mask;
		hole_size >>= inode->i_blkbits;
		if (last_pos_in_file < start_pos) {
			ret = btrfs_insert_file_extent(trans, root,
						       inode->i_ino,
						       last_pos_in_file,
						       0, 0, hole_size);
		}
		BUG_ON(ret);
	}
2172 2173
	if (inode->i_size >= PAGE_CACHE_SIZE || pos + count < inode->i_size ||
	    pos + count - start_pos > BTRFS_MAX_INLINE_DATA_SIZE(root)) {
2174
		ret = btrfs_alloc_extent(trans, root, inode->i_ino,
2175 2176
					 num_blocks, hint_block, (u64)-1,
					 &ins, 1);
2177 2178
		BUG_ON(ret);
		ret = btrfs_insert_file_extent(trans, root, inode->i_ino,
C
Chris Mason 已提交
2179 2180
				       start_pos, ins.objectid, ins.offset,
				       ins.offset);
2181 2182 2183 2184 2185
		BUG_ON(ret);
	} else {
		ins.offset = 0;
		ins.objectid = 0;
	}
2186
	BUG_ON(ret);
C
Chris Mason 已提交
2187
	alloc_extent_start = ins.objectid;
2188
	// btrfs_update_inode_block_group(trans, inode);
C
Chris Mason 已提交
2189
	ret = btrfs_end_transaction(trans, root);
2190 2191
	mutex_unlock(&root->fs_info->fs_mutex);

C
Chris Mason 已提交
2192 2193 2194 2195 2196
	while(count > 0) {
		size_t offset = pos & (PAGE_CACHE_SIZE - 1);
		size_t write_bytes = min(count, PAGE_CACHE_SIZE - offset);
		size_t num_pages = (write_bytes + PAGE_CACHE_SIZE - 1) >>
					PAGE_CACHE_SHIFT;
C
Chris Mason 已提交
2197 2198 2199

		memset(pages, 0, sizeof(pages));
		ret = prepare_pages(root, file, pages, num_pages,
2200 2201
				    pos, first_index, last_index,
				    write_bytes, alloc_extent_start);
C
Chris Mason 已提交
2202
		BUG_ON(ret);
C
Chris Mason 已提交
2203

2204
		/* FIXME blocks != pagesize */
2205 2206
		if (alloc_extent_start)
			alloc_extent_start += num_pages;
C
Chris Mason 已提交
2207 2208 2209 2210
		ret = btrfs_copy_from_user(pos, num_pages,
					   write_bytes, pages, buf);
		BUG_ON(ret);

C
Chris Mason 已提交
2211
		ret = dirty_and_release_pages(NULL, root, file, pages,
2212
					      num_pages, pos, write_bytes);
C
Chris Mason 已提交
2213 2214 2215 2216 2217 2218 2219 2220 2221
		BUG_ON(ret);
		btrfs_drop_pages(pages, num_pages);

		buf += write_bytes;
		count -= write_bytes;
		pos += write_bytes;
		num_written += write_bytes;

		balance_dirty_pages_ratelimited(inode->i_mapping);
C
Chris Mason 已提交
2222
		btrfs_btree_balance_dirty(root);
C
Chris Mason 已提交
2223 2224
		cond_resched();
	}
2225
out_unlock:
C
Chris Mason 已提交
2226 2227
	mutex_unlock(&inode->i_mutex);
out:
2228 2229 2230 2231
	if (pinned[0])
		page_cache_release(pinned[0]);
	if (pinned[1])
		page_cache_release(pinned[1]);
C
Chris Mason 已提交
2232 2233
	*ppos = pos;
	current->backing_dev_info = NULL;
2234
	mark_inode_dirty(inode);
C
Chris Mason 已提交
2235 2236 2237
	return num_written ? num_written : err;
}

C
Chris Mason 已提交
2238 2239 2240 2241 2242
static int btrfs_read_actor(read_descriptor_t *desc, struct page *page,
			unsigned long offset, unsigned long size)
{
	char *kaddr;
	unsigned long left, count = desc->count;
2243
	struct inode *inode = page->mapping->host;
C
Chris Mason 已提交
2244 2245 2246 2247 2248 2249

	if (size > count)
		size = count;

	if (!PageChecked(page)) {
		/* FIXME, do it per block */
2250
		struct btrfs_root *root = BTRFS_I(inode)->root;
C
Chris Mason 已提交
2251 2252 2253 2254 2255 2256 2257 2258 2259 2260
		int ret;
		struct buffer_head *bh;

		if (page_has_buffers(page)) {
			bh = page_buffers(page);
			if (!buffer_mapped(bh)) {
				SetPageChecked(page);
				goto checked;
			}
		}
2261

C
Chris Mason 已提交
2262
		ret = btrfs_csum_verify_file_block(root,
2263 2264 2265
				  page->mapping->host->i_ino,
				  page->index << PAGE_CACHE_SHIFT,
				  kmap(page), PAGE_CACHE_SIZE);
C
Chris Mason 已提交
2266
		if (ret) {
C
Chris Mason 已提交
2267
			if (ret != -ENOENT) {
C
Chris Mason 已提交
2268
				printk("failed to verify ino %lu page %lu ret %d\n",
C
Chris Mason 已提交
2269
				       page->mapping->host->i_ino,
C
Chris Mason 已提交
2270 2271
				       page->index, ret);
				memset(page_address(page), 1, PAGE_CACHE_SIZE);
C
Chris Mason 已提交
2272 2273
				flush_dcache_page(page);
			}
C
Chris Mason 已提交
2274 2275 2276 2277
		}
		SetPageChecked(page);
		kunmap(page);
	}
C
Chris Mason 已提交
2278
checked:
C
Chris Mason 已提交
2279 2280 2281 2282 2283 2284 2285 2286 2287 2288 2289 2290 2291 2292 2293 2294 2295 2296 2297 2298 2299 2300 2301 2302 2303 2304 2305 2306 2307 2308 2309 2310 2311 2312 2313 2314 2315 2316 2317 2318 2319 2320 2321 2322 2323 2324 2325 2326 2327 2328 2329 2330 2331 2332 2333 2334 2335 2336 2337 2338 2339 2340 2341 2342 2343 2344 2345 2346 2347 2348 2349 2350 2351 2352 2353 2354 2355 2356 2357 2358 2359 2360 2361 2362 2363 2364 2365
	/*
	 * Faults on the destination of a read are common, so do it before
	 * taking the kmap.
	 */
	if (!fault_in_pages_writeable(desc->arg.buf, size)) {
		kaddr = kmap_atomic(page, KM_USER0);
		left = __copy_to_user_inatomic(desc->arg.buf,
						kaddr + offset, size);
		kunmap_atomic(kaddr, KM_USER0);
		if (left == 0)
			goto success;
	}

	/* Do it the slow way */
	kaddr = kmap(page);
	left = __copy_to_user(desc->arg.buf, kaddr + offset, size);
	kunmap(page);

	if (left) {
		size -= left;
		desc->error = -EFAULT;
	}
success:
	desc->count = count - size;
	desc->written += size;
	desc->arg.buf += size;
	return size;
}

/**
 * btrfs_file_aio_read - filesystem read routine
 * @iocb:	kernel I/O control block
 * @iov:	io vector request
 * @nr_segs:	number of segments in the iovec
 * @pos:	current file position
 */
static ssize_t btrfs_file_aio_read(struct kiocb *iocb, const struct iovec *iov,
				   unsigned long nr_segs, loff_t pos)
{
	struct file *filp = iocb->ki_filp;
	ssize_t retval;
	unsigned long seg;
	size_t count;
	loff_t *ppos = &iocb->ki_pos;

	count = 0;
	for (seg = 0; seg < nr_segs; seg++) {
		const struct iovec *iv = &iov[seg];

		/*
		 * If any segment has a negative length, or the cumulative
		 * length ever wraps negative then return -EINVAL.
		 */
		count += iv->iov_len;
		if (unlikely((ssize_t)(count|iv->iov_len) < 0))
			return -EINVAL;
		if (access_ok(VERIFY_WRITE, iv->iov_base, iv->iov_len))
			continue;
		if (seg == 0)
			return -EFAULT;
		nr_segs = seg;
		count -= iv->iov_len;	/* This segment is no good */
		break;
	}
	retval = 0;
	if (count) {
		for (seg = 0; seg < nr_segs; seg++) {
			read_descriptor_t desc;

			desc.written = 0;
			desc.arg.buf = iov[seg].iov_base;
			desc.count = iov[seg].iov_len;
			if (desc.count == 0)
				continue;
			desc.error = 0;
			do_generic_file_read(filp, ppos, &desc,
					     btrfs_read_actor);
			retval += desc.written;
			if (desc.error) {
				retval = retval ?: desc.error;
				break;
			}
		}
	}
	return retval;
}

C
Chris Mason 已提交
2366 2367 2368 2369 2370 2371 2372 2373 2374 2375
static int create_subvol(struct btrfs_root *root, char *name, int namelen)
{
	struct btrfs_trans_handle *trans;
	struct btrfs_key key;
	struct btrfs_root_item root_item;
	struct btrfs_inode_item *inode_item;
	struct buffer_head *subvol;
	struct btrfs_leaf *leaf;
	struct btrfs_root *new_root;
	struct inode *inode;
2376
	struct inode *dir;
C
Chris Mason 已提交
2377 2378 2379 2380 2381 2382 2383 2384
	int ret;
	u64 objectid;
	u64 new_dirid = BTRFS_FIRST_FREE_OBJECTID;

	mutex_lock(&root->fs_info->fs_mutex);
	trans = btrfs_start_transaction(root, 1);
	BUG_ON(!trans);

2385
	subvol = btrfs_alloc_free_block(trans, root, 0);
C
Chris Mason 已提交
2386 2387
	if (subvol == NULL)
		return -ENOSPC;
C
Chris Mason 已提交
2388 2389 2390
	leaf = btrfs_buffer_leaf(subvol);
	btrfs_set_header_nritems(&leaf->header, 0);
	btrfs_set_header_level(&leaf->header, 0);
2391
	btrfs_set_header_blocknr(&leaf->header, bh_blocknr(subvol));
C
Chris Mason 已提交
2392
	btrfs_set_header_generation(&leaf->header, trans->transid);
2393
	btrfs_set_header_owner(&leaf->header, root->root_key.objectid);
C
Chris Mason 已提交
2394 2395
	memcpy(leaf->header.fsid, root->fs_info->disk_super->fsid,
	       sizeof(leaf->header.fsid));
2396
	mark_buffer_dirty(subvol);
C
Chris Mason 已提交
2397 2398 2399 2400 2401 2402 2403 2404 2405

	inode_item = &root_item.inode;
	memset(inode_item, 0, sizeof(*inode_item));
	btrfs_set_inode_generation(inode_item, 1);
	btrfs_set_inode_size(inode_item, 3);
	btrfs_set_inode_nlink(inode_item, 1);
	btrfs_set_inode_nblocks(inode_item, 1);
	btrfs_set_inode_mode(inode_item, S_IFDIR | 0755);

2406
	btrfs_set_root_blocknr(&root_item, bh_blocknr(subvol));
C
Chris Mason 已提交
2407
	btrfs_set_root_refs(&root_item, 1);
C
Chris Mason 已提交
2408 2409
	brelse(subvol);
	subvol = NULL;
C
Chris Mason 已提交
2410 2411 2412 2413 2414 2415 2416 2417 2418 2419 2420 2421 2422 2423 2424 2425 2426 2427 2428

	ret = btrfs_find_free_objectid(trans, root->fs_info->tree_root,
				       0, &objectid);
	BUG_ON(ret);

	btrfs_set_root_dirid(&root_item, new_dirid);

	key.objectid = objectid;
	key.offset = 1;
	key.flags = 0;
	btrfs_set_key_type(&key, BTRFS_ROOT_ITEM_KEY);
	ret = btrfs_insert_root(trans, root->fs_info->tree_root, &key,
				&root_item);
	BUG_ON(ret);

	/*
	 * insert the directory item
	 */
	key.offset = (u64)-1;
2429
	dir = root->fs_info->sb->s_root->d_inode;
C
Chris Mason 已提交
2430
	ret = btrfs_insert_dir_item(trans, root->fs_info->tree_root,
2431
				    name, namelen, dir->i_ino, &key, 0);
C
Chris Mason 已提交
2432 2433 2434 2435 2436 2437 2438 2439 2440 2441 2442
	BUG_ON(ret);

	ret = btrfs_commit_transaction(trans, root);
	BUG_ON(ret);

	new_root = btrfs_read_fs_root(root->fs_info, &key);
	BUG_ON(!new_root);

	trans = btrfs_start_transaction(new_root, 1);
	BUG_ON(!trans);

2443 2444
	inode = btrfs_new_inode(trans, new_root, new_dirid,
				BTRFS_I(dir)->block_group, S_IFDIR | 0700);
C
Chris Mason 已提交
2445 2446 2447 2448 2449 2450 2451 2452 2453 2454 2455 2456 2457 2458 2459 2460 2461
	inode->i_op = &btrfs_dir_inode_operations;
	inode->i_fop = &btrfs_dir_file_operations;

	ret = btrfs_make_empty_dir(trans, new_root, new_dirid, new_dirid);
	BUG_ON(ret);

	inode->i_nlink = 1;
	inode->i_size = 6;
	ret = btrfs_update_inode(trans, new_root, inode);
	BUG_ON(ret);

	ret = btrfs_commit_transaction(trans, new_root);
	BUG_ON(ret);

	iput(inode);

	mutex_unlock(&root->fs_info->fs_mutex);
C
Chris Mason 已提交
2462
	btrfs_btree_balance_dirty(root);
C
Chris Mason 已提交
2463 2464 2465
	return 0;
}

C
Chris Mason 已提交
2466 2467 2468 2469 2470 2471 2472 2473
static int create_snapshot(struct btrfs_root *root, char *name, int namelen)
{
	struct btrfs_trans_handle *trans;
	struct btrfs_key key;
	struct btrfs_root_item new_root_item;
	int ret;
	u64 objectid;

C
Chris Mason 已提交
2474 2475 2476
	if (!root->ref_cows)
		return -EINVAL;

C
Chris Mason 已提交
2477 2478 2479 2480 2481 2482 2483
	mutex_lock(&root->fs_info->fs_mutex);
	trans = btrfs_start_transaction(root, 1);
	BUG_ON(!trans);

	ret = btrfs_update_inode(trans, root, root->inode);
	BUG_ON(ret);

C
Chris Mason 已提交
2484 2485
	ret = btrfs_find_free_objectid(trans, root->fs_info->tree_root,
				       0, &objectid);
C
Chris Mason 已提交
2486 2487 2488 2489 2490 2491 2492 2493 2494
	BUG_ON(ret);

	memcpy(&new_root_item, &root->root_item,
	       sizeof(new_root_item));

	key.objectid = objectid;
	key.offset = 1;
	key.flags = 0;
	btrfs_set_key_type(&key, BTRFS_ROOT_ITEM_KEY);
2495
	btrfs_set_root_blocknr(&new_root_item, bh_blocknr(root->node));
C
Chris Mason 已提交
2496 2497 2498 2499 2500 2501 2502 2503 2504 2505 2506 2507 2508 2509 2510 2511 2512 2513 2514 2515 2516 2517

	ret = btrfs_insert_root(trans, root->fs_info->tree_root, &key,
				&new_root_item);
	BUG_ON(ret);

	/*
	 * insert the directory item
	 */
	key.offset = (u64)-1;
	ret = btrfs_insert_dir_item(trans, root->fs_info->tree_root,
				    name, namelen,
				    root->fs_info->sb->s_root->d_inode->i_ino,
				    &key, 0);

	BUG_ON(ret);

	ret = btrfs_inc_root_ref(trans, root);
	BUG_ON(ret);

	ret = btrfs_commit_transaction(trans, root);
	BUG_ON(ret);
	mutex_unlock(&root->fs_info->fs_mutex);
C
Chris Mason 已提交
2518
	btrfs_btree_balance_dirty(root);
C
Chris Mason 已提交
2519 2520 2521
	return 0;
}

2522 2523 2524 2525 2526 2527 2528 2529 2530 2531 2532 2533
static int add_disk(struct btrfs_root *root, char *name, int namelen)
{
	struct block_device *bdev;
	struct btrfs_path *path;
	struct super_block *sb = root->fs_info->sb;
	struct btrfs_root *dev_root = root->fs_info->dev_root;
	struct btrfs_trans_handle *trans;
	struct btrfs_device_item *dev_item;
	struct btrfs_key key;
	u16 item_size;
	u64 num_blocks;
	u64 new_blocks;
2534
	u64 device_id;
2535
	int ret;
2536

2537 2538 2539 2540 2541 2542 2543 2544 2545 2546 2547 2548 2549 2550 2551 2552 2553 2554 2555 2556 2557 2558 2559 2560 2561 2562 2563 2564 2565 2566 2567 2568 2569 2570
printk("adding disk %s\n", name);
	path = btrfs_alloc_path();
	if (!path)
		return -ENOMEM;
	num_blocks = btrfs_super_total_blocks(root->fs_info->disk_super);
	bdev = open_bdev_excl(name, O_RDWR, sb);
	if (IS_ERR(bdev)) {
		ret = PTR_ERR(bdev);
printk("open bdev excl failed ret %d\n", ret);
		goto out_nolock;
	}
	set_blocksize(bdev, sb->s_blocksize);
	new_blocks = bdev->bd_inode->i_size >> sb->s_blocksize_bits;
	key.objectid = num_blocks;
	key.offset = new_blocks;
	key.flags = 0;
	btrfs_set_key_type(&key, BTRFS_DEV_ITEM_KEY);

	mutex_lock(&dev_root->fs_info->fs_mutex);
	trans = btrfs_start_transaction(dev_root, 1);
	item_size = sizeof(*dev_item) + namelen;
printk("insert empty on %Lu %Lu %u size %d\n", num_blocks, new_blocks, key.flags, item_size);
	ret = btrfs_insert_empty_item(trans, dev_root, path, &key, item_size);
	if (ret) {
printk("insert failed %d\n", ret);
		close_bdev_excl(bdev);
		if (ret > 0)
			ret = -EEXIST;
		goto out;
	}
	dev_item = btrfs_item_ptr(btrfs_buffer_leaf(path->nodes[0]),
				  path->slots[0], struct btrfs_device_item);
	btrfs_set_device_pathlen(dev_item, namelen);
	memcpy(dev_item + 1, name, namelen);
2571 2572 2573 2574

	device_id = btrfs_super_last_device_id(root->fs_info->disk_super) + 1;
	btrfs_set_super_last_device_id(root->fs_info->disk_super, device_id);
	btrfs_set_device_id(dev_item, device_id);
2575 2576
	mark_buffer_dirty(path->nodes[0]);

2577 2578
	ret = btrfs_insert_dev_radix(root, bdev, device_id, num_blocks,
				     new_blocks);
2579 2580 2581 2582 2583 2584 2585 2586 2587 2588 2589 2590 2591 2592 2593

	if (!ret) {
		btrfs_set_super_total_blocks(root->fs_info->disk_super,
					     num_blocks + new_blocks);
		i_size_write(root->fs_info->btree_inode,
			     (num_blocks + new_blocks) <<
			     root->fs_info->btree_inode->i_blkbits);
	}

out:
	ret = btrfs_commit_transaction(trans, dev_root);
	BUG_ON(ret);
	mutex_unlock(&root->fs_info->fs_mutex);
out_nolock:
	btrfs_free_path(path);
C
Chris Mason 已提交
2594
	btrfs_btree_balance_dirty(root);
2595 2596 2597 2598

	return ret;
}

C
Chris Mason 已提交
2599 2600 2601 2602 2603
static int btrfs_ioctl(struct inode *inode, struct file *filp, unsigned int
		       cmd, unsigned long arg)
{
	struct btrfs_root *root = BTRFS_I(inode)->root;
	struct btrfs_ioctl_vol_args vol_args;
2604
	int ret = 0;
2605
	struct btrfs_dir_item *di;
C
Chris Mason 已提交
2606
	int namelen;
C
Chris Mason 已提交
2607 2608
	struct btrfs_path *path;
	u64 root_dirid;
C
Chris Mason 已提交
2609 2610 2611 2612 2613 2614 2615 2616 2617 2618

	switch (cmd) {
	case BTRFS_IOC_SNAP_CREATE:
		if (copy_from_user(&vol_args,
				   (struct btrfs_ioctl_vol_args __user *)arg,
				   sizeof(vol_args)))
			return -EFAULT;
		namelen = strlen(vol_args.name);
		if (namelen > BTRFS_VOL_NAME_MAX)
			return -EINVAL;
C
Chris Mason 已提交
2619 2620 2621
		path = btrfs_alloc_path();
		if (!path)
			return -ENOMEM;
2622
		root_dirid = root->fs_info->sb->s_root->d_inode->i_ino,
C
Chris Mason 已提交
2623
		mutex_lock(&root->fs_info->fs_mutex);
2624
		di = btrfs_lookup_dir_item(NULL, root->fs_info->tree_root,
C
Chris Mason 已提交
2625 2626 2627
				    path, root_dirid,
				    vol_args.name, namelen, 0);
		mutex_unlock(&root->fs_info->fs_mutex);
2628
		btrfs_free_path(path);
2629
		if (di && !IS_ERR(di))
C
Chris Mason 已提交
2630 2631 2632 2633 2634 2635
			return -EEXIST;

		if (root == root->fs_info->tree_root)
			ret = create_subvol(root, vol_args.name, namelen);
		else
			ret = create_snapshot(root, vol_args.name, namelen);
C
Chris Mason 已提交
2636 2637
		WARN_ON(ret);
		break;
2638 2639 2640 2641 2642 2643 2644 2645 2646 2647 2648
	case BTRFS_IOC_ADD_DISK:
		if (copy_from_user(&vol_args,
				   (struct btrfs_ioctl_vol_args __user *)arg,
				   sizeof(vol_args)))
			return -EFAULT;
		namelen = strlen(vol_args.name);
		if (namelen > BTRFS_VOL_NAME_MAX)
			return -EINVAL;
		vol_args.name[namelen] = '\0';
		ret = add_disk(root, vol_args.name, namelen);
		break;
C
Chris Mason 已提交
2649 2650 2651
	default:
		return -ENOTTY;
	}
2652
	return ret;
C
Chris Mason 已提交
2653 2654
}

C
Chris Mason 已提交
2655 2656 2657 2658 2659 2660 2661 2662 2663 2664 2665 2666 2667 2668 2669 2670 2671 2672 2673 2674 2675 2676 2677 2678 2679 2680 2681 2682 2683 2684 2685 2686
static struct kmem_cache *btrfs_inode_cachep;
struct kmem_cache *btrfs_trans_handle_cachep;
struct kmem_cache *btrfs_transaction_cachep;
struct kmem_cache *btrfs_bit_radix_cachep;
struct kmem_cache *btrfs_path_cachep;

/*
 * Called inside transaction, so use GFP_NOFS
 */
static struct inode *btrfs_alloc_inode(struct super_block *sb)
{
	struct btrfs_inode *ei;

	ei = kmem_cache_alloc(btrfs_inode_cachep, GFP_NOFS);
	if (!ei)
		return NULL;
	return &ei->vfs_inode;
}

static void btrfs_destroy_inode(struct inode *inode)
{
	WARN_ON(!list_empty(&inode->i_dentry));
	WARN_ON(inode->i_data.nrpages);

	kmem_cache_free(btrfs_inode_cachep, BTRFS_I(inode));
}

static void init_once(void * foo, struct kmem_cache * cachep,
		      unsigned long flags)
{
	struct btrfs_inode *ei = (struct btrfs_inode *) foo;

C
Chris Mason 已提交
2687
	if ((flags & (SLAB_CTOR_CONSTRUCTOR)) ==
C
Chris Mason 已提交
2688 2689 2690 2691 2692 2693 2694 2695 2696 2697 2698 2699 2700 2701 2702 2703 2704 2705 2706 2707 2708 2709 2710 2711 2712 2713 2714 2715 2716 2717 2718 2719 2720 2721 2722 2723 2724 2725 2726 2727 2728 2729 2730 2731 2732 2733 2734 2735
	    SLAB_CTOR_CONSTRUCTOR) {
		inode_init_once(&ei->vfs_inode);
	}
}

static int init_inodecache(void)
{
	btrfs_inode_cachep = kmem_cache_create("btrfs_inode_cache",
					     sizeof(struct btrfs_inode),
					     0, (SLAB_RECLAIM_ACCOUNT|
						SLAB_MEM_SPREAD),
					     init_once, NULL);
	btrfs_trans_handle_cachep = kmem_cache_create("btrfs_trans_handle_cache",
					     sizeof(struct btrfs_trans_handle),
					     0, (SLAB_RECLAIM_ACCOUNT|
						SLAB_MEM_SPREAD),
					     NULL, NULL);
	btrfs_transaction_cachep = kmem_cache_create("btrfs_transaction_cache",
					     sizeof(struct btrfs_transaction),
					     0, (SLAB_RECLAIM_ACCOUNT|
						SLAB_MEM_SPREAD),
					     NULL, NULL);
	btrfs_path_cachep = kmem_cache_create("btrfs_path_cache",
					     sizeof(struct btrfs_transaction),
					     0, (SLAB_RECLAIM_ACCOUNT|
						SLAB_MEM_SPREAD),
					     NULL, NULL);
	btrfs_bit_radix_cachep = kmem_cache_create("btrfs_radix",
					     256,
					     0, (SLAB_RECLAIM_ACCOUNT|
						SLAB_MEM_SPREAD |
						SLAB_DESTROY_BY_RCU),
					     NULL, NULL);
	if (btrfs_inode_cachep == NULL || btrfs_trans_handle_cachep == NULL ||
	    btrfs_transaction_cachep == NULL || btrfs_bit_radix_cachep == NULL)
		return -ENOMEM;
	return 0;
}

static void destroy_inodecache(void)
{
	kmem_cache_destroy(btrfs_inode_cachep);
	kmem_cache_destroy(btrfs_trans_handle_cachep);
	kmem_cache_destroy(btrfs_transaction_cachep);
	kmem_cache_destroy(btrfs_bit_radix_cachep);
	kmem_cache_destroy(btrfs_path_cachep);
}

2736 2737 2738 2739 2740 2741 2742
static int btrfs_get_sb(struct file_system_type *fs_type,
	int flags, const char *dev_name, void *data, struct vfsmount *mnt)
{
	return get_sb_bdev(fs_type, flags, dev_name, data,
			   btrfs_fill_super, mnt);
}

2743 2744 2745 2746 2747 2748 2749 2750 2751
static int btrfs_getattr(struct vfsmount *mnt,
			 struct dentry *dentry, struct kstat *stat)
{
	struct inode *inode = dentry->d_inode;
	generic_fillattr(inode, stat);
	stat->blksize = 256 * 1024;
	return 0;
}

C
Chris Mason 已提交
2752 2753 2754 2755 2756 2757 2758 2759 2760 2761 2762 2763 2764
static int btrfs_statfs(struct dentry *dentry, struct kstatfs *buf)
{
	struct btrfs_root *root = btrfs_sb(dentry->d_sb);
	struct btrfs_super_block *disk_super = root->fs_info->disk_super;

	buf->f_namelen = BTRFS_NAME_LEN;
	buf->f_blocks = btrfs_super_total_blocks(disk_super);
	buf->f_bfree = buf->f_blocks - btrfs_super_blocks_used(disk_super);
	buf->f_bavail = buf->f_bfree;
	buf->f_bsize = dentry->d_sb->s_blocksize;
	buf->f_type = BTRFS_SUPER_MAGIC;
	return 0;
}
C
Chris Mason 已提交
2765

C
Chris Mason 已提交
2766 2767 2768 2769 2770 2771 2772 2773 2774 2775 2776 2777 2778 2779 2780 2781 2782 2783 2784 2785 2786 2787 2788 2789 2790 2791 2792 2793 2794 2795 2796 2797 2798 2799 2800 2801 2802 2803 2804 2805 2806 2807 2808 2809 2810 2811 2812 2813 2814 2815 2816 2817 2818 2819 2820 2821 2822 2823 2824 2825 2826 2827 2828 2829 2830 2831 2832 2833 2834 2835 2836 2837 2838 2839 2840 2841 2842 2843 2844 2845 2846 2847
static int btrfs_rename(struct inode * old_dir, struct dentry *old_dentry,
			   struct inode * new_dir,struct dentry *new_dentry)
{
	struct btrfs_trans_handle *trans;
	struct btrfs_root *root = BTRFS_I(old_dir)->root;
	struct inode *new_inode = new_dentry->d_inode;
	struct inode *old_inode = old_dentry->d_inode;
	struct timespec ctime = CURRENT_TIME;
	struct btrfs_path *path;
	struct btrfs_dir_item *di;
	int ret;

	if (S_ISDIR(old_inode->i_mode) && new_inode &&
	    new_inode->i_size > BTRFS_EMPTY_DIR_SIZE) {
		return -ENOTEMPTY;
	}
	mutex_lock(&root->fs_info->fs_mutex);
	trans = btrfs_start_transaction(root, 1);
	btrfs_set_trans_block_group(trans, new_dir);
	path = btrfs_alloc_path();
	if (!path) {
		ret = -ENOMEM;
		goto out_fail;
	}

	old_dentry->d_inode->i_nlink++;
	old_dir->i_ctime = old_dir->i_mtime = ctime;
	new_dir->i_ctime = new_dir->i_mtime = ctime;
	old_inode->i_ctime = ctime;
	if (S_ISDIR(old_inode->i_mode) && old_dir != new_dir) {
		struct btrfs_key *location = &BTRFS_I(new_dir)->location;
		u64 old_parent_oid;
		di = btrfs_lookup_dir_item(trans, root, path, old_inode->i_ino,
					   "..", 2, -1);
		if (IS_ERR(di)) {
			ret = PTR_ERR(di);
			goto out_fail;
		}
		if (!di) {
			ret = -ENOENT;
			goto out_fail;
		}
		old_parent_oid = btrfs_disk_key_objectid(&di->location);
		ret = btrfs_del_item(trans, root, path);
		if (ret) {
			ret = -EIO;
			goto out_fail;
		}
		btrfs_release_path(root, path);

		di = btrfs_lookup_dir_index_item(trans, root, path,
						 old_inode->i_ino,
						 old_parent_oid,
						 "..", 2, -1);
		if (IS_ERR(di)) {
			ret = PTR_ERR(di);
			goto out_fail;
		}
		if (!di) {
			ret = -ENOENT;
			goto out_fail;
		}
		ret = btrfs_del_item(trans, root, path);
		if (ret) {
			ret = -EIO;
			goto out_fail;
		}
		btrfs_release_path(root, path);

		ret = btrfs_insert_dir_item(trans, root, "..", 2,
					    old_inode->i_ino, location, 0);
		if (ret)
			goto out_fail;
	}


	ret = btrfs_unlink_trans(trans, root, old_dir, old_dentry);
	if (ret)
		goto out_fail;

	if (new_inode) {
		new_inode->i_ctime = CURRENT_TIME;
C
Chris Mason 已提交
2848 2849 2850
		ret = btrfs_unlink_trans(trans, root, new_dir, new_dentry);
		if (ret)
			goto out_fail;
C
Chris Mason 已提交
2851 2852 2853 2854 2855 2856
		if (S_ISDIR(new_inode->i_mode))
			clear_nlink(new_inode);
		else
			drop_nlink(new_inode);
		btrfs_update_inode(trans, root, new_inode);
	}
C
Chris Mason 已提交
2857 2858 2859 2860
	ret = btrfs_add_link(trans, new_dentry, old_inode);
	if (ret)
		goto out_fail;

C
Chris Mason 已提交
2861 2862 2863 2864 2865 2866 2867
out_fail:
	btrfs_free_path(path);
	btrfs_end_transaction(trans, root);
	mutex_unlock(&root->fs_info->fs_mutex);
	return ret;
}

C
Chris Mason 已提交
2868 2869 2870 2871 2872 2873 2874 2875 2876 2877 2878 2879 2880 2881 2882 2883 2884 2885 2886 2887 2888 2889 2890 2891 2892 2893 2894 2895 2896 2897 2898 2899 2900 2901 2902 2903 2904 2905 2906 2907 2908 2909 2910 2911 2912 2913 2914 2915 2916 2917 2918 2919 2920 2921 2922 2923 2924 2925 2926 2927 2928 2929 2930 2931 2932 2933 2934 2935 2936 2937 2938 2939 2940 2941 2942 2943 2944 2945 2946 2947 2948 2949 2950 2951 2952 2953 2954 2955
static int btrfs_symlink(struct inode *dir, struct dentry *dentry,
			 const char *symname)
{
	struct btrfs_trans_handle *trans;
	struct btrfs_root *root = BTRFS_I(dir)->root;
	struct btrfs_path *path;
	struct btrfs_key key;
	struct inode *inode;
	int err;
	int drop_inode = 0;
	u64 objectid;
	int name_len;
	int datasize;
	char *ptr;
	struct btrfs_file_extent_item *ei;

	name_len = strlen(symname) + 1;
	if (name_len > BTRFS_MAX_INLINE_DATA_SIZE(root))
		return -ENAMETOOLONG;
	mutex_lock(&root->fs_info->fs_mutex);
	trans = btrfs_start_transaction(root, 1);
	btrfs_set_trans_block_group(trans, dir);

	err = btrfs_find_free_objectid(trans, root, dir->i_ino, &objectid);
	if (err) {
		err = -ENOSPC;
		goto out_unlock;
	}

	inode = btrfs_new_inode(trans, root, objectid,
				BTRFS_I(dir)->block_group, S_IFLNK|S_IRWXUGO);
	err = PTR_ERR(inode);
	if (IS_ERR(inode))
		goto out_unlock;

	btrfs_set_trans_block_group(trans, inode);
	err = btrfs_add_nondir(trans, dentry, inode);
	if (err)
		drop_inode = 1;
	else {
		inode->i_mapping->a_ops = &btrfs_aops;
		inode->i_fop = &btrfs_file_operations;
		inode->i_op = &btrfs_file_inode_operations;
	}
	dir->i_sb->s_dirt = 1;
	btrfs_update_inode_block_group(trans, inode);
	btrfs_update_inode_block_group(trans, dir);
	if (drop_inode)
		goto out_unlock;

	path = btrfs_alloc_path();
	BUG_ON(!path);
	key.objectid = inode->i_ino;
	key.offset = 0;
	key.flags = 0;
	btrfs_set_key_type(&key, BTRFS_EXTENT_DATA_KEY);
	datasize = btrfs_file_extent_calc_inline_size(name_len);
	err = btrfs_insert_empty_item(trans, root, path, &key,
				      datasize);
	BUG_ON(err);
	ei = btrfs_item_ptr(btrfs_buffer_leaf(path->nodes[0]),
	       path->slots[0], struct btrfs_file_extent_item);
	btrfs_set_file_extent_generation(ei, trans->transid);
	btrfs_set_file_extent_type(ei,
				   BTRFS_FILE_EXTENT_INLINE);
	ptr = btrfs_file_extent_inline_start(ei);
	btrfs_memcpy(root, path->nodes[0]->b_data,
		     ptr, symname, name_len);
	mark_buffer_dirty(path->nodes[0]);
	btrfs_free_path(path);
	inode->i_op = &btrfs_symlink_inode_operations;
	inode->i_mapping->a_ops = &btrfs_symlink_aops;
	inode->i_size = name_len - 1;
	btrfs_update_inode(trans, root, inode);
	err = 0;

out_unlock:
	btrfs_end_transaction(trans, root);
	mutex_unlock(&root->fs_info->fs_mutex);

	if (drop_inode) {
		inode_dec_link_count(inode);
		iput(inode);
	}
	btrfs_btree_balance_dirty(root);
	return err;
}

2956 2957 2958 2959 2960 2961 2962 2963
static struct file_system_type btrfs_fs_type = {
	.owner		= THIS_MODULE,
	.name		= "btrfs",
	.get_sb		= btrfs_get_sb,
	.kill_sb	= kill_block_super,
	.fs_flags	= FS_REQUIRES_DEV,
};

C
Chris Mason 已提交
2964
static struct super_operations btrfs_super_ops = {
C
Chris Mason 已提交
2965
	.delete_inode	= btrfs_delete_inode,
C
Chris Mason 已提交
2966 2967
	.put_super	= btrfs_put_super,
	.read_inode	= btrfs_read_locked_inode,
2968 2969
	.write_super	= btrfs_write_super,
	.sync_fs	= btrfs_sync_fs,
C
Chris Mason 已提交
2970
	.write_inode	= btrfs_write_inode,
C
Chris Mason 已提交
2971
	.dirty_inode	= btrfs_dirty_inode,
C
Chris Mason 已提交
2972 2973
	.alloc_inode	= btrfs_alloc_inode,
	.destroy_inode	= btrfs_destroy_inode,
C
Chris Mason 已提交
2974
	.statfs		= btrfs_statfs,
C
Chris Mason 已提交
2975 2976 2977 2978
};

static struct inode_operations btrfs_dir_inode_operations = {
	.lookup		= btrfs_lookup,
2979
	.create		= btrfs_create,
C
Chris Mason 已提交
2980
	.unlink		= btrfs_unlink,
C
Chris Mason 已提交
2981
	.link		= btrfs_link,
C
Chris Mason 已提交
2982
	.mkdir		= btrfs_mkdir,
C
Chris Mason 已提交
2983
	.rmdir		= btrfs_rmdir,
C
Chris Mason 已提交
2984
	.rename		= btrfs_rename,
C
Chris Mason 已提交
2985
	.symlink	= btrfs_symlink,
C
Chris Mason 已提交
2986
	.setattr	= btrfs_setattr,
C
Chris Mason 已提交
2987 2988
};

2989 2990 2991 2992
static struct inode_operations btrfs_dir_ro_inode_operations = {
	.lookup		= btrfs_lookup,
};

C
Chris Mason 已提交
2993 2994 2995 2996
static struct file_operations btrfs_dir_file_operations = {
	.llseek		= generic_file_llseek,
	.read		= generic_read_dir,
	.readdir	= btrfs_readdir,
C
Chris Mason 已提交
2997
	.ioctl		= btrfs_ioctl,
C
Chris Mason 已提交
2998 2999
};

C
Chris Mason 已提交
3000 3001 3002 3003 3004
static struct address_space_operations btrfs_aops = {
	.readpage	= btrfs_readpage,
	.writepage	= btrfs_writepage,
	.sync_page	= block_sync_page,
	.prepare_write	= btrfs_prepare_write,
C
Chris Mason 已提交
3005
	.commit_write	= btrfs_commit_write,
C
Chris Mason 已提交
3006 3007
};

C
Chris Mason 已提交
3008 3009 3010 3011 3012
static struct address_space_operations btrfs_symlink_aops = {
	.readpage	= btrfs_readpage,
	.writepage	= btrfs_writepage,
};

C
Chris Mason 已提交
3013
static struct inode_operations btrfs_file_inode_operations = {
C
Chris Mason 已提交
3014
	.truncate	= btrfs_truncate,
3015
	.getattr	= btrfs_getattr,
C
Chris Mason 已提交
3016
	.setattr	= btrfs_setattr,
C
Chris Mason 已提交
3017 3018 3019 3020 3021
};

static struct file_operations btrfs_file_operations = {
	.llseek		= generic_file_llseek,
	.read		= do_sync_read,
3022 3023
	.aio_read       = btrfs_file_aio_read,
	.write		= btrfs_file_write,
C
Chris Mason 已提交
3024 3025
	.mmap		= generic_file_mmap,
	.open		= generic_file_open,
C
Chris Mason 已提交
3026
	.ioctl		= btrfs_ioctl,
C
Chris Mason 已提交
3027
	.fsync		= btrfs_sync_file,
C
Chris Mason 已提交
3028
};
C
Chris Mason 已提交
3029

C
Chris Mason 已提交
3030 3031 3032 3033 3034 3035
static struct inode_operations btrfs_symlink_inode_operations = {
	.readlink	= generic_readlink,
	.follow_link	= page_follow_link_light,
	.put_link	= page_put_link,
};

3036 3037
static int __init init_btrfs_fs(void)
{
C
Chris Mason 已提交
3038
	int err;
3039
	printk("btrfs loaded!\n");
C
Chris Mason 已提交
3040 3041 3042
	err = init_inodecache();
	if (err)
		return err;
3043
	return register_filesystem(&btrfs_fs_type);
3044 3045
	destroy_inodecache();
	return err;
3046 3047 3048 3049
}

static void __exit exit_btrfs_fs(void)
{
C
Chris Mason 已提交
3050
	destroy_inodecache();
3051 3052 3053 3054 3055 3056 3057 3058
	unregister_filesystem(&btrfs_fs_type);
	printk("btrfs unloaded\n");
}

module_init(init_btrfs_fs)
module_exit(exit_btrfs_fs)

MODULE_LICENSE("GPL");