|
version 1.16, 2002/02/12 13:15:22
|
version 1.17, 2002/02/12 23:28:58
|
|
|
|
| } | } |
| } | } |
| | |
| |
|
| |
Boolean MessageQueueService::_enqueueResponse( |
| |
Message* request, |
| |
Message* response) |
| |
{ |
| |
if(request->_async != 0 ) |
| |
{ |
| |
Uint32 mask = request->_async->getMask(); |
| |
if ( mask & message_mask::ha_async) |
| |
{ |
| |
if ( mask & message_mask::ha_request) |
| |
{ |
| |
AsyncOpNode *op = (static_cast<AsyncRequest *>(request->_async)->op); |
| |
|
| |
AsyncLegacyOperationResult *async_result = |
| |
new AsyncLegacyOperationResult( |
| |
(static_cast<AsyncRequest *>(request->_async))->getKey(), |
| |
(static_cast<AsyncRequest *>(request->_async))->getRouting(), |
| |
op, |
| |
response); |
| |
_completeAsyncResponse(static_cast<AsyncRequest *>(request->_async), |
| |
async_result, |
| |
ASYNC_OPSTATE_COMPLETE, |
| |
0); |
| |
return true; |
| |
} |
| |
} |
| |
} |
| |
return false; |
| |
} |
| |
|
| void MessageQueueService::_make_response(AsyncRequest *req, Uint32 code) | void MessageQueueService::_make_response(AsyncRequest *req, Uint32 code) |
| { | { |
| AsyncReply *reply = | AsyncReply *reply = |
Return to
MessageQueueService.cpp
CVS log
Up to [Pegasus] / pegasus / src / Pegasus / Common