| /illumos-gate/usr/src/cmd/sort/common/ |
| H A D | streams_common.h | 40 extern void stream_set(stream_t *, flag_t);
41 extern void stream_unset(stream_t *, flag_t);
43 extern int stream_is_primed(stream_t *);
|
| H A D | streams.h | 64 extern void stream_add_file_to_chain(stream_t **, char *);
65 extern void stream_clear(stream_t *);
66 extern void stream_close_all_previous(stream_t *);
67 extern uint_t stream_count_chain(stream_t *);
68 extern int stream_insert(sort_t *, stream_t *, stream_t *);
69 extern stream_t *stream_new(int);
70 extern int stream_open_for_read(sort_t *, stream_t *);
71 extern void stream_push_to_chain(stream_t **, stream_t *);
[all...] |
| H A D | streams_stdio.h | 51 extern int stream_stdio_open_for_write(stream_t *str);
52 extern int stream_stdio_is_closable(stream_t *str);
53 extern int stream_stdio_close(stream_t *str);
54 extern int stream_stdio_unlink(stream_t *str);
55 extern int stream_stdio_free(stream_t *str);
57 extern ssize_t stream_stdio_fetch_overwrite(stream_t *);
58 extern void stream_stdio_put_line_unique(stream_t *, line_rec_t *);
59 extern void stream_stdio_flush(stream_t *);
|
| H A D | streams_wide.h | 50 extern ssize_t stream_wide_fetch_overwrite(stream_t *);
51 extern void stream_wide_put_line_unique(stream_t *, line_rec_t *);
|
| H A D | streams_array.c | 37 stream_array_prime(stream_t *str)
58 stream_array_fetch(stream_t *str)
74 stream_array_is_closable(stream_t *str)
84 stream_array_close(stream_t *str)
92 stream_array_free(stream_t *str)
104 stream_array_eos(stream_t *str)
121 stream_array_release_line(stream_t *str)
|
| H A D | streams.c | 43 stream_t *
46 stream_t *str = safe_realloc(NULL, sizeof (stream_t));
55 stream_set(stream_t *str, flag_t flags)
126 stream_unset(stream_t *streamp, flag_t flags)
134 stream_is_primed(stream_t *streamp)
140 stream_clear(stream_t *str)
142 (void) memset(str, 0, sizeof (stream_t));
146 stream_copy(stream_t *dest, stream_t *sr
[all...] |
| H A D | merge.c | 69 static stream_t **pq_queue;
75 prepare_output_stream(stream_t *ostrp, sort_t *S)
94 merge_one_stream(field_t *fields_chain, stream_t *strp, stream_t *outstrp,
128 merge_two_streams(field_t *fields_chain, stream_t *str_a, stream_t *str_b,
129 stream_t *outstrp, vchar_t field_separator, flag_t coll_flags)
224 heap_up(stream_t **A, int k, flag_t coll_flags)
235 heap_down(stream_t **A, int k, int N, flag_t coll_flags)
262 pq_queue = safe_realloc(NULL, sizeof (stream_t *) * (max_siz
[all...] |
| H A D | streams_mmap.c | 37 stream_mmap_prime(stream_t *str)
73 stream_mmap_fetch(stream_t *str)
115 stream_mmap_is_closable(stream_t *str)
123 stream_mmap_close(stream_t *str)
135 stream_mmap_free(stream_t *str)
157 stream_mmap_eos(stream_t *str)
191 stream_mmap_release_line(stream_t *str)
|
| H A D | streams_stdio.c | 48 stream_stdio_open_for_write(stream_t *str)
80 stream_stdio_prime(stream_t *str)
173 stream_stdio_fetch(stream_t *str)
275 stream_stdio_fetch_overwrite(stream_t *str)
320 stream_stdio_is_closable(stream_t *str)
328 stream_stdio_close(stream_t *str)
352 stream_stdio_send_eol(stream_t *str)
362 stream_stdio_flush(stream_t *str)
372 stream_stdio_put_line(stream_t *str, line_rec_t *line)
390 stream_stdio_put_line_unique(stream_t *st
[all...] |
| H A D | convert.c | 42 stream_t *convert_chain = S->m_input_streams;
43 stream_t *cur_streamp = convert_chain;
|
| H A D | streams_wide.c | 50 stream_wide_prime(stream_t *str)
126 stream_wide_fetch(stream_t *str)
195 stream_wide_fetch_overwrite(stream_t *str)
236 stream_wide_send_eol(stream_t *str)
248 stream_wide_put_line(stream_t *str, line_rec_t *line)
265 stream_wide_put_line_unique(stream_t *str, line_rec_t *line)
295 stream_wide_eos(stream_t *str)
315 stream_wide_release_line(stream_t *str)
|
| H A D | utility.h | 142 extern void set_cleanup_chain(stream_t **);
145 extern void set_output_guard(stream_t *);
|
| H A D | internal.c | 298 radix_quicksort(stream_t *C, flag_t coll_flags)
322 stream_t *sort_stream = NULL;
323 stream_t *cur_stream;
364 sort_stream = safe_realloc(sort_stream, sizeof (stream_t));
|
| H A D | types.h | 200 * The stream_t type is provided to simplify access to files, particularly for
221 } stream_t; typedef in typeref:struct:stream
251 stream_t *m_input_streams;
254 stream_t *m_temporary_streams;
|
| H A D | initialize.c | 195 stream_t *str;
|
| H A D | check.c | 114 stream_t *cur_streamp = S->m_input_streams;
|
| H A D | utility.c | 79 static stream_t **cleanup_chain = NULL;
216 stream_t *strp = S->m_input_streams;
260 set_cleanup_chain(stream_t **strp)
278 stream_t *strp;
|
| /illumos-gate/usr/src/lib/print/libpapi-lpd/common/ |
| H A D | papi_impl.h | 60 } stream_t; typedef in typeref:struct:stream
|
| H A D | job.c | 113 stream_t *s = NULL;
173 stream_t *s = stream;
191 stream_t *s = stream;
|
| /illumos-gate/usr/src/cmd/savecore/ |
| H A D | savecore.c | 706 } stream_t; typedef in typeref:struct:stream
708 static stream_t *streams;
709 static stream_t *endstreams;
776 streams = Zalloc(nstreams * sizeof (stream_t));
807 stream_t *s;
890 lzjbblock(int corefd, stream_t *s, char *block, size_t blocksz)
982 bz2decompress(stream_t *s, void *buf, size_t size)
1013 bz2block(int corefd, stream_t *s, char *block, size_t blocksz)
1106 stream_t *s;
1195 stream_t *
[all...] |