| /illumos-gate/usr/src/uts/sun4u/io/ |
| H A D | rmc_comm_drvintf.c | 276 dp_req_resp_t *drr; in rmc_comm_send_req_resp() local
304 drr = &dps->req_resp; in rmc_comm_send_req_resp()
305 exp_resp = &drr->response; in rmc_comm_send_req_resp()
353 drr->flags = 0; in rmc_comm_send_req_resp()
354 drr->error_status = 0; in rmc_comm_send_req_resp()
395 (void) cv_reltimedwait(drr->cv_wait_reply, dps->dp_mutex, in rmc_comm_send_req_resp()
400 drr->flags, request->msg_type, in rmc_comm_send_req_resp()
410 if ((drr->flags & MSG_ERROR) != 0) { in rmc_comm_send_req_resp()
411 if (drr->error_status == 0) { in rmc_comm_send_req_resp()
414 err = drr->error_status; in rmc_comm_send_req_resp()
[all …]
|
| H A D | rmc_comm_dp.c | 332 dp_req_resp_t *drr = &dps->req_resp; in dp_tx_handle_ack() local
339 if ((drr->flags & MSG_SENT) == 0) { in dp_tx_handle_ack()
352 drr->flags |= MSG_ACKED; in dp_tx_handle_ack()
353 if (drr->response.msg_type == DP_NULL_MSG) { in dp_tx_handle_ack()
366 dp_req_resp_t *drr = &dps->req_resp; in dp_tx_handle_nak() local
372 if ((drr->flags & MSG_SENT) == 0) { in dp_tx_handle_nak()
446 dp_req_resp_t *drr = &dps->req_resp; in dp_got_bp_msg() local
454 if ((drr->flags & MSG_SENT_BP) != 0) { in dp_got_bp_msg()
467 if (datalen <= drr->response.msg_bufsiz) { in dp_got_bp_msg()
468 bcopy(pkt->buf, drr->response.msg_buf, datalen); in dp_got_bp_msg()
[all …]
|
| /illumos-gate/usr/src/cmd/zstreamdump/ |
| H A D | zstreamdump.c | 110 read_hdr(dmu_replay_record_t *drr, zio_cksum_t *cksum) in read_hdr() argument
114 size_t r = ssread(drr, sizeof (*drr) - sizeof (zio_cksum_t), cksum); in read_hdr()
118 r = ssread(&drr->drr_u.drr_checksum.drr_checksum, in read_hdr()
122 if (!ZIO_CHECKSUM_IS_ZERO(&drr->drr_u.drr_checksum.drr_checksum) && in read_hdr()
124 drr->drr_u.drr_checksum.drr_checksum)) { in read_hdr()
134 return (sizeof (*drr)); in read_hdr()
182 dmu_replay_record_t *drr = &thedrr; in main() local
246 while (read_hdr(drr, &zc)) { in main()
262 fletcher_4_incremental_byteswap(drr, in main()
273 drr->drr_type = BSWAP_32(drr->drr_type); in main()
[all …]
|
| /illumos-gate/usr/src/lib/libzfs/common/ |
| H A D | libzfs_sendrecv.c | 194 dump_record(dmu_replay_record_t *drr, void *payload, int payload_len, in dump_record() argument
199 (void) fletcher_4_incremental_native(drr, in dump_record()
201 if (drr->drr_type != DRR_BEGIN) { in dump_record()
202 ASSERT(ZIO_CHECKSUM_IS_ZERO(&drr->drr_u. in dump_record()
204 drr->drr_u.drr_checksum.drr_checksum = *zc; in dump_record()
207 &drr->drr_u.drr_checksum.drr_checksum, sizeof (zio_cksum_t), zc); in dump_record()
208 if (write(outfd, drr, sizeof (*drr)) == -1) in dump_record()
241 dmu_replay_record_t *drr = &thedrr; in cksummer() local
271 while (ssread(drr, sizeof (*drr), ofp) != 0) { in cksummer()
277 if (drr->drr_type != DRR_BEGIN) { in cksummer()
[all …]
|
| /illumos-gate/usr/src/uts/common/fs/zfs/ |
| H A D | dmu_send.c | 959 dmu_replay_record_t *drr; in dmu_send_impl() local
994 drr = kmem_zalloc(sizeof (dmu_replay_record_t), KM_SLEEP); in dmu_send_impl()
995 drr->drr_type = DRR_BEGIN; in dmu_send_impl()
996 drr->drr_u.drr_begin.drr_magic = DMU_BACKUP_MAGIC; in dmu_send_impl()
997 DMU_SET_STREAM_HDRTYPE(drr->drr_u.drr_begin.drr_versioninfo, in dmu_send_impl()
1004 kmem_free(drr, sizeof (dmu_replay_record_t)); in dmu_send_impl()
1044 DMU_SET_FEATUREFLAGS(drr->drr_u.drr_begin.drr_versioninfo, in dmu_send_impl()
1047 drr->drr_u.drr_begin.drr_creation_time = in dmu_send_impl()
1049 drr->drr_u.drr_begin.drr_type = dmu_objset_type(os); in dmu_send_impl()
1051 drr->drr_u.drr_begin.drr_flags |= DRR_FLAG_CLONE; in dmu_send_impl()
[all …]
|
| H A D | dmu_recv.c | 64 static void byteswap_record(dmu_replay_record_t *drr);
963 byteswap_record(dmu_replay_record_t *drr) in byteswap_record() argument
965 #define DO64(X) (drr->drr_u.X = BSWAP_64(drr->drr_u.X)) in byteswap_record()
966 #define DO32(X) (drr->drr_u.X = BSWAP_32(drr->drr_u.X)) in byteswap_record()
967 drr->drr_type = BSWAP_32(drr->drr_type); in byteswap_record()
968 drr->drr_payloadlen = BSWAP_32(drr->drr_payloadlen); in byteswap_record()
970 switch (drr->drr_type) { in byteswap_record()
1001 ZIO_CHECKSUM_BSWAP(&drr->drr_u.drr_write.drr_key.ddk_cksum); in byteswap_record()
1013 ZIO_CHECKSUM_BSWAP(&drr->drr_u.drr_write_byref. in byteswap_record()
1045 ZIO_CHECKSUM_BSWAP(&drr->drr_u.drr_end.drr_checksum); in byteswap_record()
[all …]
|
| /illumos-gate/usr/src/lib/libzfs_core/common/ |
| H A D | libzfs_core.c | 738 dmu_replay_record_t drr; in recv_impl() local
767 error = recv_read(input_fd, &drr, sizeof (drr)); in recv_impl()
771 drr = *begin_record; in recv_impl()
802 ASSERT3S(drr.drr_type, ==, DRR_BEGIN); in recv_impl()
803 zc.zc_begin_record = drr; in recv_impl()
|
| /illumos-gate/usr/src/test/zfs-tests/cmd/libzfs_input_check/ |
| H A D | libzfs_input_check.c | 536 dmu_replay_record_t drr = { 0 }; in test_recv_new() local
547 count = pread(fd, &drr, sizeof (drr), 0); in test_recv_new()
548 if (count != sizeof (drr)) { in test_recv_new()
554 fnvlist_add_byte_array(required, "begin_record", (uchar_t *)&drr, in test_recv_new()
555 sizeof (drr)); in test_recv_new()
|
| /illumos-gate/usr/src/cmd/truss/ |
| H A D | expound.c | 4803 struct drr_begin *drr = &zc.zc_begin_record.drr_u.drr_begin; in show_zfs_ioc() local
4805 if (drr->drr_magic) { in show_zfs_ioc()
4807 (u_longlong_t)drr->drr_magic); in show_zfs_ioc()
4809 if (drr->drr_versioninfo) { in show_zfs_ioc()
4811 (u_longlong_t)drr->drr_versioninfo); in show_zfs_ioc()
4813 if (drr->drr_creation_time) { in show_zfs_ioc()
4815 (u_longlong_t)drr->drr_creation_time); in show_zfs_ioc()
4817 if (drr->drr_type) in show_zfs_ioc()
4818 (void) printf("\tdrr_type=%u\n", drr->drr_type); in show_zfs_ioc()
4819 if (drr->drr_flags) in show_zfs_ioc()
[all …]
|