Lines Matching defs:srt_arg

2159 setup_reader_thread(struct send_reader_thread_arg *srt_arg,
2163 	VERIFY0(bqueue_init(&srt_arg->q, zfs_send_queue_ff,
2166 	srt_arg->smta = smt_arg;
2167 	srt_arg->issue_reads = !dspp->dso->dso_dryrun;
2168 	srt_arg->featureflags = featureflags;
2169 	(void) thread_create(NULL, 0, send_reader_thread, srt_arg, 0,
2375 	struct send_reader_thread_arg *srt_arg;
2458 	srt_arg = kmem_zalloc(sizeof (*srt_arg), KM_SLEEP);
2566 	setup_reader_thread(srt_arg, dspp, smt_arg, featureflags);
2568 	range = bqueue_dequeue(&srt_arg->q);
2571 		range = get_next_range(&srt_arg->q, range);
2583 		srt_arg->cancel = B_TRUE;
2585 			range = get_next_range(&srt_arg->q, range);
2590 	bqueue_destroy(&srt_arg->q);
2597 	if (err == 0 && srt_arg->error != 0)
2598 		err = srt_arg->error;
2641 	kmem_free(srt_arg, sizeof (*srt_arg));