#include <ClientConnectionHandler.h>
Definition at line 42 of file ClientConnectionHandler.h.
ClientConnectionHandler::ClientConnectionHandler |
( |
Comm * |
comm, |
|
|
Session * |
session, |
|
|
uint32_t |
timeout_ms |
|
) |
| |
ClientConnectionHandler::~ClientConnectionHandler |
( |
| ) |
|
|
virtual |
was causing deadlock ... if (m_master_addr.sin_port != 0) m_comm->close_socket(m_master_addr);
Definition at line 44 of file ClientConnectionHandler.cc.
void ClientConnectionHandler::close |
( |
| ) |
|
void Hyperspace::ClientConnectionHandler::disable_callbacks |
( |
| ) |
|
|
inline |
bool Hyperspace::ClientConnectionHandler::disconnected |
( |
| ) |
|
|
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 52 of file ClientConnectionHandler.cc.
int Hyperspace::ClientConnectionHandler::initiate_connection |
( |
struct sockaddr_in & |
addr | ) |
|
|
inline |
void Hyperspace::ClientConnectionHandler::set_session_id |
( |
uint64_t |
id | ) |
|
|
inline |
void Hyperspace::ClientConnectionHandler::set_verbose_mode |
( |
bool |
verbose | ) |
|
|
inline |
bool Hyperspace::ClientConnectionHandler::m_callbacks_enabled {} |
|
private |
Comm* Hyperspace::ClientConnectionHandler::m_comm {} |
|
private |
std::condition_variable_any Hyperspace::ClientConnectionHandler::m_cond |
|
private |
struct sockaddr_in Hyperspace::ClientConnectionHandler::m_master_addr |
|
private |
std::recursive_mutex Hyperspace::ClientConnectionHandler::m_mutex |
|
private |
Session* Hyperspace::ClientConnectionHandler::m_session {} |
|
private |
uint64_t Hyperspace::ClientConnectionHandler::m_session_id {} |
|
private |
int Hyperspace::ClientConnectionHandler::m_state {} |
|
private |
uint32_t Hyperspace::ClientConnectionHandler::m_timeout_ms {} |
|
private |
bool Hyperspace::ClientConnectionHandler::m_verbose {} |
|
private |
The documentation for this class was generated from the following files: