Home
last modified time | relevance | path

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

/titanic_50/usr/src/cmd/sort/common/
H A Dconvert.c43 stream_t *cur_streamp = convert_chain; in convert() local
57 while (cur_streamp != NULL) { in convert()
60 stream_open_for_read(S, cur_streamp); in convert()
61 if (cur_streamp->s_status & STREAM_SINGLE || in convert()
62 cur_streamp->s_status & STREAM_WIDE) in convert()
63 stream_set(cur_streamp, STREAM_INSTANT); in convert()
65 SOP_PRIME(cur_streamp); in convert()
67 cur_streamp->s_current.l_collate.sp = safe_realloc(NULL, in convert()
69 cur_streamp->s_current.l_collate_bufsize = COLLATE_BUFSIZE; in convert()
73 &cur_streamp->s_current, FCV_REALLOC, in convert()
[all …]
H A Dcheck.c114 stream_t *cur_streamp = S->m_input_streams; in check_if_sorted() local
123 if (stream_open_for_read(S, cur_streamp) > 1) in check_if_sorted()
126 if (SOP_EOS(cur_streamp)) in check_if_sorted()
135 swap_required = !(cur_streamp->s_status & STREAM_MMAP); in check_if_sorted()
137 stream_set(cur_streamp, STREAM_INSTANT); in check_if_sorted()
145 stream_set_size(cur_streamp, input_mem); in check_if_sorted()
146 stream_swap_buffer(cur_streamp, &data_buffer, &data_bufsize); in check_if_sorted()
147 stream_set_size(cur_streamp, input_mem); in check_if_sorted()
149 if (cur_streamp->s_status & STREAM_WIDE) { in check_if_sorted()
155 if (SOP_PRIME(cur_streamp) > 1) in check_if_sorted()
[all …]
H A Dmerge.c287 stream_t *cur_streamp; in merge_n_streams() local
346 for (cur_streamp = top_streamp; cur_streamp != bot_streamp; in merge_n_streams()
347 cur_streamp = cur_streamp->s_next) { in merge_n_streams()
351 if (!(cur_streamp->s_status & STREAM_ARRAY) && in merge_n_streams()
352 SOP_EOS(cur_streamp)) { in merge_n_streams()
353 stream_unlink_temporary(cur_streamp); in merge_n_streams()
361 if (SOP_PRIME(cur_streamp) != PRIME_SUCCEEDED) in merge_n_streams()
364 cur_streamp->s_current.l_collate_bufsize = in merge_n_streams()
366 cur_streamp->s_current.l_collate.sp = in merge_n_streams()
369 &cur_streamp->s_current, FCV_REALLOC, in merge_n_streams()
[all …]
H A Dstreams.c320 stream_t *cur_streamp = *str_chain; in stream_push_to_chain() local
322 if (cur_streamp == NULL) { in stream_push_to_chain()
328 while (cur_streamp->s_next != NULL) in stream_push_to_chain()
329 cur_streamp = cur_streamp->s_next; in stream_push_to_chain()
331 cur_streamp->s_next = streamp; in stream_push_to_chain()
332 streamp->s_previous = cur_streamp; in stream_push_to_chain()
425 stream_t *cur_streamp; in stream_close_all_previous() local
429 cur_streamp = tail_streamp->s_previous; in stream_close_all_previous()
430 while (cur_streamp != NULL) { in stream_close_all_previous()
431 (void) SOP_FREE(cur_streamp); in stream_close_all_previous()
[all …]