Searched refs:front_ranges (Results 1 – 1 of 1) sorted by relevance
1516 struct send_range *front_ranges[NUM_THREADS]; in send_merge_thread() local1522 front_ranges[REDACT_IDX] = in send_merge_thread()1524 front_ranges[REDACT_IDX]->eos_marker = B_TRUE; in send_merge_thread()1525 front_ranges[REDACT_IDX]->type = REDACT; in send_merge_thread()1528 front_ranges[REDACT_IDX] = in send_merge_thread()1532 front_ranges[TO_IDX] = bqueue_dequeue(&smt_arg->to_arg->q); in send_merge_thread()1538 for (range = find_next_range(front_ranges, queues, &mask); in send_merge_thread()1573 while (!front_ranges[i]->eos_marker) { in send_merge_thread()1574 front_ranges[i] = get_next_range(queues[i], in send_merge_thread()1575 front_ranges[i]); in send_merge_thread()[all …]