stream_t
bz2decompress(stream_t *s, void *buf, size_t size)
bz2block(int corefd, stream_t *s, char *block, size_t blocksz)
stream_t *s;
stream_t *s;
static stream_t *streams;
static stream_t *endstreams;
streams = Zalloc(nstreams * sizeof (stream_t));
stream_t *s;
lzjbblock(int corefd, stream_t *s, char *block, size_t blocksz)
stream_t *cur_streamp = S->m_input_streams;
stream_t *convert_chain = S->m_input_streams;
stream_t *cur_streamp = convert_chain;
stream_t *str;
radix_quicksort(stream_t *C, flag_t coll_flags)
stream_t *sort_stream = NULL;
stream_t *cur_stream;
sort_stream = safe_realloc(sort_stream, sizeof (stream_t));
merge_two_streams(field_t *fields_chain, stream_t *str_a, stream_t *str_b,
stream_t *outstrp, vchar_t field_separator, flag_t coll_flags)
heap_up(stream_t **A, int k, flag_t coll_flags)
heap_down(stream_t **A, int k, int N, flag_t coll_flags)
pq_queue = safe_realloc(NULL, sizeof (stream_t *) * (max_size + 1));
pqueue_insert(stream_t *source, flag_t coll_flags)
static stream_t *
merge_n_streams(sort_t *S, stream_t *head_streamp, int n_streams,
stream_t *out_streamp, flag_t coll_flags)
stream_t *top_streamp;
stream_t *cur_streamp;
stream_t *bot_streamp;
stream_t *loop_out_streamp;
stream_t *merge_chain;
stream_t *cur_streamp;
stream_t out_stream;
static stream_t **pq_queue;
prepare_output_stream(stream_t *ostrp, sort_t *S)
merge_one_stream(field_t *fields_chain, stream_t *strp, stream_t *outstrp,
stream_unset(stream_t *streamp, flag_t flags)
stream_is_primed(stream_t *streamp)
stream_clear(stream_t *str)
(void) memset(str, 0, sizeof (stream_t));
stream_copy(stream_t *dest, stream_t *src)
(void) memcpy(dest, src, sizeof (stream_t));
stream_stat_chain(stream_t *strp)
stream_t *cur_strp = strp;
stream_count_chain(stream_t *str)
stream_open_for_read(sort_t *S, stream_t *str)
stream_set_size(stream_t *str, size_t new_size)
stream_add_file_to_chain(stream_t **str_chain, char *filename)
stream_t *str;
stream_push_to_chain(stream_t **str_chain, stream_t *streamp)
stream_t *cur_streamp = *str_chain;
stream_dump(stream_t *str_in, stream_t *str_out)
stream_t *
stream_push_to_temporary(stream_t **str_chain, stream_t *streamp, int flags)
stream_t *out_streamp;
out_streamp = safe_realloc(NULL, sizeof (stream_t));
stream_t *
stream_close_all_previous(stream_t *tail_streamp)
stream_t *cur_streamp;
stream_unlink_temporary(stream_t *streamp)
stream_t *str = safe_realloc(NULL, sizeof (stream_t));
stream_insert(sort_t *S, stream_t *src, stream_t *dest)
stream_set(stream_t *str, flag_t flags)
stream_swap_buffer(stream_t *str, char **buf, size_t *size)
extern void stream_add_file_to_chain(stream_t **, char *);
extern void stream_clear(stream_t *);
extern void stream_close_all_previous(stream_t *);
extern uint_t stream_count_chain(stream_t *);
extern int stream_insert(sort_t *, stream_t *, stream_t *);
extern stream_t *stream_new(int);
extern int stream_open_for_read(sort_t *, stream_t *);
extern void stream_push_to_chain(stream_t **, stream_t *);
extern stream_t *stream_push_to_temporary(stream_t **, stream_t *, int);
extern void stream_set_size(stream_t *, size_t);
extern void stream_stat_chain(stream_t *);
extern void stream_swap_buffer(stream_t *, char **, size_t *);
extern void stream_unlink_temporary(stream_t *streamp);
stream_array_eos(stream_t *str)
stream_array_release_line(stream_t *str)
stream_array_prime(stream_t *str)
stream_array_fetch(stream_t *str)
stream_array_is_closable(stream_t *str)
stream_array_close(stream_t *str)
stream_array_free(stream_t *str)
extern void stream_set(stream_t *, flag_t);
extern void stream_unset(stream_t *, flag_t);
extern int stream_is_primed(stream_t *);
stream_mmap_is_closable(stream_t *str)
stream_mmap_close(stream_t *str)
stream_mmap_free(stream_t *str)
stream_mmap_eos(stream_t *str)
stream_mmap_release_line(stream_t *str)
stream_mmap_prime(stream_t *str)
stream_mmap_fetch(stream_t *str)
stream_stdio_fetch(stream_t *str)
stream_stdio_fetch_overwrite(stream_t *str)
stream_stdio_is_closable(stream_t *str)
stream_stdio_close(stream_t *str)
stream_stdio_send_eol(stream_t *str)
stream_stdio_flush(stream_t *str)
stream_stdio_put_line(stream_t *str, line_rec_t *line)
stream_stdio_put_line_unique(stream_t *str, line_rec_t *line)
stream_stdio_unlink(stream_t *str)
stream_stdio_free(stream_t *str)
stream_stdio_eos(stream_t *str)
stream_stdio_open_for_write(stream_t *str)
stream_stdio_release_line(stream_t *str)
stream_stdio_prime(stream_t *str)
extern int stream_stdio_open_for_write(stream_t *str);
extern int stream_stdio_is_closable(stream_t *str);
extern int stream_stdio_close(stream_t *str);
extern int stream_stdio_unlink(stream_t *str);
extern int stream_stdio_free(stream_t *str);
extern ssize_t stream_stdio_fetch_overwrite(stream_t *);
extern void stream_stdio_put_line_unique(stream_t *, line_rec_t *);
extern void stream_stdio_flush(stream_t *);
stream_wide_fetch(stream_t *str)
stream_wide_fetch_overwrite(stream_t *str)
stream_wide_send_eol(stream_t *str)
stream_wide_put_line(stream_t *str, line_rec_t *line)
stream_wide_put_line_unique(stream_t *str, line_rec_t *line)
stream_wide_eos(stream_t *str)
stream_wide_release_line(stream_t *str)
stream_wide_prime(stream_t *str)
extern ssize_t stream_wide_fetch_overwrite(stream_t *);
extern void stream_wide_put_line_unique(stream_t *, line_rec_t *);
stream_t *m_input_streams;
stream_t *m_temporary_streams;
stream_t *strp = S->m_input_streams;
set_cleanup_chain(stream_t **strp)
stream_t *strp;
static stream_t **cleanup_chain = NULL;
extern void set_cleanup_chain(stream_t **);
extern void set_output_guard(stream_t *);
stream_t *s = NULL;
stream_t *s = stream;
stream_t *s = stream;
stream_t stream;
stream_t stream;
static struct token * alloc_token(stream_t *stream)
static int nextchar_slow(stream_t *stream)
static inline int nextchar(stream_t *stream)
static struct token *mark_eof(stream_t *stream)
static void add_token(stream_t *stream)
static void drop_token(stream_t *stream)
static int get_one_number(int c, int next, stream_t *stream)
static int eat_string(int next, stream_t *stream, enum token_type type)
static int drop_stream_eoln(stream_t *stream)
static int drop_stream_comment(stream_t *stream)
static struct position stream_pos(stream_t *stream)
static int get_one_special(int c, stream_t *stream)
static int get_one_identifier(int c, stream_t *stream)
static int get_one_token(int c, stream_t *stream)
static struct token *setup_stream(stream_t *stream, int idx, int fd,
static struct token *tokenize_stream(stream_t *stream)