(file) Return to CimomMessage.cpp CVS log (file) (dir) Up to [Pegasus] / pegasus / src / Pegasus / Common

Diff for /pegasus/src/Pegasus/Common/CimomMessage.cpp between version 1.23 and 1.24

version 1.23, 2006/07/14 20:12:46 version 1.24, 2006/07/23 18:02:33
Line 102 
Line 102 
  
 AsyncMessage::AsyncMessage(Uint32 type, AsyncMessage::AsyncMessage(Uint32 type,
                            Uint32 destination,                            Uint32 destination,
                            Uint32 routing,  
                            Uint32 mask,                            Uint32 mask,
                            AsyncOpNode *operation)                            AsyncOpNode *operation)
    : Message(type, destination, routing, mask | message_mask::ha_async),     : Message(type, destination, mask | message_mask::ha_async),
      op(operation)      op(operation)
 { {
  
 } }
  
 AsyncRequest::AsyncRequest(Uint32 type, AsyncRequest::AsyncRequest(Uint32 type,
                            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, routing, mask | message_mask::ha_request, operation),     : AsyncMessage(type, destination, mask | message_mask::ha_request, operation),
      resp(response),      resp(response),
      block(blocking)      block(blocking)
 { {
Line 127 
Line 125 
 } }
  
 AsyncReply::AsyncReply(Uint32 type, AsyncReply::AsyncReply(Uint32 type,
                        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, routing, mask | message_mask::ha_reply, operation),     : AsyncMessage(type, destination, mask | message_mask::ha_reply, operation),
      result(result_code),      result(result_code),
      block(blocking)      block(blocking)
 { {
Line 144 
Line 141 
  
  
  
 RegisterCimService::RegisterCimService(Uint32 routing,  RegisterCimService::RegisterCimService(
                                        AsyncOpNode *operation,                                        AsyncOpNode *operation,
                                        Boolean blocking,                                        Boolean blocking,
                                        String service_name,                                        String service_name,
Line 152 
Line 149 
                                        Uint32 service_mask,                                        Uint32 service_mask,
                                        Uint32 service_queue)                                        Uint32 service_queue)
    : AsyncRequest( async_messages::REGISTER_CIM_SERVICE,    : AsyncRequest( async_messages::REGISTER_CIM_SERVICE,
                    routing, 0, operation, CIMOM_Q_ID,                     0, operation, CIMOM_Q_ID,
                    service_queue, blocking),                    service_queue, blocking),
      name(service_name),      name(service_name),
      capabilities(service_capabilities),      capabilities(service_capabilities),
Line 163 
Line 160 
 } }
  
  
 DeRegisterCimService::DeRegisterCimService(Uint32 routing,  DeRegisterCimService::DeRegisterCimService(
                                            AsyncOpNode *operation,                                            AsyncOpNode *operation,
                                            Boolean blocking,                                            Boolean blocking,
                                            Uint32 service_queue)                                            Uint32 service_queue)
    : AsyncRequest( async_messages::DEREGISTER_CIM_SERVICE,    : AsyncRequest( async_messages::DEREGISTER_CIM_SERVICE,
                    routing, 0, operation, CIMOM_Q_ID,                     0, operation, CIMOM_Q_ID,
                    service_queue, blocking),                    service_queue, blocking),
      queue(service_queue)      queue(service_queue)
 { {
Line 177 
Line 174 
  
  
  
 UpdateCimService::UpdateCimService(Uint32 routing,  UpdateCimService::UpdateCimService(
                                    AsyncOpNode *operation,                                    AsyncOpNode *operation,
                                    Boolean blocking,                                    Boolean blocking,
                                    Uint32 service_queue,                                    Uint32 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,
                    routing, 0, operation, CIMOM_Q_ID,                     0, operation, CIMOM_Q_ID,
                    service_queue, blocking),                    service_queue, blocking),
      queue(service_queue),      queue(service_queue),
      capabilities(service_capabilities),      capabilities(service_capabilities),
Line 193 
Line 190 
  
 } }
  
 RegisteredModule::RegisteredModule(Uint32 routing,  RegisteredModule::RegisteredModule(
                                    AsyncOpNode *operation,                                    AsyncOpNode *operation,
                                    Boolean blocking,                                    Boolean blocking,
                                    Uint32 service_queue,                                    Uint32 service_queue,
                                    String new_module)                                    String new_module)
    : AsyncRequest( async_messages::REGISTERED_MODULE,    : AsyncRequest( async_messages::REGISTERED_MODULE,
                    routing,  
                    0,                    0,
                    operation,                    operation,
                    CIMOM_Q_ID,                    CIMOM_Q_ID,
Line 210 
Line 206 
  
 } }
  
 DeRegisteredModule::DeRegisteredModule(Uint32 routing,  DeRegisteredModule::DeRegisteredModule(
                                      AsyncOpNode *operation,                                      AsyncOpNode *operation,
                                      Boolean blocking,                                      Boolean blocking,
                                      Uint32 service_queue,                                      Uint32 service_queue,
                                      String removed_module)                                      String removed_module)
    : AsyncRequest( async_messages::DEREGISTERED_MODULE,    : AsyncRequest( async_messages::DEREGISTERED_MODULE,
                    routing,  
                    0,                    0,
                    operation,                    operation,
                    CIMOM_Q_ID,                    CIMOM_Q_ID,
Line 228 
Line 223 
 } }
  
  
 FindModuleInService::FindModuleInService(Uint32 routing,  FindModuleInService::FindModuleInService(
                                          AsyncOpNode *operation,                                          AsyncOpNode *operation,
                                          Boolean blocking,                                          Boolean blocking,
                                          Uint32 response_queue,                                          Uint32 response_queue,
                                          String module)                                          String module)
    : AsyncRequest(async_messages::FIND_MODULE_IN_SERVICE,    : AsyncRequest(async_messages::FIND_MODULE_IN_SERVICE,
                   routing,  
                   0,                   0,
                   operation,                   operation,
                   CIMOM_Q_ID,                   CIMOM_Q_ID,
Line 245 
Line 239 
  
 } }
  
 FindModuleInServiceResponse::FindModuleInServiceResponse(Uint32 routing,  FindModuleInServiceResponse::FindModuleInServiceResponse(
                                                          AsyncOpNode *operation,                                                          AsyncOpNode *operation,
                                                          Uint32 result_code,                                                          Uint32 result_code,
                                                          Uint32 destination,                                                          Uint32 destination,
Line 253 
Line 247 
                                                          Uint32 module_service_queue)                                                          Uint32 module_service_queue)
  
    : AsyncReply(async_messages::FIND_MODULE_IN_SERVICE_RESPONSE,    : AsyncReply(async_messages::FIND_MODULE_IN_SERVICE_RESPONSE,
                 routing,  
                 0,                 0,
                 operation,                 operation,
                 result_code,                 result_code,
Line 264 
Line 257 
  
 } }
  
 AsyncIoctl::AsyncIoctl(Uint32 routing,  AsyncIoctl::AsyncIoctl(
                        AsyncOpNode *operation,                        AsyncOpNode *operation,
                        Uint32 destination,                        Uint32 destination,
                        Uint32 response,                        Uint32 response,
Line 273 
Line 266 
                        Uint32 int_param,                        Uint32 int_param,
                        void *p_param)                        void *p_param)
    : AsyncRequest( async_messages::IOCTL,    : AsyncRequest( async_messages::IOCTL,
                    routing, 0, operation,                     0, operation,
                    destination, response, blocking),                    destination, response, blocking),
      ctl(code),      ctl(code),
      intp(int_param),      intp(int_param),
Line 283 
Line 276 
 } }
  
  
 CimServiceStart::CimServiceStart(Uint32 routing,  CimServiceStart::CimServiceStart(
                                  AsyncOpNode *operation,                                  AsyncOpNode *operation,
                                  Uint32 destination,                                  Uint32 destination,
                                  Uint32 response,                                  Uint32 response,
                                  Boolean blocking)                                  Boolean blocking)
    : AsyncRequest(async_messages::CIMSERVICE_START,    : AsyncRequest(async_messages::CIMSERVICE_START,
                   routing,  
                   0, operation, destination,                   0, operation, destination,
                   response, blocking)                   response, blocking)
 { {
Line 297 
Line 289 
 } }
  
  
 CimServiceStop::CimServiceStop(Uint32 routing,  CimServiceStop::CimServiceStop(
                                AsyncOpNode *operation,                                AsyncOpNode *operation,
                                Uint32 destination,                                Uint32 destination,
                                Uint32 response,                                Uint32 response,
                                Boolean blocking)                                Boolean blocking)
    : AsyncRequest(async_messages::CIMSERVICE_STOP,    : AsyncRequest(async_messages::CIMSERVICE_STOP,
                   routing,  
                   0, operation, destination,                   0, operation, destination,
                   response, blocking)                   response, blocking)
 { {
Line 312 
Line 303 
  
  
  
 CimServicePause::CimServicePause(Uint32 routing,  CimServicePause::CimServicePause(
                                  AsyncOpNode *operation,                                  AsyncOpNode *operation,
                                  Uint32 destination,                                  Uint32 destination,
                                  Uint32 response,                                  Uint32 response,
                                  Boolean blocking)                                  Boolean blocking)
    : AsyncRequest(async_messages::CIMSERVICE_PAUSE,    : AsyncRequest(async_messages::CIMSERVICE_PAUSE,
                   routing,  
                   0, operation, destination,                   0, operation, destination,
                   response, blocking)                   response, blocking)
 { {
Line 326 
Line 316 
 } }
  
  
 CimServiceResume::CimServiceResume(Uint32 routing,  CimServiceResume::CimServiceResume(
                                    AsyncOpNode *operation,                                    AsyncOpNode *operation,
                                    Uint32 destination,                                    Uint32 destination,
                                    Uint32 response,                                    Uint32 response,
                                    Boolean blocking)                                    Boolean blocking)
    : AsyncRequest(async_messages::CIMSERVICE_RESUME,    : AsyncRequest(async_messages::CIMSERVICE_RESUME,
                   routing,  
                   0, operation, destination,                   0, operation, destination,
                   response, blocking)                   response, blocking)
 { {
  
 } }
  
 AsyncOperationStart::AsyncOperationStart(Uint32 routing,  AsyncOperationStart::AsyncOperationStart(
                                          AsyncOpNode *operation,                                          AsyncOpNode *operation,
                                          Uint32 destination,                                          Uint32 destination,
                                          Uint32 response,                                          Uint32 response,
                                          Boolean blocking,                                          Boolean blocking,
                                          Message *action)                                          Message *action)
    : AsyncRequest(async_messages::ASYNC_OP_START,    : AsyncRequest(async_messages::ASYNC_OP_START,
                   routing, 0,                    0,
                   operation,                   operation,
                   destination, response, blocking),                   destination, response, blocking),
      _act(action)      _act(action)
Line 365 
Line 354 
 } }
  
  
 AsyncOperationResult::AsyncOperationResult(Uint32 routing,  AsyncOperationResult::AsyncOperationResult(
                                            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,
                 routing, 0,                  0,
                 operation, result_code, destination,                 operation, result_code, destination,
                 blocking)                 blocking)
 { {
Line 379 
Line 368 
 } }
  
  
 AsyncModuleOperationStart::AsyncModuleOperationStart(Uint32 routing,  AsyncModuleOperationStart::AsyncModuleOperationStart(
                                                      AsyncOpNode *operation,                                                      AsyncOpNode *operation,
                                                      Uint32 destination,                                                      Uint32 destination,
                                                      Uint32 response,                                                      Uint32 response,
Line 387 
Line 376 
                                                      String target_module,                                                      String target_module,
                                                      Message *action)                                                      Message *action)
    : AsyncRequest(async_messages::ASYNC_MODULE_OP_START,    : AsyncRequest(async_messages::ASYNC_MODULE_OP_START,
                   routing, 0,                    0,
                   operation,                   operation,
                   destination, response, blocking),                   destination, response, blocking),
      _target_module(target_module),      _target_module(target_module),
Line 407 
Line 396 
  
 } }
  
 AsyncModuleOperationResult::AsyncModuleOperationResult(Uint32 routing,  AsyncModuleOperationResult::AsyncModuleOperationResult(
                                                        AsyncOpNode *operation,                                                        AsyncOpNode *operation,
                                                        Uint32 result_code,                                                        Uint32 result_code,
                                                        Uint32 destination,                                                        Uint32 destination,
Line 415 
Line 404 
                                                        String target_module,                                                        String target_module,
                                                        Message *result)                                                        Message *result)
    : AsyncReply(async_messages::ASYNC_MODULE_OP_RESULT,    : AsyncReply(async_messages::ASYNC_MODULE_OP_RESULT,
                 routing, 0,                  0,
                 operation, result_code, destination,                 operation, result_code, destination,
                 blocking),                 blocking),
      _target_module(target_module),      _target_module(target_module),
Line 433 
Line 422 
 } }
  
  
 AsyncLegacyOperationStart::AsyncLegacyOperationStart(Uint32 routing,  AsyncLegacyOperationStart::AsyncLegacyOperationStart(
                                                      AsyncOpNode *operation,                                                      AsyncOpNode *operation,
                                                      Uint32 destination,                                                      Uint32 destination,
                                                      Message *action,                                                      Message *action,
                                                      Uint32 action_destination)                                                      Uint32 action_destination)
    : AsyncRequest(async_messages::ASYNC_LEGACY_OP_START,    : AsyncRequest(async_messages::ASYNC_LEGACY_OP_START,
                   routing, 0,                    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)
 { {
Line 456 
Line 445 
  
 } }
  
 AsyncLegacyOperationResult::AsyncLegacyOperationResult(Uint32 routing,  AsyncLegacyOperationResult::AsyncLegacyOperationResult(
                                                        AsyncOpNode *operation,                                                        AsyncOpNode *operation,
                                                        Message *result)                                                        Message *result)
    : AsyncReply(async_messages::ASYNC_LEGACY_OP_RESULT,    : AsyncReply(async_messages::ASYNC_LEGACY_OP_RESULT,
                 routing, 0, operation,                  0, operation,
                 0, CIMOM_Q_ID, false),                 0, CIMOM_Q_ID, false),
      _res(result)      _res(result)
 { {
Line 475 
Line 464 
    return ret;    return ret;
 } }
  
 FindServiceQueue::FindServiceQueue(Uint32 routing,  FindServiceQueue::FindServiceQueue(
                                    AsyncOpNode *operation,                                    AsyncOpNode *operation,
                                    Uint32 response,                                    Uint32 response,
                                    Boolean blocking,                                    Boolean blocking,
Line 483 
Line 472 
                                    Uint32 service_capabilities,                                    Uint32 service_capabilities,
                                    Uint32 service_mask)                                    Uint32 service_mask)
    : AsyncRequest(async_messages::FIND_SERVICE_Q,    : AsyncRequest(async_messages::FIND_SERVICE_Q,
                   routing, 0, operation,                    0, operation,
                   CIMOM_Q_ID,                   CIMOM_Q_ID,
                   response,                   response,
                   blocking),                   blocking),
Line 495 
Line 484 
 } }
  
  
 FindServiceQueueResult::FindServiceQueueResult(Uint32 routing,  FindServiceQueueResult::FindServiceQueueResult(
                                                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,
                 routing, 0, operation,                  0, operation,
                 result_code, destination, blocking),                 result_code, destination, blocking),
      qids(queue_ids)      qids(queue_ids)
 { {
  
 } }
  
 EnumerateService::EnumerateService(Uint32 routing,  EnumerateService::EnumerateService(
                                    AsyncOpNode *operation,                                    AsyncOpNode *operation,
                                    Uint32 response,                                    Uint32 response,
                                    Boolean blocking,                                    Boolean blocking,
                                    Uint32 queue_id)                                    Uint32 queue_id)
    : AsyncRequest(async_messages::ENUMERATE_SERVICE,    : AsyncRequest(async_messages::ENUMERATE_SERVICE,
                   routing, 0,                    0,
                   operation,                   operation,
                   CIMOM_Q_ID,                   CIMOM_Q_ID,
                   response,                   response,
Line 525 
Line 514 
  
 } }
  
 EnumerateServiceResponse::EnumerateServiceResponse(Uint32 routing,  EnumerateServiceResponse::EnumerateServiceResponse(
                                                    AsyncOpNode *operation,                                                    AsyncOpNode *operation,
                                                    Uint32 result_code,                                                    Uint32 result_code,
                                                    Uint32 response,                                                    Uint32 response,
Line 535 
Line 524 
                                                    Uint32 service_mask,                                                    Uint32 service_mask,
                                                    Uint32 service_qid)                                                    Uint32 service_qid)
    : AsyncReply(async_messages::ENUMERATE_SERVICE_RESULT,    : AsyncReply(async_messages::ENUMERATE_SERVICE_RESULT,
                 routing, 0,                  0,
                 operation,                 operation,
                 result_code,                 result_code,
                 response,                 response,

Legend:
Removed from v.1.23  
changed lines
  Added in v.1.24
No CVS admin address has been configured
 Powered by
ViewCVS 0.9.2