#include <ClientKeepaliveHandler.h>
Definition at line 50 of file ClientKeepaliveHandler.h.
void ClientKeepaliveHandler::destroy |
( |
| ) |
|
|
private |
void ClientKeepaliveHandler::destroy_session |
( |
| ) |
|
void ClientKeepaliveHandler::expire_session |
( |
| ) |
|
bool Hyperspace::ClientKeepaliveHandler::get_handle_state |
( |
uint64_t |
handle, |
|
|
ClientHandleStatePtr & |
handle_state |
|
) |
| |
|
inline |
uint64_t Hyperspace::ClientKeepaliveHandler::get_session_id |
( |
| ) |
|
|
inline |
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 97 of file ClientKeepaliveHandler.cc.
void ClientKeepaliveHandler::start |
( |
| ) |
|
void Hyperspace::ClientKeepaliveHandler::unregister_handle |
( |
uint64_t |
handle | ) |
|
|
inline |
void ClientKeepaliveHandler::wait_for_destroy_session |
( |
| ) |
|
Comm* Hyperspace::ClientKeepaliveHandler::m_comm {} |
|
private |
std::condition_variable_any Hyperspace::ClientKeepaliveHandler::m_cond_destroyed |
|
private |
uint16_t Hyperspace::ClientKeepaliveHandler::m_datagram_send_port {} |
|
private |
bool Hyperspace::ClientKeepaliveHandler::m_dead {} |
|
private |
std::set<uint64_t> Hyperspace::ClientKeepaliveHandler::m_delivered_events |
|
private |
bool Hyperspace::ClientKeepaliveHandler::m_destroying {} |
|
private |
HandleMap Hyperspace::ClientKeepaliveHandler::m_handle_map |
|
private |
uint16_t Hyperspace::ClientKeepaliveHandler::m_hyperspace_port {} |
|
private |
std::vector<String> Hyperspace::ClientKeepaliveHandler::m_hyperspace_replicas |
|
private |
std::chrono::steady_clock::time_point Hyperspace::ClientKeepaliveHandler::m_jeopardy_time |
|
private |
uint32_t Hyperspace::ClientKeepaliveHandler::m_keep_alive_interval {} |
|
private |
std::chrono::steady_clock::time_point Hyperspace::ClientKeepaliveHandler::m_last_keep_alive_send_time |
|
private |
uint32_t Hyperspace::ClientKeepaliveHandler::m_lease_interval {} |
|
private |
CommAddress Hyperspace::ClientKeepaliveHandler::m_local_addr |
|
private |
sockaddr_in Hyperspace::ClientKeepaliveHandler::m_master_addr |
|
private |
std::recursive_mutex Hyperspace::ClientKeepaliveHandler::m_mutex |
|
private |
bool Hyperspace::ClientKeepaliveHandler::m_reconnect {} |
|
private |
Session* Hyperspace::ClientKeepaliveHandler::m_session {} |
|
private |
uint64_t Hyperspace::ClientKeepaliveHandler::m_session_id {} |
|
private |
bool Hyperspace::ClientKeepaliveHandler::m_verbose {} |
|
private |
const uint64_t Hyperspace::ClientKeepaliveHandler::ms_bad_notification_grace_period = 120000 |
|
staticprivate |
The documentation for this class was generated from the following files: