#include <ProxyPushSupplier.h>

Inheritance diagram for OmniEvents::ProxyPushSupplierManager:

[legend]

Collaboration diagram for OmniEvents::ProxyPushSupplierManager:

[legend]

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...

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. 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 ()

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. 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 inherited from OmniEvents::ProxyManager
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

Detailed Description

Definition at line 49 of file ProxyPushSupplier.h.

Constructor & Destructor Documentation

◆ ProxyPushSupplierManager()

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

Definition at line 91 of file ProxyPushSupplier.cc.

References OmniEvents::ProxyManager::activate().

◆ ~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, 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, and DB.

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

◆ createObject()

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().

◆ 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, 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, and DB.

◆ incarnate()

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.

◆ run_undetached()

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

◆ _condition

omni_condition OmniEvents::ProxyPushSupplierManager::_condition

Definition at line 79 of file ProxyPushSupplier.h.

Referenced by run_undetached().

◆ _lock

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().

◆ _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:

Classes

Public Member Functions

Public Attributes

Private Attributes

Additional Inherited Members