|
version 1.20, 2002/03/06 21:25:05
|
version 1.21, 2002/03/07 01:17:56
|
|
|
|
| MessageQueue *, | MessageQueue *, |
| void *); | void *); |
| AsyncOpNode *_callback_node; | AsyncOpNode *_callback_node; |
| MessageQueue *_callback_queue; |
MessageQueue *_callback_response_q; |
| void *_callback_ptr; | void *_callback_ptr; |
| |
MessageQueue *_callback_q; |
| |
|
| |
|
| | |
| friend class cimom; | friend class cimom; |
| friend class MessageQueueService; | friend class MessageQueueService; |
|
|
|
| { | { |
| _mut.lock(pegasus_thread_self()); | _mut.lock(pegasus_thread_self()); |
| gettimeofday(&_updated, NULL); | gettimeofday(&_updated, NULL); |
| // if( false == _request.exists(reinterpret_cast<void *>(const_cast<Message *>(request))) ) |
if( false == _request.exists(reinterpret_cast<void *>(const_cast<Message *>(request))) ) |
| _request.insert_last( const_cast<Message *>(request) ) ; | _request.insert_last( const_cast<Message *>(request) ) ; |
| | |
| // _request = const_cast<Message *>(request); | // _request = const_cast<Message *>(request); |
|
|
|
| { | { |
| _mut.lock(pegasus_thread_self()); | _mut.lock(pegasus_thread_self()); |
| gettimeofday(&_updated, NULL); | gettimeofday(&_updated, NULL); |
| // if (false == _response.exists(reinterpret_cast<void *>(const_cast<Message *>(response)))) |
if (false == _response.exists(reinterpret_cast<void *>(const_cast<Message *>(response)))) |
| _response.insert_last( const_cast<Message *>(response) ); | _response.insert_last( const_cast<Message *>(response) ); |
| | |
| // _response = const_cast<Message *>(response); | // _response = const_cast<Message *>(response); |
Return to
AsyncOpNode.h
CVS log
Up to [Pegasus] / pegasus / src / Pegasus / Common