143 	struct redact_list_thread_arg	*from_arg;  member
1510 	front_ranges[FROM_IDX] = bqueue_dequeue(&smt_arg->from_arg->q);  in send_merge_thread()
1511 	queues[FROM_IDX] = &smt_arg->from_arg->q;  in send_merge_thread()
1532 		} else if (smt_arg->from_arg->error_code != 0) {  in send_merge_thread()
1533 			err = smt_arg->from_arg->error_code;  in send_merge_thread()
1544 		smt_arg->from_arg->cancel = B_TRUE;  in send_merge_thread()
2099 setup_from_thread(struct redact_list_thread_arg *from_arg,  in setup_from_thread()  argument
2102 	VERIFY0(bqueue_init(&from_arg->q, zfs_send_no_prefetch_queue_ff,  in setup_from_thread()
2105 	from_arg->error_code = 0;  in setup_from_thread()
2106 	from_arg->cancel = B_FALSE;  in setup_from_thread()
2107 	from_arg->rl = from_rl;  in setup_from_thread()
2108 	from_arg->mark_redact = B_FALSE;  in setup_from_thread()
2109 	from_arg->num_blocks_visited = &dssp->dss_blocks;  in setup_from_thread()
2114 	(void) thread_create(NULL, 0, redact_list_thread, from_arg, 0,  in setup_from_thread()
2140     struct dmu_send_params *dspp, struct redact_list_thread_arg *from_arg,  in setup_merge_thread()  argument
2149 	smt_arg->from_arg = from_arg;  in setup_merge_thread()
2176     struct send_thread_arg *to_arg, struct redact_list_thread_arg *from_arg,  in setup_resume_points()  argument
2222 		SET_BOOKMARK(&from_arg->resume, objset, obj, 0, blkid);  in setup_resume_points()
2372 	struct redact_list_thread_arg *from_arg;  in dmu_send_impl()  local
2455 	from_arg = kmem_zalloc(sizeof (*from_arg), KM_SLEEP);  in dmu_send_impl()
2528 		err = setup_resume_points(dspp, to_arg, from_arg,  in dmu_send_impl()
2564 	setup_from_thread(from_arg, from_rl, dssp);  in dmu_send_impl()
2566 	setup_merge_thread(smt_arg, dspp, from_arg, to_arg, rlt_arg, os);  in dmu_send_impl()
2596 	bqueue_destroy(&from_arg->q);  in dmu_send_impl()
2638 	kmem_free(from_arg, sizeof (*from_arg));  in dmu_send_impl()