diff options
Diffstat (limited to 'TAO/orbsvcs/orbsvcs/Notify/ThreadPool_Task.cpp')
| -rw-r--r-- | TAO/orbsvcs/orbsvcs/Notify/ThreadPool_Task.cpp | 40 |
1 files changed, 20 insertions, 20 deletions
diff --git a/TAO/orbsvcs/orbsvcs/Notify/ThreadPool_Task.cpp b/TAO/orbsvcs/orbsvcs/Notify/ThreadPool_Task.cpp index b2393adc7e7..726ccb47499 100644 --- a/TAO/orbsvcs/orbsvcs/Notify/ThreadPool_Task.cpp +++ b/TAO/orbsvcs/orbsvcs/Notify/ThreadPool_Task.cpp @@ -31,22 +31,22 @@ TAO_NS_ThreadPool_Task::init (NotifyExt::ThreadPoolParams* tp_params ACE_ENV_ARG // Become an active object. if (this->ACE_Task <ACE_SYNCH>::activate (flags, - tp_params->static_threads, - 0, - tp_params->default_priority) == -1) + tp_params->static_threads, + 0, + tp_params->default_priority) == -1) { if (TAO_debug_level > 0) - { - if (ACE_OS::last_error () == EPERM) - ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("Insufficient privilege.\n"))); - else - ACE_DEBUG ((LM_ERROR, - ACE_TEXT ("(%t) task activation at priority %d failed\n") - ACE_TEXT ("exiting!\n%a"), - tp_params->default_priority)); - } - - ACE_THROW (CORBA::BAD_PARAM ()); + { + if (ACE_OS::last_error () == EPERM) + ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("Insufficient privilege.\n"))); + else + ACE_DEBUG ((LM_ERROR, + ACE_TEXT ("(%t) task activation at priority %d failed\n") + ACE_TEXT ("exiting!\n%a"), + tp_params->default_priority)); + } + + ACE_THROW (CORBA::BAD_PARAM ()); } } @@ -54,13 +54,13 @@ void TAO_NS_ThreadPool_Task::exec (TAO_NS_Method_Request& method_request) { /// Use Buffering Strategy - + TAO_NS_Method_Request* request_copy = method_request.copy (); - + this->activation_queue_.enqueue (request_copy); } -int +int TAO_NS_ThreadPool_Task::svc (void) { for (;;) @@ -71,9 +71,9 @@ TAO_NS_ThreadPool_Task::svc (void) if (0 == mo_p) { - if (TAO_debug_level > 0) - ACE_DEBUG ((LM_DEBUG, - ACE_LIB_TEXT ("(%t) activation queue shut down\n"))); + if (TAO_debug_level > 0) + ACE_DEBUG ((LM_DEBUG, + ACE_LIB_TEXT ("(%t) activation queue shut down\n"))); break; } auto_ptr<ACE_Method_Request> mo (mo_p); |