OmniEvents
OmniEvents::ProxyPushSupplierManager Class Reference

#include <ProxyPushSupplier.h>

Inheritance diagram for OmniEvents::ProxyPushSupplierManager:
Collaboration diagram for OmniEvents::ProxyPushSupplierManager:

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.
 
 ProxyPushSupplierManager (PortableServer::POA_ptr parentPoa, EventQueue &q)
 
 ~ProxyPushSupplierManager ()
 
CosEventChannelAdmin::ProxyPushSupplier_ptr createObject ()
 
void disconnect ()
 Send disconnect_push_consumer() to all connected PushConsumers.
 
voidrun_undetached (void *)
 
void _add_ref ()
 
void _remove_ref ()
 Shutdown the thread when refCount reaches zero.
 
- Public Member Functions inherited from OmniEvents::ProxyManager
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.
 
void reincarnate (const PersistNode &node)
 Re-create servants from information saved in the log file.
 
void output (ostream &os)
 Save this object's state to a stream.
 
- Public Member Functions inherited from OmniEvents::Servant
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

- Protected Member Functions inherited from OmniEvents::ProxyManager
 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.
 
- 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.
 
void deactivateObject ()
 Calls deactivate_object() to deactivate this servant in its POA.
 
- Protected Attributes inherited from OmniEvents::ProxyManager
set< Proxy * > _servants
 The set of all active Proxies in this object's _managedPoa.
 
PortableServer::POA_var _managedPoa
 The POA owned & managed by this object.
 
- Protected Attributes inherited from OmniEvents::Servant
PortableServer::POA_var _poa
 

Detailed Description

Definition at line 49 of file ProxyPushSupplier.h.

Constructor & Destructor Documentation

◆ ProxyPushSupplierManager()

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

◆ ~ProxyPushSupplierManager()

OmniEvents::ProxyPushSupplierManager::~ProxyPushSupplierManager ( )

Definition at line 105 of file ProxyPushSupplier.cc.

References DB.

Member Function Documentation

◆ _add_ref()

void OmniEvents::ProxyPushSupplierManager::_add_ref ( )

Definition at line 214 of file ProxyPushSupplier.cc.

References _lock, _refCount, OmniEvents::createNarrowedReference(), and DB.

◆ _remove_ref()

void OmniEvents::ProxyPushSupplierManager::_remove_ref ( )

Shutdown the thread when refCount reaches zero.

Definition at line 223 of file ProxyPushSupplier.cc.

References _refCount, OmniEvents::createNarrowedReference(), and DB.

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

◆ createObject()

CosEventChannelAdmin::ProxyPushSupplier_ptr OmniEvents::ProxyPushSupplierManager::createObject ( )

◆ disconnect()

void OmniEvents::ProxyPushSupplierManager::disconnect ( )

Send disconnect_push_consumer() to all connected PushConsumers.

Definition at line 119 of file ProxyPushSupplier.cc.

References OmniEvents::ProxyManager::_servants, OmniEvents::createNarrowedReference(), and OmniEvents::ProxyPushSupplier_i::disconnect_push_supplier().

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

◆ etherealize()

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, OmniEvents::createNarrowedReference(), and DB.

◆ incarnate()

PortableServer::Servant OmniEvents::ProxyPushSupplierManager::incarnate ( const PortableServer::ObjectId &  oid,
PortableServer::POA_ptr  poa 
)

◆ run_undetached()

Member Data Documentation

◆ _condition

omni_condition OmniEvents::ProxyPushSupplierManager::_condition

Definition at line 79 of file ProxyPushSupplier.h.

Referenced by run_undetached().

◆ _lock

◆ _queue

EventQueue& OmniEvents::ProxyPushSupplierManager::_queue
private

Definition at line 96 of file ProxyPushSupplier.h.

Referenced by incarnate().

◆ _refCount

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: