Searched refs:cur_stream (Results 1 – 1 of 1) sorted by relevance
323 stream_t *cur_stream; in internal_sort() local345 cur_stream = S->m_input_streams; in internal_sort()346 while (cur_stream != NULL) { in internal_sort()347 if (!(cur_stream->s_status & STREAM_OPEN)) { in internal_sort()348 if (stream_open_for_read(S, cur_stream) == -1) in internal_sort()352 if (cur_stream->s_status & STREAM_MMAP) { in internal_sort()357 stream_set_size(cur_stream, input_mem); in internal_sort()362 currently_primed = SOP_PRIME(cur_stream); in internal_sort()378 stream_insert(S, cur_stream, sort_stream); in internal_sort()384 if (SOP_EOS(cur_stream)) { in internal_sort()[all …]