|
OmniEvents
|
Base class for ServantActivator classes that manage Proxy servants. More...
#include <ProxyManager.h>


Public Member Functions | |
| void | etherealize (const PortableServer::ObjectId &oid, PortableServer::POA_ptr adapter, PortableServer::Servant serv, CORBA::Boolean cleanup_in_progress, CORBA::Boolean remaining_activations) |
| Implements etherealize() method from ServantActivator interface. More... | |
| void | reincarnate (const PersistNode &node) |
| Re-create servants from information saved in the log file. More... | |
| void | output (ostream &os) |
| Save this object's state to a stream. More... | |
Public Member Functions inherited from OmniEvents::Servant | |
| virtual PortableServer::POA_ptr | _default_POA () |
| virtual | ~Servant () |
Protected Member Functions | |
| ProxyManager (PortableServer::POA_ptr poa) | |
| virtual | ~ProxyManager () |
| void | activate (const char *name) |
| Creates the Proxy-type's POA, and registers this object as its ServantManager. More... | |
Protected Member Functions inherited from OmniEvents::Servant | |
| Servant (PortableServer::POA_ptr poa) | |
| void | activateObjectWithId (const char *oidStr) |
| Calls activate_object_with_id() to activate this servant in its POA. More... | |
| void | deactivateObject () |
| Calls deactivate_object() to deactivate this servant in its POA. More... | |
Protected Attributes | |
| set< Proxy * > | _servants |
| The set of all active Proxies in this object's _managedPoa. More... | |
| PortableServer::POA_var | _managedPoa |
| The POA owned & managed by this object. More... | |
Protected Attributes inherited from OmniEvents::Servant | |
| PortableServer::POA_var | _poa |
Base class for ServantActivator classes that manage Proxy servants.
Each ProxyManager manages its own POA (_managedPoa), with policies: PERSISTENT, USER_ID, NO_IMPLICIT_ACTIVATION, USE_SERVANT_MANAGER, SINGLE_THREAD_MODEL. This POA is only used to contain objects of a single Proxy type. Specific subclasses must implement incarnate() & createObject() methods.
Definition at line 57 of file ProxyManager.h.
|
protected |
| poa | parent POA. |
Definition at line 96 of file ProxyManager.cc.
|
protectedvirtual |
Definition at line 152 of file ProxyManager.cc.
|
protected |
Creates the Proxy-type's POA, and registers this object as its ServantManager.
| name | e.g. "ProxyPushSupplier". |
Definition at line 103 of file ProxyManager.cc.
References _managedPoa, OmniEvents::Servant::_poa, OmniEvents::Servant::activateObjectWithId(), and DB.
Referenced by OmniEvents::ProxyPullConsumerManager::ProxyPullConsumerManager(), OmniEvents::ProxyPullSupplierManager::ProxyPullSupplierManager(), and OmniEvents::ProxyPushSupplierManager::ProxyPushSupplierManager().
| void OmniEvents::ProxyManager::etherealize | ( | const PortableServer::ObjectId & | oid, |
| PortableServer::POA_ptr | adapter, | ||
| PortableServer::Servant | serv, | ||
| CORBA::Boolean | cleanup_in_progress, | ||
| CORBA::Boolean | remaining_activations | ||
| ) |
Implements etherealize() method from ServantActivator interface.
Definition at line 41 of file ProxyManager.cc.
| void OmniEvents::ProxyManager::output | ( | ostream & | os | ) |
Save this object's state to a stream.
Definition at line 87 of file ProxyManager.cc.
References _servants.
Referenced by OmniEvents::SupplierAdmin_i::output(), and OmniEvents::ConsumerAdmin_i::output().
| void OmniEvents::ProxyManager::reincarnate | ( | const PersistNode & | node | ) |
Re-create servants from information saved in the log file.
Definition at line 60 of file ProxyManager.cc.
References OmniEvents::PersistNode::_child, _managedPoa, _servants, DB, and OmniEvents::Proxy::reincarnate().
Referenced by OmniEvents::SupplierAdmin_i::reincarnate(), and OmniEvents::ConsumerAdmin_i::reincarnate().
|
protected |
The POA owned & managed by this object.
Don't confuse it with _poa (inherited from class Servant) which points to the POA in which THIS object resides.
Definition at line 95 of file ProxyManager.h.
Referenced by activate(), OmniEvents::ProxyPushSupplierManager::createObject(), OmniEvents::ProxyPushSupplierManager::incarnate(), OmniEvents::ProxyPullConsumerManager::incarnate(), OmniEvents::ProxyPullSupplierManager::incarnate(), and reincarnate().
|
protected |
The set of all active Proxies in this object's _managedPoa.
Definition at line 90 of file ProxyManager.h.
Referenced by OmniEvents::ProxyPullConsumerManager::collect(), OmniEvents::ProxyPullSupplierManager::disconnect(), OmniEvents::ProxyPushSupplierManager::disconnect(), OmniEvents::ProxyPullConsumerManager::disconnect(), OmniEvents::ProxyPushSupplierManager::etherealize(), etherealize(), OmniEvents::ProxyPushSupplierManager::incarnate(), OmniEvents::ProxyPullConsumerManager::incarnate(), OmniEvents::ProxyPullSupplierManager::incarnate(), output(), reincarnate(), OmniEvents::ProxyPushSupplierManager::run_undetached(), and OmniEvents::ProxyPullConsumerManager::triggerRequest().