| /titanic_44/usr/src/cmd/sort/common/ |
| 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 *);
72 extern stream_t *stream_push_to_temporary(stream_t **, stream_t *, int);
73 extern void stream_set_size(stream_t *, size_t);
[all …]
|
| H A D | streams.c | 43 stream_t *
46 stream_t *str = safe_realloc(NULL, sizeof (stream_t)); in stream_new()
55 stream_set(stream_t *str, flag_t flags) in stream_set()
126 stream_unset(stream_t *streamp, flag_t flags) in stream_unset()
134 stream_is_primed(stream_t *streamp) in stream_is_primed()
140 stream_clear(stream_t *str) in stream_clear()
142 (void) memset(str, 0, sizeof (stream_t)); in stream_clear()
146 stream_copy(stream_t *dest, stream_t *src) in stream_copy()
148 (void) memcpy(dest, src, sizeof (stream_t)); in stream_copy()
152 stream_stat_chain(stream_t *strp) in stream_stat_chain()
[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 | merge.c | 69 static stream_t **pq_queue;
75 prepare_output_stream(stream_t *ostrp, sort_t *S) in prepare_output_stream()
94 merge_one_stream(field_t *fields_chain, stream_t *strp, stream_t *outstrp, in merge_one_stream()
128 merge_two_streams(field_t *fields_chain, stream_t *str_a, stream_t *str_b, in merge_two_streams()
129 stream_t *outstrp, vchar_t field_separator, flag_t coll_flags) in merge_two_streams()
224 heap_up(stream_t **A, int k, flag_t coll_flags) in heap_up()
235 heap_down(stream_t **A, int k, int N, flag_t coll_flags) in heap_down()
262 pq_queue = safe_realloc(NULL, sizeof (stream_t *) * (max_size + 1)); in pqueue_init()
268 pqueue_insert(stream_t *source, flag_t coll_flags) in pqueue_insert()
274 static stream_t *
[all …]
|
| H A D | streams_array.c | 37 stream_array_prime(stream_t *str) in stream_array_prime()
58 stream_array_fetch(stream_t *str) in stream_array_fetch()
74 stream_array_is_closable(stream_t *str) in stream_array_is_closable()
84 stream_array_close(stream_t *str) in stream_array_close()
92 stream_array_free(stream_t *str) in stream_array_free()
104 stream_array_eos(stream_t *str) in stream_array_eos()
121 stream_array_release_line(stream_t *str) in stream_array_release_line()
|
| H A D | streams_stdio.c | 48 stream_stdio_open_for_write(stream_t *str) in stream_stdio_open_for_write()
80 stream_stdio_prime(stream_t *str) in stream_stdio_prime()
173 stream_stdio_fetch(stream_t *str) in stream_stdio_fetch()
275 stream_stdio_fetch_overwrite(stream_t *str) in stream_stdio_fetch_overwrite()
320 stream_stdio_is_closable(stream_t *str) in stream_stdio_is_closable()
328 stream_stdio_close(stream_t *str) in stream_stdio_close()
352 stream_stdio_send_eol(stream_t *str) in stream_stdio_send_eol()
362 stream_stdio_flush(stream_t *str) in stream_stdio_flush()
372 stream_stdio_put_line(stream_t *str, line_rec_t *line) in stream_stdio_put_line()
390 stream_stdio_put_line_unique(stream_t *str, line_rec_t *line) in stream_stdio_put_line_unique()
[all …]
|
| H A D | streams_mmap.c | 37 stream_mmap_prime(stream_t *str) in stream_mmap_prime()
73 stream_mmap_fetch(stream_t *str) in stream_mmap_fetch()
115 stream_mmap_is_closable(stream_t *str) in stream_mmap_is_closable()
123 stream_mmap_close(stream_t *str) in stream_mmap_close()
135 stream_mmap_free(stream_t *str) in stream_mmap_free()
157 stream_mmap_eos(stream_t *str) in stream_mmap_eos()
191 stream_mmap_release_line(stream_t *str) in stream_mmap_release_line()
|
| 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_wide.c | 50 stream_wide_prime(stream_t *str) in stream_wide_prime()
126 stream_wide_fetch(stream_t *str) in stream_wide_fetch()
195 stream_wide_fetch_overwrite(stream_t *str) in stream_wide_fetch_overwrite()
236 stream_wide_send_eol(stream_t *str) in stream_wide_send_eol()
248 stream_wide_put_line(stream_t *str, line_rec_t *line) in stream_wide_put_line()
265 stream_wide_put_line_unique(stream_t *str, line_rec_t *line) in stream_wide_put_line_unique()
295 stream_wide_eos(stream_t *str) in stream_wide_eos()
315 stream_wide_release_line(stream_t *str) in stream_wide_release_line()
|
| 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 | convert.c | 42 stream_t *convert_chain = S->m_input_streams; in convert()
43 stream_t *cur_streamp = convert_chain; in convert()
|
| H A D | types.h | 221 } stream_t; typedef
251 stream_t *m_input_streams;
254 stream_t *m_temporary_streams;
|
| H A D | internal.c | 298 radix_quicksort(stream_t *C, flag_t coll_flags) in radix_quicksort()
322 stream_t *sort_stream = NULL; in internal_sort()
323 stream_t *cur_stream; in internal_sort()
364 sort_stream = safe_realloc(sort_stream, sizeof (stream_t)); in internal_sort()
|
| H A D | utility.h | 142 extern void set_cleanup_chain(stream_t **);
145 extern void set_output_guard(stream_t *);
|
| H A D | utility.c | 79 static stream_t **cleanup_chain = NULL;
216 stream_t *strp = S->m_input_streams; in establish_output_guard()
260 set_cleanup_chain(stream_t **strp) in set_cleanup_chain()
278 stream_t *strp; in atexit_handler()
|
| H A D | initialize.c | 195 stream_t *str; in initialize_post()
|
| H A D | check.c | 114 stream_t *cur_streamp = S->m_input_streams; in check_if_sorted()
|
| /titanic_44/usr/src/lib/print/libpapi-lpd/common/ |
| H A D | job.c | 113 stream_t *s = NULL; in papiJobStreamOpen()
173 stream_t *s = stream; in papiJobStreamWrite()
191 stream_t *s = stream; in papiJobStreamClose()
|
| H A D | papi_impl.h | 60 } stream_t; typedef
|
| /titanic_44/usr/src/cmd/savecore/ |
| H A D | savecore.c | 706 } stream_t; typedef
708 static stream_t *streams;
709 static stream_t *endstreams;
776 streams = Zalloc(nstreams * sizeof (stream_t)); in initstreams()
807 stream_t *s; in sbarrier()
890 lzjbblock(int corefd, stream_t *s, char *block, size_t blocksz) in lzjbblock()
982 bz2decompress(stream_t *s, void *buf, size_t size) in bz2decompress()
1013 bz2block(int corefd, stream_t *s, char *block, size_t blocksz) in bz2block()
1106 stream_t *s; in runstreams()
1195 stream_t *s; in decompress_pages()
|