diff options
Diffstat (limited to 'TAO/orbsvcs/orbsvcs/Notify/Builder.cpp')
| -rw-r--r-- | TAO/orbsvcs/orbsvcs/Notify/Builder.cpp | 136 |
1 files changed, 68 insertions, 68 deletions
diff --git a/TAO/orbsvcs/orbsvcs/Notify/Builder.cpp b/TAO/orbsvcs/orbsvcs/Notify/Builder.cpp index 9efaf028d3f..171bd4a0f05 100644 --- a/TAO/orbsvcs/orbsvcs/Notify/Builder.cpp +++ b/TAO/orbsvcs/orbsvcs/Notify/Builder.cpp @@ -5,7 +5,7 @@ #include "Builder.inl" #endif /* __ACE_INLINE__ */ -ACE_RCSID(RT_Notify, TAO_NS_Builder, "$Id$") +ACE_RCSID(RT_Notify, TAO_Notify_Builder, "$Id$") #include "ace/Dynamic_Service.h" #include "tao/PortableServer/PortableServerC.h" @@ -38,7 +38,7 @@ ACE_RCSID(RT_Notify, TAO_NS_Builder, "$Id$") #include "Container_T.h" template <class PROXY_IMPL, class PROXY, class PROXY_PTR, class PROXY_VAR, class PARENT> -class TAO_NS_Proxy_Builder_T +class TAO_Notify_Proxy_Builder_T { public: PROXY_PTR @@ -47,7 +47,7 @@ public: { PROXY_VAR proxy_ret; - TAO_NS_Factory* factory = TAO_NS_PROPERTIES::instance ()->factory (); + TAO_Notify_Factory* factory = TAO_Notify_PROPERTIES::instance ()->factory (); PROXY_IMPL* proxy = 0; factory->create (proxy ACE_ENV_ARG_PARAMETER); @@ -78,106 +78,106 @@ public: }; // define the ProxyConsumer Builders. -typedef TAO_NS_Proxy_Builder_T<TAO_NS_ProxyPushConsumer +typedef TAO_Notify_Proxy_Builder_T<TAO_Notify_ProxyPushConsumer , CosNotifyChannelAdmin::ProxyConsumer , CosNotifyChannelAdmin::ProxyConsumer_ptr , CosNotifyChannelAdmin::ProxyConsumer_var - , TAO_NS_SupplierAdmin> -TAO_NS_ProxyPushConsumer_Builder; + , TAO_Notify_SupplierAdmin> +TAO_Notify_ProxyPushConsumer_Builder; -typedef TAO_NS_Proxy_Builder_T<TAO_NS_StructuredProxyPushConsumer +typedef TAO_Notify_Proxy_Builder_T<TAO_Notify_StructuredProxyPushConsumer , CosNotifyChannelAdmin::ProxyConsumer , CosNotifyChannelAdmin::ProxyConsumer_ptr , CosNotifyChannelAdmin::ProxyConsumer_var - , TAO_NS_SupplierAdmin> -TAO_NS_StructuredProxyPushConsumer_Builder; + , TAO_Notify_SupplierAdmin> +TAO_Notify_StructuredProxyPushConsumer_Builder; -typedef TAO_NS_Proxy_Builder_T<TAO_NS_SequenceProxyPushConsumer +typedef TAO_Notify_Proxy_Builder_T<TAO_Notify_SequenceProxyPushConsumer , CosNotifyChannelAdmin::ProxyConsumer , CosNotifyChannelAdmin::ProxyConsumer_ptr , CosNotifyChannelAdmin::ProxyConsumer_var - , TAO_NS_SupplierAdmin> -TAO_NS_SequenceProxyPushConsumer_Builder; + , TAO_Notify_SupplierAdmin> +TAO_Notify_SequenceProxyPushConsumer_Builder; -typedef TAO_NS_Proxy_Builder_T<TAO_NS_CosEC_ProxyPushConsumer +typedef TAO_Notify_Proxy_Builder_T<TAO_Notify_CosEC_ProxyPushConsumer , CosEventChannelAdmin::ProxyPushConsumer , CosEventChannelAdmin::ProxyPushConsumer_ptr , CosEventChannelAdmin::ProxyPushConsumer_var - , TAO_NS_SupplierAdmin> -TAO_NS_CosEC_ProxyPushConsumer_Builder; + , TAO_Notify_SupplierAdmin> +TAO_Notify_CosEC_ProxyPushConsumer_Builder; // define the ProxySupplier Builders. -typedef TAO_NS_Proxy_Builder_T<TAO_NS_ProxyPushSupplier +typedef TAO_Notify_Proxy_Builder_T<TAO_Notify_ProxyPushSupplier , CosNotifyChannelAdmin::ProxySupplier , CosNotifyChannelAdmin::ProxySupplier_ptr , CosNotifyChannelAdmin::ProxySupplier_var - , TAO_NS_ConsumerAdmin> -TAO_NS_ProxyPushSupplier_Builder; + , TAO_Notify_ConsumerAdmin> +TAO_Notify_ProxyPushSupplier_Builder; -typedef TAO_NS_Proxy_Builder_T<TAO_NS_StructuredProxyPushSupplier +typedef TAO_Notify_Proxy_Builder_T<TAO_Notify_StructuredProxyPushSupplier , CosNotifyChannelAdmin::ProxySupplier , CosNotifyChannelAdmin::ProxySupplier_ptr , CosNotifyChannelAdmin::ProxySupplier_var - , TAO_NS_ConsumerAdmin> -TAO_NS_StructuredProxyPushSupplier_Builder; + , TAO_Notify_ConsumerAdmin> +TAO_Notify_StructuredProxyPushSupplier_Builder; -typedef TAO_NS_Proxy_Builder_T<TAO_NS_SequenceProxyPushSupplier +typedef TAO_Notify_Proxy_Builder_T<TAO_Notify_SequenceProxyPushSupplier , CosNotifyChannelAdmin::ProxySupplier , CosNotifyChannelAdmin::ProxySupplier_ptr , CosNotifyChannelAdmin::ProxySupplier_var - , TAO_NS_ConsumerAdmin> -TAO_NS_SequenceProxyPushSupplier_Builder; + , TAO_Notify_ConsumerAdmin> +TAO_Notify_SequenceProxyPushSupplier_Builder; -typedef TAO_NS_Proxy_Builder_T<TAO_NS_CosEC_ProxyPushSupplier +typedef TAO_Notify_Proxy_Builder_T<TAO_Notify_CosEC_ProxyPushSupplier , CosEventChannelAdmin::ProxyPushSupplier , CosEventChannelAdmin::ProxyPushSupplier_ptr , CosEventChannelAdmin::ProxyPushSupplier_var - , TAO_NS_ConsumerAdmin> -TAO_NS_CosEC_ProxyPushSupplier_Builder; + , TAO_Notify_ConsumerAdmin> +TAO_Notify_CosEC_ProxyPushSupplier_Builder; -TAO_NS_Builder::TAO_NS_Builder (void) +TAO_Notify_Builder::TAO_Notify_Builder (void) { // Init the static members. - TAO_NS_AnyEvent::event_type_ = TAO_NS_EventType::special (); + TAO_Notify_AnyEvent::event_type_ = TAO_Notify_EventType::special (); } -TAO_NS_Builder::~TAO_NS_Builder () +TAO_Notify_Builder::~TAO_Notify_Builder () { } CosNotifyFilter::FilterFactory_ptr -TAO_NS_Builder::build_filter_factory (ACE_ENV_SINGLE_ARG_DECL) +TAO_Notify_Builder::build_filter_factory (ACE_ENV_SINGLE_ARG_DECL) { - TAO_NS_FilterFactory* ff = ACE_Dynamic_Service<TAO_NS_FilterFactory>::instance ("TAO_NS_FilterFactory"); + TAO_Notify_FilterFactory* ff = ACE_Dynamic_Service<TAO_Notify_FilterFactory>::instance ("TAO_Notify_FilterFactory"); if (ff == 0) { ACE_NEW_THROW_EX (ff, - TAO_NS_ETCL_FilterFactory (), + TAO_Notify_ETCL_FilterFactory (), CORBA::NO_MEMORY ()); ACE_CHECK_RETURN (CosNotifyFilter::FilterFactory::_nil ()); } - PortableServer::POA_var default_poa = TAO_NS_PROPERTIES::instance ()->default_poa (); + PortableServer::POA_var default_poa = TAO_Notify_PROPERTIES::instance ()->default_poa (); return ff->create (default_poa ACE_ENV_ARG_PARAMETER); } CosNotifyChannelAdmin::EventChannelFactory_ptr -TAO_NS_Builder::build_event_channel_factory (PortableServer::POA_ptr poa ACE_ENV_ARG_DECL) +TAO_Notify_Builder::build_event_channel_factory (PortableServer::POA_ptr poa ACE_ENV_ARG_DECL) { CosNotifyChannelAdmin::EventChannelFactory_var ecf_ret; - TAO_NS_Factory* factory = TAO_NS_PROPERTIES::instance ()->factory (); + TAO_Notify_Factory* factory = TAO_Notify_PROPERTIES::instance ()->factory (); // Create ECF - TAO_NS_EventChannelFactory* ecf = 0; + TAO_Notify_EventChannelFactory* ecf = 0; factory->create (ecf ACE_ENV_ARG_PARAMETER); ACE_CHECK_RETURN (ecf_ret._retn ()); PortableServer::ServantBase_var servant_var (ecf); - ecf->TAO_NS_EventChannelFactory::init (poa ACE_ENV_ARG_PARAMETER); + ecf->TAO_Notify_EventChannelFactory::init (poa ACE_ENV_ARG_PARAMETER); CORBA::Object_var obj = ecf->activate (ecf ACE_ENV_ARG_PARAMETER); ACE_CHECK_RETURN (ecf_ret._retn ()); @@ -189,13 +189,13 @@ TAO_NS_Builder::build_event_channel_factory (PortableServer::POA_ptr poa ACE_ENV } CosNotifyChannelAdmin::EventChannel_ptr -TAO_NS_Builder::build_event_channel (TAO_NS_EventChannelFactory* ecf, const CosNotification::QoSProperties & initial_qos, const CosNotification::AdminProperties & initial_admin, CosNotifyChannelAdmin::ChannelID_out id ACE_ENV_ARG_DECL) +TAO_Notify_Builder::build_event_channel (TAO_Notify_EventChannelFactory* ecf, const CosNotification::QoSProperties & initial_qos, const CosNotification::AdminProperties & initial_admin, CosNotifyChannelAdmin::ChannelID_out id ACE_ENV_ARG_DECL) { CosNotifyChannelAdmin::EventChannel_var ec_ret; - TAO_NS_Factory* factory = TAO_NS_PROPERTIES::instance ()->factory (); + TAO_Notify_Factory* factory = TAO_Notify_PROPERTIES::instance ()->factory (); - TAO_NS_EventChannel* ec = 0; + TAO_Notify_EventChannel* ec = 0; factory->create (ec ACE_ENV_ARG_PARAMETER); ACE_CHECK_RETURN (ec_ret._retn ()); @@ -221,13 +221,13 @@ TAO_NS_Builder::build_event_channel (TAO_NS_EventChannelFactory* ecf, const CosN } CosNotifyChannelAdmin::ConsumerAdmin_ptr -TAO_NS_Builder::build_consumer_admin (TAO_NS_EventChannel* ec, CosNotifyChannelAdmin::InterFilterGroupOperator op, CosNotifyChannelAdmin::AdminID_out id ACE_ENV_ARG_DECL) +TAO_Notify_Builder::build_consumer_admin (TAO_Notify_EventChannel* ec, CosNotifyChannelAdmin::InterFilterGroupOperator op, CosNotifyChannelAdmin::AdminID_out id ACE_ENV_ARG_DECL) { CosNotifyChannelAdmin::ConsumerAdmin_var ca_ret; - TAO_NS_Factory* factory = TAO_NS_PROPERTIES::instance ()->factory (); + TAO_Notify_Factory* factory = TAO_Notify_PROPERTIES::instance ()->factory (); - TAO_NS_ConsumerAdmin* ca = 0; + TAO_Notify_ConsumerAdmin* ca = 0; factory->create (ca ACE_ENV_ARG_PARAMETER); ACE_CHECK_RETURN (ca_ret._retn ()); @@ -254,13 +254,13 @@ TAO_NS_Builder::build_consumer_admin (TAO_NS_EventChannel* ec, CosNotifyChannelA } CosNotifyChannelAdmin::SupplierAdmin_ptr -TAO_NS_Builder::build_supplier_admin (TAO_NS_EventChannel* ec, CosNotifyChannelAdmin::InterFilterGroupOperator op, CosNotifyChannelAdmin::AdminID_out id ACE_ENV_ARG_DECL) +TAO_Notify_Builder::build_supplier_admin (TAO_Notify_EventChannel* ec, CosNotifyChannelAdmin::InterFilterGroupOperator op, CosNotifyChannelAdmin::AdminID_out id ACE_ENV_ARG_DECL) { CosNotifyChannelAdmin::SupplierAdmin_var sa_ret; - TAO_NS_Factory* factory = TAO_NS_PROPERTIES::instance ()->factory (); + TAO_Notify_Factory* factory = TAO_Notify_PROPERTIES::instance ()->factory (); - TAO_NS_SupplierAdmin* sa = 0; + TAO_Notify_SupplierAdmin* sa = 0; factory->create (sa ACE_ENV_ARG_PARAMETER); ACE_CHECK_RETURN (sa_ret._retn ()); @@ -287,7 +287,7 @@ TAO_NS_Builder::build_supplier_admin (TAO_NS_EventChannel* ec, CosNotifyChannelA } CosNotifyChannelAdmin::ProxyConsumer_ptr -TAO_NS_Builder::build_proxy(TAO_NS_SupplierAdmin* sa +TAO_Notify_Builder::build_proxy(TAO_Notify_SupplierAdmin* sa , CosNotifyChannelAdmin::ClientType ctype , CosNotifyChannelAdmin::ProxyID_out proxy_id , const CosNotification::QoSProperties & initial_qos @@ -297,21 +297,21 @@ TAO_NS_Builder::build_proxy(TAO_NS_SupplierAdmin* sa { case CosNotifyChannelAdmin::ANY_EVENT: { - TAO_NS_ProxyPushConsumer_Builder pb; + TAO_Notify_ProxyPushConsumer_Builder pb; return pb.build (sa, proxy_id, initial_qos ACE_ENV_ARG_PARAMETER); } break; case CosNotifyChannelAdmin::STRUCTURED_EVENT: { - TAO_NS_StructuredProxyPushConsumer_Builder pb; + TAO_Notify_StructuredProxyPushConsumer_Builder pb; return pb.build (sa, proxy_id, initial_qos ACE_ENV_ARG_PARAMETER); } break; case CosNotifyChannelAdmin::SEQUENCE_EVENT: { - TAO_NS_SequenceProxyPushConsumer_Builder pb; + TAO_Notify_SequenceProxyPushConsumer_Builder pb; return pb.build (sa, proxy_id, initial_qos ACE_ENV_ARG_PARAMETER); } break; @@ -323,7 +323,7 @@ TAO_NS_Builder::build_proxy(TAO_NS_SupplierAdmin* sa } CosNotifyChannelAdmin::ProxySupplier_ptr -TAO_NS_Builder::build_proxy(TAO_NS_ConsumerAdmin* ca +TAO_Notify_Builder::build_proxy(TAO_Notify_ConsumerAdmin* ca , CosNotifyChannelAdmin::ClientType ctype , CosNotifyChannelAdmin::ProxyID_out proxy_id , const CosNotification::QoSProperties & initial_qos @@ -333,21 +333,21 @@ TAO_NS_Builder::build_proxy(TAO_NS_ConsumerAdmin* ca { case CosNotifyChannelAdmin::ANY_EVENT: { - TAO_NS_ProxyPushSupplier_Builder pb; + TAO_Notify_ProxyPushSupplier_Builder pb; return pb.build (ca, proxy_id, initial_qos ACE_ENV_ARG_PARAMETER); } break; case CosNotifyChannelAdmin::STRUCTURED_EVENT: { - TAO_NS_StructuredProxyPushSupplier_Builder pb; + TAO_Notify_StructuredProxyPushSupplier_Builder pb; return pb.build (ca, proxy_id, initial_qos ACE_ENV_ARG_PARAMETER); } break; case CosNotifyChannelAdmin::SEQUENCE_EVENT: { - TAO_NS_SequenceProxyPushSupplier_Builder pb; + TAO_Notify_SequenceProxyPushSupplier_Builder pb; return pb.build (ca, proxy_id, initial_qos ACE_ENV_ARG_PARAMETER); } break; @@ -359,11 +359,11 @@ TAO_NS_Builder::build_proxy(TAO_NS_ConsumerAdmin* ca } CosEventChannelAdmin::ProxyPushSupplier_ptr -TAO_NS_Builder::build_proxy (TAO_NS_ConsumerAdmin* ca ACE_ENV_ARG_DECL) +TAO_Notify_Builder::build_proxy (TAO_Notify_ConsumerAdmin* ca ACE_ENV_ARG_DECL) { CosNotifyChannelAdmin::ProxyID proxy_id; - TAO_NS_CosEC_ProxyPushSupplier_Builder pb; + TAO_Notify_CosEC_ProxyPushSupplier_Builder pb; CosNotification::QoSProperties initial_qos; @@ -371,11 +371,11 @@ TAO_NS_Builder::build_proxy (TAO_NS_ConsumerAdmin* ca ACE_ENV_ARG_DECL) } CosEventChannelAdmin::ProxyPushConsumer_ptr -TAO_NS_Builder::build_proxy (TAO_NS_SupplierAdmin* sa ACE_ENV_ARG_DECL) +TAO_Notify_Builder::build_proxy (TAO_Notify_SupplierAdmin* sa ACE_ENV_ARG_DECL) { CosNotifyChannelAdmin::ProxyID proxy_id; - TAO_NS_CosEC_ProxyPushConsumer_Builder pb; + TAO_Notify_CosEC_ProxyPushConsumer_Builder pb; CosNotification::QoSProperties initial_qos; @@ -383,12 +383,12 @@ TAO_NS_Builder::build_proxy (TAO_NS_SupplierAdmin* sa ACE_ENV_ARG_DECL) } void -TAO_NS_Builder::apply_reactive_concurrency (TAO_NS_Object& object ACE_ENV_ARG_DECL) +TAO_Notify_Builder::apply_reactive_concurrency (TAO_Notify_Object& object ACE_ENV_ARG_DECL) { - TAO_NS_Reactive_Task* worker_task; + TAO_Notify_Reactive_Task* worker_task; ACE_NEW_THROW_EX (worker_task, - TAO_NS_Reactive_Task (), + TAO_Notify_Reactive_Task (), CORBA::NO_MEMORY ()); ACE_CHECK; @@ -401,12 +401,12 @@ TAO_NS_Builder::apply_reactive_concurrency (TAO_NS_Object& object ACE_ENV_ARG_DE } void -TAO_NS_Builder::apply_thread_pool_concurrency (TAO_NS_Object& object, const NotifyExt::ThreadPoolParams& tp_params ACE_ENV_ARG_DECL) +TAO_Notify_Builder::apply_thread_pool_concurrency (TAO_Notify_Object& object, const NotifyExt::ThreadPoolParams& tp_params ACE_ENV_ARG_DECL) { - TAO_NS_ThreadPool_Task* worker_task; + TAO_Notify_ThreadPool_Task* worker_task; ACE_NEW_THROW_EX (worker_task, - TAO_NS_ThreadPool_Task (), + TAO_Notify_ThreadPool_Task (), CORBA::NO_MEMORY ()); ACE_CHECK; @@ -419,7 +419,7 @@ TAO_NS_Builder::apply_thread_pool_concurrency (TAO_NS_Object& object, const Noti } void -TAO_NS_Builder::apply_lane_concurrency (TAO_NS_Object& /*object*/, const NotifyExt::ThreadPoolLanesParams& /*tpl_params*/ ACE_ENV_ARG_DECL) +TAO_Notify_Builder::apply_lane_concurrency (TAO_Notify_Object& /*object*/, const NotifyExt::ThreadPoolLanesParams& /*tpl_params*/ ACE_ENV_ARG_DECL) { // No lane support ACE_THROW (CORBA::NO_IMPLEMENT ()); @@ -427,10 +427,10 @@ TAO_NS_Builder::apply_lane_concurrency (TAO_NS_Object& /*object*/, const NotifyE #if defined (ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION) -template class ACE_Dynamic_Service<TAO_NS_FilterFactory>; +template class ACE_Dynamic_Service<TAO_Notify_FilterFactory>; #elif defined (ACE_HAS_TEMPLATE_INSTANTIATION_PRAGMA) -#pragma instantiate ACE_Dynamic_Service<TAO_NS_FilterFactory> +#pragma instantiate ACE_Dynamic_Service<TAO_Notify_FilterFactory> #endif /*ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION */ |