]> git.karo-electronics.de Git - karo-tx-linux.git/blobdiff - fs/btrfs/inode.c
Btrfs: Add writepages support
[karo-tx-linux.git] / fs / btrfs / inode.c
index b74a831fab19cc511bee5d4dfbe19aecbad20d5a..25f32d7c7ee8f5f8568f3e6097deba2e47e75f22 100644 (file)
@@ -89,6 +89,9 @@ static int run_delalloc_range(struct inode *inode, u64 start, u64 end)
        ret = btrfs_drop_extents(trans, root, inode,
                                 start, start + num_bytes, start, &alloc_hint);
 
+       if (alloc_hint == EXTENT_MAP_INLINE)
+               goto out;
+
        ret = btrfs_alloc_extent(trans, root, inode->i_ino, num_bytes, 0,
                                 alloc_hint, (u64)-1, &ins, 1);
        if (ret) {
@@ -111,7 +114,7 @@ int btrfs_writepage_io_hook(struct page *page, u64 start, u64 end)
        struct btrfs_trans_handle *trans;
        char *kaddr;
        int ret;
-       u64 page_start = page->index << PAGE_CACHE_SHIFT;
+       u64 page_start = (u64)page->index << PAGE_CACHE_SHIFT;
        size_t offset = start - page_start;
 
        mutex_lock(&root->fs_info->fs_mutex);
@@ -160,7 +163,7 @@ out:
 
 int btrfs_readpage_end_io_hook(struct page *page, u64 start, u64 end)
 {
-       size_t offset = start - (page->index << PAGE_CACHE_SHIFT);
+       size_t offset = start - ((u64)page->index << PAGE_CACHE_SHIFT);
        struct inode *inode = page->mapping->host;
        struct extent_map_tree *em_tree = &BTRFS_I(inode)->extent_tree;
        char *kaddr;
@@ -448,6 +451,9 @@ static int btrfs_rmdir(struct inode *dir, struct dentry *dentry)
        char *goodnames = "..";
        unsigned long nr;
 
+       if (inode->i_size > BTRFS_EMPTY_DIR_SIZE)
+               return -ENOTEMPTY;
+
        path = btrfs_alloc_path();
        BUG_ON(!path);
        mutex_lock(&root->fs_info->fs_mutex);
@@ -501,9 +507,9 @@ static int btrfs_rmdir(struct inode *dir, struct dentry *dentry)
 out:
        btrfs_release_path(root, path);
        btrfs_free_path(path);
-       mutex_unlock(&root->fs_info->fs_mutex);
        nr = trans->blocks_used;
        ret = btrfs_end_transaction(trans, root);
+       mutex_unlock(&root->fs_info->fs_mutex);
        btrfs_btree_balance_dirty(root, nr);
        if (ret && !err)
                err = ret;
@@ -555,6 +561,7 @@ static int btrfs_truncate_in_trans(struct btrfs_trans_handle *trans,
        u64 item_end = 0;
        int found_extent;
        int del_item;
+       int extent_type = -1;
 
        btrfs_drop_extent_cache(inode, inode->i_size, (u64)-1);
        path = btrfs_alloc_path();
@@ -594,10 +601,15 @@ static int btrfs_truncate_in_trans(struct btrfs_trans_handle *trans,
                if (found_type == BTRFS_EXTENT_DATA_KEY) {
                        fi = btrfs_item_ptr(leaf, path->slots[0],
                                            struct btrfs_file_extent_item);
-                       if (btrfs_file_extent_type(leaf, fi) !=
-                           BTRFS_FILE_EXTENT_INLINE) {
+                       extent_type = btrfs_file_extent_type(leaf, fi);
+                       if (extent_type != BTRFS_FILE_EXTENT_INLINE) {
                                item_end +=
                                    btrfs_file_extent_num_bytes(leaf, fi);
+                       } else if (extent_type == BTRFS_FILE_EXTENT_INLINE) {
+                               struct btrfs_item *item = btrfs_item_nr(leaf,
+                                                               path->slots[0]);
+                               item_end += btrfs_file_extent_inline_len(leaf,
+                                                                        item);
                        }
                }
                if (found_type == BTRFS_CSUM_ITEM_KEY) {
@@ -605,7 +617,7 @@ static int btrfs_truncate_in_trans(struct btrfs_trans_handle *trans,
                                                  inode->i_size);
                        BUG_ON(ret);
                }
-               if (item_end < inode->i_size) {
+               if (item_end <= inode->i_size) {
                        if (found_type == BTRFS_DIR_ITEM_KEY) {
                                found_type = BTRFS_INODE_ITEM_KEY;
                        } else if (found_type == BTRFS_EXTENT_ITEM_KEY) {
@@ -626,9 +638,10 @@ static int btrfs_truncate_in_trans(struct btrfs_trans_handle *trans,
                found_extent = 0;
 
                /* FIXME, shrink the extent if the ref count is only 1 */
-               if (found_type == BTRFS_EXTENT_DATA_KEY &&
-                          btrfs_file_extent_type(leaf, fi) !=
-                          BTRFS_FILE_EXTENT_INLINE) {
+               if (found_type != BTRFS_EXTENT_DATA_KEY)
+                       goto delete;
+
+               if (extent_type != BTRFS_FILE_EXTENT_INLINE) {
                        u64 num_dec;
                        extent_start = btrfs_file_extent_disk_bytenr(leaf, fi);
                        if (!del_item) {
@@ -656,7 +669,15 @@ static int btrfs_truncate_in_trans(struct btrfs_trans_handle *trans,
                                        inode->i_blocks -= num_dec;
                                }
                        }
+               } else if (extent_type == BTRFS_FILE_EXTENT_INLINE &&
+                          !del_item) {
+                       u32 newsize = inode->i_size - found_key.offset;
+                       newsize = btrfs_file_extent_calc_inline_size(newsize);
+                       ret = btrfs_truncate_item(trans, root, path,
+                                                 newsize, 1);
+                       BUG_ON(ret);
                }
+delete:
                if (del_item) {
                        ret = btrfs_del_item(trans, root, path);
                        if (ret)
@@ -685,7 +706,7 @@ static int btrfs_cow_one_page(struct inode *inode, struct page *page,
        char *kaddr;
        int ret = 0;
        struct extent_map_tree *em_tree = &BTRFS_I(inode)->extent_tree;
-       u64 page_start = page->index << PAGE_CACHE_SHIFT;
+       u64 page_start = (u64)page->index << PAGE_CACHE_SHIFT;
        u64 page_end = page_start + PAGE_CACHE_SIZE - 1;
 
        set_page_extent_mapped(page);
@@ -736,7 +757,7 @@ static int btrfs_truncate_page(struct address_space *mapping, loff_t from)
                        goto out;
                }
        }
-       page_start = page->index << PAGE_CACHE_SHIFT;
+       page_start = (u64)page->index << PAGE_CACHE_SHIFT;
 
        ret = btrfs_cow_one_page(inode, page, offset);
 
@@ -766,7 +787,7 @@ static int btrfs_setattr(struct dentry *dentry, struct iattr *attr)
                u64 pos = (inode->i_size + mask) & ~mask;
                u64 block_end = attr->ia_size | mask;
                u64 hole_size;
-               u64 alloc_hint;
+               u64 alloc_hint = 0;
 
                if (attr->ia_size <= pos)
                        goto out;
@@ -783,8 +804,11 @@ static int btrfs_setattr(struct dentry *dentry, struct iattr *attr)
                                         pos, pos + hole_size, pos,
                                         &alloc_hint);
 
-               err = btrfs_insert_file_extent(trans, root, inode->i_ino,
-                                              pos, 0, 0, hole_size);
+               if (alloc_hint != EXTENT_MAP_INLINE) {
+                       err = btrfs_insert_file_extent(trans, root,
+                                                      inode->i_ino,
+                                                      pos, 0, 0, hole_size);
+               }
                btrfs_end_transaction(trans, root);
                mutex_unlock(&root->fs_info->fs_mutex);
                unlock_extent(em_tree, pos, block_end, GFP_NOFS);
@@ -1528,8 +1552,8 @@ again:
                em->end = EXTENT_MAP_HOLE;
        }
        em->bdev = inode->i_sb->s_bdev;
-       ret = btrfs_lookup_file_extent(NULL, root, path,
-                                      objectid, start, 0);
+       ret = btrfs_lookup_file_extent(trans, root, path,
+                                      objectid, start, trans != NULL);
        if (ret < 0) {
                err = ret;
                goto out;
@@ -1593,8 +1617,7 @@ again:
 
                size = btrfs_file_extent_inline_len(leaf, btrfs_item_nr(leaf,
                                                    path->slots[0]));
-
-               extent_end = (extent_start + size) |
+               extent_end = (extent_start + size - 1) |
                        ((u64)root->sectorsize - 1);
                if (start < extent_start || start >= extent_end) {
                        em->start = start;
@@ -1607,30 +1630,41 @@ again:
                        }
                        goto not_found_em;
                }
+               em->block_start = EXTENT_MAP_INLINE;
+               em->block_end = EXTENT_MAP_INLINE;
 
-               extent_offset = (page->index << PAGE_CACHE_SHIFT) -
-                       extent_start;
-               ptr = btrfs_file_extent_inline_start(item) + extent_offset;
-               map = kmap(page);
+               if (!page) {
+                       em->start = extent_start;
+                       em->end = extent_start + size - 1;
+                       goto out;
+               }
+
+               extent_offset = ((u64)page->index << PAGE_CACHE_SHIFT) -
+                       extent_start + page_offset;
                copy_size = min_t(u64, PAGE_CACHE_SIZE - page_offset,
                                size - extent_offset);
-
-               em->block_start = EXTENT_MAP_INLINE;
-               em->block_end = EXTENT_MAP_INLINE;
                em->start = extent_start + extent_offset;
                em->end = (em->start + copy_size -1) |
                        ((u64)root->sectorsize -1);
-
-               if (!page) {
-                       goto insert;
+               map = kmap(page);
+               ptr = btrfs_file_extent_inline_start(item) + extent_offset;
+               if (create == 0 && !PageUptodate(page)) {
+                       read_extent_buffer(leaf, map + page_offset, ptr,
+                                          copy_size);
+                       flush_dcache_page(page);
+               } else if (create && PageUptodate(page)) {
+                       if (!trans) {
+                               kunmap(page);
+                               free_extent_map(em);
+                               em = NULL;
+                               btrfs_release_path(root, path);
+                               trans = btrfs_start_transaction(root, 1);
+                               goto again;
+                       }
+                       write_extent_buffer(leaf, map + page_offset, ptr,
+                                           copy_size);
+                       btrfs_mark_buffer_dirty(leaf);
                }
-
-               read_extent_buffer(leaf, map + page_offset, ptr, copy_size);
-               /*
-               memset(map + page_offset + copy_size, 0,
-                      PAGE_CACHE_SIZE - copy_size - page_offset);
-                      */
-               flush_dcache_page(page);
                kunmap(page);
                set_extent_uptodate(em_tree, em->start, em->end, GFP_NOFS);
                goto insert;
@@ -1713,6 +1747,15 @@ static int btrfs_writepage(struct page *page, struct writeback_control *wbc)
        return extent_write_full_page(tree, page, btrfs_get_extent, wbc);
 }
 
+
+static int btrfs_writepages(struct address_space *mapping,
+                           struct writeback_control *wbc)
+{
+       struct extent_map_tree *tree;
+       tree = &BTRFS_I(mapping->host)->extent_tree;
+       return extent_writepages(tree, mapping, btrfs_get_extent, wbc);
+}
+
 static int btrfs_releasepage(struct page *page, gfp_t unused_gfp_flags)
 {
        struct extent_map_tree *tree;
@@ -1764,7 +1807,7 @@ int btrfs_page_mkwrite(struct vm_area_struct *vma, struct page *page)
        lock_page(page);
        wait_on_page_writeback(page);
        size = i_size_read(inode);
-       page_start = page->index << PAGE_CACHE_SHIFT;
+       page_start = (u64)page->index << PAGE_CACHE_SHIFT;
 
        if ((page->mapping != inode->i_mapping) ||
            (page_start > size)) {
@@ -2060,7 +2103,7 @@ int btrfs_defrag_file(struct file *file) {
                                goto out_unlock;
                        }
                }
-               page_start = page->index << PAGE_CACHE_SHIFT;
+               page_start = (u64)page->index << PAGE_CACHE_SHIFT;
                page_end = page_start + PAGE_CACHE_SIZE - 1;
 
                lock_extent(em_tree, page_start, page_end, GFP_NOFS);
@@ -2173,8 +2216,12 @@ void btrfs_destroy_inode(struct inode *inode)
        kmem_cache_free(btrfs_inode_cachep, BTRFS_I(inode));
 }
 
+#if LINUX_VERSION_CODE > KERNEL_VERSION(2,6,23)
+static void init_once(struct kmem_cache * cachep, void *foo)
+#else
 static void init_once(void * foo, struct kmem_cache * cachep,
                      unsigned long flags)
+#endif
 {
        struct btrfs_inode *ei = (struct btrfs_inode *) foo;
 
@@ -2197,8 +2244,13 @@ void btrfs_destroy_cachep(void)
 
 struct kmem_cache *btrfs_cache_create(const char *name, size_t size,
                                       unsigned long extra_flags,
+#if LINUX_VERSION_CODE > KERNEL_VERSION(2,6,23)
+                                      void (*ctor)(struct kmem_cache *, void *)
+#else
                                       void (*ctor)(void *, struct kmem_cache *,
-                                                   unsigned long))
+                                                   unsigned long)
+#endif
+                                    )
 {
        return kmem_cache_create(name, size, 0, (SLAB_RECLAIM_ACCOUNT |
                                 SLAB_MEM_SPREAD | extra_flags), ctor
@@ -2483,6 +2535,7 @@ static struct extent_map_ops btrfs_extent_map_ops = {
 static struct address_space_operations btrfs_aops = {
        .readpage       = btrfs_readpage,
        .writepage      = btrfs_writepage,
+       .writepages     = btrfs_writepages,
        .sync_page      = block_sync_page,
        .prepare_write  = btrfs_prepare_write,
        .commit_write   = btrfs_commit_write,