version 1.136, 2008/05/12 09:14:51
|
version 1.138, 2008/06/19 17:57:01
|
|
|
if (rtn != PEGASUS_THREAD_OK ) | if (rtn != PEGASUS_THREAD_OK ) |
{ | { |
service->_threads--; | service->_threads--; |
// TBD-7646 |
PEG_TRACE((TRC_MESSAGEQUEUESERVICE, Tracer::LEVEL1, |
PEG_TRACE((TRC_MESSAGEQUEUESERVICE, Tracer::LEVEL2, |
|
"Could not allocate thread for %s. Queue has %d " | "Could not allocate thread for %s. Queue has %d " |
"messages waiting and %d threads servicing." | "messages waiting and %d threads servicing." |
"Skipping the service for right now. ", | "Skipping the service for right now. ", |
|
|
max_threads_per_svc_queue = MAX_THREADS_PER_SVC_QUEUE_LIMIT; | max_threads_per_svc_queue = MAX_THREADS_PER_SVC_QUEUE_LIMIT; |
} | } |
| |
PEG_TRACE((TRC_MESSAGEQUEUESERVICE, Tracer::LEVEL2, |
PEG_TRACE((TRC_MESSAGEQUEUESERVICE, Tracer::LEVEL3, |
"max_threads_per_svc_queue set to %u.", max_threads_per_svc_queue)); | "max_threads_per_svc_queue set to %u.", max_threads_per_svc_queue)); |
| |
AutoMutex autoMut(_meta_dispatcher_mutex); | AutoMutex autoMut(_meta_dispatcher_mutex); |
|
|
} | } |
catch (const Exception& e) | catch (const Exception& e) |
{ | { |
PEG_TRACE_STRING(TRC_DISCARDED_DATA, Tracer::LEVEL2, |
PEG_TRACE_STRING(TRC_DISCARDED_DATA, Tracer::LEVEL1, |
String("Caught exception: \"") + e.getMessage() + | String("Caught exception: \"") + e.getMessage() + |
"\". Exiting _req_proc."); | "\". Exiting _req_proc."); |
} | } |
catch (...) | catch (...) |
{ | { |
PEG_TRACE_CSTRING(TRC_DISCARDED_DATA, Tracer::LEVEL2, |
PEG_TRACE_CSTRING(TRC_DISCARDED_DATA, Tracer::LEVEL1, |
"Caught unrecognized exception. Exiting _req_proc."); | "Caught unrecognized exception. Exiting _req_proc."); |
} | } |
service->_threads--; | service->_threads--; |