#include <TableMutatorAsyncScatterBuffer.h>

Collaboration diagram for Hypertable::TableMutatorAsyncScatterBuffer:

Public Member Functions
	TableMutatorAsyncScatterBuffer (Comm comm, ApplicationQueueInterfacePtr &app_queue, TableMutatorAsync mutator, const TableIdentifier *, SchemaPtr &, RangeLocatorPtr &, bool auto_refresh, uint32_t timeout_ms, uint32_t id)

virtual	~TableMutatorAsyncScatterBuffer ()

void	set (const Key &, const ColumnFamilySpec cf, const void value, uint32_t value_len, size_t incr_mem)

void	set_delete (const Key &key, size_t incr_mem)

void	set (SerializedKey key, ByteString value, size_t incr_mem)

bool	full ()

void	send (uint32_t flags)

void	wait_for_completion ()

TableMutatorAsyncScatterBufferPtr	create_redo_buffer (uint32_t id)

uint64_t	get_resend_count ()

void	get_failed_mutations (FailedMutations &failed_mutations)

size_t	get_failure_count ()

void	refresh_schema (const TableIdentifier &table_id, SchemaPtr &schema)

uint32_t	get_id () const

uint32_t	get_send_flags () const

const CommAddressSet &	get_unsynced_rangeservers ()

size_t	memory_used () const
	Returns the amount of memory used by the collected mutations. More...

void	set_memory_used (size_t mem)

void	finish ()

void	set_retries_to_fail (int error)

Private Types
typedef CommAddressMap < TableMutatorAsyncSendBufferPtr >	TableMutatorAsyncSendBufferMap

Private Member Functions
int	set_failed_mutations ()

Private Attributes
Comm *	m_comm

ApplicationQueueInterfacePtr	m_app_queue

TableMutatorAsync *	m_mutator

SchemaPtr	m_schema

RangeLocatorPtr	m_range_locator

LocationCachePtr	m_location_cache

Lib::RangeServer::Client	m_range_server

TableIdentifierManaged	m_table_identifier

TableMutatorAsyncSendBufferMap	m_buffer_map

TableMutatorAsyncCompletionCounter	m_completion_counter

bool	m_full {}

uint64_t	m_resends {}

FailedMutations	m_failed_mutations

FlyweightString	m_constant_strings

bool	m_auto_refresh

uint32_t	m_timeout_ms

uint32_t	m_server_flush_limit

DynamicBuffer	m_counter_value

Timer	m_timer

uint32_t	m_id

CommAddressSet	m_unsynced_rangeservers

size_t	m_memory_used {}

std::mutex	m_mutex

std::condition_variable	m_cond

bool	m_outstanding {}

uint32_t	m_send_flags {}

uint32_t	m_wait_time

bool	dead {}

Static Private Attributes
static const uint32_t	ms_init_redo_wait_time =1000

Detailed Description

Definition at line 64 of file TableMutatorAsyncScatterBuffer.h.

Member Typedef Documentation

typedef CommAddressMap<TableMutatorAsyncSendBufferPtr> Hypertable::TableMutatorAsyncScatterBuffer::TableMutatorAsyncSendBufferMap

private

Definition at line 108 of file TableMutatorAsyncScatterBuffer.h.

Constructor & Destructor Documentation

TableMutatorAsyncScatterBuffer::TableMutatorAsyncScatterBuffer	(	Comm *	comm,
		ApplicationQueueInterfacePtr &	app_queue,
		TableMutatorAsync *	mutator,
		const TableIdentifier *	table_identifier,
		SchemaPtr &	schema,
		RangeLocatorPtr &	range_locator,
		bool	auto_refresh,
		uint32_t	timeout_ms,
		uint32_t	id
	)

Definition at line 49 of file TableMutatorAsyncScatterBuffer.cc.

TableMutatorAsyncScatterBuffer::~TableMutatorAsyncScatterBuffer ( )

virtual

Definition at line 67 of file TableMutatorAsyncScatterBuffer.cc.

Member Function Documentation

TableMutatorAsyncScatterBufferPtr TableMutatorAsyncScatterBuffer::create_redo_buffer ( uint32_t id )

Definition at line 360 of file TableMutatorAsyncScatterBuffer.cc.

void TableMutatorAsyncScatterBuffer::finish ( )

Definition at line 497 of file TableMutatorAsyncScatterBuffer.cc.

bool Hypertable::TableMutatorAsyncScatterBuffer::full ( )

inline

Definition at line 78 of file TableMutatorAsyncScatterBuffer.h.

void Hypertable::TableMutatorAsyncScatterBuffer::get_failed_mutations ( FailedMutations & failed_mutations )

inline

Definition at line 84 of file TableMutatorAsyncScatterBuffer.h.

size_t Hypertable::TableMutatorAsyncScatterBuffer::get_failure_count ( )

inline

Definition at line 87 of file TableMutatorAsyncScatterBuffer.h.

uint32_t Hypertable::TableMutatorAsyncScatterBuffer::get_id ( ) const

inline

Definition at line 93 of file TableMutatorAsyncScatterBuffer.h.

uint64_t Hypertable::TableMutatorAsyncScatterBuffer::get_resend_count ( )

inline

Definition at line 82 of file TableMutatorAsyncScatterBuffer.h.

uint32_t Hypertable::TableMutatorAsyncScatterBuffer::get_send_flags ( ) const

inline

Definition at line 94 of file TableMutatorAsyncScatterBuffer.h.

const CommAddressSet& Hypertable::TableMutatorAsyncScatterBuffer::get_unsynced_rangeservers ( )

inline

Definition at line 95 of file TableMutatorAsyncScatterBuffer.h.

size_t Hypertable::TableMutatorAsyncScatterBuffer::memory_used ( ) const

inline

Returns the amount of memory used by the collected mutations.

Returns: amount of memory used by the collected mutations.

Definition at line 101 of file TableMutatorAsyncScatterBuffer.h.

void Hypertable::TableMutatorAsyncScatterBuffer::refresh_schema	(	const TableIdentifier &	table_id,
		SchemaPtr &	schema
	)

inline

Definition at line 88 of file TableMutatorAsyncScatterBuffer.h.

void TableMutatorAsyncScatterBuffer::send ( uint32_t flags )

Send update

Definition at line 242 of file TableMutatorAsyncScatterBuffer.cc.

void TableMutatorAsyncScatterBuffer::set	(	const Key &	key,
		const ColumnFamilySpec *	cf,
		const void *	value,
		uint32_t	value_len,
		size_t	incr_mem
	)

Definition at line 73 of file TableMutatorAsyncScatterBuffer.cc.

void TableMutatorAsyncScatterBuffer::set	(	SerializedKey	key,
		ByteString	value,
		size_t	incr_mem
	)

Definition at line 194 of file TableMutatorAsyncScatterBuffer.cc.

void TableMutatorAsyncScatterBuffer::set_delete	(	const Key &	key,
		size_t	incr_mem
	)

Definition at line 149 of file TableMutatorAsyncScatterBuffer.cc.

int TableMutatorAsyncScatterBuffer::set_failed_mutations ( )

private

Definition at line 450 of file TableMutatorAsyncScatterBuffer.cc.

void Hypertable::TableMutatorAsyncScatterBuffer::set_memory_used ( size_t mem )

inline

Definition at line 102 of file TableMutatorAsyncScatterBuffer.h.

void TableMutatorAsyncScatterBuffer::set_retries_to_fail ( int error )

Definition at line 411 of file TableMutatorAsyncScatterBuffer.cc.

void TableMutatorAsyncScatterBuffer::wait_for_completion ( )

Definition at line 353 of file TableMutatorAsyncScatterBuffer.cc.

Member Data Documentation

bool Hypertable::TableMutatorAsyncScatterBuffer::dead {}

private

Definition at line 138 of file TableMutatorAsyncScatterBuffer.h.

ApplicationQueueInterfacePtr Hypertable::TableMutatorAsyncScatterBuffer::m_app_queue

private

Definition at line 111 of file TableMutatorAsyncScatterBuffer.h.

bool Hypertable::TableMutatorAsyncScatterBuffer::m_auto_refresh

private

Definition at line 124 of file TableMutatorAsyncScatterBuffer.h.

TableMutatorAsyncSendBufferMap Hypertable::TableMutatorAsyncScatterBuffer::m_buffer_map

private

Definition at line 118 of file TableMutatorAsyncScatterBuffer.h.

Comm* Hypertable::TableMutatorAsyncScatterBuffer::m_comm

private

Definition at line 110 of file TableMutatorAsyncScatterBuffer.h.

TableMutatorAsyncCompletionCounter Hypertable::TableMutatorAsyncScatterBuffer::m_completion_counter

private

Definition at line 119 of file TableMutatorAsyncScatterBuffer.h.

std::condition_variable Hypertable::TableMutatorAsyncScatterBuffer::m_cond

private

Definition at line 133 of file TableMutatorAsyncScatterBuffer.h.

FlyweightString Hypertable::TableMutatorAsyncScatterBuffer::m_constant_strings

private

Definition at line 123 of file TableMutatorAsyncScatterBuffer.h.

DynamicBuffer Hypertable::TableMutatorAsyncScatterBuffer::m_counter_value

private

Definition at line 127 of file TableMutatorAsyncScatterBuffer.h.

FailedMutations Hypertable::TableMutatorAsyncScatterBuffer::m_failed_mutations

private

Definition at line 122 of file TableMutatorAsyncScatterBuffer.h.

bool Hypertable::TableMutatorAsyncScatterBuffer::m_full {}

private

Definition at line 120 of file TableMutatorAsyncScatterBuffer.h.

uint32_t Hypertable::TableMutatorAsyncScatterBuffer::m_id

private

Definition at line 129 of file TableMutatorAsyncScatterBuffer.h.

LocationCachePtr Hypertable::TableMutatorAsyncScatterBuffer::m_location_cache

private

Definition at line 115 of file TableMutatorAsyncScatterBuffer.h.

size_t Hypertable::TableMutatorAsyncScatterBuffer::m_memory_used {}

private

Definition at line 131 of file TableMutatorAsyncScatterBuffer.h.

TableMutatorAsync* Hypertable::TableMutatorAsyncScatterBuffer::m_mutator

private

Definition at line 112 of file TableMutatorAsyncScatterBuffer.h.

std::mutex Hypertable::TableMutatorAsyncScatterBuffer::m_mutex

private

Definition at line 132 of file TableMutatorAsyncScatterBuffer.h.

bool Hypertable::TableMutatorAsyncScatterBuffer::m_outstanding {}

private

Definition at line 134 of file TableMutatorAsyncScatterBuffer.h.

RangeLocatorPtr Hypertable::TableMutatorAsyncScatterBuffer::m_range_locator

private

Definition at line 114 of file TableMutatorAsyncScatterBuffer.h.

Lib::RangeServer::Client Hypertable::TableMutatorAsyncScatterBuffer::m_range_server

private

Definition at line 116 of file TableMutatorAsyncScatterBuffer.h.

uint64_t Hypertable::TableMutatorAsyncScatterBuffer::m_resends {}

private

Definition at line 121 of file TableMutatorAsyncScatterBuffer.h.

SchemaPtr Hypertable::TableMutatorAsyncScatterBuffer::m_schema

private

Definition at line 113 of file TableMutatorAsyncScatterBuffer.h.

uint32_t Hypertable::TableMutatorAsyncScatterBuffer::m_send_flags {}

private

Definition at line 135 of file TableMutatorAsyncScatterBuffer.h.

uint32_t Hypertable::TableMutatorAsyncScatterBuffer::m_server_flush_limit

private

Definition at line 126 of file TableMutatorAsyncScatterBuffer.h.

TableIdentifierManaged Hypertable::TableMutatorAsyncScatterBuffer::m_table_identifier

private

Definition at line 117 of file TableMutatorAsyncScatterBuffer.h.

uint32_t Hypertable::TableMutatorAsyncScatterBuffer::m_timeout_ms

private

Definition at line 125 of file TableMutatorAsyncScatterBuffer.h.

Timer Hypertable::TableMutatorAsyncScatterBuffer::m_timer

private

Definition at line 128 of file TableMutatorAsyncScatterBuffer.h.

CommAddressSet Hypertable::TableMutatorAsyncScatterBuffer::m_unsynced_rangeservers

private

Definition at line 130 of file TableMutatorAsyncScatterBuffer.h.

uint32_t Hypertable::TableMutatorAsyncScatterBuffer::m_wait_time

private

Definition at line 136 of file TableMutatorAsyncScatterBuffer.h.

const uint32_t Hypertable::TableMutatorAsyncScatterBuffer::ms_init_redo_wait_time =1000

staticprivate

Definition at line 137 of file TableMutatorAsyncScatterBuffer.h.

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

/home/doug/src/hypertable/src/cc/Hypertable/Lib/TableMutatorAsyncScatterBuffer.h
/home/doug/src/hypertable/src/cc/Hypertable/Lib/TableMutatorAsyncScatterBuffer.cc

Public Member Functions

Private Types

Private Member Functions

Private Attributes

Static Private Attributes

Detailed Description

Member Typedef Documentation

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation