|
version 1.9, 2002/02/04 17:37:56
|
version 1.10, 2002/02/04 21:03:55
|
|
|
|
| | |
| void MessageQueueService::handle_CimServiceStart(CimServiceStart *req) | void MessageQueueService::handle_CimServiceStart(CimServiceStart *req) |
| { | { |
| _make_response(req, async_results::CIM_NAK); |
// clear the stoped bit and update |
| |
_capabilities &= ~(module_capabilities::stopped); |
| |
_make_response(req, async_results::OK); |
| |
// now tell the meta dispatcher we are stopped |
| |
update_service(_capabilities, _mask); |
| |
|
| } | } |
| void MessageQueueService::handle_CimServiceStop(CimServiceStop *req) | void MessageQueueService::handle_CimServiceStop(CimServiceStop *req) |
| { | { |
| _make_response(req, async_results::CIM_NAK); |
// set the stopeed bit and update |
| |
_capabilities |= module_capabilities::stopped; |
| |
_make_response(req, async_results::CIM_STOPPED); |
| |
// now tell the meta dispatcher we are stopped |
| |
update_service(_capabilities, _mask); |
| |
|
| } | } |
| void MessageQueueService::handle_CimServicePause(CimServicePause *req) | void MessageQueueService::handle_CimServicePause(CimServicePause *req) |
| { | { |
| _make_response(req, async_results::CIM_NAK); |
// set the paused bit and update |
| |
_capabilities |= module_capabilities::stopped; |
| |
_make_response(req, async_results::CIM_PAUSED); |
| |
// now tell the meta dispatcher we are stopped |
| |
update_service(_capabilities, _mask); |
| } | } |
| void MessageQueueService::handle_CimServiceResume(CimServiceResume *req) | void MessageQueueService::handle_CimServiceResume(CimServiceResume *req) |
| { | { |
| _make_response(req, async_results::CIM_NAK); |
// clear the paused bit and update |
| |
_capabilities &= ~(module_capabilities::paused); |
| |
_make_response(req, async_results::OK); |
| |
// now tell the meta dispatcher we are stopped |
| |
update_service(_capabilities, _mask); |
| } | } |
| | |
| void MessageQueueService::handle_AsyncOperationStart(AsyncOperationStart *req) | void MessageQueueService::handle_AsyncOperationStart(AsyncOperationStart *req) |
| { | { |
| _make_response(req, async_results::CIM_NAK); | _make_response(req, async_results::CIM_NAK); |
| |
|
| } | } |
| | |
| void MessageQueueService::handle_AsyncOperationResult(AsyncOperationResult *req) | void MessageQueueService::handle_AsyncOperationResult(AsyncOperationResult *req) |
| { | { |
| ; |
|
| } | } |
| | |
| AsyncOpNode *MessageQueueService::get_op(void) | AsyncOpNode *MessageQueueService::get_op(void) |
Return to
MessageQueueService.cpp
CVS log
Up to [Pegasus] / pegasus / src / Pegasus / Common