TAO_CosNotification: TAO_Notify_ProxyConsumer class Reference

00033   : supplier_admin_ (0)
00034 {
00035 }

00069 {
00070   // Adopt the supplier
00071   ACE_Auto_Ptr< TAO_Notify_Supplier > auto_supplier (supplier);
00072 
00073   TAO_Notify_Atomic_Property_Long& supplier_count = this->admin_properties().suppliers ();
00074   const TAO_Notify_Property_Long& max_suppliers = this->admin_properties().max_suppliers ();
00075 
00076   if (max_suppliers != 0 && supplier_count >= max_suppliers.value ())
00077   {
00078     throw CORBA::IMP_LIMIT (
00079       ); // we've reached the limit of suppliers connected.
00080   }
00081 
00082   {
00083     ACE_GUARD_THROW_EX (TAO_SYNCH_MUTEX, ace_mon, this->lock_,
00084                         CORBA::INTERNAL ());
00085 
00086     // if supplier is set and reconnect not allowed we get out.
00087     if (this->is_connected () && TAO_Notify_PROPERTIES::instance()->allow_reconnect() == false)
00088       {
00089         throw CosEventChannelAdmin::AlreadyConnected ();
00090       }
00091 
00092     // Adopt the supplier
00093     this->supplier_ = auto_supplier;
00094 
00095     this->supplier_admin_->subscribed_types (this->subscribed_types_); // get the parents subscribed types.
00096   }
00097 
00098   // Inform QoS values.
00099   ACE_ASSERT (this->supplier_.get() != 0);
00100   this->supplier_->qos_changed (this->qos_properties_);
00101 
00102   TAO_Notify_EventTypeSeq removed;
00103 
00104   this->event_manager().offer_change (this, this->subscribed_types_, removed);
00105 
00106   this->event_manager().connect (this);
00107 
00108   // Increment the global supplier count
00109   ++supplier_count;
00110 }

00178 {
00179   this->shutdown ();
00180   this->supplier_admin_->remove (this);
00181 
00182   // Do not reset this->supplier_.
00183   // It is not safe to delete the non-refcounted supplier here.
00184 }

00149 {
00150   TAO_Notify_EventTypeSeq added;
00151 
00152   event_manager().offer_change (this, added, this->subscribed_types_);
00153 
00154   this->event_manager().disconnect (this);
00155 
00156   // Decrement the global supplier count
00157   this->admin_properties().suppliers ()--;
00158 }

00049 {
00050   ACE_ASSERT( this->supplier_admin_.get() == 0 );
00051 
00052   TAO_Notify_Proxy::initialize (topology_parent);
00053 
00054   this->supplier_admin_.reset (dynamic_cast<TAO_Notify_SupplierAdmin *>(topology_parent));
00055   ACE_ASSERT (this->supplier_admin_.get() != 0);
00056 
00057   const CosNotification::QoSProperties &default_ps_qos =
00058     TAO_Notify_PROPERTIES::instance ()->default_proxy_consumer_qos_properties ();
00059 
00060   {
00061     ACE_GUARD_THROW_EX (TAO_SYNCH_MUTEX, ace_mon, this->lock_,
00062                          CORBA::INTERNAL ());
00063     this->TAO_Notify_Object::set_qos (default_ps_qos);
00064   }
00065 }

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

00043 {
00044   return this->supplier ();
00045 }

00113 {
00114   if (this->supports_reliable_events ())
00115     {
00116       TAO_Notify_Event::Ptr pevent(event->queueable_copy());
00117       TAO_Notify::Routing_Slip_Ptr routing_slip =
00118         TAO_Notify::Routing_Slip::create (pevent);
00119       if (DEBUG_LEVEL > 0)
00120         ACE_DEBUG((LM_DEBUG, ACE_TEXT ("ProxyConsumer routing event.\n")));
00121       routing_slip->route (this, true);
00122       routing_slip->wait_persist ();
00123     }
00124   else
00125     {
00126       TAO_Notify_Method_Request_Lookup_No_Copy request (event, this);
00127       this->execute_task (request);
00128     }
00129 }

00162 {
00163   if (this->TAO_Notify_Object::shutdown () == 1)
00164     return 1;
00165 
00166 
00167   this->disconnect ();
00168 
00169   if (this->supplier_.get() != 0)
00170   {
00171     this->supplier_->shutdown ();
00172   }
00173   return 0;
00174 }

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

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

00133 {
00134   bool reliable = false;
00135   CosNotification::PropertyValue value;
00136   if (this->find_qos_property_value (CosNotification::EventReliability, value))
00137     {
00138       CORBA::Short setting;
00139       if (value >>= setting)
00140         {
00141           reliable = (setting == CosNotification::Persistent);
00142         }
00143     }
00144   return reliable;
00145 }


Public Types
typedef TAO_Notify_Refcountable_Guard_T< TAO_Notify_ProxyConsumer >	Ptr
Public Member Functions
	TAO_Notify_ProxyConsumer (void)
	Constuctor.
virtual	~TAO_Notify_ProxyConsumer ()
	Destructor.
virtual void	init (TAO_Notify::Topology_Parent *topology_parent)
	init: overrides Topology_Object method
void	connect (TAO_Notify_Supplier *supplier)
	Connect.
void	disconnect (void)
	Disconnect.
virtual int	shutdown (void)
	Shutdown (TAO_Notify_Container_T method).
virtual void	destroy (void)
	Destroy this object.
bool	is_connected (void) const
	Return 1 if connected.
TAO_Notify_SupplierAdmin &	supplier_admin (void)
	The SA parent.
Protected Member Functions
TAO_Notify_Supplier *	supplier (void)
	Access the Supplier.
void	push_i (TAO_Notify_Event *event)
	Accept an event from the Supplier.
Private Member Functions
bool	supports_reliable_events () const
	Is this part of a reliable channel.
virtual TAO_Notify_Peer *	peer (void)
	Access our Peer.
Private Attributes
TAO_Notify_SupplierAdmin::Ptr	supplier_admin_
ACE_Auto_Ptr< TAO_Notify_Supplier >	supplier_
	The Supplier that we're connect to.

TAO_Notify_ProxyConsumer Class Reference

Public Types

Public Member Functions

Protected Member Functions

Private Member Functions

Private Attributes

Detailed Description

Member Typedef Documentation

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation