Searched defs:cur_streamp (Results 1 - 4 of 4) sorted by relevance

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

Completed in 83 milliseconds