libzfs/common/libzfs_sendrecv.c

197 dump_record(dmu_replay_record_t *drr, void *payload, int payload_len,
202 	fletcher_4_incremental_native(drr,
204 	if (drr->drr_type != DRR_BEGIN) {
205 		ASSERT(ZIO_CHECKSUM_IS_ZERO(&drr->drr_u.
207 		drr->drr_u.drr_checksum.drr_checksum = *zc;
209 	fletcher_4_incremental_native(&drr->drr_u.drr_checksum.drr_checksum,
211 	if (write(outfd, drr, sizeof (*drr)) == -1)
244 	dmu_replay_record_t *drr = &thedrr;
274 	while (ssread(drr, sizeof (*drr), ofp) != 0) {
276 		switch (drr->drr_type) {
279 			struct drr_begin *drrb = &drr->drr_u.drr_begin;
292 			if (drr->drr_payloadlen != 0) {
293 				sz = drr->drr_payloadlen;
303 			if (dump_record(drr, buf, sz, &stream_cksum,
311 			struct drr_end *drre = &drr->drr_u.drr_end;
314 			if (dump_record(drr, NULL, 0, &stream_cksum,
322 			struct drr_object *drro = &drr->drr_u.drr_object;
328 			if (dump_record(drr, buf,
337 			struct drr_spill *drrs = &drr->drr_u.drr_spill;
339 			if (dump_record(drr, buf, drrs->drr_length,
347 			if (dump_record(drr, NULL, 0, &stream_cksum,
355 			struct drr_write *drrw = &drr->drr_u.drr_write;
424 				if (dump_record(drr, buf, drrw->drr_length,
434 			    &drr->drr_u.drr_write_embedded;
437 			if (dump_record(drr, buf,
446 			if (dump_record(drr, NULL, 0, &stream_cksum,
454 			    drr->drr_type);
1683 		dmu_replay_record_t drr = { 0 };
1719 			drr.drr_type = DRR_BEGIN;
1720 			drr.drr_u.drr_begin.drr_magic = DMU_BACKUP_MAGIC;
1721 			DMU_SET_STREAM_HDRTYPE(drr.drr_u.drr_begin.
1723 			DMU_SET_FEATUREFLAGS(drr.drr_u.drr_begin.
1725 			(void) snprintf(drr.drr_u.drr_begin.drr_toname,
1726 			    sizeof (drr.drr_u.drr_begin.drr_toname),
1728 			drr.drr_payloadlen = buflen;
1730 			err = dump_record(&drr, packbuf, buflen, &zc, outfd);
1736 			bzero(&drr, sizeof (drr));
1737 			drr.drr_type = DRR_END;
1738 			drr.drr_u.drr_end.drr_checksum = zc;
1739 			err = write(outfd, &drr, sizeof (drr));
1873 		dmu_replay_record_t drr = { 0 };
1874 		drr.drr_type = DRR_END;
1875 		if (write(outfd, &drr, sizeof (drr)) == -1) {
2601     recvflags_t *flags, dmu_replay_record_t *drr, zio_cksum_t *zc,
2621 	assert(drr->drr_type == DRR_BEGIN);
2622 	assert(drr->drr_u.drr_begin.drr_magic == DMU_BACKUP_MAGIC);
2623 	assert(DMU_GET_STREAM_HDRTYPE(drr->drr_u.drr_begin.drr_versioninfo) ==
2629 	if (drr->drr_payloadlen != 0) {
2630 		error = recv_read_nvlist(hdl, fd, drr->drr_payloadlen,
2678 	if (drr->drr_payloadlen != 0) {
2696 				struct drr_begin *drrb = &drr->drr_u.drr_begin;
2754 	(void) strlcpy(sendfs, drr->drr_u.drr_begin.drr_toname,
2786 	if (drr->drr_payloadlen != 0 && fromsnap != NULL) {
2821 	dmu_replay_record_t *drr;
2829 	drr = buf;
2831 	while (recv_read(hdl, fd, drr, sizeof (dmu_replay_record_t),
2834 			drr->drr_type = BSWAP_32(drr->drr_type);
2836 		switch (drr->drr_type) {
2838 			if (drr->drr_payloadlen != 0) {
2840 				    drr->drr_payloadlen, B_FALSE, NULL);
2850 				drr->drr_u.drr_object.drr_bonuslen =
2851 				    BSWAP_32(drr->drr_u.drr_object.
2855 			    P2ROUNDUP(drr->drr_u.drr_object.drr_bonuslen, 8),
2861 				drr->drr_u.drr_write.drr_length =
2862 				    BSWAP_64(drr->drr_u.drr_write.drr_length);
2865 			    drr->drr_u.drr_write.drr_length, B_FALSE, NULL);
2869 				drr->drr_u.drr_write.drr_length =
2870 				    BSWAP_64(drr->drr_u.drr_spill.drr_length);
2873 			    drr->drr_u.drr_spill.drr_length, B_FALSE, NULL);
2877 				drr->drr_u.drr_write_embedded.drr_psize =
2878 				    BSWAP_32(drr->drr_u.drr_write_embedded.
2882 			    P2ROUNDUP(drr->drr_u.drr_write_embedded.drr_psize,
2940     const char *originsnap, recvflags_t *flags, dmu_replay_record_t *drr,
2949 	struct drr_begin *drrb = &drr->drr_u.drr_begin;
3529 	dmu_replay_record_t drr, drr_noswap;
3530 	struct drr_begin *drrb = &drr.drr_u.drr_begin;
3553 	if (0 != (err = recv_read(hdl, infd, &drr, sizeof (drr), B_FALSE,
3557 	if (drr.drr_type == DRR_END || drr.drr_type == BSWAP_32(DRR_END)) {
3563 	drr_noswap = drr;
3572 		fletcher_4_incremental_byteswap(&drr, sizeof (drr), &zcksum);
3575 		drr.drr_type = BSWAP_32(drr.drr_type);
3576 		drr.drr_payloadlen = BSWAP_32(drr.drr_payloadlen);
3586 	if (drrb->drr_magic != DMU_BACKUP_MAGIC || drr.drr_type != DRR_BEGIN) {
3618 			    drr.drr_u.drr_begin.drr_toname, ZFS_MAXNAMELEN);
3625 		    &drr, &drr_noswap, sendfs, stream_nv, stream_avl, top_zfs,
3630 		return (zfs_receive_package(hdl, infd, tosnap, flags, &drr,