| /illumos-gate/usr/src/cmd/sort/ |
| H A D | streams.h | 62 extern void stream_add_file_to_chain(stream_t **, char *);
63 extern void stream_clear(stream_t *);
64 extern void stream_close_all_previous(stream_t *);
65 extern uint_t stream_count_chain(stream_t *);
66 extern int stream_insert(sort_t *, stream_t *, stream_t *);
67 extern stream_t *stream_new(int);
68 extern int stream_open_for_read(sort_t *, stream_t *);
69 extern void stream_push_to_chain(stream_t **, stream_t *);
70 extern stream_t *stream_push_to_temporary(stream_t **, stream_t *, int);
71 extern void stream_set_size(stream_t *, size_t);
[all …]
|
| H A D | streams.c | 41 stream_t *
44 stream_t *str = safe_realloc(NULL, sizeof (stream_t)); in stream_new()
53 stream_set(stream_t *str, flag_t flags) in stream_set()
124 stream_unset(stream_t *streamp, flag_t flags) in stream_unset()
132 stream_is_primed(stream_t *streamp) in stream_is_primed()
138 stream_clear(stream_t *str) in stream_clear()
140 (void) memset(str, 0, sizeof (stream_t)); in stream_clear()
144 stream_copy(stream_t *dest, stream_t *src) in stream_copy()
146 (void) memcpy(dest, src, sizeof (stream_t)); in stream_copy()
150 stream_stat_chain(stream_t *strp) in stream_stat_chain()
[all …]
|
| H A D | streams_stdio.h | 49 extern int stream_stdio_open_for_write(stream_t *str);
50 extern int stream_stdio_is_closable(stream_t *str);
51 extern int stream_stdio_close(stream_t *str);
52 extern int stream_stdio_unlink(stream_t *str);
53 extern int stream_stdio_free(stream_t *str);
55 extern ssize_t stream_stdio_fetch_overwrite(stream_t *);
56 extern void stream_stdio_put_line_unique(stream_t *, line_rec_t *);
57 extern void stream_stdio_flush(stream_t *);
|
| H A D | merge.c | 67 static stream_t **pq_queue;
73 prepare_output_stream(stream_t *ostrp, sort_t *S) in prepare_output_stream()
92 merge_one_stream(field_t *fields_chain, stream_t *strp, stream_t *outstrp, in merge_one_stream()
126 merge_two_streams(field_t *fields_chain, stream_t *str_a, stream_t *str_b, in merge_two_streams()
127 stream_t *outstrp, vchar_t field_separator, flag_t coll_flags) in merge_two_streams()
222 heap_up(stream_t **A, int k, flag_t coll_flags) in heap_up()
233 heap_down(stream_t **A, int k, int N, flag_t coll_flags) in heap_down()
260 pq_queue = safe_realloc(NULL, sizeof (stream_t *) * (max_size + 1)); in pqueue_init()
266 pqueue_insert(stream_t *source, flag_t coll_flags) in pqueue_insert()
272 static stream_t *
[all …]
|
| H A D | streams_array.c | 35 stream_array_prime(stream_t *str) in stream_array_prime()
56 stream_array_fetch(stream_t *str) in stream_array_fetch()
72 stream_array_is_closable(stream_t *str) in stream_array_is_closable()
82 stream_array_close(stream_t *str) in stream_array_close()
90 stream_array_free(stream_t *str) in stream_array_free()
102 stream_array_eos(stream_t *str) in stream_array_eos()
119 stream_array_release_line(stream_t *str) in stream_array_release_line()
|
| H A D | streams_stdio.c | 46 stream_stdio_open_for_write(stream_t *str) in stream_stdio_open_for_write()
78 stream_stdio_prime(stream_t *str) in stream_stdio_prime()
171 stream_stdio_fetch(stream_t *str) in stream_stdio_fetch()
273 stream_stdio_fetch_overwrite(stream_t *str) in stream_stdio_fetch_overwrite()
318 stream_stdio_is_closable(stream_t *str) in stream_stdio_is_closable()
326 stream_stdio_close(stream_t *str) in stream_stdio_close()
350 stream_stdio_send_eol(stream_t *str) in stream_stdio_send_eol()
360 stream_stdio_flush(stream_t *str) in stream_stdio_flush()
370 stream_stdio_put_line(stream_t *str, line_rec_t *line) in stream_stdio_put_line()
388 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 | 35 stream_mmap_prime(stream_t *str) in stream_mmap_prime()
71 stream_mmap_fetch(stream_t *str) in stream_mmap_fetch()
113 stream_mmap_is_closable(stream_t *str) in stream_mmap_is_closable()
121 stream_mmap_close(stream_t *str) in stream_mmap_close()
133 stream_mmap_free(stream_t *str) in stream_mmap_free()
155 stream_mmap_eos(stream_t *str) in stream_mmap_eos()
189 stream_mmap_release_line(stream_t *str) in stream_mmap_release_line()
|
| H A D | streams_common.h | 38 extern void stream_set(stream_t *, flag_t);
39 extern void stream_unset(stream_t *, flag_t);
41 extern int stream_is_primed(stream_t *);
|
| H A D | streams_wide.c | 48 stream_wide_prime(stream_t *str) in stream_wide_prime()
124 stream_wide_fetch(stream_t *str) in stream_wide_fetch()
193 stream_wide_fetch_overwrite(stream_t *str) in stream_wide_fetch_overwrite()
234 stream_wide_send_eol(stream_t *str) in stream_wide_send_eol()
246 stream_wide_put_line(stream_t *str, line_rec_t *line) in stream_wide_put_line()
263 stream_wide_put_line_unique(stream_t *str, line_rec_t *line) in stream_wide_put_line_unique()
293 stream_wide_eos(stream_t *str) in stream_wide_eos()
313 stream_wide_release_line(stream_t *str) in stream_wide_release_line()
|
| H A D | streams_wide.h | 48 extern ssize_t stream_wide_fetch_overwrite(stream_t *);
49 extern void stream_wide_put_line_unique(stream_t *, line_rec_t *);
|
| H A D | types.h | 219 } stream_t; typedef
249 stream_t *m_input_streams;
252 stream_t *m_temporary_streams;
|
| H A D | convert.c | 40 stream_t *convert_chain = S->m_input_streams; in convert()
41 stream_t *cur_streamp = convert_chain; in convert()
|
| H A D | internal.c | 296 radix_quicksort(stream_t *C, flag_t coll_flags) in radix_quicksort()
320 stream_t *sort_stream = NULL; in internal_sort()
321 stream_t *cur_stream; in internal_sort()
362 sort_stream = safe_realloc(sort_stream, sizeof (stream_t)); in internal_sort()
|
| H A D | utility.h | 140 extern void set_cleanup_chain(stream_t **);
143 extern void set_output_guard(stream_t *);
|
| H A D | utility.c | 77 static stream_t **cleanup_chain = NULL;
214 stream_t *strp = S->m_input_streams; in establish_output_guard()
258 set_cleanup_chain(stream_t **strp) in set_cleanup_chain()
276 stream_t *strp; in atexit_handler()
|
| H A D | initialize.c | 205 stream_t *str; in initialize_post()
|
| H A D | check.c | 112 stream_t *cur_streamp = S->m_input_streams; in check_if_sorted()
|
| /illumos-gate/usr/src/tools/smatch/src/ |
| H A D | tokenize.c | 57 } stream_t; typedef
66 static struct position stream_pos(stream_t *stream) in stream_pos()
334 static struct token * alloc_token(stream_t *stream) in alloc_token()
345 static int nextchar_slow(stream_t *stream) in nextchar_slow()
431 static inline int nextchar(stream_t *stream) in nextchar()
451 static struct token *mark_eof(stream_t *stream) in mark_eof()
469 static void add_token(stream_t *stream) in add_token()
479 static void drop_token(stream_t *stream) in drop_token()
536 static int get_one_number(int c, int next, stream_t *stream) in get_one_number()
576 static int eat_string(int next, stream_t *stream, enum token_type type) in eat_string()
[all …]
|
| /illumos-gate/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 | 58 } stream_t; typedef
|
| /illumos-gate/usr/src/cmd/savecore/ |
| H A D | savecore.c | 727 } stream_t; typedef
729 static stream_t *streams;
730 static stream_t *endstreams;
797 streams = Zalloc(nstreams * sizeof (stream_t)); in initstreams()
828 stream_t *s; in sbarrier()
911 lzjbblock(int corefd, stream_t *s, char *block, size_t blocksz) in lzjbblock()
1003 bz2decompress(stream_t *s, void *buf, size_t size) in bz2decompress()
1034 bz2block(int corefd, stream_t *s, char *block, size_t blocksz) in bz2block()
1135 stream_t *s; in runstreams()
1224 stream_t *s; in decompress_pages()
|