Lines Matching refs:tx
1333 dmu_recv_begin_check(void *arg, dmu_tx_t *tx)
1336 dsl_pool_t *dp = dmu_tx_pool(tx);
1473 dmu_recv_begin_sync(void *arg, dmu_tx_t *tx)
1476 dsl_pool_t *dp = dmu_tx_pool(tx);
1497 snap, crflags, drba->drba_cred, tx);
1516 origin, crflags, drba->drba_cred, tx);
1525 dsl_dataset_zapify(newds, tx);
1528 8, 1, &drrb->drr_fromguid, tx));
1531 8, 1, &drrb->drr_toguid, tx));
1533 1, strlen(drrb->drr_toname) + 1, drrb->drr_toname, tx));
1537 8, 1, &one, tx));
1539 8, 1, &zero, tx));
1541 8, 1, &zero, tx));
1545 8, 1, &one, tx));
1550 8, 1, &one, tx));
1555 8, 1, &one, tx));
1559 dmu_buf_will_dirty(newds->ds_dbuf, tx);
1569 newds, dsl_dataset_get_blkptr(newds), drrb->drr_type, tx);
1575 spa_history_log_internal_ds(newds, "receive", tx, "");
1579 dmu_recv_resume_begin_check(void *arg, dmu_tx_t *tx)
1582 dsl_pool_t *dp = dmu_tx_pool(tx);
1683 dmu_recv_resume_begin_sync(void *arg, dmu_tx_t *tx)
1686 dsl_pool_t *dp = dmu_tx_pool(tx);
1704 dmu_buf_will_dirty(ds->ds_dbuf, tx);
1711 dmu_buf_will_dirty(ds->ds_dbuf, tx);
1720 spa_history_log_internal_ds(ds, "resume receive", tx, "");
2011 uint64_t object, uint64_t offset, dmu_tx_t *tx)
2013 int txgoff = dmu_tx_get_txg(tx) & TXG_MASK;
2051 dmu_tx_t *tx;
2093 tx = dmu_tx_create(rwa->os);
2094 dmu_tx_hold_bonus(tx, object);
2095 err = dmu_tx_assign(tx, TXG_WAIT);
2097 dmu_tx_abort(tx);
2105 drro->drr_bonustype, drro->drr_bonuslen, tx);
2113 drro->drr_bonustype, drro->drr_bonuslen, tx);
2116 dmu_tx_commit(tx);
2121 drro->drr_checksumtype, tx);
2123 drro->drr_compress, tx);
2129 dmu_buf_will_dirty(db, tx);
2141 dmu_tx_commit(tx);
2178 dmu_tx_t *tx;
2200 tx = dmu_tx_create(rwa->os);
2202 dmu_tx_hold_write(tx, drrw->drr_object,
2204 err = dmu_tx_assign(tx, TXG_WAIT);
2206 dmu_tx_abort(tx);
2220 dmu_assign_arcbuf(bonus, drrw->drr_offset, abuf, tx);
2228 save_resume_state(rwa, drrw->drr_object, drrw->drr_offset, tx);
2229 dmu_tx_commit(tx);
2246 dmu_tx_t *tx;
2278 tx = dmu_tx_create(rwa->os);
2280 dmu_tx_hold_write(tx, drrwbr->drr_object,
2282 err = dmu_tx_assign(tx, TXG_WAIT);
2284 dmu_tx_abort(tx);
2288 drrwbr->drr_offset, drrwbr->drr_length, dbp->db_data, tx);
2292 save_resume_state(rwa, drrwbr->drr_object, drrwbr->drr_offset, tx);
2293 dmu_tx_commit(tx);
2301 dmu_tx_t *tx;
2315 tx = dmu_tx_create(rwa->os);
2317 dmu_tx_hold_write(tx, drrwe->drr_object,
2319 err = dmu_tx_assign(tx, TXG_WAIT);
2321 dmu_tx_abort(tx);
2328 rwa->byteswap ^ ZFS_HOST_BYTEORDER, tx);
2331 save_resume_state(rwa, drrwe->drr_object, drrwe->drr_offset, tx);
2332 dmu_tx_commit(tx);
2340 dmu_tx_t *tx;
2357 tx = dmu_tx_create(rwa->os);
2359 dmu_tx_hold_spill(tx, db->db_object);
2361 err = dmu_tx_assign(tx, TXG_WAIT);
2365 dmu_tx_abort(tx);
2368 dmu_buf_will_dirty(db_spill, tx);
2372 drrs->drr_length, tx));
2378 dmu_tx_commit(tx);
3038 dmu_recv_end_check(void *arg, dmu_tx_t *tx)
3041 dsl_pool_t *dp = dmu_tx_pool(tx);
3086 origin_head, drc->drc_force, drc->drc_owner, tx);
3092 drc->drc_tosnap, tx, B_TRUE, 1, drc->drc_cred);
3100 drc->drc_tosnap, tx, B_TRUE, 1, drc->drc_cred);
3106 dmu_recv_end_sync(void *arg, dmu_tx_t *tx)
3109 dsl_pool_t *dp = dmu_tx_pool(tx);
3112 tx, "snap=%s", drc->drc_tosnap);
3136 B_FALSE, tx);
3144 origin_head, tx);
3146 drc->drc_tosnap, tx);
3149 dmu_buf_will_dirty(origin_head->ds_prev->ds_dbuf, tx);
3157 dmu_buf_will_dirty(origin_head->ds_dbuf, tx);
3165 dsl_destroy_head_sync_impl(drc->drc_ds, tx);
3172 dsl_dataset_snapshot_sync_impl(ds, drc->drc_tosnap, tx);
3175 dmu_buf_will_dirty(ds->ds_prev->ds_dbuf, tx);
3183 dmu_buf_will_dirty(ds->ds_dbuf, tx);
3187 DS_FIELD_RESUME_FROMGUID, tx);
3189 DS_FIELD_RESUME_OBJECT, tx);
3191 DS_FIELD_RESUME_OFFSET, tx);
3193 DS_FIELD_RESUME_BYTES, tx);
3195 DS_FIELD_RESUME_TOGUID, tx);
3197 DS_FIELD_RESUME_TONAME, tx);