Lines Matching refs:tx

228 	dmu_tx_t *tx = dmu_tx_create_assigned(dp, txg);  in dsl_pool_create()  local
235 NULL, &dp->dp_meta_rootbp, DMU_OST_META, tx); in dsl_pool_create()
239 DMU_OT_OBJECT_DIRECTORY, DMU_OT_NONE, 0, tx); in dsl_pool_create()
246 dp->dp_root_dir_obj = dsl_dir_create_sync(dp, NULL, NULL, tx); in dsl_pool_create()
251 (void) dsl_dir_create_sync(dp, dp->dp_root_dir, MOS_DIR_NAME, tx); in dsl_pool_create()
258 FREE_DIR_NAME, tx); in dsl_pool_create()
263 obj = bpobj_alloc(dp->dp_meta_objset, SPA_MAXBLOCKSIZE, tx); in dsl_pool_create()
265 DMU_POOL_FREE_BPOBJ, sizeof (uint64_t), 1, &obj, tx) == 0); in dsl_pool_create()
271 dsl_pool_create_origin(dp, tx); in dsl_pool_create()
274 obj = dsl_dataset_create_sync_dd(dp->dp_root_dir, NULL, 0, tx); in dsl_pool_create()
279 dsl_dataset_get_blkptr(ds), DMU_OST_ZFS, tx); in dsl_pool_create()
281 zfs_create_fs(os, kcred, zplprops, tx); in dsl_pool_create()
285 dmu_tx_commit(tx); in dsl_pool_create()
291 deadlist_enqueue_cb(void *arg, const blkptr_t *bp, dmu_tx_t *tx) in deadlist_enqueue_cb() argument
294 dsl_deadlist_insert(dl, bp, tx); in deadlist_enqueue_cb()
302 dmu_tx_t *tx; in dsl_pool_sync() local
319 tx = dmu_tx_create_assigned(dp, txg); in dsl_pool_sync()
333 dsl_dataset_sync(ds, zio, tx); in dsl_pool_sync()
344 dmu_objset_do_userquota_updates(ds->ds_objset, tx); in dsl_pool_sync()
356 dsl_dataset_sync(ds, zio, tx); in dsl_pool_sync()
367 deadlist_enqueue_cb, &ds->ds_deadlist, tx); in dsl_pool_sync()
376 dsl_sync_task_group_sync(dstg, tx); in dsl_pool_sync()
382 dsl_dir_sync(dd, tx); in dsl_pool_sync()
389 dmu_objset_sync(mos, zio, tx); in dsl_pool_sync()
400 dmu_tx_commit(tx); in dsl_pool_sync()
496 dsl_pool_tempreserve_space(dsl_pool_t *dp, uint64_t space, dmu_tx_t *tx) in dsl_pool_tempreserve_space() argument
503 atomic_add_64(&dp->dp_tempreserved[tx->tx_txg & TXG_MASK], in dsl_pool_tempreserve_space()
517 reserved = dp->dp_space_towrite[tx->tx_txg & TXG_MASK] in dsl_pool_tempreserve_space()
518 + dp->dp_tempreserved[tx->tx_txg & TXG_MASK] / 2; in dsl_pool_tempreserve_space()
524 atomic_add_64(&dp->dp_tempreserved[tx->tx_txg & TXG_MASK], space); in dsl_pool_tempreserve_space()
532 txg_delay(dp, tx->tx_txg, 1); in dsl_pool_tempreserve_space()
538 dsl_pool_tempreserve_clear(dsl_pool_t *dp, int64_t space, dmu_tx_t *tx) in dsl_pool_tempreserve_clear() argument
540 ASSERT(dp->dp_tempreserved[tx->tx_txg & TXG_MASK] >= space); in dsl_pool_tempreserve_clear()
541 atomic_add_64(&dp->dp_tempreserved[tx->tx_txg & TXG_MASK], -space); in dsl_pool_tempreserve_clear()
562 dsl_pool_willuse_space(dsl_pool_t *dp, int64_t space, dmu_tx_t *tx) in dsl_pool_willuse_space() argument
566 dp->dp_space_towrite[tx->tx_txg & TXG_MASK] += space; in dsl_pool_willuse_space()
575 dmu_tx_t *tx = arg; in upgrade_clones_cb() local
614 dmu_buf_will_dirty(ds->ds_dbuf, tx); in upgrade_clones_cb()
618 dmu_buf_will_dirty(ds->ds_dir->dd_dbuf, tx); in upgrade_clones_cb()
621 dmu_buf_will_dirty(prev->ds_dbuf, tx); in upgrade_clones_cb()
635 dmu_buf_will_dirty(prev->ds_dbuf, tx); in upgrade_clones_cb()
638 DMU_OT_NEXT_CLONES, DMU_OT_NONE, 0, tx); in upgrade_clones_cb()
641 prev->ds_phys->ds_next_clones_obj, ds->ds_object, tx)); in upgrade_clones_cb()
650 dsl_pool_upgrade_clones(dsl_pool_t *dp, dmu_tx_t *tx) in dsl_pool_upgrade_clones() argument
652 ASSERT(dmu_tx_is_syncing(tx)); in dsl_pool_upgrade_clones()
656 tx, DS_FIND_CHILDREN)); in dsl_pool_upgrade_clones()
663 dmu_tx_t *tx = arg; in upgrade_dir_clones_cb() local
677 dmu_buf_will_dirty(origin->ds_dir->dd_dbuf, tx); in upgrade_dir_clones_cb()
679 DMU_OT_DSL_CLONES, DMU_OT_NONE, 0, tx); in upgrade_dir_clones_cb()
683 origin->ds_dir->dd_phys->dd_clones, dsobj, tx)); in upgrade_dir_clones_cb()
693 dsl_pool_upgrade_dir_clones(dsl_pool_t *dp, dmu_tx_t *tx) in dsl_pool_upgrade_dir_clones() argument
695 ASSERT(dmu_tx_is_syncing(tx)); in dsl_pool_upgrade_dir_clones()
698 (void) dsl_dir_create_sync(dp, dp->dp_root_dir, FREE_DIR_NAME, tx); in dsl_pool_upgrade_dir_clones()
708 SPA_MAXBLOCKSIZE, DMU_OT_BPOBJ_HDR, sizeof (bpobj_phys_t), tx); in dsl_pool_upgrade_dir_clones()
710 DMU_POOL_FREE_BPOBJ, sizeof (uint64_t), 1, &obj, tx)); in dsl_pool_upgrade_dir_clones()
715 upgrade_dir_clones_cb, tx, DS_FIND_CHILDREN)); in dsl_pool_upgrade_dir_clones()
719 dsl_pool_create_origin(dsl_pool_t *dp, dmu_tx_t *tx) in dsl_pool_create_origin() argument
724 ASSERT(dmu_tx_is_syncing(tx)); in dsl_pool_create_origin()
730 NULL, 0, kcred, tx); in dsl_pool_create_origin()
732 dsl_dataset_snapshot_sync(ds, ORIGIN_DIR_NAME, tx); in dsl_pool_create_origin()
780 dsl_pool_user_hold_create_obj(dsl_pool_t *dp, dmu_tx_t *tx) in dsl_pool_user_hold_create_obj() argument
785 ASSERT(dmu_tx_is_syncing(tx)); in dsl_pool_user_hold_create_obj()
788 DMU_OT_NONE, 0, tx); in dsl_pool_user_hold_create_obj()
791 sizeof (uint64_t), 1, &dp->dp_tmp_userrefs_obj, tx) == 0); in dsl_pool_user_hold_create_obj()
796 const char *tag, uint64_t *now, dmu_tx_t *tx, boolean_t holding) in dsl_pool_user_hold_rele_impl() argument
804 ASSERT(dmu_tx_is_syncing(tx)); in dsl_pool_user_hold_rele_impl()
812 dsl_pool_user_hold_create_obj(dp, tx); in dsl_pool_user_hold_rele_impl()
821 error = zap_add(mos, zapobj, name, 8, 1, now, tx); in dsl_pool_user_hold_rele_impl()
823 error = zap_remove(mos, zapobj, name, tx); in dsl_pool_user_hold_rele_impl()
834 uint64_t *now, dmu_tx_t *tx) in dsl_pool_user_hold() argument
836 return (dsl_pool_user_hold_rele_impl(dp, dsobj, tag, now, tx, B_TRUE)); in dsl_pool_user_hold()
844 dmu_tx_t *tx) in dsl_pool_user_release() argument
847 tx, B_FALSE)); in dsl_pool_user_release()