Home
last modified time | relevance | path

Searched refs:TXG_MASK (Results 1 – 25 of 27) sorted by relevance

12

/src/sys/contrib/openzfs/module/zfs/
H A Dtxg.c337 tc->tc_count[txg & TXG_MASK]++; in txg_hold_open()
359 int g = th->th_txg & TXG_MASK; in txg_register_callbacks()
370 int g = th->th_txg & TXG_MASK; in txg_rele_to_sync()
392 int g = txg & TXG_MASK; in txg_quiesce()
463 int g = txg & TXG_MASK; in txg_dispatch_callbacks()
892 return (tl->tl_head[txg & TXG_MASK] == NULL); in txg_list_empty_impl()
940 int t = txg & TXG_MASK; in txg_list_add()
965 int t = txg & TXG_MASK; in txg_list_add_tail()
993 int t = txg & TXG_MASK; in txg_list_remove()
1018 int t = txg & TXG_MASK; in txg_list_remove_this()
[all …]
H A Ddsl_pool.c619 aggsum_add(&dp->dp_wrlog_pertxg[txg & TXG_MASK], size); in dsl_pool_wrlog_count()
625 if (aggsum_compare(&dp->dp_wrlog_pertxg[txg & TXG_MASK], sync_min) > 0) in dsl_pool_wrlog_count()
642 delta = -(int64_t)aggsum_value(&dp->dp_wrlog_pertxg[txg & TXG_MASK]); in dsl_pool_wrlog_clear()
643 aggsum_add(&dp->dp_wrlog_pertxg[txg & TXG_MASK], delta); in dsl_pool_wrlog_clear()
646 (void) aggsum_value(&dp->dp_wrlog_pertxg[txg & TXG_MASK]); in dsl_pool_wrlog_clear()
731 dp->dp_long_free_dirty_pertxg[txg & TXG_MASK] == 0); in dsl_pool_sync()
732 dp->dp_long_free_dirty_pertxg[txg & TXG_MASK] = 0; in dsl_pool_sync()
768 !os->os_next_write_raw[txg & TXG_MASK]) { in dsl_pool_sync()
788 !os->os_next_write_raw[txg & TXG_MASK]) { in dsl_pool_sync()
834 dsl_pool_undirty_space(dp, dp->dp_dirty_pertxg[txg & TXG_MASK], txg); in dsl_pool_sync()
[all …]
H A Ddnode.c539 dn->dn_next_bonuslen[tx->tx_txg & TXG_MASK] = DN_ZERO_BONUSLEN; in dnode_setbonuslen()
541 dn->dn_next_bonuslen[tx->tx_txg & TXG_MASK] = dn->dn_bonuslen; in dnode_setbonuslen()
552 dn->dn_next_bonustype[tx->tx_txg & TXG_MASK] = dn->dn_bonustype; in dnode_setbonus_type()
573 dn->dn_rm_spillblk[tx->tx_txg & TXG_MASK] = DN_KILL_SPILLBLK; in dnode_rm_spill()
805 dn->dn_next_indblkshift[tx->tx_txg & TXG_MASK] = ibs; in dnode_allocate()
806 dn->dn_next_bonuslen[tx->tx_txg & TXG_MASK] = dn->dn_bonuslen; in dnode_allocate()
807 dn->dn_next_bonustype[tx->tx_txg & TXG_MASK] = dn->dn_bonustype; in dnode_allocate()
808 dn->dn_next_blksz[tx->tx_txg & TXG_MASK] = dn->dn_datablksz; in dnode_allocate()
849 dn->dn_next_blksz[tx->tx_txg & TXG_MASK] = blocksize; in dnode_reallocate()
852 dn->dn_next_bonuslen[tx->tx_txg & TXG_MASK] = bonuslen; in dnode_reallocate()
[all …]
H A Dvdev_removal.c767 int txgoff = (txg + i) & TXG_MASK; in free_from_removing_vdev()
826 svr->svr_bytes_done[txg & TXG_MASK] += inflight_size; in free_from_removing_vdev()
829 ASSERT0(svr->svr_max_offset_to_sync[TXG_CLEAN(txg) & TXG_MASK]); in free_from_removing_vdev()
851 svr->svr_bytes_done[txg & TXG_MASK] += size; in free_from_removing_vdev()
944 &svr->svr_new_segments[txg & TXG_MASK], tx); in vdev_mapping_sync()
953 zfs_range_tree_vacate(svr->svr_frees[txg & TXG_MASK], in vdev_mapping_sync()
955 ASSERT3U(svr->svr_max_offset_to_sync[txg & TXG_MASK], >=, in vdev_mapping_sync()
957 svr->svr_max_offset_to_sync[txg & TXG_MASK] = 0; in vdev_mapping_sync()
1269 zio_t *nzio = zio_null(spa->spa_txg_zio[txg & TXG_MASK], spa, NULL, in spa_vdev_copy_segment()
1284 list_insert_tail(&svr->svr_new_segments[txg & TXG_MASK], entry); in spa_vdev_copy_segment()
[all …]
H A Dvdev_rebuild.c202 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()
501 uint64_t *off = &vr->vr_scan_offset[zio->io_txg & TXG_MASK]; in vdev_rebuild_cb()
601 if (vr->vr_scan_offset[txg & TXG_MASK] == 0) { in vdev_rebuild_range()
602 vr->vr_scan_offset[txg & TXG_MASK] = start; in vdev_rebuild_range()
620 vr->vr_scan_offset[txg & TXG_MASK] = start + size; in vdev_rebuild_range()
624 zio_nowait(zio_read(spa->spa_txg_zio[txg & TXG_MASK], spa, &blk, in vdev_rebuild_range()
H A Dvdev_initialize.c76 uint64_t last_offset = vd->vdev_initialize_offset[txg & TXG_MASK]; in vdev_initialize_zap_update_sync()
77 vd->vdev_initialize_offset[txg & TXG_MASK] = 0; in vdev_initialize_zap_update_sync()
216 &vd->vdev_initialize_offset[zio->io_txg & TXG_MASK]; in vdev_initialize_cb()
259 if (vd->vdev_initialize_offset[txg & TXG_MASK] == 0) { in vdev_initialize_write()
284 vd->vdev_initialize_offset[txg & TXG_MASK] = start + size; in vdev_initialize_write()
285 zio_nowait(zio_write_phys(spa->spa_txg_zio[txg & TXG_MASK], vd, start, in vdev_initialize_write()
H A Ddmu_redact.c520 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()
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()
577 md->md_furthest[txg & TXG_MASK].rbp_object = object; in commit_rl_updates()
578 md->md_furthest[txg & TXG_MASK].rbp_blkid = blkid; in commit_rl_updates()
579 list_move_tail(&md->md_blocks[txg & TXG_MASK], in commit_rl_updates()
H A Dzil.c929 if (txg_list_member(&dp->dp_dirty_zilogs, zilog, txg & TXG_MASK)) in zilog_is_dirty_in_txg()
1219 os->os_next_write_raw[tx->tx_txg & TXG_MASK] = B_TRUE; in zil_claim()
1249 os->os_next_write_raw[tx->tx_txg & TXG_MASK] = B_TRUE; in zil_claim()
1532 ASSERT3U(zilog->zl_lwb_inflight[txg & TXG_MASK], >, 0); in zil_lwb_flush_vdevs_done()
1533 zilog->zl_lwb_inflight[txg & TXG_MASK]--; in zil_lwb_flush_vdevs_done()
1534 if (zilog->zl_lwb_inflight[txg & TXG_MASK] == 0) in zil_lwb_flush_vdevs_done()
1549 while (zilog->zl_lwb_inflight[txg & TXG_MASK] > 0) in zil_lwb_flush_wait_all()
2100 zilog->zl_lwb_inflight[txg & TXG_MASK]++; in zil_lwb_write_issue()
2687 itxg_t *itxg = &zilog->zl_itxg[txg & TXG_MASK]; in zil_remove_async()
2731 itxg = &zilog->zl_itxg[txg & TXG_MASK]; in zil_itx_assign()
[all …]
H A Dvdev_trim.c233 uint64_t last_offset = vd->vdev_trim_offset[txg & TXG_MASK]; in vdev_trim_zap_update_sync()
234 vd->vdev_trim_offset[txg & TXG_MASK] = 0; in vdev_trim_zap_update_sync()
402 &vd->vdev_trim_offset[zio->io_txg & TXG_MASK]; in vdev_trim_cb()
537 vd->vdev_trim_offset[txg & TXG_MASK] == 0) { in vdev_trim_range()
565 vd->vdev_trim_offset[txg & TXG_MASK] = start + size; in vdev_trim_range()
575 zio_nowait(zio_trim(spa->spa_txg_zio[txg & TXG_MASK], vd, in vdev_trim_range()
H A Ddsl_dir.c1170 ASSERT0(dd->dd_tempreserved[tx->tx_txg & TXG_MASK]); in dsl_dir_sync()
1172 (u_longlong_t)dd->dd_space_towrite[tx->tx_txg & TXG_MASK] / 1024); in dsl_dir_sync()
1173 dd->dd_space_towrite[tx->tx_txg & TXG_MASK] = 0; in dsl_dir_sync()
1188 space += dd->dd_space_towrite[i & TXG_MASK]; in dsl_dir_space_towrite()
1379 dd->dd_tempreserved[txg & TXG_MASK] += asize; in dsl_dir_tempreserve_impl()
1477 int txgidx = tx->tx_txg & TXG_MASK; in dsl_dir_tempreserve_clear()
1521 dd->dd_space_towrite[tx->tx_txg & TXG_MASK] += space; in dsl_dir_willuse_space()
H A Ddnode_sync.c46 int txgoff = tx->tx_txg & TXG_MASK; in dnode_increase_indirection()
579 int txgoff = tx->tx_txg & TXG_MASK; in dnode_sync_free()
646 int txgoff = tx->tx_txg & TXG_MASK; in dnode_sync()
H A Dmetaslab.c2179 TXG_MASK]); in metaslab_verify_space()
3961 zfs_range_tree_walk(msp->ms_allocating[(txg + t) & TXG_MASK], in metaslab_condense()
4257 zfs_range_tree_t *alloctree = msp->ms_allocating[txg & TXG_MASK]; in metaslab_sync()
4509 ASSERT0(zfs_range_tree_space(msp->ms_allocating[txg & TXG_MASK])); in metaslab_sync()
4511 & TXG_MASK])); in metaslab_sync()
4538 msp->ms_allocating[(txg + t) & TXG_MASK])); in metaslab_evict()
4673 ASSERT0(zfs_range_tree_space(msp->ms_allocating[txg & TXG_MASK])); in metaslab_sync_done()
4886 if (zfs_range_tree_is_empty(msp->ms_allocating[txg & TXG_MASK])) in metaslab_block_alloc()
4889 zfs_range_tree_add(msp->ms_allocating[txg & TXG_MASK], start, in metaslab_block_alloc()
5778 zfs_range_tree_remove(msp->ms_allocating[txg & TXG_MASK], in metaslab_unalloc_dva()
[all …]
H A Dbrt.c1201 avl_tree_t *pending_tree = &brtvd->bv_pending_tree[txg & TXG_MASK]; in brt_pending_add()
1242 avl_tree_t *pending_tree = &brtvd->bv_pending_tree[txg & TXG_MASK]; in brt_pending_remove()
1271 avl_swap(&brtvd->bv_tree, &brtvd->bv_pending_tree[txg & TXG_MASK]); in brt_pending_apply_vdev()
H A Ddsl_dataset.c1305 os->os_next_write_raw[tx->tx_txg & TXG_MASK] = B_TRUE; in dsl_dataset_zero_zil()
1487 !os->os_next_write_raw[tx->tx_txg & TXG_MASK]) { in dsl_dataset_dirty()
2126 if (ds->ds_resume_bytes[tx->tx_txg & TXG_MASK] != 0) { in dsl_dataset_sync()
2129 &ds->ds_resume_object[tx->tx_txg & TXG_MASK], tx)); in dsl_dataset_sync()
2132 &ds->ds_resume_offset[tx->tx_txg & TXG_MASK], tx)); in dsl_dataset_sync()
2135 &ds->ds_resume_bytes[tx->tx_txg & TXG_MASK], tx)); in dsl_dataset_sync()
2136 ds->ds_resume_object[tx->tx_txg & TXG_MASK] = 0; in dsl_dataset_sync()
2137 ds->ds_resume_offset[tx->tx_txg & TXG_MASK] = 0; in dsl_dataset_sync()
2138 ds->ds_resume_bytes[tx->tx_txg & TXG_MASK] = 0; in dsl_dataset_sync()
2307 os->os_next_write_raw[tx->tx_txg & TXG_MASK] = B_FALSE; in dsl_dataset_sync_done()
[all …]
H A Dvdev_indirect.c554 &sci->sci_new_mapping_entries[txg & TXG_MASK], tx); in spa_condense_indirect_commit_sync()
555 ASSERT(list_is_empty(&sci->sci_new_mapping_entries[txg & TXG_MASK])); in spa_condense_indirect_commit_sync()
573 int txgoff = dmu_tx_get_txg(tx) & TXG_MASK; in spa_condense_indirect_commit_entry()
H A Ddmu_objset.c1129 mdn->dn_next_nlevels[tx->tx_txg & TXG_MASK] = in dmu_objset_create_impl_dnstats()
1606 int txgoff = tx->tx_txg & TXG_MASK; in sync_meta_dnode_task()
1678 os->os_next_write_raw[tx->tx_txg & TXG_MASK]) { in dmu_objset_sync()
1712 txgoff = tx->tx_txg & TXG_MASK; in dmu_objset_sync()
1776 return (!multilist_is_empty(&os->os_dirty_dnodes[txg & TXG_MASK])); in dmu_objset_is_dirty()
H A Ddmu_object.c481 dn->dn_next_type[tx->tx_txg & TXG_MASK] = dn->dn_type = in dmu_object_zapify()
H A Dvdev_raidz.c4060 int txgoff = dmu_tx_get_txg(tx) & TXG_MASK; in raidz_reflow_sync()
4216 vre->vre_bytes_copied_pertxg[rra->rra_txg & TXG_MASK] += in raidz_reflow_write_done()
4278 int txgoff = dmu_tx_get_txg(tx) & TXG_MASK; in raidz_reflow_record_progress()
4403 int txgoff = dmu_tx_get_txg(tx) & TXG_MASK; in raidz_reflow_impl()
4725 int txgoff = dmu_tx_get_txg(tx) & TXG_MASK; in raidz_reflow_scratch_sync()
4819 int txgoff = dmu_tx_get_txg(tx) & TXG_MASK; in vdev_raidz_reflow_copy_scratch()
H A Ddbuf.c2203 int txgoff = tx->tx_txg & TXG_MASK; in dbuf_dirty_lightweight()
2253 int txgoff = tx->tx_txg & TXG_MASK; in dbuf_dirty()
2442 dn->dn_next_nlevels[(tx->tx_txg-1) & TXG_MASK] > db->db_level || in dbuf_dirty()
2443 dn->dn_next_nlevels[(tx->tx_txg-2) & TXG_MASK] > db->db_level); in dbuf_dirty()
2605 list_remove(&dn->dn_dirty_records[txg & TXG_MASK], dr); in dbuf_undirty()
4855 list_insert_tail(&dn->dn_dirty_records[txg & TXG_MASK], dr); in dbuf_sync_leaf()
H A Dspa_stats.c415 ts->ndirty = dp->dp_dirty_pertxg[txg & TXG_MASK]; in spa_txg_history_init_io()
H A Ddmu.c1058 dp->dp_long_free_dirty_pertxg[txg & TXG_MASK]; in dmu_free_long_range_impl()
1085 dp->dp_long_free_dirty_pertxg[txg & TXG_MASK] += in dmu_free_long_range_impl()
H A Dspa.c2197 uint64_t idx = txg & TXG_MASK; in spa_sync_time_logger()
10681 bplist_t *free_bpl = &spa->spa_free_bplist[txg & TXG_MASK];
10856 (void) zio_wait(spa->spa_txg_zio[txg & TXG_MASK]);
10857 spa->spa_txg_zio[txg & TXG_MASK] = zio_root(spa, NULL, NULL,
10963 ASSERT0(spa->spa_vdev_removal->svr_bytes_done[txg & TXG_MASK]);
H A Ddsl_crypt.c2127 os->os_next_write_raw[tx->tx_txg & TXG_MASK] = B_TRUE; in dsl_crypto_recv_raw_objset_sync()
/src/sys/contrib/openzfs/include/sys/
H A Dtxg.h43 #define TXG_MASK (TXG_SIZE - 1) /* mask for size */ macro
45 #define TXG_IDX (txg & TXG_MASK)
/src/sys/contrib/openzfs/cmd/
H A Dzhack.c653 if (zfs_range_tree_is_empty(msp->ms_allocating[txg & TXG_MASK])) in metaslab_force_alloc()
657 zfs_range_tree_add(msp->ms_allocating[txg & TXG_MASK], ostart, in metaslab_force_alloc()

12