Searched refs:cur_streamp (Results 1 – 4 of 4) sorted by relevance
41 stream_t *cur_streamp = convert_chain; in convert() local55 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 …]
124 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 …]
285 stream_t *cur_streamp; in merge_n_streams() local344 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 …]
318 stream_t *cur_streamp = *str_chain; in stream_push_to_chain() local320 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() local428 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 …]