| 1 | |
| 2 | |
| 3 | * ext4_jbd2.h
|
| 4 | *
|
| 5 | * Written by Stephen C. Tweedie <[email protected]>, 1999
|
| 6 | *
|
| 7 | * Copyright 1998--1999 Red Hat corp --- All Rights Reserved
|
| 8 | *
|
| 9 | * Ext4-specific journaling extensions.
|
| 10 |
|
| 11 |
|
| 12 | #ifndef _EXT4_JBD2_H
|
| 13 | #define _EXT4_JBD2_H
|
| 14 |
|
| 15 | #include <linux/fs.h>
|
| 16 | #include <linux/jbd2.h>
|
| 17 | #include "ext4.h"
|
| 18 |
|
| 19 | #define EXT4_JOURNAL(inode) (EXT4_SB((inode)->i_sb)->s_journal)
|
| 20 |
|
| 21 | |
| 22 | * modify one block of data.
|
| 23 | *
|
| 24 | * We may have to touch one inode, one bitmap buffer, up to three
|
| 25 | * indirection blocks, the group and superblock summaries, and the data
|
| 26 | * block to complete the transaction.
|
| 27 | *
|
| 28 | * For extents-enabled fs we may have to allocate and modify up to
|
| 29 | * 5 levels of tree, data block (for each of these we need bitmap + group
|
| 30 | * summaries), root which is stored in the inode, sb
|
| 31 |
|
| 32 |
|
| 33 | #define EXT4_SINGLEDATA_TRANS_BLOCKS(sb) \
|
| 34 | (ext4_has_feature_extents(sb) ? 20U : 8U)
|
| 35 |
|
| 36 | |
| 37 | * two bitmap buffers, and two group summaries, in addition to the inode
|
| 38 | * and the superblock, which are already accounted for.
|
| 39 |
|
| 40 | #define EXT4_XATTR_TRANS_BLOCKS 6U
|
| 41 |
|
| 42 | |
| 43 | * needs to take into account the fact that we may end up modifying two
|
| 44 | * quota files too (one for the group, one for the user quota). The
|
| 45 | * superblock only gets updated once, of course, so don't bother
|
| 46 | * counting that again for the quota updates.
|
| 47 |
|
| 48 | #define EXT4_DATA_TRANS_BLOCKS(sb) (EXT4_SINGLEDATA_TRANS_BLOCKS(sb) + \
|
| 49 | EXT4_XATTR_TRANS_BLOCKS - 2 + \
|
| 50 | EXT4_MAXQUOTAS_TRANS_BLOCKS(sb))
|
| 51 |
|
| 52 | |
| 53 | * Define the number of metadata blocks we need to account to modify data.
|
| 54 | *
|
| 55 | * This include super block, inode block, quota blocks and xattr blocks
|
| 56 |
|
| 57 | #define EXT4_META_TRANS_BLOCKS(sb) (EXT4_XATTR_TRANS_BLOCKS + \
|
| 58 | EXT4_MAXQUOTAS_TRANS_BLOCKS(sb))
|
| 59 |
|
| 60 | |
| 61 | * writing to any given transaction. For unbounded transactions such as
|
| 62 | * write(2) and truncate(2) we can write more than this, but we always
|
| 63 | * start off at the maximum transaction size and grow the transaction
|
| 64 | * optimistically as we go.
|
| 65 |
|
| 66 | #define EXT4_MAX_TRANS_DATA 64U
|
| 67 |
|
| 68 | |
| 69 | * buffer credits gets this low, we need either to extend the
|
| 70 | * transaction or to start a new one. Reserve enough space here for
|
| 71 | * inode, bitmap, superblock, group and indirection updates for at least
|
| 72 | * one block, plus two quota updates. Quota allocations are not
|
| 73 | * needed.
|
| 74 |
|
| 75 | #define EXT4_RESERVE_TRANS_BLOCKS 12U
|
| 76 |
|
| 77 | |
| 78 | * Number of credits needed if we need to insert an entry into a
|
| 79 | * directory. For each new index block, we need 4 blocks (old index
|
| 80 | * block, new index block, bitmap block, bg summary). For normal
|
| 81 | * htree directories there are 2 levels; if the largedir feature
|
| 82 | * enabled it's 3 levels.
|
| 83 |
|
| 84 | #define EXT4_INDEX_EXTRA_TRANS_BLOCKS 12U
|
| 85 |
|
| 86 | #ifdef CONFIG_QUOTA
|
| 87 | |
| 88 | * allocated so we need to update only data block
|
| 89 | #define EXT4_QUOTA_TRANS_BLOCKS(sb) ((ext4_quota_capable(sb)) ? 1 : 0)
|
| 90 | |
| 91 | * but inode, sb and group updates are done only once
|
| 92 | #define EXT4_QUOTA_INIT_BLOCKS(sb) ((ext4_quota_capable(sb)) ?\
|
| 93 | (DQUOT_INIT_ALLOC*(EXT4_SINGLEDATA_TRANS_BLOCKS(sb)-3)\
|
| 94 | +3+DQUOT_INIT_REWRITE) : 0)
|
| 95 |
|
| 96 | #define EXT4_QUOTA_DEL_BLOCKS(sb) ((ext4_quota_capable(sb)) ?\
|
| 97 | (DQUOT_DEL_ALLOC*(EXT4_SINGLEDATA_TRANS_BLOCKS(sb)-3)\
|
| 98 | +3+DQUOT_DEL_REWRITE) : 0)
|
| 99 | #else
|
| 100 | #define EXT4_QUOTA_TRANS_BLOCKS(sb) 0
|
| 101 | #define EXT4_QUOTA_INIT_BLOCKS(sb) 0
|
| 102 | #define EXT4_QUOTA_DEL_BLOCKS(sb) 0
|
| 103 | #endif
|
| 104 | #define EXT4_MAXQUOTAS_TRANS_BLOCKS(sb) (EXT4_MAXQUOTAS*EXT4_QUOTA_TRANS_BLOCKS(sb))
|
| 105 | #define EXT4_MAXQUOTAS_INIT_BLOCKS(sb) (EXT4_MAXQUOTAS*EXT4_QUOTA_INIT_BLOCKS(sb))
|
| 106 | #define EXT4_MAXQUOTAS_DEL_BLOCKS(sb) (EXT4_MAXQUOTAS*EXT4_QUOTA_DEL_BLOCKS(sb))
|
| 107 |
|
| 108 | |
| 109 | * Ext4 handle operation types -- for logging purposes
|
| 110 |
|
| 111 | #define EXT4_HT_MISC 0
|
| 112 | #define EXT4_HT_INODE 1
|
| 113 | #define EXT4_HT_WRITE_PAGE 2
|
| 114 | #define EXT4_HT_MAP_BLOCKS 3
|
| 115 | #define EXT4_HT_DIR 4
|
| 116 | #define EXT4_HT_TRUNCATE 5
|
| 117 | #define EXT4_HT_QUOTA 6
|
| 118 | #define EXT4_HT_RESIZE 7
|
| 119 | #define EXT4_HT_MIGRATE 8
|
| 120 | #define EXT4_HT_MOVE_EXTENTS 9
|
| 121 | #define EXT4_HT_XATTR 10
|
| 122 | #define EXT4_HT_EXT_CONVERT 11
|
| 123 | #define EXT4_HT_MAX 12
|
| 124 |
|
| 125 | int
|
| 126 | ext4_mark_iloc_dirty(handle_t *handle,
|
| 127 | struct inode *inode,
|
| 128 | struct ext4_iloc *iloc);
|
| 129 |
|
| 130 | |
| 131 | * On success, We end up with an outstanding reference count against
|
| 132 | * iloc->bh. This _must_ be cleaned up later.
|
| 133 |
|
| 134 |
|
| 135 | int ext4_reserve_inode_write(handle_t *handle, struct inode *inode,
|
| 136 | struct ext4_iloc *iloc);
|
| 137 |
|
| 138 | #define ext4_mark_inode_dirty(__h, __i) \
|
| 139 | __ext4_mark_inode_dirty((__h), (__i), __func__, __LINE__)
|
| 140 | int __ext4_mark_inode_dirty(handle_t *handle, struct inode *inode,
|
| 141 | const char *func, unsigned int line);
|
| 142 |
|
| 143 | int ext4_expand_extra_isize(struct inode *inode,
|
| 144 | unsigned int new_extra_isize,
|
| 145 | struct ext4_iloc *iloc);
|
| 146 | |
| 147 | * Wrapper functions with which ext4 calls into JBD.
|
| 148 |
|
| 149 | int __ext4_journal_get_write_access(const char *where, unsigned int line,
|
| 150 | handle_t *handle, struct super_block *sb,
|
| 151 | struct buffer_head *bh,
|
| 152 | enum ext4_journal_trigger_type trigger_type);
|
| 153 |
|
| 154 | int __ext4_forget(const char *where, unsigned int line, handle_t *handle,
|
| 155 | int is_metadata, struct inode *inode,
|
| 156 | struct buffer_head *bh, ext4_fsblk_t blocknr);
|
| 157 |
|
| 158 | int __ext4_journal_get_create_access(const char *where, unsigned int line,
|
| 159 | handle_t *handle, struct super_block *sb,
|
| 160 | struct buffer_head *bh,
|
| 161 | enum ext4_journal_trigger_type trigger_type);
|
| 162 |
|
| 163 | int __ext4_handle_dirty_metadata(const char *where, unsigned int line,
|
| 164 | handle_t *handle, struct inode *inode,
|
| 165 | struct buffer_head *bh);
|
| 166 |
|
| 167 | #define ext4_journal_get_write_access(handle, sb, bh, trigger_type) \
|
| 168 | __ext4_journal_get_write_access(__func__, __LINE__, (handle), (sb), \
|
| 169 | (bh), (trigger_type))
|
| 170 | #define ext4_forget(handle, is_metadata, inode, bh, block_nr) \
|
| 171 | __ext4_forget(__func__, __LINE__, (handle), (is_metadata), (inode), \
|
| 172 | (bh), (block_nr))
|
| 173 | #define ext4_journal_get_create_access(handle, sb, bh, trigger_type) \
|
| 174 | __ext4_journal_get_create_access(__func__, __LINE__, (handle), (sb), \
|
| 175 | (bh), (trigger_type))
|
| 176 | #define ext4_handle_dirty_metadata(handle, inode, bh) \
|
| 177 | __ext4_handle_dirty_metadata(__func__, __LINE__, (handle), (inode), \
|
| 178 | (bh))
|
| 179 |
|
| 180 | handle_t *__ext4_journal_start_sb(struct inode *inode, struct super_block *sb,
|
| 181 | unsigned int line, int type, int blocks,
|
| 182 | int rsv_blocks, int revoke_creds);
|
| 183 | int __ext4_journal_stop(const char *where, unsigned int line, handle_t *handle);
|
| 184 |
|
| 185 | |
| 186 | * a properly allocated handle is using a journal or not.
|
| 187 | static inline int ext4_handle_valid(handle_t *handle)
|
| 188 | {
|
| 189 | return (handle && !handle->h_invalid);
|
| 190 | }
|
| 191 |
|
| 192 | static inline void ext4_handle_sync(handle_t *handle)
|
| 193 | {
|
| 194 | if (ext4_handle_valid(handle))
|
| 195 | handle->h_sync = 1;
|
| 196 | }
|
| 197 |
|
| 198 | static inline int ext4_handle_is_aborted(handle_t *handle)
|
| 199 | {
|
| 200 | if (ext4_handle_valid(handle))
|
| 201 | return is_handle_aborted(handle);
|
| 202 | return 0;
|
| 203 | }
|
| 204 |
|
| 205 | static inline int ext4_free_metadata_revoke_credits(struct super_block *sb,
|
| 206 | int blocks)
|
| 207 | {
|
| 208 |
|
| 209 | return blocks * EXT4_SB(sb)->s_cluster_ratio;
|
| 210 | }
|
| 211 |
|
| 212 | static inline int ext4_trans_default_revoke_credits(struct super_block *sb)
|
| 213 | {
|
| 214 | return ext4_free_metadata_revoke_credits(sb, 8);
|
| 215 | }
|
| 216 |
|
| 217 | #define ext4_journal_start_sb(sb, type, nblocks) \
|
| 218 | __ext4_journal_start_sb(NULL, (sb), __LINE__, (type), (nblocks), 0,\
|
| 219 | ext4_trans_default_revoke_credits(sb))
|
| 220 |
|
| 221 | #define ext4_journal_start(inode, type, nblocks) \
|
| 222 | __ext4_journal_start((inode), __LINE__, (type), (nblocks), 0, \
|
| 223 | ext4_trans_default_revoke_credits((inode)->i_sb))
|
| 224 |
|
| 225 | #define ext4_journal_start_with_reserve(inode, type, blocks, rsv_blocks)\
|
| 226 | __ext4_journal_start((inode), __LINE__, (type), (blocks), (rsv_blocks),\
|
| 227 | ext4_trans_default_revoke_credits((inode)->i_sb))
|
| 228 |
|
| 229 | #define ext4_journal_start_with_revoke(inode, type, blocks, revoke_creds) \
|
| 230 | __ext4_journal_start((inode), __LINE__, (type), (blocks), 0, \
|
| 231 | (revoke_creds))
|
| 232 |
|
| 233 | static inline handle_t *__ext4_journal_start(struct inode *inode,
|
| 234 | unsigned int line, int type,
|
| 235 | int blocks, int rsv_blocks,
|
| 236 | int revoke_creds)
|
| 237 | {
|
| 238 | return __ext4_journal_start_sb(inode, inode->i_sb, line, type, blocks,
|
| 239 | rsv_blocks, revoke_creds);
|
| 240 | }
|
| 241 |
|
| 242 | #define ext4_journal_stop(handle) \
|
| 243 | __ext4_journal_stop(__func__, __LINE__, (handle))
|
| 244 |
|
| 245 | #define ext4_journal_start_reserved(handle, type) \
|
| 246 | __ext4_journal_start_reserved((handle), __LINE__, (type))
|
| 247 |
|
| 248 | handle_t *__ext4_journal_start_reserved(handle_t *handle, unsigned int line,
|
| 249 | int type);
|
| 250 |
|
| 251 | static inline handle_t *ext4_journal_current_handle(void)
|
| 252 | {
|
| 253 | return journal_current_handle();
|
| 254 | }
|
| 255 |
|
| 256 | static inline int ext4_journal_extend(handle_t *handle, int nblocks, int revoke)
|
| 257 | {
|
| 258 | if (ext4_handle_valid(handle))
|
| 259 | return jbd2_journal_extend(handle, nblocks, revoke);
|
| 260 | return 0;
|
| 261 | }
|
| 262 |
|
| 263 | static inline int ext4_journal_restart(handle_t *handle, int nblocks,
|
| 264 | int revoke)
|
| 265 | {
|
| 266 | if (ext4_handle_valid(handle))
|
| 267 | return jbd2__journal_restart(handle, nblocks, revoke, GFP_NOFS);
|
| 268 | return 0;
|
| 269 | }
|
| 270 |
|
| 271 | int __ext4_journal_ensure_credits(handle_t *handle, int check_cred,
|
| 272 | int extend_cred, int revoke_cred);
|
| 273 |
|
| 274 |
|
| 275 | |
| 276 | * Ensure @handle has at least @check_creds credits available. If not,
|
| 277 | * transaction will be extended or restarted to contain at least @extend_cred
|
| 278 | * credits. Before restarting transaction @fn is executed to allow for cleanup
|
| 279 | * before the transaction is restarted.
|
| 280 | *
|
| 281 | * The return value is < 0 in case of error, 0 in case the handle has enough
|
| 282 | * credits or transaction extension succeeded, 1 in case transaction had to be
|
| 283 | * restarted.
|
| 284 |
|
| 285 | #define ext4_journal_ensure_credits_fn(handle, check_cred, extend_cred, \
|
| 286 | revoke_cred, fn) \
|
| 287 | ({ \
|
| 288 | __label__ __ensure_end; \
|
| 289 | int err = __ext4_journal_ensure_credits((handle), (check_cred), \
|
| 290 | (extend_cred), (revoke_cred)); \
|
| 291 | \
|
| 292 | if (err <= 0) \
|
| 293 | goto __ensure_end; \
|
| 294 | err = (fn); \
|
| 295 | if (err < 0) \
|
| 296 | goto __ensure_end; \
|
| 297 | err = ext4_journal_restart((handle), (extend_cred), (revoke_cred)); \
|
| 298 | if (err == 0) \
|
| 299 | err = 1; \
|
| 300 | __ensure_end: \
|
| 301 | err; \
|
| 302 | })
|
| 303 |
|
| 304 | |
| 305 | * Ensure given handle has at least requested amount of credits available,
|
| 306 | * possibly restarting transaction if needed. We also make sure the transaction
|
| 307 | * has space for at least ext4_trans_default_revoke_credits(sb) revoke records
|
| 308 | * as freeing one or two blocks is very common pattern and requesting this is
|
| 309 | * very cheap.
|
| 310 |
|
| 311 | static inline int ext4_journal_ensure_credits(handle_t *handle, int credits,
|
| 312 | int revoke_creds)
|
| 313 | {
|
| 314 | return ext4_journal_ensure_credits_fn(handle, credits, credits,
|
| 315 | revoke_creds, 0);
|
| 316 | }
|
| 317 |
|
| 318 | static inline int ext4_journal_blocks_per_folio(struct inode *inode)
|
| 319 | {
|
| 320 | if (EXT4_JOURNAL(inode) != NULL)
|
| 321 | return jbd2_journal_blocks_per_folio(inode);
|
| 322 | return 0;
|
| 323 | }
|
| 324 |
|
| 325 | static inline int ext4_journal_force_commit(journal_t *journal)
|
| 326 | {
|
| 327 | if (journal)
|
| 328 | return jbd2_journal_force_commit(journal);
|
| 329 | return 0;
|
| 330 | }
|
| 331 |
|
| 332 | static inline int ext4_jbd2_inode_add_write(handle_t *handle,
|
| 333 | struct inode *inode, loff_t start_byte, loff_t length)
|
| 334 | {
|
| 335 | if (ext4_handle_valid(handle))
|
| 336 | return jbd2_journal_inode_ranged_write(handle,
|
| 337 | EXT4_I(inode)->jinode, start_byte, length);
|
| 338 | return 0;
|
| 339 | }
|
| 340 |
|
| 341 | static inline int ext4_jbd2_inode_add_wait(handle_t *handle,
|
| 342 | struct inode *inode, loff_t start_byte, loff_t length)
|
| 343 | {
|
| 344 | if (ext4_handle_valid(handle))
|
| 345 | return jbd2_journal_inode_ranged_wait(handle,
|
| 346 | EXT4_I(inode)->jinode, start_byte, length);
|
| 347 | return 0;
|
| 348 | }
|
| 349 |
|
| 350 | static inline void ext4_update_inode_fsync_trans(handle_t *handle,
|
| 351 | struct inode *inode,
|
| 352 | int datasync)
|
| 353 | {
|
| 354 | struct ext4_inode_info *ei = EXT4_I(inode);
|
| 355 |
|
| 356 | if (ext4_handle_valid(handle) && !is_handle_aborted(handle)) {
|
| 357 | ei->i_sync_tid = handle->h_transaction->t_tid;
|
| 358 | if (datasync)
|
| 359 | ei->i_datasync_tid = handle->h_transaction->t_tid;
|
| 360 | }
|
| 361 | }
|
| 362 |
|
| 363 |
|
| 364 | int ext4_force_commit(struct super_block *sb);
|
| 365 |
|
| 366 | |
| 367 | * Ext4 inode journal modes
|
| 368 |
|
| 369 | #define EXT4_INODE_JOURNAL_DATA_MODE 0x01
|
| 370 | #define EXT4_INODE_ORDERED_DATA_MODE 0x02
|
| 371 | #define EXT4_INODE_WRITEBACK_DATA_MODE 0x04
|
| 372 |
|
| 373 | int ext4_inode_journal_mode(struct inode *inode);
|
| 374 |
|
| 375 | static inline int ext4_should_journal_data(struct inode *inode)
|
| 376 | {
|
| 377 | return ext4_inode_journal_mode(inode) & EXT4_INODE_JOURNAL_DATA_MODE;
|
| 378 | }
|
| 379 |
|
| 380 | static inline int ext4_should_order_data(struct inode *inode)
|
| 381 | {
|
| 382 | return ext4_inode_journal_mode(inode) & EXT4_INODE_ORDERED_DATA_MODE;
|
| 383 | }
|
| 384 |
|
| 385 | static inline int ext4_should_writeback_data(struct inode *inode)
|
| 386 | {
|
| 387 | return ext4_inode_journal_mode(inode) & EXT4_INODE_WRITEBACK_DATA_MODE;
|
| 388 | }
|
| 389 |
|
| 390 | static inline int ext4_free_data_revoke_credits(struct inode *inode, int blocks)
|
| 391 | {
|
| 392 | if (test_opt(inode->i_sb, DATA_FLAGS) == EXT4_MOUNT_JOURNAL_DATA)
|
| 393 | return 0;
|
| 394 | if (!ext4_should_journal_data(inode))
|
| 395 | return 0;
|
| 396 | |
| 397 | * Data blocks in one extent are contiguous, just account for partial
|
| 398 | * clusters at extent boundaries
|
| 399 |
|
| 400 | return blocks + 2*(EXT4_SB(inode->i_sb)->s_cluster_ratio - 1);
|
| 401 | }
|
| 402 |
|
| 403 | |
| 404 | * This function controls whether or not we should try to go down the
|
| 405 | * dioread_nolock code paths, which makes it safe to avoid taking
|
| 406 | * i_rwsem for direct I/O reads. This only works for extent-based
|
| 407 | * files, and it doesn't work if data journaling is enabled, since the
|
| 408 | * dioread_nolock code uses b_private to pass information back to the
|
| 409 | * I/O completion handler, and this conflicts with the jbd's use of
|
| 410 | * b_private.
|
| 411 |
|
| 412 | static inline int ext4_should_dioread_nolock(struct inode *inode)
|
| 413 | {
|
| 414 | if (!test_opt(inode->i_sb, DIOREAD_NOLOCK))
|
| 415 | return 0;
|
| 416 | if (!S_ISREG(inode->i_mode))
|
| 417 | return 0;
|
| 418 | if (!(ext4_test_inode_flag(inode, EXT4_INODE_EXTENTS)))
|
| 419 | return 0;
|
| 420 | if (ext4_should_journal_data(inode))
|
| 421 | return 0;
|
| 422 |
|
| 423 | if (!test_opt(inode->i_sb, DELALLOC))
|
| 424 | return 0;
|
| 425 | return 1;
|
| 426 | }
|
| 427 |
|
| 428 | |
| 429 | * Pass journal explicitly as it may not be cached in the sbi->s_journal in some
|
| 430 | * cases
|
| 431 |
|
| 432 | static inline int ext4_journal_destroy(struct ext4_sb_info *sbi, journal_t *journal)
|
| 433 | {
|
| 434 | int err = 0;
|
| 435 |
|
| 436 | |
| 437 | * At this point only two things can be operating on the journal.
|
| 438 | * JBD2 thread performing transaction commit and s_sb_upd_work
|
| 439 | * issuing sb update through the journal. Once we set
|
| 440 | * EXT4_JOURNAL_DESTROY, new ext4_handle_error() calls will not
|
| 441 | * queue s_sb_upd_work and ext4_force_commit() makes sure any
|
| 442 | * ext4_handle_error() calls from the running transaction commit are
|
| 443 | * finished. Hence no new s_sb_upd_work can be queued after we
|
| 444 | * flush it here.
|
| 445 |
|
| 446 | ext4_set_mount_flag(sbi->s_sb, EXT4_MF_JOURNAL_DESTROY);
|
| 447 |
|
| 448 | ext4_force_commit(sbi->s_sb);
|
| 449 | flush_work(&sbi->s_sb_upd_work);
|
| 450 |
|
| 451 | err = jbd2_journal_destroy(journal);
|
| 452 | sbi->s_journal = NULL;
|
| 453 |
|
| 454 | return err;
|
| 455 | }
|
| 456 |
|
| 457 | #endif
|