Home
last modified time | relevance | path

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

/freebsd-head/sys/contrib/openzfs/cmd/zstream/
HDzstream_redup.c108 dump_record(dmu_replay_record_t *drr, void *payload, int payload_len, in dump_record() argument
113 fletcher_4_incremental_native(drr, in dump_record()
115 if (drr->drr_type != DRR_BEGIN) { in dump_record()
116 assert(ZIO_CHECKSUM_IS_ZERO(&drr->drr_u. in dump_record()
118 drr->drr_u.drr_checksum.drr_checksum = *zc; in dump_record()
120 fletcher_4_incremental_native(&drr->drr_u.drr_checksum.drr_checksum, in dump_record()
122 if (write(outfd, drr, sizeof (*drr)) == -1) in dump_record()
182 dmu_replay_record_t *drr = &thedrr; in zfs_redup_stream() local
221 while (sfread(drr, sizeof (*drr), ofp) != 0) { in zfs_redup_stream()
227 if (drr->drr_type != DRR_BEGIN) { in zfs_redup_stream()
[all …]
HDzstream_recompress.c42 dump_record(dmu_replay_record_t *drr, void *payload, int payload_len, in dump_record() argument
47 fletcher_4_incremental_native(drr, in dump_record()
49 if (drr->drr_type != DRR_BEGIN) { in dump_record()
50 assert(ZIO_CHECKSUM_IS_ZERO(&drr->drr_u. in dump_record()
52 drr->drr_u.drr_checksum.drr_checksum = *zc; in dump_record()
54 fletcher_4_incremental_native(&drr->drr_u.drr_checksum.drr_checksum, 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
132 while (sfread(drr, sizeof (*drr), stdin) != 0) { in zstream_do_recompress()
139 if (drr->drr_type != DRR_BEGIN) { in zstream_do_recompress()
[all …]
HDzstream_decompress.c42 dump_record(dmu_replay_record_t *drr, void *payload, int payload_len, in dump_record() argument
47 fletcher_4_incremental_native(drr, in dump_record()
49 if (drr->drr_type != DRR_BEGIN) { in dump_record()
50 assert(ZIO_CHECKSUM_IS_ZERO(&drr->drr_u. in dump_record()
52 drr->drr_u.drr_checksum.drr_checksum = *zc; in dump_record()
54 fletcher_4_incremental_native(&drr->drr_u.drr_checksum.drr_checksum, in dump_record()
56 if (write(outfd, drr, sizeof (*drr)) == -1) in dump_record()
73 dmu_replay_record_t *drr = &thedrr; in zstream_do_decompress() local
166 while (sfread(drr, sizeof (*drr), stdin) != 0) { in zstream_do_decompress()
173 if (drr->drr_type != DRR_BEGIN) { in zstream_do_decompress()
[all …]
HDzstream_dump.c99 read_hdr(dmu_replay_record_t *drr, zio_cksum_t *cksum) in read_hdr() argument
103 size_t r = ssread(drr, sizeof (*drr) - sizeof (zio_cksum_t), cksum); in read_hdr()
107 r = ssread(&drr->drr_u.drr_checksum.drr_checksum, in read_hdr()
112 !ZIO_CHECKSUM_IS_ZERO(&drr->drr_u.drr_checksum.drr_checksum) && in read_hdr()
114 drr->drr_u.drr_checksum.drr_checksum)) { in read_hdr()
124 return (sizeof (*drr)); in read_hdr()
222 dmu_replay_record_t *drr = &thedrr; in zstream_do_dump() local
300 while (read_hdr(drr, &zc)) { in zstream_do_dump()
317 fletcher_4_incremental_byteswap(drr, in zstream_do_dump()
328 drr->drr_type = BSWAP_32(drr->drr_type); in zstream_do_dump()
[all …]
/freebsd-head/sys/contrib/openzfs/lib/libzfs/
HDlibzfs_sendrecv.c94 dump_record(dmu_replay_record_t *drr, void *payload, size_t payload_len, in dump_record() argument
99 fletcher_4_incremental_native(drr, in dump_record()
101 if (drr->drr_type != DRR_BEGIN) { in dump_record()
102 ASSERT(ZIO_CHECKSUM_IS_ZERO(&drr->drr_u. in dump_record()
104 drr->drr_u.drr_checksum.drr_checksum = *zc; in dump_record()
106 fletcher_4_incremental_native(&drr->drr_u.drr_checksum.drr_checksum, in dump_record()
108 if (write(outfd, drr, sizeof (*drr)) == -1) in dump_record()
2175 dmu_replay_record_t drr; in send_conclusion_record() local
2176 memset(&drr, 0, sizeof (dmu_replay_record_t)); in send_conclusion_record()
2177 drr.drr_type = DRR_END; in send_conclusion_record()
[all …]
/freebsd-head/sys/netgraph/
HDng_pipe.c514 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()
HDng_pipe.h121 u_int32_t drr; member
/freebsd-head/sys/contrib/openzfs/tests/zfs-tests/cmd/
HDlibzfs_input_check.c525 dmu_replay_record_t drr; in test_recv_new() local
532 memset(&drr, 0, sizeof (dmu_replay_record_t)); in test_recv_new()
542 count = pread(fd, &drr, sizeof (drr), 0); in test_recv_new()
543 if (count != sizeof (drr)) { in test_recv_new()
549 fnvlist_add_byte_array(required, "begin_record", (uchar_t *)&drr, in test_recv_new()
550 sizeof (drr)); in test_recv_new()
/freebsd-head/sys/contrib/openzfs/lib/libzfs_core/
HDlibzfs_core.c1009 dmu_replay_record_t drr; in recv_impl() local
1049 error = recv_read(input_fd, &drr, sizeof (drr)); in recv_impl()
1053 drr = *begin_record; in recv_impl()
1090 (uchar_t *)&drr, sizeof (drr)); in recv_impl()
1149 ASSERT3S(drr.drr_type, ==, DRR_BEGIN); in recv_impl()
1150 zc.zc_begin_record = drr.drr_u.drr_begin; in recv_impl()
/freebsd-head/sys/contrib/openzfs/module/zfs/
HDdmu_send.c2039 dmu_replay_record_t *drr = kmem_zalloc(sizeof (dmu_replay_record_t), in create_begin_record() local
2041 drr->drr_type = DRR_BEGIN; in create_begin_record()
2043 struct drr_begin *drrb = &drr->drr_u.drr_begin; in create_begin_record()
2061 drr->drr_u.drr_begin.drr_flags |= DRR_FLAG_SPILL_BLOCK; in create_begin_record()
2074 return (drr); in create_begin_record()
2366 dmu_replay_record_t *drr; in dmu_send_impl() local
2461 drr = create_begin_record(dspp, os, featureflags); in dmu_send_impl()
2464 dsc.dsc_drr = drr; in dmu_send_impl()
2552 drr->drr_payloadlen = payload_len; in dmu_send_impl()
2620 memset(drr, 0, sizeof (dmu_replay_record_t)); in dmu_send_impl()
[all …]
HDdmu_recv.c154 byteswap_record(dmu_replay_record_t *drr) in byteswap_record() argument
156 #define DO64(X) (drr->drr_u.X = BSWAP_64(drr->drr_u.X)) in byteswap_record()
157 #define DO32(X) (drr->drr_u.X = BSWAP_32(drr->drr_u.X)) in byteswap_record()
158 drr->drr_type = BSWAP_32(drr->drr_type); in byteswap_record()
159 drr->drr_payloadlen = BSWAP_32(drr->drr_payloadlen); in byteswap_record()
161 switch (drr->drr_type) { in byteswap_record()
192 ZIO_CHECKSUM_BSWAP(&drr->drr_u.drr_write.drr_key.ddk_cksum); in byteswap_record()
230 ZIO_CHECKSUM_BSWAP(&drr->drr_u.drr_end.drr_checksum); in byteswap_record()
236 if (drr->drr_type != DRR_BEGIN) { in byteswap_record()
237 ZIO_CHECKSUM_BSWAP(&drr->drr_u.drr_checksum.drr_checksum); in byteswap_record()
/freebsd-head/contrib/unbound/validator/
HDautotrust.c482 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()