/freebsd/sys/contrib/openzfs/cmd/zstream/ |
H A D | zstream_recompress.c | 47 fletcher_4_incremental_native(drr, in dump_record() 49 if (drr->drr_type != DRR_BEGIN) { in dump_record() 56 if (write(outfd, drr, sizeof (*drr)) == -1) in dump_record() 72 dmu_replay_record_t *drr = &thedrr; in zstream_do_recompress() local 143 while (sfread(drr, sizeof (*drr), stdin) != 0) { in zstream_do_recompress() 150 if (drr->drr_type != DRR_BEGIN) { in zstream_do_recompress() 156 switch (drr->drr_type) { in zstream_do_recompress() 163 uint32_t sz = drr->drr_payloadlen; in zstream_do_recompress() 331 drr->drr_type); in zstream_do_recompress() 351 if (drr->drr_type != DRR_BEGIN) { in zstream_do_recompress() [all …]
|
H A D | zstream_redup.c | 121 fletcher_4_incremental_native(drr, in dump_record() 123 if (drr->drr_type != DRR_BEGIN) { in dump_record() 130 if (write(outfd, drr, sizeof (*drr)) == -1) in dump_record() 190 dmu_replay_record_t *drr = &thedrr; in zfs_redup_stream() local 229 while (sfread(drr, sizeof (*drr), ofp) != 0) { in zfs_redup_stream() 235 if (drr->drr_type != DRR_BEGIN) { in zfs_redup_stream() 241 switch (drr->drr_type) { in zfs_redup_stream() 319 drr->drr_u.drr_write_byref; in zfs_redup_stream() 335 spread(infd, drr, sizeof (*drr), stream_offset); in zfs_redup_stream() 384 drr->drr_type); in zfs_redup_stream() [all …]
|
H A D | zstream_decompress.c | 44 fletcher_4_incremental_native(drr, in dump_record() 46 if (drr->drr_type != DRR_BEGIN) { in dump_record() 53 if (write(outfd, drr, sizeof (*drr)) == -1) in dump_record() 70 dmu_replay_record_t *drr = &thedrr; in zstream_do_decompress() local 163 while (sfread(drr, sizeof (*drr), stdin) != 0) { in zstream_do_decompress() 170 if (drr->drr_type != DRR_BEGIN) { in zstream_do_decompress() 175 switch (drr->drr_type) { in zstream_do_decompress() 182 uint32_t sz = drr->drr_payloadlen; in zstream_do_decompress() 359 drr->drr_type); in zstream_do_decompress() 379 if (drr->drr_type != DRR_BEGIN) { in zstream_do_decompress() [all …]
|
H A D | zstream_dump.c | 102 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() 327 drr->drr_type = BSWAP_32(drr->drr_type); in zstream_do_dump() 328 drr->drr_payloadlen = in zstream_do_dump() 341 drr->drr_type); in zstream_do_dump() 351 switch (drr->drr_type) { in zstream_do_dump() 383 drr->drr_payloadlen); in zstream_do_dump() 387 if (drr->drr_payloadlen != 0) { in zstream_do_dump() [all …]
|
/freebsd/sys/contrib/openzfs/lib/libzfs/ |
H A D | libzfs_sendrecv.c | 106 if (write(outfd, drr, sizeof (*drr)) == -1) in dump_record() 2175 drr.drr_type = DRR_END; in send_conclusion_record() 2178 if (write(fd, &drr, sizeof (drr)) == -1) { in send_conclusion_record() 4036 drr = buf; in recv_skip() 4041 drr->drr_type = BSWAP_32(drr->drr_type); in recv_skip() 5455 if (0 != (err = recv_read(hdl, infd, &drr, sizeof (drr), B_FALSE, in zfs_receive_impl() 5459 if (drr.drr_type == DRR_END || drr.drr_type == BSWAP_32(DRR_END)) { in zfs_receive_impl() 5465 drr_noswap = drr; in zfs_receive_impl() 5474 fletcher_4_incremental_byteswap(&drr, sizeof (drr), &zcksum); in zfs_receive_impl() 5477 drr.drr_type = BSWAP_32(drr.drr_type); in zfs_receive_impl() [all …]
|
/freebsd/sys/netgraph/ |
H A D | ng_pipe.c | 514 current->drr = 0; in parse_cfg() 520 current->drr = 0; in parse_cfg() 523 if (new->drr) { in parse_cfg() 527 if (new->drr >= 32) in parse_cfg() 528 current->drr = new->drr; in parse_cfg() 530 current->drr = 2048; /* default quantum */ in parse_cfg() 547 current->drr = 0; in parse_cfg() 672 ngp_f->rr_deficit = hinfo->cfg.drr; /* DRR quantum */ in ngp_rcvdata() 764 if (hinfo->cfg.drr) { in pipe_dequeue() 768 ngp_f->rr_deficit += hinfo->cfg.drr; in pipe_dequeue()
|
H A D | ng_pipe.h | 121 u_int32_t drr; member
|
/freebsd/sys/contrib/openzfs/tests/zfs-tests/cmd/ |
H A D | libzfs_input_check.c | 524 dmu_replay_record_t drr; in test_recv_new() local 531 memset(&drr, 0, sizeof (dmu_replay_record_t)); in test_recv_new() 541 count = pread(fd, &drr, sizeof (drr), 0); in test_recv_new() 542 if (count != sizeof (drr)) { in test_recv_new() 548 fnvlist_add_byte_array(required, "begin_record", (uchar_t *)&drr, in test_recv_new() 549 sizeof (drr)); in test_recv_new()
|
/freebsd/sys/contrib/openzfs/lib/libzfs_core/ |
H A D | libzfs_core.c | 1002 dmu_replay_record_t drr; in recv_impl() local 1042 error = recv_read(input_fd, &drr, sizeof (drr)); in recv_impl() 1046 drr = *begin_record; in recv_impl() 1083 (uchar_t *)&drr, sizeof (drr)); in recv_impl() 1142 ASSERT3S(drr.drr_type, ==, DRR_BEGIN); in recv_impl() 1143 zc.zc_begin_record = drr.drr_u.drr_begin; in recv_impl()
|
/freebsd/sys/contrib/openzfs/module/zfs/ |
H A D | dmu_send.c | 2023 drr->drr_type = DRR_BEGIN; in create_begin_record() 2025 struct drr_begin *drrb = &drr->drr_u.drr_begin; in create_begin_record() 2056 return (drr); in create_begin_record() 2348 dmu_replay_record_t *drr; in dmu_send_impl() local 2446 dsc.dsc_drr = drr; in dmu_send_impl() 2534 drr->drr_payloadlen = payload_len; in dmu_send_impl() 2602 memset(drr, 0, sizeof (dmu_replay_record_t)); in dmu_send_impl() 2603 drr->drr_type = DRR_END; in dmu_send_impl() 2604 drr->drr_u.drr_end.drr_checksum = dsc.dsc_zc; in dmu_send_impl() 2605 drr->drr_u.drr_end.drr_toguid = dsc.dsc_toguid; in dmu_send_impl() [all …]
|
H A D | dmu_recv.c | 152 byteswap_record(dmu_replay_record_t *drr) in byteswap_record() argument 154 #define DO64(X) (drr->drr_u.X = BSWAP_64(drr->drr_u.X)) in byteswap_record() 155 #define DO32(X) (drr->drr_u.X = BSWAP_32(drr->drr_u.X)) in byteswap_record() 156 drr->drr_type = BSWAP_32(drr->drr_type); in byteswap_record() 157 drr->drr_payloadlen = BSWAP_32(drr->drr_payloadlen); in byteswap_record() 159 switch (drr->drr_type) { in byteswap_record() 190 ZIO_CHECKSUM_BSWAP(&drr->drr_u.drr_write.drr_key.ddk_cksum); in byteswap_record() 228 ZIO_CHECKSUM_BSWAP(&drr->drr_u.drr_end.drr_checksum); in byteswap_record() 234 if (drr->drr_type != DRR_BEGIN) { in byteswap_record() 235 ZIO_CHECKSUM_BSWAP(&drr->drr_u.drr_checksum.drr_checksum); in byteswap_record()
|
/freebsd/contrib/unbound/validator/ |
H A D | autotrust.c | 482 uint8_t* drr; in add_trustanchor_frm_str() local 508 drr = memdup(rr, rr_len); in add_trustanchor_frm_str() 509 if(!drr) { in add_trustanchor_frm_str() 513 return add_trustanchor_frm_rr(anchors, drr, rr_len, dname_len, tp); in add_trustanchor_frm_str()
|