transaction.h 2.8 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788
  1. /*
  2. * Copyright (C) 2007 Oracle. All rights reserved.
  3. *
  4. * This program is free software; you can redistribute it and/or
  5. * modify it under the terms of the GNU General Public
  6. * License v2 as published by the Free Software Foundation.
  7. *
  8. * This program is distributed in the hope that it will be useful,
  9. * but WITHOUT ANY WARRANTY; without even the implied warranty of
  10. * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
  11. * General Public License for more details.
  12. *
  13. * You should have received a copy of the GNU General Public
  14. * License along with this program; if not, write to the
  15. * Free Software Foundation, Inc., 59 Temple Place - Suite 330,
  16. * Boston, MA 021110-1307, USA.
  17. */
  18. #ifndef __TRANSACTION__
  19. #define __TRANSACTION__
  20. #include "btrfs_inode.h"
  21. struct btrfs_transaction {
  22. u64 transid;
  23. unsigned long num_writers;
  24. unsigned long num_joined;
  25. int in_commit;
  26. int use_count;
  27. int commit_done;
  28. struct list_head list;
  29. struct extent_map_tree dirty_pages;
  30. unsigned long start_time;
  31. wait_queue_head_t writer_wait;
  32. wait_queue_head_t commit_wait;
  33. };
  34. struct btrfs_trans_handle {
  35. u64 transid;
  36. unsigned long blocks_reserved;
  37. unsigned long blocks_used;
  38. struct btrfs_transaction *transaction;
  39. struct btrfs_block_group_cache *block_group;
  40. u64 alloc_exclude_start;
  41. u64 alloc_exclude_nr;
  42. };
  43. static inline void btrfs_set_trans_block_group(struct btrfs_trans_handle *trans,
  44. struct inode *inode)
  45. {
  46. trans->block_group = BTRFS_I(inode)->block_group;
  47. }
  48. static inline void btrfs_update_inode_block_group(struct
  49. btrfs_trans_handle *trans,
  50. struct inode *inode)
  51. {
  52. BTRFS_I(inode)->block_group = trans->block_group;
  53. }
  54. static inline void btrfs_set_inode_last_trans(struct btrfs_trans_handle *trans,
  55. struct inode *inode)
  56. {
  57. BTRFS_I(inode)->last_trans = trans->transaction->transid;
  58. }
  59. int btrfs_end_transaction(struct btrfs_trans_handle *trans,
  60. struct btrfs_root *root);
  61. struct btrfs_trans_handle *btrfs_start_transaction(struct btrfs_root *root,
  62. int num_blocks);
  63. int btrfs_write_and_wait_transaction(struct btrfs_trans_handle *trans,
  64. struct btrfs_root *root);
  65. int btrfs_commit_tree_roots(struct btrfs_trans_handle *trans,
  66. struct btrfs_root *root);
  67. void btrfs_transaction_cleaner(struct work_struct *work);
  68. void btrfs_transaction_flush_work(struct btrfs_root *root);
  69. void btrfs_transaction_queue_work(struct btrfs_root *root, int delay);
  70. void btrfs_init_transaction_sys(void);
  71. void btrfs_exit_transaction_sys(void);
  72. int btrfs_add_dead_root(struct btrfs_root *root, struct btrfs_root *latest,
  73. struct list_head *dead_list);
  74. int btrfs_defrag_dirty_roots(struct btrfs_fs_info *info);
  75. int btrfs_defrag_root(struct btrfs_root *root, int cacheonly);
  76. int btrfs_clean_old_snapshots(struct btrfs_root *root);
  77. int btrfs_commit_transaction(struct btrfs_trans_handle *trans,
  78. struct btrfs_root *root);
  79. #endif