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

#include <GroupCommitTimerHandler.h>

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

Public Member Functions

 GroupCommitTimerHandler (Comm *comm, Apps::RangeServer *range_server, ApplicationQueuePtr &app_queue)
 
void start ()
 
virtual void handle (Hypertable::EventPtr &event_ptr)
 Callback method. More...
 
void shutdown ()
 
- Public Member Functions inherited from Hypertable::DispatchHandler
virtual ~DispatchHandler ()
 Destructor. More...
 

Private Attributes

std::mutex m_mutex
 
Commm_comm {}
 
Apps::RangeServerm_range_server {}
 
ApplicationQueuePtr m_app_queue
 
int32_t m_commit_interval {}
 
bool m_shutdown {}
 

Detailed Description

Definition at line 38 of file GroupCommitTimerHandler.h.

Constructor & Destructor Documentation

GroupCommitTimerHandler::GroupCommitTimerHandler ( Comm comm,
Apps::RangeServer range_server,
ApplicationQueuePtr app_queue 
)

Definition at line 38 of file GroupCommitTimerHandler.cc.

Member Function Documentation

void GroupCommitTimerHandler::handle ( Hypertable::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_ptrsmart pointer to Event object

Implements Hypertable::DispatchHandler.

Definition at line 51 of file GroupCommitTimerHandler.cc.

void GroupCommitTimerHandler::shutdown ( )

Definition at line 65 of file GroupCommitTimerHandler.cc.

void GroupCommitTimerHandler::start ( )

Definition at line 44 of file GroupCommitTimerHandler.cc.

Member Data Documentation

ApplicationQueuePtr Hypertable::GroupCommitTimerHandler::m_app_queue
private

Definition at line 50 of file GroupCommitTimerHandler.h.

Comm* Hypertable::GroupCommitTimerHandler::m_comm {}
private

Definition at line 48 of file GroupCommitTimerHandler.h.

int32_t Hypertable::GroupCommitTimerHandler::m_commit_interval {}
private

Definition at line 51 of file GroupCommitTimerHandler.h.

std::mutex Hypertable::GroupCommitTimerHandler::m_mutex
private

Definition at line 47 of file GroupCommitTimerHandler.h.

Apps::RangeServer* Hypertable::GroupCommitTimerHandler::m_range_server {}
private

Definition at line 49 of file GroupCommitTimerHandler.h.

bool Hypertable::GroupCommitTimerHandler::m_shutdown {}
private

Definition at line 52 of file GroupCommitTimerHandler.h.


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