Hypertable::ReplayBuffer Class Reference

#include <ReplayBuffer.h>

Collaboration diagram for Hypertable::ReplayBuffer:

Public Member Functions
	ReplayBuffer (PropertiesPtr &props, Comm *comm, const RangeServerRecovery::ReceiverPlan &plan, const String &location, int32_t plan_generation)
void	add (const TableIdentifier &table, SerializedKey &key, ByteString &value)
size_t	memory_used () const
void	set_current_fragment (uint32_t fragment_id)
void	flush ()

Private Types
typedef map < QualifiedRangeSpec, RangeReplayBufferPtr >	ReplayBufferMap

Private Attributes
Comm *	m_comm
const RangeServerRecovery::ReceiverPlan &	m_plan
ReplayBufferMap	m_buffer_map
String	m_location
int32_t	m_plan_generation {}
size_t	m_memory_used {}
size_t	m_flush_limit_aggregate {}
size_t	m_flush_limit_per_range {}
int32_t	m_timeout_ms {}
uint32_t	m_fragment {}

Detailed Description

Definition at line 42 of file ReplayBuffer.h.

Member Typedef Documentation

typedef map<QualifiedRangeSpec, RangeReplayBufferPtr> Hypertable::ReplayBuffer::ReplayBufferMap

private

Definition at line 63 of file ReplayBuffer.h.

Constructor & Destructor Documentation

ReplayBuffer::ReplayBuffer	(	PropertiesPtr &	props,
		Comm *	comm,
		const RangeServerRecovery::ReceiverPlan &	plan,
		const String &	location,
		int32_t	plan_generation
	)

Definition at line 32 of file ReplayBuffer.cc.

Member Function Documentation

void ReplayBuffer::add	(	const TableIdentifier &	table,
		SerializedKey &	key,
		ByteString &	value
	)

Definition at line 57 of file ReplayBuffer.cc.

void ReplayBuffer::flush

(

)

Definition at line 85 of file ReplayBuffer.cc.

size_t Hypertable::ReplayBuffer::memory_used ( ) const

inline

Definition at line 51 of file ReplayBuffer.h.

void Hypertable::ReplayBuffer::set_current_fragment ( uint32_t  fragment_id )

inline

Definition at line 53 of file ReplayBuffer.h.

Member Data Documentation

ReplayBufferMap Hypertable::ReplayBuffer::m_buffer_map

private

Definition at line 64 of file ReplayBuffer.h.

Comm* Hypertable::ReplayBuffer::m_comm

private

Definition at line 61 of file ReplayBuffer.h.

size_t Hypertable::ReplayBuffer::m_flush_limit_aggregate {}

private

Definition at line 68 of file ReplayBuffer.h.

size_t Hypertable::ReplayBuffer::m_flush_limit_per_range {}

private

Definition at line 69 of file ReplayBuffer.h.

uint32_t Hypertable::ReplayBuffer::m_fragment {}

private

Definition at line 71 of file ReplayBuffer.h.

String Hypertable::ReplayBuffer::m_location

private

Definition at line 65 of file ReplayBuffer.h.

size_t Hypertable::ReplayBuffer::m_memory_used {}

private

Definition at line 67 of file ReplayBuffer.h.

const RangeServerRecovery::ReceiverPlan& Hypertable::ReplayBuffer::m_plan

private

Definition at line 62 of file ReplayBuffer.h.

int32_t Hypertable::ReplayBuffer::m_plan_generation {}

private

Definition at line 66 of file ReplayBuffer.h.

int32_t Hypertable::ReplayBuffer::m_timeout_ms {}

private

Definition at line 70 of file ReplayBuffer.h.

---

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

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