Lines Matching refs:drr

186 dump_record(dmu_replay_record_t *drr, void *payload, int payload_len,  in dump_record()  argument
191 fletcher_4_incremental_native(drr, in dump_record()
193 if (drr->drr_type != DRR_BEGIN) { in dump_record()
194 ASSERT(ZIO_CHECKSUM_IS_ZERO(&drr->drr_u. in dump_record()
196 drr->drr_u.drr_checksum.drr_checksum = *zc; in dump_record()
198 fletcher_4_incremental_native(&drr->drr_u.drr_checksum.drr_checksum, in dump_record()
200 if (write(outfd, drr, sizeof (*drr)) == -1) in dump_record()
214 dmu_replay_record_t drr = { 0 }; in zfs_send_compoundstream_begin() local
226 drr.drr_type = DRR_BEGIN; in zfs_send_compoundstream_begin()
227 drr.drr_u.drr_begin.drr_magic = DMU_BACKUP_MAGIC; in zfs_send_compoundstream_begin()
228 DMU_SET_STREAM_HDRTYPE(drr.drr_u.drr_begin.drr_versioninfo, in zfs_send_compoundstream_begin()
230 DMU_SET_FEATUREFLAGS(drr.drr_u.drr_begin.drr_versioninfo, in zfs_send_compoundstream_begin()
232 (void) snprintf(drr.drr_u.drr_begin.drr_toname, in zfs_send_compoundstream_begin()
233 sizeof (drr.drr_u.drr_begin.drr_toname), "%s@%s", zfs_get_name(zhp), in zfs_send_compoundstream_begin()
235 drr.drr_payloadlen = payload_len; in zfs_send_compoundstream_begin()
237 err = dump_record(&drr, payload, payload_len, &zc, outfd); in zfs_send_compoundstream_begin()
241 bzero(&drr, sizeof (drr)); in zfs_send_compoundstream_begin()
242 drr.drr_type = DRR_END; in zfs_send_compoundstream_begin()
243 drr.drr_u.drr_end.drr_checksum = zc; in zfs_send_compoundstream_begin()
244 err = write(outfd, &drr, sizeof (drr)); in zfs_send_compoundstream_begin()
256 dmu_replay_record_t drr = { 0 }; in zfs_send_compoundstream_end() local
258 drr.drr_type = DRR_END; in zfs_send_compoundstream_end()
259 if (write(outfd, &drr, sizeof (drr)) == -1) in zfs_send_compoundstream_end()
288 dmu_replay_record_t *drr = &thedrr; in cksummer() local
318 while (ssread(drr, sizeof (*drr), ofp) != 0) { in cksummer()
320 switch (drr->drr_type) { in cksummer()
323 struct drr_begin *drrb = &drr->drr_u.drr_begin; in cksummer()
336 if (drr->drr_payloadlen != 0) { in cksummer()
337 sz = drr->drr_payloadlen; in cksummer()
347 if (dump_record(drr, buf, sz, &stream_cksum, in cksummer()
355 struct drr_end *drre = &drr->drr_u.drr_end; in cksummer()
358 if (dump_record(drr, NULL, 0, &stream_cksum, in cksummer()
366 struct drr_object *drro = &drr->drr_u.drr_object; in cksummer()
372 if (dump_record(drr, buf, in cksummer()
381 struct drr_spill *drrs = &drr->drr_u.drr_spill; in cksummer()
383 if (dump_record(drr, buf, drrs->drr_length, in cksummer()
391 if (dump_record(drr, NULL, 0, &stream_cksum, in cksummer()
399 struct drr_write *drrw = &drr->drr_u.drr_write; in cksummer()
468 if (dump_record(drr, buf, drrw->drr_length, in cksummer()
478 &drr->drr_u.drr_write_embedded; in cksummer()
481 if (dump_record(drr, buf, in cksummer()
490 if (dump_record(drr, NULL, 0, &stream_cksum, in cksummer()
498 drr->drr_type); in cksummer()
1724 dmu_replay_record_t drr = { 0 }; in zfs_send() local
1760 drr.drr_type = DRR_BEGIN; in zfs_send()
1761 drr.drr_u.drr_begin.drr_magic = DMU_BACKUP_MAGIC; in zfs_send()
1762 DMU_SET_STREAM_HDRTYPE(drr.drr_u.drr_begin. in zfs_send()
1764 DMU_SET_FEATUREFLAGS(drr.drr_u.drr_begin. in zfs_send()
1766 (void) snprintf(drr.drr_u.drr_begin.drr_toname, in zfs_send()
1767 sizeof (drr.drr_u.drr_begin.drr_toname), in zfs_send()
1769 drr.drr_payloadlen = buflen; in zfs_send()
1771 err = dump_record(&drr, packbuf, buflen, &zc, outfd); in zfs_send()
1777 bzero(&drr, sizeof (drr)); in zfs_send()
1778 drr.drr_type = DRR_END; in zfs_send()
1779 drr.drr_u.drr_end.drr_checksum = zc; in zfs_send()
1780 err = write(outfd, &drr, sizeof (drr)); in zfs_send()
1914 dmu_replay_record_t drr = { 0 }; in zfs_send() local
1915 drr.drr_type = DRR_END; in zfs_send()
1916 if (write(outfd, &drr, sizeof (drr)) == -1) { in zfs_send()
2613 recvflags_t *flags, dmu_replay_record_t *drr, zio_cksum_t *zc, in zfs_receive_package() argument
2632 assert(drr->drr_type == DRR_BEGIN); in zfs_receive_package()
2633 assert(drr->drr_u.drr_begin.drr_magic == DMU_BACKUP_MAGIC); in zfs_receive_package()
2634 assert(DMU_GET_STREAM_HDRTYPE(drr->drr_u.drr_begin.drr_versioninfo) == in zfs_receive_package()
2640 if (drr->drr_payloadlen != 0) { in zfs_receive_package()
2641 error = recv_read_nvlist(hdl, fd, drr->drr_payloadlen, in zfs_receive_package()
2689 if (drr->drr_payloadlen != 0) { in zfs_receive_package()
2707 struct drr_begin *drrb = &drr->drr_u.drr_begin; in zfs_receive_package()
2765 (void) strlcpy(sendfs, drr->drr_u.drr_begin.drr_toname, in zfs_receive_package()
2789 if (drr->drr_payloadlen != 0 && fromsnap != NULL) { in zfs_receive_package()
2824 dmu_replay_record_t *drr; in recv_skip() local
2832 drr = buf; in recv_skip()
2834 while (recv_read(hdl, fd, drr, sizeof (dmu_replay_record_t), in recv_skip()
2837 drr->drr_type = BSWAP_32(drr->drr_type); in recv_skip()
2839 switch (drr->drr_type) { in recv_skip()
2841 if (drr->drr_payloadlen != 0) { in recv_skip()
2843 drr->drr_payloadlen, B_FALSE, NULL); in recv_skip()
2853 drr->drr_u.drr_object.drr_bonuslen = in recv_skip()
2854 BSWAP_32(drr->drr_u.drr_object. in recv_skip()
2858 P2ROUNDUP(drr->drr_u.drr_object.drr_bonuslen, 8), in recv_skip()
2864 drr->drr_u.drr_write.drr_length = in recv_skip()
2865 BSWAP_64(drr->drr_u.drr_write.drr_length); in recv_skip()
2868 drr->drr_u.drr_write.drr_length, B_FALSE, NULL); in recv_skip()
2872 drr->drr_u.drr_write.drr_length = in recv_skip()
2873 BSWAP_64(drr->drr_u.drr_spill.drr_length); in recv_skip()
2876 drr->drr_u.drr_spill.drr_length, B_FALSE, NULL); in recv_skip()
2880 drr->drr_u.drr_write_embedded.drr_psize = in recv_skip()
2881 BSWAP_32(drr->drr_u.drr_write_embedded. in recv_skip()
2885 P2ROUNDUP(drr->drr_u.drr_write_embedded.drr_psize, in recv_skip()
2943 const char *originsnap, recvflags_t *flags, dmu_replay_record_t *drr, in zfs_receive_one() argument
2952 struct drr_begin *drrb = &drr->drr_u.drr_begin; in zfs_receive_one()
3508 dmu_replay_record_t drr, drr_noswap; in zfs_receive_impl() local
3509 struct drr_begin *drrb = &drr.drr_u.drr_begin; in zfs_receive_impl()
3532 if (0 != (err = recv_read(hdl, infd, &drr, sizeof (drr), B_FALSE, in zfs_receive_impl()
3536 if (drr.drr_type == DRR_END || drr.drr_type == BSWAP_32(DRR_END)) { in zfs_receive_impl()
3542 drr_noswap = drr; in zfs_receive_impl()
3551 fletcher_4_incremental_byteswap(&drr, sizeof (drr), &zcksum); in zfs_receive_impl()
3554 drr.drr_type = BSWAP_32(drr.drr_type); in zfs_receive_impl()
3555 drr.drr_payloadlen = BSWAP_32(drr.drr_payloadlen); in zfs_receive_impl()
3565 if (drrb->drr_magic != DMU_BACKUP_MAGIC || drr.drr_type != DRR_BEGIN) { in zfs_receive_impl()
3597 drr.drr_u.drr_begin.drr_toname, in zfs_receive_impl()
3604 &drr, &drr_noswap, sendfs, stream_nv, stream_avl, top_zfs, in zfs_receive_impl()
3609 return (zfs_receive_package(hdl, infd, tosnap, flags, &drr, in zfs_receive_impl()