create_progress(const string &message, long count) | vg::Progressive | |
create_progress(long count) | vg::Progressive | |
cursor_t typedef | vg::StreamSorter< Message > | private |
destroy_progress(void) | vg::Progressive | |
easy_sort(istream &stream_in, ostream &stream_out, StreamIndex< Message > *index_to=nullptr) | vg::StreamSorter< Message > | |
emitter_t typedef | vg::StreamSorter< Message > | private |
get_min_position(const Message &msg) const | vg::StreamSorter< Message > | |
increment_progress() | vg::Progressive | |
last_progress | vg::Progressive | private |
less_than(const Message &a, const Message &b) const | vg::StreamSorter< Message > | |
less_than(const Position &a, const Position &b) const | vg::StreamSorter< Message > | |
max_buf_size | vg::StreamSorter< Message > | private |
max_fan_in | vg::StreamSorter< Message > | private |
open_all(const vector< string > &filenames, list< ifstream > &streams, list< cursor_t > &cursors) | vg::StreamSorter< Message > | private |
preload_progress(const string &message) | vg::Progressive | |
progress | vg::Progressive | private |
progress_count | vg::Progressive | private |
progress_message | vg::Progressive | private |
progress_seen | vg::Progressive | private |
show_progress | vg::Progressive | |
sort(vector< Message > &msgs) const | vg::StreamSorter< Message > | |
stream_sort(istream &stream_in, ostream &stream_out, StreamIndex< Message > *index_to=nullptr) | vg::StreamSorter< Message > | |
streaming_merge(list< cursor_t > &cursors, emitter_t &emitter, size_t expected_messages=0) | vg::StreamSorter< Message > | private |
streaming_merge(const vector< string > &temp_names_in, unordered_map< string, size_t > *messages_per_file=nullptr) | vg::StreamSorter< Message > | private |
StreamSorter(bool show_progress=false) | vg::StreamSorter< Message > | |
update_progress(long i) | vg::Progressive | |