Lines Matching defs:to_arg
143 struct send_thread_arg *to_arg;
1507 front_ranges[TO_IDX] = bqueue_dequeue(&smt_arg->to_arg->q);
1508 queues[TO_IDX] = &smt_arg->to_arg->q;
1529 if (smt_arg->to_arg->error_code != 0) {
1530 err = smt_arg->to_arg->error_code;
1542 smt_arg->to_arg->cancel = B_TRUE;
1724 uint64_t fromtxg = srta->smta->to_arg->fromtxg;
2077 setup_to_thread(struct send_thread_arg *to_arg, objset_t *to_os,
2080 VERIFY0(bqueue_init(&to_arg->q, zfs_send_no_prefetch_queue_ff,
2083 to_arg->error_code = 0;
2084 to_arg->cancel = B_FALSE;
2085 to_arg->os = to_os;
2086 to_arg->fromtxg = fromtxg;
2087 to_arg->flags = TRAVERSE_PRE | TRAVERSE_PREFETCH_METADATA;
2089 to_arg->flags |= TRAVERSE_NO_DECRYPT;
2091 to_arg->flags |= TRAVERSE_HARD;
2092 to_arg->num_blocks_visited = &dssp->dss_blocks;
2093 (void) thread_create(NULL, 0, send_traverse_thread, to_arg, 0,
2140 struct send_thread_arg *to_arg, struct redact_list_thread_arg *rlt_arg,
2149 smt_arg->to_arg = to_arg;
2175 struct send_thread_arg *to_arg, struct redact_list_thread_arg *from_arg,
2203 SET_BOOKMARK(&to_arg->resume, to_ds->ds_object, obj, 0, blkid);
2372 struct send_thread_arg *to_arg;
2455 to_arg = kmem_zalloc(sizeof (*to_arg), KM_SLEEP);
2527 err = setup_resume_points(dspp, to_arg, from_arg,
2562 setup_to_thread(to_arg, os, dssp, fromtxg, dspp->rawok);
2565 setup_merge_thread(smt_arg, dspp, from_arg, to_arg, rlt_arg, os);
2594 bqueue_destroy(&to_arg->q);
2638 kmem_free(to_arg, sizeof (*to_arg));