Cross Reference: /illumos-gate/usr/src/cmd/sort/common/merge.c

Lines Matching defs:cur_streamp
287 	stream_t *cur_streamp;
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->s_current.l_collate_bufsize =
366 			cur_streamp->s_current.l_collate.sp =
369 			    &cur_streamp->s_current, FCV_REALLOC,
372 			pqueue_insert(cur_streamp, coll_flags);
376 			cur_streamp = pqueue_head(coll_flags);
378 			SOP_PUT_LINE(loop_out_streamp, &cur_streamp->s_current);
379 			SOP_RELEASE_LINE(cur_streamp);
381 			if (!SOP_EOS(cur_streamp)) {
382 				SOP_FETCH(cur_streamp);
384 				    &cur_streamp->s_current, FCV_REALLOC,
386 				pqueue_insert(cur_streamp, coll_flags);
390 		cur_streamp = top_streamp;
391 		while (cur_streamp != bot_streamp) {
392 			if (!(cur_streamp->s_status & STREAM_ARRAY))
393 				safe_free(cur_streamp->s_current.l_collate.sp);
394 			cur_streamp->s_current.l_collate.sp = NULL;
396 			(void) SOP_FREE(cur_streamp);
397 			stream_unlink_temporary(cur_streamp);
398 			(void) SOP_CLOSE(cur_streamp);
400 			cur_streamp = cur_streamp->s_next;
429 	stream_t *cur_streamp;
457 	cur_streamp = merge_chain;
470 			(void) stream_open_for_read(S, cur_streamp);
472 			merge_one_stream(S->m_fields_head, cur_streamp,
479 			(void) stream_open_for_read(S, cur_streamp);
480 			(void) stream_open_for_read(S, cur_streamp->s_next);
483 			merge_two_streams(S->m_fields_head, cur_streamp,
484 			    cur_streamp->s_next, &out_stream,
491 			merge_n_streams(S, cur_streamp, n_merges, &out_stream,