|
version 1.2, 2002/01/18 19:27:48
|
version 1.3, 2002/01/19 01:53:22
|
|
|
|
| Uint32 queueID, | Uint32 queueID, |
| Uint32 capabilities, | Uint32 capabilities, |
| Uint32 mask) | Uint32 mask) |
| : Base(name, false, queueID), |
: Base(name, true, queueID), |
| _capabilities(capabilities), | _capabilities(capabilities), |
| _mask(mask), | _mask(mask), |
| _die(0) | _die(0) |
|
|
|
| { | { |
| if((static_cast<AsyncReply *>(reply))->result == async_results::OK) | if((static_cast<AsyncReply *>(reply))->result == async_results::OK) |
| registered = true; | registered = true; |
| cout << " service registered " << _queueId << endl; |
|
| | |
| } | } |
| } | } |
|
|
|
| Boolean MessageQueueService::deregister_service(void) | Boolean MessageQueueService::deregister_service(void) |
| { | { |
| | |
| |
// _meta_dispatcher->deregister_module(_queueId); |
| |
// return true; |
| |
|
| |
|
| AsyncOpNode *op = _meta_dispatcher->get_cached_op(); | AsyncOpNode *op = _meta_dispatcher->get_cached_op(); |
| op->_state |= ASYNC_OPSTATE_UNKNOWN; | op->_state |= ASYNC_OPSTATE_UNKNOWN; |
| op->_flags |= ASYNC_OPFLAGS_SINGLE | ASYNC_OPFLAGS_NORMAL; | op->_flags |= ASYNC_OPFLAGS_SINGLE | ASYNC_OPFLAGS_NORMAL; |
Return to
MessageQueueService.cpp
CVS log
Up to [Pegasus] / pegasus / src / Pegasus / Common