2789 		if (drc->drc_rrd != NULL) {  in receive_read_payload_and_next_header()
2790 			drc->drc_rrd->payload = buf;  in receive_read_payload_and_next_header()
2791 			drc->drc_rrd->payload_size = len;  in receive_read_payload_and_next_header()
2792 			drc->drc_rrd->bytes_read = drc->drc_bytes_read;  in receive_read_payload_and_next_header()
2881 	switch (drc->drc_rrd->header.drr_type) {  in receive_read_record()
2885 		    &drc->drc_rrd->header.drr_u.drr_object;  in receive_read_record()
2918 		struct drr_write *drrw = &drc->drc_rrd->header.drr_u.drr_write;  in receive_read_record()
2927 		drc->drc_rrd->abd = abd;  in receive_read_record()
2935 		    &drc->drc_rrd->header.drr_u.drr_write_embedded;  in receive_read_record()
2961 		struct drr_end *drre = &drc->drc_rrd->header.drr_u.drr_end;  in receive_read_record()
2969 		struct drr_spill *drrs = &drc->drc_rrd->header.drr_u.drr_spill;  in receive_read_record()
2977 			drc->drc_rrd->abd = abd;  in receive_read_record()
3453 		ASSERT3P(drc->drc_rrd, ==, NULL);  in dmu_recv_stream()
3454 		drc->drc_rrd = drc->drc_next_rrd;  in dmu_recv_stream()
3459 		if (drc->drc_rrd->header.drr_type == DRR_END || err != 0) {  in dmu_recv_stream()
3460 			kmem_free(drc->drc_rrd, sizeof (*drc->drc_rrd));  in dmu_recv_stream()
3461 			drc->drc_rrd = NULL;  in dmu_recv_stream()
3465 		bqueue_enqueue(&rwa->q, drc->drc_rrd,  in dmu_recv_stream()
3467 		    drc->drc_rrd->payload_size);  in dmu_recv_stream()
3468 		drc->drc_rrd = NULL;  in dmu_recv_stream()
3471 	ASSERT3P(drc->drc_rrd, ==, NULL);  in dmu_recv_stream()
3472 	drc->drc_rrd = kmem_zalloc(sizeof (*drc->drc_rrd), KM_SLEEP);  in dmu_recv_stream()
3473 	drc->drc_rrd->eos_marker = B_TRUE;  in dmu_recv_stream()
3474 	bqueue_enqueue_flush(&rwa->q, drc->drc_rrd, 1);  in dmu_recv_stream()