Cross Reference: /illumos-gate/usr/src/cmd/sort/common/streams

Lines Matching refs:str
37 stream_mmap_prime(stream_t *str)
41 	if (stream_is_primed(str))
44 	stream_set(str, STREAM_PRIMED);
46 	if (str->s_buffer_size == 0) {
47 		stream_set(str, STREAM_EOS_REACHED);
51 	str->s_current.l_data.sp = str->s_buffer;
52 	str->s_type.SF.s_release_origin = str->s_buffer;
53 	if ((nl = (char *)memchr(str->s_buffer, '\n', str->s_buffer_size)) ==
55 		warn(WMSG_NEWLINE_ADDED, str->s_filename);
56 		str->s_current.l_data_length = str->s_buffer_size;
58 		str->s_current.l_data_length = nl - (char *)str->s_buffer;
61 	str->s_current.l_collate.sp = NULL;
62 	str->s_current.l_collate_length = 0;
69  * stream_mmap_fetch() sets the fields of str->s_current to delimit the next
73 stream_mmap_fetch(stream_t *str)
78 	ASSERT(stream_is_primed(str));
79 	ASSERT((str->s_status & STREAM_EOS_REACHED) == 0);
84 	str->s_current.l_data.sp = str->s_current.l_data.sp +
85 	    str->s_current.l_data_length + 1;
87 	dist_to_buf_end = str->s_buffer_size - (str->s_current.l_data.sp
88 	    - (char *)str->s_buffer);
89 	ASSERT(dist_to_buf_end >= 0 && dist_to_buf_end <= str->s_buffer_size);
91 	next_nl = memchr(str->s_current.l_data.sp, '\n', dist_to_buf_end);
94 		str->s_current.l_data_length = next_nl
95 		    - str->s_current.l_data.sp;
97 		warn(WMSG_NEWLINE_ADDED, str->s_filename);
98 		str->s_current.l_data_length = dist_to_buf_end;
104 	if (str->s_current.l_data.sp + str->s_current.l_data_length + 1 >=
105 	    (char *)str->s_buffer + str->s_buffer_size)
106 		stream_set(str, STREAM_EOS_REACHED);
108 	str->s_current.l_collate_length = 0;
115 stream_mmap_is_closable(stream_t *str)
117 	if (str->s_status & STREAM_OPEN)
123 stream_mmap_close(stream_t *str)
125 	if (str->s_type.SF.s_fd > -1) {
126 		(void) close(str->s_type.SF.s_fd);
127 		stream_unset(str, STREAM_OPEN);
135 stream_mmap_free(stream_t *str)
137 	if (!(str->s_status & STREAM_OPEN) ||
138 	    (str->s_consumer != NULL &&
139 	    str->s_consumer->s_status & STREAM_NOT_FREEABLE))
142 	if (str->s_buffer == NULL)
145 	if (munmap(str->s_buffer, str->s_buffer_size) < 0)
146 		die(EMSG_MUNMAP, str->s_filename);
148 	str->s_buffer = NULL;
149 	str->s_buffer_size = 0;
151 	stream_unset(str, STREAM_PRIMED);
157 stream_mmap_eos(stream_t *str)
161 	if (str == NULL || str->s_status & STREAM_EOS_REACHED)
169 	if (str->s_filesize == 0 ||
170 	    (stream_is_primed(str) && str->s_current.l_data.sp -
171 	    (char *)str->s_buffer + str->s_current.l_data_length + 1 >=
172 	    str->s_buffer_size)) {
174 		stream_set(str, STREAM_EOS_REACHED);
191 stream_mmap_release_line(stream_t *str)
193 	caddr_t origin = str->s_type.SF.s_release_origin;
196 	while ((caddr_t)((ulong_t)str->s_current.l_data.sp & ALIGNED) -
206 	str->s_type.SF.s_release_origin += release;