Return to WMIBaseProvider.cpp CVS log | Up to [Pegasus] / pegasus / src / WMIMapper / WMIProvider |
File: [Pegasus] / pegasus / src / WMIMapper / WMIProvider / WMIBaseProvider.cpp
(download)
Revision: 1.9, Mon Jan 30 16:19:38 2006 UTC (18 years, 5 months ago) by karl Branch: MAIN CVS Tags: TASK_PEP233_EmbeddedInstSupport-merge_out_trunk, TASK_BUG_5314_IPC_REFACTORING_ROOT, TASK_BUG_5314_IPC_REFACTORING_BRANCH, TASK_BUG_5314_IPC_REFACTORING-V1, TASK_BUG_5191_QUEUE_CONSOLIDATION_ROOT, TASK_BUG_5191_QUEUE_CONSOLIDATION_BRANCH, TASK-TASK-BUG4011_WinLocalConnect-branch-New-root, TASK-TASK-BUG4011_WinLocalConnect-branch-New-merged_out_to_branch, TASK-TASK-BUG4011_WinLocalConnect-branch-New-merged_out_from_trunk, TASK-TASK-BUG4011_WinLocalConnect-branch-New-merged_in_to_trunk, TASK-TASK-BUG4011_WinLocalConnect-branch-New-merged_in_from_branch, TASK-TASK-BUG4011_WinLocalConnect-branch-New-branch, TASK-PEP268_SSLClientCertificatePropagation-root, TASK-PEP268_SSLClientCertificatePropagation-merged_out_to_branch, TASK-PEP268_SSLClientCertificatePropagation-merged_out_from_trunk, TASK-PEP268_SSLClientCertificatePropagation-merged_in_to_trunk, TASK-PEP268_SSLClientCertificatePropagation-merged_in_from_branch, TASK-PEP268_SSLClientCertificatePropagation-branch, TASK-PEP267_SLPReregistrationSupport-root, TASK-PEP267_SLPReregistrationSupport-merging_out_to_branch, TASK-PEP267_SLPReregistrationSupport-merging_out_from_trunk, TASK-PEP267_SLPReregistrationSupport-merged_out_to_branch, TASK-PEP267_SLPReregistrationSupport-merged_out_from_trunk, TASK-PEP267_SLPReregistrationSupport-merged_in_to_trunk, TASK-PEP267_SLPReregistrationSupport-merged_in_from_branch, TASK-PEP267_SLPReregistrationSupport-branch, TASK-PEP250_RPMProvider-root, TASK-PEP250_RPMProvider-merged_out_to_branch, TASK-PEP250_RPMProvider-merged_out_from_trunk, TASK-PEP250_RPMProvider-merged_in_to_trunk, TASK-PEP250_RPMProvider-merged_in_from_branch, TASK-PEP250_RPMProvider-branch, TASK-PEP245_CimErrorInfrastructure-root, TASK-PEP245_CimErrorInfrastructure-merged_out_to_branch, TASK-PEP245_CimErrorInfrastructure-merged_out_from_trunk, TASK-PEP245_CimErrorInfrastructure-merged_in_to_trunk, TASK-PEP245_CimErrorInfrastructure-merged_in_from_branch, TASK-PEP245_CimErrorInfrastructure-branch, TASK-PEP241_OpenPegasusStressTests-root, TASK-PEP241_OpenPegasusStressTests-merged_out_to_branch, TASK-PEP241_OpenPegasusStressTests-merged_out_from_trunk, TASK-PEP241_OpenPegasusStressTests-merged_in_to_trunk, TASK-PEP241_OpenPegasusStressTests-merged_in_from_branch, TASK-PEP241_OpenPegasusStressTests-branch, TASK-Bugs5690_3913_RemoteCMPI-root, TASK-Bugs5690_3913_RemoteCMPI-merged_out_to_branch, TASK-Bugs5690_3913_RemoteCMPI-merged_out_from_trunk, TASK-Bugs5690_3913_RemoteCMPI-merged_in_to_trunk, TASK-Bugs5690_3913_RemoteCMPI-merged_in_from_branch, TASK-Bugs5690_3913_RemoteCMPI-branch, TASK-Bug2102_RCMPIWindows-root, TASK-Bug2102_RCMPIWindows-merged_out_to_branch, TASK-Bug2102_RCMPIWindows-merged_out_from_trunk, TASK-Bug2102_RCMPIWindows-merged_in_to_trunk, TASK-Bug2102_RCMPIWindows-merged_in_from_branch, TASK-Bug2102_RCMPIWindows-branch, TASK-Bug2021_RemoteCMPIonWindows-root, TASK-Bug2021_RemoteCMPIonWindows-merged_out_to_branch, TASK-Bug2021_RemoteCMPIonWindows-merged_out_from_trunk, TASK-Bug2021_RemoteCMPIonWindows-merged_in_to_trunk, TASK-Bug2021_RemoteCMPIonWindows-merged_in_from_branch, TASK-Bug2021_RemoteCMPIonWindows-branch, TASK-Bug2021_RCMPIonWindows-root, TASK-Bug2021_RCMPIonWindows-merged_out_to_branch, TASK-Bug2021_RCMPIonWindows-merged_out_from_trunk, TASK-Bug2021_RCMPIonWindows-merged_in_to_trunk, TASK-Bug2021_RCMPIonWindows-merged_in_from_branch, TASK-Bug2021_RCMPIonWindows-branch, TASK-BUG4011_WinLocalConnect-root, TASK-BUG4011_WinLocalConnect-merged_out_to_branch, TASK-BUG4011_WinLocalConnect-merged_out_from_trunk, TASK-BUG4011_WinLocalConnect-merged_in_to_trunk, TASK-BUG4011_WinLocalConnect-merged_in_from_branch, TASK-BUG4011_WinLocalConnect-branch-New, TASK-BUG4011_WinLocalConnect-branch, RELEASE_2_6_0-RC1, RELEASE_2_6_0-FC, RELEASE_2_6_0, RELEASE_2_6-root, RELEASE_2_5_5-RC2, RELEASE_2_5_5-RC1, RELEASE_2_5_5, RELEASE_2_5_4-RC2, RELEASE_2_5_4-RC1, RELEASE_2_5_4, RELEASE_2_5_3-RC1, RELEASE_2_5_3, RELEASE_2_5_2-RC1, RELEASE_2_5_2, RELEASE_2_5_1-RC1, RELEASE_2_5_1, RELEASE_2_5-root, RELEASE_2_5-branch, PEP286_PRIVILEGE_SEPARATION_ROOT, PEP286_PRIVILEGE_SEPARATION_CODE_FREEZE, PEP286_PRIVILEGE_SEPARATION_BRANCH, PEP286_PRIVILEGE_SEPARATION_1 Branch point for: RELEASE_2_6-branch Changes since 1.8: +3 -1 lines BUG#: 4691 TITLE: Update Licenses to 2006 DESCRIPTION: Updates most of the licenses to 2006. The slp_client directories are excluded for the moment pending discussion. This change has passed unit and system tests. Note that this changes just about EVERY file in Pegasus. |
//%2006//////////////////////////////////////////////////////////////////////// // // Copyright (c) 2000, 2001, 2002 BMC Software; Hewlett-Packard Development // Company, L.P.; IBM Corp.; The Open Group; Tivoli Systems. // Copyright (c) 2003 BMC Software; Hewlett-Packard Development Company, L.P.; // IBM Corp.; EMC Corporation, The Open Group. // Copyright (c) 2004 BMC Software; Hewlett-Packard Development Company, L.P.; // IBM Corp.; EMC Corporation; VERITAS Software Corporation; The Open Group. // Copyright (c) 2005 Hewlett-Packard Development Company, L.P.; IBM Corp.; // 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 // of this software and associated documentation files (the "Software"), to // deal in the Software without restriction, including without limitation the // rights to use, copy, modify, merge, publish, distribute, sublicense, and/or // sell copies of the Software, and to permit persons to whom the Software is // furnished to do so, subject to the following conditions: // // THE ABOVE COPYRIGHT NOTICE AND THIS PERMISSION NOTICE SHALL BE INCLUDED IN // ALL COPIES OR SUBSTANTIAL PORTIONS OF THE SOFTWARE. THE SOFTWARE IS PROVIDED // "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING BUT NOT // LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR // PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT // HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN // ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION // WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE. // //============================================================================== // // Author: Barbara Packard (barbara_packard@hp.com) // // Modified By: Adriano Zanuz (adriano.zanuz@hp.com) // Jair Santos, Hewlett-Packard Company (jair.santos@hp.com) // Mateus Baur, Hewlett-Packard Company (jair.santos@hp.com) // //%///////////////////////////////////////////////////////////////////////////// // WMIBaseProvider.cpp: implementation of the WMIBaseProvider class. // ////////////////////////////////////////////////////////////////////// #include "stdafx.h" #include "WMICollector.h" #include "WMIBaseProvider.h" #include "WMIClassProvider.h" #include "WMIInstanceProvider.h" #include "WMIQueryProvider.h" #include "WMIProperty.h" #include "WMIString.h" #include "WMIValue.h" #include "WMIQualifier.h" #include "WMIQualifierSet.h" #include "WMIType.h" #include "WMIException.h" PEGASUS_NAMESPACE_BEGIN ////////////////////////////////////////////////////////////////////// // Construction/Destruction ////////////////////////////////////////////////////////////////////// WMIBaseProvider::WMIBaseProvider() { } WMIBaseProvider::~WMIBaseProvider() { } ///////////////////////////////////////////////////////////////////////////// // WMIBaseProvider::initialize // // /////////////////////////////////////////////////////////////////////////// void WMIBaseProvider::initialize(bool bLocal) { PEG_METHOD_ENTER(TRC_WMIPROVIDER,"WMIBaseProvider::initialize()"); initCollector(bLocal); PEG_METHOD_EXIT(); } ///////////////////////////////////////////////////////////////////////////// // WMIBaseProvider::terminate // // /////////////////////////////////////////////////////////////////////////// void WMIBaseProvider::terminate(void) { PEG_METHOD_ENTER(TRC_WMIPROVIDER,"WMIBaseProvider::terminate()"); cleanup(); PEG_METHOD_EXIT(); } ///////////////////////////////////////////////////////////////////////////// // WMIBaseProvider::setup // ///////////////////////////////////////////////////////////////////////////// void WMIBaseProvider::setup(const String & nameSpace, const String & userName, const String & password) { m_sNamespace = nameSpace; m_sUserName = userName; m_sPassword = password; if (!m_bInitialized) { initCollector(); } if (m_bInitialized) { _collector->setNamespace(m_sNamespace); if (m_sUserName != String::EMPTY) _collector->setUserName(m_sUserName); if (m_sPassword != String::EMPTY) _collector->setPassword(m_sPassword); } } ///////////////////////////////////////////////////////////////////////////// // WMIBaseProvider::initCollector // // /////////////////////////////////////////////////////////////////////////// void WMIBaseProvider::initCollector(bool bLocal) { if (!m_bInitialized) { _collector = new WMICollector(bLocal); m_bInitialized = _collector->setup(); } } ///////////////////////////////////////////////////////////////////////////// // WMIBaseProvider::cleanup // // /////////////////////////////////////////////////////////////////////////// void WMIBaseProvider::cleanup() { if (m_bInitialized) { _collector->terminate(); delete _collector; _collector = NULL; m_bInitialized = false; } } ///////////////////////////////////////////////////////////////////////////// // WMIBaseProvider::getCIMInstance - retrieves a CIMInstance object // // /////////////////////////////////////////////////////////////////////////// CIMInstance WMIBaseProvider::getCIMInstance(const String& nameSpace, const String& userName, const String& password, const CIMObjectPath &instanceName, const CIMPropertyList &propertyList) { CIMInstance cimInstance; CIMStatusCode errorCode = CIM_ERR_SUCCESS; String errorDescription; WMIInstanceProvider provider; PEG_METHOD_ENTER(TRC_WMIPROVIDER,"WMIBaseProvider::getCIMInstance()"); try { // This fix uses the current boolean value stored in collector // to initialize it. provider.initialize(_collector->isLocalConnection()); cimInstance = provider.getInstance(nameSpace, userName, password, instanceName, false, false, false, propertyList); provider.terminate(); } catch(CIMException& exception) { provider.terminate(); errorCode = exception.getCode(); errorDescription = exception.getMessage(); throw PEGASUS_CIM_EXCEPTION(errorCode, errorDescription); } catch(Exception& exception) { provider.terminate(); errorCode = CIM_ERR_FAILED; errorDescription = exception.getMessage(); throw PEGASUS_CIM_EXCEPTION(errorCode, errorDescription); } catch(...) { provider.terminate(); throw CIMException(CIM_ERR_FAILED); } PEG_METHOD_EXIT(); return cimInstance; } ///////////////////////////////////////////////////////////////////////////// // WMIBaseProvider::getCIMClass - retrieves a CIMClass object // // /////////////////////////////////////////////////////////////////////////// CIMClass WMIBaseProvider::getCIMClass(const String& nameSpace, const String& userName, const String& password, const String& className, const CIMPropertyList &propertyList) { CIMClass cimClass; CIMStatusCode errorCode = CIM_ERR_SUCCESS; String errorDescription; WMIClassProvider provider; PEG_METHOD_ENTER(TRC_WMIPROVIDER,"WMIBaseProvider::getCIMClass()"); try { // This fix uses the current boolean value stored in collector // to initialize it. provider.initialize(_collector->isLocalConnection()); cimClass = provider.getClass(nameSpace, userName, password, className, false, true, true, propertyList); provider.terminate(); } catch(CIMException& exception) { provider.terminate(); errorCode = exception.getCode(); errorDescription = exception.getMessage(); throw PEGASUS_CIM_EXCEPTION(errorCode, errorDescription); } catch(Exception& exception) { provider.terminate(); errorCode = CIM_ERR_FAILED; errorDescription = exception.getMessage(); throw PEGASUS_CIM_EXCEPTION(errorCode, errorDescription); } catch(...) { provider.terminate(); throw CIMException(CIM_ERR_FAILED); } PEG_METHOD_EXIT(); return cimClass; } ///////////////////////////////////////////////////////////////////////////// // WMIBaseProvider::execCIMQuery - retrieves a query result // // /////////////////////////////////////////////////////////////////////////// Array<CIMObject> WMIBaseProvider::execCIMQuery( const String& nameSpace, const String& userName, const String& password, const String& queryLanguage, const String& query, const CIMPropertyList& propertyList, Boolean includeQualifiers, Boolean includeClassOrigin) { Array<CIMObject> objects; CIMInstance cimInstance; CIMStatusCode errorCode = CIM_ERR_SUCCESS; String errorDescription; WMIQueryProvider provider; PEG_METHOD_ENTER(TRC_WMIPROVIDER,"WMIBaseProvider::execCIMQuery()"); try { // This fix uses the current boolean value stored in collector // to initialize it. provider.initialize(_collector->isLocalConnection()); objects = provider.execQuery(nameSpace, userName, password, queryLanguage, query, propertyList, includeQualifiers, includeClassOrigin); provider.terminate(); } catch(CIMException& exception) { provider.terminate(); errorCode = exception.getCode(); errorDescription = exception.getMessage(); throw PEGASUS_CIM_EXCEPTION(errorCode, errorDescription); } catch(Exception& exception) { provider.terminate(); errorCode = CIM_ERR_FAILED; errorDescription = exception.getMessage(); throw PEGASUS_CIM_EXCEPTION(errorCode, errorDescription); } catch(...) { provider.terminate(); throw CIMException(CIM_ERR_FAILED); } PEG_METHOD_EXIT(); return objects; } ////////////////////////////////////////////////////////////////////////////// // WMIBaseProvider::getQueryString - builds the query string from the // input parameters for Associator and Reference commands // // /////////////////////////////////////////////////////////////////////////// String WMIBaseProvider::getQueryString(const CIMObjectPath &objectName, const String &sQueryCommand, const String &assocClass, const String &resultClass, const String &role, const String &resultRole) { bool hasWHERE = false; bool isInst; //first we need to get the object name String sObjName = getObjectName(objectName); // check if is an instance name Uint32 pos = sObjName.find(qString(Q_PERIOD)); isInst = (PEG_NOT_FOUND != pos); CMyString sQuery; sQuery.Format(CMyString(sQueryCommand), 128, CMyString(sObjName)); //set up any optional parameters if (!((0 == assocClass.size()) && (0 == resultClass.size()) && (0 == role.size()) && (0 == resultRole.size()))) { // we have optional parameters, append the appropriate ones sQuery += qChar(Q_WHERE); hasWHERE = true; if (0 != assocClass.size()) { sQuery += qChar(Q_ASSOC_CLS); sQuery += assocClass; } if (0 != resultClass.size()) { sQuery += qChar(Q_RESULT_CLASS); sQuery += resultClass; } if (0 != role.size()) { sQuery += qChar(Q_ROLE); sQuery += role; } if (0 != resultRole.size()) { sQuery += qChar(Q_RESULT_ROLE); sQuery += resultRole; } } // check if an instance if (!isInst) { // have a class, add "SchemaOnly" if (!hasWHERE) { sQuery += qChar(Q_WHERE); } sQuery += qChar(Q_SCHEMA); } Tracer::trace(TRC_WMIPROVIDER, Tracer::LEVEL3, "WMIBaseProvider::getQueryString() - Query is %s", (LPCTSTR)sQuery); String s = (LPCTSTR)sQuery; return s; } ////////////////////////////////////////////////////////////////////////////// // WMIBaseProvider::getObjectName - extracts the String object name from // CIMObjectPath // removes namespace // // Possible input Object Path formats: // 1. Fully-qualified path // example: \\hostname:port\root\cimv2:ClassName.Key1="Value",Key2="Value" // // 2. No hostname & port (implies current host) // example: root\cimv2:ClassName.Key1="Value",Key2="Value" // // 3. No namespace (implies current namespace): // example: ClassName.Key1="Value",Key2="Value" // // 4. Reference instance // example: ClassName.Key1=R"root\cimv2:RefClass.Key="RefValue"" // // In all cases, this method needs to return only the class name and keys from // the input object path (need to strip any hostname, port, and namespace). // For example, the return for cases #1-3, above, should be: // ClassName.Key1="Value",Key2="Value" // // Also, for "reference" keys, the reference indicator (R) needs to be removed. // Therefore, the output from case #4, above, would be: // ClassName.Key1="root\cimv2:RefClass.Key="RefValue"" // // /////////////////////////////////////////////////////////////////////////// String WMIBaseProvider::getObjectName( const CIMObjectPath& objectName) { String sObjName; String sObjNameLower; bool bHaveReference = false; PEG_METHOD_ENTER(TRC_WMIPROVIDER,"WMIBaseProvider::getObjectName()"); sObjName = objectName.toString(); sObjNameLower = sObjName; sObjNameLower.toLower(); Tracer::trace(TRC_WMIPROVIDER, Tracer::LEVEL3, "WMIBaseProvider::getObjectName() - ObjectName: %s", sObjName.getCString()); Uint32 pos; // 1. if Object name initiates with a hostname then remove it if ((sObjName.subString(0, 4) != "root") && (sObjNameLower.subString(0, 2) != "//") && (sObjNameLower.subString(0, 2) != "\\\\")) { pos = sObjNameLower.find("root"); if (sObjNameLower.find("=") > pos) { if (PEG_NOT_FOUND != pos) { sObjName.remove(0, pos); sObjNameLower.remove(0, pos); } } } //2. Remove the machine name and port if it exists if ((sObjNameLower.subString(0, 2) == "//") || (sObjNameLower.subString(0, 2) == "\\\\")) { pos = sObjNameLower.find("root"); if (PEG_NOT_FOUND != pos) { sObjName.remove(0, pos); sObjNameLower.remove(0, pos); } //3. After ensuring that all stuff before root was removed, // get the class/instance name. pos = sObjName.find(qString(Q_COLON)); if (PEG_NOT_FOUND != pos) { sObjName.remove(0, pos + 1); } } else { // get the class/instance name. if (sObjNameLower.subString(0, 4) == "root") { pos = sObjName.find(qString(Q_COLON)); if (PEG_NOT_FOUND != pos) { sObjName.remove(0, pos + 1); } } } //4. Check if has =R".." for a reference instance and // if so, remove the R //Uint32 pos = sObjName.find(qString(Q_REF_KEY)); pos = sObjName.find(qString(Q_REF_KEY)); bHaveReference = (PEG_NOT_FOUND != pos); if (bHaveReference) { while (PEG_NOT_FOUND != pos) { sObjName.remove(pos + 1, 1); //removing R" pos = sObjName.find(qString(Q_REF_KEY)); } } Tracer::trace(TRC_WMIPROVIDER, Tracer::LEVEL3, "WMIBaseProvider::getObjectName() - ObjectName: %s", sObjName.getCString()); PEG_METHOD_EXIT(); return sObjName; } PEGASUS_NAMESPACE_END
No CVS admin address has been configured |
Powered by ViewCVS 0.9.2 |