Searched refs:smt_arg (Results 1 – 1 of 1) sorted by relevance
1491 struct send_merge_thread_arg *smt_arg = arg; in send_merge_thread() local1497 if (smt_arg->redact_arg == NULL) { in send_merge_thread()1505 bqueue_dequeue(&smt_arg->redact_arg->q); in send_merge_thread()1506 queues[REDACT_IDX] = &smt_arg->redact_arg->q; in send_merge_thread()1508 front_ranges[TO_IDX] = bqueue_dequeue(&smt_arg->to_arg->q); in send_merge_thread()1509 queues[TO_IDX] = &smt_arg->to_arg->q; in send_merge_thread()1510 front_ranges[FROM_IDX] = bqueue_dequeue(&smt_arg->from_arg->q); in send_merge_thread()1511 queues[FROM_IDX] = &smt_arg->from_arg->q; in send_merge_thread()1515 !range->eos_marker && err == 0 && !smt_arg->cancel; in send_merge_thread()1528 bqueue_enqueue(&smt_arg->q, range, sizeof (*range)); in send_merge_thread()[all …]