#include <GroupCommitTimerHandler.h>
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 |
Comm * | m_comm {} |
Apps::RangeServer * | m_range_server {} |
ApplicationQueuePtr | m_app_queue |
int32_t | m_commit_interval {} |
bool | m_shutdown {} |
Definition at line 38 of file GroupCommitTimerHandler.h.
GroupCommitTimerHandler::GroupCommitTimerHandler | ( | Comm * | comm, |
Apps::RangeServer * | range_server, | ||
ApplicationQueuePtr & | app_queue | ||
) |
Definition at line 38 of file GroupCommitTimerHandler.cc.
|
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.
event_ptr | smart 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.
|
private |
Definition at line 50 of file GroupCommitTimerHandler.h.
|
private |
Definition at line 48 of file GroupCommitTimerHandler.h.
|
private |
Definition at line 51 of file GroupCommitTimerHandler.h.
|
private |
Definition at line 47 of file GroupCommitTimerHandler.h.
|
private |
Definition at line 49 of file GroupCommitTimerHandler.h.
|
private |
Definition at line 52 of file GroupCommitTimerHandler.h.