1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19#ifndef __BTRFS_TRANSACTION__
20#define __BTRFS_TRANSACTION__
21#include "btrfs_inode.h"
22#include "delayed-ref.h"
23#include "ctree.h"
24
25enum btrfs_trans_state {
26 TRANS_STATE_RUNNING = 0,
27 TRANS_STATE_BLOCKED = 1,
28 TRANS_STATE_COMMIT_START = 2,
29 TRANS_STATE_COMMIT_DOING = 3,
30 TRANS_STATE_UNBLOCKED = 4,
31 TRANS_STATE_COMPLETED = 5,
32 TRANS_STATE_MAX = 6,
33};
34
35#define BTRFS_TRANS_HAVE_FREE_BGS 0
36#define BTRFS_TRANS_DIRTY_BG_RUN 1
37#define BTRFS_TRANS_CACHE_ENOSPC 2
38
39struct btrfs_transaction {
40 u64 transid;
41
42
43
44
45
46 atomic_t num_extwriters;
47
48
49
50
51 atomic_t num_writers;
52 atomic_t use_count;
53 atomic_t pending_ordered;
54
55 unsigned long flags;
56
57
58 enum btrfs_trans_state state;
59 struct list_head list;
60 struct extent_io_tree dirty_pages;
61 unsigned long start_time;
62 wait_queue_head_t writer_wait;
63 wait_queue_head_t commit_wait;
64 wait_queue_head_t pending_wait;
65 struct list_head pending_snapshots;
66 struct list_head pending_chunks;
67 struct list_head switch_commits;
68 struct list_head dirty_bgs;
69 struct list_head io_bgs;
70 struct list_head dropped_roots;
71 u64 num_dirty_bgs;
72
73
74
75
76
77
78 struct mutex cache_write_mutex;
79 spinlock_t dirty_bgs_lock;
80
81 struct list_head deleted_bgs;
82 spinlock_t dropped_roots_lock;
83 struct btrfs_delayed_ref_root delayed_refs;
84 int aborted;
85};
86
87#define __TRANS_FREEZABLE (1U << 0)
88
89#define __TRANS_USERSPACE (1U << 8)
90#define __TRANS_START (1U << 9)
91#define __TRANS_ATTACH (1U << 10)
92#define __TRANS_JOIN (1U << 11)
93#define __TRANS_JOIN_NOLOCK (1U << 12)
94#define __TRANS_DUMMY (1U << 13)
95
96#define TRANS_USERSPACE (__TRANS_USERSPACE | __TRANS_FREEZABLE)
97#define TRANS_START (__TRANS_START | __TRANS_FREEZABLE)
98#define TRANS_ATTACH (__TRANS_ATTACH)
99#define TRANS_JOIN (__TRANS_JOIN | __TRANS_FREEZABLE)
100#define TRANS_JOIN_NOLOCK (__TRANS_JOIN_NOLOCK)
101
102#define TRANS_EXTWRITERS (__TRANS_USERSPACE | __TRANS_START | \
103 __TRANS_ATTACH)
104
105#define BTRFS_SEND_TRANS_STUB ((void *)1)
106
107struct btrfs_trans_handle {
108 u64 transid;
109 u64 bytes_reserved;
110 u64 chunk_bytes_reserved;
111 unsigned long use_count;
112 unsigned long blocks_reserved;
113 unsigned long delayed_ref_updates;
114 struct btrfs_transaction *transaction;
115 struct btrfs_block_rsv *block_rsv;
116 struct btrfs_block_rsv *orig_rsv;
117 short aborted;
118 short adding_csums;
119 bool allocating_chunk;
120 bool can_flush_pending_bgs;
121 bool reloc_reserved;
122 bool sync;
123 bool dirty;
124 unsigned int type;
125
126
127
128
129
130 struct btrfs_root *root;
131 struct btrfs_fs_info *fs_info;
132 struct seq_list delayed_ref_elem;
133 struct list_head qgroup_ref_list;
134 struct list_head new_bgs;
135};
136
137struct btrfs_pending_snapshot {
138 struct dentry *dentry;
139 struct inode *dir;
140 struct btrfs_root *root;
141 struct btrfs_root_item *root_item;
142 struct btrfs_root *snap;
143 struct btrfs_qgroup_inherit *inherit;
144 struct btrfs_path *path;
145
146 struct btrfs_block_rsv block_rsv;
147 u64 qgroup_reserved;
148
149 int error;
150 bool readonly;
151 struct list_head list;
152};
153
154static inline void btrfs_set_inode_last_trans(struct btrfs_trans_handle *trans,
155 struct inode *inode)
156{
157 spin_lock(&BTRFS_I(inode)->lock);
158 BTRFS_I(inode)->last_trans = trans->transaction->transid;
159 BTRFS_I(inode)->last_sub_trans = BTRFS_I(inode)->root->log_transid;
160 BTRFS_I(inode)->last_log_commit = BTRFS_I(inode)->root->last_log_commit;
161 spin_unlock(&BTRFS_I(inode)->lock);
162}
163
164
165
166
167
168static inline void btrfs_set_skip_qgroup(struct btrfs_trans_handle *trans,
169 u64 qgroupid)
170{
171 struct btrfs_delayed_ref_root *delayed_refs;
172
173 delayed_refs = &trans->transaction->delayed_refs;
174 WARN_ON(delayed_refs->qgroup_to_skip);
175 delayed_refs->qgroup_to_skip = qgroupid;
176}
177
178static inline void btrfs_clear_skip_qgroup(struct btrfs_trans_handle *trans)
179{
180 struct btrfs_delayed_ref_root *delayed_refs;
181
182 delayed_refs = &trans->transaction->delayed_refs;
183 WARN_ON(!delayed_refs->qgroup_to_skip);
184 delayed_refs->qgroup_to_skip = 0;
185}
186
187int btrfs_end_transaction(struct btrfs_trans_handle *trans,
188 struct btrfs_root *root);
189struct btrfs_trans_handle *btrfs_start_transaction(struct btrfs_root *root,
190 unsigned int num_items);
191struct btrfs_trans_handle *btrfs_start_transaction_fallback_global_rsv(
192 struct btrfs_root *root,
193 unsigned int num_items,
194 int min_factor);
195struct btrfs_trans_handle *btrfs_start_transaction_lflush(
196 struct btrfs_root *root,
197 unsigned int num_items);
198struct btrfs_trans_handle *btrfs_join_transaction(struct btrfs_root *root);
199struct btrfs_trans_handle *btrfs_join_transaction_nolock(struct btrfs_root *root);
200struct btrfs_trans_handle *btrfs_attach_transaction(struct btrfs_root *root);
201struct btrfs_trans_handle *btrfs_attach_transaction_barrier(
202 struct btrfs_root *root);
203struct btrfs_trans_handle *btrfs_start_ioctl_transaction(struct btrfs_root *root);
204int btrfs_wait_for_commit(struct btrfs_root *root, u64 transid);
205
206void btrfs_add_dead_root(struct btrfs_root *root);
207int btrfs_defrag_root(struct btrfs_root *root);
208int btrfs_clean_one_deleted_snapshot(struct btrfs_root *root);
209int btrfs_commit_transaction(struct btrfs_trans_handle *trans,
210 struct btrfs_root *root);
211int btrfs_commit_transaction_async(struct btrfs_trans_handle *trans,
212 struct btrfs_root *root,
213 int wait_for_unblock);
214int btrfs_end_transaction_throttle(struct btrfs_trans_handle *trans,
215 struct btrfs_root *root);
216int btrfs_should_end_transaction(struct btrfs_trans_handle *trans,
217 struct btrfs_root *root);
218void btrfs_throttle(struct btrfs_root *root);
219int btrfs_record_root_in_trans(struct btrfs_trans_handle *trans,
220 struct btrfs_root *root);
221int btrfs_write_marked_extents(struct btrfs_root *root,
222 struct extent_io_tree *dirty_pages, int mark);
223int btrfs_wait_marked_extents(struct btrfs_root *root,
224 struct extent_io_tree *dirty_pages, int mark);
225int btrfs_transaction_blocked(struct btrfs_fs_info *info);
226int btrfs_transaction_in_commit(struct btrfs_fs_info *info);
227void btrfs_put_transaction(struct btrfs_transaction *transaction);
228void btrfs_apply_pending_changes(struct btrfs_fs_info *fs_info);
229void btrfs_add_dropped_root(struct btrfs_trans_handle *trans,
230 struct btrfs_root *root);
231#endif
232