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

Diff for /pegasus/src/Pegasus/ProviderManager2/Default/ProviderMessageHandler.cpp between version 1.16 and 1.30

version 1.16, 2008/08/14 17:30:44 version 1.30, 2014/12/06 21:26:30
Line 1 
Line 1 
 //%2006////////////////////////////////////////////////////////////////////////  //%LICENSE////////////////////////////////////////////////////////////////
 // //
 // Copyright (c) 2000, 2001, 2002 BMC Software; Hewlett-Packard Development  // Licensed to The Open Group (TOG) under one or more contributor license
 // Company, L.P.; IBM Corp.; The Open Group; Tivoli Systems.  // agreements.  Refer to the OpenPegasusNOTICE.txt file distributed with
 // Copyright (c) 2003 BMC Software; Hewlett-Packard Development Company, L.P.;  // this work for additional information regarding copyright ownership.
 // IBM Corp.; EMC Corporation, The Open Group.  // Each contributor licenses this file to you under the OpenPegasus Open
 // Copyright (c) 2004 BMC Software; Hewlett-Packard Development Company, L.P.;  // Source License; you may not use this file except in compliance with the
 // IBM Corp.; EMC Corporation; VERITAS Software Corporation; The Open Group.  // License.
 // Copyright (c) 2005 Hewlett-Packard Development Company, L.P.; IBM Corp.;  //
 // EMC Corporation; VERITAS Software Corporation; The Open Group.  // Permission is hereby granted, free of charge, to any person obtaining a
 // Copyright (c) 2006 Hewlett-Packard Development Company, L.P.; IBM Corp.;  // copy of this software and associated documentation files (the "Software"),
 // EMC Corporation; Symantec Corporation; The Open Group.  // to deal in the Software without restriction, including without limitation
 //  // the rights to use, copy, modify, merge, publish, distribute, sublicense,
 // Permission is hereby granted, free of charge, to any person obtaining a copy  // and/or sell copies of the Software, and to permit persons to whom the
 // of this software and associated documentation files (the "Software"), to  // Software is furnished to do so, subject to the following conditions:
 // deal in the Software without restriction, including without limitation the  //
 // rights to use, copy, modify, merge, publish, distribute, sublicense, and/or  // The above copyright notice and this permission notice shall be included
 // sell copies of the Software, and to permit persons to whom the Software is  // in all copies or substantial portions of the Software.
 // furnished to do so, subject to the following conditions:  //
 //  // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS
 // THE ABOVE COPYRIGHT NOTICE AND THIS PERMISSION NOTICE SHALL BE INCLUDED IN  // OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
 // ALL COPIES OR SUBSTANTIAL PORTIONS OF THE SOFTWARE. THE SOFTWARE IS PROVIDED  // MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT.
 // "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING BUT NOT  // IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY
 // LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR  // CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT,
 // PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT  // TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE
 // HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN  // SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
 // ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION  
 // WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.  
 // //
 //==============================================================================  //////////////////////////////////////////////////////////////////////////
 // //
 //%///////////////////////////////////////////////////////////////////////////// //%/////////////////////////////////////////////////////////////////////////////
  
Line 165 
Line 163 
     {     {
         _provider->initialize(cimom);         _provider->initialize(cimom);
     }     }
       catch (CIMException& e)
       {
           PEG_TRACE((TRC_DISCARDED_DATA, Tracer::LEVEL1,
               "Caught CIMexception from provider %s initialize() method."
               " Code: %u Msg: %s",
               (const char*)_fullyQualifiedProviderName.getCString(),
                e.getCode(), cimStatusCodeToString(e.getCode()) ));
           throw;
       }
       catch (Exception& e)
       {
   
           PEG_TRACE((TRC_DISCARDED_DATA, Tracer::LEVEL1,
               "Caught Exception from provider %s initialize() method. %s",
               (const char*)_fullyQualifiedProviderName.getCString(),
               (const char*) e.getMessage().getCString() ));
           throw;
       }
     catch (...)     catch (...)
     {     {
         PEG_TRACE((TRC_DISCARDED_DATA, Tracer::LEVEL1,         PEG_TRACE((TRC_DISCARDED_DATA, Tracer::LEVEL1,
Line 213 
Line 229 
     _subscriptionInitComplete = true;     _subscriptionInitComplete = true;
 } }
  
   void ProviderMessageHandler::indicationServiceDisabled()
   {
       _subscriptionInitComplete = false;
   }
   
 CIMResponseMessage* ProviderMessageHandler::processMessage( CIMResponseMessage* ProviderMessageHandler::processMessage(
     CIMRequestMessage* request)     CIMRequestMessage* request)
 { {
Line 299 
Line 320 
             break;             break;
  
         default:         default:
             PEGASUS_ASSERT(0);              PEGASUS_UNREACHABLE(PEGASUS_ASSERT(0);)
             break;             break;
         }         }
     }     }
     catch (CIMException& e)     catch (CIMException& e)
     {     {
         PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL1,          PEG_TRACE((TRC_PROVIDERMANAGER, Tracer::LEVEL1,"CIMException: %s",
             "CIMException: " + e.getMessage());              (const char*)e.getMessage().getCString()));
         response = request->buildResponse();         response = request->buildResponse();
         response->cimException = PEGASUS_CIM_EXCEPTION_LANG(         response->cimException = PEGASUS_CIM_EXCEPTION_LANG(
             e.getContentLanguages(), e.getCode(), e.getMessage());             e.getContentLanguages(), e.getCode(), e.getMessage());
     }     }
     catch (Exception& e)     catch (Exception& e)
     {     {
         PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL1,          PEG_TRACE((TRC_PROVIDERMANAGER, Tracer::LEVEL1,"Exception: %s",
             "Exception: " + e.getMessage());              (const char*)e.getMessage().getCString()));
         response = request->buildResponse();         response = request->buildResponse();
         response->cimException = PEGASUS_CIM_EXCEPTION_LANG(         response->cimException = PEGASUS_CIM_EXCEPTION_LANG(
             e.getContentLanguages(), CIM_ERR_FAILED, e.getMessage());             e.getContentLanguages(), CIM_ERR_FAILED, e.getMessage());
Line 342 
Line 363 
     providerContext.insert(context.get(AcceptLanguageListContainer::NAME));     providerContext.insert(context.get(AcceptLanguageListContainer::NAME));
     providerContext.insert(context.get(ContentLanguageListContainer::NAME));     providerContext.insert(context.get(ContentLanguageListContainer::NAME));
  
       if (context.contains(UserRoleContainer::NAME))
       {
           providerContext.insert(context.get(UserRoleContainer::NAME));
       }
   
     return providerContext;     return providerContext;
 } }
  
Line 432 
Line 458 
         TRC_PROVIDERMANAGER,         TRC_PROVIDERMANAGER,
         Tracer::LEVEL3,         Tracer::LEVEL3,
         "ProviderMessageHandler::_handleEnumerateInstancesRequest - "         "ProviderMessageHandler::_handleEnumerateInstancesRequest - "
             "Object path: %s",              "Object path: %s MessageId=%s",
         (const char*) objectPath.toString().getCString()));          (const char*) objectPath.toString().getCString(),
           (const char*)message->messageId.getCString()));
  
     OperationContext providerContext(     OperationContext providerContext(
         _createProviderOperationContext(request->operationContext));         _createProviderOperationContext(request->operationContext));
Line 490 
Line 517 
         TRC_PROVIDERMANAGER,         TRC_PROVIDERMANAGER,
         Tracer::LEVEL3,         Tracer::LEVEL3,
         "ProviderMessageHandler::_handleEnumerateInstanceNamesRequest - "         "ProviderMessageHandler::_handleEnumerateInstanceNamesRequest - "
             "Object path: %s",              "Object path: %s messageId=%s",
         (const char*) objectPath.toString().getCString()));          (const char*) objectPath.toString().getCString(),
           (const char*)message->messageId.getCString() ));
  
     OperationContext providerContext(     OperationContext providerContext(
         _createProviderOperationContext(request->operationContext));         _createProviderOperationContext(request->operationContext));
Line 713 
Line 741 
         TRC_PROVIDERMANAGER,         TRC_PROVIDERMANAGER,
         Tracer::LEVEL3,         Tracer::LEVEL3,
         "ProviderMessageHandler::_handleExecQueryRequest - "         "ProviderMessageHandler::_handleExecQueryRequest - "
             "Object path: %s",              "Object path: %s MessageId=%s",
         (const char*) objectPath.toString().getCString()));          (const char*) objectPath.toString().getCString(),
           (const char*)message->messageId.getCString()));
  
     QueryExpression qx(request->queryLanguage,request->query);     QueryExpression qx(request->queryLanguage,request->query);
  
Line 772 
Line 801 
         TRC_PROVIDERMANAGER,         TRC_PROVIDERMANAGER,
         Tracer::LEVEL3,         Tracer::LEVEL3,
         "ProviderMessageHandler::_handleAssociatorsRequest - "         "ProviderMessageHandler::_handleAssociatorsRequest - "
             "Object path: %s",              "Object path: %s MessageId=%s",
         (const char*) objectPath.toString().getCString()));          (const char*) objectPath.toString().getCString(),
           (const char*)message->messageId.getCString()));
  
     CIMObjectPath assocPath(     CIMObjectPath assocPath(
         System::getHostName(),         System::getHostName(),
Line 840 
Line 870 
         TRC_PROVIDERMANAGER,         TRC_PROVIDERMANAGER,
         Tracer::LEVEL3,         Tracer::LEVEL3,
         "ProviderMessageHandler::_handleAssociationNamesRequest - "         "ProviderMessageHandler::_handleAssociationNamesRequest - "
             "Object path: %s",              "Object path: %s MessageId=%s",
         (const char*) objectPath.toString().getCString()));          (const char*) objectPath.toString().getCString(),
           (const char*)message->messageId.getCString()));
  
     CIMObjectPath assocPath(     CIMObjectPath assocPath(
         System::getHostName(),         System::getHostName(),
Line 905 
Line 936 
         TRC_PROVIDERMANAGER,         TRC_PROVIDERMANAGER,
         Tracer::LEVEL3,         Tracer::LEVEL3,
         "ProviderMessageHandler::_handleReferencesRequest - "         "ProviderMessageHandler::_handleReferencesRequest - "
             "Object path: %s",              "Object path: %s MessageId=%s",
         (const char*) objectPath.toString().getCString()));          (const char*) objectPath.toString().getCString(),
           (const char*)message->messageId.getCString()));
  
     CIMObjectPath resultPath(     CIMObjectPath resultPath(
         System::getHostName(),         System::getHostName(),
Line 971 
Line 1003 
         TRC_PROVIDERMANAGER,         TRC_PROVIDERMANAGER,
         Tracer::LEVEL3,         Tracer::LEVEL3,
         "ProviderMessageHandler::_handleReferenceNamesRequest - "         "ProviderMessageHandler::_handleReferenceNamesRequest - "
             "Object path: %s",              "Object path: %s MessageId=%s",
         (const char*) objectPath.toString().getCString()));          (const char*) objectPath.toString().getCString(),
           (const char*)message->messageId.getCString()));
  
     CIMObjectPath resultPath(      // KS_TODO Confirm that the following is cruft and not needed.
         System::getHostName(),  //    CIMObjectPath resultPath(
         request->nameSpace,  //       System::getHostName(),
         request->resultClass.getString());  //        request->nameSpace,
   //        request->resultClass.getString());
  
     OperationContext providerContext(     OperationContext providerContext(
         _createProviderOperationContext(request->operationContext));         _createProviderOperationContext(request->operationContext));
Line 1029 
Line 1063 
         request->messageId,         request->messageId,
         request->nameSpace,         request->nameSpace,
         request->instanceName,         request->instanceName,
         false,  // localOnly  
         false,  // includeQualifiers         false,  // includeQualifiers
         false,  // includeClassOrigin         false,  // includeClassOrigin
         propertyList,         propertyList,
Line 1094 
Line 1127 
  
     if (response->cimException.getCode() == CIM_ERR_SUCCESS)     if (response->cimException.getCode() == CIM_ERR_SUCCESS)
     {     {
         CIMInstance instance = getInstanceResponse->cimInstance;          CIMInstance instance =
               getInstanceResponse->getResponseData().getInstance();
  
         Uint32 pos = instance.findProperty(request->propertyName);         Uint32 pos = instance.findProperty(request->propertyName);
  
Line 1583 
Line 1617 
     providerContext.insert(request->operationContext.get(     providerContext.insert(request->operationContext.get(
         ContentLanguageListContainer::NAME));         ContentLanguageListContainer::NAME));
  
     AutoPThreadSecurity threadLevelSecurity(providerContext);  
   
     CIMIndicationConsumerProvider* provider =     CIMIndicationConsumerProvider* provider =
         getProviderInterface<CIMIndicationConsumerProvider>(_provider);         getProviderInterface<CIMIndicationConsumerProvider>(_provider);
  

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