|
version 1.25.2.3, 2006/04/21 17:33:35
|
version 1.25.2.4, 2006/05/19 17:31:41
|
|
|
|
| { | { |
| public: | public: |
| OutstandingRequestEntry( | OutstandingRequestEntry( |
| String messageId_, |
String originalMessageId_, |
| CIMRequestMessage* requestMessage_, | CIMRequestMessage* requestMessage_, |
| CIMResponseMessage*& responseMessage_, | CIMResponseMessage*& responseMessage_, |
| Semaphore* responseReady_) | Semaphore* responseReady_) |
| : messageId(messageId_), |
: originalMessageId(originalMessageId_), |
| requestMessage(requestMessage_), | requestMessage(requestMessage_), |
| responseMessage(responseMessage_), | responseMessage(responseMessage_), |
| responseReady(responseReady_) | responseReady(responseReady_) |
| { | { |
| } | } |
| | |
| String messageId; |
/** |
| |
A unique value is substituted as the request messageId attribute to |
| |
allow responses to be definitively correllated with requests. |
| |
The original messageId value is stored here to avoid a race condition |
| |
between the processing of a response chunk and the resetting of the |
| |
original messageId in the request message. |
| |
*/ |
| |
String originalMessageId; |
| CIMRequestMessage* requestMessage; | CIMRequestMessage* requestMessage; |
| CIMResponseMessage*& responseMessage; | CIMResponseMessage*& responseMessage; |
| Semaphore* responseReady; | Semaphore* responseReady; |
|
|
|
| i != 0; i++) | i != 0; i++) |
| { | { |
| PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL2, | PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL2, |
| String("Completing messageId \"") + i.value()->messageId + |
String("Completing messageId \"") + i.key() + |
| "\" with a null response."); | "\" with a null response."); |
| i.value()->responseMessage = response; | i.value()->responseMessage = response; |
| i.value()->responseReady->signal(); | i.value()->responseReady->signal(); |
|
|
|
| // | // |
| Semaphore waitSemaphore(0); | Semaphore waitSemaphore(0); |
| OutstandingRequestEntry outstandingRequestEntry( | OutstandingRequestEntry outstandingRequestEntry( |
| uniqueMessageId, request, response, &waitSemaphore); |
originalMessageId, request, response, &waitSemaphore); |
| | |
| // | // |
| // Lock the Provider Agent Container while initializing the | // Lock the Provider Agent Container while initializing the |
|
|
|
| | |
| // Put the original message ID into the response | // Put the original message ID into the response |
| response->messageId = | response->messageId = |
| _outstandingRequestEntry->requestMessage->messageId; |
_outstandingRequestEntry->originalMessageId; |
| | |
| // Call the response chunk callback to process the chunk | // Call the response chunk callback to process the chunk |
| _responseChunkCallback( | _responseChunkCallback( |
Return to
OOPProviderManagerRouter.cpp
CVS log
Up to [Pegasus] / pegasus / src / Pegasus / ProviderManager2 / Attic