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()
2287 				    drrw->drr_offset,  in flush_write_batch_impl()
2288 				    drrw->drr_logical_size,  in flush_write_batch_impl()
2303 				zp.zp_compress = drrw->drr_compressiontype;  in flush_write_batch_impl()
2305 				    !!DRR_IS_RAW_BYTESWAPPED(drrw->drr_flags) ^  in flush_write_batch_impl()
2307 				memcpy(zp.zp_salt, drrw->drr_salt,  in flush_write_batch_impl()
2309 				memcpy(zp.zp_iv, drrw->drr_iv,  in flush_write_batch_impl()
2311 				memcpy(zp.zp_mac, drrw->drr_mac,  in flush_write_batch_impl()
2322 			} else if (DRR_WRITE_COMPRESSED(drrw)) {  in flush_write_batch_impl()
2323 				ASSERT3U(drrw->drr_compressed_size, >, 0);  in flush_write_batch_impl()
2324 				ASSERT3U(drrw->drr_logical_size, >=,  in flush_write_batch_impl()
2325 				    drrw->drr_compressed_size);  in flush_write_batch_impl()
2326 				zp.zp_compress = drrw->drr_compressiontype;  in flush_write_batch_impl()
2339 				    DMU_OT_BYTESWAP(drrw->drr_type);  in flush_write_batch_impl()
2342 				    DRR_WRITE_PAYLOAD_SIZE(drrw));  in flush_write_batch_impl()
2351 			    drrw->drr_offset, abd, &zp, zio_flags, tx);  in flush_write_batch_impl()
2368 		save_resume_state(rwa, drrw->drr_object, drrw->drr_offset, tx);  in flush_write_batch_impl()
2405 	struct drr_write *drrw = &rrd->header.drr_u.drr_write;  in receive_process_write_record()  local
2407 	if (drrw->drr_offset + drrw->drr_logical_size < drrw->drr_offset ||  in receive_process_write_record()
2408 	    !DMU_OT_IS_VALID(drrw->drr_type))  in receive_process_write_record()
2421 			    DMU_OT_BYTESWAP(drrw->drr_type);  in receive_process_write_record()
2423 			    DRR_WRITE_PAYLOAD_SIZE(drrw));  in receive_process_write_record()
2426 		err = dmu_buf_hold_noread(rwa->os, drrw->drr_object,  in receive_process_write_record()
2427 		    drrw->drr_offset, FTAG, &dbp);  in receive_process_write_record()
2446 		if (drrw->drr_logical_size != dbp->db_size) {  in receive_process_write_record()
2453 		err = do_corrective_recv(rwa, drrw, rrd, bp);  in receive_process_write_record()
2462 	if (drrw->drr_object < rwa->last_object ||  in receive_process_write_record()
2463 	    (drrw->drr_object == rwa->last_object &&  in receive_process_write_record()
2464 	    drrw->drr_offset < rwa->last_offset)) {  in receive_process_write_record()
2473 	    (drrw->drr_object != first_drrw->drr_object ||  in receive_process_write_record()
2474 	    drrw->drr_offset >= first_drrw->drr_offset + batch_size)) {  in receive_process_write_record()
2480 	rwa->last_object = drrw->drr_object;  in receive_process_write_record()
2481 	rwa->last_offset = drrw->drr_offset;  in receive_process_write_record()
2918 		struct drr_write *drrw = &drc->drc_rrd->header.drr_u.drr_write;  in receive_read_record()  local
2919 		int size = DRR_WRITE_PAYLOAD_SIZE(drrw);  in receive_read_record()
2928 		receive_read_prefetch(drc, drrw->drr_object, drrw->drr_offset,  in receive_read_record()
2929 		    drrw->drr_logical_size);  in receive_read_record()
3022 		struct drr_write *drrw = &rrd->header.drr_u.drr_write;  in dprintf_drr()  local
3026 		    (u_longlong_t)drrw->drr_object, drrw->drr_type,  in dprintf_drr()
3027 		    (u_longlong_t)drrw->drr_offset,  in dprintf_drr()
3028 		    (u_longlong_t)drrw->drr_logical_size,  in dprintf_drr()
3029 		    drrw->drr_checksumtype, drrw->drr_flags,  in dprintf_drr()
3030 		    drrw->drr_compressiontype,  in dprintf_drr()
3031 		    (u_longlong_t)drrw->drr_compressed_size, err);  in dprintf_drr()