44 	stream_t *str = safe_realloc(NULL, sizeof (stream_t));  in stream_new()  local
46 	stream_clear(str);  in stream_new()
47 	stream_set(str, src);  in stream_new()
49 	return (str);  in stream_new()
53 stream_set(stream_t *str, flag_t flags)  in stream_set()  argument
61 		str->s_status &= ~STREAM_SOURCE_MASK;  in stream_set()
62 		str->s_status |= flags & STREAM_SOURCE_MASK;  in stream_set()
66 				str->s_element_size = 0;  in stream_set()
67 				str->s_ops = invalid_ops;  in stream_set()
73 				str->s_ops = stream_array_ops;  in stream_set()
76 				str->s_element_size = sizeof (char);  in stream_set()
77 				str->s_ops = stream_mmap_ops;  in stream_set()
80 				str->s_element_size = sizeof (char);  in stream_set()
81 				str->s_ops = stream_stdio_ops;  in stream_set()
84 				str->s_element_size = sizeof (wchar_t);  in stream_set()
85 				str->s_ops = stream_wide_ops;  in stream_set()
88 				die(EMSG_UNKN_STREAM, str->s_status);  in stream_set()
92 	str->s_status |= (flags & ~STREAM_SOURCE_MASK);  in stream_set()
94 	if (str->s_status & STREAM_UNIQUE)  in stream_set()
95 		switch (str->s_status & STREAM_SOURCE_MASK) {  in stream_set()
97 				str->s_ops.sop_put_line =  in stream_set()
101 				str->s_ops.sop_put_line =  in stream_set()
108 	if (str->s_status & STREAM_INSTANT)  in stream_set()
109 		switch (str->s_status & STREAM_SOURCE_MASK) {  in stream_set()
111 				str->s_ops.sop_fetch =  in stream_set()
115 				str->s_ops.sop_fetch =  in stream_set()
138 stream_clear(stream_t *str)  in stream_clear()  argument
140 	(void) memset(str, 0, sizeof (stream_t));  in stream_clear()
174 stream_count_chain(stream_t *str)  in stream_count_chain()  argument
178 	while (str != NULL) {  in stream_count_chain()
180 		str = str->s_next;  in stream_count_chain()
187 stream_open_for_read(sort_t *S, stream_t *str)  in stream_open_for_read()  argument
191 	ASSERT(!(str->s_status & STREAM_OUTPUT));  in stream_open_for_read()
196 	if ((str->s_status & STREAM_SOURCE_MASK) == STREAM_ARRAY) {  in stream_open_for_read()
197 		stream_set(str, STREAM_ARRAY | STREAM_OPEN);  in stream_open_for_read()
204 	if (str->s_status & STREAM_NOTFILE) {  in stream_open_for_read()
205 		str->s_type.BF.s_fp = stdin;  in stream_open_for_read()
206 		stream_set(str, STREAM_OPEN | (S->m_single_byte_locale ?  in stream_open_for_read()
211 	ASSERT(str->s_filename);  in stream_open_for_read()
215 	    str->s_filesize > 0 &&  in stream_open_for_read()
216 	    str->s_filesize < SSIZE_MAX) {  in stream_open_for_read()
220 		fd = open(str->s_filename, O_RDONLY);  in stream_open_for_read()
225 				die(EMSG_OPEN, str->s_filename);  in stream_open_for_read()
227 		str->s_buffer = mmap(0, str->s_filesize, PROT_READ,  in stream_open_for_read()
230 		if (str->s_buffer != MAP_FAILED) {  in stream_open_for_read()
231 			str->s_buffer_size = str->s_filesize;  in stream_open_for_read()
232 			str->s_type.SF.s_fd = fd;  in stream_open_for_read()
234 			stream_set(str, STREAM_MMAP | STREAM_OPEN);  in stream_open_for_read()
235 			stream_unset(str, STREAM_PRIMED);  in stream_open_for_read()
245 		str->s_buffer = NULL;  in stream_open_for_read()
249 	if ((str->s_type.BF.s_fp = fopen(str->s_filename, "r")) == NULL) {  in stream_open_for_read()
253 			die(EMSG_OPEN, str->s_filename);  in stream_open_for_read()
256 	str->s_type.BF.s_vbuf = safe_realloc(NULL, STDIO_VBUF_SIZE);  in stream_open_for_read()
257 	if (setvbuf(str->s_type.BF.s_fp, str->s_type.BF.s_vbuf, _IOFBF,  in stream_open_for_read()
259 		safe_free(str->s_type.BF.s_vbuf);  in stream_open_for_read()
260 		str->s_type.BF.s_vbuf = NULL;  in stream_open_for_read()
263 	stream_set(str, STREAM_OPEN | (S->m_single_byte_locale ? STREAM_SINGLE :  in stream_open_for_read()
265 	stream_unset(str, STREAM_PRIMED);  in stream_open_for_read()
271 stream_set_size(stream_t *str, size_t new_size)  in stream_set_size()  argument
281 	if (str->s_buffer_size == p_new_size)  in stream_set_size()
284 	if (str->s_buffer != NULL)  in stream_set_size()
285 		(void) munmap(str->s_buffer, str->s_buffer_size);  in stream_set_size()
288 		str->s_buffer = NULL;  in stream_set_size()
289 		str->s_buffer_size = 0;  in stream_set_size()
293 	str->s_buffer = xzmap(0, p_new_size, PROT_READ | PROT_WRITE,  in stream_set_size()
296 	if (str->s_buffer == MAP_FAILED)  in stream_set_size()
299 	str->s_buffer_size = p_new_size;  in stream_set_size()
305 	stream_t *str;  in stream_add_file_to_chain()  local
307 	str = stream_new(STREAM_NO_SOURCE);  in stream_add_file_to_chain()
309 	str->s_filename = filename;  in stream_add_file_to_chain()
310 	str->s_type.SF.s_fd = -1;  in stream_add_file_to_chain()
312 	stream_push_to_chain(str_chain, str);  in stream_add_file_to_chain()
580 stream_swap_buffer(stream_t *str, char **buf, size_t *size)  in stream_swap_buffer()  argument
585 	*buf = str->s_buffer;  in stream_swap_buffer()
586 	*size = str->s_buffer_size;  in stream_swap_buffer()
588 	str->s_buffer = tb;  in stream_swap_buffer()
589 	str->s_buffer_size = ts;  in stream_swap_buffer()