diff options
Diffstat (limited to 'TAO/orbsvcs/orbsvcs/Notify/Consumer.inl')
| -rw-r--r-- | TAO/orbsvcs/orbsvcs/Notify/Consumer.inl | 18 |
1 files changed, 9 insertions, 9 deletions
diff --git a/TAO/orbsvcs/orbsvcs/Notify/Consumer.inl b/TAO/orbsvcs/orbsvcs/Notify/Consumer.inl index 9c5c391e6f9..77a5f12c554 100644 --- a/TAO/orbsvcs/orbsvcs/Notify/Consumer.inl +++ b/TAO/orbsvcs/orbsvcs/Notify/Consumer.inl @@ -3,31 +3,31 @@ #include "ProxySupplier.h" ACE_INLINE TAO_SYNCH_MUTEX* -TAO_NS_Consumer::proxy_lock (void) +TAO_Notify_Consumer::proxy_lock (void) { return &this->proxy_->lock_; } -ACE_INLINE TAO_NS_ProxySupplier* -TAO_NS_Consumer::proxy_supplier (void) +ACE_INLINE TAO_Notify_ProxySupplier* +TAO_Notify_Consumer::proxy_supplier (void) { return this->proxy_; } ACE_INLINE CORBA::Boolean -TAO_NS_Consumer::is_suspended (void) +TAO_Notify_Consumer::is_suspended (void) { return this->is_suspended_; } ACE_INLINE void -TAO_NS_Consumer::suspend (ACE_ENV_SINGLE_ARG_DECL_NOT_USED) +TAO_Notify_Consumer::suspend (ACE_ENV_SINGLE_ARG_DECL_NOT_USED) { this->is_suspended_ = 1; } ACE_INLINE void -TAO_NS_Consumer::push (const TAO_NS_Event_var &event ACE_ENV_ARG_DECL) +TAO_Notify_Consumer::push (const TAO_Notify_Event_var &event ACE_ENV_ARG_DECL) { if (this->is_suspended_ == 1) // If we're suspended, queue for later delivery. { @@ -60,14 +60,14 @@ TAO_NS_Consumer::push (const TAO_NS_Event_var &event ACE_ENV_ARG_DECL) } ACE_INLINE void -TAO_NS_Consumer::push (const TAO_NS_Event* event ACE_ENV_ARG_DECL) +TAO_Notify_Consumer::push (const TAO_Notify_Event* event ACE_ENV_ARG_DECL) { if (this->is_suspended_ == 1) // If we're suspended, queue for later delivery. { ACE_GUARD (TAO_SYNCH_MUTEX, ace_mon, *this->proxy_lock ()); - TAO_NS_Event* event_copy = event->copy (ACE_ENV_SINGLE_ARG_PARAMETER); - TAO_NS_Event_Copy_var event_var (event_copy); + TAO_Notify_Event* event_copy = event->copy (ACE_ENV_SINGLE_ARG_PARAMETER); + TAO_Notify_Event_Copy_var event_var (event_copy); this->event_collection_->enqueue_head (event_var); |