Lines Matching defs:txg
64 * the transaction group number is less than the current, open txg.
90 #include <sys/txg.h>
388 * The callbacks are ordered by txg number.
1218 uint64_t txg;
1236 txg = dmu_tx_get_txg(tx);
1237 ASSERT(txg != 0);
1238 return (txg);
1266 uint64_t offset, uint64_t gen, uint64_t txg, uint64_t crtxg)
1273 bt->bt_txg = txg;
1279 uint64_t offset, uint64_t gen, uint64_t txg, uint64_t crtxg)
1286 ASSERT3U(bt->bt_txg, <=, txg);
1425 uint64_t txg;
1444 txg = ztest_tx_assign(tx, TXG_WAIT, FTAG);
1445 if (txg == 0)
1488 ztest_bt_generate(bbt, os, lr->lr_foid, -1ULL, lr->lr_gen, txg, txg);
1508 uint64_t object, txg;
1529 txg = ztest_tx_assign(tx, TXG_WAIT, FTAG);
1530 if (txg == 0) {
1560 uint64_t gen, txg, lrtxg, crtxg;
1609 txg = ztest_tx_assign(tx, TXG_WAIT, FTAG);
1610 if (txg == 0) {
1635 offset, gen, txg, crtxg);
1647 MAX(gen, bt->bt_gen), MAX(txg, lrtxg),
1652 * Set the bt's gen/txg to the bonus buffer's gen/txg
1655 ztest_bt_generate(bt, os, lr->lr_foid, offset, gen, txg, crtxg);
1682 uint64_t txg;
1696 txg = ztest_tx_assign(tx, TXG_WAIT, FTAG);
1697 if (txg == 0) {
1723 uint64_t txg, lrtxg, crtxg;
1735 txg = ztest_tx_assign(tx, TXG_WAIT, FTAG);
1736 if (txg == 0) {
1762 * Verify that the current bonus buffer is not newer than our txg.
1765 MAX(txg, lrtxg), crtxg);
1774 ztest_bt_generate(bbt, os, lr->lr_foid, -1ULL, lr->lr_mode, txg, crtxg);
1841 uint64_t txg = lr->lr_common.lrc_txg;
1857 if (crtxg == 0 || crtxg > txg) {
2134 uint64_t txg;
2146 txg = ztest_tx_assign(tx, TXG_WAIT, FTAG);
2148 if (txg != 0) {
2151 txg_wait_synced(dmu_objset_pool(os), txg);
3546 uint64_t n, s, txg;
3650 txg = ztest_tx_assign(tx, TXG_MIGHTWAIT, FTAG);
3651 if (txg == 0) {
3688 if (pack->bw_txg > txg)
3689 fatal(0, "future leak: got %llx, open txg is %llx",
3690 pack->bw_txg, txg);
3706 pack->bw_txg = txg;
3722 " txg %llx\n",
3725 (u_longlong_t)txg);
3731 " txg %llx\n",
3734 (u_longlong_t)txg);
3766 uint64_t bigsize, uint64_t n, uint64_t chunksize, uint64_t txg)
3790 if (pack->bw_txg > txg)
3791 fatal(0, "future leak: got %llx, open txg is %llx",
3792 pack->bw_txg, txg);
3805 pack->bw_txg = txg;
3821 uint64_t n, s, txg;
3891 * Iteration 2 test zcopy to dirty dbuf in the same txg.
3892 * Iteration 3 test zcopy to dbuf dirty in previous txg.
3927 txg = ztest_tx_assign(tx, TXG_MIGHTWAIT, FTAG);
3928 if (txg == 0) {
3961 n, chunksize, txg);
3970 " txg %llx\n",
3973 (u_longlong_t)txg);
4110 uint64_t txg, last_txg;
4132 txg = ztest_tx_assign(tx, TXG_MIGHTWAIT, FTAG);
4133 if (txg == 0)
4193 * The first is named txg_%llu, and contains the txg
4196 * should be txg + object + n.
4200 txg = ztest_tx_assign(tx, TXG_MIGHTWAIT, FTAG);
4201 if (txg == 0)
4204 if (last_txg > txg)
4205 fatal(0, "zap future leak: old %llu new %llu", last_txg, txg);
4208 value[i] = txg + object + i;
4211 1, &txg, tx));
4233 txg = ztest_tx_assign(tx, TXG_MIGHTWAIT, FTAG);
4234 if (txg == 0)
4249 uint64_t object, txg;
4274 txg = ztest_tx_assign(tx, TXG_MIGHTWAIT, FTAG);
4275 if (txg == 0)
4290 uint64_t txg, object, count, wsize, wc, zl_wsize, zl_wc;
4319 wsize = sizeof (txg);
4321 data = &txg;
4340 txg = ztest_tx_assign(tx, TXG_MIGHTWAIT, FTAG);
4341 if (txg == 0)
4346 txg = 0;
4418 fatal(0, "commit callback of txg %" PRIu64 " called prematurely"
4419 ", last synced txg = %" PRIu64 "\n", data->zcd_txg,
4453 ztest_create_cb_data(objset_t *os, uint64_t txg)
4459 cb_data->zcd_txg = txg;
4482 uint64_t old_txg, txg;
4504 txg = error ? 0 : dmu_tx_get_txg(tx);
4506 cb_data[0]->zcd_txg = txg;
4507 cb_data[1] = ztest_create_cb_data(os, txg);
4532 cb_data[2] = ztest_create_cb_data(os, txg);
4541 if (old_txg > txg)
4542 fatal(0, "future leak: got %" PRIu64 ", open txg is %" PRIu64,
4543 old_txg, txg);
4545 dmu_write(os, od[0].od_object, 0, sizeof (uint64_t), &txg, tx);
4552 * after an arbitrary amount of time has elapsed since its txg has been
4563 (txg - ZTEST_COMMIT_CALLBACK_THRESH) > tmp_cb->zcd_txg) {
4564 fatal(0, "Commit callback threshold exceeded, oldest txg: %"
4565 PRIu64 ", open txg: %" PRIu64 "\n", tmp_cb->zcd_txg, txg);
4571 * Even though the list is ordered by txg, it is possible for the
4572 * insertion point to not be the end because our txg may already be
4573 * quiescing at this point and other callbacks in the open txg
4577 while (tmp_cb != NULL && tmp_cb->zcd_txg > txg)
5021 uint64_t object, blocksize, txg, pattern, psize;
5059 txg = ztest_tx_assign(tx, TXG_WAIT, FTAG);
5060 if (txg == 0) {
5086 txg_wait_synced(spa_get_dsl(spa), txg);
5828 * We do a txg_wait_synced() after each iteration to force the txg