version 1.43.2.8, 2013/09/15 23:00:27
|
version 1.43.2.11, 2013/11/20 02:22:03
|
|
|
#endif | #endif |
binaryRequest = request->binaryRequest; | binaryRequest = request->binaryRequest; |
binaryResponse = request->binaryResponse; | binaryResponse = request->binaryResponse; |
|
internalOperation = request->internalOperation; |
} | } |
| |
CIMResponseMessage* CIMGetClassRequestMessage::buildResponse() const | CIMResponseMessage* CIMGetClassRequestMessage::buildResponse() const |
|
|
return response.release(); | return response.release(); |
} | } |
| |
|
CIMResponseMessage* |
|
CIMPullInstancesRequestMessage::buildResponse() const |
|
{ |
|
AutoPtr<CIMPullInstancesResponseMessage> response( |
|
new CIMPullInstancesResponseMessage( |
|
messageId, |
|
CIMException(), |
|
queueIds.copyAndPop(), |
|
false, |
|
enumerationContext)); |
|
response->syncAttributes(this); |
|
return response.release(); |
|
} |
|
|
CIMResponseMessage* CIMCloseEnumerationRequestMessage::buildResponse() const | CIMResponseMessage* CIMCloseEnumerationRequestMessage::buildResponse() const |
{ | { |
AutoPtr<CIMCloseEnumerationResponseMessage> response( | AutoPtr<CIMCloseEnumerationResponseMessage> response( |
|
|
| |
binaryRequest = false; | binaryRequest = false; |
binaryResponse = false; | binaryResponse = false; |
|
internalOperation = false; |
} | } |
| |
#ifndef PEGASUS_DISABLE_PERFINST | #ifndef PEGASUS_DISABLE_PERFINST |
|
|
Uint64 serverTimeMicroseconds = | Uint64 serverTimeMicroseconds = |
_totalServerTimeMicroseconds - _providerTimeMicroseconds; | _totalServerTimeMicroseconds - _providerTimeMicroseconds; |
| |
Uint16 statType = (Uint16)((getType() >= CIM_GET_CLASS_RESPONSE_MESSAGE) ? |
MessageType msgType = getType(); |
getType() - CIM_GET_CLASS_RESPONSE_MESSAGE : getType() - 1); |
StatisticalData::current()->addToValue(serverTimeMicroseconds, |
|
msgType, |
StatisticalData::current()->addToValue(serverTimeMicroseconds, statType, |
|
StatisticalData::PEGASUS_STATDATA_SERVER); | StatisticalData::PEGASUS_STATDATA_SERVER); |
| |
StatisticalData::current()->addToValue(_providerTimeMicroseconds, statType, |
StatisticalData::current()->addToValue(_providerTimeMicroseconds, |
|
msgType, |
StatisticalData::PEGASUS_STATDATA_PROVIDER); | StatisticalData::PEGASUS_STATDATA_PROVIDER); |
| |
/* This adds the number of bytes read to the total.the request size | /* This adds the number of bytes read to the total.the request size |
|
|
| |
StatisticalData::current()->addToValue( | StatisticalData::current()->addToValue( |
StatisticalData::current()->requSize, | StatisticalData::current()->requSize, |
statType, |
msgType, |
StatisticalData::PEGASUS_STATDATA_BYTES_READ); | StatisticalData::PEGASUS_STATDATA_BYTES_READ); |
} | } |
#endif | #endif |
|
|
enumerationContext(enumerationContext_) | enumerationContext(enumerationContext_) |
{ | { |
} | } |
|
|
CIMPullInstancesWithPathResponseMessage:: | CIMPullInstancesWithPathResponseMessage:: |
CIMPullInstancesWithPathResponseMessage( | CIMPullInstancesWithPathResponseMessage( |
const String& messageId_, | const String& messageId_, |
|
|
{ | { |
} | } |
| |
|
CIMPullInstancesResponseMessage:: |
|
CIMPullInstancesResponseMessage( |
|
const String& messageId_, |
|
const CIMException& cimException_, |
|
const QueueIdStack& queueIds_, |
|
const Boolean endOfSequence_, |
|
const String& enumerationContext_ |
|
) |
|
: CIMResponseDataMessage(CIM_PULL_INSTANCES_RESPONSE_MESSAGE, |
|
messageId_, cimException_, queueIds_,CIMResponseData::RESP_INSTANCES), |
|
endOfSequence(endOfSequence_), |
|
enumerationContext(enumerationContext_) |
|
{ |
|
} |
|
|
CIMCloseEnumerationResponseMessage:: | CIMCloseEnumerationResponseMessage:: |
CIMCloseEnumerationResponseMessage( | CIMCloseEnumerationResponseMessage( |
const String& messageId_, | const String& messageId_, |