Home
last modified time | relevance | path

Searched refs:drr (Results 1 – 10 of 10) sorted by relevance

/f-stack/freebsd/contrib/openzfs/cmd/zstream/
H A Dzstream_redup.c122 fletcher_4_incremental_native(drr, in dump_record()
124 if (drr->drr_type != DRR_BEGIN) { in dump_record()
131 if (write(outfd, drr, sizeof (*drr)) == -1) in dump_record()
226 while (sfread(drr, sizeof (*drr), ofp) != 0) { in zfs_redup_stream()
232 if (drr->drr_type != DRR_BEGIN) { in zfs_redup_stream()
238 switch (drr->drr_type) { in zfs_redup_stream()
253 int sz = drr->drr_payloadlen; in zfs_redup_stream()
301 drr->drr_u.drr_write_byref; in zfs_redup_stream()
316 spread(infd, drr, sizeof (*drr), stream_offset); in zfs_redup_stream()
362 drr->drr_type); in zfs_redup_stream()
[all …]
H A Dzstream_dump.c102 size_t r = ssread(drr, sizeof (*drr) - sizeof (zio_cksum_t), cksum); in read_hdr()
123 return (sizeof (*drr)); in read_hdr()
221 dmu_replay_record_t *drr = &thedrr; in zstream_do_dump() local
299 while (read_hdr(drr, &zc)) { in zstream_do_dump()
326 drr->drr_type = BSWAP_32(drr->drr_type); in zstream_do_dump()
327 drr->drr_payloadlen = in zstream_do_dump()
340 drr->drr_type); in zstream_do_dump()
350 switch (drr->drr_type) { in zstream_do_dump()
382 drr->drr_payloadlen); in zstream_do_dump()
386 if (drr->drr_payloadlen != 0) { in zstream_do_dump()
[all …]
/f-stack/freebsd/contrib/openzfs/lib/libzfs/
H A Dlibzfs_sendrecv.c104 if (write(outfd, drr, sizeof (*drr)) == -1) in dump_record()
1956 drr.drr_type = DRR_END; in send_conclusion_record()
1959 if (write(fd, &drr, sizeof (drr)) == -1) { in send_conclusion_record()
3754 drr = buf; in recv_skip()
3759 drr->drr_type = BSWAP_32(drr->drr_type); in recv_skip()
5023 if (0 != (err = recv_read(hdl, infd, &drr, sizeof (drr), B_FALSE, in zfs_receive_impl()
5027 if (drr.drr_type == DRR_END || drr.drr_type == BSWAP_32(DRR_END)) { in zfs_receive_impl()
5033 drr_noswap = drr; in zfs_receive_impl()
5042 fletcher_4_incremental_byteswap(&drr, sizeof (drr), &zcksum); in zfs_receive_impl()
5045 drr.drr_type = BSWAP_32(drr.drr_type); in zfs_receive_impl()
[all …]
/f-stack/freebsd/netgraph/
H A Dng_pipe.c515 current->drr = 0; in parse_cfg()
521 current->drr = 0; in parse_cfg()
524 if (new->drr) { in parse_cfg()
528 if (new->drr >= 32) in parse_cfg()
529 current->drr = new->drr; in parse_cfg()
531 current->drr = 2048; /* default quantum */ in parse_cfg()
548 current->drr = 0; in parse_cfg()
667 ngp_f->rr_deficit = hinfo->cfg.drr; /* DRR quantum */ in ngp_rcvdata()
759 if (hinfo->cfg.drr) { in pipe_dequeue()
763 ngp_f->rr_deficit += hinfo->cfg.drr; in pipe_dequeue()
H A Dng_pipe.h123 u_int32_t drr; member
/f-stack/freebsd/contrib/openzfs/lib/libzfs_core/
H A Dlibzfs_core.c790 dmu_replay_record_t drr; in recv_impl() local
820 error = recv_read(input_fd, &drr, sizeof (drr)); in recv_impl()
824 drr = *begin_record; in recv_impl()
861 (uchar_t *)&drr, sizeof (drr)); in recv_impl()
917 ASSERT3S(drr.drr_type, ==, DRR_BEGIN); in recv_impl()
918 zc.zc_begin_record = drr.drr_u.drr_begin; in recv_impl()
/f-stack/freebsd/contrib/openzfs/tests/zfs-tests/cmd/libzfs_input_check/
H A Dlibzfs_input_check.c524 dmu_replay_record_t drr = { 0 }; in test_recv_new() local
535 count = pread(fd, &drr, sizeof (drr), 0); in test_recv_new()
536 if (count != sizeof (drr)) { in test_recv_new()
542 fnvlist_add_byte_array(required, "begin_record", (uchar_t *)&drr, in test_recv_new()
543 sizeof (drr)); in test_recv_new()
/f-stack/tools/compat/include/netgraph/
H A Dng_pipe.h121 u_int32_t drr; member
/f-stack/freebsd/contrib/openzfs/module/zfs/
H A Ddmu_recv.c136 byteswap_record(dmu_replay_record_t *drr) in byteswap_record() argument
138 #define DO64(X) (drr->drr_u.X = BSWAP_64(drr->drr_u.X)) in byteswap_record()
139 #define DO32(X) (drr->drr_u.X = BSWAP_32(drr->drr_u.X)) in byteswap_record()
140 drr->drr_type = BSWAP_32(drr->drr_type); in byteswap_record()
141 drr->drr_payloadlen = BSWAP_32(drr->drr_payloadlen); in byteswap_record()
143 switch (drr->drr_type) { in byteswap_record()
174 ZIO_CHECKSUM_BSWAP(&drr->drr_u.drr_write.drr_key.ddk_cksum); in byteswap_record()
212 ZIO_CHECKSUM_BSWAP(&drr->drr_u.drr_end.drr_checksum); in byteswap_record()
218 if (drr->drr_type != DRR_BEGIN) { in byteswap_record()
219 ZIO_CHECKSUM_BSWAP(&drr->drr_u.drr_checksum.drr_checksum); in byteswap_record()
H A Ddmu_send.c2007 drr->drr_type = DRR_BEGIN; in create_begin_record()
2009 struct drr_begin *drrb = &drr->drr_u.drr_begin; in create_begin_record()
2040 return (drr); in create_begin_record()
2329 dmu_replay_record_t *drr; in dmu_send_impl() local
2427 dsc.dsc_drr = drr; in dmu_send_impl()
2516 drr->drr_payloadlen = payload_len; in dmu_send_impl()
2584 bzero(drr, sizeof (dmu_replay_record_t)); in dmu_send_impl()
2585 drr->drr_type = DRR_END; in dmu_send_impl()
2586 drr->drr_u.drr_end.drr_checksum = dsc.dsc_zc; in dmu_send_impl()
2587 drr->drr_u.drr_end.drr_toguid = dsc.dsc_toguid; in dmu_send_impl()
[all …]