Searched refs:front_ranges (Results 1 – 1 of 1) sorted by relevance
1492 struct send_range *front_ranges[NUM_THREADS]; in send_merge_thread() local1498 front_ranges[REDACT_IDX] = in send_merge_thread()1500 front_ranges[REDACT_IDX]->eos_marker = B_TRUE; in send_merge_thread()1501 front_ranges[REDACT_IDX]->type = REDACT; in send_merge_thread()1504 front_ranges[REDACT_IDX] = in send_merge_thread()1508 front_ranges[TO_IDX] = bqueue_dequeue(&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()1514 for (range = find_next_range(front_ranges, queues, &mask); in send_merge_thread()1516 range = find_next_range(front_ranges, queues, &mask)) { in send_merge_thread()1549 while (!front_ranges[i]->eos_marker) { in send_merge_thread()[all …]