|
version 1.13, 2005/05/16 20:00:49
|
version 1.14, 2005/06/24 19:34:27
|
|
|
|
| | |
| PEG_TRACE_STRING(TRC_BINARY_MSG_HANDLER, Tracer::LEVEL4, | PEG_TRACE_STRING(TRC_BINARY_MSG_HANDLER, Tracer::LEVEL4, |
| "Allocating pooled thread to handle binary message."); | "Allocating pooled thread to handle binary message."); |
| _thread_pool->allocate_and_awaken( |
if (_thread_pool->allocate_and_awaken( |
| (void *)this, BinaryMessageHandler::handle_binary_message); |
(void *)this, BinaryMessageHandler::handle_binary_message)!=PEGASUS_THREAD_OK) |
| |
{ |
| |
Logger::put(Logger::STANDARD_LOG, System::CIMSERVER, Logger::TRACE, |
| |
"Not enough threads to handle binary message."); |
| |
|
| |
Tracer::trace(TRC_BINARY_MSG_HANDLER, Tracer::LEVEL2, |
| |
"Could not allocate thread for %s. " \ |
| |
"Queue has %d messages waiting. ", |
| |
getQueueName(), |
| |
_msg_q.count()); |
| |
} |
| } | } |
| else if(request->getType() == async_messages::CIMSERVICE_STOP) | else if(request->getType() == async_messages::CIMSERVICE_STOP) |
| { | { |
Return to
BinaryMessageHandler.cpp
CVS log
Up to [Pegasus] / pegasus / src / Pegasus / Server / Attic