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

#include <AsyncAccessManager.h>

Collaboration diagram for AsyncAccessManager:
Collaboration graph
[legend]

Public Member Functions

 AsyncAccessManager (UpdateableServerInfo &info, ImR_Locator_i &locator)
 
 ~AsyncAccessManager ()
 
void started_running ()
 
bool is_terminating () const
 
bool is_running () const
 
bool has_server (const char *name) const
 
void remote_state (ImplementationRepository::AAM_Status s)
 
void add_interest (ImR_ResponseHandler *rh, bool manual)
 
ImplementationRepository::AAM_Status status () const
 
bool force_remove_rh (ImR_ResponseHandler *rh)
 
void activator_replied_start_running (bool success, int pid)
 
void server_is_running (const char *partial_ior, ImplementationRepository::ServerObject_ptr ref)
 
void server_is_shutting_down ()
 
void shutdown_initiated ()
 
bool notify_child_death (int pid)
 
void ping_replied (LiveStatus server)
 
void listener_disconnected ()
 
AsyncAccessManager_add_ref ()
 
void _remove_ref ()
 
void update_prev_pid ()
 

Static Public Member Functions

static const char * status_name (ImplementationRepository::AAM_Status s)
 
static bool is_final (ImplementationRepository::AAM_Status s)
 

Private Member Functions

void report (const char *operation) const
 
void final_state (bool active=true)
 
void notify_waiter (ImR_ResponseHandler *rh)
 
void notify_waiters ()
 
void status (ImplementationRepository::AAM_Status s)
 
void update_status (ImplementationRepository::AAM_Status s)
 
bool send_start_request ()
 

Private Attributes

UpdateableServerInfo info_
 
bool manual_start_
 
int retries_
 
ImR_ResponseHandlerremove_on_death_rh_
 
ImR_Locator_ilocator_
 
PortableServer::POA_var poa_
 
ACE_Vector< ImR_ResponseHandler * > rh_list_
 
ImplementationRepository::AAM_Status status_
 
int refcount_
 
TAO_SYNCH_MUTEX lock_
 
int prev_pid_
 
ImplementationRepository::ServerObject_var server_
 The cached server object in case this is a per client activated AAM.
 
ACE_CString partial_ior_
 Current endpoint used by the server in case this is a per client activated AAM.
 

Constructor & Destructor Documentation

◆ AsyncAccessManager()

AsyncAccessManager::AsyncAccessManager ( UpdateableServerInfo & info,
ImR_Locator_i & locator )

◆ ~AsyncAccessManager()

AsyncAccessManager::~AsyncAccessManager ( )

Member Function Documentation

◆ _add_ref()

AsyncAccessManager * AsyncAccessManager::_add_ref ( )

◆ _remove_ref()

void AsyncAccessManager::_remove_ref ( )

◆ activator_replied_start_running()

void AsyncAccessManager::activator_replied_start_running ( bool success,
int pid )

◆ add_interest()

void AsyncAccessManager::add_interest ( ImR_ResponseHandler * rh,
bool manual )

◆ final_state()

void AsyncAccessManager::final_state ( bool active = true)
private

◆ force_remove_rh()

bool AsyncAccessManager::force_remove_rh ( ImR_ResponseHandler * rh)

◆ has_server()

bool AsyncAccessManager::has_server ( const char * name) const

◆ is_final()

bool AsyncAccessManager::is_final ( ImplementationRepository::AAM_Status s)
static

◆ is_running()

bool AsyncAccessManager::is_running ( ) const

◆ is_terminating()

bool AsyncAccessManager::is_terminating ( ) const

◆ listener_disconnected()

void AsyncAccessManager::listener_disconnected ( )

◆ notify_child_death()

bool AsyncAccessManager::notify_child_death ( int pid)

◆ notify_waiter()

void AsyncAccessManager::notify_waiter ( ImR_ResponseHandler * rh)
private

◆ notify_waiters()

void AsyncAccessManager::notify_waiters ( )
private

◆ ping_replied()

void AsyncAccessManager::ping_replied ( LiveStatus server)

◆ remote_state()

void AsyncAccessManager::remote_state ( ImplementationRepository::AAM_Status s)

◆ report()

void AsyncAccessManager::report ( const char * operation) const
private

◆ send_start_request()

bool AsyncAccessManager::send_start_request ( )
private

◆ server_is_running()

void AsyncAccessManager::server_is_running ( const char * partial_ior,
ImplementationRepository::ServerObject_ptr ref )

◆ server_is_shutting_down()

void AsyncAccessManager::server_is_shutting_down ( )

◆ shutdown_initiated()

void AsyncAccessManager::shutdown_initiated ( )

◆ started_running()

void AsyncAccessManager::started_running ( )

◆ status() [1/2]

ImplementationRepository::AAM_Status AsyncAccessManager::status ( ) const

◆ status() [2/2]

void AsyncAccessManager::status ( ImplementationRepository::AAM_Status s)
private

◆ status_name()

const char * AsyncAccessManager::status_name ( ImplementationRepository::AAM_Status s)
static

◆ update_prev_pid()

void AsyncAccessManager::update_prev_pid ( )

◆ update_status()

void AsyncAccessManager::update_status ( ImplementationRepository::AAM_Status s)
private

Member Data Documentation

◆ info_

UpdateableServerInfo AsyncAccessManager::info_
private

◆ locator_

ImR_Locator_i& AsyncAccessManager::locator_
private

◆ lock_

TAO_SYNCH_MUTEX AsyncAccessManager::lock_
private

◆ manual_start_

bool AsyncAccessManager::manual_start_
private

◆ partial_ior_

ACE_CString AsyncAccessManager::partial_ior_
private

Current endpoint used by the server in case this is a per client activated AAM.

◆ poa_

PortableServer::POA_var AsyncAccessManager::poa_
private

◆ prev_pid_

int AsyncAccessManager::prev_pid_
private

◆ refcount_

int AsyncAccessManager::refcount_
private

◆ remove_on_death_rh_

ImR_ResponseHandler* AsyncAccessManager::remove_on_death_rh_
private

◆ retries_

int AsyncAccessManager::retries_
private

◆ rh_list_

ACE_Vector<ImR_ResponseHandler *> AsyncAccessManager::rh_list_
private

◆ server_

ImplementationRepository::ServerObject_var AsyncAccessManager::server_
private

The cached server object in case this is a per client activated AAM.

◆ status_

ImplementationRepository::AAM_Status AsyncAccessManager::status_
private

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