(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.9 and 1.13

version 1.9, 2002/02/25 23:57:07 version 1.13, 2002/03/19 21:03:37
Line 84 
Line 84 
 const Uint32 async_messages::ENUMERATE_SERVICE =        0x0000000f; const Uint32 async_messages::ENUMERATE_SERVICE =        0x0000000f;
 const Uint32 async_messages::ENUMERATE_SERVICE_RESULT = 0x00000010; const Uint32 async_messages::ENUMERATE_SERVICE_RESULT = 0x00000010;
  
   const Uint32 async_messages::REGISTERED_MODULE =               0x00000011;
   const Uint32 async_messages::DEREGISTERED_MODULE =             0x00000012;
   const Uint32 async_messages::FIND_MODULE_IN_SERVICE =          0x00000013;
   const Uint32 async_messages::FIND_MODULE_IN_SERVICE_RESPONSE = 0x00000014;
   
   const Uint32 async_messages::ASYNC_MODULE_OP_START =           0x00000015;
   const Uint32 async_messages::ASYNC_MODULE_OP_RESULT  =         0x00000016;
   
   
  
 AsyncMessage::AsyncMessage(Uint32 type, AsyncMessage::AsyncMessage(Uint32 type,
                            Uint32 destination,                            Uint32 destination,
Line 92 
Line 101 
                            Uint32 mask,                            Uint32 mask,
                            AsyncOpNode *operation)                            AsyncOpNode *operation)
    : Message(type, destination, key, routing, mask | message_mask::ha_async),    : Message(type, destination, key, routing, mask | message_mask::ha_async),
      op(operation),       op(operation)
      _myself(0),  
      _service(0)  
 { {
  
 } }
Line 186 
Line 193 
  
 } }
  
   RegisteredModule::RegisteredModule(Uint32 routing,
                                      AsyncOpNode *operation,
                                      Boolean blocking,
                                      Uint32 service_queue,
                                      String new_module)
      : AsyncRequest( async_messages::REGISTERED_MODULE,
                      Message::getNextKey(),
                      routing,
                      0,
                      operation,
                      CIMOM_Q_ID,
                      service_queue,
                      blocking),
        _module(new_module)
   {
   
   }
   
   DeRegisteredModule::DeRegisteredModule(Uint32 routing,
                                        AsyncOpNode *operation,
                                        Boolean blocking,
                                        Uint32 service_queue,
                                        String removed_module)
      : AsyncRequest( async_messages::DEREGISTERED_MODULE,
                      Message::getNextKey(),
                      routing,
                      0,
                      operation,
                      CIMOM_Q_ID,
                      service_queue,
                      blocking),
        _module(removed_module)
   {
   
   }
   
   
   FindModuleInService::FindModuleInService(Uint32 routing,
                                            AsyncOpNode *operation,
                                            Boolean blocking,
                                            Uint32 response_queue,
                                            String module)
      : AsyncRequest(async_messages::FIND_MODULE_IN_SERVICE,
                     Message::getNextKey(),
                     routing,
                     0,
                     operation,
                     CIMOM_Q_ID,
                     response_queue,
                     blocking),
        _module(module)
   {
   
   }
   
   FindModuleInServiceResponse::FindModuleInServiceResponse(Uint32 routing,
                                                            Uint32 key,
                                                            AsyncOpNode *operation,
                                                            Uint32 result_code,
                                                            Uint32 destination,
                                                            Uint32 blocking,
                                                            Uint32 module_service_queue)
   
      : AsyncReply(async_messages::FIND_MODULE_IN_SERVICE_RESPONSE,
                   key,
                   routing,
                   0,
                   operation,
                   result_code,
                   destination,
                   blocking),
        _module_service_queue(module_service_queue)
   {
   
   }
  
 AsyncIoctl::AsyncIoctl(Uint32 routing, AsyncIoctl::AsyncIoctl(Uint32 routing,
                        AsyncOpNode *operation,                        AsyncOpNode *operation,
Line 279 
Line 361 
 } }
  
  
 inline Message * AsyncOperationStart::get_action(void)  Message * AsyncOperationStart::get_action(void)
 { {
    Message *ret = _act;    Message *ret = _act;
    _act = 0;    _act = 0;
Line 304 
Line 386 
 } }
  
  
   AsyncModuleOperationStart::AsyncModuleOperationStart(Uint32 routing,
                                                        AsyncOpNode *operation,
                                                        Uint32 destination,
                                                        Uint32 response,
                                                        Boolean blocking,
                                                        String target_module,
                                                        Message *action)
      : AsyncRequest(async_messages::ASYNC_MODULE_OP_START,
                     Message::getNextKey(), routing, 0,
                     operation,
                     destination, response, blocking),
        _target_module(target_module),
        _act(action)
   {
      _act->put_async(this);
   
   }
   
   
   Message * AsyncModuleOperationStart::get_action(void)
   {
      Message *ret = _act;
      _act = 0;
      ret->put_async(0);
      return ret;
   
   }
   
   AsyncModuleOperationResult::AsyncModuleOperationResult(Uint32 key,
                                                          Uint32 routing,
                                                          AsyncOpNode *operation,
                                                          Uint32 result_code,
                                                          Uint32 destination,
                                                          Uint32 blocking,
                                                          String target_module,
                                                          Message *result)
      : AsyncReply(async_messages::ASYNC_MODULE_OP_RESULT,
                   key, routing, 0,
                   operation, result_code, destination,
                   blocking),
        _target_module(target_module),
        _res(result)
   {
      _res->put_async(this);
   }
  
 AsyncLegacyOperationStart::AsyncLegacyOperationStart(Uint32 routing, AsyncLegacyOperationStart::AsyncLegacyOperationStart(Uint32 routing,
                                                      AsyncOpNode *operation,                                                      AsyncOpNode *operation,

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