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

version 1.11.8.3, 2006/03/07 18:45:56 version 1.13, 2006/01/30 16:18:01
Line 33 
Line 33 
 // //
 // 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)  
 // //
 //%///////////////////////////////////////////////////////////////////////////// //%/////////////////////////////////////////////////////////////////////////////
  
Line 41 
Line 40 
  
 #include <Pegasus/Common/Logger.h> #include <Pegasus/Common/Logger.h>
  
   #include <Pegasus/ProviderManager2/ProviderManagerService.h>
   
 PEGASUS_NAMESPACE_BEGIN PEGASUS_NAMESPACE_BEGIN
  
 // //
Line 49 
Line 50 
  
 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 65 
Line 64 
  #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 227 
Line 226 
  
         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 270 
Line 269 
  
 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 280 
Line 278 
     // operation.     // operation.
     CIMClass cimClass;     CIMClass cimClass;
  
     NormalizerContext * context = 0;  
   
     try     try
     {     {
         CachedClassDefinitionContainer container =         CachedClassDefinitionContainer container =
             request->operationContext.get(CachedClassDefinitionContainer::NAME);             request->operationContext.get(CachedClassDefinitionContainer::NAME);
  
         cimClass = container.getClass();         cimClass = container.getClass();
 #ifdef PEGASUS_EMBEDDED_INSTANCE_SUPPORT  
         NormalizerContextContainer contextContainer =  
             request->operationContext.get(NormalizerContextContainer::NAME);  
         context = contextContainer.getContext();  
 #endif //PEGASUS_EMBEDDED_INSTANCE_SUPPORT  
     }     }
     catch(Exception &)     catch(Exception &)
     {     {
Line 304 
Line 296 
         ObjectNormalizer(         ObjectNormalizer(
             cimClass,             cimClass,
             request->includeQualifiers,             request->includeQualifiers,
             request->includeClassOrigin,              request->includeClassOrigin);
             request->nameSpace,  
             context);  
     #endif     #endif
 } }
  
Line 394 
Line 384 
  
 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
     // operation. If it does not exist, then this feature is disabled for this     // operation. If it does not exist, then this feature is disabled for this
     // operation.     // operation.
     CIMClass cimClass;     CIMClass cimClass;
     NormalizerContext * context = 0;  
  
     try     try
     {     {
Line 411 
Line 399 
             request->operationContext.get(CachedClassDefinitionContainer::NAME);             request->operationContext.get(CachedClassDefinitionContainer::NAME);
  
         cimClass = container.getClass();         cimClass = container.getClass();
 #ifdef PEGASUS_EMBEDDED_INSTANCE_SUPPORT  
         NormalizerContextContainer contextContainer =  
             request->operationContext.get(NormalizerContextContainer::NAME);  
         context = contextContainer.getContext();  
 #endif // PEGASUS_EMBEDDED_INSTANCE_SUPPORT  
     }     }
     catch(Exception &)     catch(Exception &)
     {     {
Line 427 
Line 410 
         ObjectNormalizer(         ObjectNormalizer(
             cimClass,             cimClass,
             request->includeQualifiers,             request->includeQualifiers,
             request->includeClassOrigin,              request->includeClassOrigin);
             request->nameSpace,  
             context);  
     #endif     #endif
 } }
  
Line 470 
Line 451 
  
 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
     // operation. If it does not exist, then this feature is disabled for this     // operation. If it does not exist, then this feature is disabled for this
     // operation.     // operation.
     CIMClass cimClass;     CIMClass cimClass;
     NormalizerContext * context = 0;  
  
     try     try
     {     {
Line 487 
Line 466 
             request->operationContext.get(CachedClassDefinitionContainer::NAME);             request->operationContext.get(CachedClassDefinitionContainer::NAME);
  
         cimClass = container.getClass();         cimClass = container.getClass();
 #ifdef PEGASUS_EMBEDDED_INSTANCE_SUPPORT  
         NormalizerContextContainer contextContainer =  
             request->operationContext.get(NormalizerContextContainer::NAME);  
         context = contextContainer.getContext();  
 #endif // PEGASUS_EMBEDDED_INSTANCE_SUPPORT  
     }     }
     catch(Exception &)     catch(Exception &)
     {     {
Line 503 
Line 477 
         ObjectNormalizer(         ObjectNormalizer(
             cimClass,             cimClass,
             false,             false,
             false,              false);
             request->nameSpace,  
             context);  
     #endif     #endif
 } }
  
Line 546 
Line 518 
  
 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 622 
Line 593 
  
 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 639 
Line 609 
  
 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 656 
Line 625 
  
 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 708 
Line 676 
  
 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 725 
Line 692 
  
 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 769 
Line 735 
  
 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 808 
Line 773 
  
 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 847 
Line 811 
  
 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 886 
Line 849 
  
 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 925 
Line 887 
  
 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 981 
Line 942 
 // 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.3  
changed lines
  Added in v.1.13
No CVS admin address has been configured
 Powered by
ViewCVS 0.9.2