fs/zfs/dmu_send.c

9  * or http://www.opensolaris.org/os/licensing.
470 	objset_t *os;
476 	err = dmu_objset_from_ds(ds, &os);
489 	if (dmu_objset_type(os) == DMU_OST_ZFS) {
491 		if (zfs_get_zplprop(os, ZFS_PROP_VERSION, &version) != 0) {
506 	drr->drr_u.drr_begin.drr_type = dmu_objset_type(os);
530 	dsp->dsa_os = os;
1279 restore_object(struct restorearg *ra, objset_t *os, struct drr_object *drro)
1297 	err = dmu_object_info(os, drro->drr_object, NULL);
1310 		tx = dmu_tx_create(os);
1317 		err = dmu_object_claim(os, drro->drr_object,
1323 		err = dmu_object_reclaim(os, drro->drr_object,
1331 	tx = dmu_tx_create(os);
1339 	dmu_object_set_checksum(os, drro->drr_object, drro->drr_checksumtype,
1341 	dmu_object_set_compress(os, drro->drr_object, drro->drr_compress, tx);
1346 		VERIFY(0 == dmu_bonus_hold(os, drro->drr_object, FTAG, &db));
1365 restore_freeobjects(struct restorearg *ra, objset_t *os,
1375 	    (void) dmu_object_next(os, &obj, FALSE, 0)) {
1378 		if (dmu_object_info(os, obj, NULL) != 0)
1381 		err = dmu_free_long_object(os, obj);
1389 restore_write(struct restorearg *ra, objset_t *os,
1404 	if (dmu_object_info(os, drrw->drr_object, NULL) != 0)
1407 	tx = dmu_tx_create(os);
1421 	dmu_write(os, drrw->drr_object,
1435 restore_write_byref(struct restorearg *ra, objset_t *os,
1462 		ref_os = os;
1469 	tx = dmu_tx_create(os);
1478 	dmu_write(os, drrwbr->drr_object,
1486 restore_spill(struct restorearg *ra, objset_t *os, struct drr_spill *drrs)
1501 	if (dmu_object_info(os, drrs->drr_object, NULL) != 0)
1504 	VERIFY(0 == dmu_bonus_hold(os, drrs->drr_object, FTAG, &db));
1510 	tx = dmu_tx_create(os);
1537 restore_free(struct restorearg *ra, objset_t *os,
1546 	if (dmu_object_info(os, drrf->drr_object, NULL) != 0)
1549 	err = dmu_free_long_range(os, drrf->drr_object,
1573 	objset_t *os;
1593 	VERIFY0(dmu_objset_from_ds(drc->drc_ds, &os));
1657 			ra.err = restore_object(&ra, os, &drro);
1664 			ra.err = restore_freeobjects(&ra, os, &drrfo);
1670 			ra.err = restore_write(&ra, os, &drrw);
1677 			ra.err = restore_write_byref(&ra, os, &drrwbr);
1683 			ra.err = restore_free(&ra, os, &drrf);
1701 			ra.err = restore_spill(&ra, os, &drrs);
1959 dmu_objset_is_receiving(objset_t *os)
1961 	return (os->os_dsl_dataset != NULL &&
1962 	    os->os_dsl_dataset->ds_owner == dmu_recv_tag);