Home
last modified time | relevance | path

Searched refs:txg (Results 1 – 25 of 80) sorted by relevance

1234

/f-stack/freebsd/contrib/openzfs/include/sys/
H A Dtxg.h43 #define TXG_IDX (txg & TXG_MASK)
70 extern void txg_init(struct dsl_pool *dp, uint64_t txg);
89 extern void txg_wait_synced(struct dsl_pool *dp, uint64_t txg);
102 extern void txg_wait_open(struct dsl_pool *dp, uint64_t txg,
114 extern void txg_verify(spa_t *spa, uint64_t txg);
126 #define TXG_CLEAN(txg) ((txg) - 1) argument
130 extern boolean_t txg_list_empty(txg_list_t *tl, uint64_t txg);
134 extern void *txg_list_remove(txg_list_t *tl, uint64_t txg);
137 extern void *txg_list_head(txg_list_t *tl, uint64_t txg);
145 #define TXG_VERIFY(spa, txg) txg_verify(spa, txg) argument
[all …]
H A Ddsl_pool.h150 int dsl_pool_init(spa_t *spa, uint64_t txg, dsl_pool_t **dpp);
154 struct dsl_crypto_params *dcp, uint64_t txg);
155 void dsl_pool_sync(dsl_pool_t *dp, uint64_t txg);
156 void dsl_pool_sync_done(dsl_pool_t *dp, uint64_t txg);
162 void dsl_pool_undirty_space(dsl_pool_t *dp, int64_t space, uint64_t txg);
163 void dsl_free(dsl_pool_t *dp, uint64_t txg, const blkptr_t *bpp);
164 void dsl_free_sync(zio_t *pio, dsl_pool_t *dp, uint64_t txg,
H A Dvdev.h63 extern int vdev_create(vdev_t *, uint64_t txg, boolean_t isreplace);
73 uint64_t txg, uint64_t size);
75 uint64_t txg, uint64_t size);
81 extern void vdev_dtl_reassess(vdev_t *vd, uint64_t txg, uint64_t scrub_txg,
100 extern int vdev_metaslab_init(vdev_t *vd, uint64_t txg);
103 extern void vdev_expand(vdev_t *vd, uint64_t txg);
163 extern int vdev_config_sync(vdev_t **svd, int svdcount, uint64_t txg);
189 extern nvlist_t *vdev_label_read_config(vdev_t *vd, uint64_t txg);
206 extern int vdev_label_init(vdev_t *vd, uint64_t txg, vdev_labeltype_t reason);
/f-stack/freebsd/contrib/openzfs/module/zfs/
H A Dtxg.c300 uint64_t txg; in txg_hold_open() local
318 th->th_txg = txg; in txg_hold_open()
320 return (txg); in txg_hold_open()
519 uint64_t txg; in txg_sync_thread() local
573 spa_sync(spa, txg); in txg_sync_thread()
600 uint64_t txg; in txg_quiesce_thread() local
652 tx->tx_syncing_txg == txg-1 || tx->tx_synced_txg == txg-1) in txg_delay()
656 if (tx->tx_open_txg > txg || tx->tx_synced_txg == txg-1) { in txg_delay()
681 if (txg == 0) in txg_wait_synced_impl()
740 if (txg == 0) in txg_wait_open()
[all …]
H A Ddsl_pool.c187 dsl_pool_open_impl(spa_t *spa, uint64_t txg) in dsl_pool_open_impl() argument
196 txg_init(dp, txg); in dsl_pool_open_impl()
237 dsl_pool_t *dp = dsl_pool_open_impl(spa, txg); in dsl_pool_init()
459 uint64_t txg) in dsl_pool_create() argument
485 VERIFY0(dsl_scan_init(dp, txg)); in dsl_pool_create()
620 dsl_pool_sync(dsl_pool_t *dp, uint64_t txg) in dsl_pool_sync() argument
632 tx = dmu_tx_create_assigned(dp, txg); in dsl_pool_sync()
648 ASSERT(dsl_early_sync_task_verify(dp, txg)); in dsl_pool_sync()
758 if (dmu_objset_is_dirty(mos, txg)) { in dsl_pool_sync()
775 dsl_pool_undirty_space(dp, dp->dp_dirty_pertxg[txg & TXG_MASK], txg); in dsl_pool_sync()
[all …]
H A Dvdev_removal.c573 uint64_t, txg + i); in free_from_removing_vdev()
1053 vcsa->vcsa_txg = txg; in spa_vdev_copy_segment()
1076 vdev_dirty(vd, 0, NULL, txg); in spa_vdev_copy_segment()
1182 uint64_t txg; in vdev_remove_complete() local
1189 txg = spa_vdev_enter(spa); in vdev_remove_complete()
1199 vd->vdev_id, txg); in vdev_remove_complete()
1236 txg = spa_vdev_enter(spa); in vdev_remove_complete()
1541 if (txg != last_txg) in spa_vdev_remove_thread()
1543 last_txg = txg; in spa_vdev_remove_thread()
2192 uint64_t txg = 0; in spa_vdev_remove() local
[all …]
H A Dzil.c671 uint64_t txg = 0; in zil_create() local
749 uint64_t txg; in zil_destroy() local
1455 uint64_t txg; in zil_lwb_write_issue() local
1659 txg = lrc->lrc_txg; in zil_lwb_commit()
1891 uint64_t otxg, txg; in zil_remove_async() local
1906 for (txg = otxg; txg < (otxg + TXG_CONCURRENT_STATES); txg++) { in zil_remove_async()
1936 uint64_t txg; in zil_itx_assign() local
2074 for (txg = otxg; txg < (otxg + TXG_CONCURRENT_STATES); txg++) { in zil_get_commit_list()
2119 for (txg = otxg; txg < (otxg + TXG_CONCURRENT_STATES); txg++) { in zil_async_to_sync()
3260 uint64_t txg; in zil_close() local
[all …]
H A Duberblock.c48 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 Dspa_stats.c194 uint64_t txg; /* txg id */ member
250 (longlong_t)sth->txg, sth->times[TXG_STATE_BIRTH], state, in spa_txg_history_show()
327 sth->txg = txg; in spa_txg_history_add()
355 if (sth->txg == txg) { in spa_txg_history_set()
384 if (sth->txg == txg) { in spa_txg_history_set_io()
413 ts->txg = txg; in spa_txg_history_init_io()
414 ts->ndirty = dp->dp_dirty_pertxg[txg & TXG_MASK]; in spa_txg_history_init_io()
437 spa_txg_history_set_io(spa, ts->txg, in spa_txg_history_fini_io()
620 uint64_t txg; /* txg of last sync */ member
651 (u_longlong_t)smh->mmp_node_id, (u_longlong_t)smh->txg, in spa_mmp_history_show()
[all …]
H A Dspa_log_spacemap.c416 if (e->lse_start > txg) in spa_log_summary_decrement_mscount()
534 spa_log_sm_decrement_mscount(spa_t *spa, uint64_t txg) in spa_log_sm_decrement_mscount() argument
536 spa_log_sm_t target = { .sls_txg = txg }; in spa_log_sm_decrement_mscount()
569 e->lse_start = txg; in summary_add_data()
573 ASSERT3U(e->lse_start, <=, txg); in summary_add_data()
718 uint64_t txg = dmu_tx_get_txg(tx); in spa_flush_metaslabs() local
746 if (spa->spa_uberblock.ub_rootbp.blk_birth < txg && in spa_flush_metaslabs()
802 if (metaslab_unflushed_txg(curr) == txg) in spa_flush_metaslabs()
913 spa_log_sm_alloc(uint64_t sm_obj, uint64_t txg) in spa_log_sm_alloc() argument
917 sls->sls_txg = txg; in spa_log_sm_alloc()
[all …]
H A Dmetaslab.c658 if (txg > in metaslab_class_evict_old()
662 metaslab_evict(msp, txg); in metaslab_class_evict_old()
2589 msp->ms_selected_txg = txg; in metaslab_set_selected_txg()
2687 if (txg <= TXG_INITIAL) { in metaslab_init()
2693 if (txg != 0) { in metaslab_init()
4591 msp->ms_alloc_txg = txg; in metaslab_block_alloc()
5647 uint64_t txg) in metaslab_claim_concrete() argument
5740 arg.mcca_txg = txg; in metaslab_claim_impl()
5747 offset, size, txg); in metaslab_claim_impl()
5833 BP_SET_BIRTH(bp, txg, 0); in metaslab_alloc()
[all …]
H A Dspa_config.c398 spa_config_generate(spa_t *spa, vdev_t *vd, uint64_t txg, int getstats) in spa_config_generate() argument
419 if (txg == -1ULL) in spa_config_generate()
420 txg = spa->spa_config_txg; in spa_config_generate()
443 fnvlist_add_uint64(config, ZPOOL_CONFIG_POOL_TXG, txg); in spa_config_generate()
549 uint64_t txg; in spa_config_update() local
555 txg = spa_last_synced_txg(spa) + 1; in spa_config_update()
582 vdev_expand(tvd, txg); in spa_config_update()
590 txg_wait_synced(spa->spa_dsl_pool, txg); in spa_config_update()
H A Dvdev_label.c831 (u_longlong_t)txg); in vdev_label_read_config()
878 &txg) != 0)) { in vdev_inuse()
904 txg == 0 && vdtxg == crtxg) in vdev_inuse()
1096 uint64_t txg = 0ULL; in vdev_label_init() local
1099 txg = spa->spa_uberblock.ub_txg; in vdev_label_init()
1765 vd->vdev_child[c], l, txg, flags); in vdev_label_sync()
1884 ASSERT(ub->ub_txg <= txg); in vdev_config_sync()
1892 if (ub->ub_txg < txg) { in vdev_config_sync()
1894 txg, spa->spa_mmp.mmp_delay); in vdev_config_sync()
1900 if (txg > spa_freeze_txg(spa)) in vdev_config_sync()
[all …]
H A Dspa.c5725 spa->spa_first_txg = txg;
5771 vdev_expand(vd, txg);
5911 txg_wait_synced(dp, txg);
6433 uint64_t txg, ndraid = 0; local
6515 txg, EINVAL));
6869 uint64_t txg; local
7064 vdev_expand(tvd, txg);
7366 uint64_t txg, *glist; local
8935 dsl_pool_sync(dp, txg);
8956 ddt_sync(spa, txg);
[all …]
H A Dvdev.c1411 if (txg == 0) in vdev_metaslab_init()
1423 if (txg == 0) in vdev_metaslab_init()
2058 uint64_t txg; in vdev_validate() local
2083 txg = UINT64_MAX; in vdev_validate()
2928 if (txg != 0 && in vdev_dtl_reassess()
2942 if (txg != 0) in vdev_dtl_reassess()
3532 metaslab_sync_done(msp, txg); in vdev_sync_done()
3578 metaslab_sync(msp, txg); in vdev_sync()
3583 vdev_dtl_sync(lvd, txg); in vdev_sync()
4304 uint64_t txg = zio->io_txg; in vdev_stat_update() local
[all …]
H A Ddmu_redact.c92 uint64_t txg; /* txg to traverse since */ member
519 uint64_t txg = dmu_tx_get_txg(tx); in redaction_list_update_sync() local
520 list_t *list = &md->md_blocks[txg & TXG_MASK]; in redaction_list_update_sync()
522 &md->md_furthest[txg & TXG_MASK]; in redaction_list_update_sync()
556 md->md_synctask_txg[txg & TXG_MASK] = B_FALSE; in redaction_list_update_sync()
568 uint64_t txg = dmu_tx_get_txg(tx); in commit_rl_updates() local
569 if (!md->md_synctask_txg[txg & TXG_MASK]) { in commit_rl_updates()
572 md->md_synctask_txg[txg & TXG_MASK] = B_TRUE; in commit_rl_updates()
573 md->md_latest_synctask_txg = txg; in commit_rl_updates()
576 md->md_furthest[txg & TXG_MASK].rbp_blkid = blkid; in commit_rl_updates()
[all …]
/f-stack/freebsd/contrib/openzfs/include/os/linux/zfs/sys/
H A Dtrace_txg.h46 TP_PROTO(dsl_pool_t *dp, uint64_t txg),
47 TP_ARGS(dp, txg),
49 __field(uint64_t, txg)
52 __entry->txg = txg;
54 TP_printk("txg %llu", __entry->txg)
61 TP_PROTO(dsl_pool_t *dp, uint64_t txg), \
62 TP_ARGS(dp, txg))
H A Dtrace_dmu.h95 uint64_t txg),
96 TP_ARGS(long_free_dirty_all_txgs, chunk_len, txg),
100 __field(uint64_t, txg)
105 __entry->txg = txg;
109 __entry->chunk_len, __entry->txg)
117 uint64_t chunk_len, uint64_t txg), \
118 TP_ARGS(long_free_dirty_all_txgs, chunk_len, txg))
H A Dtrace_vdev.h91 TP_PROTO(spa_t *spa, uint64_t offset, uint64_t size, uint64_t txg),
92 TP_ARGS(spa, offset, size, txg),
103 __entry->vdev_txg = txg;
113 TP_PROTO(spa_t *spa, uint64_t offset, uint64_t size,uint64_t txg), \
114 TP_ARGS(spa, offset, size, txg))
/f-stack/freebsd/contrib/openzfs/module/os/freebsd/zfs/
H A Dspa_os.c96 uint64_t txg; in spa_generate_rootconf() local
99 &txg) == 0); in spa_generate_rootconf()
100 if (txg > best_txg) { in spa_generate_rootconf()
101 best_txg = txg; in spa_generate_rootconf()
193 uint64_t txg; in spa_import_rootpool() local
206 VERIFY(nvlist_lookup_uint64(config, ZPOOL_CONFIG_POOL_TXG, &txg) in spa_import_rootpool()
/f-stack/freebsd/contrib/openzfs/tests/zfs-tests/tests/functional/cli_root/zpool_import/
H A Dimport_rewind_device_replaced.ksh94 typeset txg
95 txg=$(get_last_txg_synced $TESTPOOL1)
117 log_must zpool import -d $DEVICE_DIR -o readonly=on -T $txg $TESTPOOL1
137 log_must zpool import -d $DEVICE_DIR -T $txg $TESTPOOL1
H A Dimport_rewind_config_changed.ksh74 typeset txg
75 txg=$(get_last_txg_synced $TESTPOOL1)
129 log_must zpool import -d $DEVICE_DIR -T $txg $TESTPOOL1
/f-stack/freebsd/contrib/openzfs/tests/zfs-tests/tests/functional/cli_root/zpool_sync/
H A Dzpool_sync_001_pos.ksh36 typeset -i txg=$(zdb -u $1 | sed -n 's/^[ ][ ]*txg = \(.*\)$/\1/p')
37 echo $txg
/f-stack/freebsd/contrib/openzfs/module/os/linux/zfs/
H A Darc_os.c251 arc_memory_throttle(spa_t *spa, uint64_t reserve, uint64_t txg) in arc_memory_throttle() argument
258 if (txg > spa->spa_lowmem_last_txg) { in arc_memory_throttle()
259 spa->spa_lowmem_last_txg = txg; in arc_memory_throttle()
448 arc_memory_throttle(spa_t *spa, uint64_t reserve, uint64_t txg) in arc_memory_throttle() argument
/f-stack/freebsd/contrib/openzfs/cmd/ztest/
H A Dztest.c1619 uint64_t txg; in ztest_tx_assign() local
1639 return (txg); in ztest_tx_assign()
1854 uint64_t txg; in ztest_replay_create() local
1875 if (txg == 0) in ztest_replay_create()
1920 lr->lr_gen, txg, txg); in ztest_replay_create()
2122 uint64_t txg; in ztest_replay_truncate() local
2579 uint64_t txg; in ztest_prealloc() local
5154 if (txg == 0) in ztest_zap()
5222 if (txg == 0) in ztest_zap()
5255 if (txg == 0) in ztest_zap()
[all …]

1234