Lines Matching defs:srta

1588 issue_data_read(struct send_reader_thread_arg *srta, struct send_range *range)
1592 	objset_t *os = srta->smta->os;
1604 	    !(srta->featureflags & DMU_BACKUP_FEATURE_LARGE_BLOCKS);
1616 	    (srta->featureflags & DMU_BACKUP_FEATURE_COMPRESSED) &&
1622 	if (srta->featureflags & DMU_BACKUP_FEATURE_RAW) {
1633 	if (!srta->issue_reads)
1637 	if (send_do_embed(bp, srta->featureflags))
1671 enqueue_range(struct send_reader_thread_arg *srta, bqueue_t *q, dnode_t *dn,
1694 		issue_data_read(srta, range);
1718 piggyback_unmodified_spill(struct send_reader_thread_arg *srta,
1724 	uint64_t fromtxg = srta->smta->to_arg->fromtxg;
1738 	issue_data_read(srta, spill_range);
1754 	struct send_reader_thread_arg *srta = arg;
1755 	struct send_merge_thread_arg *smta = srta->smta;
1757 	bqueue_t *outq = &srta->q;
1773 	while (!range->eos_marker && !srta->cancel && smta->error == 0 &&
1778 			issue_data_read(srta, range);
1783 			spill = piggyback_unmodified_spill(srta, range);
1884 					enqueue_range(srta, outq, dn, blkid,
1895 				enqueue_range(srta, outq, dn, blkid, 1, &bp,
1904 	if (srta->cancel || err != 0) {
1906 		srta->error = err;
1908 		srta->error = smta->error;