Hypertable::ReplayDispatchHandler Class Reference

#include <ReplayDispatchHandler.h>

Inheritance diagram for Hypertable::ReplayDispatchHandler:

Collaboration diagram for Hypertable::ReplayDispatchHandler:

Public Member Functions
	ReplayDispatchHandler (Comm *comm, const String &location, int plan_generation, int32_t timeout_ms)
virtual void	handle (EventPtr &event)
	Callback method. More...
void	add (const CommAddress &addr, const QualifiedRangeSpec &range, uint32_t fragment, StaticBuffer &buffer)
void	wait_for_completion ()
Public Member Functions inherited from Hypertable::DispatchHandler
virtual	~DispatchHandler ()
	Destructor. More...

Private Attributes
std::mutex	m_mutex
std::condition_variable	m_cond
RangeServer::Client	m_rsclient
String	m_recover_location
String	m_error_msg
int32_t	m_error {}
int	m_plan_generation {}
size_t	m_outstanding {}

Detailed Description

Definition at line 39 of file ReplayDispatchHandler.h.

Constructor & Destructor Documentation

Hypertable::ReplayDispatchHandler::ReplayDispatchHandler ( Comm *  comm, const String &  location, int  plan_generation, int32_t  timeout_ms  )

inline

Definition at line 42 of file ReplayDispatchHandler.h.

Member Function Documentation

void ReplayDispatchHandler::add	(	const CommAddress &	addr,
		const QualifiedRangeSpec &	range,
		uint32_t	fragment,
		StaticBuffer &	buffer
	)

Definition at line 72 of file ReplayDispatchHandler.cc.

void ReplayDispatchHandler::handle ( EventPtr &  event_ptr )

virtual

Callback method.

When the Comm layer needs to deliver an event to the application, this method is called to do so. The set of event types include, CONNECTION_ESTABLISHED, DISCONNECT, MESSAGE, ERROR, and TIMER.

Parameters

event_ptr

smart pointer to Event object

Implements Hypertable::DispatchHandler.

Definition at line 31 of file ReplayDispatchHandler.cc.

void ReplayDispatchHandler::wait_for_completion

(

)

Definition at line 95 of file ReplayDispatchHandler.cc.

Member Data Documentation

std::condition_variable Hypertable::ReplayDispatchHandler::m_cond

private

Definition at line 56 of file ReplayDispatchHandler.h.

int32_t Hypertable::ReplayDispatchHandler::m_error {}

private

Definition at line 60 of file ReplayDispatchHandler.h.

String Hypertable::ReplayDispatchHandler::m_error_msg

private

Definition at line 59 of file ReplayDispatchHandler.h.

std::mutex Hypertable::ReplayDispatchHandler::m_mutex

private

Definition at line 55 of file ReplayDispatchHandler.h.

size_t Hypertable::ReplayDispatchHandler::m_outstanding {}

private

Definition at line 62 of file ReplayDispatchHandler.h.

int Hypertable::ReplayDispatchHandler::m_plan_generation {}

private

Definition at line 61 of file ReplayDispatchHandler.h.

String Hypertable::ReplayDispatchHandler::m_recover_location

private

Definition at line 58 of file ReplayDispatchHandler.h.

RangeServer::Client Hypertable::ReplayDispatchHandler::m_rsclient

private

Definition at line 57 of file ReplayDispatchHandler.h.

---

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

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