Lines Matching defs:drr
188 dump_record(dmu_replay_record_t *drr, void *payload, int payload_len,
193 fletcher_4_incremental_native(drr,
195 if (drr->drr_type != DRR_BEGIN) {
196 ASSERT(ZIO_CHECKSUM_IS_ZERO(&drr->drr_u.
198 drr->drr_u.drr_checksum.drr_checksum = *zc;
200 fletcher_4_incremental_native(&drr->drr_u.drr_checksum.drr_checksum,
202 if (write(outfd, drr, sizeof (*drr)) == -1)
216 dmu_replay_record_t drr = { 0 };
228 drr.drr_type = DRR_BEGIN;
229 drr.drr_u.drr_begin.drr_magic = DMU_BACKUP_MAGIC;
230 DMU_SET_STREAM_HDRTYPE(drr.drr_u.drr_begin.drr_versioninfo,
232 DMU_SET_FEATUREFLAGS(drr.drr_u.drr_begin.drr_versioninfo,
234 (void) snprintf(drr.drr_u.drr_begin.drr_toname,
235 sizeof (drr.drr_u.drr_begin.drr_toname), "%s@%s", zfs_get_name(zhp),
237 drr.drr_payloadlen = payload_len;
239 err = dump_record(&drr, payload, payload_len, &zc, outfd);
243 bzero(&drr, sizeof (drr));
244 drr.drr_type = DRR_END;
245 drr.drr_u.drr_end.drr_checksum = zc;
246 err = write(outfd, &drr, sizeof (drr));
258 dmu_replay_record_t drr = { 0 };
260 drr.drr_type = DRR_END;
261 if (write(outfd, &drr, sizeof (drr)) == -1)
290 dmu_replay_record_t *drr = &thedrr;
320 while (ssread(drr, sizeof (*drr), ofp) != 0) {
322 switch (drr->drr_type) {
325 struct drr_begin *drrb = &drr->drr_u.drr_begin;
338 if (drr->drr_payloadlen != 0) {
339 sz = drr->drr_payloadlen;
349 if (dump_record(drr, buf, sz, &stream_cksum,
357 struct drr_end *drre = &drr->drr_u.drr_end;
360 if (dump_record(drr, NULL, 0, &stream_cksum,
368 struct drr_object *drro = &drr->drr_u.drr_object;
374 if (dump_record(drr, buf,
383 struct drr_spill *drrs = &drr->drr_u.drr_spill;
385 if (dump_record(drr, buf, drrs->drr_length,
393 if (dump_record(drr, NULL, 0, &stream_cksum,
401 struct drr_write *drrw = &drr->drr_u.drr_write;
470 if (dump_record(drr, buf, drrw->drr_length,
480 &drr->drr_u.drr_write_embedded;
483 if (dump_record(drr, buf,
492 if (dump_record(drr, NULL, 0, &stream_cksum,
500 drr->drr_type);
1726 dmu_replay_record_t drr = { 0 };
1762 drr.drr_type = DRR_BEGIN;
1763 drr.drr_u.drr_begin.drr_magic = DMU_BACKUP_MAGIC;
1764 DMU_SET_STREAM_HDRTYPE(drr.drr_u.drr_begin.
1766 DMU_SET_FEATUREFLAGS(drr.drr_u.drr_begin.
1768 (void) snprintf(drr.drr_u.drr_begin.drr_toname,
1769 sizeof (drr.drr_u.drr_begin.drr_toname),
1771 drr.drr_payloadlen = buflen;
1773 err = dump_record(&drr, packbuf, buflen, &zc, outfd);
1779 bzero(&drr, sizeof (drr));
1780 drr.drr_type = DRR_END;
1781 drr.drr_u.drr_end.drr_checksum = zc;
1782 err = write(outfd, &drr, sizeof (drr));
1916 dmu_replay_record_t drr = { 0 };
1917 drr.drr_type = DRR_END;
1918 if (write(outfd, &drr, sizeof (drr)) == -1) {
2615 recvflags_t *flags, dmu_replay_record_t *drr, zio_cksum_t *zc,
2635 assert(drr->drr_type == DRR_BEGIN);
2636 assert(drr->drr_u.drr_begin.drr_magic == DMU_BACKUP_MAGIC);
2637 assert(DMU_GET_STREAM_HDRTYPE(drr->drr_u.drr_begin.drr_versioninfo) ==
2643 if (drr->drr_payloadlen != 0) {
2644 error = recv_read_nvlist(hdl, fd, drr->drr_payloadlen,
2692 if (drr->drr_payloadlen != 0) {
2710 struct drr_begin *drrb = &drr->drr_u.drr_begin;
2768 (void) strlcpy(sendfs, drr->drr_u.drr_begin.drr_toname,
2800 if (drr->drr_payloadlen != 0 && fromsnap != NULL) {
2835 dmu_replay_record_t *drr;
2843 drr = buf;
2845 while (recv_read(hdl, fd, drr, sizeof (dmu_replay_record_t),
2848 drr->drr_type = BSWAP_32(drr->drr_type);
2850 switch (drr->drr_type) {
2852 if (drr->drr_payloadlen != 0) {
2854 drr->drr_payloadlen, B_FALSE, NULL);
2864 drr->drr_u.drr_object.drr_bonuslen =
2865 BSWAP_32(drr->drr_u.drr_object.
2869 P2ROUNDUP(drr->drr_u.drr_object.drr_bonuslen, 8),
2875 drr->drr_u.drr_write.drr_length =
2876 BSWAP_64(drr->drr_u.drr_write.drr_length);
2879 drr->drr_u.drr_write.drr_length, B_FALSE, NULL);
2883 drr->drr_u.drr_write.drr_length =
2884 BSWAP_64(drr->drr_u.drr_spill.drr_length);
2887 drr->drr_u.drr_spill.drr_length, B_FALSE, NULL);
2891 drr->drr_u.drr_write_embedded.drr_psize =
2892 BSWAP_32(drr->drr_u.drr_write_embedded.
2896 P2ROUNDUP(drr->drr_u.drr_write_embedded.drr_psize,
2954 const char *originsnap, recvflags_t *flags, dmu_replay_record_t *drr,
2963 struct drr_begin *drrb = &drr->drr_u.drr_begin;
3533 dmu_replay_record_t drr, drr_noswap;
3534 struct drr_begin *drrb = &drr.drr_u.drr_begin;
3557 if (0 != (err = recv_read(hdl, infd, &drr, sizeof (drr), B_FALSE,
3561 if (drr.drr_type == DRR_END || drr.drr_type == BSWAP_32(DRR_END)) {
3567 drr_noswap = drr;
3576 fletcher_4_incremental_byteswap(&drr, sizeof (drr), &zcksum);
3579 drr.drr_type = BSWAP_32(drr.drr_type);
3580 drr.drr_payloadlen = BSWAP_32(drr.drr_payloadlen);
3590 if (drrb->drr_magic != DMU_BACKUP_MAGIC || drr.drr_type != DRR_BEGIN) {
3622 drr.drr_u.drr_begin.drr_toname,
3630 &drr, &drr_noswap, sendfs, stream_nv, stream_avl, top_zfs,
3635 return (zfs_receive_package(hdl, infd, tosnap, flags, &drr,