TAO_CosEvent 2.0.5
Public Types | Public Member Functions | Protected Member Functions | Private Attributes | Friends
TAO_CEC_TypedProxyPushConsumer Class Reference

#include <CEC_TypedProxyPushConsumer.h>

Collaboration diagram for TAO_CEC_TypedProxyPushConsumer:
Collaboration graph
[legend]

List of all members.

Public Types

typedef
CosTypedEventChannelAdmin::TypedProxyPushConsumer_ptr 
_ptr_type
typedef
CosTypedEventChannelAdmin::TypedProxyPushConsumer_var 
_var_type

Public Member Functions

 TAO_CEC_TypedProxyPushConsumer (TAO_CEC_TypedEventChannel *typed_event_channel, const ACE_Time_Value &timeout)
virtual ~TAO_CEC_TypedProxyPushConsumer (void)
virtual void activate (CosTypedEventChannelAdmin::TypedProxyPushConsumer_ptr &activated_proxy)
 Activate in the POA.
virtual void deactivate (void)
 Deactivate from the POA.
CORBA::Boolean supplier_non_existent (CORBA::Boolean_out disconnected)
virtual void shutdown (void)
 The event channel is shutting down.
CORBA::ULong _incr_refcnt (void)
 Increment and decrement the reference count.
CORBA::ULong _decr_refcnt (void)
virtual void connect_push_supplier (CosEventComm::PushSupplier_ptr push_supplier)
virtual void push (const CORBA::Any &event)
virtual void invoke (const TAO_CEC_TypedEvent &typed_event)
virtual void disconnect_push_consumer (void)
virtual CORBA::Object_ptr get_typed_consumer ()
virtual PortableServer::POA_ptr _default_POA (void)
virtual void _add_ref (void)
virtual void _remove_ref (void)

Protected Member Functions

CORBA::Boolean is_connected_i (void) const
 The private version (without locking) of is_connected().
void cleanup_i (void)
 Release the supplier.
CosEventComm::PushSupplier_ptr apply_policy (CosEventComm::PushSupplier_ptr pre)

Private Attributes

TAO_CEC_TypedEventChanneltyped_event_channel_
 The typed supplier admin, used for activation and memory managment.
ACE_Time_Value timeout_
ACE_Locklock_
 The locking strategy.
CORBA::ULong refcount_
 The reference count.
CosEventComm::PushSupplier_var typed_supplier_
CosEventComm::PushSupplier_var nopolicy_typed_supplier_
 The typed supplier without any policies applied.
TAO_CEC_DynamicImplementationServerdsi_impl_
 The DSI impl.
PortableServer::ObjectId_var oid_
 The DSI Portable Server OID.
int connected_
PortableServer::POA_var default_POA_
 Store the default POA.

Friends

class TAO_CEC_TypedProxyPushConsumer_Guard

Member Typedef Documentation

typedef CosTypedEventChannelAdmin::TypedProxyPushConsumer_ptr TAO_CEC_TypedProxyPushConsumer::_ptr_type
typedef CosTypedEventChannelAdmin::TypedProxyPushConsumer_var TAO_CEC_TypedProxyPushConsumer::_var_type

Constructor & Destructor Documentation

TAO_CEC_TypedProxyPushConsumer::TAO_CEC_TypedProxyPushConsumer ( TAO_CEC_TypedEventChannel typed_event_channel,
const ACE_Time_Value timeout 
)
TAO_CEC_TypedProxyPushConsumer::~TAO_CEC_TypedProxyPushConsumer ( void  ) [virtual]

Member Function Documentation

void TAO_CEC_TypedProxyPushConsumer::_add_ref ( void  ) [virtual]
CORBA::ULong TAO_CEC_TypedProxyPushConsumer::_decr_refcnt ( void  )
PortableServer::POA_ptr TAO_CEC_TypedProxyPushConsumer::_default_POA ( void  ) [virtual]
CORBA::ULong TAO_CEC_TypedProxyPushConsumer::_incr_refcnt ( void  )

Increment and decrement the reference count.

void TAO_CEC_TypedProxyPushConsumer::_remove_ref ( void  ) [virtual]
void TAO_CEC_TypedProxyPushConsumer::activate ( CosTypedEventChannelAdmin::TypedProxyPushConsumer_ptr &  activated_proxy) [virtual]

Activate in the POA.

CosEventComm::PushSupplier_ptr TAO_CEC_TypedProxyPushConsumer::apply_policy ( CosEventComm::PushSupplier_ptr  pre) [protected]

Assigns the parameter to both supplier_ and nopolicy_supplier_, and applies policies (when appropriate) to supplier_.

void TAO_CEC_TypedProxyPushConsumer::cleanup_i ( void  ) [protected]

Release the supplier.

void TAO_CEC_TypedProxyPushConsumer::connect_push_supplier ( CosEventComm::PushSupplier_ptr  push_supplier) [virtual]
void TAO_CEC_TypedProxyPushConsumer::deactivate ( void  ) [virtual]

Deactivate from the POA.

void TAO_CEC_TypedProxyPushConsumer::disconnect_push_consumer ( void  ) [virtual]
CORBA::Object_ptr TAO_CEC_TypedProxyPushConsumer::get_typed_consumer ( void  ) [virtual]
void TAO_CEC_TypedProxyPushConsumer::invoke ( const TAO_CEC_TypedEvent typed_event) [virtual]
CORBA::Boolean TAO_CEC_TypedProxyPushConsumer::is_connected_i ( void  ) const [protected]

The private version (without locking) of is_connected().

void TAO_CEC_TypedProxyPushConsumer::push ( const CORBA::Any &  event) [virtual]
void TAO_CEC_TypedProxyPushConsumer::shutdown ( void  ) [virtual]

The event channel is shutting down.

CORBA::Boolean TAO_CEC_TypedProxyPushConsumer::supplier_non_existent ( CORBA::Boolean_out  disconnected)

Invoke the _non_existent() pseudo-operation on the supplier. If it is disconnected then it returns true and sets the <disconnected> flag.


Friends And Related Function Documentation

friend class TAO_CEC_TypedProxyPushConsumer_Guard [friend]

Member Data Documentation

If the flag is not zero then we are connected, notice that the supplier can be nil.

Store the default POA.

The DSI impl.

The locking strategy.

CosEventComm::PushSupplier_var TAO_CEC_TypedProxyPushConsumer::nopolicy_typed_supplier_ [private]

The typed supplier without any policies applied.

The DSI Portable Server OID.

The reference count.

The typed supplier admin, used for activation and memory managment.

CosEventComm::PushSupplier_var TAO_CEC_TypedProxyPushConsumer::typed_supplier_ [private]

The typed supplier -- use apply_policy() instead of assigning directly to typed_supplier_. This will keep typed_supplier_ and nopolicy_typed_supplier_ in sync.


The documentation for this class was generated from the following files:
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Friends Defines