| /fs/bcachefs/ |
| A D | move.c | 126 struct moving_context *ctxt = io->write.ctxt; in move_free() local
149 struct moving_context *ctxt = io->write.ctxt; in move_write_done() local
173 struct moving_context *ctxt = io->write.ctxt; in move_write() local
231 struct moving_context *ctxt = io->write.ctxt; in move_read_endio() local
263 move_ctxt_wait_event(ctxt, list_empty(&ctxt->reads)); in bch2_moving_ctxt_flush_all()
291 memset(ctxt, 0, sizeof(*ctxt)); in bch2_moving_ctxt_exit()
301 memset(ctxt, 0, sizeof(*ctxt)); in bch2_moving_ctxt_init()
307 ctxt->wp = wp; in bch2_moving_ctxt_init()
371 io->write.ctxt = ctxt; in bch2_move_extent()
399 if (ctxt->rate) in bch2_move_extent()
[all …]
|
| A D | movinggc.c | 130 bch2_trans_unlock_long(ctxt->trans); in move_buckets_wait()
142 struct btree_trans *trans = ctxt->trans; in bch2_copygc_get_buckets()
212 struct btree_trans *trans = ctxt->trans; in bch2_copygc()
347 struct moving_context ctxt; in bch2_copygc_thread() local
378 bch2_trans_unlock_long(ctxt.trans); in bch2_copygc_thread()
382 move_buckets_wait(&ctxt, &buckets, true); in bch2_copygc_thread()
388 move_buckets_wait(&ctxt, &buckets, true); in bch2_copygc_thread()
399 move_buckets_wait(&ctxt, &buckets, true); in bch2_copygc_thread()
420 move_buckets_wait(&ctxt, &buckets, true); in bch2_copygc_thread()
426 move_buckets_wait(&ctxt, &buckets, true); in bch2_copygc_thread()
[all …]
|
| A D | rebalance.c | 413 struct btree_trans *trans = ctxt->trans; in do_rebalance_extent()
422 ctxt->stats = &r->work_stats; in do_rebalance_extent()
445 bch2_move_ctxt_wait_for_io(ctxt); in do_rebalance_extent()
462 struct btree_trans *trans = ctxt->trans; in do_rebalance_scan()
467 ctxt->stats = &r->scan_stats; in do_rebalance_scan()
540 struct btree_trans *trans = ctxt->trans; in do_rebalance()
557 while (!bch2_move_ratelimit(ctxt)) { in do_rebalance()
559 bch2_moving_ctxt_flush_all(ctxt); in do_rebalance()
597 bch2_moving_ctxt_flush_all(ctxt); in do_rebalance()
611 struct moving_context ctxt; in bch2_rebalance_thread() local
[all …]
|
| A D | data_update.c | 70 bool __bkey_nocow_lock(struct bch_fs *c, struct moving_context *ctxt, struct bkey_ptrs_c ptrs, in __bkey_nocow_lock() argument
73 if (!ctxt) { in __bkey_nocow_lock()
90 move_ctxt_wait_event(ctxt, in __bkey_nocow_lock()
92 list_empty(&ctxt->ios)); in __bkey_nocow_lock()
99 static bool bkey_nocow_lock(struct bch_fs *c, struct moving_context *ctxt, struct bkey_ptrs_c ptrs) in bkey_nocow_lock() argument
106 return __bkey_nocow_lock(c, ctxt, ptrs, ptr); in bkey_nocow_lock()
814 struct moving_context *ctxt, in bch2_data_update_init() argument
846 m->ctxt = ctxt; in bch2_data_update_init()
847 m->stats = ctxt ? ctxt->stats : NULL; in bch2_data_update_init()
978 !bkey_nocow_lock(c, ctxt, ptrs)) { in bch2_data_update_init()
|
| A D | data_update.h | 45 struct moving_context *ctxt; member
|
| /fs/nilfs2/ |
| A D | btnode.c | 214 __u64 oldkey = ctxt->oldkey, newkey = ctxt->newkey; in nilfs_btnode_prepare_change_key()
220 obh = ctxt->bh; in nilfs_btnode_prepare_change_key()
221 ctxt->newbh = NULL; in nilfs_btnode_prepare_change_key()
260 ctxt->newbh = nbh; in nilfs_btnode_prepare_change_key()
288 struct buffer_head *obh = ctxt->bh, *nbh = ctxt->newbh; in nilfs_btnode_commit_change_key()
289 __u64 oldkey = ctxt->oldkey, newkey = ctxt->newkey; in nilfs_btnode_commit_change_key()
316 ctxt->bh = nbh; in nilfs_btnode_commit_change_key()
337 struct nilfs_btnode_chkey_ctxt *ctxt) in nilfs_btnode_abort_change_key() argument
339 struct buffer_head *nbh = ctxt->newbh; in nilfs_btnode_abort_change_key()
340 __u64 oldkey = ctxt->oldkey, newkey = ctxt->newkey; in nilfs_btnode_abort_change_key()
[all …]
|
| /fs/ocfs2/ |
| A D | xattr.c | 793 len, ctxt->meta_ac, &ctxt->dealloc, 1); in __ocfs2_remove_xattr_range()
866 vb, ctxt); in ocfs2_xattr_value_truncate()
1916 ctxt); in ocfs2_xa_value_truncate()
2098 ctxt); in ocfs2_xa_reuse_entry()
2416 if (ctxt.meta_ac) in ocfs2_remove_value_outside()
2883 ret = ocfs2_claim_metadata(ctxt->handle, ctxt->meta_ac, 1, in ocfs2_create_xattr_block()
3656 if (ctxt.data_ac) in ocfs2_xattr_set()
3658 if (ctxt.meta_ac) in ocfs2_xattr_set()
5317 ctxt); in ocfs2_add_new_xattr_bucket()
5616 ctxt); in ocfs2_xattr_set_entry_index_block()
[all …]
|
| A D | alloc.c | 3681 if (ctxt->c_split_covers_rec && ctxt->c_has_empty_extent) { in ocfs2_try_to_merge_extent()
4486 ctxt->c_contig_type = ret; in ocfs2_figure_merge_contig_type()
5082 struct ocfs2_merge_ctxt ctxt; in ocfs2_split_extent() local
5095 &ctxt); in ocfs2_split_extent()
5118 ctxt.c_split_covers_rec = 1; in ocfs2_split_extent()
5120 ctxt.c_split_covers_rec = 0; in ocfs2_split_extent()
5125 ctxt.c_has_empty_extent, in ocfs2_split_extent()
5126 ctxt.c_split_covers_rec); in ocfs2_split_extent()
5129 if (ctxt.c_split_covers_rec) in ocfs2_split_extent()
5141 dealloc, &ctxt); in ocfs2_split_extent()
[all …]
|
| A D | alloc.h | 196 int ocfs2_cache_cluster_dealloc(struct ocfs2_cached_dealloc_ctxt *ctxt,
198 int ocfs2_cache_block_dealloc(struct ocfs2_cached_dealloc_ctxt *ctxt,
206 struct ocfs2_cached_dealloc_ctxt *ctxt);
|
| /fs/ocfs2/dlm/ |
| A D | dlmdomain.c | 1564 struct domain_join_ctxt *ctxt, in dlm_should_restart_join() argument
1590 struct domain_join_ctxt *ctxt; in dlm_try_to_join_domain() local
1595 ctxt = kzalloc(sizeof(*ctxt), GFP_KERNEL); in dlm_try_to_join_domain()
1596 if (!ctxt) { in dlm_try_to_join_domain()
1627 set_bit(node, ctxt->yes_resp_map); in dlm_try_to_join_domain()
1629 if (dlm_should_restart_join(dlm, ctxt, response)) { in dlm_try_to_join_domain()
1661 dlm_send_join_asserts(dlm, ctxt->yes_resp_map); in dlm_try_to_join_domain()
1681 if (ctxt) { in dlm_try_to_join_domain()
1685 ctxt->yes_resp_map, in dlm_try_to_join_domain()
1686 sizeof(ctxt->yes_resp_map)); in dlm_try_to_join_domain()
[all …]
|
| /fs/ocfs2/cluster/ |
| A D | netdebug.c | 378 static int sc_common_open(struct file *file, int ctxt) in sc_common_open() argument
393 sd->dbg_ctxt = ctxt; in sc_common_open()
|
| /fs/smb/client/ |
| A D | smb2pdu.c | 774 unsigned int len = le16_to_cpu(ctxt->DataLength); in decode_preauth_context()
787 if (le16_to_cpu(ctxt->HashAlgorithmCount) != 1) in decode_preauth_context()
794 struct smb2_compression_capabilities_context *ctxt) in decode_compress_ctx() argument
796 unsigned int len = le16_to_cpu(ctxt->DataLength); in decode_compress_ctx()
816 alg = ctxt->CompressionAlgorithms[0]; in decode_compress_ctx()
829 struct smb2_encryption_neg_context *ctxt) in decode_encrypt_ctx() argument
831 unsigned int len = le16_to_cpu(ctxt->DataLength); in decode_encrypt_ctx()
844 if (le16_to_cpu(ctxt->CipherCount) != 1) { in decode_encrypt_ctx()
850 if (ctxt->Ciphers[0] != SMB2_ENCRYPTION_AES256_GCM) { in decode_encrypt_ctx()
854 } else if (ctxt->Ciphers[0] == 0) { in decode_encrypt_ctx()
[all …]
|