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

Diff for /pegasus/src/Pegasus/ProviderManager2/OperationResponseHandler.cpp between version 1.11.8.5 and 1.12

version 1.11.8.5, 2006/03/17 21:40:51 version 1.12, 2006/01/10 19:41:20
Line 1 
Line 1 
 //%2006////////////////////////////////////////////////////////////////////////  //%2005////////////////////////////////////////////////////////////////////////
 // //
 // Copyright (c) 2000, 2001, 2002 BMC Software; Hewlett-Packard Development // Copyright (c) 2000, 2001, 2002 BMC Software; Hewlett-Packard Development
 // Company, L.P.; IBM Corp.; The Open Group; Tivoli Systems. // Company, L.P.; IBM Corp.; The Open Group; Tivoli Systems.
Line 8 
Line 8 
 // IBM Corp.; EMC Corporation; VERITAS Software Corporation; The Open Group. // IBM Corp.; EMC Corporation; VERITAS Software Corporation; The Open Group.
 // Copyright (c) 2005 Hewlett-Packard Development Company, L.P.; IBM Corp.; // Copyright (c) 2005 Hewlett-Packard Development Company, L.P.; IBM Corp.;
 // EMC Corporation; VERITAS Software Corporation; The Open Group. // EMC Corporation; VERITAS Software Corporation; The Open Group.
 // Copyright (c) 2006 Hewlett-Packard Development Company, L.P.; IBM Corp.;  
 // EMC Corporation; Symantec Corporation; The Open Group.  
 // //
 // Permission is hereby granted, free of charge, to any person obtaining a copy // Permission is hereby granted, free of charge, to any person obtaining a copy
 // of this software and associated documentation files (the "Software"), to // of this software and associated documentation files (the "Software"), to
Line 33 
Line 31 
 // //
 // Modified By: // Modified By:
 //         Brian G. Campbell, EMC (campbell_brian@emc.com) - PEP140/phase2 //         Brian G. Campbell, EMC (campbell_brian@emc.com) - PEP140/phase2
 //         Roger Kumpf, Hewlett-Packard Company (roger_kumpf@hp.com)  
 // //
 //%///////////////////////////////////////////////////////////////////////////// //%/////////////////////////////////////////////////////////////////////////////
  
 #include "OperationResponseHandler.h" #include "OperationResponseHandler.h"
  
 #include <Pegasus/Common/Logger.h> #include <Pegasus/Common/Logger.h>
 #include <Pegasus/Provider/CIMOMHandle.h>  
  
 PEGASUS_NAMESPACE_BEGIN  #include <Pegasus/ProviderManager2/ProviderManagerService.h>
   
 /**********************************************************  
  * Define CIMOMHandleContext class  
  **********************************************************/  
 class CIMOMHandleContext : public NormalizerContext  
 {  
 public:  
     CIMOMHandleContext() {}  
     virtual ~CIMOMHandleContext() {}  
   
     virtual CIMClass getClass(  
               const CIMNamespaceName& nameSpace,  
               const CIMName& name);  
   
     virtual Array<CIMName> enumerateClassNames(  
         const CIMNamespaceName& nameSpace, const CIMName& className,  
         bool deepInheritance);  
   
     virtual AutoPtr<NormalizerContext> clone();  
  
 protected:  PEGASUS_NAMESPACE_BEGIN
     CIMOMHandleContext(CIMOMHandle & hndl) : handle(hndl) {}  
 private:  
     CIMOMHandleContext(const CIMOMHandleContext &);  
     operator=(const CIMOMHandleContext &);  
     CIMOMHandle handle;  
     OperationContext emptyContext;  
 };  
   
 CIMClass CIMOMHandleContext::getClass(  
     const CIMNamespaceName& nameSpace,  
     const CIMName& name)  
 {  
     // Get the whole class definition  
     return handle.getClass(emptyContext, nameSpace, name, false, true, true,  
         CIMPropertyList());  
 }  
   
 Array<CIMName> CIMOMHandleContext::enumerateClassNames(  
     const CIMNamespaceName& nameSpace, const CIMName& className,  
     bool deepInheritance)  
 {  
     return handle.enumerateClassNames(emptyContext, nameSpace, className,  
         deepInheritance);  
 }  
   
 AutoPtr<NormalizerContext> CIMOMHandleContext::clone()  
 {  
   AutoPtr<NormalizerContext> tmpPtr(new CIMOMHandleContext(handle));  
   return tmpPtr;  
 }  
   
 /**********************************************************  
  * End CIMOMHandleContext class  
  **********************************************************/  
  
 // //
 // OperationResponseHandler // OperationResponseHandler
Line 105 
Line 48 
  
 OperationResponseHandler::OperationResponseHandler( OperationResponseHandler::OperationResponseHandler(
     CIMRequestMessage *request,     CIMRequestMessage *request,
     CIMResponseMessage *response,      CIMResponseMessage *response)
     PEGASUS_RESPONSE_CHUNK_CALLBACK_T responseChunkCallback)  
     : _request(request),     : _request(request),
     _response(response),     _response(response),
     _responseChunkCallback(responseChunkCallback),  
     _responseObjectTotal(0),     _responseObjectTotal(0),
     _responseMessageTotal(0),     _responseMessageTotal(0),
     _responseObjectThreshold(0)     _responseObjectThreshold(0)
Line 121 
Line 62 
  #define PEGASUS_RESPONSE_OBJECT_COUNT_THRESHOLD  ~0  #define PEGASUS_RESPONSE_OBJECT_COUNT_THRESHOLD  ~0
 #endif #endif
  
     if (!request)      if (!request || (request->requestIsOOP == true))
     {     {
         _responseObjectThreshold = ~0;         _responseObjectThreshold = ~0;
     }     }
Line 283 
Line 224 
  
         if (isComplete == false)         if (isComplete == false)
         {         {
             _responseChunkCallback(_request, _response);                  ProviderManagerService::handleCimResponse(*_request, *_response);
         }         }
  
         // put caller's allocated response back in place. Note that _response         // put caller's allocated response back in place. Note that _response
Line 326 
Line 267 
  
 GetInstanceResponseHandler::GetInstanceResponseHandler( GetInstanceResponseHandler::GetInstanceResponseHandler(
     CIMGetInstanceRequestMessage* request,     CIMGetInstanceRequestMessage* request,
     CIMGetInstanceResponseMessage* response,      CIMGetInstanceResponseMessage * response)
     PEGASUS_RESPONSE_CHUNK_CALLBACK_T responseChunkCallback)      : OperationResponseHandler(request, response)
     : OperationResponseHandler(request, response, responseChunkCallback)  
 { {
     #ifdef PEGASUS_ENABLE_OBJECT_NORMALIZATION     #ifdef PEGASUS_ENABLE_OBJECT_NORMALIZATION
     // Attempt to get the cached class definition used to validate results of this     // Attempt to get the cached class definition used to validate results of this
Line 342 
Line 282 
             request->operationContext.get(CachedClassDefinitionContainer::NAME);             request->operationContext.get(CachedClassDefinitionContainer::NAME);
  
         cimClass = container.getClass();         cimClass = container.getClass();
   
     }     }
     catch(Exception &)     catch(Exception &)
     {     {
Line 349 
Line 290 
         // for this operation.         // for this operation.
     }     }
  
     AutoPtr<NormalizerContext> tmpContext(new CIMOMHandleContext());      _normalizer =
     ObjectNormalizer tmpNormalizer(          ObjectNormalizer(
         cimClass,         cimClass,
         request->includeQualifiers,         request->includeQualifiers,
         request->includeClassOrigin,              request->includeClassOrigin);
         request->nameSpace,  
         tmpContext);  
     _normalizer = tmpNormalizer;  
     #endif     #endif
 } }
  
Line 444 
Line 382 
  
 EnumerateInstancesResponseHandler::EnumerateInstancesResponseHandler( EnumerateInstancesResponseHandler::EnumerateInstancesResponseHandler(
     CIMEnumerateInstancesRequestMessage* request,     CIMEnumerateInstancesRequestMessage* request,
     CIMEnumerateInstancesResponseMessage* response,      CIMEnumerateInstancesResponseMessage * response)
     PEGASUS_RESPONSE_CHUNK_CALLBACK_T responseChunkCallback)      : OperationResponseHandler(request, response)
     : OperationResponseHandler(request, response, responseChunkCallback)  
 { {
     #ifdef PEGASUS_ENABLE_OBJECT_NORMALIZATION     #ifdef PEGASUS_ENABLE_OBJECT_NORMALIZATION
     // Attempt to get the cached class definition used to validate results of this     // Attempt to get the cached class definition used to validate results of this
Line 467 
Line 404 
         // for this operation.         // for this operation.
     }     }
  
     AutoPtr<NormalizerContext> tmpContext(new CIMOMHandleContext());      _normalizer =
     ObjectNormalizer tmpNormalizer(          ObjectNormalizer(
         cimClass,         cimClass,
         request->includeQualifiers,         request->includeQualifiers,
         request->includeClassOrigin,              request->includeClassOrigin);
         request->nameSpace,  
         tmpContext);  
     _normalizer = tmpNormalizer;  
 #endif #endif
 } }
  
Line 515 
Line 449 
  
 EnumerateInstanceNamesResponseHandler::EnumerateInstanceNamesResponseHandler( EnumerateInstanceNamesResponseHandler::EnumerateInstanceNamesResponseHandler(
     CIMEnumerateInstanceNamesRequestMessage* request,     CIMEnumerateInstanceNamesRequestMessage* request,
     CIMEnumerateInstanceNamesResponseMessage* response,      CIMEnumerateInstanceNamesResponseMessage * response)
     PEGASUS_RESPONSE_CHUNK_CALLBACK_T responseChunkCallback)      : OperationResponseHandler(request, response)
     : OperationResponseHandler(request, response, responseChunkCallback)  
 { {
     #ifdef PEGASUS_ENABLE_OBJECT_NORMALIZATION     #ifdef PEGASUS_ENABLE_OBJECT_NORMALIZATION
     // Attempt to get the cached class definition used to validate results of this     // Attempt to get the cached class definition used to validate results of this
Line 538 
Line 471 
         // for this operation.         // for this operation.
     }     }
  
     AutoPtr<NormalizerContext> tmpContext(new CIMOMHandleContext());      _normalizer =
     ObjectNormalizer tmpNormalizer(          ObjectNormalizer(
         cimClass,         cimClass,
         false,         false,
         false,              false);
         request->nameSpace,  
         tmpContext);  
     _normalizer = tmpNormalizer;  
 #endif #endif
 } }
  
Line 586 
Line 516 
  
 CreateInstanceResponseHandler::CreateInstanceResponseHandler( CreateInstanceResponseHandler::CreateInstanceResponseHandler(
     CIMCreateInstanceRequestMessage* request,     CIMCreateInstanceRequestMessage* request,
     CIMCreateInstanceResponseMessage* response,      CIMCreateInstanceResponseMessage * response)
     PEGASUS_RESPONSE_CHUNK_CALLBACK_T responseChunkCallback)      : OperationResponseHandler(request, response)
     : OperationResponseHandler(request, response, responseChunkCallback)  
 { {
 } }
  
Line 662 
Line 591 
  
 ModifyInstanceResponseHandler::ModifyInstanceResponseHandler( ModifyInstanceResponseHandler::ModifyInstanceResponseHandler(
     CIMModifyInstanceRequestMessage* request,     CIMModifyInstanceRequestMessage* request,
     CIMModifyInstanceResponseMessage* response,      CIMModifyInstanceResponseMessage * response)
     PEGASUS_RESPONSE_CHUNK_CALLBACK_T responseChunkCallback)      : OperationResponseHandler(request, response)
     : OperationResponseHandler(request, response, responseChunkCallback)  
 { {
 } }
  
Line 679 
Line 607 
  
 DeleteInstanceResponseHandler::DeleteInstanceResponseHandler( DeleteInstanceResponseHandler::DeleteInstanceResponseHandler(
     CIMDeleteInstanceRequestMessage* request,     CIMDeleteInstanceRequestMessage* request,
     CIMDeleteInstanceResponseMessage* response,      CIMDeleteInstanceResponseMessage * response)
     PEGASUS_RESPONSE_CHUNK_CALLBACK_T responseChunkCallback)      : OperationResponseHandler(request, response)
     : OperationResponseHandler(request, response, responseChunkCallback)  
 { {
 } }
  
Line 696 
Line 623 
  
 GetPropertyResponseHandler::GetPropertyResponseHandler( GetPropertyResponseHandler::GetPropertyResponseHandler(
     CIMGetPropertyRequestMessage* request,     CIMGetPropertyRequestMessage* request,
     CIMGetPropertyResponseMessage* response,      CIMGetPropertyResponseMessage * response)
     PEGASUS_RESPONSE_CHUNK_CALLBACK_T responseChunkCallback)      : OperationResponseHandler(request, response)
     : OperationResponseHandler(request, response, responseChunkCallback)  
 { {
 } }
  
Line 748 
Line 674 
  
 SetPropertyResponseHandler::SetPropertyResponseHandler( SetPropertyResponseHandler::SetPropertyResponseHandler(
     CIMSetPropertyRequestMessage* request,     CIMSetPropertyRequestMessage* request,
     CIMSetPropertyResponseMessage* response,      CIMSetPropertyResponseMessage * response)
     PEGASUS_RESPONSE_CHUNK_CALLBACK_T responseChunkCallback)      : OperationResponseHandler(request, response)
     : OperationResponseHandler(request, response, responseChunkCallback)  
 { {
 } }
  
Line 765 
Line 690 
  
 ExecQueryResponseHandler::ExecQueryResponseHandler( ExecQueryResponseHandler::ExecQueryResponseHandler(
     CIMExecQueryRequestMessage* request,     CIMExecQueryRequestMessage* request,
     CIMExecQueryResponseMessage* response,      CIMExecQueryResponseMessage * response)
     PEGASUS_RESPONSE_CHUNK_CALLBACK_T responseChunkCallback)      : OperationResponseHandler(request, response)
     : OperationResponseHandler(request, response, responseChunkCallback)  
 { {
 } }
  
Line 809 
Line 733 
  
 AssociatorsResponseHandler::AssociatorsResponseHandler( AssociatorsResponseHandler::AssociatorsResponseHandler(
     CIMAssociatorsRequestMessage* request,     CIMAssociatorsRequestMessage* request,
     CIMAssociatorsResponseMessage* response,      CIMAssociatorsResponseMessage * response)
     PEGASUS_RESPONSE_CHUNK_CALLBACK_T responseChunkCallback)      : OperationResponseHandler(request, response)
     : OperationResponseHandler(request, response, responseChunkCallback)  
 { {
 } }
  
Line 848 
Line 771 
  
 AssociatorNamesResponseHandler::AssociatorNamesResponseHandler( AssociatorNamesResponseHandler::AssociatorNamesResponseHandler(
     CIMAssociatorNamesRequestMessage* request,     CIMAssociatorNamesRequestMessage* request,
     CIMAssociatorNamesResponseMessage* response,      CIMAssociatorNamesResponseMessage * response)
     PEGASUS_RESPONSE_CHUNK_CALLBACK_T responseChunkCallback)      : OperationResponseHandler(request, response)
     : OperationResponseHandler(request, response, responseChunkCallback)  
 { {
 } }
  
Line 887 
Line 809 
  
 ReferencesResponseHandler::ReferencesResponseHandler( ReferencesResponseHandler::ReferencesResponseHandler(
     CIMReferencesRequestMessage* request,     CIMReferencesRequestMessage* request,
     CIMReferencesResponseMessage* response,      CIMReferencesResponseMessage * response)
     PEGASUS_RESPONSE_CHUNK_CALLBACK_T responseChunkCallback)      : OperationResponseHandler(request, response)
     : OperationResponseHandler(request, response, responseChunkCallback)  
 { {
 } }
  
Line 926 
Line 847 
  
 ReferenceNamesResponseHandler::ReferenceNamesResponseHandler( ReferenceNamesResponseHandler::ReferenceNamesResponseHandler(
     CIMReferenceNamesRequestMessage* request,     CIMReferenceNamesRequestMessage* request,
     CIMReferenceNamesResponseMessage* response,      CIMReferenceNamesResponseMessage * response)
     PEGASUS_RESPONSE_CHUNK_CALLBACK_T responseChunkCallback)      : OperationResponseHandler(request, response)
     : OperationResponseHandler(request, response, responseChunkCallback)  
 { {
 } }
  
Line 965 
Line 885 
  
 InvokeMethodResponseHandler::InvokeMethodResponseHandler( InvokeMethodResponseHandler::InvokeMethodResponseHandler(
     CIMInvokeMethodRequestMessage* request,     CIMInvokeMethodRequestMessage* request,
     CIMInvokeMethodResponseMessage* response,      CIMInvokeMethodResponseMessage * response)
     PEGASUS_RESPONSE_CHUNK_CALLBACK_T responseChunkCallback)      : OperationResponseHandler(request, response)
     : OperationResponseHandler(request, response, responseChunkCallback)  
 { {
 } }
  
Line 1021 
Line 940 
 // EnableIndicationsResponseHandler // EnableIndicationsResponseHandler
 // //
  
   typedef void (*PEGASUS_INDICATION_CALLBACK)(CIMProcessIndicationRequestMessage*);
   
 EnableIndicationsResponseHandler::EnableIndicationsResponseHandler( EnableIndicationsResponseHandler::EnableIndicationsResponseHandler(
     CIMRequestMessage* request,     CIMRequestMessage* request,
     CIMResponseMessage* response,     CIMResponseMessage* response,
     CIMInstance& provider,     CIMInstance& provider,
     PEGASUS_INDICATION_CALLBACK_T indicationCallback,      PEGASUS_INDICATION_CALLBACK indicationCallback)
     PEGASUS_RESPONSE_CHUNK_CALLBACK_T responseChunkCallback)      : OperationResponseHandler(request, response),
     : OperationResponseHandler(request, response, responseChunkCallback),  
       _indicationCallback(indicationCallback)       _indicationCallback(indicationCallback)
 { {
     _provider = provider;     _provider = provider;

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