diff options
Diffstat (limited to 'TAO/orbsvcs/orbsvcs/Notify/Notify_Default_EMO_Factory.cpp')
-rw-r--r-- | TAO/orbsvcs/orbsvcs/Notify/Notify_Default_EMO_Factory.cpp | 48 |
1 files changed, 24 insertions, 24 deletions
diff --git a/TAO/orbsvcs/orbsvcs/Notify/Notify_Default_EMO_Factory.cpp b/TAO/orbsvcs/orbsvcs/Notify/Notify_Default_EMO_Factory.cpp index 102c11c435e..8504fedf3a2 100644 --- a/TAO/orbsvcs/orbsvcs/Notify/Notify_Default_EMO_Factory.cpp +++ b/TAO/orbsvcs/orbsvcs/Notify/Notify_Default_EMO_Factory.cpp @@ -129,7 +129,7 @@ TAO_Notify_Default_EMO_Factory::init (int argc, char* argv[]) } TAO_Notify_Worker_Task* -TAO_Notify_Default_EMO_Factory::create_task (int mt, int tp_size,CORBA::Environment &ACE_TRY_ENV) +TAO_Notify_Default_EMO_Factory::create_task (int mt, int tp_size TAO_ENV_ARG_DECL) { TAO_Notify_Worker_Task* task; @@ -166,21 +166,21 @@ TAO_Notify_Default_EMO_Factory::init_instance (void) int TAO_Notify_Default_EMO_Factory::preallocate_tasks (void) { - ACE_DECLARE_NEW_CORBA_ENV; + TAO_ENV_DECLARE_NEW_ENV; this->prealloc_source_eval_task_ = - create_task (EMO_OPTIONS::instance ()->mt_source_eval_, EMO_OPTIONS::instance ()->source_threads_, - ACE_TRY_ENV); + create_task (EMO_OPTIONS::instance ()->mt_source_eval_, EMO_OPTIONS::instance ()->source_threads_ + TAO_ENV_ARG_PARAMETER); ACE_CHECK_RETURN (-1); this->prealloc_listener_eval_task_ = - create_task (EMO_OPTIONS::instance ()->mt_listener_eval_, EMO_OPTIONS::instance ()->listener_threads_, - ACE_TRY_ENV); + create_task (EMO_OPTIONS::instance ()->mt_listener_eval_, EMO_OPTIONS::instance ()->listener_threads_ + TAO_ENV_ARG_PARAMETER); ACE_CHECK_RETURN (-1); this->prealloc_dispatching_task_ = - create_task (EMO_OPTIONS::instance ()->mt_dispatching_, EMO_OPTIONS::instance ()->dispatching_threads_, - ACE_TRY_ENV); + create_task (EMO_OPTIONS::instance ()->mt_dispatching_, EMO_OPTIONS::instance ()->dispatching_threads_ + TAO_ENV_ARG_PARAMETER); ACE_CHECK_RETURN (-1); return 0; @@ -194,7 +194,7 @@ TAO_Notify_Default_EMO_Factory::fini (void) } TAO_Notify_Event_Manager* -TAO_Notify_Default_EMO_Factory::create_event_manager (TAO_Notify_EventChannel_i* channel, CORBA::Environment &ACE_TRY_ENV) +TAO_Notify_Default_EMO_Factory::create_event_manager (TAO_Notify_EventChannel_i* channel TAO_ENV_ARG_DECL) { TAO_Notify_Event_Manager* event_manager; ACE_NEW_THROW_EX (event_manager, @@ -204,7 +204,7 @@ TAO_Notify_Default_EMO_Factory::create_event_manager (TAO_Notify_EventChannel_i* } TAO_Notify_Event_Map* -TAO_Notify_Default_EMO_Factory::create_event_map (CORBA::Environment &ACE_TRY_ENV) +TAO_Notify_Default_EMO_Factory::create_event_map (TAO_ENV_SINGLE_ARG_DECL) { TAO_Notify_Event_Map* event_map; ACE_NEW_THROW_EX (event_map, @@ -214,7 +214,7 @@ TAO_Notify_Default_EMO_Factory::create_event_map (CORBA::Environment &ACE_TRY_EN } TAO_Notify_Event_Processor* -TAO_Notify_Default_EMO_Factory::create_event_processor (TAO_Notify_Event_Manager* event_manager, CORBA::Environment &ACE_TRY_ENV) +TAO_Notify_Default_EMO_Factory::create_event_processor (TAO_Notify_Event_Manager* event_manager TAO_ENV_ARG_DECL) { TAO_Notify_Event_Processor* event_processor; ACE_NEW_THROW_EX (event_processor, @@ -225,49 +225,49 @@ TAO_Notify_Default_EMO_Factory::create_event_processor (TAO_Notify_Event_Manager TAO_Notify_Worker_Task* -TAO_Notify_Default_EMO_Factory::create_source_eval_task (CORBA::Environment &ACE_TRY_ENV) +TAO_Notify_Default_EMO_Factory::create_source_eval_task (TAO_ENV_SINGLE_ARG_DECL) { if (EMO_OPTIONS::instance ()->alloc_task_per_proxy_ == 1) return create_task (EMO_OPTIONS::instance ()->mt_source_eval_, - EMO_OPTIONS::instance ()->source_threads_, - ACE_TRY_ENV); + EMO_OPTIONS::instance ()->source_threads_ + TAO_ENV_ARG_PARAMETER); else return prealloc_source_eval_task_; } TAO_Notify_Worker_Task* -TAO_Notify_Default_EMO_Factory::create_lookup_task (CORBA::Environment &ACE_TRY_ENV) +TAO_Notify_Default_EMO_Factory::create_lookup_task (TAO_ENV_SINGLE_ARG_DECL) { return create_task (EMO_OPTIONS::instance ()->mt_lookup_, - EMO_OPTIONS::instance ()->lookup_threads_, ACE_TRY_ENV); + EMO_OPTIONS::instance ()->lookup_threads_ TAO_ENV_ARG_PARAMETER); } TAO_Notify_Worker_Task* -TAO_Notify_Default_EMO_Factory::create_listener_eval_task (CORBA::Environment &ACE_TRY_ENV) +TAO_Notify_Default_EMO_Factory::create_listener_eval_task (TAO_ENV_SINGLE_ARG_DECL) { if (EMO_OPTIONS::instance ()->alloc_task_per_proxy_ == 1) return create_task (EMO_OPTIONS::instance ()->mt_listener_eval_, - EMO_OPTIONS::instance ()->listener_threads_, - ACE_TRY_ENV); + EMO_OPTIONS::instance ()->listener_threads_ + TAO_ENV_ARG_PARAMETER); else return prealloc_listener_eval_task_; } TAO_Notify_Worker_Task* -TAO_Notify_Default_EMO_Factory::create_dispatching_task (CORBA::Environment &ACE_TRY_ENV) +TAO_Notify_Default_EMO_Factory::create_dispatching_task (TAO_ENV_SINGLE_ARG_DECL) { if (EMO_OPTIONS::instance ()->alloc_task_per_proxy_ == 1) return create_task (EMO_OPTIONS::instance ()->mt_dispatching_, - EMO_OPTIONS::instance ()->dispatching_threads_, - ACE_TRY_ENV); + EMO_OPTIONS::instance ()->dispatching_threads_ + TAO_ENV_ARG_PARAMETER); else return prealloc_dispatching_task_; } TAO_Notify_Worker_Task* -TAO_Notify_Default_EMO_Factory::create_updates_task (CORBA::Environment &ACE_TRY_ENV) +TAO_Notify_Default_EMO_Factory::create_updates_task (TAO_ENV_SINGLE_ARG_DECL) { - return create_task (EMO_OPTIONS::instance ()->asynch_updates_, ASYNCH_UPDATES_THREADS, ACE_TRY_ENV); + return create_task (EMO_OPTIONS::instance ()->asynch_updates_, ASYNCH_UPDATES_THREADS TAO_ENV_ARG_PARAMETER); } void |