#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.
1.8.8