0.9.8.10
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Modules Pages
Public Member Functions | Private Types | Private Member Functions | Private Attributes | Static Private Attributes | List of all members
Hypertable::TableMutatorAsyncScatterBuffer Class Reference

#include <TableMutatorAsyncScatterBuffer.h>

Collaboration diagram for Hypertable::TableMutatorAsyncScatterBuffer:
Collaboration graph
[legend]

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 CommAddressSetget_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

Commm_comm
 
ApplicationQueueInterfacePtr m_app_queue
 
TableMutatorAsyncm_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

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: