|
version 1.12, 2002/02/05 04:30:33
|
version 1.13, 2002/02/06 15:15:35
|
|
|
|
| | |
| service->_handle_incoming_operation(operation, myself, service); | service->_handle_incoming_operation(operation, myself, service); |
| } | } |
| |
|
| } | } |
| | |
| myself->exit_self( (PEGASUS_THREAD_RETURN) 1 ); | myself->exit_self( (PEGASUS_THREAD_RETURN) 1 ); |
|
|
|
| else if (type == async_messages::CIMSERVICE_STOP) | else if (type == async_messages::CIMSERVICE_STOP) |
| handle_CimServiceStop(static_cast<CimServiceStop *>(req)); | handle_CimServiceStop(static_cast<CimServiceStop *>(req)); |
| else if (type == async_messages::CIMSERVICE_PAUSE) | else if (type == async_messages::CIMSERVICE_PAUSE) |
| |
{ |
| handle_CimServicePause(static_cast<CimServicePause *>(req)); | handle_CimServicePause(static_cast<CimServicePause *>(req)); |
| |
} |
| |
|
| else if (type == async_messages::CIMSERVICE_RESUME) | else if (type == async_messages::CIMSERVICE_RESUME) |
| handle_CimServiceResume(static_cast<CimServiceResume *>(req)); | handle_CimServiceResume(static_cast<CimServiceResume *>(req)); |
| else if ( type == async_messages::ASYNC_OP_START) | else if ( type == async_messages::ASYNC_OP_START) |
|
|
|
| void MessageQueueService::handle_CimServiceStart(CimServiceStart *req) | void MessageQueueService::handle_CimServiceStart(CimServiceStart *req) |
| { | { |
| // 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); |
| // now tell the meta dispatcher we are stopped | // now tell the meta dispatcher we are stopped |
| update_service(_capabilities, _mask); | update_service(_capabilities, _mask); |
|
|
|
| void MessageQueueService::handle_CimServicePause(CimServicePause *req) | void MessageQueueService::handle_CimServicePause(CimServicePause *req) |
| { | { |
| // set the paused bit and update | // set the paused bit and update |
| _capabilities |= module_capabilities::stopped; |
_capabilities |= module_capabilities::paused; |
| update_service(_capabilities, _mask); | update_service(_capabilities, _mask); |
| _make_response(req, async_results::CIM_PAUSED); | _make_response(req, async_results::CIM_PAUSED); |
| // now tell the meta dispatcher we are stopped | // now tell the meta dispatcher we are stopped |
| |
|
| cout << " service paused " << endl; |
|
| |
|
| } | } |
| void MessageQueueService::handle_CimServiceResume(CimServiceResume *req) | void MessageQueueService::handle_CimServiceResume(CimServiceResume *req) |
| { | { |
| // clear the paused bit and update | // clear the paused bit and update |
| _capabilities &= ~(module_capabilities::paused); |
_capabilities &= (~(module_capabilities::paused)); |
| update_service(_capabilities, _mask); | update_service(_capabilities, _mask); |
| _make_response(req, async_results::OK); | _make_response(req, async_results::OK); |
| // now tell the meta dispatcher we are stopped | // now tell the meta dispatcher we are stopped |
| |
|
| |
|
| cout << " service resumed " << endl; |
|
| } | } |
| | |
| void MessageQueueService::handle_AsyncOperationStart(AsyncOperationStart *req) | void MessageQueueService::handle_AsyncOperationStart(AsyncOperationStart *req) |
Return to
MessageQueueService.cpp
CVS log
Up to [Pegasus] / pegasus / src / Pegasus / Common