Searched refs:cur_stream (Results 1 – 1 of 1) sorted by relevance
321 stream_t *cur_stream; in internal_sort() local343 cur_stream = S->m_input_streams; in internal_sort()344 while (cur_stream != NULL) { in internal_sort()345 if (!(cur_stream->s_status & STREAM_OPEN)) { in internal_sort()346 if (stream_open_for_read(S, cur_stream) == -1) in internal_sort()350 if (cur_stream->s_status & STREAM_MMAP) { in internal_sort()355 stream_set_size(cur_stream, input_mem); in internal_sort()360 currently_primed = SOP_PRIME(cur_stream); in internal_sort()376 stream_insert(S, cur_stream, sort_stream); in internal_sort()382 if (SOP_EOS(cur_stream)) { in internal_sort()[all …]