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()
60 cur_streamp->s_status & STREAM_WIDE) in convert()
63 SOP_PRIME(cur_streamp); in convert()
78 cur_streamp->s_current.l_data.wp); in convert()
88 if (SOP_EOS(cur_streamp)) in convert()
91 SOP_FETCH(cur_streamp); in convert()
94 (void) SOP_FREE(cur_streamp); in convert()
95 (void) SOP_CLOSE(cur_streamp); in convert()
[all …]
H A Dcheck.c124 if (SOP_EOS(cur_streamp)) 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()
145 stream_set_size(cur_streamp, input_mem); in check_if_sorted()
153 if (SOP_PRIME(cur_streamp) > 1) in check_if_sorted()
164 * cur_streamp->s_element_size; in check_if_sorted()
170 cur_streamp->s_element_size; in check_if_sorted()
182 while (!SOP_EOS(cur_streamp)) { in check_if_sorted()
183 (void) SOP_FETCH(cur_streamp); in check_if_sorted()
202 fail_check(&cur_streamp->s_current, 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()
350 SOP_EOS(cur_streamp)) { in merge_n_streams()
379 if (!SOP_EOS(cur_streamp)) { in merge_n_streams()
380 SOP_FETCH(cur_streamp); in merge_n_streams()
388 cur_streamp = top_streamp; in merge_n_streams()
394 (void) SOP_FREE(cur_streamp); in merge_n_streams()
398 cur_streamp = cur_streamp->s_next; in merge_n_streams()
427 stream_t *cur_streamp; in merge() local
[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()
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
428 while (cur_streamp != NULL) { in stream_close_all_previous()
429 (void) SOP_FREE(cur_streamp); in stream_close_all_previous()
430 if (SOP_IS_CLOSABLE(cur_streamp)) in stream_close_all_previous()
431 (void) SOP_CLOSE(cur_streamp); in stream_close_all_previous()
[all …]