|
version 1.7, 2005/06/24 19:34:24
|
version 1.8, 2005/07/25 02:11:01
|
|
|
|
| "Not enough threads for consumer worker routine.")); | "Not enough threads for consumer worker routine.")); |
| } | } |
| | |
| |
//wait until the listening thread has started. Otherwise, there is a miniscule chance that the first event will be enqueued |
| |
//before the consumer is waiting for it and the first indication after loading the consumer will be lost |
| |
consumer->waitForEventThread(); |
| |
|
| //load any outstanding requests | //load any outstanding requests |
| Array<CIMInstance> outstandingIndications = _deserializeOutstandingIndications(consumerName); | Array<CIMInstance> outstandingIndications = _deserializeOutstandingIndications(consumerName); |
| if (outstandingIndications.size()) | if (outstandingIndications.size()) |
|
|
|
| | |
| PEGASUS_STD(cout) << "Worker thread started for consumer : " << name << endl; | PEGASUS_STD(cout) << "Worker thread started for consumer : " << name << endl; |
| | |
| |
myself->_listeningSemaphore->signal(); |
| |
|
| while (true) | while (true) |
| { | { |
| try | try |
Return to
ConsumerManager.cpp
CVS log
Up to [Pegasus] / pegasus / src / Pegasus / DynListener