summaryrefslogtreecommitdiff
path: root/TAO/orbsvcs/orbsvcs/Event/RT_Task.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'TAO/orbsvcs/orbsvcs/Event/RT_Task.cpp')
-rw-r--r--TAO/orbsvcs/orbsvcs/Event/RT_Task.cpp9
1 files changed, 3 insertions, 6 deletions
diff --git a/TAO/orbsvcs/orbsvcs/Event/RT_Task.cpp b/TAO/orbsvcs/orbsvcs/Event/RT_Task.cpp
index 066a923782c..84a568a6497 100644
--- a/TAO/orbsvcs/orbsvcs/Event/RT_Task.cpp
+++ b/TAO/orbsvcs/orbsvcs/Event/RT_Task.cpp
@@ -121,15 +121,14 @@ ACE_RT_Task::svc (void)
thread_priority,
subpriority,
preemption_priority, ACE_TRY_ENV);
- ACE_TRY_CHECK;
#else
ACE_Scheduler_Factory::server ()->priority
(this->rt_info_,
thread_priority,
subpriority,
preemption_priority, ACE_TRY_ENV);
- ACE_TRY_CHECK;
#endif
+ ACE_TRY_CHECK;
if (ACE_OS::thr_setprio (thread_priority) == -1)
{
#if defined (ACE_HAS_STHREADS)
@@ -263,13 +262,12 @@ ACE_RT_Task::open_task (const char* name)
#if 1
rt_info_ =
this->scheduler_->create (tempname, ACE_TRY_ENV);
- ACE_TRY_CHECK;
#else
rt_info_ =
ACE_Scheduler_Factory::server()->create (tempname,
ACE_TRY_ENV);
- ACE_TRY_CHECK;
#endif
+ ACE_TRY_CHECK;
// @@ TODO: We do no initialization of the new rt_info, the
// caller does, this is (IMnsHO) very error prone.
}
@@ -326,15 +324,14 @@ ACE_RT_Task::synch_threads (size_t threads)
thread_priority,
subpriority,
preemption_priority, ACE_TRY_ENV);
- ACE_TRY_CHECK;
#else
ACE_Scheduler_Factory::server ()->priority
(rt_info_,
thread_priority,
subpriority,
preemption_priority, ACE_TRY_ENV);
- ACE_TRY_CHECK;
#endif
+ ACE_TRY_CHECK;
}
ACE_DEBUG ((LM_DEBUG, "EC (%t) spawning %d threads at os thread"