TAO_Implementation_Repository
2.3.3
|
#include <LiveCheck.h>
Public Member Functions | |
LiveCheck () | |
~LiveCheck (void) | |
void | init (CORBA::ORB_ptr orb, const ACE_Time_Value &interval) |
void | shutdown (void) |
int | handle_timeout (const ACE_Time_Value ¤t_time, const void *act=0) |
bool | has_server (const char *server) |
void | add_server (const char *server, bool may_ping, ImplementationRepository::ServerObject_ptr ref) |
void | remove_server (const char *server) |
void | remove_deferred_servers (void) |
bool | remove_per_client_entry (LiveEntry *entry) |
bool | add_listener (LiveListener *listener) |
bool | add_poll_listener (LiveListener *listener) |
bool | add_per_client_listener (LiveListener *listener, ImplementationRepository::ServerObject_ptr ref) |
void | remove_listener (LiveListener *listener) |
bool | schedule_ping (LiveEntry *entry) |
LiveStatus | is_alive (const char *server) |
const ACE_Time_Value & | ping_interval (void) const |
Public Member Functions inherited from ACE_Event_Handler | |
virtual | ~ACE_Event_Handler (void) |
virtual ACE_HANDLE | get_handle (void) const |
virtual void | set_handle (ACE_HANDLE) |
virtual int | priority (void) const |
virtual void | priority (int priority) |
virtual int | handle_input (ACE_HANDLE fd=ACE_INVALID_HANDLE) |
virtual int | handle_output (ACE_HANDLE fd=ACE_INVALID_HANDLE) |
virtual int | handle_exception (ACE_HANDLE fd=ACE_INVALID_HANDLE) |
virtual int | handle_exit (ACE_Process *) |
virtual int | handle_close (ACE_HANDLE handle, ACE_Reactor_Mask close_mask) |
virtual int | handle_signal (int signum, siginfo_t *=0, ucontext_t *=0) |
virtual int | resume_handler (void) |
virtual int | handle_qos (ACE_HANDLE=ACE_INVALID_HANDLE) |
virtual int | handle_group_qos (ACE_HANDLE=ACE_INVALID_HANDLE) |
virtual void | reactor (ACE_Reactor *reactor) |
virtual ACE_Reactor * | reactor (void) const |
virtual ACE_Reactor_Timer_Interface * | reactor_timer_interface (void) const |
virtual Reference_Count | add_reference (void) |
virtual Reference_Count | remove_reference (void) |
Reference_Counting_Policy & | reference_counting_policy (void) |
Private Types | |
typedef ACE_Hash_Map_Manager_Ex< ACE_CString, LiveEntry *, ACE_Hash< ACE_CString >, ACE_Equal_To< ACE_CString >, TAO_SYNCH_MUTEX > | LiveEntryMap |
typedef ACE_Unbounded_Set< LiveEntry * > | PerClientStack |
typedef ACE_Unbounded_Set< ACE_CString > | NameStack |
Private Attributes | |
LiveEntryMap | entry_map_ |
PerClientStack | per_client_ |
PortableServer::POA_var | poa_ |
ACE_Time_Value | ping_interval_ |
bool | running_ |
int | token_ |
int | handle_timeout_busy_ |
bool | want_timeout_ |
ACE_Time_Value | deferred_timeout_ |
NameStack | removed_entries_ |
Friends | |
class | LC_TimeoutGuard |
|
private |
|
private |
|
private |
LiveCheck::LiveCheck | ( | ) |
LiveCheck::~LiveCheck | ( | void | ) |
bool LiveCheck::add_listener | ( | LiveListener * | listener | ) |
bool LiveCheck::add_per_client_listener | ( | LiveListener * | listener, |
ImplementationRepository::ServerObject_ptr | ref | ||
) |
bool LiveCheck::add_poll_listener | ( | LiveListener * | listener | ) |
void LiveCheck::add_server | ( | const char * | server, |
bool | may_ping, | ||
ImplementationRepository::ServerObject_ptr | ref | ||
) |
|
virtual |
Reimplemented from ACE_Event_Handler.
bool LiveCheck::has_server | ( | const char * | server | ) |
void LiveCheck::init | ( | CORBA::ORB_ptr | orb, |
const ACE_Time_Value & | interval | ||
) |
LiveStatus LiveCheck::is_alive | ( | const char * | server | ) |
const ACE_Time_Value & LiveCheck::ping_interval | ( | void | ) | const |
void LiveCheck::remove_deferred_servers | ( | void | ) |
void LiveCheck::remove_listener | ( | LiveListener * | listener | ) |
bool LiveCheck::remove_per_client_entry | ( | LiveEntry * | entry | ) |
void LiveCheck::remove_server | ( | const char * | server | ) |
bool LiveCheck::schedule_ping | ( | LiveEntry * | entry | ) |
void LiveCheck::shutdown | ( | void | ) |
|
friend |
|
private |
|
private |
|
private |
|
private |
|
private |
|
private |
|
private |
|
private |
|
private |
|
private |