diff options
Diffstat (limited to 'TAO/orbsvcs/orbsvcs/Event/RT_Task.cpp')
-rw-r--r-- | TAO/orbsvcs/orbsvcs/Event/RT_Task.cpp | 9 |
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" |