TAO_Implementation_Repository
2.2.8
|
#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 |
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 | ||
) |
int LiveCheck::handle_timeout | ( | const ACE_Time_Value & | current_time, |
const void * | act = 0 |
||
) |
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 |