Lines Matching defs:drr
93 dump_record(dmu_replay_record_t *drr, void *payload, size_t payload_len,
98 fletcher_4_incremental_native(drr,
100 if (drr->drr_type != DRR_BEGIN) {
101 ASSERT(ZIO_CHECKSUM_IS_ZERO(&drr->drr_u.
103 drr->drr_u.drr_checksum.drr_checksum = *zc;
105 fletcher_4_incremental_native(&drr->drr_u.drr_checksum.drr_checksum,
107 if (write(outfd, drr, sizeof (*drr)) == -1)
2174 dmu_replay_record_t drr;
2175 memset(&drr, 0, sizeof (dmu_replay_record_t));
2176 drr.drr_type = DRR_END;
2178 drr.drr_u.drr_end.drr_checksum = *zc;
2179 if (write(fd, &drr, sizeof (drr)) == -1) {
2277 dmu_replay_record_t drr;
2278 memset(&drr, 0, sizeof (dmu_replay_record_t));
2280 drr.drr_type = DRR_BEGIN;
2281 drr.drr_u.drr_begin.drr_magic = DMU_BACKUP_MAGIC;
2282 DMU_SET_STREAM_HDRTYPE(drr.drr_u.drr_begin.
2284 DMU_SET_FEATUREFLAGS(drr.drr_u.drr_begin.
2286 if (snprintf(drr.drr_u.drr_begin.drr_toname,
2287 sizeof (drr.drr_u.drr_begin.drr_toname), "%s@%s", tofs,
2288 tosnap) >= sizeof (drr.drr_u.drr_begin.drr_toname)) {
2292 drr.drr_payloadlen = buflen;
2294 err = dump_record(&drr, packbuf, buflen, &zc, fd);
3809 recvflags_t *flags, dmu_replay_record_t *drr, zio_cksum_t *zc,
3829 assert(drr->drr_type == DRR_BEGIN);
3830 assert(drr->drr_u.drr_begin.drr_magic == DMU_BACKUP_MAGIC);
3831 assert(DMU_GET_STREAM_HDRTYPE(drr->drr_u.drr_begin.drr_versioninfo) ==
3837 if (drr->drr_payloadlen != 0) {
3838 error = recv_read_nvlist(hdl, fd, drr->drr_payloadlen,
3887 if (drr->drr_payloadlen != 0) {
3904 struct drr_begin *drrb = &drr->drr_u.drr_begin;
3962 (void) strlcpy(sendfs, drr->drr_u.drr_begin.drr_toname,
3993 if (drr->drr_payloadlen != 0 && recursive && fromsnap != NULL) {
4033 dmu_replay_record_t *drr;
4042 drr = buf;
4044 while (recv_read(hdl, fd, drr, sizeof (dmu_replay_record_t),
4047 drr->drr_type = BSWAP_32(drr->drr_type);
4049 switch (drr->drr_type) {
4051 if (drr->drr_payloadlen != 0) {
4053 drr->drr_payloadlen, B_FALSE, NULL);
4063 drr->drr_u.drr_object.drr_bonuslen =
4064 BSWAP_32(drr->drr_u.drr_object.
4066 drr->drr_u.drr_object.drr_raw_bonuslen =
4067 BSWAP_32(drr->drr_u.drr_object.
4072 DRR_OBJECT_PAYLOAD_SIZE(&drr->drr_u.drr_object);
4079 drr->drr_u.drr_write.drr_logical_size =
4081 drr->drr_u.drr_write.drr_logical_size);
4082 drr->drr_u.drr_write.drr_compressed_size =
4084 drr->drr_u.drr_write.drr_compressed_size);
4087 DRR_WRITE_PAYLOAD_SIZE(&drr->drr_u.drr_write);
4094 drr->drr_u.drr_spill.drr_length =
4095 BSWAP_64(drr->drr_u.drr_spill.drr_length);
4096 drr->drr_u.drr_spill.drr_compressed_size =
4097 BSWAP_64(drr->drr_u.drr_spill.
4102 DRR_SPILL_PAYLOAD_SIZE(&drr->drr_u.drr_spill);
4108 drr->drr_u.drr_write_embedded.drr_psize =
4109 BSWAP_32(drr->drr_u.drr_write_embedded.
4113 P2ROUNDUP(drr->drr_u.drr_write_embedded.drr_psize,
4405 const char *originsnap, recvflags_t *flags, dmu_replay_record_t *drr,
4413 struct drr_begin *drrb = &drr->drr_u.drr_begin;
5021 err = recv_read(hdl, infd, buf, drr->drr_payloadlen,
5433 dmu_replay_record_t drr, drr_noswap;
5434 struct drr_begin *drrb = &drr.drr_u.drr_begin;
5461 if (0 != (err = recv_read(hdl, infd, &drr, sizeof (drr), B_FALSE,
5465 if (drr.drr_type == DRR_END || drr.drr_type == BSWAP_32(DRR_END)) {
5471 drr_noswap = drr;
5480 fletcher_4_incremental_byteswap(&drr, sizeof (drr), &zcksum);
5483 drr.drr_type = BSWAP_32(drr.drr_type);
5484 drr.drr_payloadlen = BSWAP_32(drr.drr_payloadlen);
5494 if (drrb->drr_magic != DMU_BACKUP_MAGIC || drr.drr_type != DRR_BEGIN) {
5545 drr.drr_u.drr_begin.drr_toname,
5553 &drr, &drr_noswap, sendfs, stream_nv, stream_avl, top_zfs,
5558 return (zfs_receive_package(hdl, infd, tosnap, flags, &drr,