Lines Matching refs:tx
174 dsl_scan_setup_check(void *arg, dmu_tx_t *tx)
176 dsl_scan_t *scn = dmu_tx_pool(tx)->dp_scan;
185 dsl_scan_setup_sync(void *arg, dmu_tx_t *tx)
187 dsl_scan_t *scn = dmu_tx_pool(tx)->dp_scan;
199 scn->scn_phys.scn_max_txg = tx->tx_txg;
244 ot ? ot : DMU_OT_SCAN_QUEUE, DMU_OT_NONE, 0, tx);
246 dsl_scan_sync_state(scn, tx);
248 spa_history_log_internal(spa, "scan setup", tx,
255 dsl_scan_done(dsl_scan_t *scn, boolean_t complete, dmu_tx_t *tx)
276 DMU_POOL_DIRECTORY_OBJECT, old_names[i], tx);
281 scn->scn_phys.scn_queue_obj, tx));
297 if (dsl_scan_restarting(scn, tx))
298 spa_history_log_internal(spa, "scan aborted, restarting", tx,
301 spa_history_log_internal(spa, "scan cancelled", tx,
304 spa_history_log_internal(spa, "scan done", tx,
322 vdev_dtl_reassess(spa->spa_root_vdev, tx->tx_txg,
342 dsl_scan_cancel_check(void *arg, dmu_tx_t *tx)
344 dsl_scan_t *scn = dmu_tx_pool(tx)->dp_scan;
353 dsl_scan_cancel_sync(void *arg, dmu_tx_t *tx)
355 dsl_scan_t *scn = dmu_tx_pool(tx)->dp_scan;
357 dsl_scan_done(scn, B_FALSE, tx);
358 dsl_scan_sync_state(scn, tx);
370 dmu_objset_type_t ostype, dmu_tx_t *tx);
373 dnode_phys_t *dnp, uint64_t object, dmu_tx_t *tx);
398 dsl_scan_sync_state(dsl_scan_t *scn, dmu_tx_t *tx)
403 &scn->scn_phys, tx));
622 const zbookmark_phys_t *zb, dmu_tx_t *tx)
652 ds, scn, ostype, tx);
677 cdnp, zb->zb_blkid * epb + i, tx);
696 &osp->os_meta_dnode, DMU_META_DNODE_OBJECT, tx);
707 DMU_GROUPUSED_OBJECT, tx);
710 DMU_USERUSED_OBJECT, tx);
721 uint64_t object, dmu_tx_t *tx)
731 &czb, dnp, ds, scn, ostype, tx);
739 &czb, dnp, ds, scn, ostype, tx);
750 dmu_objset_type_t ostype, dmu_tx_t *tx)
778 if (dsl_scan_recurse(scn, ds, ostype, dnp, &bp_toread, zb, tx) != 0)
806 dmu_tx_t *tx)
813 ds, scn, DMU_OST_NONE, tx);
819 dsl_scan_ds_destroyed(dsl_dataset_t *ds, dmu_tx_t *tx)
859 scn->scn_phys.scn_queue_obj, ds->ds_object, tx));
869 mintxg, tx) == 0);
885 dsl_scan_sync_state(scn, tx);
889 dsl_scan_ds_snapshotted(dsl_dataset_t *ds, dmu_tx_t *tx)
910 scn->scn_phys.scn_queue_obj, ds->ds_object, tx));
913 dsl_dataset_phys(ds)->ds_prev_snap_obj, mintxg, tx) == 0);
919 dsl_scan_sync_state(scn, tx);
923 dsl_scan_ds_clone_swapped(dsl_dataset_t *ds1, dsl_dataset_t *ds2, dmu_tx_t *tx)
953 scn->scn_phys.scn_queue_obj, ds1->ds_object, tx));
955 scn->scn_phys.scn_queue_obj, ds2->ds_object, mintxg, tx);
961 ds1->ds_object, mintxg, tx));
972 scn->scn_phys.scn_queue_obj, ds2->ds_object, tx));
974 scn->scn_phys.scn_queue_obj, ds1->ds_object, mintxg, tx));
981 dsl_scan_sync_state(scn, tx);
985 dmu_tx_t *tx;
1017 dsl_dataset_phys(ds)->ds_prev_snap_txg, eca->tx) == 0);
1023 dsl_scan_visitds(dsl_scan_t *scn, uint64_t dsobj, dmu_tx_t *tx)
1087 dmu_buf_will_dirty(ds->ds_dbuf, tx);
1089 dsl_scan_visit_rootbp(scn, ds, &dsl_dataset_phys(ds)->ds_bp, tx);
1117 scn->scn_phys.scn_cur_max_txg, tx) == 0);
1128 dsl_dataset_phys(ds)->ds_creation_txg, tx) == 0);
1152 dsl_dataset_phys(ds)->ds_creation_txg, tx));
1155 eca.tx = tx;
1171 dmu_tx_t *tx = arg;
1202 ds->ds_object, dsl_dataset_phys(ds)->ds_prev_snap_txg, tx) == 0);
1241 dsl_scan_ddt(dsl_scan_t *scn, dmu_tx_t *tx)
1263 dsl_scan_ddt_entry(scn, ddb->ddb_checksum, &dde, tx);
1282 ddt_entry_t *dde, dmu_tx_t *tx)
1304 dsl_scan_visit(dsl_scan_t *scn, dmu_tx_t *tx)
1314 dsl_scan_ddt(scn, tx);
1325 &dp->dp_meta_rootbp, tx);
1332 enqueue_cb, tx, DS_FIND_CHILDREN));
1335 dp->dp_origin_snap->ds_object, tx);
1346 dsl_scan_visitds(scn, scn->scn_phys.scn_bookmark.zb_objset, tx);
1366 scn->scn_phys.scn_queue_obj, dsobj, tx));
1382 dsl_scan_visitds(scn, dsobj, tx);
1409 dsl_scan_free_block_cb(void *arg, const blkptr_t *bp, dmu_tx_t *tx)
1420 dmu_tx_get_txg(tx), bp, 0));
1421 dsl_dir_diduse_space(tx->tx_pool->dp_free_dir, DD_USED_HEAD,
1423 -BP_GET_PSIZE(bp), -BP_GET_UCSIZE(bp), tx);
1450 dsl_scan_sync(dsl_pool_t *dp, dmu_tx_t *tx)
1461 if (dsl_scan_restarting(scn, tx)) {
1463 dsl_scan_done(scn, B_FALSE, tx);
1467 func, tx->tx_txg);
1468 dsl_scan_setup_sync(&func, tx);
1509 dsl_scan_free_block_cb, scn, tx);
1522 dp->dp_bptree_obj, B_TRUE, dsl_scan_free_block_cb, scn, tx);
1534 spa_feature_decr(spa, SPA_FEATURE_ASYNC_DESTROY, tx);
1539 DMU_POOL_BPTREE_OBJ, tx));
1541 dp->dp_bptree_obj, tx));
1564 (longlong_t)tx->tx_txg, err);
1572 ddt_sync(spa, tx->tx_txg);
1589 LEAK_DIR_NAME, tx);
1597 dsl_dir_phys(dp->dp_free_dir)->dd_uncompressed_bytes, tx);
1601 -dsl_dir_phys(dp->dp_free_dir)->dd_uncompressed_bytes, tx);
1613 if (scn->scn_done_txg == tx->tx_txg) {
1616 zfs_dbgmsg("txg %llu scan complete", tx->tx_txg);
1617 dsl_scan_done(scn, B_TRUE, tx);
1619 dsl_scan_sync_state(scn, tx);
1627 (longlong_t)tx->tx_txg,
1638 (longlong_t)tx->tx_txg,
1648 dsl_scan_visit(scn, tx);
1658 scn->scn_done_txg = tx->tx_txg + 1;
1660 tx->tx_txg, scn->scn_done_txg);
1672 dsl_scan_sync_state(scn, tx);
1682 dmu_tx_t *tx;
1683 tx = dmu_tx_create_dd(dp->dp_mos_dir);
1684 VERIFY(0 == dmu_tx_assign(tx, TXG_WAIT));
1686 txg = dmu_tx_get_txg(tx);
1688 dmu_tx_commit(tx);
1889 dsl_scan_restarting(dsl_scan_t *scn, dmu_tx_t *tx)
1892 scn->scn_restart_txg <= tx->tx_txg);