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

This class is a DispatchHandler class that is used for collecting asynchronous commit log sync requests. More...

#include <TableMutatorSyncDispatchHandler.h>

Inheritance diagram for Hypertable::TableMutatorSyncDispatchHandler:
Inheritance graph
[legend]
Collaboration diagram for Hypertable::TableMutatorSyncDispatchHandler:
Collaboration graph
[legend]

Classes

struct  ErrorResult
 

Public Member Functions

 TableMutatorSyncDispatchHandler (Comm *comm, TableIdentifierManaged &table_id, time_t timeout)
 Constructor. More...
 
 ~TableMutatorSyncDispatchHandler ()
 Destructor. More...
 
void add (const CommAddress &addr)
 Adds. More...
 
virtual void handle (EventPtr &event_ptr)
 Dispatch method. More...
 
bool wait_for_completion ()
 
void retry ()
 
void get_errors (vector< ErrorResult > &errors)
 
- Public Member Functions inherited from Hypertable::DispatchHandler
virtual ~DispatchHandler ()
 Destructor. More...
 

Private Attributes

std::mutex m_mutex
 
std::condition_variable m_cond
 
int m_outstanding {}
 
RangeServer::Client m_client
 
vector< ErrorResultm_errors
 
CommAddressSet m_pending
 
TableIdentifierManagedm_table_identifier
 

Detailed Description

This class is a DispatchHandler class that is used for collecting asynchronous commit log sync requests.

Definition at line 52 of file TableMutatorSyncDispatchHandler.h.

Constructor & Destructor Documentation

TableMutatorSyncDispatchHandler::TableMutatorSyncDispatchHandler ( Comm comm,
TableIdentifierManaged table_id,
time_t  timeout 
)

Constructor.

Definition at line 40 of file TableMutatorSyncDispatchHandler.cc.

TableMutatorSyncDispatchHandler::~TableMutatorSyncDispatchHandler ( )

Destructor.

Definition at line 45 of file TableMutatorSyncDispatchHandler.cc.

Member Function Documentation

void TableMutatorSyncDispatchHandler::add ( const CommAddress addr)

Adds.

Definition at line 47 of file TableMutatorSyncDispatchHandler.cc.

void TableMutatorSyncDispatchHandler::get_errors ( vector< ErrorResult > &  errors)

Definition at line 128 of file TableMutatorSyncDispatchHandler.cc.

void TableMutatorSyncDispatchHandler::handle ( EventPtr event_ptr)
virtual

Dispatch method.

This gets called by the AsyncComm layer when an event occurs in response to a previously sent request that was supplied with this dispatch handler.

Parameters
event_ptrshared pointer to event object

Implements Hypertable::DispatchHandler.

Definition at line 66 of file TableMutatorSyncDispatchHandler.cc.

void TableMutatorSyncDispatchHandler::retry ( )

Definition at line 100 of file TableMutatorSyncDispatchHandler.cc.

bool TableMutatorSyncDispatchHandler::wait_for_completion ( )

Definition at line 121 of file TableMutatorSyncDispatchHandler.cc.

Member Data Documentation

RangeServer::Client Hypertable::TableMutatorSyncDispatchHandler::m_client
private

Definition at line 95 of file TableMutatorSyncDispatchHandler.h.

std::condition_variable Hypertable::TableMutatorSyncDispatchHandler::m_cond
private

Definition at line 93 of file TableMutatorSyncDispatchHandler.h.

vector<ErrorResult> Hypertable::TableMutatorSyncDispatchHandler::m_errors
private

Definition at line 96 of file TableMutatorSyncDispatchHandler.h.

std::mutex Hypertable::TableMutatorSyncDispatchHandler::m_mutex
private

Definition at line 92 of file TableMutatorSyncDispatchHandler.h.

int Hypertable::TableMutatorSyncDispatchHandler::m_outstanding {}
private

Definition at line 94 of file TableMutatorSyncDispatchHandler.h.

CommAddressSet Hypertable::TableMutatorSyncDispatchHandler::m_pending
private

Definition at line 97 of file TableMutatorSyncDispatchHandler.h.

TableIdentifierManaged& Hypertable::TableMutatorSyncDispatchHandler::m_table_identifier
private

Definition at line 98 of file TableMutatorSyncDispatchHandler.h.


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