|
version 1.78, 2003/10/14 22:03:26
|
version 1.79, 2003/10/15 13:59:35
|
|
|
|
| | |
| void MessageQueueService::force_shutdown(Boolean destroy_flag) | void MessageQueueService::force_shutdown(Boolean destroy_flag) |
| { | { |
| |
return; |
| | |
| #ifdef MESSAGEQUEUESERVICE_DEBUG | #ifdef MESSAGEQUEUESERVICE_DEBUG |
| //l10n | //l10n |
|
|
|
| { | { |
| | |
| MessageQueueService *service = static_cast<MessageQueueService *>(req->op->_service_ptr); | MessageQueueService *service = static_cast<MessageQueueService *>(req->op->_service_ptr); |
| |
PEGASUS_STD(cout) << service->getQueueName() << " Received AsyncIoctl::IO_CLOSE " << PEGASUS_STD(endl); |
| |
|
| | |
| // respond to this message. this is fire and forget, so we don't need to delete anything. | // respond to this message. this is fire and forget, so we don't need to delete anything. |
| // this takes care of two problems that were being found | // this takes care of two problems that were being found |
|
|
|
| | |
| void MessageQueueService::handle_CimServiceStart(CimServiceStart *req) | void MessageQueueService::handle_CimServiceStart(CimServiceStart *req) |
| { | { |
| |
|
| |
PEGASUS_STD(cout) << getQueueName() << "received START" << PEGASUS_STD(endl); |
| |
|
| // clear the stoped bit and update | // clear the stoped bit and update |
| _capabilities &= (~(module_capabilities::stopped)); | _capabilities &= (~(module_capabilities::stopped)); |
| _make_response(req, async_results::OK); | _make_response(req, async_results::OK); |
|
|
|
| } | } |
| void MessageQueueService::handle_CimServiceStop(CimServiceStop *req) | void MessageQueueService::handle_CimServiceStop(CimServiceStop *req) |
| { | { |
| |
PEGASUS_STD(cout) << getQueueName() << "received STOP" << PEGASUS_STD(endl); |
| // set the stopeed bit and update | // set the stopeed bit and update |
| _capabilities |= module_capabilities::stopped; | _capabilities |= module_capabilities::stopped; |
| _make_response(req, async_results::CIM_STOPPED); | _make_response(req, async_results::CIM_STOPPED); |
Return to
MessageQueueService.cpp
CVS log
Up to [Pegasus] / pegasus / src / Pegasus / Common