Lines Matching defs:from_arg
142 struct redact_list_thread_arg *from_arg;
1509 front_ranges[FROM_IDX] = bqueue_dequeue(&smt_arg->from_arg->q);
1510 queues[FROM_IDX] = &smt_arg->from_arg->q;
1531 } else if (smt_arg->from_arg->error_code != 0) {
1532 err = smt_arg->from_arg->error_code;
1543 smt_arg->from_arg->cancel = B_TRUE;
2098 setup_from_thread(struct redact_list_thread_arg *from_arg,
2101 VERIFY0(bqueue_init(&from_arg->q, zfs_send_no_prefetch_queue_ff,
2104 from_arg->error_code = 0;
2105 from_arg->cancel = B_FALSE;
2106 from_arg->rl = from_rl;
2107 from_arg->mark_redact = B_FALSE;
2108 from_arg->num_blocks_visited = &dssp->dss_blocks;
2113 (void) thread_create(NULL, 0, redact_list_thread, from_arg, 0,
2139 struct dmu_send_params *dspp, struct redact_list_thread_arg *from_arg,
2148 smt_arg->from_arg = from_arg;
2175 struct send_thread_arg *to_arg, struct redact_list_thread_arg *from_arg,
2221 SET_BOOKMARK(&from_arg->resume, objset, obj, 0, blkid);
2371 struct redact_list_thread_arg *from_arg;
2454 from_arg = kmem_zalloc(sizeof (*from_arg), KM_SLEEP);
2527 err = setup_resume_points(dspp, to_arg, from_arg,
2563 setup_from_thread(from_arg, from_rl, dssp);
2565 setup_merge_thread(smt_arg, dspp, from_arg, to_arg, rlt_arg, os);
2595 bqueue_destroy(&from_arg->q);
2637 kmem_free(from_arg, sizeof (*from_arg));