#include <RangeServer.h>

Collaboration diagram for Hypertable::Apps::RangeServer:

Public Member Functions
	RangeServer (PropertiesPtr &, ConnectionManagerPtr &, ApplicationQueuePtr &, Hyperspace::SessionPtr &)

virtual	~RangeServer ()

void	compact (ResponseCallback , const TableIdentifier &, const char row, int32_t flags)

void	create_scanner (Response::Callback::CreateScanner , const TableIdentifier &, const RangeSpec &, const ScanSpec &, QueryCache::Key )

void	destroy_scanner (ResponseCallback *cb, int32_t scanner_id)

void	fetch_scanblock (Response::Callback::CreateScanner *, int32_t scanner_id)

void	load_range (ResponseCallback *, const TableIdentifier &, const RangeSpec &, const RangeState &, bool needs_compaction)

void	acknowledge_load (Response::Callback::AcknowledgeLoad *cb, const vector< QualifiedRangeSpec > &specs)

void	update_schema (ResponseCallback , const TableIdentifier &, const char )

void	update (Response::Callback::Update *cb, uint64_t cluster_id, const TableIdentifier &table, uint32_t count, StaticBuffer &buffer, uint32_t flags)
	Inserts data into a table. More...

void	batch_update (std::vector< UpdateRecTable * > &updates, ClockT::time_point expire_time)

void	commit_log_sync (ResponseCallback *cb, uint64_t cluster_id, const TableIdentifier &table)

void	drop_table (ResponseCallback *cb, const TableIdentifier &table)

void	dump (ResponseCallback , const char , bool)

void	dump_pseudo_table (ResponseCallback cb, const TableIdentifier &table, const char pseudo_table, const char *outfile)

void	get_statistics (Response::Callback::GetStatistics *cb, const std::vector< SystemVariable::Spec > &specs, uint64_t generation)

void	drop_range (ResponseCallback *, const TableIdentifier &, const RangeSpec &)

void	relinquish_range (ResponseCallback *, const TableIdentifier &, const RangeSpec &)

void	heapcheck (ResponseCallback , const char )

void	metadata_sync (ResponseCallback , const char , uint32_t flags, std::vector< const char * > columns)

void	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)

void	phantom_load (ResponseCallback *, const String &location, int32_t plan_generation, const vector< int32_t > &fragments, const vector< QualifiedRangeSpec > &specs, const vector< RangeState > &states)

void	phantom_update (Response::Callback::PhantomUpdate *, const String &location, int32_t plan_generation, const QualifiedRangeSpec &range, int32_t fragment, EventPtr &event)

void	phantom_prepare_ranges (ResponseCallback *, int64_t op_id, const String &location, int32_t plan_generation, const vector< QualifiedRangeSpec > &ranges)

void	phantom_commit_ranges (ResponseCallback *, int64_t op_id, const String &location, int32_t plan_generation, const vector< QualifiedRangeSpec > &ranges)

void	set_state (ResponseCallback *cb, const std::vector< SystemVariable::Spec > &specs, int64_t generation)

void	table_maintenance_enable (ResponseCallback *cb, const TableIdentifier &table)
	Enables maintenance for a table. More...

void	table_maintenance_disable (ResponseCallback *cb, const TableIdentifier &table)
	Disables maintenance for a table. More...

void	wait_for_maintenance (ResponseCallback *cb)
	Blocks while the maintenance queue is non-empty. More...

void	group_commit ()

void	do_maintenance ()

MaintenanceSchedulerPtr &	get_scheduler ()

ApplicationQueuePtr	get_application_queue ()

void	master_change ()

bool	replay_finished ()

void	status (Response::Callback::Status *cb)

void	shutdown ()

void	write_profile_data (const String &line)

Private Types
typedef std::map< String, SchemaPtr >	TableSchemaMap

typedef map< String, PhantomRangeMapPtr >	FailoverPhantomRangeMap

Private Member Functions
void	initialize (PropertiesPtr &)

void	local_recover ()

void	decode_table_id (const uint8_t *bufp, size_t remainp, TableIdentifier *tid)

void	get_table_schemas (TableSchemaMap &table_schemas)

void	replay_load_range (TableInfoMap &replay_map, MetaLogEntityRangePtr &range_entity)

void	replay_log (TableInfoMap &replay_map, CommitLogReaderPtr &log_reader)

void	verify_schema (TableInfoPtr &, uint32_t generation, const TableSchemaMap *table_schemas=0)

bool	live (const vector< QualifiedRangeSpec > &ranges)

bool	live (const QualifiedRangeSpec &spec)

void	group_commit_add (EventPtr &event, uint64_t cluster_id, SchemaPtr &schema, const TableIdentifier &table, uint32_t count, StaticBuffer &buffer, uint32_t flags)

bool	test_and_set_get_statistics_outstanding (bool value)
	Performs a "test and set" operation on m_get_statistics_outstanding. More...

Static Private Member Functions
static void	map_table_schemas (const String &parent, const std::vector< DirEntryAttr > &listing, TableSchemaMap &table_schemas)

Private Attributes
std::mutex	m_mutex

ContextPtr	m_context

LogReplayBarrierPtr	m_log_replay_barrier

UpdatePipelinePtr	m_update_pipeline_metadata
	Update pipeline for METADTA table. More...

UpdatePipelinePtr	m_update_pipeline_system
	Update pipeline for other (non-METADATA) system tables. More...

UpdatePipelinePtr	m_update_pipeline_user
	Update pipeline for USER tables. More...

Filesystem::Flags	m_log_flush_method_meta
	Flush method for METADATA commit log updates. More...

Filesystem::Flags	m_log_flush_method_user {}
	Flush method for USER commit log updates. More...

std::mutex	m_stats_mutex

PropertiesPtr	m_props
	Configuration properties. More...

bool	m_verbose {}
	Flag indicating if verbose logging is enabled. More...

bool	m_startup {true}
	Flag indicating if server is starting up. More...

bool	m_shutdown {}
	Flag indicating if server is shutting down. More...

FailoverPhantomRangeMap	m_failover_map

std::mutex	m_failover_mutex

ConnectionManagerPtr	m_conn_manager

ApplicationQueuePtr	m_app_queue

uint64_t	m_existence_file_handle

LockSequencer	m_existence_file_sequencer

std::shared_ptr < ConnectionHandler >	m_master_connection_handler

Lib::Master::ClientPtr	m_master_client

Hyperspace::SessionPtr	m_hyperspace

ScannerMap	m_scanner_map
	Outstanding scanner map. More...

uint32_t	m_scanner_ttl

uint64_t	m_bytes_loaded

uint64_t	m_log_roll_limit

StatsRangeServerPtr	m_stats

LoadStatisticsPtr	m_load_statistics

int64_t	m_stats_last_timestamp {}
	Timestamp (nanoseconds) of last metrics collection. More...

bool	m_get_statistics_outstanding {}
	Indicates if a get_statistics() call is outstanding. More...

NameIdMapperPtr	m_namemap
	Table name-to-ID mapper More...

MaintenanceSchedulerPtr	m_maintenance_scheduler
	Smart pointer to maintenance scheduler. More...

TimerHandlerPtr	m_timer_handler
	Smart pointer to timer handler. More...

GroupCommitInterfacePtr	m_group_commit

GroupCommitTimerHandlerPtr	m_group_commit_timer_handler

QueryCachePtr	m_query_cache

int64_t	m_scanner_buffer_size {}

time_t	m_last_metrics_update {}

time_t	m_next_metrics_update {}

double	m_loadavg_accum {}

uint64_t	m_page_in_accum {}

uint64_t	m_page_out_accum {}

LoadFactors	m_load_factors

size_t	m_metric_samples {}

size_t	m_cores {}

std::mutex	m_pending_metrics_mutex

CellsBuilder *	m_pending_metrics_updates {}

std::chrono::steady_clock::time_point	m_last_control_file_check

int32_t	m_control_file_check_interval {}

std::ofstream	m_profile_query_out

bool	m_profile_query {}

std::mutex	m_profile_mutex

MetricsCollectorGangliaPtr	m_ganglia_collector
	Ganglia metrics collector. More...

MetricsProcess	m_metrics_process
	Process metrics. More...

Detailed Description

Definition at line 94 of file RangeServer.h.

Member Typedef Documentation

typedef map<String, PhantomRangeMapPtr> Hypertable::Apps::RangeServer::FailoverPhantomRangeMap

private

Definition at line 291 of file RangeServer.h.

typedef std::map<String, SchemaPtr> Hypertable::Apps::RangeServer::TableSchemaMap

private

Definition at line 230 of file RangeServer.h.

Constructor & Destructor Documentation

Apps::RangeServer::RangeServer	(	PropertiesPtr &	props,
		ConnectionManagerPtr &	conn_mgr,
		ApplicationQueuePtr &	app_queue,
		Hyperspace::SessionPtr &	hyperspace
	)

Compute maintenance threads

Check for and connect to commit log FS broker

Listen for incoming connections

Definition at line 110 of file RangeServer.cc.

Apps::RangeServer::~RangeServer ( )

virtual

Definition at line 477 of file RangeServer.cc.

Member Function Documentation

void Apps::RangeServer::acknowledge_load	(	Response::Callback::AcknowledgeLoad *	cb,
		const vector< QualifiedRangeSpec > &	specs
	)

Definition at line 1941 of file RangeServer.cc.

void Apps::RangeServer::batch_update	(	std::vector< UpdateRecTable * > &	updates,
		ClockT::time_point	expire_time
	)

Definition at line 2147 of file RangeServer.cc.

void Apps::RangeServer::commit_log_sync	(	ResponseCallback *	cb,
		uint64_t	cluster_id,
		const TableIdentifier &	table
	)

Definition at line 2018 of file RangeServer.cc.

void Apps::RangeServer::compact	(	ResponseCallback *	cb,
		const TableIdentifier &	table,
		const char *	row,
		int32_t	flags
	)

Definition at line 1131 of file RangeServer.cc.

void Apps::RangeServer::create_scanner	(	Response::Callback::CreateScanner *	cb,
		const TableIdentifier &	table,
		const RangeSpec &	range_spec,
		const ScanSpec &	scan_spec,
		QueryCache::Key *	cache_key
	)

Send back data

Definition at line 1427 of file RangeServer.cc.

void Apps::RangeServer::decode_table_id	(	const uint8_t **	bufp,
		size_t *	remainp,
		TableIdentifier *	tid
	)

private

Definition at line 957 of file RangeServer.cc.

void Apps::RangeServer::destroy_scanner	(	ResponseCallback *	cb,
		int32_t	scanner_id
	)

Definition at line 1616 of file RangeServer.cc.

void Apps::RangeServer::do_maintenance ( )

Definition at line 3670 of file RangeServer.cc.

void Apps::RangeServer::drop_range	(	ResponseCallback *	cb,
		const TableIdentifier &	table,
		const RangeSpec &	range_spec
	)

Remove the range

Definition at line 2819 of file RangeServer.cc.

void Apps::RangeServer::drop_table	(	ResponseCallback *	cb,
		const TableIdentifier &	table
	)

Definition at line 2155 of file RangeServer.cc.

void Apps::RangeServer::dump	(	ResponseCallback *	cb,
		const char *	outfile,
		bool	nokeys
	)

Definition at line 2236 of file RangeServer.cc.

void Apps::RangeServer::dump_pseudo_table	(	ResponseCallback *	cb,
		const TableIdentifier &	table,
		const char *	pseudo_table,
		const char *	outfile
	)

Deprecated:

Definition at line 2306 of file RangeServer.cc.

void Apps::RangeServer::fetch_scanblock	(	Response::Callback::CreateScanner *	cb,
		int32_t	scanner_id
	)

Send back data

Definition at line 1623 of file RangeServer.cc.

ApplicationQueuePtr Hypertable::Apps::RangeServer::get_application_queue ( )

inline

Definition at line 206 of file RangeServer.h.

MaintenanceSchedulerPtr& Hypertable::Apps::RangeServer::get_scheduler ( )

inline

Definition at line 204 of file RangeServer.h.

void Apps::RangeServer::get_statistics	(	Response::Callback::GetStatistics *	cb,
		const std::vector< SystemVariable::Spec > &	specs,
		uint64_t	generation
	)

Aggregate per-table stats

If created a mutator above, write data to sys/RS_METRICS

Definition at line 2463 of file RangeServer.cc.

void Hypertable::Apps::RangeServer::get_table_schemas ( TableSchemaMap & table_schemas )

private

void Apps::RangeServer::group_commit ( )

Definition at line 3666 of file RangeServer.cc.

void Apps::RangeServer::group_commit_add	(	EventPtr &	event,
		uint64_t	cluster_id,
		SchemaPtr &	schema,
		const TableIdentifier &	table,
		uint32_t	count,
		StaticBuffer &	buffer,
		uint32_t	flags
	)

private

Definition at line 3720 of file RangeServer.cc.

void Apps::RangeServer::heapcheck	(	ResponseCallback *	cb,
		const char *	outfile
	)

Definition at line 2373 of file RangeServer.cc.

void Apps::RangeServer::initialize ( PropertiesPtr & props )

private

Figure out and create range server directory
Clear any Range server state (including any partially created commit logs)
Open the commit log

Create log directories

Definition at line 486 of file RangeServer.cc.

bool Apps::RangeServer::live ( const vector< QualifiedRangeSpec > & ranges )

private

Definition at line 3604 of file RangeServer.cc.

bool Apps::RangeServer::live ( const QualifiedRangeSpec & spec )

private

Definition at line 3617 of file RangeServer.cc.

void Apps::RangeServer::load_range	(	ResponseCallback *	cb,
		const TableIdentifier &	table,
		const RangeSpec &	range_spec,
		const RangeState &	range_state,
		bool	needs_compaction
	)

Queue "range_start_row" update for sys/RS_METRICS table

Check for existence of and create, if necessary, range directory (md5 of endrow) under all locality group directories for this table

Take ownership of the range by writing the 'Location' column in the METADATA table, or /hypertable/root{location} attribute of Hyperspace if it is the root range.

Take ownership of the range

Definition at line 1720 of file RangeServer.cc.

void Apps::RangeServer::local_recover ( )

private

Create the logs

Definition at line 596 of file RangeServer.cc.

static void Hypertable::Apps::RangeServer::map_table_schemas	(	const String &	parent,
		const std::vector< DirEntryAttr > &	listing,
		TableSchemaMap &	table_schemas
	)

staticprivate

void Hypertable::Apps::RangeServer::master_change ( )

void Apps::RangeServer::metadata_sync	(	ResponseCallback *	cb,
		const char *	table_id,
		uint32_t	flags,
		std::vector< const char * >	columns
	)

Definition at line 1289 of file RangeServer.cc.

void Apps::RangeServer::phantom_commit_ranges	(	ResponseCallback *	cb,
		int64_t	op_id,
		const String &	location,
		int32_t	plan_generation,
		const vector< QualifiedRangeSpec > &	ranges
	)

Take ownership of the range by writing the 'Location' column in the METADATA table, or /hypertable/root{location} attribute of Hyperspace if it is the root range.

Definition at line 3395 of file RangeServer.cc.

void Apps::RangeServer::phantom_load	(	ResponseCallback *	cb,
		const String &	location,
		int32_t	plan_generation,
		const vector< int32_t > &	fragments,
		const vector< QualifiedRangeSpec > &	specs,
		const vector< RangeState > &	states
	)

Definition at line 3033 of file RangeServer.cc.

void Apps::RangeServer::phantom_prepare_ranges	(	ResponseCallback *	cb,
		int64_t	op_id,
		const String &	location,
		int32_t	plan_generation,
		const vector< QualifiedRangeSpec > &	ranges
	)

Definition at line 3174 of file RangeServer.cc.

void Apps::RangeServer::phantom_update	(	Response::Callback::PhantomUpdate *	cb,
		const String &	location,
		int32_t	plan_generation,
		const QualifiedRangeSpec &	range,
		int32_t	fragment,
		EventPtr &	event
	)

Definition at line 3115 of file RangeServer.cc.

void Apps::RangeServer::relinquish_range	(	ResponseCallback *	cb,
		const TableIdentifier &	table,
		const RangeSpec &	range_spec
	)

Definition at line 2852 of file RangeServer.cc.

bool Hypertable::Apps::RangeServer::replay_finished ( )

inline

Definition at line 210 of file RangeServer.h.

void Apps::RangeServer::replay_fragments	(	ResponseCallback *	cb,
		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
	)

Definition at line 2890 of file RangeServer.cc.

void Apps::RangeServer::replay_load_range	(	TableInfoMap &	replay_map,
		MetaLogEntityRangePtr &	range_entity
	)

private

Lazily create sys/METADATA table pointer

Definition at line 976 of file RangeServer.cc.

void Apps::RangeServer::replay_log	(	TableInfoMap &	replay_map,
		CommitLogReaderPtr &	log_reader
	)

private

Definition at line 1052 of file RangeServer.cc.

void Apps::RangeServer::set_state	(	ResponseCallback *	cb,
		const std::vector< SystemVariable::Spec > &	specs,
		int64_t	generation
	)

Definition at line 2397 of file RangeServer.cc.

void Apps::RangeServer::shutdown ( )

Definition at line 397 of file RangeServer.cc.

void Apps::RangeServer::status ( Response::Callback::Status * cb )

Definition at line 375 of file RangeServer.cc.

void Apps::RangeServer::table_maintenance_disable	(	ResponseCallback *	cb,
		const TableIdentifier &	table
	)

Disables maintenance for a table.

This function disables maintenance for the table identified by table, waits for any in progress maintenance on any of the table's ranges to complete, and then calls IndexUpdaterFactory::clear_cache() to drop any cached index tables.

Parameters

cb	Response callback
table	Table identifier

Definition at line 2431 of file RangeServer.cc.

void Apps::RangeServer::table_maintenance_enable	(	ResponseCallback *	cb,
		const TableIdentifier &	table
	)

Enables maintenance for a table.

Parameters

cb	Response callback
table	Table identifier

Definition at line 2408 of file RangeServer.cc.

bool Hypertable::Apps::RangeServer::test_and_set_get_statistics_outstanding ( bool value )

inlineprivate

Performs a "test and set" operation on m_get_statistics_outstanding.

Parameters

value New value for m_get_statistics_outstanding

Returns: Previous value of m_get_statistics_outstanding

Definition at line 251 of file RangeServer.h.

void Apps::RangeServer::update	(	Response::Callback::Update *	cb,
		uint64_t	cluster_id,
		const TableIdentifier &	table,
		uint32_t	count,
		StaticBuffer &	buffer,
		uint32_t	flags
	)

Inserts data into a table.

TODO: set commit_interval.

Definition at line 2091 of file RangeServer.cc.

void Apps::RangeServer::update_schema	(	ResponseCallback *	cb,
		const TableIdentifier &	table,
		const char *	schema_str
	)

Definition at line 1995 of file RangeServer.cc.

void Apps::RangeServer::verify_schema	(	TableInfoPtr &	table_info,
		uint32_t	generation,
		const TableSchemaMap *	table_schemas = `0`
	)

private

Definition at line 3635 of file RangeServer.cc.

void Apps::RangeServer::wait_for_maintenance ( ResponseCallback * cb )

Blocks while the maintenance queue is non-empty.

Parameters

cb	Response callback

Definition at line 3627 of file RangeServer.cc.

void Hypertable::Apps::RangeServer::write_profile_data ( const String & line )

inline

Definition at line 218 of file RangeServer.h.

Member Data Documentation

ApplicationQueuePtr Hypertable::Apps::RangeServer::m_app_queue

private

Definition at line 296 of file RangeServer.h.

uint64_t Hypertable::Apps::RangeServer::m_bytes_loaded

private

Definition at line 306 of file RangeServer.h.

ConnectionManagerPtr Hypertable::Apps::RangeServer::m_conn_manager

private

Definition at line 295 of file RangeServer.h.

ContextPtr Hypertable::Apps::RangeServer::m_context

private

Definition at line 259 of file RangeServer.h.

int32_t Hypertable::Apps::RangeServer::m_control_file_check_interval {}

private

Definition at line 342 of file RangeServer.h.

size_t Hypertable::Apps::RangeServer::m_cores {}

private

Definition at line 338 of file RangeServer.h.

uint64_t Hypertable::Apps::RangeServer::m_existence_file_handle

private

Definition at line 297 of file RangeServer.h.

LockSequencer Hypertable::Apps::RangeServer::m_existence_file_sequencer

private

Definition at line 298 of file RangeServer.h.

FailoverPhantomRangeMap Hypertable::Apps::RangeServer::m_failover_map

private

Definition at line 292 of file RangeServer.h.

std::mutex Hypertable::Apps::RangeServer::m_failover_mutex

private

Definition at line 293 of file RangeServer.h.

MetricsCollectorGangliaPtr Hypertable::Apps::RangeServer::m_ganglia_collector

private

Ganglia metrics collector.

Definition at line 348 of file RangeServer.h.

bool Hypertable::Apps::RangeServer::m_get_statistics_outstanding {}

private

Indicates if a get_statistics() call is outstanding.

Definition at line 316 of file RangeServer.h.

GroupCommitInterfacePtr Hypertable::Apps::RangeServer::m_group_commit

private

Definition at line 327 of file RangeServer.h.

GroupCommitTimerHandlerPtr Hypertable::Apps::RangeServer::m_group_commit_timer_handler

private

Definition at line 328 of file RangeServer.h.

Hyperspace::SessionPtr Hypertable::Apps::RangeServer::m_hyperspace

private

Definition at line 301 of file RangeServer.h.

std::chrono::steady_clock::time_point Hypertable::Apps::RangeServer::m_last_control_file_check

private

Definition at line 341 of file RangeServer.h.

time_t Hypertable::Apps::RangeServer::m_last_metrics_update {}

private

Definition at line 331 of file RangeServer.h.

LoadFactors Hypertable::Apps::RangeServer::m_load_factors

private

Definition at line 336 of file RangeServer.h.

LoadStatisticsPtr Hypertable::Apps::RangeServer::m_load_statistics

private

Definition at line 310 of file RangeServer.h.

double Hypertable::Apps::RangeServer::m_loadavg_accum {}

private

Definition at line 333 of file RangeServer.h.

Filesystem::Flags Hypertable::Apps::RangeServer::m_log_flush_method_meta

private

Flush method for METADATA commit log updates.

Definition at line 272 of file RangeServer.h.

Filesystem::Flags Hypertable::Apps::RangeServer::m_log_flush_method_user {}

private

Flush method for USER commit log updates.

Definition at line 275 of file RangeServer.h.

LogReplayBarrierPtr Hypertable::Apps::RangeServer::m_log_replay_barrier

private

Definition at line 260 of file RangeServer.h.

uint64_t Hypertable::Apps::RangeServer::m_log_roll_limit

private

Definition at line 307 of file RangeServer.h.

MaintenanceSchedulerPtr Hypertable::Apps::RangeServer::m_maintenance_scheduler

private

Smart pointer to maintenance scheduler.

Definition at line 322 of file RangeServer.h.

Lib::Master::ClientPtr Hypertable::Apps::RangeServer::m_master_client

private

Definition at line 300 of file RangeServer.h.

std::shared_ptr<ConnectionHandler> Hypertable::Apps::RangeServer::m_master_connection_handler

private

Definition at line 299 of file RangeServer.h.

size_t Hypertable::Apps::RangeServer::m_metric_samples {}

private

Definition at line 337 of file RangeServer.h.

MetricsProcess Hypertable::Apps::RangeServer::m_metrics_process

private

Process metrics.

Definition at line 351 of file RangeServer.h.

std::mutex Hypertable::Apps::RangeServer::m_mutex

private

Definition at line 258 of file RangeServer.h.

NameIdMapperPtr Hypertable::Apps::RangeServer::m_namemap

private

Table name-to-ID mapper

Definition at line 319 of file RangeServer.h.

time_t Hypertable::Apps::RangeServer::m_next_metrics_update {}

private

Definition at line 332 of file RangeServer.h.

uint64_t Hypertable::Apps::RangeServer::m_page_in_accum {}

private

Definition at line 334 of file RangeServer.h.

uint64_t Hypertable::Apps::RangeServer::m_page_out_accum {}

private

Definition at line 335 of file RangeServer.h.

std::mutex Hypertable::Apps::RangeServer::m_pending_metrics_mutex

private

Definition at line 339 of file RangeServer.h.

CellsBuilder* Hypertable::Apps::RangeServer::m_pending_metrics_updates {}

private

Definition at line 340 of file RangeServer.h.

std::mutex Hypertable::Apps::RangeServer::m_profile_mutex

private

Definition at line 345 of file RangeServer.h.

bool Hypertable::Apps::RangeServer::m_profile_query {}

private

Definition at line 344 of file RangeServer.h.

std::ofstream Hypertable::Apps::RangeServer::m_profile_query_out

private

Definition at line 343 of file RangeServer.h.

PropertiesPtr Hypertable::Apps::RangeServer::m_props

private

Configuration properties.

Definition at line 280 of file RangeServer.h.

QueryCachePtr Hypertable::Apps::RangeServer::m_query_cache

private

Definition at line 329 of file RangeServer.h.

int64_t Hypertable::Apps::RangeServer::m_scanner_buffer_size {}

private

Definition at line 330 of file RangeServer.h.

ScannerMap Hypertable::Apps::RangeServer::m_scanner_map

private

Outstanding scanner map.

Definition at line 304 of file RangeServer.h.

uint32_t Hypertable::Apps::RangeServer::m_scanner_ttl

private

Definition at line 305 of file RangeServer.h.

bool Hypertable::Apps::RangeServer::m_shutdown {}

private

Flag indicating if server is shutting down.

Definition at line 289 of file RangeServer.h.

bool Hypertable::Apps::RangeServer::m_startup {true}

private

Flag indicating if server is starting up.

Definition at line 286 of file RangeServer.h.

StatsRangeServerPtr Hypertable::Apps::RangeServer::m_stats

private

Definition at line 309 of file RangeServer.h.

int64_t Hypertable::Apps::RangeServer::m_stats_last_timestamp {}

private

Timestamp (nanoseconds) of last metrics collection.

Definition at line 313 of file RangeServer.h.

std::mutex Hypertable::Apps::RangeServer::m_stats_mutex

private

Definition at line 277 of file RangeServer.h.

TimerHandlerPtr Hypertable::Apps::RangeServer::m_timer_handler

private

Smart pointer to timer handler.

Definition at line 325 of file RangeServer.h.

UpdatePipelinePtr Hypertable::Apps::RangeServer::m_update_pipeline_metadata

private

Update pipeline for METADTA table.

Definition at line 263 of file RangeServer.h.

UpdatePipelinePtr Hypertable::Apps::RangeServer::m_update_pipeline_system

private

Update pipeline for other (non-METADATA) system tables.

Definition at line 266 of file RangeServer.h.

UpdatePipelinePtr Hypertable::Apps::RangeServer::m_update_pipeline_user

private

Update pipeline for USER tables.

Definition at line 269 of file RangeServer.h.

bool Hypertable::Apps::RangeServer::m_verbose {}

private

Flag indicating if verbose logging is enabled.

Definition at line 283 of file RangeServer.h.

The documentation for this class was generated from the following files:

/home/doug/src/hypertable/src/cc/Hypertable/RangeServer/RangeServer.h
/home/doug/src/hypertable/src/cc/Hypertable/RangeServer/RangeServer.cc

Public Member Functions

Private Types

Private Member Functions

Static Private Member Functions

Private Attributes

Detailed Description

Member Typedef Documentation

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation