Home
last modified time | relevance | path

Searched refs:cur_streamp (Results 1 – 4 of 4) sorted by relevance

/illumos-gate/usr/src/cmd/sort/
H A Dconvert.c41 stream_t *cur_streamp = convert_chain; in convert() local
55 while (cur_streamp != NULL) { in convert()
58 stream_open_for_read(S, cur_streamp); in convert()
59 if (cur_streamp->s_status & STREAM_SINGLE || in convert()
60 cur_streamp->s_status & STREAM_WIDE) in convert()
61 stream_set(cur_streamp, STREAM_INSTANT); in convert()
63 SOP_PRIME(cur_streamp); in convert()
65 cur_streamp->s_current.l_collate.sp = safe_realloc(NULL, in convert()
67 cur_streamp->s_current.l_collate_bufsize = COLLATE_BUFSIZE; in convert()
71 &cur_streamp->s_current, FCV_REALLOC, in convert()
[all …]
H A Dcheck.c112 stream_t *cur_streamp = S->m_input_streams; in check_if_sorted() local
121 if (stream_open_for_read(S, cur_streamp) > 1) in check_if_sorted()
124 if (SOP_EOS(cur_streamp)) in check_if_sorted()
133 swap_required = !(cur_streamp->s_status & STREAM_MMAP); in check_if_sorted()
135 stream_set(cur_streamp, STREAM_INSTANT); in check_if_sorted()
143 stream_set_size(cur_streamp, input_mem); in check_if_sorted()
144 stream_swap_buffer(cur_streamp, &data_buffer, &data_bufsize); in check_if_sorted()
145 stream_set_size(cur_streamp, input_mem); in check_if_sorted()
147 if (cur_streamp->s_status & STREAM_WIDE) { in check_if_sorted()
153 if (SOP_PRIME(cur_streamp) > 1) in check_if_sorted()
[all …]
H A Dmerge.c285 stream_t *cur_streamp; in merge_n_streams() local
344 for (cur_streamp = top_streamp; cur_streamp != bot_streamp; in merge_n_streams()
345 cur_streamp = cur_streamp->s_next) { in merge_n_streams()
349 if (!(cur_streamp->s_status & STREAM_ARRAY) && in merge_n_streams()
350 SOP_EOS(cur_streamp)) { in merge_n_streams()
351 stream_unlink_temporary(cur_streamp); in merge_n_streams()
359 if (SOP_PRIME(cur_streamp) != PRIME_SUCCEEDED) in merge_n_streams()
362 cur_streamp->s_current.l_collate_bufsize = in merge_n_streams()
364 cur_streamp->s_current.l_collate.sp = in merge_n_streams()
367 &cur_streamp->s_current, FCV_REALLOC, in merge_n_streams()
[all …]
H A Dstreams.c318 stream_t *cur_streamp = *str_chain; in stream_push_to_chain() local
320 if (cur_streamp == NULL) { in stream_push_to_chain()
326 while (cur_streamp->s_next != NULL) in stream_push_to_chain()
327 cur_streamp = cur_streamp->s_next; in stream_push_to_chain()
329 cur_streamp->s_next = streamp; in stream_push_to_chain()
330 streamp->s_previous = cur_streamp; in stream_push_to_chain()
423 stream_t *cur_streamp; in stream_close_all_previous() local
427 cur_streamp = tail_streamp->s_previous; in stream_close_all_previous()
428 while (cur_streamp != NULL) { in stream_close_all_previous()
429 (void) SOP_FREE(cur_streamp); in stream_close_all_previous()
[all …]