Searched refs:front_ranges (Results 1 – 1 of 1) sorted by relevance
1531 struct send_range *front_ranges[NUM_THREADS]; in send_merge_thread() local1537 front_ranges[REDACT_IDX] = in send_merge_thread()1539 front_ranges[REDACT_IDX]->eos_marker = B_TRUE; in send_merge_thread()1540 front_ranges[REDACT_IDX]->type = REDACT; in send_merge_thread()1543 front_ranges[REDACT_IDX] = in send_merge_thread()1547 front_ranges[TO_IDX] = bqueue_dequeue(&smt_arg->to_arg->q); in send_merge_thread()1553 for (range = find_next_range(front_ranges, queues, &mask); in send_merge_thread()1588 while (!front_ranges[i]->eos_marker) { in send_merge_thread()1589 front_ranges[i] = get_next_range(queues[i], in send_merge_thread()1590 front_ranges[i]); in send_merge_thread()[all …]