Lines Matching refs:txg
67 * the transaction group number is less than the current, open txg.
93 #include <sys/txg.h>
429 * The callbacks are ordered by txg number.
1357 uint64_t txg;
1375 txg = dmu_tx_get_txg(tx);
1376 ASSERT(txg != 0);
1377 return (txg);
1405 uint64_t dnodesize, uint64_t offset, uint64_t gen, uint64_t txg,
1414 bt->bt_txg = txg;
1420 uint64_t dnodesize, uint64_t offset, uint64_t gen, uint64_t txg,
1429 ASSERT3U(bt->bt_txg, <=, txg);
1615 uint64_t txg;
1635 txg = ztest_tx_assign(tx, TXG_WAIT, FTAG);
1636 if (txg == 0)
1681 lr->lr_gen, txg, txg);
1704 uint64_t object, txg;
1725 txg = ztest_tx_assign(tx, TXG_WAIT, FTAG);
1726 if (txg == 0) {
1758 uint64_t gen, txg, lrtxg, crtxg;
1807 txg = ztest_tx_assign(tx, TXG_WAIT, FTAG);
1808 if (txg == 0) {
1833 offset, gen, txg, crtxg);
1845 MAX(gen, bt->bt_gen), MAX(txg, lrtxg),
1850 * Set the bt's gen/txg to the bonus buffer's gen/txg
1853 ztest_bt_generate(bt, os, lr->lr_foid, 0, offset, gen, txg,
1883 uint64_t txg;
1897 txg = ztest_tx_assign(tx, TXG_WAIT, FTAG);
1898 if (txg == 0) {
1926 uint64_t txg, lrtxg, crtxg, dnodesize;
1938 txg = ztest_tx_assign(tx, TXG_WAIT, FTAG);
1939 if (txg == 0) {
1966 * Verify that the current bonus buffer is not newer than our txg.
1969 MAX(txg, lrtxg), crtxg);
1979 txg, crtxg);
2045 uint64_t txg = lr->lr_common.lrc_txg;
2065 if (crtxg == 0 || crtxg > txg) {
2338 uint64_t txg;
2350 txg = ztest_tx_assign(tx, TXG_WAIT, FTAG);
2352 if (txg != 0) {
2355 txg_wait_synced(dmu_objset_pool(os), txg);
4103 uint64_t n, s, txg;
4209 txg = ztest_tx_assign(tx, TXG_MIGHTWAIT, FTAG);
4210 if (txg == 0) {
4247 if (pack->bw_txg > txg)
4248 fatal(0, "future leak: got %llx, open txg is %llx",
4249 pack->bw_txg, txg);
4265 pack->bw_txg = txg;
4281 " txg %llx\n",
4284 (u_longlong_t)txg);
4290 " txg %llx\n",
4293 (u_longlong_t)txg);
4325 uint64_t bigsize, uint64_t n, uint64_t chunksize, uint64_t txg)
4349 if (pack->bw_txg > txg)
4350 fatal(0, "future leak: got %llx, open txg is %llx",
4351 pack->bw_txg, txg);
4364 pack->bw_txg = txg;
4380 uint64_t n, s, txg;
4452 * Iteration 2 test zcopy to dirty dbuf in the same txg.
4453 * Iteration 3 test zcopy to dbuf dirty in previous txg.
4488 txg = ztest_tx_assign(tx, TXG_MIGHTWAIT, FTAG);
4489 if (txg == 0) {
4521 n, chunksize, txg);
4530 " txg %llx\n",
4533 (u_longlong_t)txg);
4672 uint64_t txg, last_txg;
4694 txg = ztest_tx_assign(tx, TXG_MIGHTWAIT, FTAG);
4695 if (txg == 0)
4755 * The first is named txg_%llu, and contains the txg
4758 * should be txg + object + n.
4762 txg = ztest_tx_assign(tx, TXG_MIGHTWAIT, FTAG);
4763 if (txg == 0)
4766 if (last_txg > txg)
4767 fatal(0, "zap future leak: old %llu new %llu", last_txg, txg);
4770 value[i] = txg + object + i;
4773 1, &txg, tx));
4795 txg = ztest_tx_assign(tx, TXG_MIGHTWAIT, FTAG);
4796 if (txg == 0)
4811 uint64_t object, txg;
4836 txg = ztest_tx_assign(tx, TXG_MIGHTWAIT, FTAG);
4837 if (txg == 0)
4852 uint64_t txg, object, count, wsize, wc, zl_wsize, zl_wc;
4882 wsize = sizeof (txg);
4884 data = &txg;
4903 txg = ztest_tx_assign(tx, TXG_MIGHTWAIT, FTAG);
4904 if (txg == 0)
4909 txg = 0;
4981 fatal(0, "commit callback of txg %" PRIu64 " called prematurely"
4982 ", last synced txg = %" PRIu64 "\n", data->zcd_txg,
5016 ztest_create_cb_data(objset_t *os, uint64_t txg)
5022 cb_data->zcd_txg = txg;
5045 uint64_t old_txg, txg;
5067 txg = error ? 0 : dmu_tx_get_txg(tx);
5069 cb_data[0]->zcd_txg = txg;
5070 cb_data[1] = ztest_create_cb_data(os, txg);
5095 cb_data[2] = ztest_create_cb_data(os, txg);
5104 if (old_txg > txg)
5105 fatal(0, "future leak: got %" PRIu64 ", open txg is %" PRIu64,
5106 old_txg, txg);
5108 dmu_write(os, od[0].od_object, 0, sizeof (uint64_t), &txg, tx);
5115 * after an arbitrary amount of time has elapsed since its txg has been
5126 (txg - ZTEST_COMMIT_CALLBACK_THRESH) > tmp_cb->zcd_txg) {
5127 fatal(0, "Commit callback threshold exceeded, oldest txg: %"
5128 PRIu64 ", open txg: %" PRIu64 "\n", tmp_cb->zcd_txg, txg);
5134 * Even though the list is ordered by txg, it is possible for the
5135 * insertion point to not be the end because our txg may already be
5136 * quiescing at this point and other callbacks in the open txg
5140 while (tmp_cb != NULL && tmp_cb->zcd_txg > txg)
5670 uint64_t object, blocksize, txg, pattern, psize;
5714 txg = ztest_tx_assign(tx, TXG_WAIT, FTAG);
5715 if (txg == 0) {
5741 txg_wait_synced(spa_get_dsl(spa), txg);
6548 * We do a txg_wait_synced() after each iteration to force the txg