Lines Matching refs:drrw

1502 receive_write(struct receive_writer_arg *rwa, struct drr_write *drrw,  in receive_write()  argument
1509 if (drrw->drr_offset + drrw->drr_logical_size < drrw->drr_offset || in receive_write()
1510 !DMU_OT_IS_VALID(drrw->drr_type)) in receive_write()
1517 if (drrw->drr_object < rwa->last_object || in receive_write()
1518 (drrw->drr_object == rwa->last_object && in receive_write()
1519 drrw->drr_offset < rwa->last_offset)) { in receive_write()
1522 rwa->last_object = drrw->drr_object; in receive_write()
1523 rwa->last_offset = drrw->drr_offset; in receive_write()
1528 if (dmu_object_info(rwa->os, drrw->drr_object, NULL) != 0) in receive_write()
1532 dmu_tx_hold_write(tx, drrw->drr_object, in receive_write()
1533 drrw->drr_offset, drrw->drr_logical_size); in receive_write()
1543 DMU_OT_BYTESWAP(drrw->drr_type); in receive_write()
1545 DRR_WRITE_PAYLOAD_SIZE(drrw)); in receive_write()
1548 VERIFY0(dnode_hold(rwa->os, drrw->drr_object, FTAG, &dn)); in receive_write()
1549 err = dmu_assign_arcbuf_by_dnode(dn, drrw->drr_offset, abuf, tx); in receive_write()
1563 save_resume_state(rwa, drrw->drr_object, drrw->drr_offset, tx); in receive_write()
2095 struct drr_write *drrw = &ra->rrd->header.drr_u.drr_write; in receive_read_record() local
2097 boolean_t is_meta = DMU_OT_IS_METADATA(drrw->drr_type); in receive_read_record()
2101 !!DRR_IS_RAW_BYTESWAPPED(drrw->drr_flags) ^ in receive_read_record()
2105 drrw->drr_object, byteorder, drrw->drr_salt, in receive_read_record()
2106 drrw->drr_iv, drrw->drr_mac, drrw->drr_type, in receive_read_record()
2107 drrw->drr_compressed_size, drrw->drr_logical_size, in receive_read_record()
2108 drrw->drr_compressiontype); in receive_read_record()
2109 } else if (DRR_WRITE_COMPRESSED(drrw)) { in receive_read_record()
2110 ASSERT3U(drrw->drr_compressed_size, >, 0); in receive_read_record()
2111 ASSERT3U(drrw->drr_logical_size, >=, in receive_read_record()
2112 drrw->drr_compressed_size); in receive_read_record()
2116 drrw->drr_compressed_size, drrw->drr_logical_size, in receive_read_record()
2117 drrw->drr_compressiontype); in receive_read_record()
2120 is_meta, drrw->drr_logical_size); in receive_read_record()
2124 DRR_WRITE_PAYLOAD_SIZE(drrw), abuf->b_data); in receive_read_record()
2130 receive_read_prefetch(ra, drrw->drr_object, drrw->drr_offset, in receive_read_record()
2131 drrw->drr_logical_size); in receive_read_record()
2248 struct drr_write *drrw = &rrd->header.drr_u.drr_write; in receive_process_record() local
2249 err = receive_write(rwa, drrw, rrd->arc_buf); in receive_process_record()