Lines Matching refs:rlt_arg
1296 struct redact_list_thread_arg *rlt_arg = arg; in redact_list_thread() local
1299 if (rlt_arg->rl != NULL) { in redact_list_thread()
1301 rlcba.cancel = &rlt_arg->cancel; in redact_list_thread()
1302 rlcba.q = &rlt_arg->q; in redact_list_thread()
1303 rlcba.num_blocks_visited = rlt_arg->num_blocks_visited; in redact_list_thread()
1304 rlcba.mark_redact = rlt_arg->mark_redact; in redact_list_thread()
1305 int err = dsl_redaction_list_traverse(rlt_arg->rl, in redact_list_thread()
1306 &rlt_arg->resume, redact_list_cb, &rlcba); in redact_list_thread()
1308 rlt_arg->error_code = err; in redact_list_thread()
1311 bqueue_enqueue_flush(&rlt_arg->q, record, sizeof (*record)); in redact_list_thread()
2119 setup_redact_list_thread(struct redact_list_thread_arg *rlt_arg, in setup_redact_list_thread() argument
2125 rlt_arg->cancel = B_FALSE; in setup_redact_list_thread()
2126 VERIFY0(bqueue_init(&rlt_arg->q, zfs_send_no_prefetch_queue_ff, in setup_redact_list_thread()
2129 rlt_arg->error_code = 0; in setup_redact_list_thread()
2130 rlt_arg->mark_redact = B_TRUE; in setup_redact_list_thread()
2131 rlt_arg->rl = rl; in setup_redact_list_thread()
2132 rlt_arg->num_blocks_visited = &dssp->dss_blocks; in setup_redact_list_thread()
2134 (void) thread_create(NULL, 0, redact_list_thread, rlt_arg, 0, in setup_redact_list_thread()
2141 struct send_thread_arg *to_arg, struct redact_list_thread_arg *rlt_arg, in setup_merge_thread() argument
2152 smt_arg->redact_arg = rlt_arg; in setup_merge_thread()
2177 struct redact_list_thread_arg *rlt_arg, in setup_resume_points() argument
2201 SET_BOOKMARK(&rlt_arg->resume, to_ds->ds_object, obj, 0, blkid); in setup_resume_points()
2374 struct redact_list_thread_arg *rlt_arg; in dmu_send_impl() local
2457 rlt_arg = kmem_zalloc(sizeof (*rlt_arg), KM_SLEEP); in dmu_send_impl()
2529 rlt_arg, smt_arg, resuming, os, redact_rl, nvl); in dmu_send_impl()
2565 setup_redact_list_thread(rlt_arg, dspp, redact_rl, dssp); in dmu_send_impl()
2566 setup_merge_thread(smt_arg, dspp, from_arg, to_arg, rlt_arg, os); in dmu_send_impl()
2594 bqueue_destroy(&rlt_arg->q); in dmu_send_impl()
2640 kmem_free(rlt_arg, sizeof (*rlt_arg)); in dmu_send_impl()