OmniEvents::ProxyPushSupplierManager Class Reference

#include <ProxyPushSupplier.h>

Inheritance diagram for OmniEvents::ProxyPushSupplierManager:

[legend]Collaboration diagram for OmniEvents::ProxyPushSupplierManager:

[legend]List of all members.

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.
	ProxyPushSupplierManager (PortableServer::POA_ptr parentPoa, EventQueue &q)
	~ProxyPushSupplierManager ()
CosEventChannelAdmin::ProxyPushSupplier_ptr	createObject ()
void	disconnect ()
	Send disconnect_push_consumer() to all connected PushConsumers.
void *	run_undetached (void *)
void	_add_ref ()
void	_remove_ref ()
	Shutdown the thread when refCount reaches zero.
Public Attributes
omni_mutex	_lock
omni_condition	_condition
Private Attributes
EventQueue &	_queue
int	_refCount
Classes
class	PauseThenWake
	Helper class that locks ProxyPushSupplier upon construction, and wakes it up on destruction. More...

---

Detailed Description

Definition at line 49 of file ProxyPushSupplier.h.

---

Constructor & Destructor Documentation

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.

---

Member Function Documentation

void OmniEvents::ProxyPushSupplierManager::_add_ref (   )

Definition at line 214 of file ProxyPushSupplier.cc. References _lock, _refCount, and DB.

void OmniEvents::ProxyPushSupplierManager::_remove_ref (   )

Shutdown the thread when refCount reaches zero. Definition at line 223 of file ProxyPushSupplier.cc. References _refCount, and DB. 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. Reimplemented from OmniEvents::ProxyManager. 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().

---

Member Data Documentation

omni_condition OmniEvents::ProxyPushSupplierManager::_condition

Definition at line 79 of file ProxyPushSupplier.h. Referenced by run_undetached(), 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_undetached(), 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_undetached().

---

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

• ProxyPushSupplier.h
• ProxyPushSupplier.cc

---