The AdminProperties per EventChannel. More...

#include <AdminProperties.h>

Inheritance diagram for TAO_Notify_AdminProperties:

Collaboration diagram for TAO_Notify_AdminProperties:

[legend]

Public Types
typedef ACE_Strong_Bound_Ptr< TAO_Notify_AdminProperties, TAO_SYNCH_MUTEX >	Ptr

Public Member Functions
	TAO_Notify_AdminProperties ()
	Constructor.

virtual	~TAO_Notify_AdminProperties ()
	Destructor.

int	init (const CosNotification::PropertySeq &prop_seq)
	Init.

void	init ()
	finish initialization after values are set by topology load

const TAO_Notify_Property_Long &	max_global_queue_length () const

const TAO_Notify_Property_Long &	max_consumers () const

const TAO_Notify_Property_Long &	max_suppliers () const

const TAO_Notify_Property_Boolean &	reject_new_events () const

TAO_Notify_Property_Long &	max_global_queue_length ()

TAO_Notify_Property_Long &	max_consumers ()

TAO_Notify_Property_Long &	max_suppliers ()

TAO_Notify_Property_Boolean &	reject_new_events ()

CORBA::Long &	global_queue_length ()

TAO_SYNCH_MUTEX &	global_queue_lock ()

TAO_SYNCH_CONDITION &	global_queue_not_full ()

TAO_Notify_Atomic_Property_Long &	consumers ()

TAO_Notify_Atomic_Property_Long &	suppliers ()

CORBA::Boolean	queue_full ()
	Returns true if Queue is full.

Public Member Functions inherited from TAO_Notify_PropertySeq
	TAO_Notify_PropertySeq ()
	Constructor.

	~TAO_Notify_PropertySeq ()
	Destructor.

int	init (const CosNotification::PropertySeq &prop_seq)
	Return 0 on success, -1 on error.

int	find (const char *name, CosNotification::PropertyValue &value) const
	Find the for property <name>. Returns 0 on success.

int	populate (CosNotification::PropertySeq_var &prop_seq) const
	Return -1 on error.

size_t	size () const
	return the number of properties available as a sequence

Protected Attributes
TAO_Notify_Property_Long	max_global_queue_length_

TAO_Notify_Property_Long	max_consumers_

TAO_Notify_Property_Long	max_suppliers_

TAO_Notify_Property_Boolean	reject_new_events_
	Reject any new event.

CORBA::Long	global_queue_length_

TAO_SYNCH_MUTEX	global_queue_lock_
	Global queue lock used to serialize access to all queues.

TAO_SYNCH_CONDITION	global_queue_not_full_
	The condition that the queue_length_ is not at max.

TAO_Notify_Atomic_Property_Long	consumers_

TAO_Notify_Atomic_Property_Long	suppliers_

Protected Attributes inherited from TAO_Notify_PropertySeq
PROPERTY_MAP	property_map_

Additional Inherited Members
Protected Types inherited from TAO_Notify_PropertySeq
typedef ACE_Hash_Map_Manager< ACE_CString, CosNotification::PropertyValue, ACE_SYNCH_NULL_MUTEX >	PROPERTY_MAP
	Property Map.

Protected Member Functions inherited from TAO_Notify_PropertySeq
void	add (const ACE_CString &name, const CORBA::Any &val)

Detailed Description

The AdminProperties per EventChannel.

Member Typedef Documentation

◆ Ptr

typedef ACE_Strong_Bound_Ptr<TAO_Notify_AdminProperties, TAO_SYNCH_MUTEX> TAO_Notify_AdminProperties::Ptr

Constructor & Destructor Documentation

◆ TAO_Notify_AdminProperties()

TAO_Notify_AdminProperties::TAO_Notify_AdminProperties ( )

Constructor.

◆ ~TAO_Notify_AdminProperties()

TAO_Notify_AdminProperties::~TAO_Notify_AdminProperties ( )

virtual

Destructor.

Member Function Documentation

◆ consumers()

TAO_Notify_Atomic_Property_Long & TAO_Notify_AdminProperties::consumers ( )

◆ global_queue_length()

CORBA::Long & TAO_Notify_AdminProperties::global_queue_length ( )

◆ global_queue_lock()

TAO_SYNCH_MUTEX & TAO_Notify_AdminProperties::global_queue_lock ( )

◆ global_queue_not_full()

TAO_SYNCH_CONDITION & TAO_Notify_AdminProperties::global_queue_not_full ( )

◆ init() [1/2]

void TAO_Notify_AdminProperties::init ( )

finish initialization after values are set by topology load

◆ init() [2/2]

int TAO_Notify_AdminProperties::init ( const CosNotification::PropertySeq & prop_seq )

Init.

◆ max_consumers() [1/2]

TAO_Notify_Property_Long & TAO_Notify_AdminProperties::max_consumers ( )

◆ max_consumers() [2/2]

const TAO_Notify_Property_Long & TAO_Notify_AdminProperties::max_consumers ( ) const

◆ max_global_queue_length() [1/2]

TAO_Notify_Property_Long & TAO_Notify_AdminProperties::max_global_queue_length ( )

◆ max_global_queue_length() [2/2]

const TAO_Notify_Property_Long & TAO_Notify_AdminProperties::max_global_queue_length ( ) const

◆ max_suppliers() [1/2]

TAO_Notify_Property_Long & TAO_Notify_AdminProperties::max_suppliers ( )

◆ max_suppliers() [2/2]

const TAO_Notify_Property_Long & TAO_Notify_AdminProperties::max_suppliers ( ) const

◆ queue_full()

CORBA::Boolean TAO_Notify_AdminProperties::queue_full ( )

Returns true if Queue is full.

◆ reject_new_events() [1/2]

TAO_Notify_Property_Boolean & TAO_Notify_AdminProperties::reject_new_events ( )

◆ reject_new_events() [2/2]

const TAO_Notify_Property_Boolean & TAO_Notify_AdminProperties::reject_new_events ( ) const

◆ suppliers()

TAO_Notify_Atomic_Property_Long & TAO_Notify_AdminProperties::suppliers ( )

Member Data Documentation

◆ consumers_

TAO_Notify_Atomic_Property_Long TAO_Notify_AdminProperties::consumers_

protected

These are used to count the number of consumers and suppliers connected to the system.

◆ global_queue_length_

CORBA::Long TAO_Notify_AdminProperties::global_queue_length_

protected

This is used to count the queue length across all buffers in the Notify Service to enforce the "MaxQueueLength" property.

◆ global_queue_lock_

TAO_SYNCH_MUTEX TAO_Notify_AdminProperties::global_queue_lock_

protected

Global queue lock used to serialize access to all queues.

◆ global_queue_not_full_

TAO_SYNCH_CONDITION TAO_Notify_AdminProperties::global_queue_not_full_

protected

The condition that the queue_length_ is not at max.

◆ max_consumers_

TAO_Notify_Property_Long TAO_Notify_AdminProperties::max_consumers_

protected

The maximum number of consumers that can be connected to the channel at any given time.

◆ max_global_queue_length_

TAO_Notify_Property_Long TAO_Notify_AdminProperties::max_global_queue_length_

protected

The maximum number of events that will be queued by the channel before the channel begins discarding events or rejecting new events upon receipt of each new event.

◆ max_suppliers_

TAO_Notify_Property_Long TAO_Notify_AdminProperties::max_suppliers_

protected

The maximum number of suppliers that can be connected to the channel at any given time.

◆ reject_new_events_

TAO_Notify_Property_Boolean TAO_Notify_AdminProperties::reject_new_events_

protected

Reject any new event.

◆ suppliers_

TAO_Notify_Atomic_Property_Long TAO_Notify_AdminProperties::suppliers_

protected

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

Public Types

Public Member Functions

Protected Attributes

Additional Inherited Members

Detailed Description

Member Typedef Documentation

◆ Ptr

Constructor & Destructor Documentation

◆ TAO_Notify_AdminProperties()

◆ ~TAO_Notify_AdminProperties()

Member Function Documentation

◆ consumers()

◆ global_queue_length()

◆ global_queue_lock()

◆ global_queue_not_full()

◆ init() [1/2]

◆ init() [2/2]

◆ max_consumers() [1/2]

◆ max_consumers() [2/2]

◆ max_global_queue_length() [1/2]

◆ max_global_queue_length() [2/2]

◆ max_suppliers() [1/2]

◆ max_suppliers() [2/2]

◆ queue_full()

◆ reject_new_events() [1/2]

◆ reject_new_events() [2/2]

◆ suppliers()

Member Data Documentation

◆ consumers_

◆ global_queue_length_

◆ global_queue_lock_

◆ global_queue_not_full_

◆ max_consumers_

◆ max_global_queue_length_

◆ max_suppliers_

◆ reject_new_events_

◆ suppliers_