|
version 1.2, 2004/10/17 20:40:01
|
version 1.3, 2004/10/25 18:26:00
|
|
|
|
| // Author: Chip Vincent (cvincent@us.ibm.com) | // Author: Chip Vincent (cvincent@us.ibm.com) |
| // | // |
| // Modified By: | // Modified By: |
| // |
// Brian G. Campbell, EMC (campbell_brian@emc.com) - PEP140/phase2 |
| //%///////////////////////////////////////////////////////////////////////////// | //%///////////////////////////////////////////////////////////////////////////// |
| | |
| #include "OperationResponseHandler.h" | #include "OperationResponseHandler.h" |
| |
#include "ProviderManagerService.h" |
| | |
| PEGASUS_NAMESPACE_BEGIN | PEGASUS_NAMESPACE_BEGIN |
| | |
| |
OperationResponseHandler::OperationResponseHandler |
| |
(CIMRequestMessage *request, |
| |
CIMResponseMessage *response) : |
| |
_request(request), _response(response) |
| |
{ |
| |
|
| |
#ifndef PEGASUS_RESPONSE_OBJECT_COUNT_THRESHOLD |
| |
#define PEGASUS_RESPONSE_OBJECT_COUNT_THRESHOLD 100 |
| |
#elif PEGASUS_RESPONSE_OBJECT_COUNT_THRESHOLD == 0 |
| |
#undef PEGASUS_RESPONSE_OBJECT_COUNT_THRESHOLD |
| |
#define PEGASUS_RESPONSE_OBJECT_COUNT_THRESHOLD ~0 |
| |
#endif |
| |
|
| |
_responseObjectTotal = 0; |
| |
_responseMessageTotal = 0; |
| |
_responseObjectThreshold = PEGASUS_RESPONSE_OBJECT_COUNT_THRESHOLD; |
| |
|
| |
#ifdef PEGASUS_DEBUG |
| |
static const char *responseObjectThreshold = |
| |
getenv("PEGASUS_RESPONSE_OBJECT_COUNT_THRESHOLD"); |
| |
if (responseObjectThreshold) |
| |
{ |
| |
Uint32 i = (Uint32) atoi(responseObjectThreshold); |
| |
if (i > 0) |
| |
_responseObjectThreshold = i; |
| |
} |
| |
#endif |
| |
} |
| |
|
| |
OperationResponseHandler::~OperationResponseHandler() |
| |
{ |
| |
_request = 0; |
| |
_response = 0; |
| |
} |
| |
|
| |
// This is only called from SimpleResponseHandler.deliver() but lives in this |
| |
// class because all asyncronous response must have a "response" pointer |
| |
// to go through. Only operation classes have a response pointer |
| |
|
| |
void OperationResponseHandler::send(Boolean isComplete) |
| |
{ |
| |
// some handlers do not send async because their callers cannot handle |
| |
// partial responses. If this is the case, stop here. |
| |
|
| |
if (isAsync() == false) |
| |
{ |
| |
// preserve tradional behavior |
| |
if (isComplete == true) |
| |
transfer(); |
| |
return; |
| |
} |
| |
|
| |
SimpleResponseHandler *simpleP = dynamic_cast<SimpleResponseHandler*>(this); |
| |
|
| |
// It is possible to instantiate this class directly (not derived) |
| |
// The caller would do this only if the operation does not have any data to |
| |
// be returned |
| |
|
| |
if (! simpleP) |
| |
{ |
| |
// if there is no data to be returned, then the message should NEVER be |
| |
// incomplete (even on an error) |
| |
if (isComplete == false) |
| |
PEGASUS_ASSERT(false); |
| |
return; |
| |
} |
| |
|
| |
SimpleResponseHandler &simple = *simpleP; |
| |
PEGASUS_ASSERT(_response); |
| |
Uint32 objectCount = simple.size(); |
| |
|
| |
// have not reached threshold yet |
| |
if (isComplete == false && objectCount < _responseObjectThreshold) |
| |
return; |
| |
|
| |
CIMResponseMessage *response = _response; |
| |
|
| |
// for complete responses, just use the one handed down from caller |
| |
// otherwise, create our own that the caller never sees but is |
| |
// utilized for async responses underneath |
| |
|
| |
if (isComplete == false) |
| |
_response = _request->buildResponse(); |
| |
|
| |
_response->setComplete(isComplete); |
| |
_responseObjectTotal += objectCount; |
| |
|
| |
// since we are reusing response for every chunk,keep track of original count |
| |
_response->setIndex(_responseMessageTotal++); |
| |
|
| |
// set the originally allocated response to one more than the current. |
| |
// The reason for doing this is proactive in case of an exception. This |
| |
// allows the last response to be set as it may not re-enter this code. |
| |
|
| |
if (isComplete == false) |
| |
response->setIndex(_responseMessageTotal); |
| |
|
| |
validate(); |
| |
|
| |
if (_response->cimException.getCode() != CIM_ERR_SUCCESS) |
| |
simple.clear(); |
| |
|
| |
String function = getClass() + "::" + "transfer"; |
| |
Logger::put(Logger::STANDARD_LOG, System::CIMSERVER, Logger::TRACE, |
| |
function); |
| |
|
| |
transfer(); |
| |
simple.clear(); |
| |
|
| |
// l10n |
| |
_response->operationContext. |
| |
set(ContentLanguageListContainer(simple.getLanguages())); |
| |
|
| |
// call thru ProviderManager to get externally declared entry point |
| |
|
| |
if (isComplete == false) |
| |
{ |
| |
ProviderManagerService::handleCimResponse(*_request, *_response); |
| |
} |
| |
|
| |
// put caller's allocated response back in place. Note that _response |
| |
// is INVALID after sending because it has been deleted externally |
| |
|
| |
_response = response; |
| |
} |
| |
|
| PEGASUS_NAMESPACE_END | PEGASUS_NAMESPACE_END |
Return to
OperationResponseHandler.cpp
CVS log
Up to [Pegasus] / pegasus / src / Pegasus / ProviderManager2