version 1.76, 2009/06/30 10:31:29
|
version 1.77, 2009/07/09 09:19:37
|
|
|
_connected(false), | _connected(false), |
_doReconnect(false), | _doReconnect(false), |
_binaryRequest(false), | _binaryRequest(false), |
_binaryResponse(false) |
_binaryResponse(false), |
|
_localConnect(false) |
{ | { |
// | // |
// Create Monitor and HTTPConnector | // Create Monitor and HTTPConnector |
|
|
_authenticator.clear(); | _authenticator.clear(); |
_authenticator.setAuthType(ClientAuthenticator::LOCAL); | _authenticator.setAuthType(ClientAuthenticator::LOCAL); |
| |
|
_localConnect=true; |
|
|
#ifndef PEGASUS_DISABLE_LOCAL_DOMAIN_SOCKET | #ifndef PEGASUS_DISABLE_LOCAL_DOMAIN_SOCKET |
_connectSSLContext.reset(); | _connectSSLContext.reset(); |
_connectHost = String::EMPTY; | _connectHost = String::EMPTY; |
|
|
_disconnect(); | _disconnect(); |
_authenticator.clear(); | _authenticator.clear(); |
_connectSSLContext.reset(); | _connectSSLContext.reset(); |
|
_localConnect=false; |
} | } |
| |
Boolean CIMClientRep::isConnected() const throw() | Boolean CIMClientRep::isConnected() const throw() |
|
|
return _connected; | return _connected; |
} | } |
| |
|
Boolean CIMClientRep::isLocalConnect() const throw() |
|
{ |
|
return _localConnect; |
|
} |
|
|
AcceptLanguageList CIMClientRep::getRequestAcceptLanguages() const | AcceptLanguageList CIMClientRep::getRequestAcceptLanguages() const |
{ | { |
return requestAcceptLanguages; | return requestAcceptLanguages; |
|
|
return response->getResponseData().getCimInstance(); | return response->getResponseData().getCimInstance(); |
} | } |
| |
|
#if defined(PEGASUS_ENABLE_PROTOCOL_BINARY) |
|
Array<Uint8> CIMClientRep::getBinaryInstance( |
|
const CIMNamespaceName& nameSpace, |
|
const CIMObjectPath& instanceName, |
|
Boolean localOnly, |
|
Boolean includeQualifiers, |
|
Boolean includeClassOrigin, |
|
const CIMPropertyList& propertyList) |
|
{ |
|
AutoPtr<CIMRequestMessage> request(new CIMGetInstanceRequestMessage( |
|
String::EMPTY, |
|
nameSpace, |
|
instanceName, |
|
includeQualifiers, |
|
includeClassOrigin, |
|
propertyList, |
|
QueueIdStack())); |
|
dynamic_cast<CIMGetInstanceRequestMessage*>(request.get())->localOnly = |
|
localOnly; |
|
|
|
Message* message = _doRequest(request, CIM_GET_INSTANCE_RESPONSE_MESSAGE); |
|
|
|
CIMGetInstanceResponseMessage* response = |
|
(CIMGetInstanceResponseMessage*)message; |
|
|
|
AutoPtr<CIMGetInstanceResponseMessage> destroyer(response); |
|
|
|
return response->getResponseData().getBinaryCimInstance(); |
|
} |
|
#endif // PEGASUS_ENABLE_PROTOCOL_BINARY |
|
|
|
|
void CIMClientRep::deleteClass( | void CIMClientRep::deleteClass( |
const CIMNamespaceName& nameSpace, | const CIMNamespaceName& nameSpace, |
const CIMName& className) | const CIMName& className) |
|
|
return response->getResponseData().getNamedInstances(); | return response->getResponseData().getNamedInstances(); |
} | } |
| |
|
#if defined(PEGASUS_ENABLE_PROTOCOL_BINARY) |
|
Array<Uint8> CIMClientRep::enumerateBinaryInstances( |
|
const CIMNamespaceName& nameSpace, |
|
const CIMName& className, |
|
Boolean deepInheritance, |
|
Boolean localOnly, |
|
Boolean includeQualifiers, |
|
Boolean includeClassOrigin, |
|
const CIMPropertyList& propertyList) |
|
{ |
|
AutoPtr<CIMRequestMessage> request(new CIMEnumerateInstancesRequestMessage( |
|
String::EMPTY, |
|
nameSpace, |
|
className, |
|
deepInheritance, |
|
includeQualifiers, |
|
includeClassOrigin, |
|
propertyList, |
|
QueueIdStack())); |
|
dynamic_cast<CIMEnumerateInstancesRequestMessage*>( |
|
request.get())->localOnly = localOnly; |
|
|
|
Message* message = |
|
_doRequest(request, CIM_ENUMERATE_INSTANCES_RESPONSE_MESSAGE); |
|
|
|
CIMEnumerateInstancesResponseMessage* response = |
|
(CIMEnumerateInstancesResponseMessage*)message; |
|
|
|
AutoPtr<CIMEnumerateInstancesResponseMessage> destroyer(response); |
|
|
|
|
|
return response->getResponseData().getBinaryCimInstances(); |
|
} |
|
#endif // PEGASUS_ENABLE_PROTOCOL_BINARY |
|
|
Array<CIMObjectPath> CIMClientRep::enumerateInstanceNames( | Array<CIMObjectPath> CIMClientRep::enumerateInstanceNames( |
const CIMNamespaceName& nameSpace, | const CIMNamespaceName& nameSpace, |
const CIMName& className) | const CIMName& className) |
|
|
return response->getResponseData().getCIMObjects(); | return response->getResponseData().getCIMObjects(); |
} | } |
| |
|
#if defined(PEGASUS_ENABLE_PROTOCOL_BINARY) |
|
Array<Uint8> CIMClientRep::execQueryBinary( |
|
const CIMNamespaceName& nameSpace, |
|
const String& queryLanguage, |
|
const String& query) |
|
{ |
|
AutoPtr<CIMRequestMessage> request(new CIMExecQueryRequestMessage( |
|
String::EMPTY, |
|
nameSpace, |
|
queryLanguage, |
|
query, |
|
QueueIdStack())); |
|
|
|
Message* message = _doRequest(request, CIM_EXEC_QUERY_RESPONSE_MESSAGE); |
|
|
|
CIMExecQueryResponseMessage* response = |
|
(CIMExecQueryResponseMessage*)message; |
|
|
|
AutoPtr<CIMExecQueryResponseMessage> destroyer(response); |
|
|
|
return response->getResponseData().getBinaryCimObjects(); |
|
} |
|
#endif |
|
|
Array<CIMObject> CIMClientRep::associators( | Array<CIMObject> CIMClientRep::associators( |
const CIMNamespaceName& nameSpace, | const CIMNamespaceName& nameSpace, |
const CIMObjectPath& objectName, | const CIMObjectPath& objectName, |
|
|
return response->getResponseData().getCIMObjects(); | return response->getResponseData().getCIMObjects(); |
} | } |
| |
|
#if defined(PEGASUS_ENABLE_PROTOCOL_BINARY) |
|
Array<Uint8> CIMClientRep::associatorsBinary( |
|
const CIMNamespaceName& nameSpace, |
|
const CIMObjectPath& objectName, |
|
const CIMName& assocClass, |
|
const CIMName& resultClass, |
|
const String& role, |
|
const String& resultRole, |
|
Boolean includeQualifiers, |
|
Boolean includeClassOrigin, |
|
const CIMPropertyList& propertyList) |
|
{ |
|
AutoPtr<CIMRequestMessage> request(new CIMAssociatorsRequestMessage( |
|
String::EMPTY, |
|
nameSpace, |
|
objectName, |
|
assocClass, |
|
resultClass, |
|
role, |
|
resultRole, |
|
includeQualifiers, |
|
includeClassOrigin, |
|
propertyList, |
|
QueueIdStack())); |
|
|
|
Message* message = _doRequest(request, CIM_ASSOCIATORS_RESPONSE_MESSAGE); |
|
|
|
CIMAssociatorsResponseMessage* response = |
|
(CIMAssociatorsResponseMessage*)message; |
|
|
|
AutoPtr<CIMAssociatorsResponseMessage> destroyer(response); |
|
|
|
return response->getResponseData().getBinaryCimObjects(); |
|
} |
|
#endif |
|
|
Array<CIMObjectPath> CIMClientRep::associatorNames( | Array<CIMObjectPath> CIMClientRep::associatorNames( |
const CIMNamespaceName& nameSpace, | const CIMNamespaceName& nameSpace, |
const CIMObjectPath& objectName, | const CIMObjectPath& objectName, |