| /fs/jbd2/ |
| D | journal.c | 149 journal_t *journal = from_timer(journal, t, j_commit_timer); in commit_timeout() local
151 wake_up_process(journal->j_task); in commit_timeout()
174 journal_t *journal = arg; in kjournald2() local
181 timer_setup(&journal->j_commit_timer, commit_timeout, 0); in kjournald2()
186 journal->j_task = current; in kjournald2()
187 wake_up(&journal->j_wait_done_commit); in kjournald2()
200 write_lock(&journal->j_state_lock); in kjournald2()
203 if (journal->j_flags & JBD2_UNMOUNT) in kjournald2()
207 journal->j_commit_sequence, journal->j_commit_request); in kjournald2()
209 if (journal->j_commit_sequence != journal->j_commit_request) { in kjournald2()
[all …]
|
| D | checkpoint.c | 61 void __jbd2_log_wait_for_space(journal_t *journal) in __jbd2_log_wait_for_space() argument
62 __acquires(&journal->j_state_lock) in __jbd2_log_wait_for_space()
63 __releases(&journal->j_state_lock) in __jbd2_log_wait_for_space()
68 nblocks = journal->j_max_transaction_buffers; in __jbd2_log_wait_for_space()
69 while (jbd2_log_space_left(journal) < nblocks) { in __jbd2_log_wait_for_space()
70 write_unlock(&journal->j_state_lock); in __jbd2_log_wait_for_space()
71 mutex_lock_io(&journal->j_checkpoint_mutex); in __jbd2_log_wait_for_space()
84 write_lock(&journal->j_state_lock); in __jbd2_log_wait_for_space()
85 if (journal->j_flags & JBD2_ABORT) { in __jbd2_log_wait_for_space()
86 mutex_unlock(&journal->j_checkpoint_mutex); in __jbd2_log_wait_for_space()
[all …]
|
| D | commit.c | 116 static int journal_submit_commit_record(journal_t *journal, in journal_submit_commit_record() argument
128 if (is_journal_aborted(journal)) in journal_submit_commit_record()
141 if (jbd2_has_feature_checksum(journal)) { in journal_submit_commit_record()
146 jbd2_commit_block_csum_set(journal, bh); in journal_submit_commit_record()
154 if (journal->j_flags & JBD2_BARRIER && in journal_submit_commit_record()
155 !jbd2_has_feature_async_commit(journal)) in journal_submit_commit_record()
169 static int journal_wait_on_commit_record(journal_t *journal, in journal_wait_on_commit_record() argument
222 int jbd2_wait_inode_data(journal_t *journal, struct jbd2_inode *jinode) in jbd2_wait_inode_data() argument
241 static int journal_submit_data_buffers(journal_t *journal, in journal_submit_data_buffers() argument
247 spin_lock(&journal->j_list_lock); in journal_submit_data_buffers()
[all …]
|
| D | transaction.c | 68 static int jbd2_descriptor_blocks_per_trans(journal_t *journal) in jbd2_descriptor_blocks_per_trans() argument
70 int tag_space = journal->j_blocksize - sizeof(journal_header_t); in jbd2_descriptor_blocks_per_trans()
75 if (jbd2_journal_has_csum_v2or3(journal)) in jbd2_descriptor_blocks_per_trans()
78 tags_per_block = (tag_space - 16) / journal_tag_bytes(journal); in jbd2_descriptor_blocks_per_trans()
83 return 1 + DIV_ROUND_UP(journal->j_max_transaction_buffers, in jbd2_descriptor_blocks_per_trans()
102 static void jbd2_get_transaction(journal_t *journal, in jbd2_get_transaction() argument
105 transaction->t_journal = journal; in jbd2_get_transaction()
108 transaction->t_tid = journal->j_transaction_sequence++; in jbd2_get_transaction()
109 transaction->t_expires = jiffies + journal->j_commit_interval; in jbd2_get_transaction()
112 jbd2_descriptor_blocks_per_trans(journal) + in jbd2_get_transaction()
[all …]
|
| D | revoke.c | 131 static inline int hash(journal_t *journal, unsigned long long block) in hash() argument
133 return hash_64(block, journal->j_revoke->hash_shift); in hash()
136 static int insert_revoke_hash(journal_t *journal, unsigned long long blocknr, in insert_revoke_hash() argument
151 hash_list = &journal->j_revoke->hash_table[hash(journal, blocknr)]; in insert_revoke_hash()
152 spin_lock(&journal->j_revoke_lock); in insert_revoke_hash()
154 spin_unlock(&journal->j_revoke_lock); in insert_revoke_hash()
160 static struct jbd2_revoke_record_s *find_revoke_record(journal_t *journal, in find_revoke_record() argument
166 hash_list = &journal->j_revoke->hash_table[hash(journal, blocknr)]; in find_revoke_record()
168 spin_lock(&journal->j_revoke_lock); in find_revoke_record()
172 spin_unlock(&journal->j_revoke_lock); in find_revoke_record()
[all …]
|
| D | recovery.c | 38 static int do_one_pass(journal_t *journal,
66 static int do_readahead(journal_t *journal, unsigned int start) in do_readahead() argument
76 max = start + (128 * 1024 / journal->j_blocksize); in do_readahead()
77 if (max > journal->j_total_len) in do_readahead()
78 max = journal->j_total_len; in do_readahead()
86 err = jbd2_journal_bmap(journal, next, &blocknr); in do_readahead()
94 bh = __getblk(journal->j_dev, blocknr, journal->j_blocksize); in do_readahead()
128 static int jread(struct buffer_head **bhp, journal_t *journal, in jread() argument
137 if (offset >= journal->j_total_len) { in jread()
142 err = jbd2_journal_bmap(journal, offset, &blocknr); in jread()
[all …]
|
| D | Makefile | 10 jbd2-objs := transaction.o commit.o recovery.o checkpoint.o revoke.o journal.o
|
| /fs/reiserfs/ |
| D | journal.c | 94 struct reiserfs_journal *journal);
115 struct reiserfs_journal *journal = SB_JOURNAL(sb); in init_journal_hash() local
116 memset(journal->j_hash_table, 0, in init_journal_hash()
157 struct reiserfs_journal *journal = SB_JOURNAL(sb); in get_bitmap_node() local
159 struct list_head *entry = journal->j_bitmap_nodes.next; in get_bitmap_node()
161 journal->j_used_bitmap_nodes++; in get_bitmap_node()
164 if (entry != &journal->j_bitmap_nodes) { in get_bitmap_node()
168 journal->j_free_bitmap_nodes--; in get_bitmap_node()
181 struct reiserfs_journal *journal = SB_JOURNAL(sb); in free_bitmap_node() local
182 journal->j_used_bitmap_nodes--; in free_bitmap_node()
[all …]
|
| D | super.c | 724 struct reiserfs_journal *journal = SB_JOURNAL(s); in reiserfs_show_options() local
764 if (journal->j_max_commit_age != journal->j_default_max_commit_age) in reiserfs_show_options()
765 seq_printf(seq, ",commit=%d", journal->j_max_commit_age); in reiserfs_show_options()
1439 struct reiserfs_journal *journal = SB_JOURNAL(s); in reiserfs_remount() local
1500 journal->j_max_commit_age = commit_max_age; in reiserfs_remount()
1501 journal->j_max_trans_age = commit_max_age; in reiserfs_remount()
1504 journal->j_max_commit_age = journal->j_default_max_commit_age; in reiserfs_remount()
1505 journal->j_max_trans_age = JOURNAL_MAX_TRANS_AGE; in reiserfs_remount()
1550 if (reiserfs_is_journal_aborted(journal)) { in reiserfs_remount()
1551 err = journal->j_errno; in reiserfs_remount()
|
| D | Makefile | 10 hashes.o tail_conversion.o journal.o resize.o \
|
| /fs/ocfs2/ |
| D | journal.c | 61 static void ocfs2_queue_recovery_completion(struct ocfs2_journal *journal,
154 ocfs2_queue_recovery_completion(osb->journal, i, NULL, in ocfs2_queue_replay_slots()
296 struct ocfs2_journal *journal = NULL; in ocfs2_commit_cache() local
298 journal = osb->journal; in ocfs2_commit_cache()
301 down_write(&journal->j_trans_barrier); in ocfs2_commit_cache()
303 flushed = atomic_read(&journal->j_num_trans); in ocfs2_commit_cache()
306 up_write(&journal->j_trans_barrier); in ocfs2_commit_cache()
310 jbd2_journal_lock_updates(journal->j_journal); in ocfs2_commit_cache()
311 status = jbd2_journal_flush(journal->j_journal, 0); in ocfs2_commit_cache()
312 jbd2_journal_unlock_updates(journal->j_journal); in ocfs2_commit_cache()
[all …]
|
| D | journal.h | 78 static inline void ocfs2_set_ci_lock_trans(struct ocfs2_journal *journal, in ocfs2_set_ci_lock_trans() argument
82 ci->ci_last_trans = journal->j_trans_id; in ocfs2_set_ci_lock_trans()
94 struct ocfs2_journal *journal = in ocfs2_ci_fully_checkpointed() local
95 OCFS2_SB(ocfs2_metadata_cache_get_super(ci))->journal; in ocfs2_ci_fully_checkpointed()
98 ret = time_after(journal->j_trans_id, ci->ci_last_trans); in ocfs2_ci_fully_checkpointed()
110 struct ocfs2_journal *journal = in ocfs2_ci_is_new() local
111 OCFS2_SB(ocfs2_metadata_cache_get_super(ci))->journal; in ocfs2_ci_is_new()
114 ret = !(time_after(journal->j_trans_id, ci->ci_created_trans)); in ocfs2_ci_is_new()
137 ci->ci_created_trans = osb->journal->j_trans_id; in ocfs2_ci_set_new()
171 int ocfs2_journal_init(struct ocfs2_journal *journal,
[all …]
|
| D | super.c | 287 "Journal", osb->journal->j_state, in ocfs2_osb_dump()
288 osb->journal->j_trans_id, in ocfs2_osb_dump()
289 atomic_read(&osb->journal->j_num_trans)); in ocfs2_osb_dump()
411 if (jbd2_journal_start_commit(osb->journal->j_journal, in ocfs2_sync_fs()
414 jbd2_log_wait_commit(osb->journal->j_journal, in ocfs2_sync_fs()
1990 jbd2_journal_check_used_features(osb->journal->j_journal, 0, 0, in ocfs2_journal_addressable()
2011 struct ocfs2_journal *journal; in ocfs2_initialize_super() local
2201 journal = kzalloc(sizeof(struct ocfs2_journal), GFP_KERNEL); in ocfs2_initialize_super()
2202 if (!journal) { in ocfs2_initialize_super()
2207 osb->journal = journal; in ocfs2_initialize_super()
[all …]
|
| D | inode.c | 128 journal_t *journal = OCFS2_SB(sb)->journal->j_journal; in ocfs2_iget() local
175 if (journal) { in ocfs2_iget()
180 read_lock(&journal->j_state_lock); in ocfs2_iget()
181 if (journal->j_running_transaction) in ocfs2_iget()
182 transaction = journal->j_running_transaction; in ocfs2_iget()
184 transaction = journal->j_committing_transaction; in ocfs2_iget()
188 tid = journal->j_commit_sequence; in ocfs2_iget()
189 read_unlock(&journal->j_state_lock); in ocfs2_iget()
1208 jbd2_journal_release_jbd_inode(osb->journal->j_journal, in ocfs2_clear_inode()
|
| D | Makefile | 25 journal.o \
|
| /fs/ext4/ |
| D | ext4_jbd2.c | 66 journal_t *journal; in ext4_journal_check_start() local
76 journal = EXT4_SB(sb)->s_journal; in ext4_journal_check_start()
82 if (journal && is_journal_aborted(journal)) { in ext4_journal_check_start()
83 ext4_abort(sb, -journal->j_errno, "Detected aborted journal"); in ext4_journal_check_start()
93 journal_t *journal; in __ext4_journal_start_sb() local
102 journal = EXT4_SB(sb)->s_journal; in __ext4_journal_start_sb()
103 if (!journal || (EXT4_SB(sb)->s_mount_state & EXT4_FC_REPLAY)) in __ext4_journal_start_sb()
105 return jbd2__journal_start(journal, blocks, rsv_blocks, revoke_creds, in __ext4_journal_start_sb()
|
| D | fast_commit.c | 911 static int ext4_fc_submit_inode_data_all(journal_t *journal) in ext4_fc_submit_inode_data_all() argument
913 struct super_block *sb = (struct super_block *)(journal->j_private); in ext4_fc_submit_inode_data_all()
945 static int ext4_fc_wait_inode_data_all(journal_t *journal) in ext4_fc_wait_inode_data_all() argument
947 struct super_block *sb = (struct super_block *)(journal->j_private); in ext4_fc_wait_inode_data_all()
959 ret = jbd2_wait_inode_data(journal, pos->jinode); in ext4_fc_wait_inode_data_all()
970 static int ext4_fc_commit_dentry_updates(journal_t *journal, u32 *crc) in ext4_fc_commit_dentry_updates() argument
974 struct super_block *sb = (struct super_block *)(journal->j_private); in ext4_fc_commit_dentry_updates()
1039 static int ext4_fc_perform_commit(journal_t *journal) in ext4_fc_perform_commit() argument
1041 struct super_block *sb = (struct super_block *)(journal->j_private); in ext4_fc_perform_commit()
1050 ret = ext4_fc_submit_inode_data_all(journal); in ext4_fc_perform_commit()
[all …]
|
| D | fsync.c | 108 journal_t *journal = EXT4_SB(inode->i_sb)->s_journal; in ext4_fsync_journal() local
111 if (journal->j_flags & JBD2_BARRIER && in ext4_fsync_journal()
112 !jbd2_trans_will_send_data_barrier(journal, commit_tid)) in ext4_fsync_journal()
115 return ext4_fc_commit(journal, commit_tid); in ext4_fsync_journal()
|
| D | super.c | 433 static void ext4_journal_commit_callback(journal_t *journal, transaction_t *txn) in ext4_journal_commit_callback() argument
435 struct super_block *sb = journal->j_private; in ext4_journal_commit_callback()
437 int error = is_journal_aborted(journal); in ext4_journal_commit_callback()
634 journal_t *journal = EXT4_SB(sb)->s_journal; in ext4_handle_error() local
643 if (journal) in ext4_handle_error()
644 jbd2_journal_abort(journal, -EIO); in ext4_handle_error()
655 if (continue_fs && journal) in ext4_handle_error()
687 journal_t *journal = sbi->s_journal; in flush_stashed_error_work() local
698 if (!sb_rdonly(sbi->s_sb) && journal) { in flush_stashed_error_work()
700 handle = jbd2_journal_start(journal, 1); in flush_stashed_error_work()
[all …]
|
| D | inode.c | 207 journal_t *journal = EXT4_SB(inode->i_sb)->s_journal; in ext4_evict_inode() local
210 jbd2_complete_transaction(journal, commit_tid); in ext4_evict_inode()
3148 journal_t *journal; in ext4_bmap() local
3190 journal = EXT4_JOURNAL(inode); in ext4_bmap()
3191 jbd2_journal_lock_updates(journal); in ext4_bmap()
3192 err = jbd2_journal_flush(journal, 0); in ext4_bmap()
3193 jbd2_journal_unlock_updates(journal); in ext4_bmap()
3248 journal_t *journal = EXT4_JOURNAL(page->mapping->host); in __ext4_journalled_invalidatepage() local
3258 return jbd2_journal_invalidatepage(journal, page, offset, length); in __ext4_journalled_invalidatepage()
3271 journal_t *journal = EXT4_JOURNAL(page->mapping->host); in ext4_releasepage() local
[all …]
|
| D | ext4_jbd2.h | 413 static inline int ext4_journal_force_commit(journal_t *journal) in ext4_journal_force_commit() argument
415 if (journal) in ext4_journal_force_commit()
416 return jbd2_journal_force_commit(journal); in ext4_journal_force_commit()
|
| D | fsmap.c | 259 journal_t *journal = EXT4_SB(sb)->s_journal; in ext4_getfsmap_logdev() local
282 irec.fmr_physical = journal->j_blk_offset; in ext4_getfsmap_logdev()
283 irec.fmr_length = journal->j_total_len; in ext4_getfsmap_logdev()
|
| /fs/f2fs/ |
| D | segment.c | 2515 memcpy(&dst->journal, curseg->journal, SUM_JOURNAL_SIZE); in write_current_sum_page()
3774 memcpy(seg_i->journal, kaddr, SUM_JOURNAL_SIZE); in read_compacted_summaries()
3778 memcpy(seg_i->journal, kaddr + SUM_JOURNAL_SIZE, SUM_JOURNAL_SIZE); in read_compacted_summaries()
3880 memcpy(curseg->journal, &sum->journal, SUM_JOURNAL_SIZE); in read_normal_summaries()
3897 struct f2fs_journal *sit_j = CURSEG_I(sbi, CURSEG_COLD_DATA)->journal; in restore_curseg_summaries()
3898 struct f2fs_journal *nat_j = CURSEG_I(sbi, CURSEG_HOT_DATA)->journal; in restore_curseg_summaries()
3953 memcpy(kaddr, seg_i->journal, SUM_JOURNAL_SIZE); in write_compacted_summaries()
3958 memcpy(kaddr + written_size, seg_i->journal, SUM_JOURNAL_SIZE); in write_compacted_summaries()
4017 int f2fs_lookup_journal_in_cursum(struct f2fs_journal *journal, int type, in f2fs_lookup_journal_in_cursum() argument
4023 for (i = 0; i < nats_in_cursum(journal); i++) { in f2fs_lookup_journal_in_cursum()
[all …]
|
| D | node.c | 551 struct f2fs_journal *journal = curseg->journal; in f2fs_get_node_info() local
588 i = f2fs_lookup_journal_in_cursum(journal, NAT_JOURNAL, nid, 0); in f2fs_get_node_info()
590 ne = nat_in_journal(journal, i); in f2fs_get_node_info()
2401 struct f2fs_journal *journal = curseg->journal; in scan_curseg_cache() local
2405 for (i = 0; i < nats_in_cursum(journal); i++) { in scan_curseg_cache()
2409 addr = le32_to_cpu(nat_in_journal(journal, i).block_addr); in scan_curseg_cache()
2410 nid = le32_to_cpu(nid_in_journal(journal, i)); in scan_curseg_cache()
2862 struct f2fs_journal *journal = curseg->journal; in remove_nats_in_journal() local
2866 for (i = 0; i < nats_in_cursum(journal); i++) { in remove_nats_in_journal()
2869 nid_t nid = le32_to_cpu(nid_in_journal(journal, i)); in remove_nats_in_journal()
[all …]
|
| /fs/ubifs/ |
| D | Makefile | 4 ubifs-y += shrinker.o journal.o file.o dir.o super.o sb.o io.o
|