Lines Matching defs:smt_arg
1490 struct send_merge_thread_arg *smt_arg = arg;
1496 if (smt_arg->redact_arg == NULL) {
1504 bqueue_dequeue(&smt_arg->redact_arg->q);
1505 queues[REDACT_IDX] = &smt_arg->redact_arg->q;
1507 front_ranges[TO_IDX] = bqueue_dequeue(&smt_arg->to_arg->q);
1508 queues[TO_IDX] = &smt_arg->to_arg->q;
1509 front_ranges[FROM_IDX] = bqueue_dequeue(&smt_arg->from_arg->q);
1510 queues[FROM_IDX] = &smt_arg->from_arg->q;
1514 !range->eos_marker && err == 0 && !smt_arg->cancel;
1527 bqueue_enqueue(&smt_arg->q, range, sizeof (*range));
1529 if (smt_arg->to_arg->error_code != 0) {
1530 err = smt_arg->to_arg->error_code;
1531 } else if (smt_arg->from_arg->error_code != 0) {
1532 err = smt_arg->from_arg->error_code;
1533 } else if (smt_arg->redact_arg != NULL &&
1534 smt_arg->redact_arg->error_code != 0) {
1535 err = smt_arg->redact_arg->error_code;
1538 if (smt_arg->cancel && err == 0)
1540 smt_arg->error = err;
1541 if (smt_arg->error != 0) {
1542 smt_arg->to_arg->cancel = B_TRUE;
1543 smt_arg->from_arg->cancel = B_TRUE;
1544 if (smt_arg->redact_arg != NULL)
1545 smt_arg->redact_arg->cancel = B_TRUE;
1555 bqueue_enqueue_flush(&smt_arg->q, range, 1);
2138 setup_merge_thread(struct send_merge_thread_arg *smt_arg,
2143 VERIFY0(bqueue_init(&smt_arg->q, zfs_send_no_prefetch_queue_ff,
2146 smt_arg->cancel = B_FALSE;
2147 smt_arg->error = 0;
2148 smt_arg->from_arg = from_arg;
2149 smt_arg->to_arg = to_arg;
2151 smt_arg->redact_arg = rlt_arg;
2153 smt_arg->os = os;
2154 (void) thread_create(NULL, 0, send_merge_thread, smt_arg, 0, curproc,
2160 struct dmu_send_params *dspp, struct send_merge_thread_arg *smt_arg,
2166 srt_arg->smta = smt_arg;
2177 struct send_merge_thread_arg *smt_arg, boolean_t resuming, objset_t *os,
2180 (void) smt_arg;
2374 struct send_merge_thread_arg *smt_arg;
2457 smt_arg = kmem_zalloc(sizeof (*smt_arg), KM_SLEEP);
2528 rlt_arg, smt_arg, resuming, os, redact_rl, nvl);
2565 setup_merge_thread(smt_arg, dspp, from_arg, to_arg, rlt_arg, os);
2566 setup_reader_thread(srt_arg, dspp, smt_arg, featureflags);
2591 bqueue_destroy(&smt_arg->q);
2640 kmem_free(smt_arg, sizeof (*smt_arg));