TAO_CosNotification: TAO_Notify_ProxySupplier class Reference

00023   : consumer_admin_ (0)
00024 {
00025 }

00058 {
00059   // Adopt the consumer
00060   ACE_Auto_Ptr< TAO_Notify_Consumer > auto_consumer (consumer);
00061 
00062   TAO_Notify_Atomic_Property_Long& consumer_count = this->admin_properties().consumers ();
00063   const TAO_Notify_Property_Long& max_consumers = this->admin_properties().max_consumers ();
00064 
00065   if (max_consumers != 0 && consumer_count >= max_consumers.value ())
00066   {
00067     throw CORBA::IMP_LIMIT (
00068       ); // we've reached the limit of consumers connected.
00069   }
00070 
00071   {
00072     ACE_GUARD_THROW_EX (TAO_SYNCH_MUTEX, ace_mon, this->lock_,
00073                         CORBA::INTERNAL ());
00074 
00075     // if consumer is set and reconnect not allowed we get out.
00076     if (this->is_connected () && TAO_Notify_PROPERTIES::instance()->allow_reconnect() == false)
00077       {
00078           throw CosEventChannelAdmin::AlreadyConnected ();
00079       }
00080 
00081     // Adopt the consumer
00082     if (this->consumer_.get() != 0)
00083       auto_consumer->assume_pending_events (*this->consumer_.get ());
00084     this->consumer_ = auto_consumer;
00085 
00086     this->consumer_admin_->subscribed_types (this->subscribed_types_); // get the parents subscribed types.
00087   }
00088 
00089   // Inform QoS values.
00090   ACE_ASSERT (this->consumer_.get() != 0);
00091   this->consumer_->qos_changed (this->qos_properties_);
00092 
00093   TAO_Notify_EventTypeSeq removed;
00094 
00095   this->event_manager().subscription_change (this, this->subscribed_types_, removed);
00096 
00097   this->event_manager().connect (this);
00098 
00099   // Increment the global consumer count
00100   ++consumer_count;
00101 }

00015 {
00016   return this->consumer_.get();
00017 }

00021 {
00022   ACE_ASSERT( this->consumer_admin_.get() != 0 );
00023   return *this->consumer_admin_;
00024 }

00144 {
00145   this->execute_task (request);
00146 }

00134 {
00135   this->shutdown ();
00136   this->consumer_admin_->remove (this);
00137 
00138   // Do not reset this->consumer_.
00139   // It is not safe to delete the non-refcounted consumer here.
00140 }

00105 {
00106   TAO_Notify_EventTypeSeq added;
00107 
00108   this->event_manager().subscription_change (this, added, this->subscribed_types_);
00109 
00110   this->event_manager().disconnect (this);
00111 
00112   // Decrement the global consumer count
00113   this->admin_properties().consumers ()--;
00114 }

00033 {
00034   ACE_ASSERT (consumer_admin != 0 && this->consumer_admin_.get() == 0);
00035 
00036   TAO_Notify_Proxy::initialize (consumer_admin);
00037 
00038   this->consumer_admin_.reset (consumer_admin);
00039 
00040   const CosNotification::QoSProperties &default_ps_qos =
00041     TAO_Notify_PROPERTIES::instance ()->default_proxy_supplier_qos_properties ();
00042 
00043   {
00044     ACE_GUARD_THROW_EX (TAO_SYNCH_MUTEX, ace_mon, this->lock_,
00045                           CORBA::INTERNAL ());
00046     this->TAO_Notify_Object::set_qos (default_ps_qos);
00047   }
00048 }

00009 {
00010   return ( this->consumer_.get() != 0 );
00011 }

00052 {
00053   return this->consumer ();
00054 }

00150 {
00151   TAO_Notify_Proxy::qos_changed (qos_properties);
00152 }

00118 {
00119   if (this->TAO_Notify_Object::shutdown () == 1)
00120     return 1;
00121 
00122 
00123   this->disconnect ();
00124 
00125   if (this->consumer_.get() != 0)
00126   {
00127     this->consumer_->shutdown ();
00128   }
00129   return 0;
00130 }


Public Types
typedef TAO_Notify_Refcountable_Guard_T< TAO_Notify_ProxySupplier >	Ptr
Public Member Functions
	TAO_Notify_ProxySupplier (void)
	Constuctor.
virtual	~TAO_Notify_ProxySupplier ()
	Destructor.
virtual void	init (TAO_Notify_ConsumerAdmin *consumer_admin)
	Init.
void	connect (TAO_Notify_Consumer *consumer)
	Connect.
void	disconnect (void)
	Disconnect.
virtual void	deliver (TAO_Notify_Method_Request_Dispatch_No_Copy &request)
	Dispatch Event to consumer.
virtual int	shutdown (void)
	Override TAO_Notify_Container_T::shutdown method.
virtual void	destroy (void)
	Destroy this object.
virtual void	qos_changed (const TAO_Notify_QoSProperties &qos_properties)
	Override, TAO_Notify_Proxy::qos_changed to apply MaxEventssPerConsumer QoS.
bool	is_connected (void) const
	Returns true if connected.
TAO_Notify_Consumer *	consumer (void)
	Access the Consumer.
TAO_Notify_ConsumerAdmin &	consumer_admin (void)
	The CA parent.
Private Member Functions
virtual TAO_Notify_Peer *	peer (void)
	Access our Peer.
Private Attributes
TAO_Notify_ConsumerAdmin::Ptr	consumer_admin_
ACE_Auto_Ptr< TAO_Notify_Consumer >	consumer_
	The Consumer that we're connect to.
Friends
class	TAO_Notify_Consumer

TAO_Notify_ProxySupplier Class Reference

Public Types

Public Member Functions

Private Member Functions

Private Attributes

Friends

Detailed Description

Member Typedef Documentation

Constructor & Destructor Documentation

Member Function Documentation

Friends And Related Function Documentation

Member Data Documentation