OmniEvents
|
#include <ProxyPushSupplier.h>
Classes | |
class | PauseThenWake |
Helper class that locks ProxyPushSupplier upon construction, and wakes it up on destruction. More... | |
Public Member Functions | |
PortableServer::Servant | incarnate (const PortableServer::ObjectId &oid, PortableServer::POA_ptr poa) |
void | etherealize (const PortableServer::ObjectId &oid, PortableServer::POA_ptr adapter, PortableServer::Servant serv, CORBA::Boolean cleanup_in_progress, CORBA::Boolean remaining_activations) |
Pauses the thread, and then calls the parent's implementation. More... | |
ProxyPushSupplierManager (PortableServer::POA_ptr parentPoa, EventQueue &q) | |
~ProxyPushSupplierManager () | |
CosEventChannelAdmin::ProxyPushSupplier_ptr | createObject () |
void | disconnect () |
Send disconnect_push_consumer() to all connected PushConsumers. More... | |
void * | run_undetached (void *) |
void | _add_ref () |
void | _remove_ref () |
Shutdown the thread when refCount reaches zero. More... | |
![]() | |
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... | |
![]() | |
virtual PortableServer::POA_ptr | _default_POA () |
virtual | ~Servant () |
Public Attributes | |
omni_mutex | _lock |
omni_condition | _condition |
Private Attributes | |
EventQueue & | _queue |
int | _refCount |
Additional Inherited Members | |
![]() | |
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... | |
![]() | |
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... | |
![]() | |
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... | |
![]() | |
PortableServer::POA_var | _poa |
Definition at line 49 of file ProxyPushSupplier.h.
OmniEvents::ProxyPushSupplierManager::ProxyPushSupplierManager | ( | PortableServer::POA_ptr | parentPoa, |
EventQueue & | q | ||
) |
Definition at line 91 of file ProxyPushSupplier.cc.
References OmniEvents::ProxyManager::activate().
OmniEvents::ProxyPushSupplierManager::~ProxyPushSupplierManager | ( | ) |
Definition at line 105 of file ProxyPushSupplier.cc.
References DB.
void OmniEvents::ProxyPushSupplierManager::_add_ref | ( | ) |
Definition at line 214 of file ProxyPushSupplier.cc.
void OmniEvents::ProxyPushSupplierManager::_remove_ref | ( | ) |
Shutdown the thread when refCount reaches zero.
Definition at line 223 of file ProxyPushSupplier.cc.
Referenced by OmniEvents::ConsumerAdmin_i::~ConsumerAdmin_i().
CosEventChannelAdmin::ProxyPushSupplier_ptr OmniEvents::ProxyPushSupplierManager::createObject | ( | ) |
Definition at line 111 of file ProxyPushSupplier.cc.
References OmniEvents::ProxyManager::_managedPoa.
Referenced by OmniEvents::ConsumerAdmin_i::obtain_push_supplier().
void OmniEvents::ProxyPushSupplierManager::disconnect | ( | ) |
Send disconnect_push_consumer() to all connected PushConsumers.
Definition at line 119 of file ProxyPushSupplier.cc.
References OmniEvents::ProxyManager::_servants, and OmniEvents::ProxyPushSupplier_i::disconnect_push_supplier().
Referenced by OmniEvents::ConsumerAdmin_i::disconnect().
void OmniEvents::ProxyPushSupplierManager::etherealize | ( | const PortableServer::ObjectId & | oid, |
PortableServer::POA_ptr | adapter, | ||
PortableServer::Servant | serv, | ||
CORBA::Boolean | cleanup_in_progress, | ||
CORBA::Boolean | remaining_activations | ||
) |
Pauses the thread, and then calls the parent's implementation.
Definition at line 64 of file ProxyPushSupplier.cc.
References _lock, OmniEvents::ProxyManager::_servants, and DB.
PortableServer::Servant OmniEvents::ProxyPushSupplierManager::incarnate | ( | const PortableServer::ObjectId & | oid, |
PortableServer::POA_ptr | poa | ||
) |
Definition at line 52 of file ProxyPushSupplier.cc.
References OmniEvents::ProxyManager::_managedPoa, _queue, and OmniEvents::ProxyManager::_servants.
void * OmniEvents::ProxyPushSupplierManager::run_undetached | ( | void * | ) |
Definition at line 133 of file ProxyPushSupplier.cc.
References _condition, _lock, _refCount, OmniEvents::ProxyManager::_servants, DB, IF_OMNIORB4, NP_MINORSTRING, and OmniEvents::ProxyPushSupplier_i::trigger().
omni_condition OmniEvents::ProxyPushSupplierManager::_condition |
Definition at line 79 of file ProxyPushSupplier.h.
Referenced by run_undetached().
omni_mutex OmniEvents::ProxyPushSupplierManager::_lock |
Definition at line 78 of file ProxyPushSupplier.h.
Referenced by _add_ref(), etherealize(), OmniEvents::ConsumerAdmin_i::output(), OmniEvents::ProxyPushSupplierManager::PauseThenWake::PauseThenWake(), and run_undetached().
|
private |
Definition at line 96 of file ProxyPushSupplier.h.
Referenced by incarnate().
|
private |
Definition at line 97 of file ProxyPushSupplier.h.
Referenced by _add_ref(), _remove_ref(), and run_undetached().