Home
last modified time | relevance | path

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

1234

/freebsd/sys/contrib/openzfs/module/zfs/
H A Dtxg.c122 txg_init(dsl_pool_t *dp, uint64_t txg) in txg_init() argument
153 tx->tx_open_txg = txg; in txg_init()
323 uint64_t txg; in txg_hold_open() local
334 txg = tx->tx_open_txg; in txg_hold_open()
337 tc->tc_count[txg & TXG_MASK]++; in txg_hold_open()
341 th->th_txg = txg; in txg_hold_open()
343 return (txg); in txg_hold_open()
388 txg_quiesce(dsl_pool_t *dp, uint64_t txg) in txg_quiesce() argument
392 int g = txg & TXG_MASK; in txg_quiesce()
401 ASSERT(txg == tx->tx_open_txg); in txg_quiesce()
[all …]
H A Ddsl_pool.c190 dsl_pool_open_impl(spa_t *spa, uint64_t txg) in dsl_pool_open_impl() argument
199 txg_init(dp, txg); in dsl_pool_open_impl()
240 dsl_pool_init(spa_t *spa, uint64_t txg, dsl_pool_t **dpp) in dsl_pool_init() argument
243 dsl_pool_t *dp = dsl_pool_open_impl(spa, txg); in dsl_pool_init()
478 dsl_crypto_params_t *dcp, uint64_t txg) in dsl_pool_create() argument
481 dsl_pool_t *dp = dsl_pool_open_impl(spa, txg); in dsl_pool_create()
482 dmu_tx_t *tx = dmu_tx_create_assigned(dp, txg); in dsl_pool_create()
504 VERIFY0(dsl_scan_init(dp, txg)); in dsl_pool_create()
615 dsl_pool_wrlog_count(dsl_pool_t *dp, int64_t size, uint64_t txg) in dsl_pool_wrlog_count() argument
619 aggsum_add(&dp->dp_wrlog_pertxg[txg & TXG_MASK], size); in dsl_pool_wrlog_count()
[all …]
H A Dvdev_removal.c224 vdev_passivate(vdev_t *vd, uint64_t *txg) in vdev_passivate() argument
270 *txg + TXG_CONCURRENT_STATES + TXG_DEFER_SIZE, 0, FTAG); in vdev_passivate()
280 *txg = spa_vdev_config_enter(spa); in vdev_passivate()
309 uint64_t txg; in spa_vdev_noalloc() local
315 txg = spa_vdev_enter(spa); in spa_vdev_noalloc()
326 error = vdev_passivate(vd, &txg); in spa_vdev_noalloc()
329 vdev_dirty_leaves(vd, VDD_DTL, txg); in spa_vdev_noalloc()
333 error = spa_vdev_exit(spa, NULL, txg, error); in spa_vdev_noalloc()
342 uint64_t txg; in spa_vdev_alloc() local
348 txg = spa_vdev_enter(spa); in spa_vdev_alloc()
[all …]
H A Dzfs_crrd.c131 rrd_add(rrd_t *rrd, hrtime_t time, uint64_t txg) in rrd_add() argument
137 if (tail->rrdd_txg < txg) { in rrd_add()
138 tail->rrdd_txg = txg; in rrd_add()
145 rrd->rrd_entries[rrd->rrd_tail].rrdd_txg = txg; in rrd_add()
157 dbrrd_add(dbrrd_t *db, hrtime_t time, uint64_t txg) in dbrrd_add() argument
166 rrd_add(&db->dbr_months, time, txg); in dbrrd_add()
168 rrd_add(&db->dbr_days, time, txg); in dbrrd_add()
170 rrd_add(&db->dbr_minutes, time, txg); in dbrrd_add()
H A Dzil.c468 zil_parse_lr_func_t *parse_lr_func, void *arg, uint64_t txg, in zil_parse() argument
508 error = parse_blk_func(zilog, &blk, arg, txg); in zil_parse()
562 error = parse_lr_func(zilog, lr, arg, txg); in zil_parse()
823 boolean_t slog, uint64_t txg) in zil_alloc_lwb() argument
858 lwb->lwb_alloc_txg = txg; in zil_alloc_lwb()
899 zilog_dirty(zilog_t *zilog, uint64_t txg) in zilog_dirty() argument
909 if (txg_list_add(&dp->dp_dirty_zilogs, zilog, txg)) { in zilog_dirty()
913 zilog->zl_dirty_max_txg = MAX(txg, zilog->zl_dirty_max_txg); in zilog_dirty()
925 zilog_is_dirty_in_txg(zilog_t *zilog, uint64_t txg) in zilog_is_dirty_in_txg() argument
929 if (txg_list_member(&dp->dp_dirty_zilogs, zilog, txg & TXG_MASK)) in zilog_is_dirty_in_txg()
[all …]
H A Dspa_log_spacemap.c393 summary_entry_is_full(spa_t *spa, log_summary_entry_t *e, uint64_t txg) in summary_entry_is_full() argument
395 if (e->lse_end == txg) in summary_entry_is_full()
419 spa_log_summary_decrement_mscount(spa_t *spa, uint64_t txg, boolean_t dirty) in spa_log_summary_decrement_mscount() argument
431 if (e->lse_start > txg) in spa_log_summary_decrement_mscount()
548 spa_log_sm_decrement_mscount(spa_t *spa, uint64_t txg) in spa_log_sm_decrement_mscount() argument
550 spa_log_sm_t target = { .sls_txg = txg }; in spa_log_sm_decrement_mscount()
576 summary_add_data(spa_t *spa, uint64_t txg, uint64_t metaslabs_flushed, in summary_add_data() argument
581 if (e == NULL || summary_entry_is_full(spa, e, txg)) { in summary_add_data()
583 e->lse_start = e->lse_end = txg; in summary_add_data()
588 ASSERT3U(e->lse_start, <=, txg); in summary_add_data()
[all …]
H A Duberblock.c49 uberblock_update(uberblock_t *ub, vdev_t *rvd, uint64_t txg, uint64_t mmp_delay) in uberblock_update() argument
51 ASSERT(ub->ub_txg < txg); in uberblock_update()
58 ub->ub_txg = txg; in uberblock_update()
74 return (BP_GET_LOGICAL_BIRTH(&ub->ub_rootbp) == txg); in uberblock_update()
H A Dspa_stats.c195 uint64_t txg; /* txg id */ member
251 (longlong_t)sth->txg, sth->times[TXG_STATE_BIRTH], state, in spa_txg_history_show()
319 spa_txg_history_add(spa_t *spa, uint64_t txg, hrtime_t birth_time) in spa_txg_history_add() argument
328 sth->txg = txg; in spa_txg_history_add()
343 spa_txg_history_set(spa_t *spa, uint64_t txg, txg_state_t completed_state, in spa_txg_history_set() argument
356 if (sth->txg == txg) { in spa_txg_history_set()
372 spa_txg_history_set_io(spa_t *spa, uint64_t txg, uint64_t nread, in spa_txg_history_set_io() argument
385 if (sth->txg == txg) { in spa_txg_history_set_io()
401 spa_txg_history_init_io(spa_t *spa, uint64_t txg, dsl_pool_t *dp) in spa_txg_history_init_io() argument
414 ts->txg = txg; in spa_txg_history_init_io()
[all …]
H A Dspa.c2196 spa_sync_time_logger(spa_t *spa, uint64_t txg, boolean_t force) in spa_sync_time_logger() argument
2201 uint64_t idx = txg & TXG_MASK; in spa_sync_time_logger()
2208 if (txg > spa->spa_last_noted_txg && in spa_sync_time_logger()
2212 spa->spa_last_noted_txg = txg; in spa_sync_time_logger()
2215 dbrrd_add(&spa->spa_txg_log_time, curtime, txg); in spa_sync_time_logger()
2223 if (txg > spa_final_dirty_txg(spa)) { in spa_sync_time_logger()
2236 tx = dmu_tx_create_assigned(spa_get_dsl(spa), txg); in spa_sync_time_logger()
2253 uint64_t txg; in spa_unload_sync_time_logger() local
2257 txg = dmu_tx_get_txg(tx); in spa_unload_sync_time_logger()
2258 spa_sync_time_logger(spa, txg, B_TRUE); in spa_unload_sync_time_logger()
[all …]
H A Dspa_config.c327 spa_config_generate(spa_t *spa, vdev_t *vd, uint64_t txg, int getstats) in spa_config_generate() argument
348 if (txg == -1ULL) in spa_config_generate()
349 txg = spa->spa_config_txg; in spa_config_generate()
372 fnvlist_add_uint64(config, ZPOOL_CONFIG_POOL_TXG, txg); in spa_config_generate()
483 uint64_t txg; in spa_config_update() local
489 txg = spa_last_synced_txg(spa) + 1; in spa_config_update()
516 vdev_expand(tvd, txg); in spa_config_update()
524 txg_wait_synced(spa->spa_dsl_pool, txg); in spa_config_update()
H A Dmetaslab.c888 metaslab_class_evict_old(metaslab_class_t *mc, uint64_t txg) in metaslab_class_evict_old() argument
915 if (txg > in metaslab_class_evict_old()
920 metaslab_evict(msp, txg); in metaslab_class_evict_old()
2132 metaslab_verify_space(metaslab_t *msp, uint64_t txg) in metaslab_verify_space() argument
2151 if (txg != spa_syncing_txg(spa) || msp->ms_sm == NULL || in metaslab_verify_space()
2178 zfs_range_tree_space(msp->ms_allocating[(txg + t) & in metaslab_verify_space()
2853 metaslab_set_selected_txg(metaslab_t *msp, uint64_t txg) in metaslab_set_selected_txg() argument
2861 msp->ms_selected_txg = txg; in metaslab_set_selected_txg()
2887 uint64_t txg, metaslab_t **msp) in metaslab_init() argument
2992 if (txg <= TXG_INITIAL) { in metaslab_init()
[all …]
H A Dvdev.c350 vdev_default_psize(vdev_t *vd, uint64_t asize, uint64_t txg) in vdev_default_psize() argument
355 csize = vdev_asize_to_psize_txg(vd->vdev_child[c], asize, txg); in vdev_default_psize()
367 vdev_default_asize(vdev_t *vd, uint64_t psize, uint64_t txg) in vdev_default_asize() argument
373 csize = vdev_psize_to_asize_txg(vd->vdev_child[c], psize, txg); in vdev_default_asize()
1641 vdev_metaslab_init(vdev_t *vd, uint64_t txg) in vdev_metaslab_init() argument
1650 ASSERT(txg == 0 || spa_config_held(spa, SCL_ALLOC, RW_WRITER)); in vdev_metaslab_init()
1691 if (txg == 0 && vd->vdev_ms_array != 0) { in vdev_metaslab_init()
1703 error = metaslab_init(vd->vdev_mg, m, object, txg, in vdev_metaslab_init()
1744 if (txg != 0) { in vdev_metaslab_init()
1746 slog_ms, txg); in vdev_metaslab_init()
[all …]
H A Dvdev_label.c805 vdev_label_read_config(vdev_t *vd, uint64_t txg) in vdev_label_read_config() argument
865 } else if (label_txg <= txg && label_txg > best_txg) { in vdev_label_read_config()
889 (u_longlong_t)txg); in vdev_label_read_config()
908 uint64_t state, pool_guid, device_guid, txg, spare_pool; in vdev_inuse() local
938 &txg) != 0)) { in vdev_inuse()
964 txg == 0 && vdtxg == crtxg) in vdev_inuse()
1218 uint64_t txg = 0ULL; in vdev_label_init() local
1221 txg = spa->spa_uberblock.ub_txg; in vdev_label_init()
1222 label = spa_config_generate(spa, vd, txg, B_FALSE); in vdev_label_init()
1931 vdev_t *vd, int l, uint64_t txg, int flags) in vdev_label_sync() argument
[all …]
H A Dvdev_rebuild.c198 uint64_t txg = dmu_tx_get_txg(tx); in vdev_rebuild_update_sync() local
202 if (vr->vr_scan_offset[txg & TXG_MASK] > 0) { in vdev_rebuild_update_sync()
203 vrp->vrp_last_offset = vr->vr_scan_offset[txg & TXG_MASK]; in vdev_rebuild_update_sync()
204 vr->vr_scan_offset[txg & TXG_MASK] = 0; in vdev_rebuild_update_sync()
281 vdev_rebuild_initiate(vdev_t *vd, uint64_t txg) in vdev_rebuild_initiate() argument
289 dmu_tx_t *tx = dmu_tx_create_assigned(spa_get_dsl(spa), txg); in vdev_rebuild_initiate()
595 uint64_t txg = dmu_tx_get_txg(tx); in vdev_rebuild_range() local
596 vr->vr_last_txg = txg; in vdev_rebuild_range()
602 if (vr->vr_scan_offset[txg & TXG_MASK] == 0) { in vdev_rebuild_range()
603 vr->vr_scan_offset[txg & TXG_MASK] = start; in vdev_rebuild_range()
[all …]
H A Ddmu_redact.c94 uint64_t txg; /* txg to traverse since */ member
368 err = traverse_dataset_resume(rt_arg->ds, rt_arg->txg, in redact_traverse_thread()
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()
558 md->md_synctask_txg[txg & TXG_MASK] = B_FALSE; in redaction_list_update_sync()
570 uint64_t txg = dmu_tx_get_txg(tx); in commit_rl_updates() local
571 if (!md->md_synctask_txg[txg & TXG_MASK]) { in commit_rl_updates()
574 md->md_synctask_txg[txg & TXG_MASK] = B_TRUE; in commit_rl_updates()
575 md->md_latest_synctask_txg = txg; in commit_rl_updates()
[all …]
/freebsd/sys/contrib/openzfs/include/sys/
H A Dtxg.h45 #define TXG_IDX (txg & TXG_MASK)
89 extern void txg_init(struct dsl_pool *dp, uint64_t txg);
98 extern void txg_delay(struct dsl_pool *dp, uint64_t txg, hrtime_t delta,
100 extern void txg_kick(struct dsl_pool *dp, uint64_t txg);
109 extern int txg_wait_synced_flags(struct dsl_pool *dp, uint64_t txg,
116 extern void txg_wait_synced(struct dsl_pool *dp, uint64_t txg);
129 extern void txg_wait_open(struct dsl_pool *dp, uint64_t txg,
141 extern void txg_verify(spa_t *spa, uint64_t txg);
153 #define TXG_CLEAN(txg) ((txg) - 1) argument
157 extern boolean_t txg_list_empty(txg_list_t *tl, uint64_t txg);
[all …]
H A Dvdev.h66 extern int vdev_create(vdev_t *, uint64_t txg, boolean_t isreplace);
76 uint64_t txg, uint64_t size);
78 uint64_t txg, uint64_t size);
84 extern void vdev_dtl_reassess(vdev_t *vd, uint64_t txg, uint64_t scrub_txg,
104 extern int vdev_metaslab_init(vdev_t *vd, uint64_t txg);
107 extern void vdev_expand(vdev_t *vd, uint64_t txg);
138 uint64_t txg);
140 uint64_t txg);
196 extern int vdev_config_sync(vdev_t **svd, int svdcount, uint64_t txg);
223 extern nvlist_t *vdev_label_read_config(vdev_t *vd, uint64_t txg);
[all …]
H A Ddsl_pool.h156 int dsl_pool_init(spa_t *spa, uint64_t txg, dsl_pool_t **dpp);
160 struct dsl_crypto_params *dcp, uint64_t txg);
161 void dsl_pool_sync(dsl_pool_t *dp, uint64_t txg);
162 void dsl_pool_sync_done(dsl_pool_t *dp, uint64_t txg);
168 void dsl_pool_wrlog_count(dsl_pool_t *dp, int64_t size, uint64_t txg);
171 void dsl_pool_undirty_space(dsl_pool_t *dp, int64_t space, uint64_t txg);
172 void dsl_free(dsl_pool_t *dp, uint64_t txg, const blkptr_t *bpp);
173 void dsl_free_sync(zio_t *pio, dsl_pool_t *dp, uint64_t txg,
H A Dvdev_impl.h72 typedef uint64_t vdev_asize_func_t(vdev_t *vd, uint64_t psize, uint64_t txg);
594 extern void vdev_sync(vdev_t *vd, uint64_t txg);
595 extern void vdev_sync_dispatch(vdev_t *vd, uint64_t txg);
596 extern void vdev_sync_done(vdev_t *vd, uint64_t txg);
597 extern void vdev_dirty(vdev_t *vd, int flags, void *arg, uint64_t txg);
598 extern void vdev_dirty_leaves(vdev_t *vd, int flags, uint64_t txg);
621 extern uint64_t vdev_default_psize(vdev_t *vd, uint64_t asize, uint64_t txg);
622 extern uint64_t vdev_default_asize(vdev_t *vd, uint64_t psize, uint64_t txg);
/freebsd/sys/contrib/openzfs/include/os/linux/zfs/sys/
H A Dtrace_txg.h47 TP_PROTO(dsl_pool_t *dp, uint64_t txg),
48 TP_ARGS(dp, txg),
50 __field(uint64_t, txg)
53 __entry->txg = txg;
55 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.h94 uint64_t txg),
95 TP_ARGS(long_free_dirty_all_txgs, chunk_len, txg),
99 __field(uint64_t, txg)
104 __entry->txg = txg;
108 __entry->chunk_len, __entry->txg)
115 uint64_t chunk_len, uint64_t txg), \
116 TP_ARGS(long_free_dirty_all_txgs, chunk_len, txg))
H A Dtrace_vdev.h90 TP_PROTO(spa_t *spa, uint64_t offset, uint64_t size, uint64_t txg),
91 TP_ARGS(spa, offset, size, txg),
102 __entry->vdev_txg = txg;
111 TP_PROTO(spa_t *spa, uint64_t offset, uint64_t size,uint64_t txg), \
112 TP_ARGS(spa, offset, size, txg))
/freebsd/sys/contrib/openzfs/tests/zfs-tests/tests/functional/cli_root/zpool_import/
H A Dimport_rewind_device_replaced.ksh95 typeset txg
96 txg=$(get_last_txg_synced $TESTPOOL1)
118 log_must zpool import -d $DEVICE_DIR -o readonly=on -T $txg $TESTPOOL1
138 log_must zpool import -d $DEVICE_DIR -T $txg $TESTPOOL1
/freebsd/sys/contrib/openzfs/module/os/freebsd/zfs/
H A Dspa_os.c96 uint64_t txg; in spa_generate_rootconf() local
100 txg = fnvlist_lookup_uint64(configs[i], ZPOOL_CONFIG_POOL_TXG); in spa_generate_rootconf()
101 if (txg > best_txg) { in spa_generate_rootconf()
102 best_txg = txg; in spa_generate_rootconf()
/freebsd/sys/contrib/openzfs/lib/libzpool/
H A Darc_os.c62 arc_memory_throttle(spa_t *spa, uint64_t reserve, uint64_t txg) in arc_memory_throttle() argument
64 (void) spa, (void) reserve, (void) txg; in arc_memory_throttle()

1234