|
version 1.12.14.1, 2006/07/27 23:12:05
|
version 1.16, 2007/03/16 17:16:55
|
|
|
|
| // | // |
| //============================================================================== | //============================================================================== |
| // | // |
| // |
|
| // Author: Dong Xiang, EMC Corporation (xiang_dong@emc.com) |
|
| // |
|
| // Modified By: Seema Gupta (gseema@in.ibm.com) for PEP135 |
|
| // |
|
| //%///////////////////////////////////////////////////////////////////////////// | //%///////////////////////////////////////////////////////////////////////////// |
| | |
| #include "CIMListenerIndicationDispatcher.h" | #include "CIMListenerIndicationDispatcher.h" |
|
|
|
| ContentLanguageList contentLangs) | ContentLanguageList contentLangs) |
| { | { |
| // go thru all consumers and broadcast the result; should be run in seperate thread | // go thru all consumers and broadcast the result; should be run in seperate thread |
| Iterator* it = _consumers->iterator(); |
AutoPtr<Iterator> it( _consumers->iterator() ); |
| |
|
| while(it->hasNext()==true) | while(it->hasNext()==true) |
| { | { |
| CIMIndicationConsumer* consumer = static_cast<CIMIndicationConsumer*>(it->next()); | CIMIndicationConsumer* consumer = static_cast<CIMIndicationConsumer*>(it->next()); |
|
|
|
| | |
| if (rtn != PEGASUS_THREAD_OK) | if (rtn != PEGASUS_THREAD_OK) |
| { | { |
| Logger::put(Logger::STANDARD_LOG, System::CIMSERVER, Logger::TRACE, |
Logger::put(Logger::STANDARD_LOG, System::CIMLISTENER, Logger::TRACE, |
| "Not enough threads to allocate a worker to deliver the event. "); | "Not enough threads to allocate a worker to deliver the event. "); |
| | |
| Tracer::trace(TRC_SERVER, Tracer::LEVEL2, |
PEG_TRACE_CSTRING(TRC_SERVER, Tracer::LEVEL2, |
| "Could not allocate thread to deliver event. Instead using current thread."); | "Could not allocate thread to deliver event. Instead using current thread."); |
| delete event; | delete event; |
| throw Exception(MessageLoaderParms("Listener.CIMListenerIndicationDispatcher.CANNOT_ALLOCATE_THREAD", | throw Exception(MessageLoaderParms("Listener.CIMListenerIndicationDispatcher.CANNOT_ALLOCATE_THREAD", |
Return to
CIMListenerIndicationDispatcher.cpp
CVS log
Up to [Pegasus] / pegasus / src / Pegasus / Listener