/illumos-gate/usr/src/uts/common/fs/zfs/ |
H A D | txg.c | 118 txg_init(dsl_pool_t *dp, uint64_t txg) in txg_init() argument 149 tx->tx_open_txg = txg; in txg_init() 297 uint64_t txg; in txg_hold_open() local 300 txg = tx->tx_open_txg; in txg_hold_open() 303 tc->tc_count[txg & TXG_MASK]++; in txg_hold_open() 307 th->th_txg = txg; in txg_hold_open() 309 return (txg); in txg_hold_open() 354 txg_quiesce(dsl_pool_t *dp, uint64_t txg) in txg_quiesce() argument 357 int g = txg & TXG_MASK; in txg_quiesce() 366 ASSERT(txg == tx->tx_open_txg); in txg_quiesce() [all …]
|
H A D | dsl_pool.c | 186 dsl_pool_open_impl(spa_t *spa, uint64_t txg) in dsl_pool_open_impl() argument 195 txg_init(dp, txg); in dsl_pool_open_impl() 232 dsl_pool_init(spa_t *spa, uint64_t txg, dsl_pool_t **dpp) in dsl_pool_init() argument 235 dsl_pool_t *dp = dsl_pool_open_impl(spa, txg); in dsl_pool_init() 446 uint64_t txg) in dsl_pool_create() argument 449 dsl_pool_t *dp = dsl_pool_open_impl(spa, txg); in dsl_pool_create() 450 dmu_tx_t *tx = dmu_tx_create_assigned(dp, txg); in dsl_pool_create() 467 VERIFY0(dsl_scan_init(dp, txg)); in dsl_pool_create() 577 dsl_early_sync_task_verify(dsl_pool_t *dp, uint64_t txg) in dsl_early_sync_task_verify() argument 587 for (ms = txg_list_head(tl, TXG_CLEAN(txg)); ms; in dsl_early_sync_task_verify() [all …]
|
H A D | zil.c | 322 zil_parse_lr_func_t *parse_lr_func, void *arg, uint64_t txg, in zil_parse() argument 363 error = parse_blk_func(zilog, &blk, arg, txg); in zil_parse() 385 error = parse_lr_func(zilog, lr, arg, txg); in zil_parse() 517 zil_alloc_lwb(zilog_t *zilog, blkptr_t *bp, boolean_t slog, uint64_t txg) in zil_alloc_lwb() argument 527 lwb->lwb_max_txg = txg; in zil_alloc_lwb() 579 zilog_dirty(zilog_t *zilog, uint64_t txg) in zilog_dirty() argument 589 if (txg_list_add(&dp->dp_dirty_zilogs, zilog, txg)) { in zilog_dirty() 593 zilog->zl_dirty_max_txg = MAX(txg, zilog->zl_dirty_max_txg); in zilog_dirty() 605 zilog_is_dirty_in_txg(zilog_t *zilog, uint64_t txg) in zilog_is_dirty_in_txg() argument 609 if (txg_list_member(&dp->dp_dirty_zilogs, zilog, txg & TXG_MASK)) in zilog_is_dirty_in_txg() [all …]
|
H A D | vdev_removal.c | 242 uint64_t txg = dmu_tx_get_txg(tx); in vdev_remove_initiate_sync() local 307 ASSERT3P(txg_list_head(&vd->vdev_ms_list, TXG_CLEAN(txg)), ==, NULL); in vdev_remove_initiate_sync() 482 uint64_t txg = spa_syncing_txg(spa); in free_from_removing_vdev() local 549 int txgoff = (txg + i) & TXG_MASK; in free_from_removing_vdev() 562 uint64_t, txg + i); in free_from_removing_vdev() 608 svr->svr_bytes_done[txg & TXG_MASK] += inflight_size; in free_from_removing_vdev() 611 ASSERT0(svr->svr_max_offset_to_sync[TXG_CLEAN(txg) & TXG_MASK]); in free_from_removing_vdev() 632 svr->svr_bytes_done[txg & TXG_MASK] += size; in free_from_removing_vdev() 716 uint64_t txg = dmu_tx_get_txg(tx); in vdev_mapping_sync() local 720 ASSERT3U(txg, ==, spa_syncing_txg(spa)); in vdev_mapping_sync() [all …]
|
H A D | uberblock.c | 48 uberblock_update(uberblock_t *ub, vdev_t *rvd, uint64_t txg, uint64_t mmp_delay) in uberblock_update() argument 50 ASSERT(ub->ub_txg < txg); in uberblock_update() 57 ub->ub_txg = txg; in uberblock_update() 73 return (ub->ub_rootbp.blk_birth == txg); in uberblock_update()
|
H A D | spa_log_spacemap.c | 406 spa_log_summary_decrement_mscount(spa_t *spa, uint64_t txg) in spa_log_summary_decrement_mscount() argument 418 if (e->lse_start > txg) in spa_log_summary_decrement_mscount() 536 spa_log_sm_decrement_mscount(spa_t *spa, uint64_t txg) in spa_log_sm_decrement_mscount() argument 538 spa_log_sm_t target = { .sls_txg = txg }; in spa_log_sm_decrement_mscount() 565 summary_add_data(spa_t *spa, uint64_t txg, uint64_t metaslabs_flushed, in summary_add_data() argument 572 e->lse_start = txg; in summary_add_data() 576 ASSERT3U(e->lse_start, <=, txg); in summary_add_data() 721 uint64_t txg = dmu_tx_get_txg(tx); in spa_flush_metaslabs() local 749 if (spa->spa_uberblock.ub_rootbp.blk_birth < txg && in spa_flush_metaslabs() 750 !dmu_objset_is_dirty(spa_meta_objset(spa), txg) && in spa_flush_metaslabs() [all …]
|
H A D | metaslab.c | 601 metaslab_class_evict_old(metaslab_class_t *mc, uint64_t txg) in metaslab_class_evict_old() argument 625 if (txg > in metaslab_class_evict_old() 629 metaslab_evict(msp, txg); in metaslab_class_evict_old() 1830 metaslab_verify_space(metaslab_t *msp, uint64_t txg) in metaslab_verify_space() argument 1849 if (txg != spa_syncing_txg(spa) || msp->ms_sm == NULL || in metaslab_verify_space() 1876 range_tree_space(msp->ms_allocating[(txg + t) & TXG_MASK]); in metaslab_verify_space() 2526 metaslab_set_selected_txg(metaslab_t *msp, uint64_t txg) in metaslab_set_selected_txg() argument 2534 msp->ms_selected_txg = txg; in metaslab_set_selected_txg() 2555 uint64_t txg, metaslab_t **msp) in metaslab_init() argument 2629 if (txg <= TXG_INITIAL) { in metaslab_init() [all …]
|
H A D | spa_config.c | 364 spa_config_generate(spa_t *spa, vdev_t *vd, uint64_t txg, int getstats) in spa_config_generate() argument 385 if (txg == -1ULL) in spa_config_generate() 386 txg = spa->spa_config_txg; in spa_config_generate() 410 fnvlist_add_uint64(config, ZPOOL_CONFIG_POOL_TXG, txg); in spa_config_generate() 521 uint64_t txg; in spa_config_update() local 527 txg = spa_last_synced_txg(spa) + 1; in spa_config_update() 554 vdev_expand(tvd, txg); in spa_config_update() 562 txg_wait_synced(spa->spa_dsl_pool, txg); in spa_config_update()
|
H A D | vdev_label.c | 747 vdev_label_read_config(vdev_t *vd, uint64_t txg) in vdev_label_read_config() argument 793 } else if (label_txg <= txg && label_txg > best_txg) { in vdev_label_read_config() 817 (u_longlong_t)txg); in vdev_label_read_config() 834 uint64_t state, pool_guid, device_guid, txg, spare_pool; in vdev_inuse() local 864 &txg) != 0)) { in vdev_inuse() 890 txg == 0 && vdtxg == crtxg) in vdev_inuse() 1080 uint64_t txg = 0ULL; in vdev_label_init() local 1083 txg = spa->spa_uberblock.ub_txg; in vdev_label_init() 1084 label = spa_config_generate(spa, vd, txg, B_FALSE); in vdev_label_init() 1661 vdev_t *vd, int l, uint64_t txg, int flags) in vdev_label_sync() argument [all …]
|
H A D | spa.c | 2593 uint64_t txg = ub->ub_txg; in spa_activity_check() local 2642 if (txg != ub->ub_txg || timestamp != ub->ub_timestamp || in spa_activity_check() 2648 txg, ub->ub_txg, timestamp, ub->ub_timestamp, in spa_activity_check() 5086 uint64_t txg = TXG_INITIAL; local 5165 spa->spa_first_txg = txg; 5166 spa->spa_uberblock.ub_txg = txg - 1; 5200 (error = vdev_create(rvd, txg, B_FALSE)) == 0 && 5201 (error = spa_validate_aux(spa, nvroot, txg, 5211 vdev_expand(vd, txg); 5256 spa->spa_dsl_pool = dp = dsl_pool_create(spa, zplprops, dcp, txg); [all …]
|
H A D | vdev.c | 1209 vdev_metaslab_init(vdev_t *vd, uint64_t txg) in vdev_metaslab_init() argument 1220 ASSERT(txg == 0 || spa_config_held(spa, SCL_ALLOC, RW_WRITER)); in vdev_metaslab_init() 1249 if (txg == 0 && vd->vdev_ms_array != 0) { in vdev_metaslab_init() 1271 error = metaslab_init(vd->vdev_mg, m, object, txg, in vdev_metaslab_init() 1280 if (txg == 0) in vdev_metaslab_init() 1292 if (txg == 0) in vdev_metaslab_init() 1821 uint64_t txg; in vdev_validate() local 1846 txg = UINT64_MAX; in vdev_validate() 1848 txg = spa_last_synced_txg(spa); in vdev_validate() 1850 if ((label = vdev_label_read_config(vd, txg)) == NULL) { in vdev_validate() [all …]
|
H A D | ddt.c | 247 ddt_bp_fill(const ddt_phys_t *ddp, blkptr_t *bp, uint64_t txg) in ddt_bp_fill() argument 249 ASSERT(txg != 0); in ddt_bp_fill() 253 BP_SET_BIRTH(bp, txg, ddp->ddp_phys_birth); in ddt_bp_fill() 327 ddt_phys_free(ddt_t *ddt, ddt_key_t *ddk, ddt_phys_t *ddp, uint64_t txg) in ddt_phys_free() argument 333 zio_free(ddt->ddt_spa, txg, &blk); in ddt_phys_free() 1014 ddt_sync_entry(ddt_t *ddt, ddt_entry_t *dde, dmu_tx_t *tx, uint64_t txg) in ddt_sync_entry() argument 1037 ddt_phys_free(ddt, ddk, ddp, txg); in ddt_sync_entry() 1041 ddt_phys_free(ddt, ddk, ddp, txg); in ddt_sync_entry() 1081 ddt_sync_table(ddt_t *ddt, dmu_tx_t *tx, uint64_t txg) in ddt_sync_table() argument 1099 ddt_sync_entry(ddt, dde, tx, txg); in ddt_sync_table() [all …]
|
H A D | vdev_initialize.c | 66 uint64_t txg = dmu_tx_get_txg(tx); in vdev_initialize_zap_update_sync() local 73 uint64_t last_offset = vd->vdev_initialize_offset[txg & TXG_MASK]; in vdev_initialize_zap_update_sync() 74 vd->vdev_initialize_offset[txg & TXG_MASK] = 0; in vdev_initialize_zap_update_sync() 201 uint64_t txg = dmu_tx_get_txg(tx); in vdev_initialize_write() local 206 if (vd->vdev_initialize_offset[txg & TXG_MASK] == 0) { in vdev_initialize_write() 232 vd->vdev_initialize_offset[txg & TXG_MASK] = start + size; in vdev_initialize_write() 233 zio_nowait(zio_write_phys(spa->spa_txg_zio[txg & TXG_MASK], vd, start, in vdev_initialize_write()
|
/illumos-gate/usr/src/uts/common/fs/zfs/sys/ |
H A D | txg.h | 43 #define TXG_IDX (txg & TXG_MASK) 69 extern void txg_init(struct dsl_pool *dp, uint64_t txg); 78 extern void txg_delay(struct dsl_pool *dp, uint64_t txg, hrtime_t delta, 88 extern void txg_wait_synced(struct dsl_pool *dp, uint64_t txg); 93 extern boolean_t txg_wait_synced_sig(struct dsl_pool *dp, uint64_t txg); 101 extern void txg_wait_open(struct dsl_pool *dp, uint64_t txg, 113 extern void txg_verify(spa_t *spa, uint64_t txg); 119 #define TXG_CLEAN(txg) ((txg) - 1) argument 123 extern boolean_t txg_list_empty(txg_list_t *tl, uint64_t txg); 125 extern boolean_t txg_list_add(txg_list_t *tl, void *p, uint64_t txg); [all …]
|
H A D | vdev.h | 61 extern int vdev_create(vdev_t *, uint64_t txg, boolean_t isreplace); 71 uint64_t txg, uint64_t size); 73 uint64_t txg, uint64_t size); 76 extern void vdev_dtl_reassess(vdev_t *vd, uint64_t txg, uint64_t scrub_txg, 94 extern int vdev_metaslab_init(vdev_t *vd, uint64_t txg); 97 extern void vdev_expand(vdev_t *vd, uint64_t txg); 151 extern int vdev_config_sync(vdev_t **svd, int svdcount, uint64_t txg); 178 extern nvlist_t *vdev_label_read_config(vdev_t *vd, uint64_t txg); 195 extern int vdev_label_init(vdev_t *vd, uint64_t txg, vdev_labeltype_t reason);
|
H A D | dsl_pool.h | 146 int dsl_pool_init(spa_t *spa, uint64_t txg, dsl_pool_t **dpp); 150 struct dsl_crypto_params *dcp, uint64_t txg); 151 void dsl_pool_sync(dsl_pool_t *dp, uint64_t txg); 152 void dsl_pool_sync_done(dsl_pool_t *dp, uint64_t txg); 158 void dsl_pool_undirty_space(dsl_pool_t *dp, int64_t space, uint64_t txg); 159 void dsl_free(dsl_pool_t *dp, uint64_t txg, const blkptr_t *bpp); 160 void dsl_free_sync(zio_t *pio, dsl_pool_t *dp, uint64_t txg,
|
H A D | zil.h | 403 uint64_t txg); 405 uint64_t txg); 411 zil_parse_lr_func_t *parse_lr_func, void *arg, uint64_t txg, 449 extern void zil_lwb_add_txg(struct lwb *lwb, uint64_t txg);
|
H A D | zio.h | 519 extern zio_t *zio_write(zio_t *pio, spa_t *spa, uint64_t txg, blkptr_t *bp, 526 extern zio_t *zio_rewrite(zio_t *pio, spa_t *spa, uint64_t txg, blkptr_t *bp, 533 extern void zio_free(spa_t *spa, uint64_t txg, const blkptr_t *bp); 535 extern zio_t *zio_claim(zio_t *pio, spa_t *spa, uint64_t txg, 556 extern zio_t *zio_free_sync(zio_t *pio, spa_t *spa, uint64_t txg, 559 extern int zio_alloc_zil(spa_t *spa, objset_t *os, uint64_t txg, 561 extern void zio_free_zil(spa_t *spa, uint64_t txg, blkptr_t *bp);
|
H A D | vdev_impl.h | 530 extern void vdev_sync(vdev_t *vd, uint64_t txg); 531 extern void vdev_sync_done(vdev_t *vd, uint64_t txg); 532 extern void vdev_dirty(vdev_t *vd, int flags, void *arg, uint64_t txg); 533 extern void vdev_dirty_leaves(vdev_t *vd, int flags, uint64_t txg);
|
H A D | dsl_scan.h | 162 int dsl_scan_init(struct dsl_pool *dp, uint64_t txg); 170 void dsl_scan_restart_resilver(struct dsl_pool *, uint64_t txg);
|
/illumos-gate/usr/src/test/zfs-tests/tests/functional/cli_root/zpool_import/ |
H A D | zpool_import.kshlib | 347 txg=$(tail "/proc/spl/kstat/zfs/$pool/txgs" | 349 [[ "$txg" ]] || txg=0 350 echo $txg 372 typeset -i txg 373 txg=$(mdb -k -e "$mdbcmd") 376 echo $txg
|
H A D | import_rewind_device_replaced.ksh | 93 typeset txg 94 txg=$(get_last_txg_synced $TESTPOOL1) 116 log_must zpool import -d $DEVICE_DIR -o readonly=on -T $txg $TESTPOOL1 136 log_must zpool import -d $DEVICE_DIR -T $txg $TESTPOOL1
|
H A D | import_rewind_config_changed.ksh | 75 typeset txg 76 txg=$(get_last_txg_synced $TESTPOOL1) 130 log_must zpool import -d $DEVICE_DIR -T $txg $TESTPOOL1
|
/illumos-gate/usr/src/cmd/ztest/ |
H A D | ztest.c | 1400 uint64_t txg; in ztest_tx_assign() local 1418 txg = dmu_tx_get_txg(tx); in ztest_tx_assign() 1419 ASSERT(txg != 0); in ztest_tx_assign() 1420 return (txg); in ztest_tx_assign() 1448 uint64_t dnodesize, uint64_t offset, uint64_t gen, uint64_t txg, in ztest_bt_generate() argument 1457 bt->bt_txg = txg; in ztest_bt_generate() 1463 uint64_t dnodesize, uint64_t offset, uint64_t gen, uint64_t txg, in ztest_bt_verify() argument 1472 ASSERT3U(bt->bt_txg, <=, txg); in ztest_bt_verify() 1658 uint64_t txg; in ztest_replay_create() local 1678 txg = ztest_tx_assign(tx, TXG_WAIT, FTAG); in ztest_replay_create() [all …]
|
/illumos-gate/usr/src/test/zfs-tests/tests/functional/cli_root/zpool_sync/ |
H A D | zpool_sync_001_pos.ksh | 36 typeset -i txg=$(zdb -u $1 | sed -n 's/^[ ][ ]*txg = \(.*\)$/\1/p') 37 echo $txg
|