Main Page   Namespace List   Class Hierarchy   Compound List   File List   Namespace Members   Compound Members   File Members  

OmniEvents::ProxyPushSupplierManager Class Reference

#include <ProxyPushSupplier.h>

Inheritance diagram for OmniEvents::ProxyPushSupplierManager:

Inheritance graph
[legend]
Collaboration diagram for OmniEvents::ProxyPushSupplierManager:

Collaboration graph
[legend]
List of all members.

Public Methods

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 (void *)
void _add_ref ()
void _remove_ref ()
 Shutdown the thread when refCount reaches zero. More...


Public Attributes

omni_mutex _lock
omni_condition _condition

Private Attributes

EventQueue_queue
int _refCount

Constructor & Destructor Documentation

OmniEvents::ProxyPushSupplierManager::ProxyPushSupplierManager PortableServer::POA_ptr    parentPoa,
EventQueue   q
 

Definition at line 77 of file ProxyPushSupplier.cc.

OmniEvents::ProxyPushSupplierManager::~ProxyPushSupplierManager  
 

Definition at line 90 of file ProxyPushSupplier.cc.

References DB.


Member Function Documentation

void OmniEvents::ProxyPushSupplierManager::_add_ref  
 

Definition at line 196 of file ProxyPushSupplier.cc.

References _lock, and _refCount.

Referenced by OmniEvents::ConsumerAdmin_i::obtain_push_supplier(), and OmniEvents::ConsumerAdmin_i::reincarnate().

void OmniEvents::ProxyPushSupplierManager::_remove_ref  
 

Shutdown the thread when refCount reaches zero.

Definition at line 202 of file ProxyPushSupplier.cc.

References _refCount, and DB.

Referenced by OmniEvents::ConsumerAdmin_i::~ConsumerAdmin_i().

CosEventChannelAdmin::ProxyPushSupplier_ptr OmniEvents::ProxyPushSupplierManager::createObject  
 

Definition at line 96 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 104 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.

Reimplemented from OmniEvents::ProxyManager.

Definition at line 64 of file ProxyPushSupplier.cc.

References _lock.

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 void *   
 

Definition at line 115 of file ProxyPushSupplier.cc.

References _condition, _lock, _refCount, OmniEvents::ProxyManager::_servants, DB, IF_OMNIORB4, NP_MINORSTRING, and OmniEvents::ProxyPushSupplier_i::trigger().


Member Data Documentation

omni_condition OmniEvents::ProxyPushSupplierManager::_condition
 

Definition at line 79 of file ProxyPushSupplier.h.

Referenced by run(), and OmniEvents::ProxyPushSupplierManager::PauseThenWake::~PauseThenWake().

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(), run(), and OmniEvents::ProxyPushSupplierManager::PauseThenWake::~PauseThenWake().

EventQueue& OmniEvents::ProxyPushSupplierManager::_queue [private]
 

Definition at line 96 of file ProxyPushSupplier.h.

Referenced by incarnate().

int OmniEvents::ProxyPushSupplierManager::_refCount [private]
 

Definition at line 97 of file ProxyPushSupplier.h.

Referenced by _add_ref(), _remove_ref(), and run().


The documentation for this class was generated from the following files:
Generated on Fri Nov 19 17:42:36 2004 for OmniEvents by doxygen1.2.15