|
version 1.1.2.3, 2012/02/15 17:47:07
|
version 1.1.2.4, 2013/06/03 22:35:12
|
|
|
|
| void IndicationRouter::deliverAndWaitForStatus() | void IndicationRouter::deliverAndWaitForStatus() |
| { | { |
| String uniqueMessageId; | String uniqueMessageId; |
| Uint32 timeoutMilliSec = _request->timeoutMilliSec; |
|
| | |
| #ifdef PEGASUS_ENABLE_INDICATION_ORDERING | #ifdef PEGASUS_ENABLE_INDICATION_ORDERING |
| // Wait only if this indication is not coming from OOP provider. | // Wait only if this indication is not coming from OOP provider. |
| |
Uint32 timeoutMilliSec = _request->timeoutMilliSec; |
| |
|
| if (!_request->oopAgentName.size()) | if (!_request->oopAgentName.size()) |
| { | { |
| char messagePtrString[20]; | char messagePtrString[20]; |
|
|
|
| | |
| AutoMutex mtx(_statusMutex); | AutoMutex mtx(_statusMutex); |
| _entry = new DeliveryStatusEntry; | _entry = new DeliveryStatusEntry; |
| Boolean ok = _statusTable.insert(uniqueMessageId, _entry); |
PEGASUS_FCT_EXECUTE_AND_ASSERT( |
| PEGASUS_ASSERT(ok); |
true, |
| |
_statusTable.insert(uniqueMessageId, _entry)); |
| } | } |
| | |
| _deliveryRoutine(_request); | _deliveryRoutine(_request); |
Return to
IndicationRouter.cpp
CVS log
Up to [Pegasus] / pegasus / src / Pegasus / Common