|
version 1.133, 2007/07/24 20:02:06
|
version 1.134, 2007/11/30 18:53:43
|
|
|
|
| } | } |
| } | } |
| | |
| if (request->_async != 0) |
AsyncRequest* asyncRequest = |
| |
static_cast<AsyncRequest*>(request->get_async()); |
| |
|
| |
if (asyncRequest != 0) |
| { | { |
| Uint32 mask = request->_async->getMask(); |
PEGASUS_ASSERT(asyncRequest->getMask() & |
| PEGASUS_ASSERT(mask & |
|
| (MessageMask::ha_async | MessageMask::ha_request)); | (MessageMask::ha_async | MessageMask::ha_request)); |
| | |
| AsyncRequest *async = static_cast<AsyncRequest *>(request->_async); |
AsyncOpNode* op = asyncRequest->op; |
| AsyncOpNode *op = async->op; |
|
| request->_async = 0; |
|
| // the legacy request is going to be deleted by its handler | // the legacy request is going to be deleted by its handler |
| // remove it from the op node | // remove it from the op node |
| | |
| static_cast<AsyncLegacyOperationStart *>(async)->get_action(); |
static_cast<AsyncLegacyOperationStart *>(asyncRequest)->get_action(); |
| | |
| AsyncLegacyOperationResult *async_result = | AsyncLegacyOperationResult *async_result = |
| new AsyncLegacyOperationResult( | new AsyncLegacyOperationResult( |
| op, | op, |
| response); | response); |
| _completeAsyncResponse( | _completeAsyncResponse( |
| async, |
asyncRequest, |
| async_result, | async_result, |
| ASYNC_OPSTATE_COMPLETE, | ASYNC_OPSTATE_COMPLETE, |
| 0); | 0); |
Return to
MessageQueueService.cpp
CVS log
Up to [Pegasus] / pegasus / src / Pegasus / Common