Lines Matching defs:txg
66 * the transaction group number is less than the current, open txg.
95 #include <sys/txg.h>
515 * The callbacks are ordered by txg number.
577 * whether the minimum txg delay is acceptable.
1819 uint64_t txg;
1837 txg = dmu_tx_get_txg(tx);
1838 ASSERT3U(txg, !=, 0);
1839 return (txg);
1844 uint64_t dnodesize, uint64_t offset, uint64_t gen, uint64_t txg,
1853 bt->bt_txg = txg;
1859 uint64_t dnodesize, uint64_t offset, uint64_t gen, uint64_t txg,
1868 ASSERT3U(bt->bt_txg, <=, txg);
2055 uint64_t txg;
2075 txg = ztest_tx_assign(tx, TXG_WAIT, FTAG);
2076 if (txg == 0)
2121 lr->lr_gen, txg, txg);
2144 uint64_t object, txg;
2165 txg = ztest_tx_assign(tx, TXG_WAIT, FTAG);
2166 if (txg == 0) {
2198 uint64_t gen, txg, lrtxg, crtxg;
2247 txg = ztest_tx_assign(tx, TXG_WAIT, FTAG);
2248 if (txg == 0) {
2281 offset, gen, txg, crtxg);
2293 MAX(gen, bt->bt_gen), MAX(txg, lrtxg),
2298 * Set the bt's gen/txg to the bonus buffer's gen/txg
2301 ztest_bt_generate(bt, os, lr->lr_foid, 0, offset, gen, txg,
2331 uint64_t txg;
2345 txg = ztest_tx_assign(tx, TXG_WAIT, FTAG);
2346 if (txg == 0) {
2374 uint64_t txg, lrtxg, crtxg, dnodesize;
2386 txg = ztest_tx_assign(tx, TXG_WAIT, FTAG);
2387 if (txg == 0) {
2414 * Verify that the current bonus buffer is not newer than our txg.
2417 MAX(txg, lrtxg), crtxg);
2427 txg, crtxg);
2496 uint64_t txg = lr->lr_common.lrc_txg;
2515 if (crtxg == 0 || crtxg > txg) {
2792 uint64_t txg;
2804 txg = ztest_tx_assign(tx, TXG_WAIT, FTAG);
2806 if (txg != 0) {
2809 txg_wait_synced(dmu_objset_pool(os), txg);
4214 * must wait at least 1 txg to ensure that the removal
5058 uint64_t i, n, s, txg;
5172 txg = ztest_tx_assign(tx, TXG_MIGHTWAIT, FTAG);
5173 if (txg == 0) {
5211 if (pack->bw_txg > txg)
5213 "future leak: got %"PRIx64", open txg is %"PRIx64"",
5214 pack->bw_txg, txg);
5233 pack->bw_txg = txg;
5249 " txg %"PRIx64"\n",
5250 bigoff, bigsize, txg);
5256 " txg %"PRIx64"\n",
5257 bigoff, bigsize, txg);
5290 uint64_t bigsize, uint64_t n, uint64_t chunksize, uint64_t txg)
5314 if (pack->bw_txg > txg)
5316 "future leak: got %"PRIx64", open txg is %"PRIx64"",
5317 pack->bw_txg, txg);
5333 pack->bw_txg = txg;
5353 uint64_t n, s, txg;
5437 * Iteration 2 test zcopy to dirty dbuf in the same txg.
5438 * Iteration 3 test zcopy to dbuf dirty in previous txg.
5473 txg = ztest_tx_assign(tx, TXG_MIGHTWAIT, FTAG);
5474 if (txg == 0) {
5508 n, chunksize, txg);
5517 " txg %"PRIx64"\n",
5518 bigoff, bigsize, txg);
5669 uint64_t txg, last_txg;
5693 txg = ztest_tx_assign(tx, TXG_MIGHTWAIT, FTAG);
5694 if (txg == 0)
5754 * The first is named txg_%llu, and contains the txg
5757 * should be txg + object + n.
5761 txg = ztest_tx_assign(tx, TXG_MIGHTWAIT, FTAG);
5762 if (txg == 0)
5765 if (last_txg > txg)
5767 last_txg, txg);
5770 value[i] = txg + object + i;
5773 1, &txg, tx));
5795 txg = ztest_tx_assign(tx, TXG_MIGHTWAIT, FTAG);
5796 if (txg == 0)
5813 uint64_t object, txg, value;
5838 txg = ztest_tx_assign(tx, TXG_MIGHTWAIT, FTAG);
5839 if (txg == 0)
5856 uint64_t txg, object, count, wsize, wc, zl_wsize, zl_wc;
5888 wsize = sizeof (txg);
5890 data = &txg;
5909 txg = ztest_tx_assign(tx, TXG_MIGHTWAIT, FTAG);
5910 if (txg == 0) {
5917 txg = 0;
5992 "commit callback of txg %"PRIu64" called prematurely, "
5993 "last synced txg = %"PRIu64"\n",
6029 ztest_create_cb_data(objset_t *os, uint64_t txg)
6035 cb_data->zcd_txg = txg;
6052 uint64_t old_txg, txg;
6077 txg = error ? 0 : dmu_tx_get_txg(tx);
6079 cb_data[0]->zcd_txg = txg;
6080 cb_data[1] = ztest_create_cb_data(os, txg);
6106 cb_data[2] = ztest_create_cb_data(os, txg);
6115 if (old_txg > txg)
6117 "future leak: got %"PRIu64", open txg is %"PRIu64"",
6118 old_txg, txg);
6120 dmu_write(os, od->od_object, 0, sizeof (uint64_t), &txg, tx);
6127 * after an arbitrary amount of time has elapsed since its txg has been
6138 tmp_cb->zcd_txg + ZTEST_COMMIT_CB_THRESH < txg) {
6141 "oldest txg: %"PRIu64", open txg: %"PRIu64"\n",
6142 tmp_cb->zcd_txg, txg);
6148 * Even though the list is ordered by txg, it is possible for the
6149 * insertion point to not be the end because our txg may already be
6150 * quiescing at this point and other callbacks in the open txg
6154 while (tmp_cb != NULL && tmp_cb->zcd_txg > txg)
7955 * We do a txg_wait_synced() after each iteration to force the txg