1416 do_corrective_recv(struct receive_writer_arg *rwa, struct drr_write *drrw,  in do_corrective_recv()  argument
1431 	err = dnode_hold(rwa->os, drrw->drr_object, FTAG, &dn);  in do_corrective_recv()
1434 	SET_BOOKMARK(&zb, dmu_objset_id(rwa->os), drrw->drr_object, 0,  in do_corrective_recv()
1435 	    dbuf_whichblock(dn, 0, drrw->drr_offset));  in do_corrective_recv()
1438 	if (!rwa->raw && DRR_WRITE_COMPRESSED(drrw)) {  in do_corrective_recv()
1441 		    drrw->drr_logical_size, B_FALSE);  in do_corrective_recv()
1442 		err = zio_decompress_data(drrw->drr_compressiontype,  in do_corrective_recv()
1555 		cb_data->size = drrw->drr_logical_size;  in do_corrective_recv()
1559 		    abd_alloc_for_io(drrw->drr_logical_size, B_FALSE),  in do_corrective_recv()
1560 		    drrw->drr_logical_size, corrective_read_done,  in do_corrective_recv()
2250 		struct drr_write *drrw = &rrd->header.drr_u.drr_write;  in flush_write_batch_impl()  local
2253 		ASSERT3U(drrw->drr_object, ==, rwa->last_object);  in flush_write_batch_impl()
2255 		if (drrw->drr_logical_size != dn->dn_datablksz) {  in flush_write_batch_impl()
2264 			ASSERT3U(drrw->drr_logical_size, >, dn->dn_datablksz);  in flush_write_batch_impl()
2265 			if (DRR_WRITE_COMPRESSED(drrw)) {  in flush_write_batch_impl()
2267 				    abd_alloc_linear(drrw->drr_logical_size,  in flush_write_batch_impl()
2271 				    drrw->drr_compressiontype,  in flush_write_batch_impl()
2278 					    drrw->drr_offset,  in flush_write_batch_impl()
2279 					    drrw->drr_logical_size,  in flush_write_batch_impl()
2285 				    drrw->drr_offset,  in flush_write_batch_impl()
2286 				    drrw->drr_logical_size,  in flush_write_batch_impl()
2299 				zp.zp_compress = drrw->drr_compressiontype;  in flush_write_batch_impl()
2301 				    !!DRR_IS_RAW_BYTESWAPPED(drrw->drr_flags) ^  in flush_write_batch_impl()
2303 				memcpy(zp.zp_salt, drrw->drr_salt,  in flush_write_batch_impl()
2305 				memcpy(zp.zp_iv, drrw->drr_iv,  in flush_write_batch_impl()
2307 				memcpy(zp.zp_mac, drrw->drr_mac,  in flush_write_batch_impl()
2318 			} else if (DRR_WRITE_COMPRESSED(drrw)) {  in flush_write_batch_impl()
2319 				ASSERT3U(drrw->drr_compressed_size, >, 0);  in flush_write_batch_impl()
2320 				ASSERT3U(drrw->drr_logical_size, >=,  in flush_write_batch_impl()
2321 				    drrw->drr_compressed_size);  in flush_write_batch_impl()
2322 				zp.zp_compress = drrw->drr_compressiontype;  in flush_write_batch_impl()
2335 				    DMU_OT_BYTESWAP(drrw->drr_type);  in flush_write_batch_impl()
2338 				    DRR_WRITE_PAYLOAD_SIZE(drrw));  in flush_write_batch_impl()
2347 			    drrw->drr_offset, abd, &zp, zio_flags, tx);  in flush_write_batch_impl()
2364 		save_resume_state(rwa, drrw->drr_object, drrw->drr_offset, tx);  in flush_write_batch_impl()
2401 	struct drr_write *drrw = &rrd->header.drr_u.drr_write;  in receive_process_write_record()  local
2403 	if (drrw->drr_offset + drrw->drr_logical_size < drrw->drr_offset ||  in receive_process_write_record()
2404 	    !DMU_OT_IS_VALID(drrw->drr_type))  in receive_process_write_record()
2417 			    DMU_OT_BYTESWAP(drrw->drr_type);  in receive_process_write_record()
2419 			    DRR_WRITE_PAYLOAD_SIZE(drrw));  in receive_process_write_record()
2422 		err = dmu_buf_hold_noread(rwa->os, drrw->drr_object,  in receive_process_write_record()
2423 		    drrw->drr_offset, FTAG, &dbp);  in receive_process_write_record()
2442 		if (drrw->drr_logical_size != dbp->db_size) {  in receive_process_write_record()
2449 		err = do_corrective_recv(rwa, drrw, rrd, bp);  in receive_process_write_record()
2458 	if (drrw->drr_object < rwa->last_object ||  in receive_process_write_record()
2459 	    (drrw->drr_object == rwa->last_object &&  in receive_process_write_record()
2460 	    drrw->drr_offset < rwa->last_offset)) {  in receive_process_write_record()
2469 	    (drrw->drr_object != first_drrw->drr_object ||  in receive_process_write_record()
2470 	    drrw->drr_offset >= first_drrw->drr_offset + batch_size)) {  in receive_process_write_record()
2476 	rwa->last_object = drrw->drr_object;  in receive_process_write_record()
2477 	rwa->last_offset = drrw->drr_offset;  in receive_process_write_record()
2913 		struct drr_write *drrw = &drc->drc_rrd->header.drr_u.drr_write;  in receive_read_record()  local
2914 		int size = DRR_WRITE_PAYLOAD_SIZE(drrw);  in receive_read_record()
2923 		receive_read_prefetch(drc, drrw->drr_object, drrw->drr_offset,  in receive_read_record()
2924 		    drrw->drr_logical_size);  in receive_read_record()
3017 		struct drr_write *drrw = &rrd->header.drr_u.drr_write;  in dprintf_drr()  local
3021 		    (u_longlong_t)drrw->drr_object, drrw->drr_type,  in dprintf_drr()
3022 		    (u_longlong_t)drrw->drr_offset,  in dprintf_drr()
3023 		    (u_longlong_t)drrw->drr_logical_size,  in dprintf_drr()
3024 		    drrw->drr_checksumtype, drrw->drr_flags,  in dprintf_drr()
3025 		    drrw->drr_compressiontype,  in dprintf_drr()
3026 		    (u_longlong_t)drrw->drr_compressed_size, err);  in dprintf_drr()