Lines Matching defs:rlt_arg
1295 struct redact_list_thread_arg *rlt_arg = arg;
1298 if (rlt_arg->rl != NULL) {
1300 rlcba.cancel = &rlt_arg->cancel;
1301 rlcba.q = &rlt_arg->q;
1302 rlcba.num_blocks_visited = rlt_arg->num_blocks_visited;
1303 rlcba.mark_redact = rlt_arg->mark_redact;
1304 int err = dsl_redaction_list_traverse(rlt_arg->rl,
1305 &rlt_arg->resume, redact_list_cb, &rlcba);
1307 rlt_arg->error_code = err;
1310 bqueue_enqueue_flush(&rlt_arg->q, record, sizeof (*record));
2118 setup_redact_list_thread(struct redact_list_thread_arg *rlt_arg,
2124 rlt_arg->cancel = B_FALSE;
2125 VERIFY0(bqueue_init(&rlt_arg->q, zfs_send_no_prefetch_queue_ff,
2128 rlt_arg->error_code = 0;
2129 rlt_arg->mark_redact = B_TRUE;
2130 rlt_arg->rl = rl;
2131 rlt_arg->num_blocks_visited = &dssp->dss_blocks;
2133 (void) thread_create(NULL, 0, redact_list_thread, rlt_arg, 0,
2140 struct send_thread_arg *to_arg, struct redact_list_thread_arg *rlt_arg,
2151 smt_arg->redact_arg = rlt_arg;
2176 struct redact_list_thread_arg *rlt_arg,
2200 SET_BOOKMARK(&rlt_arg->resume, to_ds->ds_object, obj, 0, blkid);
2373 struct redact_list_thread_arg *rlt_arg;
2456 rlt_arg = kmem_zalloc(sizeof (*rlt_arg), KM_SLEEP);
2528 rlt_arg, smt_arg, resuming, os, redact_rl, nvl);
2564 setup_redact_list_thread(rlt_arg, dspp, redact_rl, dssp);
2565 setup_merge_thread(smt_arg, dspp, from_arg, to_arg, rlt_arg, os);
2593 bqueue_destroy(&rlt_arg->q);
2639 kmem_free(rlt_arg, sizeof (*rlt_arg));