Lines Matching refs:strp
92 merge_one_stream(field_t *fields_chain, stream_t *strp, stream_t *outstrp, in merge_one_stream() argument
95 size_t element_size = strp->s_element_size; in merge_one_stream()
98 if (strp->s_status & STREAM_SINGLE || strp->s_status & STREAM_WIDE) in merge_one_stream()
99 stream_set(strp, STREAM_INSTANT); in merge_one_stream()
101 if (SOP_PRIME(strp) == PRIME_SUCCEEDED) { in merge_one_stream()
102 strp->s_current.l_collate_bufsize = initial_size; in merge_one_stream()
103 strp->s_current.l_collate.sp = safe_realloc(NULL, initial_size); in merge_one_stream()
105 (void) mg_coll_convert(fields_chain, &strp->s_current, in merge_one_stream()
107 SOP_PUT_LINE(outstrp, &strp->s_current); in merge_one_stream()
108 SOP_RELEASE_LINE(strp); in merge_one_stream()
110 while (!SOP_EOS(strp)) { in merge_one_stream()
111 SOP_FETCH(strp); in merge_one_stream()
112 if (strp->s_current.l_collate_length == 0) in merge_one_stream()
114 &strp->s_current, FCV_REALLOC, in merge_one_stream()
116 SOP_PUT_LINE(outstrp, &strp->s_current); in merge_one_stream()
117 SOP_RELEASE_LINE(strp); in merge_one_stream()
120 (void) SOP_CLOSE(strp); in merge_one_stream()