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

Diff for /pegasus/src/Pegasus/ProviderManager2/Default/DefaultProviderManager.cpp between version 1.47 and 1.50

version 1.47, 2005/02/05 23:00:30 version 1.50, 2005/03/03 19:27:56
Line 37 
Line 37 
 //              Roger Kumpf, Hewlett-Packard Company (roger_kumpf@hp.com) //              Roger Kumpf, Hewlett-Packard Company (roger_kumpf@hp.com)
 //                              Seema Gupta (gseema@in.ibm.com) for PEP135 //                              Seema Gupta (gseema@in.ibm.com) for PEP135
 //                              Willis White (whiwill@us.ibm.com) //                              Willis White (whiwill@us.ibm.com)
   //              Josephine Eskaline Joyce (jojustin@in.ibm.com) for PEP#101
 // //
 //%///////////////////////////////////////////////////////////////////////////// //%/////////////////////////////////////////////////////////////////////////////
  
Line 44 
Line 45 
  
 #include <Pegasus/Common/CIMMessage.h> #include <Pegasus/Common/CIMMessage.h>
 #include <Pegasus/Common/OperationContext.h> #include <Pegasus/Common/OperationContext.h>
 #include <Pegasus/Common/Destroyer.h>  
 #include <Pegasus/Common/Tracer.h> #include <Pegasus/Common/Tracer.h>
 #include <Pegasus/Common/StatisticalData.h> #include <Pegasus/Common/StatisticalData.h>
 #include <Pegasus/Common/Logger.h> #include <Pegasus/Common/Logger.h>
Line 87 
Line 87 
 // //
 DefaultProviderManager::DefaultProviderManager(void) DefaultProviderManager::DefaultProviderManager(void)
 { {
       _subscriptionInitComplete = false;
 } }
  
 DefaultProviderManager::~DefaultProviderManager(void) DefaultProviderManager::~DefaultProviderManager(void)
Line 171 
Line 172 
         response = handleDeleteSubscriptionRequest(request);         response = handleDeleteSubscriptionRequest(request);
  
         break;         break;
     case CIM_ENABLE_INDICATIONS_REQUEST_MESSAGE:  
         response = handleEnableIndicationsRequest(request);  
   
         break;  
     case CIM_DISABLE_INDICATIONS_REQUEST_MESSAGE:  
         response = handleDisableIndicationsRequest(request);  
   
         break;  
     case CIM_EXPORT_INDICATION_REQUEST_MESSAGE:     case CIM_EXPORT_INDICATION_REQUEST_MESSAGE:
         response = handleExportIndicationRequest(request);         response = handleExportIndicationRequest(request);
         break;         break;
Line 199 
Line 192 
         response = handleInitializeProviderRequest(request);         response = handleInitializeProviderRequest(request);
  
         break;         break;
       case CIM_SUBSCRIPTION_INIT_COMPLETE_REQUEST_MESSAGE:
           response = handleSubscriptionInitCompleteRequest (request);
   
           break;
     default:     default:
         response = handleUnsupportedRequest(request);         response = handleUnsupportedRequest(request);
  
Line 253 
Line 250 
             request->operationContext.get(ProviderIdContainer::NAME));             request->operationContext.get(ProviderIdContainer::NAME));
  
         // get cached or load new provider module         // get cached or load new provider module
         OpProviderHolder ph =          OpProviderHolder ph = providerManager.getProvider(
             providerManager.getProvider(name.getPhysicalName(),              name.getPhysicalName(), name.getLogicalName());
                 name.getLogicalName(), String::EMPTY);  
   
     }     }
     catch(CIMException & e)     catch(CIMException & e)
     {     {
Line 332 
Line 327 
             request->operationContext.get(ProviderIdContainer::NAME));             request->operationContext.get(ProviderIdContainer::NAME));
  
         // get cached or load new provider module         // get cached or load new provider module
         OpProviderHolder ph =          OpProviderHolder ph = providerManager.getProvider(
             providerManager.getProvider(name.getPhysicalName(), name.getLogicalName(), String::EMPTY);              name.getPhysicalName(), name.getLogicalName());
  
         // convert arguments         // convert arguments
         OperationContext context;         OperationContext context;
Line 436 
Line 431 
             request->operationContext.get(ProviderIdContainer::NAME));             request->operationContext.get(ProviderIdContainer::NAME));
  
         // get cached or load new provider module         // get cached or load new provider module
         OpProviderHolder ph = providerManager.getProvider(name.getPhysicalName(),          OpProviderHolder ph = providerManager.getProvider(
                 name.getLogicalName(), String::EMPTY);              name.getPhysicalName(), name.getLogicalName());
  
         // convert arguments         // convert arguments
         OperationContext context;         OperationContext context;
Line 541 
Line 536 
             request->operationContext.get(ProviderIdContainer::NAME));             request->operationContext.get(ProviderIdContainer::NAME));
  
         // get cached or load new provider module         // get cached or load new provider module
         OpProviderHolder ph =          OpProviderHolder ph = providerManager.getProvider(
             providerManager.getProvider(name.getPhysicalName(), name.getLogicalName());              name.getPhysicalName(), name.getLogicalName());
  
         // convert arguments         // convert arguments
         OperationContext context;         OperationContext context;
Line 642 
Line 637 
             request->operationContext.get(ProviderIdContainer::NAME));             request->operationContext.get(ProviderIdContainer::NAME));
  
         // get cached or load new provider module         // get cached or load new provider module
         OpProviderHolder ph =          OpProviderHolder ph = providerManager.getProvider(
             providerManager.getProvider(name.getPhysicalName(), name.getLogicalName(), String::EMPTY);              name.getPhysicalName(), name.getLogicalName());
  
         // convert arguments         // convert arguments
         OperationContext context;         OperationContext context;
Line 743 
Line 738 
             request->operationContext.get(ProviderIdContainer::NAME));             request->operationContext.get(ProviderIdContainer::NAME));
  
         // get cached or load new provider module         // get cached or load new provider module
         OpProviderHolder ph =          OpProviderHolder ph = providerManager.getProvider(
             providerManager.getProvider(name.getPhysicalName(), name.getLogicalName(), String::EMPTY);              name.getPhysicalName(), name.getLogicalName());
  
         // convert arguments         // convert arguments
         OperationContext context;         OperationContext context;
Line 848 
Line 843 
             request->operationContext.get(ProviderIdContainer::NAME));             request->operationContext.get(ProviderIdContainer::NAME));
  
         // get cached or load new provider module         // get cached or load new provider module
         OpProviderHolder ph =          OpProviderHolder ph = providerManager.getProvider(
             providerManager.getProvider(name.getPhysicalName(), name.getLogicalName(), String::EMPTY);              name.getPhysicalName(), name.getLogicalName());
  
         // convert arguments         // convert arguments
         OperationContext context;         OperationContext context;
Line 947 
Line 942 
             request->operationContext.get(ProviderIdContainer::NAME));             request->operationContext.get(ProviderIdContainer::NAME));
  
         // get cached or load new provider module         // get cached or load new provider module
         OpProviderHolder ph =          OpProviderHolder ph = providerManager.getProvider(
             providerManager.getProvider(name.getPhysicalName(),              name.getPhysicalName(), name.getLogicalName());
                                         name.getLogicalName(), String::EMPTY);  
  
         if (dynamic_cast<CIMInstanceQueryProvider*>(ph.GetCIMProvider()) == 0) {         if (dynamic_cast<CIMInstanceQueryProvider*>(ph.GetCIMProvider()) == 0) {
            String errorString = " instance provider is registered supporting execQuery "            String errorString = " instance provider is registered supporting execQuery "
Line 1062 
Line 1056 
             request->operationContext.get(ProviderIdContainer::NAME));             request->operationContext.get(ProviderIdContainer::NAME));
  
         // get cached or load new provider module         // get cached or load new provider module
         OpProviderHolder ph =          OpProviderHolder ph = providerManager.getProvider(
             providerManager.getProvider(name.getPhysicalName(), name.getLogicalName(), String::EMPTY);              name.getPhysicalName(), name.getLogicalName());
  
         // convert arguments         // convert arguments
         OperationContext context;         OperationContext context;
Line 1170 
Line 1164 
             request->operationContext.get(ProviderIdContainer::NAME));             request->operationContext.get(ProviderIdContainer::NAME));
  
         // get cached or load new provider module         // get cached or load new provider module
         OpProviderHolder ph =          OpProviderHolder ph = providerManager.getProvider(
             providerManager.getProvider(name.getPhysicalName(), name.getLogicalName(), String::EMPTY);              name.getPhysicalName(), name.getLogicalName());
  
         // convert arguments         // convert arguments
         OperationContext context;         OperationContext context;
Line 1275 
Line 1269 
             request->operationContext.get(ProviderIdContainer::NAME));             request->operationContext.get(ProviderIdContainer::NAME));
  
         // get cached or load new provider module         // get cached or load new provider module
         OpProviderHolder ph =          OpProviderHolder ph = providerManager.getProvider(
             providerManager.getProvider(name.getPhysicalName(), name.getLogicalName(), String::EMPTY);              name.getPhysicalName(), name.getLogicalName());
  
         // convert arguments         // convert arguments
         OperationContext context;         OperationContext context;
Line 1384 
Line 1378 
             request->operationContext.get(ProviderIdContainer::NAME));             request->operationContext.get(ProviderIdContainer::NAME));
  
         // get cached or load new provider module         // get cached or load new provider module
         OpProviderHolder ph =          OpProviderHolder ph = providerManager.getProvider(
             providerManager.getProvider(name.getPhysicalName(), name.getLogicalName(), String::EMPTY);              name.getPhysicalName(), name.getLogicalName());
  
         // convert arguments         // convert arguments
         OperationContext context;         OperationContext context;
Line 1485 
Line 1479 
             request->operationContext.get(ProviderIdContainer::NAME));             request->operationContext.get(ProviderIdContainer::NAME));
  
         // get cached or load new provider module         // get cached or load new provider module
         OpProviderHolder ph =          OpProviderHolder ph = providerManager.getProvider(
             providerManager.getProvider(name.getPhysicalName(), name.getLogicalName(), String::EMPTY);              name.getPhysicalName(), name.getLogicalName());
  
         // convert arguments         // convert arguments
         OperationContext context;         OperationContext context;
Line 1590 
Line 1584 
             request->operationContext.get(ProviderIdContainer::NAME));             request->operationContext.get(ProviderIdContainer::NAME));
  
         // get cached or load new provider module         // get cached or load new provider module
         OpProviderHolder ph =          OpProviderHolder ph = providerManager.getProvider(
             providerManager.getProvider(name.getPhysicalName(), name.getLogicalName(), String::EMPTY);              name.getPhysicalName(), name.getLogicalName());
  
         // convert arguments         // convert arguments
         OperationContext context;         OperationContext context;
Line 1698 
Line 1692 
             request->operationContext.get(ProviderIdContainer::NAME));             request->operationContext.get(ProviderIdContainer::NAME));
  
         // get cached or load new provider module         // get cached or load new provider module
         OpProviderHolder ph =          OpProviderHolder ph = providerManager.getProvider(
             providerManager.getProvider(name.getPhysicalName(), name.getLogicalName(), String::EMPTY);              name.getPhysicalName(), name.getLogicalName());
  
         // convert arguments         // convert arguments
         OperationContext context;         OperationContext context;
Line 1816 
Line 1810 
                                   req_providerModule.getProperty(req_providerModule.findProperty                                   req_providerModule.getProperty(req_providerModule.findProperty
                                   ("InterfaceType")).getValue().toString(),                                   ("InterfaceType")).getValue().toString(),
                                    0);                                    0);
   
                 // get cached or load new provider module                 // get cached or load new provider module
         OpProviderHolder ph =          OpProviderHolder ph = providerManager.getProvider(
             providerManager.getProvider(name.getPhysicalName(), name.getLogicalName(), String::EMPTY);              name.getPhysicalName(), name.getLogicalName());
   
           //
           //  Save the provider instance from the request
           //
           ph.GetProvider ().setProviderInstance (req_provider);
  
         // convert arguments         // convert arguments
         OperationContext context;         OperationContext context;
Line 1861 
Line 1861 
             classNames,             classNames,
             propertyList,             propertyList,
             repeatNotificationPolicy);             repeatNotificationPolicy);
   
           //
           //  Increment count of current subscriptions for this provider
           //
           if (ph.GetProvider ().testIfZeroAndIncrementSubscriptions ())
           {
               //
               //  If there were no current subscriptions before the increment,
               //  the first subscription has been created
               //  Call the provider's enableIndications method
               //
               if (_subscriptionInitComplete)
               {
                   _callEnableIndications (req_provider,
                       _indicationCallback, ph);
               }
           }
     }     }
     catch(CIMException & e)     catch(CIMException & e)
     {     {
Line 1949 
Line 1966 
                                    0);                                    0);
  
         // get cached or load new provider module         // get cached or load new provider module
         OpProviderHolder ph =          OpProviderHolder ph = providerManager.getProvider(
             providerManager.getProvider(name.getPhysicalName(), name.getLogicalName(), String::EMPTY);              name.getPhysicalName(), name.getLogicalName());
  
         // convert arguments         // convert arguments
         OperationContext context;         OperationContext context;
Line 2081 
Line 2098 
                                    0);                                    0);
  
         // get cached or load new provider module         // get cached or load new provider module
         OpProviderHolder ph =          OpProviderHolder ph = providerManager.getProvider(
             providerManager.getProvider(name.getPhysicalName(), name.getLogicalName(), String::EMPTY);              name.getPhysicalName(), name.getLogicalName());
  
         // convert arguments         // convert arguments
         OperationContext context;         OperationContext context;
Line 2117 
Line 2134 
             context,             context,
             subscriptionName,             subscriptionName,
             classNames);             classNames);
     }  
     catch(CIMException & e)  
     {  
         PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,  
             "Exception: " + e.getMessage());  
   
         handler.setStatus(e.getCode(), e.getContentLanguages(), e.getMessage()); // l10n  
     }  
     catch(Exception & e)  
     {  
         PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,  
             "Exception: " + e.getMessage());  
   
         handler.setStatus(CIM_ERR_FAILED, e.getContentLanguages(), e.getMessage()); // l10n  
     }  
     catch(...)  
     {  
         PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,  
             "Exception: Unknown");  
   
         handler.setStatus(CIM_ERR_FAILED, "Unknown Error");  
     }  
   
     PEG_METHOD_EXIT();  
   
     return(response);  
 }  
   
 Message * DefaultProviderManager::handleEnableIndicationsRequest(const Message * message)  
 {  
     PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManager:: handleEnableIndicationsRequest");  
   
     CIMEnableIndicationsRequestMessage * request =  
         dynamic_cast<CIMEnableIndicationsRequestMessage *>(const_cast<Message *>(message));  
  
     PEGASUS_ASSERT(request != 0);          //
           //  Decrement count of current subscriptions for this provider
     CIMEnableIndicationsResponseMessage * response =          //
         new CIMEnableIndicationsResponseMessage(          if (ph.GetProvider ().decrementSubscriptionsAndTestIfZero ())
         request->messageId,  
         CIMException(),  
         request->queueIds.copyAndPop());  
   
     PEGASUS_ASSERT(response != 0);  
   
     // preserve message key  
     response->setKey(request->getKey());  
   
     //  Set HTTP method in response from request  
     response->setHttpMethod(request->getHttpMethod());  
   
     response->dest = request->queueIds.top();  
   
         CIMInstance req_provider, req_providerModule;  
         ProviderIdContainer pidc = (ProviderIdContainer)request->operationContext.get(ProviderIdContainer::NAME);  
   
         req_provider = pidc.getProvider();  
         req_providerModule = pidc.getModule();  
   
     EnableIndicationsResponseHandler *handler =  
         new EnableIndicationsResponseHandler(  
             request, response, req_provider, _indicationCallback);  
   
   
   
     try  
     {  
           String physicalName=_resolvePhysicalName( req_providerModule.getProperty(  
                                                     req_providerModule.findProperty("Location")).getValue().toString());  
   
           ProviderName name(req_provider.getProperty(req_provider.findProperty("Name")).getValue ().toString (),  
                                   physicalName,  
                                   req_providerModule.getProperty(req_providerModule.findProperty  
                                   ("InterfaceType")).getValue().toString(),  
                                    0);  
   
         // get cached or load new provider module  
         OpProviderHolder ph =  
             providerManager.getProvider(name.getPhysicalName(), name.getLogicalName(), String::EMPTY);  
   
         PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,  
             "Calling provider.enableIndications: " +  
             ph.GetProvider().getName());  
   
         pm_service_op_lock op_lock(&ph.GetProvider());  
         ph.GetProvider().protect();  
   
         ph.GetProvider().enableIndications(*handler);  
   
   
         // if no exception, store the handler so it is persistent for as  
         // long as the provider has indications enabled.  
         PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,  
             "Storing indication handler for " + ph.GetProvider().getName());  
   
         _insertEntry(ph.GetProvider(), handler);  
     }  
     catch(CIMException & e)  
     {  
         PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,  
             "Exception: " + e.getMessage());  
   
         response->cimException = CIMException(e);  
     }  
     catch(Exception & e)  
     {  
         PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,  
             "Exception: " + e.getMessage());  
         response->cimException = CIMException(CIM_ERR_FAILED, MessageLoaderParms(  
             "ProviderManager.DefaultProviderManager.INTERNAL_ERROR",  
             "Internal Error"));  
     }  
     catch(...)  
     {  
         PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,  
             "Exception: Unknown");  
         response->cimException = CIMException(CIM_ERR_FAILED, MessageLoaderParms(  
             "ProviderManager.DefaultProviderManager.UNKNOWN_ERROR",  
             "Unknown Error"));  
     }  
   
     PEG_METHOD_EXIT();  
   
     return(response);  
 }  
   
 Message * DefaultProviderManager::handleDisableIndicationsRequest(const Message * message)  
 { {
     PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManager::handleDisableIndicationsRequest");              //
               //  If there are no current subscriptions after the decrement,
     CIMDisableIndicationsRequestMessage * request =              //  the last subscription has been deleted
         dynamic_cast<CIMDisableIndicationsRequestMessage *>(const_cast<Message *>(message));              //  Call the provider's disableIndications method
               //
     PEGASUS_ASSERT(request != 0);              if (_subscriptionInitComplete)
   
     CIMDisableIndicationsResponseMessage * response =  
         new CIMDisableIndicationsResponseMessage(  
         request->messageId,  
         CIMException(),  
         request->queueIds.copyAndPop());  
   
     // preserve message key  
     response->setKey(request->getKey());  
   
     //  Set HTTP method in response from request  
     response->setHttpMethod (request->getHttpMethod ());  
   
     OperationResponseHandler handler(request, response);  
   
         CIMInstance req_provider, req_providerModule;  
         ProviderIdContainer pidc = (ProviderIdContainer)request->operationContext.get(ProviderIdContainer::NAME);  
   
         req_provider = pidc.getProvider();  
         req_providerModule = pidc.getModule();  
   
     try  
     {     {
        String physicalName=_resolvePhysicalName(  
               req_providerModule.getProperty(  
                 req_providerModule.findProperty("Location")).getValue().toString());  
   
        ProviderName name(  
                req_provider.getProperty(req_provider.findProperty  
                    ("Name")).getValue ().toString (),  
                physicalName,  
                 req_providerModule.getProperty(req_providerModule.findProperty  
                     ("InterfaceType")).getValue().toString(),  
             0);  
         // get cached or load new provider module  
         OpProviderHolder ph =  
             providerManager.getProvider(name.getPhysicalName(), name.getLogicalName(), String::EMPTY);  
   
         PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,         PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,
             "Calling provider.disableIndications: " +             "Calling provider.disableIndications: " +
             ph.GetProvider().getName());             ph.GetProvider().getName());
Line 2297 
Line 2155 
  
         ph.GetProvider().unprotect();         ph.GetProvider().unprotect();
  
                   //
                   //
                   //
         PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,         PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,
             "Removing and Destroying indication handler for " +             "Removing and Destroying indication handler for " +
             ph.GetProvider().getName());             ph.GetProvider().getName());
  
         delete _removeEntry(_generateKey(ph.GetProvider()));         delete _removeEntry(_generateKey(ph.GetProvider()));
     }     }
           }
       }
     catch(CIMException & e)     catch(CIMException & e)
     {     {
         PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,         PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,
             "Exception: " + e.getMessage());             "Exception: " + e.getMessage());
  
         response->cimException = CIMException(e);          handler.setStatus(e.getCode(), e.getContentLanguages(), e.getMessage()); // l10n
     }     }
     catch(Exception & e)     catch(Exception & e)
     {     {
         PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,         PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,
             "Exception: " + e.getMessage());             "Exception: " + e.getMessage());
             response->cimException = CIMException(CIM_ERR_FAILED, MessageLoaderParms(  
             "ProviderManager.DefaultProviderManager.INTERNAL_ERROR",          handler.setStatus(CIM_ERR_FAILED, e.getContentLanguages(), e.getMessage()); // l10n
             "Internal Error"));  
     }     }
     catch(...)     catch(...)
     {     {
         PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,         PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,
             "Exception: Unknown");             "Exception: Unknown");
             response->cimException = CIMException(CIM_ERR_FAILED, MessageLoaderParms(  
             "ProviderManager.DefaultProviderManager.UNKNOWN_ERROR",          handler.setStatus(CIM_ERR_FAILED, "Unknown Error");
             "Unknown Error"));  
     }     }
  
     PEG_METHOD_EXIT();     PEG_METHOD_EXIT();
Line 2365 
Line 2225 
             request->operationContext.get(ProviderIdContainer::NAME));             request->operationContext.get(ProviderIdContainer::NAME));
  
         // get cached or load new provider module         // get cached or load new provider module
         OpProviderHolder ph =          OpProviderHolder ph = providerManager.getProvider(
             providerManager.getProvider(name.getPhysicalName(), name.getLogicalName(), String::EMPTY);              name.getPhysicalName(), name.getLogicalName());
  
                 STAT_GETSTARTTIME                 STAT_GETSTARTTIME
  
Line 2485 
Line 2345 
             }             }
             else if (ret_value == 1)  // Success             else if (ret_value == 1)  // Success
             {             {
                 // if It is an indication provider  
                 // remove the entry from the table since the  
                 // provider has been disabled  
                 if (_indicationProviders[i])                 if (_indicationProviders[i])
                 {                 {
                       //
                       //  Reset the indication provider's count of current
                       //  subscriptions since it has been disabled
                       //
                       if (physicalName.size () > 0)
                       {
                           OpProviderHolder ph = providerManager.getProvider(
                               physicalName, pName);
   
                           ph.GetProvider ().resetSubscriptions ();
                       }
   
                       //
                       //  If it is an indication provider
                       //  remove the entry from the table since the
                       //  provider has been disabled
                       //
                     delete _removeEntry(_generateKey(pName,physicalName));                     delete _removeEntry(_generateKey(pName,physicalName));
                 }                 }
             }             }
Line 2622 
Line 2496 
     return(response);     return(response);
 } }
  
   Message *
   DefaultProviderManager::handleSubscriptionInitCompleteRequest
       (const Message * message)
   {
       PEG_METHOD_ENTER (TRC_PROVIDERMANAGER,
        "DefaultProviderManager::handleSubscriptionInitCompleteRequest");
   
       CIMSubscriptionInitCompleteRequestMessage * request =
           dynamic_cast <CIMSubscriptionInitCompleteRequestMessage *>
               (const_cast <Message *> (message));
   
       PEGASUS_ASSERT (request != 0);
   
       CIMSubscriptionInitCompleteResponseMessage * response =
           dynamic_cast <CIMSubscriptionInitCompleteResponseMessage *>
               (request->buildResponse ());
   
       PEGASUS_ASSERT (response != 0);
   
       //
       //  Set indicator
       //
       _subscriptionInitComplete = true;
   
       //
       //  For each provider that has at least one subscription, call
       //  provider's enableIndications method
       //
       Array <Provider *> enableProviders;
       enableProviders = providerManager.getIndicationProvidersToEnable ();
   
       Uint32 numProviders = enableProviders.size ();
       for (Uint32 i = 0; i < numProviders; i++)
       {
           try
           {
               CIMInstance provider;
               provider = enableProviders [i]->getProviderInstance ();
   
               //
               //  Get cached or load new provider module
               //
               OpProviderHolder ph = providerManager.getProvider(
                   enableProviders[i]->getModule()->getFileName(),
                   enableProviders[i]->getName());
   
               _callEnableIndications (provider, _indicationCallback, ph);
           }
           catch (CIMException & e)
           {
               PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL2,
                   "CIMException: " + e.getMessage ());
           }
           catch (Exception & e)
           {
               PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL2,
                   "Exception: " + e.getMessage ());
           }
           catch(...)
           {
               PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL2,
                   "Unknown error in handleSubscriptionInitCompleteRequest");
           }
       }
   
       PEG_METHOD_EXIT ();
       return (response);
   }
   
 void DefaultProviderManager::_insertEntry ( void DefaultProviderManager::_insertEntry (
     const Provider & provider,     const Provider & provider,
     const EnableIndicationsResponseHandler *handler)     const EnableIndicationsResponseHandler *handler)
Line 2727 
Line 2670 
     providerManager.unloadIdleProviders();     providerManager.unloadIdleProviders();
 } }
  
   void DefaultProviderManager::_callEnableIndications
       (CIMInstance & req_provider,
        PEGASUS_INDICATION_CALLBACK _indicationCallback,
        OpProviderHolder & ph)
   {
       PEG_METHOD_ENTER (TRC_PROVIDERMANAGER,
           "DefaultProviderManager::_callEnableIndications");
   
       try
       {
           CIMRequestMessage * request = 0;
           CIMResponseMessage * response = 0;
           EnableIndicationsResponseHandler * enableHandler =
               new EnableIndicationsResponseHandler
                   (request, response, req_provider, _indicationCallback);
   
           PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL4,
               "Calling provider.enableIndications: " +
               ph.GetProvider ().getName ());
   
           pm_service_op_lock op_lock (& ph.GetProvider ());
           ph.GetProvider ().protect ();
           ph.GetProvider ().enableIndications (* enableHandler);
   
           //
           //  Store the handler so it is persistent for as
           //  long as the provider has indications enabled
           //
           PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL4,
               "Storing indication handler for " +
               ph.GetProvider ().getName ());
   
           _insertEntry (ph.GetProvider (), enableHandler);
       }
       catch (CIMException & e)
       {
           PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL2,
               "CIMException: " + e.getMessage ());
   
           Logger::put_l (Logger::ERROR_LOG, System::CIMSERVER, Logger::WARNING,
               "ProviderManager.Default.DefaultProviderManager."
                   "ENABLE_INDICATIONS_FAILED",
               "Failed to enable indications for provider $0: $1.",
               ph.GetProvider ().getName (), e.getMessage ());
       }
       catch (Exception & e)
       {
           PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL2,
               "Exception: " + e.getMessage ());
   
           Logger::put_l (Logger::ERROR_LOG, System::CIMSERVER, Logger::WARNING,
               "ProviderManager.Default.DefaultProviderManager."
                   "ENABLE_INDICATIONS_FAILED",
               "Failed to enable indications for provider $0: $1.",
               ph.GetProvider ().getName (), e.getMessage ());
       }
       catch(...)
       {
           PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL2,
               "Unexpected error in _callEnableIndications");
   
           Logger::put_l (Logger::ERROR_LOG, System::CIMSERVER, Logger::WARNING,
               "ProviderManager.Default.DefaultProviderManager."
                   "ENABLE_INDICATIONS_FAILED_UNKNOWN",
               "Failed to enable indications for provider $0.",
               ph.GetProvider ().getName ());
       }
   
       PEG_METHOD_EXIT ();
   }
   
 PEGASUS_NAMESPACE_END PEGASUS_NAMESPACE_END

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