(file) Return to ProviderManagerService.cpp CVS log (file) (dir) Up to [Pegasus] / pegasus / src / Pegasus / ProviderManager2 / Attic

Diff for /pegasus/src/Pegasus/ProviderManager2/Attic/ProviderManagerService.cpp between version 1.24.6.5 and 1.30

version 1.24.6.5, 2004/04/05 08:55:51 version 1.30, 2004/03/23 15:51:32
Line 31 
Line 31 
 //              Karl Schopmeyer(k.schopmeyer@opengroup.org) - Fix associators. //              Karl Schopmeyer(k.schopmeyer@opengroup.org) - Fix associators.
 //              Yi Zhou, Hewlett-Packard Company (yi_zhou@hp.com) //              Yi Zhou, Hewlett-Packard Company (yi_zhou@hp.com)
 //              Adrian Schuur, IBM (schuur@de.ibm.com) //              Adrian Schuur, IBM (schuur@de.ibm.com)
   //              Dan Gorey, djgorey@us.ibm.com
 // //
 //%///////////////////////////////////////////////////////////////////////////// //%/////////////////////////////////////////////////////////////////////////////
  
Line 267 
Line 268 
  
         _incomingQueue.enqueue(request->op);         _incomingQueue.enqueue(request->op);
  
          while (!_thread_pool->allocate_and_awaken(          _thread_pool->allocate_and_awaken((void *)this, ProviderManagerService::handleCimOperation);
                      (void *)this, ProviderManagerService::handleCimOperation))  
          {  
              pegasus_yield();  
          }  
     }     }
     else     else
     {     {
Line 389 
Line 386 
     // get the responsible provider Manager     // get the responsible provider Manager
     ProviderManager * pm = locateProviderManager(message,ifc);     ProviderManager * pm = locateProviderManager(message,ifc);
     if (pm) {     if (pm) {
         response = pm->processMessage(request);          response = pm->processMessage(request,providerManagerName);
     }     }
  
     else for (Uint32 i = 0, n = _providerManagers.size(); i < n; i++) {     else for (Uint32 i = 0, n = _providerManagers.size(); i < n; i++) {
Line 400 
Line 397 
                 dynamic_cast<CIMEnableModuleRequestMessage*>(const_cast<Message*>(message));                 dynamic_cast<CIMEnableModuleRequestMessage*>(const_cast<Message*>(message));
              if (request->providerModule.getProperty(request->providerModule.findProperty              if (request->providerModule.getProperty(request->providerModule.findProperty
                  ("InterfaceType")).getValue().toString()==pmc->getInterfaceName())                  ("InterfaceType")).getValue().toString()==pmc->getInterfaceName())
              response=pmc->getProviderManager()->processMessage(request);               response=pmc->getProviderManager()->processMessage(request,providerManagerName);
           }           }
           break;           break;
        case CIM_DISABLE_MODULE_REQUEST_MESSAGE: {        case CIM_DISABLE_MODULE_REQUEST_MESSAGE: {
Line 408 
Line 405 
                 dynamic_cast<CIMDisableModuleRequestMessage*>(const_cast<Message*>(message));                 dynamic_cast<CIMDisableModuleRequestMessage*>(const_cast<Message*>(message));
              if (request->providerModule.getProperty(request->providerModule.findProperty              if (request->providerModule.getProperty(request->providerModule.findProperty
                  ("InterfaceType")).getValue().toString()==pmc->getInterfaceName())                  ("InterfaceType")).getValue().toString()==pmc->getInterfaceName())
              response=pmc->getProviderManager()->processMessage(request);               response=pmc->getProviderManager()->processMessage(request,providerManagerName);
           }           }
           break;           break;
        case CIM_STOP_ALL_PROVIDERS_REQUEST_MESSAGE: {        case CIM_STOP_ALL_PROVIDERS_REQUEST_MESSAGE: {
           Message  *resp=pmc->getProviderManager()->processMessage(request);            Message  *resp=pmc->getProviderManager()->processMessage(request,providerManagerName);
           if (resp) response=resp; }           if (resp) response=resp; }
           break;           break;
        default:        default:
Line 472 
Line 469 
  
        // find provider manager        // find provider manager
        name = ProviderRegistrar().findProvider(name,false);        name = ProviderRegistrar().findProvider(name,false);
          providerManagerName = name;
        it=name.getInterfaceName();        it=name.getInterfaceName();
     }     }
  
Line 508 
Line 506 
  
 void ProviderManagerService::unload_idle_providers(void) void ProviderManagerService::unload_idle_providers(void)
 { {
     for(Uint32 i = 0, n = _providerManagers.size(); i < n; i++)  
     {  
       ProviderManagerContainer *pmc=_providerManagers[i];  
            pmc->getProviderManager()->unload_idle_providers();  
     }  
 } }
  
 PEGASUS_NAMESPACE_END PEGASUS_NAMESPACE_END

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