16cbd5570SChris Mason /* 26cbd5570SChris Mason * Copyright (C) 2007 Oracle. All rights reserved. 36cbd5570SChris Mason * 46cbd5570SChris Mason * This program is free software; you can redistribute it and/or 56cbd5570SChris Mason * modify it under the terms of the GNU General Public 66cbd5570SChris Mason * License v2 as published by the Free Software Foundation. 76cbd5570SChris Mason * 86cbd5570SChris Mason * This program is distributed in the hope that it will be useful, 96cbd5570SChris Mason * but WITHOUT ANY WARRANTY; without even the implied warranty of 106cbd5570SChris Mason * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU 116cbd5570SChris Mason * General Public License for more details. 126cbd5570SChris Mason * 136cbd5570SChris Mason * You should have received a copy of the GNU General Public 146cbd5570SChris Mason * License along with this program; if not, write to the 156cbd5570SChris Mason * Free Software Foundation, Inc., 59 Temple Place - Suite 330, 166cbd5570SChris Mason * Boston, MA 021110-1307, USA. 176cbd5570SChris Mason */ 186cbd5570SChris Mason 1979154b1bSChris Mason #include <linux/module.h> 2079154b1bSChris Mason #include <linux/fs.h> 2134088780SChris Mason #include <linux/sched.h> 2279154b1bSChris Mason #include "ctree.h" 2379154b1bSChris Mason #include "disk-io.h" 2479154b1bSChris Mason #include "transaction.h" 2579154b1bSChris Mason 2678fae27eSChris Mason static int total_trans = 0; 272c90e5d6SChris Mason extern struct kmem_cache *btrfs_trans_handle_cachep; 282c90e5d6SChris Mason extern struct kmem_cache *btrfs_transaction_cachep; 292c90e5d6SChris Mason 3008607c1bSChris Mason static struct workqueue_struct *trans_wq; 3108607c1bSChris Mason 320f7d52f4SChris Mason #define BTRFS_ROOT_TRANS_TAG 0 330f7d52f4SChris Mason 3479154b1bSChris Mason static void put_transaction(struct btrfs_transaction *transaction) 3579154b1bSChris Mason { 362c90e5d6SChris Mason WARN_ON(transaction->use_count == 0); 3779154b1bSChris Mason transaction->use_count--; 3878fae27eSChris Mason if (transaction->use_count == 0) { 3978fae27eSChris Mason WARN_ON(total_trans == 0); 4078fae27eSChris Mason total_trans--; 418fd17795SChris Mason list_del_init(&transaction->list); 422c90e5d6SChris Mason memset(transaction, 0, sizeof(*transaction)); 432c90e5d6SChris Mason kmem_cache_free(btrfs_transaction_cachep, transaction); 4479154b1bSChris Mason } 4578fae27eSChris Mason } 4679154b1bSChris Mason 4779154b1bSChris Mason static int join_transaction(struct btrfs_root *root) 4879154b1bSChris Mason { 4979154b1bSChris Mason struct btrfs_transaction *cur_trans; 5079154b1bSChris Mason cur_trans = root->fs_info->running_transaction; 5179154b1bSChris Mason if (!cur_trans) { 522c90e5d6SChris Mason cur_trans = kmem_cache_alloc(btrfs_transaction_cachep, 532c90e5d6SChris Mason GFP_NOFS); 5478fae27eSChris Mason total_trans++; 5579154b1bSChris Mason BUG_ON(!cur_trans); 560f7d52f4SChris Mason root->fs_info->generation++; 5779154b1bSChris Mason root->fs_info->running_transaction = cur_trans; 5879154b1bSChris Mason cur_trans->num_writers = 0; 590f7d52f4SChris Mason cur_trans->transid = root->fs_info->generation; 6079154b1bSChris Mason init_waitqueue_head(&cur_trans->writer_wait); 6179154b1bSChris Mason init_waitqueue_head(&cur_trans->commit_wait); 6279154b1bSChris Mason cur_trans->in_commit = 0; 63d5719762SChris Mason cur_trans->use_count = 1; 6479154b1bSChris Mason cur_trans->commit_done = 0; 6508607c1bSChris Mason cur_trans->start_time = get_seconds(); 668fd17795SChris Mason list_add_tail(&cur_trans->list, &root->fs_info->trans_list); 677c4452b9SChris Mason init_bit_radix(&cur_trans->dirty_pages); 6879154b1bSChris Mason } 6979154b1bSChris Mason cur_trans->num_writers++; 7079154b1bSChris Mason return 0; 7179154b1bSChris Mason } 7279154b1bSChris Mason 7379154b1bSChris Mason struct btrfs_trans_handle *btrfs_start_transaction(struct btrfs_root *root, 7479154b1bSChris Mason int num_blocks) 7579154b1bSChris Mason { 762c90e5d6SChris Mason struct btrfs_trans_handle *h = 772c90e5d6SChris Mason kmem_cache_alloc(btrfs_trans_handle_cachep, GFP_NOFS); 7879154b1bSChris Mason int ret; 790f7d52f4SChris Mason u64 running_trans_id; 8079154b1bSChris Mason 8179154b1bSChris Mason mutex_lock(&root->fs_info->trans_mutex); 8279154b1bSChris Mason ret = join_transaction(root); 8379154b1bSChris Mason BUG_ON(ret); 840f7d52f4SChris Mason running_trans_id = root->fs_info->running_transaction->transid; 850f7d52f4SChris Mason 860f7d52f4SChris Mason if (root != root->fs_info->tree_root && root->last_trans < 870f7d52f4SChris Mason running_trans_id) { 885eda7b5eSChris Mason if (root->root_item.refs != 0) { 890f7d52f4SChris Mason radix_tree_tag_set(&root->fs_info->fs_roots_radix, 902619ba1fSChris Mason (unsigned long)root->root_key.objectid, 912619ba1fSChris Mason BTRFS_ROOT_TRANS_TAG); 920f7d52f4SChris Mason root->commit_root = root->node; 930f7d52f4SChris Mason get_bh(root->node); 945eda7b5eSChris Mason } else { 955eda7b5eSChris Mason WARN_ON(1); 965eda7b5eSChris Mason } 970f7d52f4SChris Mason } 980f7d52f4SChris Mason root->last_trans = running_trans_id; 990f7d52f4SChris Mason h->transid = running_trans_id; 10079154b1bSChris Mason h->transaction = root->fs_info->running_transaction; 10179154b1bSChris Mason h->blocks_reserved = num_blocks; 10279154b1bSChris Mason h->blocks_used = 0; 10331f3c99bSChris Mason h->block_group = NULL; 10479154b1bSChris Mason root->fs_info->running_transaction->use_count++; 10579154b1bSChris Mason mutex_unlock(&root->fs_info->trans_mutex); 10679154b1bSChris Mason return h; 10779154b1bSChris Mason } 10879154b1bSChris Mason 10979154b1bSChris Mason int btrfs_end_transaction(struct btrfs_trans_handle *trans, 11079154b1bSChris Mason struct btrfs_root *root) 11179154b1bSChris Mason { 11279154b1bSChris Mason struct btrfs_transaction *cur_trans; 113d6e4a428SChris Mason 11479154b1bSChris Mason mutex_lock(&root->fs_info->trans_mutex); 11579154b1bSChris Mason cur_trans = root->fs_info->running_transaction; 116d5719762SChris Mason WARN_ON(cur_trans->num_writers < 1); 11779154b1bSChris Mason if (waitqueue_active(&cur_trans->writer_wait)) 11879154b1bSChris Mason wake_up(&cur_trans->writer_wait); 11979154b1bSChris Mason cur_trans->num_writers--; 12079154b1bSChris Mason put_transaction(cur_trans); 12179154b1bSChris Mason mutex_unlock(&root->fs_info->trans_mutex); 122d6025579SChris Mason memset(trans, 0, sizeof(*trans)); 1232c90e5d6SChris Mason kmem_cache_free(btrfs_trans_handle_cachep, trans); 12479154b1bSChris Mason return 0; 12579154b1bSChris Mason } 12679154b1bSChris Mason 12779154b1bSChris Mason 12879154b1bSChris Mason int btrfs_write_and_wait_transaction(struct btrfs_trans_handle *trans, 12979154b1bSChris Mason struct btrfs_root *root) 13079154b1bSChris Mason { 1317c4452b9SChris Mason unsigned long gang[16]; 1327c4452b9SChris Mason int ret; 1337c4452b9SChris Mason int i; 1347c4452b9SChris Mason int err; 1357c4452b9SChris Mason int werr = 0; 1367c4452b9SChris Mason struct page *page; 1377c4452b9SChris Mason struct radix_tree_root *dirty_pages; 1387c4452b9SChris Mason struct inode *btree_inode = root->fs_info->btree_inode; 1397c4452b9SChris Mason 1407c4452b9SChris Mason if (!trans || !trans->transaction) { 1417c4452b9SChris Mason return filemap_write_and_wait(btree_inode->i_mapping); 1427c4452b9SChris Mason } 1437c4452b9SChris Mason dirty_pages = &trans->transaction->dirty_pages; 1447c4452b9SChris Mason while(1) { 145e37c9e69SChris Mason ret = find_first_radix_bit(dirty_pages, gang, 146e37c9e69SChris Mason 0, ARRAY_SIZE(gang)); 1477c4452b9SChris Mason if (!ret) 1487c4452b9SChris Mason break; 1497c4452b9SChris Mason for (i = 0; i < ret; i++) { 1507c4452b9SChris Mason /* FIXME EIO */ 1517c4452b9SChris Mason clear_radix_bit(dirty_pages, gang[i]); 1527c4452b9SChris Mason page = find_lock_page(btree_inode->i_mapping, 1537c4452b9SChris Mason gang[i]); 1547c4452b9SChris Mason if (!page) 1557c4452b9SChris Mason continue; 1567c4452b9SChris Mason err = write_one_page(page, 0); 1577c4452b9SChris Mason if (err) 1587c4452b9SChris Mason werr = err; 1597c4452b9SChris Mason page_cache_release(page); 1607c4452b9SChris Mason } 1617c4452b9SChris Mason } 1627c4452b9SChris Mason err = filemap_fdatawait(btree_inode->i_mapping); 1637c4452b9SChris Mason if (err) 1647c4452b9SChris Mason werr = err; 1657c4452b9SChris Mason return werr; 16679154b1bSChris Mason } 16779154b1bSChris Mason 16879154b1bSChris Mason int btrfs_commit_tree_roots(struct btrfs_trans_handle *trans, 16979154b1bSChris Mason struct btrfs_root *root) 17079154b1bSChris Mason { 17179154b1bSChris Mason int ret; 17279154b1bSChris Mason u64 old_extent_block; 17379154b1bSChris Mason struct btrfs_fs_info *fs_info = root->fs_info; 17479154b1bSChris Mason struct btrfs_root *tree_root = fs_info->tree_root; 17579154b1bSChris Mason struct btrfs_root *extent_root = fs_info->extent_root; 17679154b1bSChris Mason 1779078a3e1SChris Mason btrfs_write_dirty_block_groups(trans, extent_root); 17879154b1bSChris Mason while(1) { 17979154b1bSChris Mason old_extent_block = btrfs_root_blocknr(&extent_root->root_item); 1807eccb903SChris Mason if (old_extent_block == bh_blocknr(extent_root->node)) 18179154b1bSChris Mason break; 18279154b1bSChris Mason btrfs_set_root_blocknr(&extent_root->root_item, 1837eccb903SChris Mason bh_blocknr(extent_root->node)); 18479154b1bSChris Mason ret = btrfs_update_root(trans, tree_root, 18579154b1bSChris Mason &extent_root->root_key, 18679154b1bSChris Mason &extent_root->root_item); 18779154b1bSChris Mason BUG_ON(ret); 1889078a3e1SChris Mason btrfs_write_dirty_block_groups(trans, extent_root); 18979154b1bSChris Mason } 19079154b1bSChris Mason return 0; 19179154b1bSChris Mason } 19279154b1bSChris Mason 19379154b1bSChris Mason static int wait_for_commit(struct btrfs_root *root, 19479154b1bSChris Mason struct btrfs_transaction *commit) 19579154b1bSChris Mason { 19679154b1bSChris Mason DEFINE_WAIT(wait); 19779154b1bSChris Mason while(!commit->commit_done) { 19879154b1bSChris Mason prepare_to_wait(&commit->commit_wait, &wait, 19979154b1bSChris Mason TASK_UNINTERRUPTIBLE); 20079154b1bSChris Mason if (commit->commit_done) 20179154b1bSChris Mason break; 20279154b1bSChris Mason mutex_unlock(&root->fs_info->trans_mutex); 20379154b1bSChris Mason schedule(); 20479154b1bSChris Mason mutex_lock(&root->fs_info->trans_mutex); 20579154b1bSChris Mason } 20679154b1bSChris Mason finish_wait(&commit->commit_wait, &wait); 20779154b1bSChris Mason return 0; 20879154b1bSChris Mason } 20979154b1bSChris Mason 2100f7d52f4SChris Mason struct dirty_root { 2110f7d52f4SChris Mason struct list_head list; 2120f7d52f4SChris Mason struct btrfs_key snap_key; 2130f7d52f4SChris Mason struct buffer_head *commit_root; 2140f7d52f4SChris Mason struct btrfs_root *root; 2155eda7b5eSChris Mason int free_on_drop; 2160f7d52f4SChris Mason }; 2170f7d52f4SChris Mason 2185eda7b5eSChris Mason int btrfs_add_dead_root(struct btrfs_root *root, struct list_head *dead_list) 2195eda7b5eSChris Mason { 2205eda7b5eSChris Mason struct dirty_root *dirty; 2215eda7b5eSChris Mason 2225eda7b5eSChris Mason dirty = kmalloc(sizeof(*dirty), GFP_NOFS); 2235eda7b5eSChris Mason if (!dirty) 2245eda7b5eSChris Mason return -ENOMEM; 2255eda7b5eSChris Mason memcpy(&dirty->snap_key, &root->root_key, sizeof(root->root_key)); 2265eda7b5eSChris Mason dirty->commit_root = root->node; 2275eda7b5eSChris Mason dirty->root = root; 2285eda7b5eSChris Mason dirty->free_on_drop = 1; 2295eda7b5eSChris Mason list_add(&dirty->list, dead_list); 2305eda7b5eSChris Mason return 0; 2315eda7b5eSChris Mason } 2325eda7b5eSChris Mason 23335b7e476SChris Mason static int add_dirty_roots(struct btrfs_trans_handle *trans, 23435b7e476SChris Mason struct radix_tree_root *radix, 23535b7e476SChris Mason struct list_head *list) 2360f7d52f4SChris Mason { 2370f7d52f4SChris Mason struct dirty_root *dirty; 2380f7d52f4SChris Mason struct btrfs_root *gang[8]; 2390f7d52f4SChris Mason struct btrfs_root *root; 2405eda7b5eSChris Mason struct btrfs_root_item tmp_item; 2410f7d52f4SChris Mason int i; 2420f7d52f4SChris Mason int ret; 24354aa1f4dSChris Mason int err = 0; 2445eda7b5eSChris Mason u32 refs; 24554aa1f4dSChris Mason 2460f7d52f4SChris Mason while(1) { 2470f7d52f4SChris Mason ret = radix_tree_gang_lookup_tag(radix, (void **)gang, 0, 2480f7d52f4SChris Mason ARRAY_SIZE(gang), 2490f7d52f4SChris Mason BTRFS_ROOT_TRANS_TAG); 2500f7d52f4SChris Mason if (ret == 0) 2510f7d52f4SChris Mason break; 2520f7d52f4SChris Mason for (i = 0; i < ret; i++) { 2530f7d52f4SChris Mason root = gang[i]; 2542619ba1fSChris Mason radix_tree_tag_clear(radix, 2552619ba1fSChris Mason (unsigned long)root->root_key.objectid, 2560f7d52f4SChris Mason BTRFS_ROOT_TRANS_TAG); 2570f7d52f4SChris Mason if (root->commit_root == root->node) { 2587eccb903SChris Mason WARN_ON(bh_blocknr(root->node) != 2590f7d52f4SChris Mason btrfs_root_blocknr(&root->root_item)); 2600f7d52f4SChris Mason brelse(root->commit_root); 2610f7d52f4SChris Mason root->commit_root = NULL; 2620f7d52f4SChris Mason continue; 2630f7d52f4SChris Mason } 2640f7d52f4SChris Mason dirty = kmalloc(sizeof(*dirty), GFP_NOFS); 2650f7d52f4SChris Mason BUG_ON(!dirty); 2660f7d52f4SChris Mason memcpy(&dirty->snap_key, &root->root_key, 2670f7d52f4SChris Mason sizeof(root->root_key)); 2680f7d52f4SChris Mason dirty->commit_root = root->commit_root; 2690f7d52f4SChris Mason root->commit_root = NULL; 2700f7d52f4SChris Mason dirty->root = root; 2715eda7b5eSChris Mason dirty->free_on_drop = 0; 2725eda7b5eSChris Mason memcpy(&tmp_item, &root->root_item, sizeof(tmp_item)); 2735eda7b5eSChris Mason 2740f7d52f4SChris Mason root->root_key.offset = root->fs_info->generation; 2750f7d52f4SChris Mason btrfs_set_root_blocknr(&root->root_item, 2767eccb903SChris Mason bh_blocknr(root->node)); 2770f7d52f4SChris Mason err = btrfs_insert_root(trans, root->fs_info->tree_root, 2780f7d52f4SChris Mason &root->root_key, 2790f7d52f4SChris Mason &root->root_item); 28054aa1f4dSChris Mason if (err) 28154aa1f4dSChris Mason break; 2825eda7b5eSChris Mason 2835eda7b5eSChris Mason refs = btrfs_root_refs(&tmp_item); 2845eda7b5eSChris Mason btrfs_set_root_refs(&tmp_item, refs - 1); 2855eda7b5eSChris Mason err = btrfs_update_root(trans, root->fs_info->tree_root, 2865eda7b5eSChris Mason &dirty->snap_key, 2875eda7b5eSChris Mason &tmp_item); 2885eda7b5eSChris Mason 2895eda7b5eSChris Mason BUG_ON(err); 2905eda7b5eSChris Mason if (refs == 1) 2910f7d52f4SChris Mason list_add(&dirty->list, list); 2925eda7b5eSChris Mason else 2935eda7b5eSChris Mason kfree(dirty); 2940f7d52f4SChris Mason } 2950f7d52f4SChris Mason } 29654aa1f4dSChris Mason return err; 2970f7d52f4SChris Mason } 2980f7d52f4SChris Mason 29935b7e476SChris Mason static int drop_dirty_roots(struct btrfs_root *tree_root, 30035b7e476SChris Mason struct list_head *list) 3010f7d52f4SChris Mason { 3020f7d52f4SChris Mason struct dirty_root *dirty; 3030f7d52f4SChris Mason struct btrfs_trans_handle *trans; 30454aa1f4dSChris Mason int ret = 0; 3050f7d52f4SChris Mason while(!list_empty(list)) { 306facda1e7SChris Mason mutex_lock(&tree_root->fs_info->fs_mutex); 3070f7d52f4SChris Mason dirty = list_entry(list->next, struct dirty_root, list); 3080f7d52f4SChris Mason list_del_init(&dirty->list); 3095eda7b5eSChris Mason 3100f7d52f4SChris Mason trans = btrfs_start_transaction(tree_root, 1); 3115eda7b5eSChris Mason printk("deleting root %Lu %u %Lu\n", dirty->snap_key.objectid, dirty->snap_key.flags, dirty->snap_key.offset); 3120f7d52f4SChris Mason ret = btrfs_drop_snapshot(trans, dirty->root, 3130f7d52f4SChris Mason dirty->commit_root); 3140f7d52f4SChris Mason BUG_ON(ret); 3150f7d52f4SChris Mason ret = btrfs_del_root(trans, tree_root, &dirty->snap_key); 31654aa1f4dSChris Mason if (ret) 31754aa1f4dSChris Mason break; 3180f7d52f4SChris Mason ret = btrfs_end_transaction(trans, tree_root); 3190f7d52f4SChris Mason BUG_ON(ret); 3205eda7b5eSChris Mason 3215eda7b5eSChris Mason if (dirty->free_on_drop) 3225eda7b5eSChris Mason kfree(dirty->root); 3230f7d52f4SChris Mason kfree(dirty); 324facda1e7SChris Mason mutex_unlock(&tree_root->fs_info->fs_mutex); 3258c2383c3SChris Mason btrfs_btree_balance_dirty(tree_root); 3260f7d52f4SChris Mason } 32754aa1f4dSChris Mason return ret; 3280f7d52f4SChris Mason } 3290f7d52f4SChris Mason 33079154b1bSChris Mason int btrfs_commit_transaction(struct btrfs_trans_handle *trans, 33179154b1bSChris Mason struct btrfs_root *root) 33279154b1bSChris Mason { 33379154b1bSChris Mason int ret = 0; 33479154b1bSChris Mason struct btrfs_transaction *cur_trans; 3358fd17795SChris Mason struct btrfs_transaction *prev_trans = NULL; 3360f7d52f4SChris Mason struct list_head dirty_fs_roots; 33779154b1bSChris Mason DEFINE_WAIT(wait); 33879154b1bSChris Mason 3390f7d52f4SChris Mason INIT_LIST_HEAD(&dirty_fs_roots); 340d6e4a428SChris Mason 34179154b1bSChris Mason mutex_lock(&root->fs_info->trans_mutex); 34279154b1bSChris Mason if (trans->transaction->in_commit) { 34379154b1bSChris Mason cur_trans = trans->transaction; 34479154b1bSChris Mason trans->transaction->use_count++; 34579154b1bSChris Mason btrfs_end_transaction(trans, root); 34679154b1bSChris Mason ret = wait_for_commit(root, cur_trans); 34779154b1bSChris Mason BUG_ON(ret); 34879154b1bSChris Mason put_transaction(cur_trans); 34979154b1bSChris Mason mutex_unlock(&root->fs_info->trans_mutex); 35079154b1bSChris Mason return 0; 35179154b1bSChris Mason } 3522c90e5d6SChris Mason cur_trans = trans->transaction; 3532c90e5d6SChris Mason trans->transaction->in_commit = 1; 35479154b1bSChris Mason while (trans->transaction->num_writers > 1) { 3552c90e5d6SChris Mason WARN_ON(cur_trans != trans->transaction); 35679154b1bSChris Mason prepare_to_wait(&trans->transaction->writer_wait, &wait, 35779154b1bSChris Mason TASK_UNINTERRUPTIBLE); 35879154b1bSChris Mason if (trans->transaction->num_writers <= 1) 35979154b1bSChris Mason break; 36079154b1bSChris Mason mutex_unlock(&root->fs_info->trans_mutex); 36179154b1bSChris Mason schedule(); 36279154b1bSChris Mason mutex_lock(&root->fs_info->trans_mutex); 3632c90e5d6SChris Mason finish_wait(&trans->transaction->writer_wait, &wait); 36479154b1bSChris Mason } 36579154b1bSChris Mason finish_wait(&trans->transaction->writer_wait, &wait); 3662c90e5d6SChris Mason WARN_ON(cur_trans != trans->transaction); 36754aa1f4dSChris Mason ret = add_dirty_roots(trans, &root->fs_info->fs_roots_radix, 36854aa1f4dSChris Mason &dirty_fs_roots); 36954aa1f4dSChris Mason BUG_ON(ret); 37054aa1f4dSChris Mason 37179154b1bSChris Mason ret = btrfs_commit_tree_roots(trans, root); 37279154b1bSChris Mason BUG_ON(ret); 37354aa1f4dSChris Mason 37478fae27eSChris Mason cur_trans = root->fs_info->running_transaction; 37578fae27eSChris Mason root->fs_info->running_transaction = NULL; 3768fd17795SChris Mason if (cur_trans->list.prev != &root->fs_info->trans_list) { 3778fd17795SChris Mason prev_trans = list_entry(cur_trans->list.prev, 3788fd17795SChris Mason struct btrfs_transaction, list); 3798fd17795SChris Mason if (prev_trans->commit_done) 3808fd17795SChris Mason prev_trans = NULL; 3818fd17795SChris Mason else 3828fd17795SChris Mason prev_trans->use_count++; 3838fd17795SChris Mason } 38478fae27eSChris Mason mutex_unlock(&root->fs_info->trans_mutex); 3858fd17795SChris Mason mutex_unlock(&root->fs_info->fs_mutex); 38679154b1bSChris Mason ret = btrfs_write_and_wait_transaction(trans, root); 3878fd17795SChris Mason if (prev_trans) { 3888fd17795SChris Mason mutex_lock(&root->fs_info->trans_mutex); 3898fd17795SChris Mason wait_for_commit(root, prev_trans); 3908fd17795SChris Mason put_transaction(prev_trans); 3918fd17795SChris Mason mutex_unlock(&root->fs_info->trans_mutex); 3928fd17795SChris Mason } 3938fd17795SChris Mason btrfs_set_super_generation(root->fs_info->disk_super, 3948fd17795SChris Mason cur_trans->transid); 39579154b1bSChris Mason BUG_ON(ret); 39679154b1bSChris Mason write_ctree_super(trans, root); 3978fd17795SChris Mason 3988fd17795SChris Mason mutex_lock(&root->fs_info->fs_mutex); 39978fae27eSChris Mason btrfs_finish_extent_commit(trans, root); 40078fae27eSChris Mason mutex_lock(&root->fs_info->trans_mutex); 4012c90e5d6SChris Mason cur_trans->commit_done = 1; 4022c90e5d6SChris Mason wake_up(&cur_trans->commit_wait); 40379154b1bSChris Mason put_transaction(cur_trans); 40478fae27eSChris Mason put_transaction(cur_trans); 405facda1e7SChris Mason if (root->fs_info->closing) 406facda1e7SChris Mason list_splice_init(&root->fs_info->dead_roots, &dirty_fs_roots); 407facda1e7SChris Mason else 408facda1e7SChris Mason list_splice_init(&dirty_fs_roots, &root->fs_info->dead_roots); 40978fae27eSChris Mason mutex_unlock(&root->fs_info->trans_mutex); 4102c90e5d6SChris Mason kmem_cache_free(btrfs_trans_handle_cachep, trans); 41179154b1bSChris Mason 412facda1e7SChris Mason if (root->fs_info->closing) { 413facda1e7SChris Mason mutex_unlock(&root->fs_info->fs_mutex); 4140f7d52f4SChris Mason drop_dirty_roots(root->fs_info->tree_root, &dirty_fs_roots); 415facda1e7SChris Mason mutex_lock(&root->fs_info->fs_mutex); 416facda1e7SChris Mason } 41779154b1bSChris Mason return ret; 41879154b1bSChris Mason } 41979154b1bSChris Mason 42008607c1bSChris Mason void btrfs_transaction_cleaner(struct work_struct *work) 42108607c1bSChris Mason { 42208607c1bSChris Mason struct btrfs_fs_info *fs_info = container_of(work, 42308607c1bSChris Mason struct btrfs_fs_info, 42408607c1bSChris Mason trans_work.work); 42508607c1bSChris Mason 42608607c1bSChris Mason struct btrfs_root *root = fs_info->tree_root; 42708607c1bSChris Mason struct btrfs_transaction *cur; 42808607c1bSChris Mason struct btrfs_trans_handle *trans; 429facda1e7SChris Mason struct list_head dirty_roots; 43008607c1bSChris Mason unsigned long now; 43108607c1bSChris Mason unsigned long delay = HZ * 30; 43208607c1bSChris Mason int ret; 43308607c1bSChris Mason 434facda1e7SChris Mason INIT_LIST_HEAD(&dirty_roots); 43508607c1bSChris Mason mutex_lock(&root->fs_info->fs_mutex); 43608607c1bSChris Mason mutex_lock(&root->fs_info->trans_mutex); 43708607c1bSChris Mason cur = root->fs_info->running_transaction; 43808607c1bSChris Mason if (!cur) { 43908607c1bSChris Mason mutex_unlock(&root->fs_info->trans_mutex); 44008607c1bSChris Mason goto out; 44108607c1bSChris Mason } 44208607c1bSChris Mason now = get_seconds(); 44308607c1bSChris Mason if (now < cur->start_time || now - cur->start_time < 30) { 44408607c1bSChris Mason mutex_unlock(&root->fs_info->trans_mutex); 44508607c1bSChris Mason delay = HZ * 5; 44608607c1bSChris Mason goto out; 44708607c1bSChris Mason } 44808607c1bSChris Mason mutex_unlock(&root->fs_info->trans_mutex); 44908607c1bSChris Mason trans = btrfs_start_transaction(root, 1); 45008607c1bSChris Mason ret = btrfs_commit_transaction(trans, root); 45108607c1bSChris Mason out: 45208607c1bSChris Mason mutex_unlock(&root->fs_info->fs_mutex); 453ad693af6SChris Mason 454ad693af6SChris Mason mutex_lock(&root->fs_info->trans_mutex); 455ad693af6SChris Mason list_splice_init(&root->fs_info->dead_roots, &dirty_roots); 456ad693af6SChris Mason mutex_unlock(&root->fs_info->trans_mutex); 457ad693af6SChris Mason 458ad693af6SChris Mason if (!list_empty(&dirty_roots)) { 459ad693af6SChris Mason drop_dirty_roots(root, &dirty_roots); 460ad693af6SChris Mason } 46108607c1bSChris Mason btrfs_transaction_queue_work(root, delay); 46208607c1bSChris Mason } 46308607c1bSChris Mason 46408607c1bSChris Mason void btrfs_transaction_queue_work(struct btrfs_root *root, int delay) 46508607c1bSChris Mason { 46608607c1bSChris Mason queue_delayed_work(trans_wq, &root->fs_info->trans_work, delay); 46708607c1bSChris Mason } 46808607c1bSChris Mason 46908607c1bSChris Mason void btrfs_transaction_flush_work(struct btrfs_root *root) 47008607c1bSChris Mason { 47108607c1bSChris Mason cancel_rearming_delayed_workqueue(trans_wq, &root->fs_info->trans_work); 47208607c1bSChris Mason flush_workqueue(trans_wq); 47308607c1bSChris Mason } 47408607c1bSChris Mason 47508607c1bSChris Mason void __init btrfs_init_transaction_sys(void) 47608607c1bSChris Mason { 47708607c1bSChris Mason trans_wq = create_workqueue("btrfs"); 47808607c1bSChris Mason } 47908607c1bSChris Mason 48008607c1bSChris Mason void __exit btrfs_exit_transaction_sys(void) 48108607c1bSChris Mason { 48208607c1bSChris Mason destroy_workqueue(trans_wq); 48308607c1bSChris Mason } 48408607c1bSChris Mason 485