Line data Source code
1 : // SPDX-License-Identifier: GPL-2.0
2 : /*
3 : * Copyright (c) 2000-2002,2005 Silicon Graphics, Inc.
4 : * All Rights Reserved.
5 : */
6 : #ifndef __XFS_TRANS_H__
7 : #define __XFS_TRANS_H__
8 :
9 : /* kernel only transaction subsystem defines */
10 :
11 : struct xlog;
12 : struct xfs_buf;
13 : struct xfs_buftarg;
14 : struct xfs_efd_log_item;
15 : struct xfs_efi_log_item;
16 : struct xfs_inode;
17 : struct xfs_item_ops;
18 : struct xfs_log_iovec;
19 : struct xfs_mount;
20 : struct xfs_trans;
21 : struct xfs_trans_res;
22 : struct xfs_dquot_acct;
23 : struct xfs_rud_log_item;
24 : struct xfs_rui_log_item;
25 : struct xfs_btree_cur;
26 : struct xfs_cui_log_item;
27 : struct xfs_cud_log_item;
28 : struct xfs_bui_log_item;
29 : struct xfs_bud_log_item;
30 :
31 : struct xfs_log_item {
32 : struct list_head li_ail; /* AIL pointers */
33 : struct list_head li_trans; /* transaction list */
34 : xfs_lsn_t li_lsn; /* last on-disk lsn */
35 : struct xlog *li_log;
36 : struct xfs_ail *li_ailp; /* ptr to AIL */
37 : uint li_type; /* item type */
38 : unsigned long li_flags; /* misc flags */
39 : struct xfs_buf *li_buf; /* real buffer pointer */
40 : struct list_head li_bio_list; /* buffer item list */
41 : const struct xfs_item_ops *li_ops; /* function list */
42 :
43 : /* delayed logging */
44 : struct list_head li_cil; /* CIL pointers */
45 : struct xfs_log_vec *li_lv; /* active log vector */
46 : struct xfs_log_vec *li_lv_shadow; /* standby vector */
47 : xfs_csn_t li_seq; /* CIL commit seq */
48 : uint32_t li_order_id; /* CIL commit order */
49 : };
50 :
51 : /*
52 : * li_flags use the (set/test/clear)_bit atomic interfaces because updates can
53 : * race with each other and we don't want to have to use the AIL lock to
54 : * serialise all updates.
55 : */
56 : #define XFS_LI_IN_AIL 0
57 : #define XFS_LI_ABORTED 1
58 : #define XFS_LI_FAILED 2
59 : #define XFS_LI_DIRTY 3
60 : #define XFS_LI_WHITEOUT 4
61 :
62 : #define XFS_LI_FLAGS \
63 : { (1u << XFS_LI_IN_AIL), "IN_AIL" }, \
64 : { (1u << XFS_LI_ABORTED), "ABORTED" }, \
65 : { (1u << XFS_LI_FAILED), "FAILED" }, \
66 : { (1u << XFS_LI_DIRTY), "DIRTY" }, \
67 : { (1u << XFS_LI_WHITEOUT), "WHITEOUT" }
68 :
69 : struct xfs_item_ops {
70 : unsigned flags;
71 : void (*iop_size)(struct xfs_log_item *, int *, int *);
72 : void (*iop_format)(struct xfs_log_item *, struct xfs_log_vec *);
73 : void (*iop_pin)(struct xfs_log_item *);
74 : void (*iop_unpin)(struct xfs_log_item *, int remove);
75 : uint64_t (*iop_sort)(struct xfs_log_item *lip);
76 : int (*iop_precommit)(struct xfs_trans *tp, struct xfs_log_item *lip);
77 : void (*iop_committing)(struct xfs_log_item *lip, xfs_csn_t seq);
78 : xfs_lsn_t (*iop_committed)(struct xfs_log_item *, xfs_lsn_t);
79 : uint (*iop_push)(struct xfs_log_item *, struct list_head *);
80 : void (*iop_release)(struct xfs_log_item *);
81 : int (*iop_recover)(struct xfs_log_item *lip,
82 : struct list_head *capture_list);
83 : bool (*iop_match)(struct xfs_log_item *item, uint64_t id);
84 : struct xfs_log_item *(*iop_relog)(struct xfs_log_item *intent,
85 : struct xfs_trans *tp);
86 : struct xfs_log_item *(*iop_intent)(struct xfs_log_item *intent_done);
87 : };
88 :
89 : /*
90 : * Log item ops flags
91 : */
92 : /*
93 : * Release the log item when the journal commits instead of inserting into the
94 : * AIL for writeback tracking and/or log tail pinning.
95 : */
96 : #define XFS_ITEM_RELEASE_WHEN_COMMITTED (1 << 0)
97 : #define XFS_ITEM_INTENT (1 << 1)
98 : #define XFS_ITEM_INTENT_DONE (1 << 2)
99 :
100 : static inline bool
101 : xlog_item_is_intent(struct xfs_log_item *lip)
102 : {
103 5221 : return lip->li_ops->flags & XFS_ITEM_INTENT;
104 : }
105 :
106 : static inline bool
107 : xlog_item_is_intent_done(struct xfs_log_item *lip)
108 : {
109 403683062 : return lip->li_ops->flags & XFS_ITEM_INTENT_DONE;
110 : }
111 :
112 : void xfs_log_item_init(struct xfs_mount *mp, struct xfs_log_item *item,
113 : int type, const struct xfs_item_ops *ops);
114 :
115 : /*
116 : * Return values for the iop_push() routines.
117 : */
118 : #define XFS_ITEM_SUCCESS 0
119 : #define XFS_ITEM_PINNED 1
120 : #define XFS_ITEM_LOCKED 2
121 : #define XFS_ITEM_FLUSHING 3
122 :
123 : /*
124 : * This is the structure maintained for every active transaction.
125 : */
126 : typedef struct xfs_trans {
127 : unsigned int t_magic; /* magic number */
128 : unsigned int t_log_res; /* amt of log space resvd */
129 : unsigned int t_log_count; /* count for perm log res */
130 : unsigned int t_blk_res; /* # of blocks resvd */
131 : unsigned int t_blk_res_used; /* # of resvd blocks used */
132 : unsigned int t_rtx_res; /* # of rt extents resvd */
133 : unsigned int t_rtx_res_used; /* # of resvd rt extents used */
134 : unsigned int t_flags; /* misc flags */
135 : xfs_agnumber_t t_highest_agno; /* highest AGF locked */
136 : struct xlog_ticket *t_ticket; /* log mgr ticket */
137 : struct xfs_mount *t_mountp; /* ptr to fs mount struct */
138 : struct xfs_dquot_acct *t_dqinfo; /* acctg info for dquots */
139 : int64_t t_icount_delta; /* superblock icount change */
140 : int64_t t_ifree_delta; /* superblock ifree change */
141 : int64_t t_fdblocks_delta; /* superblock fdblocks chg */
142 : int64_t t_res_fdblocks_delta; /* on-disk only chg */
143 : int64_t t_frextents_delta;/* superblock freextents chg*/
144 : int64_t t_res_frextents_delta; /* on-disk only chg */
145 : int64_t t_dblocks_delta;/* superblock dblocks change */
146 : int64_t t_agcount_delta;/* superblock agcount change */
147 : int64_t t_imaxpct_delta;/* superblock imaxpct change */
148 : int64_t t_rextsize_delta;/* superblock rextsize chg */
149 : int64_t t_rbmblocks_delta;/* superblock rbmblocks chg */
150 : int64_t t_rblocks_delta;/* superblock rblocks change */
151 : int64_t t_rextents_delta;/* superblocks rextents chg */
152 : int64_t t_rextslog_delta;/* superblocks rextslog chg */
153 : struct list_head t_items; /* log item descriptors */
154 : struct list_head t_busy; /* list of busy extents */
155 : struct list_head t_dfops; /* deferred operations */
156 : unsigned long t_pflags; /* saved process flags state */
157 :
158 : /* Count of deferred ops attached to transaction. */
159 : unsigned int t_dfops_nr;
160 : /* Maximum t_dfops_nr seen in a loop. */
161 : unsigned int t_dfops_nr_max;
162 : /* Number of dfops finished. */
163 : unsigned int t_dfops_finished;
164 : } xfs_trans_t;
165 :
166 : /*
167 : * XFS transaction mechanism exported interfaces that are
168 : * actually macros.
169 : */
170 : #define xfs_trans_set_sync(tp) ((tp)->t_flags |= XFS_TRANS_SYNC)
171 :
172 : /*
173 : * XFS transaction mechanism exported interfaces.
174 : */
175 : int xfs_trans_alloc(struct xfs_mount *mp, struct xfs_trans_res *resp,
176 : uint blocks, uint rtextents, uint flags,
177 : struct xfs_trans **tpp);
178 : int xfs_trans_reserve_more(struct xfs_trans *tp,
179 : unsigned int blocks, unsigned int rtextents);
180 : int xfs_trans_alloc_empty(struct xfs_mount *mp,
181 : struct xfs_trans **tpp);
182 : void xfs_trans_mod_sb(xfs_trans_t *, uint, int64_t);
183 :
184 : int xfs_trans_get_buf_map(struct xfs_trans *tp, struct xfs_buftarg *target,
185 : struct xfs_buf_map *map, int nmaps, xfs_buf_flags_t flags,
186 : struct xfs_buf **bpp);
187 :
188 : static inline int
189 : xfs_trans_get_buf(
190 : struct xfs_trans *tp,
191 : struct xfs_buftarg *target,
192 : xfs_daddr_t blkno,
193 : int numblks,
194 : xfs_buf_flags_t flags,
195 : struct xfs_buf **bpp)
196 : {
197 60334989 : DEFINE_SINGLE_BUF_MAP(map, blkno, numblks);
198 60334989 : return xfs_trans_get_buf_map(tp, target, &map, 1, flags, bpp);
199 : }
200 :
201 : int xfs_trans_read_buf_map(struct xfs_mount *mp,
202 : struct xfs_trans *tp,
203 : struct xfs_buftarg *target,
204 : struct xfs_buf_map *map, int nmaps,
205 : xfs_buf_flags_t flags,
206 : struct xfs_buf **bpp,
207 : const struct xfs_buf_ops *ops);
208 :
209 : static inline int
210 : xfs_trans_read_buf(
211 : struct xfs_mount *mp,
212 : struct xfs_trans *tp,
213 : struct xfs_buftarg *target,
214 : xfs_daddr_t blkno,
215 : int numblks,
216 : xfs_buf_flags_t flags,
217 : struct xfs_buf **bpp,
218 : const struct xfs_buf_ops *ops)
219 : {
220 22264878772 : DEFINE_SINGLE_BUF_MAP(map, blkno, numblks);
221 22264878772 : return xfs_trans_read_buf_map(mp, tp, target, &map, 1,
222 : flags, bpp, ops);
223 : }
224 :
225 : struct xfs_buf *xfs_trans_getsb(struct xfs_trans *);
226 :
227 : void xfs_trans_brelse(xfs_trans_t *, struct xfs_buf *);
228 : void xfs_trans_bjoin(xfs_trans_t *, struct xfs_buf *);
229 : void xfs_trans_bdetach(struct xfs_trans *tp, struct xfs_buf *bp);
230 : void xfs_trans_bhold(xfs_trans_t *, struct xfs_buf *);
231 : void xfs_trans_bhold_release(xfs_trans_t *, struct xfs_buf *);
232 : void xfs_trans_binval(xfs_trans_t *, struct xfs_buf *);
233 : void xfs_trans_inode_buf(xfs_trans_t *, struct xfs_buf *);
234 : void xfs_trans_stale_inode_buf(xfs_trans_t *, struct xfs_buf *);
235 : bool xfs_trans_ordered_buf(xfs_trans_t *, struct xfs_buf *);
236 : void xfs_trans_dquot_buf(xfs_trans_t *, struct xfs_buf *, uint);
237 : void xfs_trans_inode_alloc_buf(xfs_trans_t *, struct xfs_buf *);
238 : void xfs_trans_ichgtime(struct xfs_trans *, struct xfs_inode *, int);
239 : void xfs_trans_ijoin(struct xfs_trans *, struct xfs_inode *, uint);
240 : void xfs_trans_log_buf(struct xfs_trans *, struct xfs_buf *, uint,
241 : uint);
242 : void xfs_trans_dirty_buf(struct xfs_trans *, struct xfs_buf *);
243 : bool xfs_trans_buf_is_dirty(struct xfs_buf *bp);
244 : void xfs_trans_log_inode(xfs_trans_t *, struct xfs_inode *, uint);
245 :
246 : int xfs_trans_commit(struct xfs_trans *);
247 : int xfs_trans_roll(struct xfs_trans **);
248 : int xfs_trans_roll_inode(struct xfs_trans **, struct xfs_inode *);
249 : void xfs_trans_cancel(xfs_trans_t *);
250 : int xfs_trans_ail_init(struct xfs_mount *);
251 : void xfs_trans_ail_destroy(struct xfs_mount *);
252 :
253 : void xfs_trans_buf_set_type(struct xfs_trans *, struct xfs_buf *,
254 : enum xfs_blft);
255 : void xfs_trans_buf_copy_type(struct xfs_buf *dst_bp,
256 : struct xfs_buf *src_bp);
257 :
258 : extern struct kmem_cache *xfs_trans_cache;
259 :
260 : static inline struct xfs_log_item *
261 : xfs_trans_item_relog(
262 : struct xfs_log_item *lip,
263 : struct xfs_trans *tp)
264 : {
265 76077 : return lip->li_ops->iop_relog(lip, tp);
266 : }
267 :
268 : struct xfs_dquot;
269 :
270 : int xfs_trans_alloc_inode(struct xfs_inode *ip, struct xfs_trans_res *resv,
271 : unsigned int dblocks, unsigned int rblocks, bool force,
272 : struct xfs_trans **tpp);
273 : int xfs_trans_reserve_more_inode(struct xfs_trans *tp, struct xfs_inode *ip,
274 : unsigned int dblocks, unsigned int rblocks, bool force_quota);
275 : int xfs_trans_alloc_icreate(struct xfs_mount *mp, struct xfs_trans_res *resv,
276 : struct xfs_dquot *udqp, struct xfs_dquot *gdqp,
277 : struct xfs_dquot *pdqp, unsigned int dblocks,
278 : struct xfs_trans **tpp);
279 : int xfs_trans_alloc_ichange(struct xfs_inode *ip, struct xfs_dquot *udqp,
280 : struct xfs_dquot *gdqp, struct xfs_dquot *pdqp, bool force,
281 : struct xfs_trans **tpp);
282 : int xfs_trans_alloc_dir(struct xfs_inode *dp, struct xfs_trans_res *resv,
283 : struct xfs_inode *ip, unsigned int *dblocks,
284 : struct xfs_trans **tpp, int *nospace_error);
285 :
286 : static inline void
287 3171449060 : xfs_trans_set_context(
288 : struct xfs_trans *tp)
289 : {
290 3171449060 : ASSERT(current->journal_info == NULL);
291 3171449060 : tp->t_pflags = memalloc_nofs_save();
292 3171449060 : current->journal_info = tp;
293 3171449060 : }
294 :
295 : static inline void
296 4501601521 : xfs_trans_clear_context(
297 : struct xfs_trans *tp)
298 : {
299 4501601521 : if (current->journal_info == tp) {
300 3172230165 : memalloc_nofs_restore(tp->t_pflags);
301 3172230165 : current->journal_info = NULL;
302 : }
303 4501601521 : }
304 :
305 : static inline void
306 1330992095 : xfs_trans_switch_context(
307 : struct xfs_trans *old_tp,
308 : struct xfs_trans *new_tp)
309 : {
310 1330992095 : ASSERT(current->journal_info == old_tp);
311 1330992095 : new_tp->t_pflags = old_tp->t_pflags;
312 1330992095 : old_tp->t_pflags = 0;
313 1330992095 : current->journal_info = new_tp;
314 1330992095 : }
315 :
316 : #endif /* __XFS_TRANS_H__ */
|
