version 1.131, 2006/11/10 18:14:58
|
version 1.132, 2007/03/16 17:16:50
|
|
|
"Not enough threads to process this request. " | "Not enough threads to process this request. " |
"Skipping."); | "Skipping."); |
| |
Tracer::trace(TRC_MESSAGEQUEUESERVICE, Tracer::LEVEL2, |
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. ", |
service->getQueueName(), | service->getQueueName(), |
service->_incoming.count(), | service->_incoming.count(), |
service->_threads.get()); |
service->_threads.get())); |
| |
Threads::yield(); | Threads::yield(); |
service = NULL; | service = NULL; |
|
|
max_threads_per_svc_queue = MAX_THREADS_PER_SVC_QUEUE_LIMIT; | max_threads_per_svc_queue = MAX_THREADS_PER_SVC_QUEUE_LIMIT; |
} | } |
| |
Tracer::trace(TRC_MESSAGEQUEUESERVICE, Tracer::LEVEL2, |
PEG_TRACE((TRC_MESSAGEQUEUESERVICE, Tracer::LEVEL2, |
"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 (ListClosed&) | catch (ListClosed&) |
{ | { |
// ATTN: This appears to be a common loop exit path. | // ATTN: This appears to be a common loop exit path. |
//PEG_TRACE_STRING(TRC_DISCARDED_DATA, Tracer::LEVEL2, |
//PEG_TRACE_CSTRING(TRC_DISCARDED_DATA, Tracer::LEVEL2, |
// "Caught ListClosed exception. Exiting _req_proc."); | // "Caught ListClosed exception. Exiting _req_proc."); |
break; | break; |
} | } |
|
|
} | } |
catch (...) | catch (...) |
{ | { |
PEG_TRACE_STRING(TRC_DISCARDED_DATA, Tracer::LEVEL2, |
PEG_TRACE_CSTRING(TRC_DISCARDED_DATA, Tracer::LEVEL2, |
"Caught unrecognized exception. Exiting _req_proc."); | "Caught unrecognized exception. Exiting _req_proc."); |
} | } |
service->_threads--; | service->_threads--; |