diff options
Diffstat (limited to 'TAO/orbsvcs/orbsvcs/Notify/ProxySupplier_T.cpp')
| -rw-r--r-- | TAO/orbsvcs/orbsvcs/Notify/ProxySupplier_T.cpp | 33 |
1 files changed, 16 insertions, 17 deletions
diff --git a/TAO/orbsvcs/orbsvcs/Notify/ProxySupplier_T.cpp b/TAO/orbsvcs/orbsvcs/Notify/ProxySupplier_T.cpp index 04db7d0d999..c8ba03e66ab 100644 --- a/TAO/orbsvcs/orbsvcs/Notify/ProxySupplier_T.cpp +++ b/TAO/orbsvcs/orbsvcs/Notify/ProxySupplier_T.cpp @@ -9,14 +9,13 @@ #include "ProxySupplier_T.inl" #endif /* __ACE_INLINE__ */ -ACE_RCSID(Notify, TAO_NS_ProxySupplier_T, "$id$") +ACE_RCSID(Notify, TAO_NS_ProxySupplier_T, "$Id$") #include "Consumer.h" #include "Structured/StructuredEvent.h" #include "Any/AnyEvent.h" #include "Method_Request_Dispatch.h" -#include "Method_Request_Dispatch_No_Filtering.h" #include "Worker_Task.h" #include "Event_Manager.h" #include "ConsumerAdmin.h" @@ -46,50 +45,50 @@ TAO_NS_ProxySupplier_T<SERVANT_TYPE>::forward_structured (const CosNotification: CORBA::SystemException )) { - TAO_NS_Event_var event (new TAO_NS_StructuredEvent (notification)); + TAO_NS_StructuredEvent_No_Copy event (notification); - TAO_NS_Method_Request_Dispatch request (event, this); + TAO_NS_Method_Request_Dispatch_No_Copy request (&event, this, 1); - this->worker_task ()->exec (request); + this->worker_task ()->execute (request ACE_ENV_ARG_DECL); } template <class SERVANT_TYPE> void -TAO_NS_ProxySupplier_T<SERVANT_TYPE>::forward_structured_no_filtering (const CosNotification::StructuredEvent& notification ACE_ENV_ARG_DECL_NOT_USED) +TAO_NS_ProxySupplier_T<SERVANT_TYPE>::forward_structured_no_filtering (const CosNotification::StructuredEvent& notification ACE_ENV_ARG_DECL) ACE_THROW_SPEC (( CORBA::SystemException )) { - TAO_NS_Event_var event (new TAO_NS_StructuredEvent (notification)); + TAO_NS_StructuredEvent_No_Copy event(notification); - TAO_NS_Method_Request_Dispatch_No_Filtering request (event, this); + TAO_NS_Method_Request_Dispatch_No_Copy request (&event, this, 0); - this->worker_task ()->exec (request); + this->worker_task ()->execute (request ACE_ENV_ARG_DECL); } template <class SERVANT_TYPE> void -TAO_NS_ProxySupplier_T<SERVANT_TYPE>::forward_any (const CORBA::Any & data ACE_ENV_ARG_DECL_NOT_USED) +TAO_NS_ProxySupplier_T<SERVANT_TYPE>::forward_any (const CORBA::Any & any ACE_ENV_ARG_DECL_NOT_USED) ACE_THROW_SPEC (( CORBA::SystemException )) { - TAO_NS_Event_var event (new TAO_NS_AnyEvent (data)); + TAO_NS_AnyEvent_No_Copy event (any); - TAO_NS_Method_Request_Dispatch request (event, this); + TAO_NS_Method_Request_Dispatch_No_Copy request (&event, this, 1); - this->worker_task ()->exec (request); + this->worker_task ()->execute (request ACE_ENV_ARG_PARAMETER); } template <class SERVANT_TYPE> void -TAO_NS_ProxySupplier_T<SERVANT_TYPE>::forward_any_no_filtering (const CORBA::Any& data ACE_ENV_ARG_DECL_NOT_USED) +TAO_NS_ProxySupplier_T<SERVANT_TYPE>::forward_any_no_filtering (const CORBA::Any& any ACE_ENV_ARG_DECL) ACE_THROW_SPEC (( CORBA::SystemException )) { - TAO_NS_Event_var event (new TAO_NS_AnyEvent (data)); + TAO_NS_AnyEvent_No_Copy event(any); - TAO_NS_Method_Request_Dispatch_No_Filtering request (event, this); + TAO_NS_Method_Request_Dispatch_No_Copy request (&event, this, 0); - this->worker_task ()->exec (request); + this->worker_task ()->execute (request ACE_ENV_ARG_PARAMETER); } template <class SERVANT_TYPE> CosNotification::EventTypeSeq* |