acknowledge_load(Response::Callback::AcknowledgeLoad *cb, const vector< QualifiedRangeSpec > &specs) | Hypertable::Apps::RangeServer | |
batch_update(std::vector< UpdateRecTable * > &updates, ClockT::time_point expire_time) | Hypertable::Apps::RangeServer | |
commit_log_sync(ResponseCallback *cb, uint64_t cluster_id, const TableIdentifier &table) | Hypertable::Apps::RangeServer | |
compact(ResponseCallback *, const TableIdentifier &, const char *row, int32_t flags) | Hypertable::Apps::RangeServer | |
create_scanner(Response::Callback::CreateScanner *, const TableIdentifier &, const RangeSpec &, const ScanSpec &, QueryCache::Key *) | Hypertable::Apps::RangeServer | |
decode_table_id(const uint8_t **bufp, size_t *remainp, TableIdentifier *tid) | Hypertable::Apps::RangeServer | private |
destroy_scanner(ResponseCallback *cb, int32_t scanner_id) | Hypertable::Apps::RangeServer | |
do_maintenance() | Hypertable::Apps::RangeServer | |
drop_range(ResponseCallback *, const TableIdentifier &, const RangeSpec &) | Hypertable::Apps::RangeServer | |
drop_table(ResponseCallback *cb, const TableIdentifier &table) | Hypertable::Apps::RangeServer | |
dump(ResponseCallback *, const char *, bool) | Hypertable::Apps::RangeServer | |
dump_pseudo_table(ResponseCallback *cb, const TableIdentifier &table, const char *pseudo_table, const char *outfile) | Hypertable::Apps::RangeServer | |
FailoverPhantomRangeMap typedef | Hypertable::Apps::RangeServer | private |
fetch_scanblock(Response::Callback::CreateScanner *, int32_t scanner_id) | Hypertable::Apps::RangeServer | |
get_application_queue() | Hypertable::Apps::RangeServer | inline |
get_scheduler() | Hypertable::Apps::RangeServer | inline |
get_statistics(Response::Callback::GetStatistics *cb, const std::vector< SystemVariable::Spec > &specs, uint64_t generation) | Hypertable::Apps::RangeServer | |
get_table_schemas(TableSchemaMap &table_schemas) | Hypertable::Apps::RangeServer | private |
group_commit() | Hypertable::Apps::RangeServer | |
group_commit_add(EventPtr &event, uint64_t cluster_id, SchemaPtr &schema, const TableIdentifier &table, uint32_t count, StaticBuffer &buffer, uint32_t flags) | Hypertable::Apps::RangeServer | private |
heapcheck(ResponseCallback *, const char *) | Hypertable::Apps::RangeServer | |
initialize(PropertiesPtr &) | Hypertable::Apps::RangeServer | private |
live(const vector< QualifiedRangeSpec > &ranges) | Hypertable::Apps::RangeServer | private |
live(const QualifiedRangeSpec &spec) | Hypertable::Apps::RangeServer | private |
load_range(ResponseCallback *, const TableIdentifier &, const RangeSpec &, const RangeState &, bool needs_compaction) | Hypertable::Apps::RangeServer | |
local_recover() | Hypertable::Apps::RangeServer | private |
m_app_queue | Hypertable::Apps::RangeServer | private |
m_bytes_loaded | Hypertable::Apps::RangeServer | private |
m_conn_manager | Hypertable::Apps::RangeServer | private |
m_context | Hypertable::Apps::RangeServer | private |
m_control_file_check_interval | Hypertable::Apps::RangeServer | private |
m_cores | Hypertable::Apps::RangeServer | private |
m_existence_file_handle | Hypertable::Apps::RangeServer | private |
m_existence_file_sequencer | Hypertable::Apps::RangeServer | private |
m_failover_map | Hypertable::Apps::RangeServer | private |
m_failover_mutex | Hypertable::Apps::RangeServer | private |
m_ganglia_collector | Hypertable::Apps::RangeServer | private |
m_get_statistics_outstanding | Hypertable::Apps::RangeServer | private |
m_group_commit | Hypertable::Apps::RangeServer | private |
m_group_commit_timer_handler | Hypertable::Apps::RangeServer | private |
m_hyperspace | Hypertable::Apps::RangeServer | private |
m_last_control_file_check | Hypertable::Apps::RangeServer | private |
m_last_metrics_update | Hypertable::Apps::RangeServer | private |
m_load_factors | Hypertable::Apps::RangeServer | private |
m_load_statistics | Hypertable::Apps::RangeServer | private |
m_loadavg_accum | Hypertable::Apps::RangeServer | private |
m_log_flush_method_meta | Hypertable::Apps::RangeServer | private |
m_log_flush_method_user | Hypertable::Apps::RangeServer | private |
m_log_replay_barrier | Hypertable::Apps::RangeServer | private |
m_log_roll_limit | Hypertable::Apps::RangeServer | private |
m_maintenance_scheduler | Hypertable::Apps::RangeServer | private |
m_master_client | Hypertable::Apps::RangeServer | private |
m_master_connection_handler | Hypertable::Apps::RangeServer | private |
m_metric_samples | Hypertable::Apps::RangeServer | private |
m_metrics_process | Hypertable::Apps::RangeServer | private |
m_mutex | Hypertable::Apps::RangeServer | private |
m_namemap | Hypertable::Apps::RangeServer | private |
m_next_metrics_update | Hypertable::Apps::RangeServer | private |
m_page_in_accum | Hypertable::Apps::RangeServer | private |
m_page_out_accum | Hypertable::Apps::RangeServer | private |
m_pending_metrics_mutex | Hypertable::Apps::RangeServer | private |
m_pending_metrics_updates | Hypertable::Apps::RangeServer | private |
m_profile_mutex | Hypertable::Apps::RangeServer | private |
m_profile_query | Hypertable::Apps::RangeServer | private |
m_profile_query_out | Hypertable::Apps::RangeServer | private |
m_props | Hypertable::Apps::RangeServer | private |
m_query_cache | Hypertable::Apps::RangeServer | private |
m_scanner_buffer_size | Hypertable::Apps::RangeServer | private |
m_scanner_map | Hypertable::Apps::RangeServer | private |
m_scanner_ttl | Hypertable::Apps::RangeServer | private |
m_shutdown | Hypertable::Apps::RangeServer | private |
m_startup | Hypertable::Apps::RangeServer | private |
m_stats | Hypertable::Apps::RangeServer | private |
m_stats_last_timestamp | Hypertable::Apps::RangeServer | private |
m_stats_mutex | Hypertable::Apps::RangeServer | private |
m_timer_handler | Hypertable::Apps::RangeServer | private |
m_update_pipeline_metadata | Hypertable::Apps::RangeServer | private |
m_update_pipeline_system | Hypertable::Apps::RangeServer | private |
m_update_pipeline_user | Hypertable::Apps::RangeServer | private |
m_verbose | Hypertable::Apps::RangeServer | private |
map_table_schemas(const String &parent, const std::vector< DirEntryAttr > &listing, TableSchemaMap &table_schemas) | Hypertable::Apps::RangeServer | privatestatic |
master_change() | Hypertable::Apps::RangeServer | |
metadata_sync(ResponseCallback *, const char *, uint32_t flags, std::vector< const char * > columns) | Hypertable::Apps::RangeServer | |
phantom_commit_ranges(ResponseCallback *, int64_t op_id, const String &location, int32_t plan_generation, const vector< QualifiedRangeSpec > &ranges) | Hypertable::Apps::RangeServer | |
phantom_load(ResponseCallback *, const String &location, int32_t plan_generation, const vector< int32_t > &fragments, const vector< QualifiedRangeSpec > &specs, const vector< RangeState > &states) | Hypertable::Apps::RangeServer | |
phantom_prepare_ranges(ResponseCallback *, int64_t op_id, const String &location, int32_t plan_generation, const vector< QualifiedRangeSpec > &ranges) | Hypertable::Apps::RangeServer | |
phantom_update(Response::Callback::PhantomUpdate *, const String &location, int32_t plan_generation, const QualifiedRangeSpec &range, int32_t fragment, EventPtr &event) | Hypertable::Apps::RangeServer | |
RangeServer(PropertiesPtr &, ConnectionManagerPtr &, ApplicationQueuePtr &, Hyperspace::SessionPtr &) | Hypertable::Apps::RangeServer | |
relinquish_range(ResponseCallback *, const TableIdentifier &, const RangeSpec &) | Hypertable::Apps::RangeServer | |
replay_finished() | Hypertable::Apps::RangeServer | inline |
replay_fragments(ResponseCallback *, int64_t op_id, const String &location, int32_t plan_generation, int32_t type, const vector< int32_t > &fragments, const RangeServerRecovery::ReceiverPlan &receiver_plan, int32_t replay_timeout) | Hypertable::Apps::RangeServer | |
replay_load_range(TableInfoMap &replay_map, MetaLogEntityRangePtr &range_entity) | Hypertable::Apps::RangeServer | private |
replay_log(TableInfoMap &replay_map, CommitLogReaderPtr &log_reader) | Hypertable::Apps::RangeServer | private |
set_state(ResponseCallback *cb, const std::vector< SystemVariable::Spec > &specs, int64_t generation) | Hypertable::Apps::RangeServer | |
shutdown() | Hypertable::Apps::RangeServer | |
status(Response::Callback::Status *cb) | Hypertable::Apps::RangeServer | |
table_maintenance_disable(ResponseCallback *cb, const TableIdentifier &table) | Hypertable::Apps::RangeServer | |
table_maintenance_enable(ResponseCallback *cb, const TableIdentifier &table) | Hypertable::Apps::RangeServer | |
TableSchemaMap typedef | Hypertable::Apps::RangeServer | private |
test_and_set_get_statistics_outstanding(bool value) | Hypertable::Apps::RangeServer | inlineprivate |
update(Response::Callback::Update *cb, uint64_t cluster_id, const TableIdentifier &table, uint32_t count, StaticBuffer &buffer, uint32_t flags) | Hypertable::Apps::RangeServer | |
update_schema(ResponseCallback *, const TableIdentifier &, const char *) | Hypertable::Apps::RangeServer | |
verify_schema(TableInfoPtr &, uint32_t generation, const TableSchemaMap *table_schemas=0) | Hypertable::Apps::RangeServer | private |
wait_for_maintenance(ResponseCallback *cb) | Hypertable::Apps::RangeServer | |
write_profile_data(const String &line) | Hypertable::Apps::RangeServer | inline |
~RangeServer() | Hypertable::Apps::RangeServer | virtual |