| /freebsd/sys/contrib/openzfs/module/zfs/ |
| H A D | dmu_tx.c | 68 dmu_tx_t *tx = kmem_zalloc(sizeof (dmu_tx_t), KM_SLEEP); in dmu_tx_create_dd() local
83 dmu_tx_t *tx = dmu_tx_create_dd(os->os_dsl_dataset->ds_dir); in dmu_tx_create() local
91 dmu_tx_t *tx = dmu_tx_create_dd(NULL); in dmu_tx_create_assigned() local
102 dmu_tx_is_syncing(dmu_tx_t *tx) in dmu_tx_is_syncing()
108 dmu_tx_private_ok(dmu_tx_t *tx) in dmu_tx_private_ok()
114 dmu_tx_hold_dnode_impl(dmu_tx_t *tx, dnode_t *dn, enum dmu_tx_hold_type type, in dmu_tx_hold_dnode_impl()
149 dmu_tx_hold_object_impl(dmu_tx_t *tx, objset_t *os, uint64_t object, in dmu_tx_hold_object_impl()
170 dmu_tx_add_new_object(dmu_tx_t *tx, dnode_t *dn) in dmu_tx_add_new_object()
356 dmu_tx_hold_write(dmu_tx_t *tx, uint64_t object, uint64_t off, int len) in dmu_tx_hold_write()
373 dmu_tx_hold_write_by_dnode(dmu_tx_t *tx, dnode_t *dn, uint64_t off, int len) in dmu_tx_hold_write_by_dnode()
[all …]
|
| H A D | txg.c | 123 tx_state_t *tx = &dp->dp_tx; in txg_init() local
161 tx_state_t *tx = &dp->dp_tx; in txg_fini() local
199 tx_state_t *tx = &dp->dp_tx; in txg_sync_start() local
224 txg_thread_enter(tx_state_t *tx, callb_cpr_t *cpr) in txg_thread_enter()
231 txg_thread_exit(tx_state_t *tx, callb_cpr_t *cpr, kthread_t **tpp) in txg_thread_exit()
242 txg_thread_wait(tx_state_t *tx, callb_cpr_t *cpr, kcondvar_t *cv, clock_t time) in txg_thread_wait()
262 tx_state_t *tx = &dp->dp_tx; in txg_sync_stop() local
320 tx_state_t *tx = &dp->dp_tx; in txg_hold_open() local
389 tx_state_t *tx = &dp->dp_tx; in txg_quiesce() local
452 tx_state_t *tx = &dp->dp_tx; in txg_dispatch_callbacks() local
[all …]
|
| H A D | dmu_object.c | 50 int dnodesize, dnode_t **allocated_dnode, const void *tag, dmu_tx_t *tx) in dmu_object_alloc_impl()
228 dmu_object_type_t bonustype, int bonuslen, dmu_tx_t *tx) in dmu_object_alloc()
237 dmu_tx_t *tx) in dmu_object_alloc_ibs()
245 dmu_object_type_t bonustype, int bonuslen, int dnodesize, dmu_tx_t *tx) in dmu_object_alloc_dnsize()
259 int dnodesize, dnode_t **allocated_dnode, const void *tag, dmu_tx_t *tx) in dmu_object_alloc_hold()
267 int blocksize, dmu_object_type_t bonustype, int bonuslen, dmu_tx_t *tx) in dmu_object_claim()
276 int dnodesize, dmu_tx_t *tx) in dmu_object_claim_dnsize()
305 int blocksize, dmu_object_type_t bonustype, int bonuslen, dmu_tx_t *tx) in dmu_object_reclaim()
314 boolean_t keep_spill, dmu_tx_t *tx) in dmu_object_reclaim_dnsize()
339 dmu_object_rm_spill(objset_t *os, uint64_t object, dmu_tx_t *tx) in dmu_object_rm_spill()
[all …]
|
| H A D | zap.c | 110 fzap_upgrade(zap_t *zap, dmu_tx_t *tx, zap_flags_t flags) in fzap_upgrade()
161 zap_tryupgradedir(zap_t *zap, dmu_tx_t *tx) in zap_tryupgradedir()
179 dmu_tx_t *tx) in zap_table_grow()
255 dmu_tx_t *tx) in zap_table_store()
350 zap_grow_ptrtbl(zap_t *zap, dmu_tx_t *tx) in zap_grow_ptrtbl()
399 zap_increment_num_entries(zap_t *zap, int delta, dmu_tx_t *tx) in zap_increment_num_entries()
427 zap_create_leaf(zap_t *zap, dmu_tx_t *tx) in zap_create_leaf()
536 zap_get_leaf_byblk(zap_t *zap, uint64_t blkid, dmu_tx_t *tx, krw_t lt, in zap_get_leaf_byblk()
602 zap_set_idx_to_blk(zap_t *zap, uint64_t idx, uint64_t blk, dmu_tx_t *tx) in zap_set_idx_to_blk()
618 dmu_tx_t *tx) in zap_set_idx_range_to_blk()
[all …]
|
| H A D | dsl_destroy.c | 92 dsl_destroy_snapshot_check(void *arg, dmu_tx_t *tx) in dsl_destroy_snapshot_check()
129 process_old_cb(void *arg, const blkptr_t *bp, boolean_t bp_freed, dmu_tx_t *tx) in process_old_cb()
156 dsl_dataset_t *ds_next, boolean_t after_branch_point, dmu_tx_t *tx) in process_old_deadlist()
206 dsl_dir_remove_clones_key_impl(dsl_dir_t *dd, uint64_t mintxg, dmu_tx_t *tx, in dsl_dir_remove_clones_key_impl()
251 dsl_dir_remove_clones_key(dsl_dir_t *top_dd, uint64_t mintxg, dmu_tx_t *tx) in dsl_dir_remove_clones_key()
276 dmu_tx_t *tx) in dsl_destroy_snapshot_handle_remaps()
308 dsl_destroy_snapshot_sync_impl(dsl_dataset_t *ds, boolean_t defer, dmu_tx_t *tx) in dsl_destroy_snapshot_sync_impl()
572 dsl_destroy_snapshot_sync(void *arg, dmu_tx_t *tx) in dsl_destroy_snapshot_sync()
709 dmu_tx_t *tx; member
718 dmu_tx_t *tx = ka->tx; in kill_blkptr() local
[all …]
|
| H A D | spa_history.c | 88 spa_history_create_obj(spa_t *spa, dmu_tx_t *tx) in spa_history_create_obj()
153 dmu_tx_t *tx) in spa_history_write()
253 spa_history_log_sync(void *arg, dmu_tx_t *tx) in spa_history_log_sync()
376 dmu_tx_t *tx; in spa_history_log_nvl() local
520 dmu_tx_t *tx, const char *fmt, va_list adx) in log_internal()
556 dmu_tx_t *tx, const char *fmt, ...) in spa_history_log_internal()
581 dmu_tx_t *tx, const char *fmt, ...) in spa_history_log_internal_ds()
600 dmu_tx_t *tx, const char *fmt, ...) in spa_history_log_internal_dd()
619 spa_history_log_version(spa_t *spa, const char *operation, dmu_tx_t *tx) in spa_history_log_version()
|
| H A D | dsl_synctask.c | 37 dsl_null_checkfunc(void *arg, dmu_tx_t *tx) in dsl_null_checkfunc()
49 dmu_tx_t *tx; in dsl_sync_task_common() local
174 dmu_tx_t *tx, boolean_t early) in dsl_sync_task_nowait_common()
194 dmu_tx_t *tx) in dsl_sync_task_nowait()
201 dmu_tx_t *tx) in dsl_early_sync_task_nowait()
210 dsl_sync_task_sync(dsl_sync_task_t *dst, dmu_tx_t *tx) in dsl_sync_task_sync()
|
| H A D | dsl_deadlist.c | 379 dsl_deadlist_alloc(objset_t *os, dmu_tx_t *tx) in dsl_deadlist_alloc()
388 dsl_deadlist_free(objset_t *os, uint64_t dlobj, dmu_tx_t *tx) in dsl_deadlist_free()
419 const blkptr_t *bp, boolean_t bp_freed, dmu_tx_t *tx) in dle_enqueue()
436 uint64_t obj, dmu_tx_t *tx) in dle_enqueue_subobj()
465 dmu_tx_t *tx) in dsl_deadlist_insert()
506 dsl_deadlist_insert_alloc_cb(void *arg, const blkptr_t *bp, dmu_tx_t *tx) in dsl_deadlist_insert_alloc_cb()
514 dsl_deadlist_insert_free_cb(void *arg, const blkptr_t *bp, dmu_tx_t *tx) in dsl_deadlist_insert_free_cb()
526 dsl_deadlist_add_key(dsl_deadlist_t *dl, uint64_t mintxg, dmu_tx_t *tx) in dsl_deadlist_add_key()
553 dsl_deadlist_remove_key(dsl_deadlist_t *dl, uint64_t mintxg, dmu_tx_t *tx) in dsl_deadlist_remove_key()
585 dsl_deadlist_remove_entry(dsl_deadlist_t *dl, uint64_t mintxg, dmu_tx_t *tx) in dsl_deadlist_remove_entry()
[all …]
|
| H A D | zfs_log.c | 299 zfs_log_create(zilog_t *zilog, dmu_tx_t *tx, uint64_t txtype, in zfs_log_create()
413 zfs_log_remove(zilog_t *zilog, dmu_tx_t *tx, uint64_t txtype, in zfs_log_remove()
448 zfs_log_link(zilog_t *zilog, dmu_tx_t *tx, uint64_t txtype, in zfs_log_link()
471 zfs_log_symlink(zilog_t *zilog, dmu_tx_t *tx, uint64_t txtype, in zfs_log_symlink()
502 do_zfs_log_rename(zilog_t *zilog, dmu_tx_t *tx, uint64_t txtype, znode_t *sdzp, in do_zfs_log_rename()
530 zfs_log_rename(zilog_t *zilog, dmu_tx_t *tx, uint64_t txtype, znode_t *sdzp, in zfs_log_rename()
541 zfs_log_rename_exchange(zilog_t *zilog, dmu_tx_t *tx, uint64_t txtype, in zfs_log_rename_exchange()
556 zfs_log_rename_whiteout(zilog_t *zilog, dmu_tx_t *tx, uint64_t txtype, in zfs_log_rename_whiteout()
613 zfs_log_write(zilog_t *zilog, dmu_tx_t *tx, int txtype, in zfs_log_write()
710 zfs_log_truncate(zilog_t *zilog, dmu_tx_t *tx, int txtype, in zfs_log_truncate()
[all …]
|
| H A D | zfeature.c | 306 dmu_tx_t *tx) in feature_sync()
339 feature_enable_sync(spa_t *spa, zfeature_info_t *feature, dmu_tx_t *tx) in feature_enable_sync()
404 dmu_tx_t *tx) in feature_do_action()
439 spa_feature_create_zap_objects(spa_t *spa, dmu_tx_t *tx) in spa_feature_create_zap_objects()
463 spa_feature_enable(spa_t *spa, spa_feature_t fid, dmu_tx_t *tx) in spa_feature_enable()
471 spa_feature_incr(spa_t *spa, spa_feature_t fid, dmu_tx_t *tx) in spa_feature_incr()
477 spa_feature_decr(spa_t *spa, spa_feature_t fid, dmu_tx_t *tx) in spa_feature_decr()
|
| H A D | dsl_pool.c | 448 dsl_pool_create_obsolete_bpobj(dsl_pool_t *dp, dmu_tx_t *tx) in dsl_pool_create_obsolete_bpobj()
465 dsl_pool_destroy_obsolete_bpobj(dsl_pool_t *dp, dmu_tx_t *tx) in dsl_pool_destroy_obsolete_bpobj()
482 dmu_tx_t *tx = dmu_tx_create_assigned(dp, txg); in dsl_pool_create() local
583 dsl_pool_sync_mos(dsl_pool_t *dp, dmu_tx_t *tx) in dsl_pool_sync_mos()
680 dmu_tx_t *tx; in dsl_pool_sync() local
991 dsl_pool_dirty_space(dsl_pool_t *dp, int64_t space, dmu_tx_t *tx) in dsl_pool_dirty_space()
1028 dmu_tx_t *tx = arg; in upgrade_clones_cb() local
1106 dsl_pool_upgrade_clones(dsl_pool_t *dp, dmu_tx_t *tx) in dsl_pool_upgrade_clones()
1118 dmu_tx_t *tx = arg; in upgrade_dir_clones_cb() local
1144 dsl_pool_upgrade_dir_clones(dsl_pool_t *dp, dmu_tx_t *tx) in dsl_pool_upgrade_dir_clones()
[all …]
|
| H A D | bpobj.c | 39 bpobj_alloc_empty(objset_t *os, int blocksize, dmu_tx_t *tx) in bpobj_alloc_empty()
63 bpobj_decr_empty(objset_t *os, dmu_tx_t *tx) in bpobj_decr_empty()
79 bpobj_alloc(objset_t *os, int blocksize, dmu_tx_t *tx) in bpobj_alloc()
98 bpobj_free(objset_t *os, uint64_t obj, dmu_tx_t *tx) in bpobj_free()
264 int64_t comp_freed, int64_t uncomp_freed, dmu_tx_t *tx) in propagate_space_reduction()
281 int64_t start, dmu_tx_t *tx, boolean_t free) in bpobj_iterate_blkptrs()
371 dmu_tx_t *tx, boolean_t free, uint64_t *bpobj_size) in bpobj_iterate_impl()
544 bpobj_iterate(bpobj_t *bpo, bpobj_itor_t func, void *arg, dmu_tx_t *tx) in bpobj_iterate()
673 bpobj_enqueue_subobj(bpobj_t *bpo, uint64_t subobj, dmu_tx_t *tx) in bpobj_enqueue_subobj()
872 dmu_tx_t *tx) in bpobj_enqueue()
[all …]
|
| H A D | spa_checkpoint.c | 188 spa_checkpoint_discard_complete_sync(void *arg, dmu_tx_t *tx) in spa_checkpoint_discard_complete_sync()
282 spa_checkpoint_discard_thread_sync(void *arg, dmu_tx_t *tx) in spa_checkpoint_discard_thread_sync()
455 spa_checkpoint_check(void *arg, dmu_tx_t *tx) in spa_checkpoint_check()
482 spa_checkpoint_sync(void *arg, dmu_tx_t *tx) in spa_checkpoint_sync()
579 spa_checkpoint_discard_check(void *arg, dmu_tx_t *tx) in spa_checkpoint_discard_check()
597 spa_checkpoint_discard_sync(void *arg, dmu_tx_t *tx) in spa_checkpoint_discard_sync()
|
| H A D | zcp_set.c | 40 const char *prop_name, const char *prop_val, dmu_tx_t *tx) in zcp_set_user_prop()
56 zcp_set_prop_check(void *arg, dmu_tx_t *tx) in zcp_set_prop_check()
87 zcp_set_prop_sync(void *arg, dmu_tx_t *tx) in zcp_set_prop_sync()
|
| H A D | ddt_log.c | 99 ddt_log_update_header(ddt_t *ddt, ddt_log_t *ddl, dmu_tx_t *tx) in ddt_log_update_header()
116 ddt_log_create_one(ddt_t *ddt, ddt_log_t *ddl, uint_t n, dmu_tx_t *tx) in ddt_log_create_one()
135 ddt_log_create(ddt_t *ddt, dmu_tx_t *tx) in ddt_log_create()
142 ddt_log_destroy_one(ddt_t *ddt, ddt_log_t *ddl, uint_t n, dmu_tx_t *tx) in ddt_log_destroy_one()
161 ddt_log_destroy(ddt_t *ddt, dmu_tx_t *tx) in ddt_log_destroy()
194 ddt_log_begin(ddt_t *ddt, size_t nentries, dmu_tx_t *tx, ddt_log_update_t *dlu) in ddt_log_begin()
390 ddt_log_checkpoint(ddt_t *ddt, ddt_lightweight_entry_t *ddlwe, dmu_tx_t *tx) in ddt_log_checkpoint()
415 ddt_log_truncate(ddt_t *ddt, dmu_tx_t *tx) in ddt_log_truncate()
436 ddt_log_swap(ddt_t *ddt, dmu_tx_t *tx) in ddt_log_swap()
|
| H A D | zap_micro.c | 622 zap_lockdir_impl(dnode_t *dn, dmu_buf_t *db, const void *tag, dmu_tx_t *tx, in zap_lockdir_impl()
723 zap_lockdir_by_dnode(dnode_t *dn, dmu_tx_t *tx, in zap_lockdir_by_dnode()
742 zap_lockdir(objset_t *os, uint64_t obj, dmu_tx_t *tx, in zap_lockdir()
775 mzap_upgrade(zap_t **zapp, const void *tag, dmu_tx_t *tx, zap_flags_t flags) in mzap_upgrade()
840 mzap_create_impl(dnode_t *dn, int normflags, zap_flags_t flags, dmu_tx_t *tx) in mzap_create_impl()
870 dnode_t **allocated_dnode, const void *tag, dmu_tx_t *tx) in zap_create_impl()
895 dmu_object_type_t bonustype, int bonuslen, dmu_tx_t *tx) in zap_create_claim()
903 dmu_object_type_t bonustype, int bonuslen, int dnodesize, dmu_tx_t *tx) in zap_create_claim_dnsize()
912 dmu_object_type_t bonustype, int bonuslen, dmu_tx_t *tx) in zap_create_claim_norm()
921 int dnodesize, dmu_tx_t *tx) in zap_create_claim_norm_dnsize()
[all …]
|
| H A D | dnode_sync.c | 43 dnode_increase_indirection(dnode_t *dn, dmu_tx_t *tx) in dnode_increase_indirection()
135 free_blocks(dnode_t *dn, blkptr_t *bp, int num, dmu_tx_t *tx) in free_blocks()
177 free_verify(dmu_buf_impl_t *db, uint64_t start, uint64_t end, dmu_tx_t *tx) in free_verify()
275 boolean_t free_indirects, dmu_tx_t *tx) in free_children()
373 boolean_t free_indirects, dmu_tx_t *tx) in dnode_sync_free_range_impl()
576 dnode_sync_free(dnode_t *dn, dmu_tx_t *tx) in dnode_sync_free()
641 dnode_sync(dnode_t *dn, dmu_tx_t *tx) in dnode_sync()
|
| H A D | dsl_dir.c | 569 dsl_dir_init_fs_ss_count(dsl_dir_t *dd, dmu_tx_t *tx) in dsl_dir_init_fs_ss_count()
653 dsl_dir_actv_fs_ss_limit_check(void *arg, dmu_tx_t *tx) in dsl_dir_actv_fs_ss_limit_check()
684 dsl_dir_actv_fs_ss_limit_sync(void *arg, dmu_tx_t *tx) in dsl_dir_actv_fs_ss_limit_sync()
909 dmu_tx_t *tx) in dsl_fs_ss_count_adjust()
960 dmu_tx_t *tx) in dsl_dir_create_sync()
1150 dsl_dir_dirty(dsl_dir_t *dd, dmu_tx_t *tx) in dsl_dir_dirty()
1172 dsl_dir_sync(dsl_dir_t *dd, dmu_tx_t *tx) in dsl_dir_sync()
1277 dmu_tx_t *tx, boolean_t first) in dsl_dir_tempreserve_impl()
1423 boolean_t netfree, void **tr_cookiep, dmu_tx_t *tx) in dsl_dir_tempreserve_space()
1480 dsl_dir_tempreserve_clear(void *tr_cookie, dmu_tx_t *tx) in dsl_dir_tempreserve_clear()
[all …]
|
| /freebsd/sys/dev/gve/ |
| H A D | gve_tx_dqo.c | 38 gve_unmap_packet(struct gve_tx_ring *tx, in gve_unmap_packet()
54 gve_free_tx_mbufs_dqo(struct gve_tx_ring *tx) in gve_free_tx_mbufs_dqo()
77 struct gve_tx_ring *tx = &priv->tx[i]; in gve_tx_free_ring_dqo() local
115 gve_tx_alloc_rda_fields_dqo(struct gve_tx_ring *tx) in gve_tx_alloc_rda_fields_dqo()
163 struct gve_tx_ring *tx = &priv->tx[i]; in gve_tx_alloc_ring_dqo() local
249 gve_tx_fill_pkt_desc_dqo(struct gve_tx_ring *tx, in gve_tx_fill_pkt_desc_dqo()
377 gve_tx_fill_ctx_descs(struct gve_tx_ring *tx, struct mbuf *mbuf, in gve_tx_fill_ctx_descs()
415 gve_map_mbuf_dqo(struct gve_tx_ring *tx, in gve_map_mbuf_dqo()
483 num_avail_desc_ring_slots(const struct gve_tx_ring *tx) in num_avail_desc_ring_slots()
492 gve_alloc_pending_packet(struct gve_tx_ring *tx) in gve_alloc_pending_packet()
[all …]
|
| H A D | gve_tx.c | 38 gve_tx_fifo_init(struct gve_priv *priv, struct gve_tx_ring *tx) in gve_tx_fifo_init()
54 struct gve_tx_ring *tx = &priv->tx[i]; in gve_tx_free_ring_gqi() local
70 struct gve_tx_ring *tx = &priv->tx[i]; in gve_tx_free_ring() local
98 struct gve_tx_ring *tx = &priv->tx[i]; in gve_tx_alloc_ring_gqi() local
136 struct gve_tx_ring *tx = &priv->tx[i]; in gve_tx_alloc_ring() local
212 gve_tx_clear_desc_ring(struct gve_tx_ring *tx) in gve_tx_clear_desc_ring()
229 struct gve_tx_ring *tx = &priv->tx[i]; in gve_clear_tx_ring() local
245 struct gve_tx_ring *tx = &priv->tx[i]; in gve_start_tx_ring() local
269 struct gve_tx_ring *tx; in gve_create_tx_rings() local
311 struct gve_tx_ring *tx = &priv->tx[i]; in gve_stop_tx_ring() local
[all …]
|
| /freebsd/contrib/kyua/store/ |
| H A D | write_transaction_test.cpp | 78 store::write_transaction tx = backend.start_write(); in do_put_result_ok_test() local
114 store::write_transaction tx = backend.start_write(); in ATF_TEST_CASE_BODY() local
135 store::write_transaction tx = backend.start_write(); in ATF_TEST_CASE_BODY() local
146 store::write_transaction tx = backend.start_write(); in ATF_TEST_CASE_BODY() local
162 store::write_transaction tx = backend.start_write(); in ATF_TEST_CASE_BODY() local
190 store::write_transaction tx = backend.start_write(); in ATF_TEST_CASE_BODY() local
226 store::write_transaction tx = backend.start_write(); in ATF_TEST_CASE_BODY() local
245 store::write_transaction tx = backend.start_write(); in ATF_TEST_CASE_BODY() local
272 store::write_transaction tx = backend.start_write(); in ATF_TEST_CASE_BODY() local
302 store::write_transaction tx = backend.start_write(); in ATF_TEST_CASE_BODY() local
[all …]
|
| H A D | transaction_test.cpp | 70 store::write_transaction tx = backend.start_write(); in check_get_put_context() local
76 store::read_transaction tx = backend.start_read(); in check_get_put_context() local
147 store::write_transaction tx = backend.start_write(); in ATF_TEST_CASE_BODY() local
158 store::read_transaction tx = backend.start_read(); in ATF_TEST_CASE_BODY() local
|
| H A D | read_transaction_test.cpp | 69 store::read_transaction tx = backend.start_read(); in ATF_TEST_CASE_BODY() local
95 store::read_transaction tx = backend.start_read(); in ATF_TEST_CASE_BODY() local
125 store::read_transaction tx = backend.start_read(); in ATF_TEST_CASE_BODY() local
146 store::read_transaction tx = backend.start_read(); in ATF_TEST_CASE_BODY() local
164 store::read_transaction tx = backend.start_read(); in ATF_TEST_CASE_BODY() local
181 store::write_transaction tx = backend.start_write(); in ATF_TEST_CASE_BODY() local
|
| /freebsd/contrib/kyua/utils/sqlite/ |
| H A D | transaction_test.cpp | 78 sqlite::transaction tx = db.begin_transaction(); in ATF_TEST_CASE_BODY() local
93 sqlite::transaction tx = db.begin_transaction(); in ATF_TEST_CASE_BODY() local
109 sqlite::transaction tx = db.begin_transaction(); in ATF_TEST_CASE_BODY() local
123 sqlite::transaction tx = db.begin_transaction(); in ATF_TEST_CASE_BODY() local
|
| /freebsd/contrib/kyua/drivers/ |
| H A D | run_tests.cpp | 99 store::write_transaction& tx, in find_test_program_id()
122 store::write_transaction& tx) in put_test_result()
167 store::write_transaction& tx, in start_test()
199 store::write_transaction& tx, in finish_test()
266 store::write_transaction tx = db.start_write(); in drive() local
|