|
version 1.8, 2002/02/18 12:31:29
|
version 1.9, 2002/02/25 23:57:07
|
|
|
|
| Message::getNextKey(), routing, 0, | Message::getNextKey(), routing, 0, |
| operation, | operation, |
| destination, response, blocking), | destination, response, blocking), |
| act(action) |
_act(action) |
| { | { |
| | |
| } | } |
| | |
| | |
| |
inline Message * AsyncOperationStart::get_action(void) |
| |
{ |
| |
Message *ret = _act; |
| |
_act = 0; |
| |
ret->put_async(0); |
| |
return ret; |
| |
|
| |
} |
| |
|
| |
|
| AsyncOperationResult::AsyncOperationResult(Uint32 key, | AsyncOperationResult::AsyncOperationResult(Uint32 key, |
| Uint32 routing, | Uint32 routing, |
| AsyncOpNode *operation, | AsyncOpNode *operation, |
|
|
|
| : AsyncRequest(async_messages::ASYNC_LEGACY_OP_START, | : AsyncRequest(async_messages::ASYNC_LEGACY_OP_START, |
| Message::getNextKey(), routing, 0, | Message::getNextKey(), routing, 0, |
| operation, destination, CIMOM_Q_ID, false), | operation, destination, CIMOM_Q_ID, false), |
| act(action) , legacy_destination(action_destination) |
_act(action) , _legacy_destination(action_destination) |
| { | { |
| act->_async = this; |
_act->put_async(this); |
| } | } |
| | |
| | |
| |
Message * AsyncLegacyOperationStart::get_action(void) |
| |
{ |
| |
Message *ret = _act; |
| |
_act = 0; |
| |
// ret->put_async(0); |
| |
return ret; |
| |
|
| |
} |
| |
|
| AsyncLegacyOperationResult::AsyncLegacyOperationResult(Uint32 key, | AsyncLegacyOperationResult::AsyncLegacyOperationResult(Uint32 key, |
| Uint32 routing, | Uint32 routing, |
| AsyncOpNode *operation, | AsyncOpNode *operation, |
|
|
|
| : AsyncReply(async_messages::ASYNC_LEGACY_OP_RESULT, | : AsyncReply(async_messages::ASYNC_LEGACY_OP_RESULT, |
| key, routing, 0, operation, | key, routing, 0, operation, |
| 0, CIMOM_Q_ID, false), | 0, CIMOM_Q_ID, false), |
| res(result) |
_res(result) |
| { | { |
| res->_async = this; |
_res->put_async(this); |
| } | } |
| | |
| |
Message *AsyncLegacyOperationResult::get_result(void) |
| |
{ |
| |
Message *ret = _res; |
| |
_res = 0; |
| |
// ret->put_async(0); |
| |
return ret; |
| |
} |
| | |
| FindServiceQueue::FindServiceQueue(Uint32 routing, | FindServiceQueue::FindServiceQueue(Uint32 routing, |
| AsyncOpNode *operation, | AsyncOpNode *operation, |
|
|
|
| } | } |
| | |
| | |
| |
|
| FindServiceQueueResult::FindServiceQueueResult(Uint32 key, | FindServiceQueueResult::FindServiceQueueResult(Uint32 key, |
| Uint32 routing, | Uint32 routing, |
| AsyncOpNode *operation, | AsyncOpNode *operation, |
Return to
CimomMessage.cpp
CVS log
Up to [Pegasus] / pegasus / src / Pegasus / Common