|
version 1.80, 2003/10/16 23:38:39
|
version 1.81, 2003/10/17 18:08:01
|
|
|
|
| { | { |
| | |
| 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); |
|
| | |
| |
#ifdef MESSAGEQUEUESERVICE_DEBUG |
| |
PEGASUS_STD(cout) << service->getQueueName() << " Received AsyncIoctl::IO_CLOSE " << PEGASUS_STD(endl); |
| |
#endif |
| | |
| // 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) |
| { | { |
| | |
| |
#ifdef MESSAGEQUEUESERVICE_DEBUG |
| PEGASUS_STD(cout) << getQueueName() << "received START" << PEGASUS_STD(endl); | PEGASUS_STD(cout) << getQueueName() << "received START" << PEGASUS_STD(endl); |
| |
#endif |
| | |
| // clear the stoped bit and update | // clear the stoped bit and update |
| _capabilities &= (~(module_capabilities::stopped)); | _capabilities &= (~(module_capabilities::stopped)); |
|
|
|
| } | } |
| void MessageQueueService::handle_CimServiceStop(CimServiceStop *req) | void MessageQueueService::handle_CimServiceStop(CimServiceStop *req) |
| { | { |
| |
#ifdef MESSAGEQUEUESERVICE_DEBUG |
| PEGASUS_STD(cout) << getQueueName() << "received STOP" << PEGASUS_STD(endl); | PEGASUS_STD(cout) << getQueueName() << "received STOP" << PEGASUS_STD(endl); |
| |
#endif |
| // 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