version 1.16, 2002/06/01 00:56:30
|
version 1.23, 2006/07/14 20:12:46
|
|
|
//%///////////////////////////////////////////////////////////////////////////// |
//%2006//////////////////////////////////////////////////////////////////////// |
// | // |
// Copyright (c) 2000, 2001, 2002 BMC Software, Hewlett-Packard Company, IBM, |
// Copyright (c) 2000, 2001, 2002 BMC Software; Hewlett-Packard Development |
// The Open Group, Tivoli Systems |
// Company, L.P.; IBM Corp.; The Open Group; Tivoli Systems. |
|
// Copyright (c) 2003 BMC Software; Hewlett-Packard Development Company, L.P.; |
|
// IBM Corp.; EMC Corporation, The Open Group. |
|
// Copyright (c) 2004 BMC Software; Hewlett-Packard Development Company, L.P.; |
|
// IBM Corp.; EMC Corporation; VERITAS Software Corporation; The Open Group. |
|
// Copyright (c) 2005 Hewlett-Packard Development Company, L.P.; IBM Corp.; |
|
// EMC Corporation; VERITAS Software Corporation; The Open Group. |
|
// Copyright (c) 2006 Hewlett-Packard Development Company, L.P.; IBM Corp.; |
|
// EMC Corporation; Symantec Corporation; The Open Group. |
// | // |
// Permission is hereby granted, free of charge, to any person obtaining a copy | // Permission is hereby granted, free of charge, to any person obtaining a copy |
// of this software and associated documentation files (the "Software"), to | // of this software and associated documentation files (the "Software"), to |
|
|
const Uint32 async_results::CIM_STOPPED = 0x00000015; | const Uint32 async_results::CIM_STOPPED = 0x00000015; |
| |
| |
|
|
const Uint32 async_messages::HEARTBEAT = DUMMY_MESSAGE; | const Uint32 async_messages::HEARTBEAT = DUMMY_MESSAGE; |
const Uint32 async_messages::REPLY = DUMMY_MESSAGE; | const Uint32 async_messages::REPLY = DUMMY_MESSAGE; |
const Uint32 async_messages::REGISTER_CIM_SERVICE = NUMBER_OF_MESSAGES + 0x00000001; |
const Uint32 async_messages::REGISTER_CIM_SERVICE = ASYNC_REGISTER_CIM_SERVICE; |
const Uint32 async_messages::DEREGISTER_CIM_SERVICE = NUMBER_OF_MESSAGES + 0x00000002; |
const Uint32 async_messages::DEREGISTER_CIM_SERVICE = ASYNC_DEREGISTER_CIM_SERVICE; |
const Uint32 async_messages::UPDATE_CIM_SERVICE = NUMBER_OF_MESSAGES + 0x00000003; |
const Uint32 async_messages::UPDATE_CIM_SERVICE = ASYNC_UPDATE_CIM_SERVICE; |
const Uint32 async_messages::IOCTL = NUMBER_OF_MESSAGES + 0x00000004; |
const Uint32 async_messages::IOCTL = ASYNC_IOCTL; |
const Uint32 async_messages::CIMSERVICE_START = NUMBER_OF_MESSAGES + 0x00000005; |
const Uint32 async_messages::CIMSERVICE_START = ASYNC_CIMSERVICE_START; |
const Uint32 async_messages::CIMSERVICE_STOP = NUMBER_OF_MESSAGES + 0x00000006; |
const Uint32 async_messages::CIMSERVICE_STOP = ASYNC_CIMSERVICE_STOP; |
const Uint32 async_messages::CIMSERVICE_PAUSE = NUMBER_OF_MESSAGES + 0x00000007; |
const Uint32 async_messages::CIMSERVICE_PAUSE = ASYNC_CIMSERVICE_PAUSE; |
const Uint32 async_messages::CIMSERVICE_RESUME = NUMBER_OF_MESSAGES + 0x00000008; |
const Uint32 async_messages::CIMSERVICE_RESUME = ASYNC_CIMSERVICE_RESUME; |
|
|
const Uint32 async_messages::ASYNC_OP_START = NUMBER_OF_MESSAGES + 0x00000009; |
const Uint32 async_messages::ASYNC_OP_START = ASYNC_ASYNC_OP_START; |
const Uint32 async_messages::ASYNC_OP_RESULT = NUMBER_OF_MESSAGES + 0x0000000a; |
const Uint32 async_messages::ASYNC_OP_RESULT = ASYNC_ASYNC_OP_RESULT; |
const Uint32 async_messages::ASYNC_LEGACY_OP_START = NUMBER_OF_MESSAGES + 0x0000000b; |
const Uint32 async_messages::ASYNC_LEGACY_OP_START = ASYNC_ASYNC_LEGACY_OP_START; |
const Uint32 async_messages::ASYNC_LEGACY_OP_RESULT = NUMBER_OF_MESSAGES + 0x0000000c; |
const Uint32 async_messages::ASYNC_LEGACY_OP_RESULT = ASYNC_ASYNC_LEGACY_OP_RESULT; |
|
|
const Uint32 async_messages::FIND_SERVICE_Q = NUMBER_OF_MESSAGES + 0x0000000d; |
const Uint32 async_messages::FIND_SERVICE_Q = ASYNC_FIND_SERVICE_Q; |
const Uint32 async_messages::FIND_SERVICE_Q_RESULT = NUMBER_OF_MESSAGES + 0x0000000e; |
const Uint32 async_messages::FIND_SERVICE_Q_RESULT = ASYNC_FIND_SERVICE_Q_RESULT; |
const Uint32 async_messages::ENUMERATE_SERVICE = NUMBER_OF_MESSAGES + 0x0000000f; |
const Uint32 async_messages::ENUMERATE_SERVICE = ASYNC_ENUMERATE_SERVICE; |
const Uint32 async_messages::ENUMERATE_SERVICE_RESULT = NUMBER_OF_MESSAGES + 0x00000010; |
const Uint32 async_messages::ENUMERATE_SERVICE_RESULT = ASYNC_ENUMERATE_SERVICE_RESULT; |
|
|
const Uint32 async_messages::REGISTERED_MODULE = NUMBER_OF_MESSAGES + 0x00000011; |
const Uint32 async_messages::REGISTERED_MODULE = ASYNC_REGISTERED_MODULE; |
const Uint32 async_messages::DEREGISTERED_MODULE = NUMBER_OF_MESSAGES + 0x00000012; |
const Uint32 async_messages::DEREGISTERED_MODULE = ASYNC_DEREGISTERED_MODULE; |
const Uint32 async_messages::FIND_MODULE_IN_SERVICE = NUMBER_OF_MESSAGES + 0x00000013; |
const Uint32 async_messages::FIND_MODULE_IN_SERVICE = ASYNC_FIND_MODULE_IN_SERVICE; |
const Uint32 async_messages::FIND_MODULE_IN_SERVICE_RESPONSE = NUMBER_OF_MESSAGES + 0x00000014; |
const Uint32 async_messages::FIND_MODULE_IN_SERVICE_RESPONSE = ASYNC_FIND_MODULE_IN_SERVICE_RESPONSE; |
|
const Uint32 async_messages::ASYNC_MODULE_OP_START = ASYNC_ASYNC_MODULE_OP_START; |
const Uint32 async_messages::ASYNC_MODULE_OP_START = NUMBER_OF_MESSAGES + 0x00000015; |
const Uint32 async_messages::ASYNC_MODULE_OP_RESULT = ASYNC_ASYNC_MODULE_OP_RESULT; |
const Uint32 async_messages::ASYNC_MODULE_OP_RESULT = NUMBER_OF_MESSAGES + 0x00000016; |
|
| |
| |
| |
AsyncMessage::AsyncMessage(Uint32 type, | AsyncMessage::AsyncMessage(Uint32 type, |
Uint32 destination, | Uint32 destination, |
Uint32 key, |
|
Uint32 routing, | Uint32 routing, |
Uint32 mask, | Uint32 mask, |
AsyncOpNode *operation) | AsyncOpNode *operation) |
: Message(type, destination, key, routing, mask | message_mask::ha_async), |
: Message(type, destination, routing, mask | message_mask::ha_async), |
op(operation) | op(operation) |
{ | { |
| |
} | } |
| |
AsyncRequest::AsyncRequest(Uint32 type, | AsyncRequest::AsyncRequest(Uint32 type, |
Uint32 key, |
|
Uint32 routing, | Uint32 routing, |
Uint32 mask, | Uint32 mask, |
AsyncOpNode *operation, | AsyncOpNode *operation, |
Uint32 destination, | Uint32 destination, |
Uint32 response, | Uint32 response, |
Boolean blocking) | Boolean blocking) |
: AsyncMessage(type, destination, key, routing, mask | message_mask::ha_request, operation), |
: AsyncMessage(type, destination, routing, mask | message_mask::ha_request, operation), |
resp(response), | resp(response), |
block(blocking) | block(blocking) |
{ | { |
|
|
} | } |
| |
AsyncReply::AsyncReply(Uint32 type, | AsyncReply::AsyncReply(Uint32 type, |
Uint32 key, |
|
Uint32 routing, | Uint32 routing, |
Uint32 mask, | Uint32 mask, |
AsyncOpNode *operation, | AsyncOpNode *operation, |
Uint32 result_code, | Uint32 result_code, |
Uint32 destination, | Uint32 destination, |
Boolean blocking) | Boolean blocking) |
: AsyncMessage(type, destination, key, routing, mask | message_mask::ha_reply, operation), |
: AsyncMessage(type, destination, routing, mask | message_mask::ha_reply, operation), |
result(result_code), | result(result_code), |
block(blocking) | block(blocking) |
{ | { |
|
|
Uint32 service_mask, | Uint32 service_mask, |
Uint32 service_queue) | Uint32 service_queue) |
: AsyncRequest( async_messages::REGISTER_CIM_SERVICE, | : AsyncRequest( async_messages::REGISTER_CIM_SERVICE, |
Message::getNextKey(), |
|
routing, 0, operation, CIMOM_Q_ID, | routing, 0, operation, CIMOM_Q_ID, |
service_queue, blocking), | service_queue, blocking), |
name(service_name), | name(service_name), |
|
|
Boolean blocking, | Boolean blocking, |
Uint32 service_queue) | Uint32 service_queue) |
: AsyncRequest( async_messages::DEREGISTER_CIM_SERVICE, | : AsyncRequest( async_messages::DEREGISTER_CIM_SERVICE, |
Message::getNextKey(), |
|
routing, 0, operation, CIMOM_Q_ID, | routing, 0, operation, CIMOM_Q_ID, |
service_queue, blocking), | service_queue, blocking), |
queue(service_queue) | queue(service_queue) |
|
|
Uint32 service_capabilities, | Uint32 service_capabilities, |
Uint32 service_mask) | Uint32 service_mask) |
: AsyncRequest( async_messages::UPDATE_CIM_SERVICE, | : AsyncRequest( async_messages::UPDATE_CIM_SERVICE, |
Message::getNextKey(), |
|
routing, 0, operation, CIMOM_Q_ID, | routing, 0, operation, CIMOM_Q_ID, |
service_queue, blocking), | service_queue, blocking), |
queue(service_queue), | queue(service_queue), |
|
|
Uint32 service_queue, | Uint32 service_queue, |
String new_module) | String new_module) |
: AsyncRequest( async_messages::REGISTERED_MODULE, | : AsyncRequest( async_messages::REGISTERED_MODULE, |
Message::getNextKey(), |
|
routing, | routing, |
0, | 0, |
operation, | operation, |
|
|
Uint32 service_queue, | Uint32 service_queue, |
String removed_module) | String removed_module) |
: AsyncRequest( async_messages::DEREGISTERED_MODULE, | : AsyncRequest( async_messages::DEREGISTERED_MODULE, |
Message::getNextKey(), |
|
routing, | routing, |
0, | 0, |
operation, | operation, |
|
|
Uint32 response_queue, | Uint32 response_queue, |
String module) | String module) |
: AsyncRequest(async_messages::FIND_MODULE_IN_SERVICE, | : AsyncRequest(async_messages::FIND_MODULE_IN_SERVICE, |
Message::getNextKey(), |
|
routing, | routing, |
0, | 0, |
operation, | operation, |
|
|
} | } |
| |
FindModuleInServiceResponse::FindModuleInServiceResponse(Uint32 routing, | FindModuleInServiceResponse::FindModuleInServiceResponse(Uint32 routing, |
Uint32 key, |
|
AsyncOpNode *operation, | AsyncOpNode *operation, |
Uint32 result_code, | Uint32 result_code, |
Uint32 destination, | Uint32 destination, |
|
|
Uint32 module_service_queue) | Uint32 module_service_queue) |
| |
: AsyncReply(async_messages::FIND_MODULE_IN_SERVICE_RESPONSE, | : AsyncReply(async_messages::FIND_MODULE_IN_SERVICE_RESPONSE, |
key, |
|
routing, | routing, |
0, | 0, |
operation, | operation, |
|
|
Uint32 int_param, | Uint32 int_param, |
void *p_param) | void *p_param) |
: AsyncRequest( async_messages::IOCTL, | : AsyncRequest( async_messages::IOCTL, |
Message::getNextKey(), |
|
routing, 0, operation, | routing, 0, operation, |
destination, response, blocking), | destination, response, blocking), |
ctl(code), | ctl(code), |
|
|
Uint32 response, | Uint32 response, |
Boolean blocking) | Boolean blocking) |
: AsyncRequest(async_messages::CIMSERVICE_START, | : AsyncRequest(async_messages::CIMSERVICE_START, |
Message::getNextKey(), routing, |
routing, |
0, operation, destination, | 0, operation, destination, |
response, blocking) | response, blocking) |
{ | { |
|
|
Uint32 response, | Uint32 response, |
Boolean blocking) | Boolean blocking) |
: AsyncRequest(async_messages::CIMSERVICE_STOP, | : AsyncRequest(async_messages::CIMSERVICE_STOP, |
Message::getNextKey(), routing, |
routing, |
0, operation, destination, | 0, operation, destination, |
response, blocking) | response, blocking) |
{ | { |
|
|
Uint32 response, | Uint32 response, |
Boolean blocking) | Boolean blocking) |
: AsyncRequest(async_messages::CIMSERVICE_PAUSE, | : AsyncRequest(async_messages::CIMSERVICE_PAUSE, |
Message::getNextKey(), routing, |
routing, |
0, operation, destination, | 0, operation, destination, |
response, blocking) | response, blocking) |
{ | { |
|
|
Uint32 response, | Uint32 response, |
Boolean blocking) | Boolean blocking) |
: AsyncRequest(async_messages::CIMSERVICE_RESUME, | : AsyncRequest(async_messages::CIMSERVICE_RESUME, |
Message::getNextKey(), routing, |
routing, |
0, operation, destination, | 0, operation, destination, |
response, blocking) | response, blocking) |
{ | { |
|
|
Boolean blocking, | Boolean blocking, |
Message *action) | Message *action) |
: AsyncRequest(async_messages::ASYNC_OP_START, | : AsyncRequest(async_messages::ASYNC_OP_START, |
Message::getNextKey(), routing, 0, |
routing, 0, |
operation, | operation, |
destination, response, blocking), | destination, response, blocking), |
_act(action) | _act(action) |
|
|
} | } |
| |
| |
AsyncOperationResult::AsyncOperationResult(Uint32 key, |
AsyncOperationResult::AsyncOperationResult(Uint32 routing, |
Uint32 routing, |
|
AsyncOpNode *operation, | AsyncOpNode *operation, |
Uint32 result_code, | Uint32 result_code, |
Uint32 destination, | Uint32 destination, |
Uint32 blocking) | Uint32 blocking) |
: AsyncReply(async_messages::ASYNC_OP_RESULT, | : AsyncReply(async_messages::ASYNC_OP_RESULT, |
key, routing, 0, |
routing, 0, |
operation, result_code, destination, | operation, result_code, destination, |
blocking) | blocking) |
{ | { |
|
|
String target_module, | String target_module, |
Message *action) | Message *action) |
: AsyncRequest(async_messages::ASYNC_MODULE_OP_START, | : AsyncRequest(async_messages::ASYNC_MODULE_OP_START, |
Message::getNextKey(), routing, 0, |
routing, 0, |
operation, | operation, |
destination, response, blocking), | destination, response, blocking), |
_target_module(target_module), | _target_module(target_module), |
|
|
| |
} | } |
| |
AsyncModuleOperationResult::AsyncModuleOperationResult(Uint32 key, |
AsyncModuleOperationResult::AsyncModuleOperationResult(Uint32 routing, |
Uint32 routing, |
|
AsyncOpNode *operation, | AsyncOpNode *operation, |
Uint32 result_code, | Uint32 result_code, |
Uint32 destination, | Uint32 destination, |
|
|
String target_module, | String target_module, |
Message *result) | Message *result) |
: AsyncReply(async_messages::ASYNC_MODULE_OP_RESULT, | : AsyncReply(async_messages::ASYNC_MODULE_OP_RESULT, |
key, routing, 0, |
routing, 0, |
operation, result_code, destination, | operation, result_code, destination, |
blocking), | blocking), |
_target_module(target_module), | _target_module(target_module), |
|
|
Message *action, | Message *action, |
Uint32 action_destination) | Uint32 action_destination) |
: AsyncRequest(async_messages::ASYNC_LEGACY_OP_START, | : AsyncRequest(async_messages::ASYNC_LEGACY_OP_START, |
Message::getNextKey(), routing, 0, |
routing, 0, |
operation, destination, CIMOM_Q_ID, false), | operation, destination, CIMOM_Q_ID, false), |
_act(action) , _legacy_destination(action_destination) | _act(action) , _legacy_destination(action_destination) |
{ | { |
|
|
| |
} | } |
| |
AsyncLegacyOperationResult::AsyncLegacyOperationResult(Uint32 key, |
AsyncLegacyOperationResult::AsyncLegacyOperationResult(Uint32 routing, |
Uint32 routing, |
|
AsyncOpNode *operation, | AsyncOpNode *operation, |
Message *result) | Message *result) |
: AsyncReply(async_messages::ASYNC_LEGACY_OP_RESULT, | : AsyncReply(async_messages::ASYNC_LEGACY_OP_RESULT, |
key, routing, 0, operation, |
routing, 0, operation, |
0, CIMOM_Q_ID, false), | 0, CIMOM_Q_ID, false), |
_res(result) | _res(result) |
{ | { |
|
|
Uint32 service_capabilities, | Uint32 service_capabilities, |
Uint32 service_mask) | Uint32 service_mask) |
: AsyncRequest(async_messages::FIND_SERVICE_Q, | : AsyncRequest(async_messages::FIND_SERVICE_Q, |
Message::getNextKey(), |
|
routing, 0, operation, | routing, 0, operation, |
CIMOM_Q_ID, | CIMOM_Q_ID, |
response, | response, |
|
|
} | } |
| |
| |
FindServiceQueueResult::FindServiceQueueResult(Uint32 key, |
FindServiceQueueResult::FindServiceQueueResult(Uint32 routing, |
Uint32 routing, |
|
AsyncOpNode *operation, | AsyncOpNode *operation, |
Uint32 result_code, | Uint32 result_code, |
Uint32 destination, | Uint32 destination, |
Boolean blocking, | Boolean blocking, |
Array<Uint32> queue_ids) | Array<Uint32> queue_ids) |
: AsyncReply(async_messages::FIND_SERVICE_Q_RESULT, | : AsyncReply(async_messages::FIND_SERVICE_Q_RESULT, |
key, routing, 0, operation, |
routing, 0, operation, |
result_code, destination, blocking), | result_code, destination, blocking), |
qids(queue_ids) | qids(queue_ids) |
{ | { |
|
|
Boolean blocking, | Boolean blocking, |
Uint32 queue_id) | Uint32 queue_id) |
: AsyncRequest(async_messages::ENUMERATE_SERVICE, | : AsyncRequest(async_messages::ENUMERATE_SERVICE, |
Message::getNextKey(), |
|
routing, 0, | routing, 0, |
operation, | operation, |
CIMOM_Q_ID, | CIMOM_Q_ID, |
|
|
| |
} | } |
| |
EnumerateServiceResponse::EnumerateServiceResponse(Uint32 key, |
EnumerateServiceResponse::EnumerateServiceResponse(Uint32 routing, |
Uint32 routing, |
|
AsyncOpNode *operation, | AsyncOpNode *operation, |
Uint32 result_code, | Uint32 result_code, |
Uint32 response, | Uint32 response, |
|
|
Uint32 service_mask, | Uint32 service_mask, |
Uint32 service_qid) | Uint32 service_qid) |
: AsyncReply(async_messages::ENUMERATE_SERVICE_RESULT, | : AsyncReply(async_messages::ENUMERATE_SERVICE_RESULT, |
key, |
|
routing, 0, | routing, 0, |
operation, | operation, |
result_code, | result_code, |
|
|
| |
} | } |
| |
|
AsyncMessage::~AsyncMessage(void) |
|
{ |
|
} |
|
|
|
AsyncRequest::~AsyncRequest(void) |
|
{ |
|
} |
| |
PEGASUS_NAMESPACE_END | PEGASUS_NAMESPACE_END |