| /f-stack/freebsd/contrib/openzfs/module/zfs/ |
| H A D | txg.c | 288 cv_wait(&tx->tx_exit_cv, &tx->tx_sync_lock); in txg_sync_stop() 531 tx->tx_synced_txg >= tx->tx_sync_txg_waiting && in txg_sync_thread() 546 if (tx->tx_quiesce_txg_waiting < tx->tx_open_txg+1) in txg_sync_thread() 547 tx->tx_quiesce_txg_waiting = tx->tx_open_txg+1; in txg_sync_thread() 553 txg_thread_exit(tx, &cpr, &tx->tx_sync_thread); in txg_sync_thread() 615 txg_thread_exit(tx, &cpr, &tx->tx_quiesce_thread); in txg_quiesce_thread() 690 tx->tx_synced_txg, tx->tx_sync_txg_waiting, dp); in txg_wait_synced_impl() 778 tx->tx_quiesce_txg_waiting <= tx->tx_open_txg && in txg_kick() 779 tx->tx_sync_txg_waiting <= tx->tx_synced_txg && in txg_kick() 780 tx->tx_quiesced_txg <= tx->tx_synced_txg) { in txg_kick() [all …]
|
| H A D | dmu_tx.c | 74 return (tx); in dmu_tx_create_dd() 82 return (tx); in dmu_tx_create() 95 return (tx); in dmu_tx_create_assigned() 308 txh = dmu_tx_hold_object_impl(tx, tx->tx_objset, in dmu_tx_hold_write() 441 txh = dmu_tx_hold_object_impl(tx, tx->tx_objset, in dmu_tx_hold_free() 514 txh = dmu_tx_hold_object_impl(tx, tx->tx_objset, in dmu_tx_hold_zap() 540 txh = dmu_tx_hold_object_impl(tx, tx->tx_objset, in dmu_tx_hold_bonus() 565 txh = dmu_tx_hold_object_impl(tx, tx->tx_objset, in dmu_tx_hold_space() 893 tx->tx_txg = txg_hold_open(tx->tx_pool, &tx->tx_txgh); in dmu_tx_try_assign() 951 asize, tx->tx_netfree, &tx->tx_tempreserve_cookie, tx); in dmu_tx_try_assign() [all …]
|
| H A D | dsl_destroy.c | 359 tx)); in dsl_destroy_snapshot_sync_impl() 409 tx); in dsl_destroy_snapshot_sync_impl() 552 tx)); in dsl_destroy_snapshot_sync_impl() 555 tx)); in dsl_destroy_snapshot_sync_impl() 704 dmu_tx_t *tx; member 713 dmu_tx_t *tx = ka->tx; in kill_blkptr() local 725 dsl_free(ka->tx->tx_pool, ka->tx->tx_txg, bp); in kill_blkptr() 753 ka.tx = tx; in old_synchronous_dataset_destroy() 946 tx); in dsl_async_clone_destroy() 977 tx); in dsl_async_dataset_destroy() [all …]
|
| H A D | dmu_object.c | 193 bonuslen, dn_slots, tx); in dmu_object_alloc_impl() 236 dmu_tx_t *tx) in dmu_object_alloc_ibs() argument 269 bonuslen, 0, tx)); in dmu_object_claim() 295 dmu_tx_add_new_object(tx, dn); in dmu_object_claim_dnsize() 331 keep_spill, tx); in dmu_object_reclaim_dnsize() 350 dbuf_rm_spill(dn, tx); in dmu_object_rm_spill() 351 dnode_rm_spill(dn, tx); in dmu_object_rm_spill() 378 dnode_free(dn, tx); in dmu_object_free() 457 dmu_tx_t *tx) in dmu_object_zapify() argument 461 ASSERT(dmu_tx_is_syncing(tx)); in dmu_object_zapify() [all …]
|
| H A D | dsl_dataset.c | 98 dmu_tx_t *tx); 238 tx); in dsl_dataset_block_remapped() 259 dsl_free(tx->tx_pool, tx->tx_txg, bp); in dsl_dataset_block_kill() 286 dsl_free(tx->tx_pool, tx->tx_txg, bp); in dsl_dataset_block_kill() 1081 dmu_tx_t *tx) in dsl_dataset_activate_feature() argument 1389 obj, tx); in dsl_dataset_remove_from_next_clones() 2083 &ds->ds_resume_object[tx->tx_txg & TXG_MASK], tx)); in dsl_dataset_sync() 2086 &ds->ds_resume_offset[tx->tx_txg & TXG_MASK], tx)); in dsl_dataset_sync() 2089 &ds->ds_resume_bytes[tx->tx_txg & TXG_MASK], tx)); in dsl_dataset_sync() 2219 tx->tx_txg - 1, tx); in dsl_flush_pending_livelist() [all …]
|
| H A D | dsl_synctask.c | 48 dmu_tx_t *tx; in dsl_sync_task_common() local 60 VERIFY0(dmu_tx_assign(tx, TXG_WAIT)); in dsl_sync_task_common() 63 dst.dst_txg = dmu_tx_get_txg(tx); in dsl_sync_task_common() 73 err = dst.dst_checkfunc(arg, tx); in dsl_sync_task_common() 77 dmu_tx_commit(tx); in dsl_sync_task_common() 86 dmu_tx_commit(tx); in dsl_sync_task_common() 90 sigfunc(arg, tx); in dsl_sync_task_common() 173 dmu_tx_t *tx, boolean_t early) in dsl_sync_task_nowait_common() argument 178 dst->dst_txg = dmu_tx_get_txg(tx); in dsl_sync_task_nowait_common() 193 dmu_tx_t *tx) in dsl_sync_task_nowait() argument [all …]
|
| H A D | dsl_pool.c | 500 FREE_DIR_NAME, tx); in dsl_pool_create() 541 dmu_tx_commit(tx); in dsl_pool_create() 623 dmu_tx_t *tx; in dsl_pool_sync() local 739 dsl_dir_sync(dd, tx); in dsl_pool_sync() 797 dmu_tx_commit(tx); in dsl_pool_sync() 948 dmu_tx_t *tx = arg; in upgrade_clones_cb() local 1039 dmu_tx_t *tx = arg; in upgrade_dir_clones_cb() local 1052 0, tx); in upgrade_dir_clones_cb() 1057 ds->ds_object, tx)); in upgrade_dir_clones_cb() 1229 dmu_tx_t *tx) in dsl_pool_user_release() argument [all …]
|
| H A D | dsl_deadlist.c | 400 bpobj_free(os, obj, tx); in dsl_deadlist_free() 443 dmu_tx_t *tx) in dsl_deadlist_insert() argument 523 mintxg, obj, tx)); in dsl_deadlist_add_key() 587 bpobj_decr_empty(os, tx); in dsl_deadlist_remove_entry() 603 dmu_tx_t *tx) in dsl_deadlist_clear_entry() argument 623 new_obj, tx)); in dsl_deadlist_clear_entry() 784 dmu_tx_t *tx) in dsl_deadlist_insert_bpobj() argument 814 dmu_tx_t *tx) in dsl_deadlist_insert_cb() argument 868 dmu_tx_t *tx) in dsl_deadlist_move_bpobj() argument 950 dmu_tx_t *tx) in dsl_livelist_iterate() argument [all …]
|
| H A D | spa_history.c | 100 &spa->spa_history, tx)); in spa_history_create_obj() 106 dmu_buf_will_dirty(dbp, tx); in spa_history_create_obj() 152 dmu_tx_t *tx) in spa_history_write() argument 374 dmu_tx_t *tx; in spa_history_log_nvl() local 388 dmu_tx_abort(tx); in spa_history_log_nvl() 401 dmu_tx_commit(tx); in spa_history_log_nvl() 543 dmu_tx_t *htx = tx; in spa_history_log_internal() 547 if (tx == NULL) { in spa_history_log_internal() 560 if (tx == NULL) in spa_history_log_internal() 572 ASSERT(tx != NULL); in spa_history_log_internal_ds() [all …]
|
| H A D | zfeature.c | 305 dmu_tx_t *tx) in feature_sync() argument 311 sizeof (uint64_t), 1, &refcount, tx)); in feature_sync() 360 feature->fi_desc, tx)); in feature_enable_sync() 365 uint64_t enabling_txg = dmu_tx_get_txg(tx); in feature_enable_sync() 371 DMU_POOL_FEATURE_ENABLED_TXG, tx); in feature_enable_sync() 396 dmu_tx_t *tx) in feature_do_action() argument 408 ASSERT(dmu_tx_is_syncing(tx)); in feature_do_action() 427 feature_sync(spa, feature, refcount, tx); in feature_do_action() 442 DMU_POOL_FEATURES_FOR_READ, tx); in spa_feature_create_zap_objects() 445 DMU_POOL_FEATURES_FOR_WRITE, tx); in spa_feature_create_zap_objects() [all …]
|
| H A D | spa_checkpoint.c | 324 sdc.sdc_txg = tx->tx_txg; in spa_checkpoint_discard_thread_sync() 356 space_map_free(vd->vdev_checkpoint_sm, tx); in spa_checkpoint_discard_thread_sync() 454 spa_checkpoint_check(void *arg, dmu_tx_t *tx) in spa_checkpoint_check() argument 456 spa_t *spa = dmu_tx_pool(tx)->dp_spa; in spa_checkpoint_check() 478 spa_checkpoint_sync(void *arg, dmu_tx_t *tx) in spa_checkpoint_sync() argument 480 dsl_pool_t *dp = dmu_tx_pool(tx); in spa_checkpoint_sync() 517 &checkpoint, tx)); in spa_checkpoint_sync() 527 spa_history_log_internal(spa, "spa checkpoint", tx, in spa_checkpoint_sync() 577 spa_t *spa = dmu_tx_pool(tx)->dp_spa; in spa_checkpoint_discard_check() 595 spa_t *spa = dmu_tx_pool(tx)->dp_spa; in spa_checkpoint_discard_sync() [all …]
|
| H A D | bpobj.c | 71 DMU_POOL_EMPTY_BPOBJ, tx)); in bpobj_decr_empty() 329 uncomp_freed, tx); in bpobj_iterate_blkptrs() 333 DMU_OBJECT_END, tx)); in bpobj_iterate_blkptrs() 417 tx)); in bpobj_iterate_impl() 434 tx); in bpobj_iterate_impl() 440 bpo->bpo_object, tx); in bpobj_iterate_impl() 726 DMU_OT_NONE, 0, tx); in bpobj_enqueue_subobj() 755 bps->db_data, tx); in bpobj_enqueue_subobj() 767 DMU_OT_NONE, 0, tx); in bpobj_enqueue_subobj() 785 dmu_tx_t *tx) in bpobj_enqueue() argument [all …]
|
| H A D | zap.c | 140 dmu_buf_will_dirty(db, tx); in fzap_upgrade() 170 dmu_tx_t *tx) in zap_table_grow() argument 245 dmu_tx_t *tx) in zap_table_store() argument 262 dmu_buf_will_dirty(db, tx); in zap_table_store() 588 ASSERT(tx != NULL); in zap_set_idx_to_blk() 596 idx, blk, tx)); in zap_set_idx_to_blk() 1012 tx)); in zap_create_link_dnsize() 1081 8, 1, &value, tx); in zap_join_key() 1092 dmu_tx_t *tx) in zap_join_increment() argument 1179 dmu_tx_t *tx) in zap_increment() argument [all …]
|
| H A D | dsl_dir.c | 565 dsl_dir_zapify(dd, tx); in dsl_dir_init_fs_ss_count() 890 dmu_tx_t *tx) in dsl_fs_ss_count_adjust() argument 932 tx)); in dsl_fs_ss_count_adjust() 941 dmu_tx_t *tx) in dsl_dir_create_sync() argument 1268 txg = tx->tx_txg; in dsl_dir_tempreserve_impl() 1456 ASSERT3U(tx->tx_txg, !=, 0); in dsl_dir_tempreserve_clear() 1505 dsl_dir_dirty(dd, tx); in dsl_dir_willuse_space() 1762 delta, 0, 0, tx); in dsl_dir_set_reservation_sync_impl() 1955 if (dmu_tx_is_syncing(tx)) { in dsl_dir_rename_check() 2112 dd->dd_myname, tx)); in dsl_dir_rename_sync() [all …]
|
| /f-stack/freebsd/contrib/openzfs/include/sys/ |
| H A D | zap.h | 126 int dnodesize, dmu_tx_t *tx); 133 int dnodesize, dmu_tx_t *tx); 148 dmu_tx_t *tx); 244 const void *val, dmu_tx_t *tx); 247 const void *val, dmu_tx_t *tx); 250 const void *val, dmu_tx_t *tx); 286 matchtype_t mt, dmu_tx_t *tx); 315 uint64_t value, dmu_tx_t *tx); 319 dmu_tx_t *tx); 329 dmu_tx_t *tx); [all …]
|
| H A D | dmu_tx.h | 142 int dmu_tx_assign(dmu_tx_t *tx, uint64_t txg_how); 143 void dmu_tx_commit(dmu_tx_t *tx); 144 void dmu_tx_abort(dmu_tx_t *tx); 145 uint64_t dmu_tx_get_txg(dmu_tx_t *tx); 146 struct dsl_pool *dmu_tx_pool(dmu_tx_t *tx); 147 void dmu_tx_wait(dmu_tx_t *tx); 158 int dmu_tx_is_syncing(dmu_tx_t *tx); 159 int dmu_tx_private_ok(dmu_tx_t *tx); 162 void dmu_tx_hold_space(dmu_tx_t *tx, uint64_t space); 165 #define DMU_TX_DIRTY_BUF(tx, db) dmu_tx_dirty_buf(tx, db) argument [all …]
|
| H A D | dsl_deadlist.h | 95 uint64_t dsl_deadlist_alloc(objset_t *os, dmu_tx_t *tx); 96 void dsl_deadlist_free(objset_t *os, uint64_t dlobj, dmu_tx_t *tx); 98 boolean_t free, dmu_tx_t *tx); 99 int dsl_deadlist_insert_alloc_cb(void *arg, const blkptr_t *bp, dmu_tx_t *tx); 100 int dsl_deadlist_insert_free_cb(void *arg, const blkptr_t *bp, dmu_tx_t *tx); 101 void dsl_deadlist_add_key(dsl_deadlist_t *dl, uint64_t mintxg, dmu_tx_t *tx); 104 dmu_tx_t *tx); 108 uint64_t mrs_obj, dmu_tx_t *tx); 114 void dsl_deadlist_merge(dsl_deadlist_t *dl, uint64_t obj, dmu_tx_t *tx); 116 dmu_tx_t *tx); [all …]
|
| H A D | dmu.h | 414 dmu_tx_t *tx); 464 dmu_tx_t *tx); 478 int ibs, dmu_tx_t *tx); 486 dmu_tx_t *tx); 493 dmu_tx_t *tx); 500 dmu_tx_t *tx); 506 dmu_tx_t *tx); 848 dmu_tx_t *tx); 854 dmu_tx_t *tx); 856 dmu_tx_t *tx); [all …]
|
| H A D | bpobj.h | 73 dmu_tx_t *tx); 75 uint64_t bpobj_alloc(objset_t *mos, int blocksize, dmu_tx_t *tx); 76 uint64_t bpobj_alloc_empty(objset_t *os, int blocksize, dmu_tx_t *tx); 77 void bpobj_free(objset_t *os, uint64_t obj, dmu_tx_t *tx); 78 void bpobj_decr_empty(objset_t *os, dmu_tx_t *tx); 84 int bpobj_iterate(bpobj_t *bpo, bpobj_itor_t func, void *arg, dmu_tx_t *tx); 89 void bpobj_enqueue_subobj(bpobj_t *bpo, uint64_t subobj, dmu_tx_t *tx); 91 dmu_tx_t *tx); 100 dmu_tx_t *tx);
|
| /f-stack/freebsd/contrib/openzfs/module/os/freebsd/zfs/ |
| H A D | zfs_dir.c | 297 dmu_tx_t *tx; in zfs_unlinked_drain() local 344 dmu_tx_abort(tx); in zfs_unlinked_drain() 377 dmu_tx_t *tx; in zfs_purgedir() local 406 dmu_tx_abort(tx); in zfs_purgedir() 415 dmu_tx_commit(tx); in zfs_purgedir() 432 dmu_tx_t *tx; in zfs_rmnode() local 507 dmu_tx_abort(tx); in zfs_rmnode() 544 dmu_tx_commit(tx); in zfs_rmnode() 807 dmu_tx_t *tx; in zfs_make_xattrdir() local 836 dmu_tx_abort(tx); in zfs_make_xattrdir() [all …]
|
| /f-stack/freebsd/contrib/openzfs/module/os/linux/zfs/ |
| H A D | zfs_vnops_os.c | 558 dmu_tx_t *tx; in zfs_create() local 802 dmu_tx_t *tx; in zfs_tmpfile() local 945 dmu_tx_t *tx; in zfs_remove() local 1182 dmu_tx_t *tx; in zfs_mkdir() local 1370 dmu_tx_t *tx; in zfs_rmdir() local 1793 tx = NULL; in zfs_setattr_dir() 1806 if (tx) in zfs_setattr_dir() 1842 dmu_tx_t *tx; in zfs_setattr() local 2672 dmu_tx_t *tx; in zfs_rename() local 3038 dmu_tx_t *tx; in zfs_symlink() local [all …]
|
| H A D | zfs_dir.c | 594 dmu_tx_t *tx; in zfs_purgedir() local 623 dmu_tx_abort(tx); in zfs_purgedir() 651 dmu_tx_t *tx; in zfs_rmnode() local 728 dmu_tx_abort(tx); in zfs_rmnode() 754 zp->z_id, tx); in zfs_rmnode() 768 dmu_tx_commit(tx); in zfs_rmnode() 826 &value, tx); in zfs_link_create() 923 tx); in zfs_dropname() 1059 dmu_tx_t *tx; in zfs_make_xattrdir() local 1091 dmu_tx_abort(tx); in zfs_make_xattrdir() [all …]
|
| /f-stack/dpdk/examples/performance-thread/l3fwd-thread/ |
| H A D | test.sh | 16 --tx="(1,0)" \ 28 --tx="(2,0)(3,1)" \ 39 --tx="(4,0)(5,1)(6,2)(7,3)" \ 50 --tx="(8,0)(9,1)(10,2)(11,3)(12,4)(13,5)(14,6)(15,7)" \ 66 --tx="(1,0)" \ 78 --tx="(2,0)(3,1)" \ 89 --tx="(4,0)(5,1)(6,2)(7,3)" \ 100 --tx="(8,0)(9,1)(10,2)(11,3)(12,4)(13,5)(14,6)(15,7)" \ 116 --tx="(0,0)" \ 126 --tx="(0,0)(0,1)" \ [all …]
|
| /f-stack/freebsd/contrib/openzfs/include/os/linux/zfs/sys/ |
| H A D | trace_dmu.h | 47 TP_PROTO(dmu_tx_t *tx, uint64_t dirty, uint64_t min_tx_time), 48 TP_ARGS(tx, dirty, min_tx_time), 62 __entry->tx_txg = tx->tx_txg; 63 __entry->tx_lastsnap_txg = tx->tx_lastsnap_txg; 64 __entry->tx_lasttried_txg = tx->tx_lasttried_txg; 65 __entry->tx_anyobj = tx->tx_anyobj; 66 __entry->tx_dirty_delayed = tx->tx_dirty_delayed; 67 __entry->tx_start = tx->tx_start; 68 __entry->tx_wait_dirty = tx->tx_wait_dirty; 69 __entry->tx_err = tx->tx_err; [all …]
|
| /f-stack/freebsd/contrib/libsodium/src/libsodium/crypto_kx/ |
| H A D | crypto_kx.c | 35 unsigned char tx[crypto_kx_SESSIONKEYBYTES], in crypto_kx_client_session_keys() 46 rx = tx; in crypto_kx_client_session_keys() 48 if (tx == NULL) { in crypto_kx_client_session_keys() 49 tx = rx; in crypto_kx_client_session_keys() 67 tx[i] = keys[i + crypto_kx_SESSIONKEYBYTES]; in crypto_kx_client_session_keys() 76 unsigned char tx[crypto_kx_SESSIONKEYBYTES], in crypto_kx_server_session_keys() 87 rx = tx; in crypto_kx_server_session_keys() 89 if (tx == NULL) { in crypto_kx_server_session_keys() 90 tx = rx; in crypto_kx_server_session_keys() 107 tx[i] = keys[i]; in crypto_kx_server_session_keys()
|