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); |