Lines Matching refs:txg
462 zil_parse_lr_func_t *parse_lr_func, void *arg, uint64_t txg, in zil_parse() argument
502 error = parse_blk_func(zilog, &blk, arg, txg); in zil_parse()
556 error = parse_lr_func(zilog, lr, arg, txg); in zil_parse()
817 uint64_t txg, lwb_state_t state) in zil_alloc_lwb() argument
849 lwb->lwb_alloc_txg = txg; in zil_alloc_lwb()
892 zilog_dirty(zilog_t *zilog, uint64_t txg) in zilog_dirty() argument
902 if (txg_list_add(&dp->dp_dirty_zilogs, zilog, txg)) { in zilog_dirty()
906 zilog->zl_dirty_max_txg = MAX(txg, zilog->zl_dirty_max_txg); in zilog_dirty()
918 zilog_is_dirty_in_txg(zilog_t *zilog, uint64_t txg) in zilog_is_dirty_in_txg() argument
922 if (txg_list_member(&dp->dp_dirty_zilogs, zilog, txg & TXG_MASK)) in zilog_is_dirty_in_txg()
953 uint64_t txg = 0; in zil_commit_activate_saxattr_feature() local
962 txg = dmu_tx_get_txg(tx); in zil_commit_activate_saxattr_feature()
969 txg_wait_synced(zilog->zl_dmu_pool, txg); in zil_commit_activate_saxattr_feature()
981 uint64_t txg = 0; in zil_create() local
1008 txg = dmu_tx_get_txg(tx); in zil_create()
1011 zio_free(zilog->zl_spa, txg, &blk); in zil_create()
1015 error = zio_alloc_zil(zilog->zl_spa, zilog->zl_os, txg, &blk, in zil_create()
1025 lwb = zil_alloc_lwb(zilog, 0, &blk, slog, txg, LWB_STATE_NEW); in zil_create()
1049 txg_wait_synced(zilog->zl_dmu_pool, txg); in zil_create()
1083 uint64_t txg; in zil_destroy() local
1098 txg = dmu_tx_get_txg(tx); in zil_destroy()
1102 ASSERT3U(zilog->zl_destroy_txg, <, txg); in zil_destroy()
1103 zilog->zl_destroy_txg = txg; in zil_destroy()
1113 zio_free(zilog->zl_spa, txg, &lwb->lwb_blk); in zil_destroy()
1435 zil_lwb_add_txg(lwb_t *lwb, uint64_t txg) in zil_lwb_add_txg() argument
1437 lwb->lwb_max_txg = MAX(lwb->lwb_max_txg, txg); in zil_lwb_add_txg()
1516 uint64_t txg = lwb->lwb_issued_txg; in zil_lwb_flush_vdevs_done() local
1522 ASSERT3U(zilog->zl_lwb_inflight[txg & TXG_MASK], >, 0); in zil_lwb_flush_vdevs_done()
1523 zilog->zl_lwb_inflight[txg & TXG_MASK]--; in zil_lwb_flush_vdevs_done()
1524 if (zilog->zl_lwb_inflight[txg & TXG_MASK] == 0) in zil_lwb_flush_vdevs_done()
1534 zil_lwb_flush_wait_all(zilog_t *zilog, uint64_t txg) in zil_lwb_flush_wait_all() argument
1536 ASSERT3U(txg, ==, spa_syncing_txg(zilog->zl_spa)); in zil_lwb_flush_wait_all()
1539 while (zilog->zl_lwb_inflight[txg & TXG_MASK] > 0) in zil_lwb_flush_wait_all()
1548 if (lwb->lwb_issued_txg <= txg) { in zil_lwb_flush_wait_all()
1982 uint64_t txg = dmu_tx_get_txg(tx); in zil_lwb_write_issue() local
1992 error = zio_alloc_zil(spa, zilog->zl_os, txg, bp, nlwb->lwb_sz, in zil_lwb_write_issue()
1996 ASSERT3U(BP_GET_LOGICAL_BIRTH(bp), ==, txg); in zil_lwb_write_issue()
2008 lwb->lwb_issued_txg = txg; in zil_lwb_write_issue()
2009 zilog->zl_lwb_inflight[txg & TXG_MASK]++; in zil_lwb_write_issue()
2010 zilog->zl_lwb_max_issued_txg = MAX(txg, zilog->zl_lwb_max_issued_txg); in zil_lwb_write_issue()
2028 nlwb->lwb_alloc_txg = txg; in zil_lwb_write_issue()
2501 uint64_t otxg, txg; in zil_remove_async() local
2516 for (txg = otxg; txg < (otxg + TXG_CONCURRENT_STATES); txg++) { in zil_remove_async()
2517 itxg_t *itxg = &zilog->zl_itxg[txg & TXG_MASK]; in zil_remove_async()
2520 if (itxg->itxg_txg != txg) { in zil_remove_async()
2546 uint64_t txg; in zil_itx_assign() local
2557 txg = ZILTEST_TXG; in zil_itx_assign()
2559 txg = dmu_tx_get_txg(tx); in zil_itx_assign()
2561 itxg = &zilog->zl_itxg[txg & TXG_MASK]; in zil_itx_assign()
2564 if (itxg->itxg_txg != txg) { in zil_itx_assign()
2575 itxg->itxg_txg = txg; in zil_itx_assign()
2669 uint64_t otxg, txg, wtxg = 0; in zil_get_commit_list() local
2684 for (txg = otxg; txg < (otxg + TXG_CONCURRENT_STATES); txg++) { in zil_get_commit_list()
2685 itxg_t *itxg = &zilog->zl_itxg[txg & TXG_MASK]; in zil_get_commit_list()
2688 if (itxg->itxg_txg != txg) { in zil_get_commit_list()
2701 ASSERT(zilog_is_dirty_in_txg(zilog, txg) || in zil_get_commit_list()
2712 wtxg = MAX(wtxg, txg); in zil_get_commit_list()
2738 uint64_t otxg, txg; in zil_async_to_sync() local
2752 for (txg = otxg; txg < (otxg + TXG_CONCURRENT_STATES); txg++) { in zil_async_to_sync()
2753 itxg_t *itxg = &zilog->zl_itxg[txg & TXG_MASK]; in zil_async_to_sync()
2756 if (itxg->itxg_txg != txg) { in zil_async_to_sync()
2943 uint64_t txg = lrc->lrc_txg; in zil_process_commit_list() local
2945 ASSERT3U(txg, !=, 0); in zil_process_commit_list()
2955 boolean_t synced = txg <= spa_last_synced_txg(spa); in zil_process_commit_list()
2956 boolean_t frozen = txg > spa_freeze_txg(spa); in zil_process_commit_list()
3702 uint64_t txg = dmu_tx_get_txg(tx); in zil_sync() local
3704 uint64_t *replayed_seq = &zilog->zl_replayed_seq[txg & TXG_MASK]; in zil_sync()
3714 zil_lwb_flush_wait_all(zilog, txg); in zil_sync()
3726 if (zilog->zl_destroy_txg == txg) { in zil_sync()
3763 lwb->lwb_alloc_txg > txg || lwb->lwb_max_txg > txg) in zil_sync()
3767 zio_free(spa, txg, &lwb->lwb_blk); in zil_sync()
3967 uint64_t txg; in zil_close() local
3978 txg = zilog->zl_dirty_max_txg; in zil_close()
3981 txg = MAX(txg, lwb->lwb_alloc_txg); in zil_close()
3982 txg = MAX(txg, lwb->lwb_max_txg); in zil_close()
3992 txg = MAX(zilog->zl_lwb_max_issued_txg, txg); in zil_close()
4000 if (txg != 0) in zil_close()
4001 txg_wait_synced(zilog->zl_dmu_pool, txg); in zil_close()
4005 (u_longlong_t)txg); in zil_close()
4006 if (txg < spa_freeze_txg(zilog->zl_spa)) in zil_close()