TAO_Implementation_Repository 4.0.3
Loading...
Searching...
No Matches
Public Member Functions | Static Public Member Functions | Private Types | Private Attributes | Static Private Attributes | List of all members
LiveEntry Class Reference

#include <LiveCheck.h>

Collaboration diagram for LiveEntry:
Collaboration graph
[legend]

Public Member Functions

 LiveEntry (LiveCheck *owner, const char *server, bool may_ping, ImplementationRepository::ServerObject_ptr ref, int pid)
 
 ~LiveEntry ()
 
void release_callback ()
 
void add_listener (LiveListener *ll)
 
void remove_listener (LiveListener *ll)
 
LiveStatus status () const
 
void status (LiveStatus l)
 
void reset_status ()
 
void update_listeners ()
 
bool validate_ping (bool &want_reping, ACE_Time_Value &next)
 
void do_ping (PortableServer::POA_ptr poa)
 
const ACE_Time_Valuenext_check () const
 
bool reping_available () const
 
int next_reping ()
 
void max_retry_msec (int max)
 
const char * server_name () const
 
void set_pid (int pid)
 
bool has_pid (int pid) const
 
int pid () const
 
bool may_ping () const
 

Static Public Member Functions

static const char * status_name (LiveStatus s)
 the current state value as text
 
static void set_reping_limit (int max)
 

Private Types

typedef ACE_Unbounded_Set< LiveListener_ptrListen_Set
 

Private Attributes

LiveCheckowner_
 
ACE_CString server_
 
ImplementationRepository::ServerObject_var ref_
 
LiveStatus liveliness_
 
ACE_Time_Value next_check_
 
int repings_
 
int max_retry_
 
bool may_ping_
 
Listen_Set listeners_
 
TAO_SYNCH_MUTEX lock_
 
PortableServer::ServantBase_var callback_
 
int pid_
 

Static Private Attributes

static const int reping_msec_ [] = {10, 100, 500, 1000, 1000, 2000, 2000, 5000, 5000}
 
static int reping_limit_ = sizeof (LiveEntry::reping_msec_) / sizeof (int)
 

Member Typedef Documentation

◆ Listen_Set

Constructor & Destructor Documentation

◆ LiveEntry()

LiveEntry::LiveEntry ( LiveCheck * owner,
const char * server,
bool may_ping,
ImplementationRepository::ServerObject_ptr ref,
int pid )

◆ ~LiveEntry()

LiveEntry::~LiveEntry ( )

Member Function Documentation

◆ add_listener()

void LiveEntry::add_listener ( LiveListener * ll)

◆ do_ping()

void LiveEntry::do_ping ( PortableServer::POA_ptr poa)

◆ has_pid()

bool LiveEntry::has_pid ( int pid) const

◆ max_retry_msec()

void LiveEntry::max_retry_msec ( int max)

◆ may_ping()

bool LiveEntry::may_ping ( ) const

◆ next_check()

const ACE_Time_Value & LiveEntry::next_check ( ) const

◆ next_reping()

int LiveEntry::next_reping ( )

◆ pid()

int LiveEntry::pid ( ) const

◆ release_callback()

void LiveEntry::release_callback ( )

◆ remove_listener()

void LiveEntry::remove_listener ( LiveListener * ll)

◆ reping_available()

bool LiveEntry::reping_available ( ) const

◆ reset_status()

void LiveEntry::reset_status ( )

◆ server_name()

const char * LiveEntry::server_name ( ) const

◆ set_pid()

void LiveEntry::set_pid ( int pid)

◆ set_reping_limit()

void LiveEntry::set_reping_limit ( int max)
static

◆ status() [1/2]

LiveStatus LiveEntry::status ( ) const

◆ status() [2/2]

void LiveEntry::status ( LiveStatus l)

◆ status_name()

const char * LiveEntry::status_name ( LiveStatus s)
static

the current state value as text

◆ update_listeners()

void LiveEntry::update_listeners ( )

◆ validate_ping()

bool LiveEntry::validate_ping ( bool & want_reping,
ACE_Time_Value & next )

Member Data Documentation

◆ callback_

PortableServer::ServantBase_var LiveEntry::callback_
private

◆ listeners_

Listen_Set LiveEntry::listeners_
private

◆ liveliness_

LiveStatus LiveEntry::liveliness_
private

◆ lock_

TAO_SYNCH_MUTEX LiveEntry::lock_
private

◆ max_retry_

int LiveEntry::max_retry_
private

◆ may_ping_

bool LiveEntry::may_ping_
private

◆ next_check_

ACE_Time_Value LiveEntry::next_check_
private

◆ owner_

LiveCheck* LiveEntry::owner_
private

◆ pid_

int LiveEntry::pid_
private

◆ ref_

ImplementationRepository::ServerObject_var LiveEntry::ref_
private

◆ reping_limit_

int LiveEntry::reping_limit_ = sizeof (LiveEntry::reping_msec_) / sizeof (int)
staticprivate

◆ reping_msec_

const int LiveEntry::reping_msec_ = {10, 100, 500, 1000, 1000, 2000, 2000, 5000, 5000}
staticprivate

◆ repings_

int LiveEntry::repings_
private

◆ server_

ACE_CString LiveEntry::server_
private

The documentation for this class was generated from the following files: