cmpi_enumeration.cpp

Pegasus is an open-source implementationof the DMTF CIM and WBEM standards. It is designed to be por

//%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:      Adrian Schuur, [e-mail]
//
// Modified By:
//
//%/////////////////////////////////////////////////////////////////////////////

#include "CMPI_Version.h"

#include "CMPI_Enumeration.h"
#include "CMPI_Object.h"
#include "CMPI_Ftabs.h"

PEGASUS_USING_STD;
PEGASUS_NAMESPACE_BEGIN

extern "C" {

   static CMPIStatus enumRelease(CMPIEnumeration* eObj) {
       if ((void*)eObj->ft==(void*)CMPI_InstEnumeration_Ftab)
       {
           CMPI_InstEnumeration* ie=(CMPI_InstEnumeration*)eObj->hdl;
           if (ie){
               Array<CIMInstance>* enm=(Array<CIMInstance>*)ie->hdl;
               if (enm) {
                   delete enm;
               }
               delete ie;
           }
           (reinterpret_cast<CMPI_Object*>(eObj))->unlinkAndDelete();
       }
       else if ((void*)eObj->ft==(void*)CMPI_ObjEnumeration_Ftab)
       {
           CMPI_ObjEnumeration* ie=(CMPI_ObjEnumeration*)eObj->hdl;
           if (ie){
               Array<CIMObject>* enm=(Array<CIMObject>*)ie->hdl;
               if (enm) {
                   delete enm;
               }
               delete ie;
           }
           (reinterpret_cast<CMPI_Object*>(eObj))->unlinkAndDelete();
       }
       else if ((void*)eObj->ft==(void*)CMPI_OpEnumeration_Ftab)
       {
           CMPI_OpEnumeration* ie=(CMPI_OpEnumeration*)eObj->hdl;
           if (ie){
               Array<CIMObjectPath>* enm=(Array<CIMObjectPath>*)ie->hdl;
               if (enm) {
                   delete enm;
               }
               delete ie;
           }
           (reinterpret_cast<CMPI_Object*>(eObj))->unlinkAndDelete();
       }

      CMReturn(CMPI_RC_OK);
   }

   //static CMPIStatus enumReleaseNop(CMPIEnumeration* eEnum) {
   //   CMReturn(CMPI_RC_OK);
   //}

   static CMPIEnumeration* enumClone(const CMPIEnumeration* eEnum, CMPIStatus* rc) {
   //   CIMInstance* enm=(CIMInstance*)eEnum->hdl;
   //   CIMInstance* cInst=new CIMInstance(enum->clone());
   //   CMPIEnumeration* neEnum=(CMPIEnumeration*)new CMPI_Object(cInst,CMPI_Instance_Ftab);
      if (rc) CMSetStatus(rc,CMPI_RC_ERR_NOT_SUPPORTED);
   //   return neEnum;
      return NULL;
   }

   static CMPIData enumGetNext(const CMPIEnumeration* eEnum, CMPIStatus* rc) {
      CMPIData data={0,CMPI_nullValue,{0}};
      if (!eEnum->hdl)
        {
            if (rc) CMSetStatus(rc, CMPI_RC_ERR_INVALID_PARAMETER);
            return data;
        }
      if ((void*)eEnum->ft==(void*)CMPI_ObjEnumeration_Ftab) {
         CMPI_ObjEnumeration* ie=(CMPI_ObjEnumeration*)eEnum;
         data.type=CMPI_instance;
         Array<CIMInstance>* ia=(Array<CIMInstance>*)ie->hdl;
         if (ie->cursor<ie->max) {
            data.value.inst=reinterpret_cast<CMPIInstance*>
         (new CMPI_Object(new CIMInstance((*ia)[ie->cursor++])));
            if (rc) CMSetStatus(rc,CMPI_RC_OK);
         }
         else if (rc) CMSetStatus(rc,CMPI_RC_ERR_FAILED);
      }

      else if ((void*)eEnum->ft==(void*)CMPI_InstEnumeration_Ftab) {
         CMPI_InstEnumeration* ie=(CMPI_InstEnumeration*)eEnum;
         data.type=CMPI_instance;
         Array<CIMInstance>* ia=(Array<CIMInstance>*)ie->hdl;
         if (ie->cursor<ie->max) {
            data.value.inst=reinterpret_cast<CMPIInstance*>
         (new CMPI_Object(new CIMInstance((*ia)[ie->cursor++])));
            if (rc) CMSetStatus(rc,CMPI_RC_OK);
         }
         else if (rc) CMSetStatus(rc,CMPI_RC_ERR_FAILED);
      }

      else {
         CMPI_OpEnumeration* oe=(CMPI_OpEnumeration*)eEnum;
         data.type=CMPI_ref;
         Array<CIMObjectPath>* opa=(Array<CIMObjectPath>*)oe->hdl;
         if (oe->cursor<oe->max) {
            data.value.ref=reinterpret_cast<CMPIObjectPath*>
         (new CMPI_Object(new CIMObjectPath((*opa)[oe->cursor++])));
            if (rc) CMSetStatus(rc,CMPI_RC_OK);
         }
         else if (rc) CMSetStatus(rc,CMPI_RC_ERR_FAILED);
      }
      return data;
   }

   static CMPIBoolean enumHasNext(const CMPIEnumeration* eEnum, CMPIStatus* rc) {
      if (!eEnum->hdl)
        {
            if (rc) CMSetStatus(rc, CMPI_RC_ERR_INVALID_PARAMETER);
            return false;
        }
      if (rc) CMSetStatus(rc,CMPI_RC_OK);
      if ((void*)eEnum->ft==(void*)CMPI_ObjEnumeration_Ftab) {
         CMPI_ObjEnumeration* ie=(CMPI_ObjEnumeration*)eEnum;
         if (ie->cursor<ie->max) return true;
      }
      else if ((void*)eEnum->ft==(void*)CMPI_InstEnumeration_Ftab) {
         CMPI_InstEnumeration* ie=(CMPI_InstEnumeration*)eEnum;
         if (ie->cursor<ie->max) return true;
      }
      else {
         CMPI_OpEnumeration* oe=(CMPI_OpEnumeration*)eEnum;
         if (oe->cursor<oe->max) return true;
      }
      return false;
   }

   extern CMPIArray* mbEncNewArray(const CMPIBroker* mb, CMPICount count, CMPIType type,
                                 CMPIStatus *rc);
   extern CMPIStatus arraySetElementAt(CMPIArray* eArray, CMPICount pos,
                                       const CMPIValue *val, CMPIType type);

   static CMPIArray* enumToArray(const CMPIEnumeration* eEnum, CMPIStatus* rc) {
      Uint32 size;
      CMPI_Object* obj;
      CMPIArray *nar=NULL;
      if (!eEnum->hdl)
        {
            if (rc) CMSetStatus(rc, CMPI_RC_ERR_INVALID_PARAMETER);
            return NULL;
        }
      if ((void*)eEnum->ft==(void*)CMPI_ObjEnumeration_Ftab ||
         (void*)eEnum->ft==(void*)CMPI_InstEnumeration_Ftab) {
         Array<CIMInstance>* ia;
         if ((void*)eEnum->ft==(void*)CMPI_ObjEnumeration_Ftab) {
            CMPI_ObjEnumeration* ie=(CMPI_ObjEnumeration*)eEnum;
            ia=(Array<CIMInstance>*)ie->hdl;
         }
         else {
            CMPI_InstEnumeration* ie=(CMPI_InstEnumeration*)eEnum;
            ia=(Array<CIMInstance>*)ie->hdl;
         }
         size=ia->size();
         nar=mbEncNewArray(NULL,size,CMPI_instance,NULL);
         for (Uint32 i=0; i<size; i++) {
            CIMInstance &inst=(*ia)[i];
            obj=new CMPI_Object(new CIMInstance(inst));
            arraySetElementAt(nar,i,(CMPIValue*)&obj,CMPI_instance);
         }
      }
      else {
         CMPI_OpEnumeration* oe=(CMPI_OpEnumeration*)eEnum;
         Array<CIMObjectPath>* opa=(Array<CIMObjectPath>*)oe->hdl;
         size=opa->size();
         nar=mbEncNewArray(NULL,size,CMPI_ref,NULL);
         for (Uint32 i=0; i<size; i++) {
            CIMObjectPath &op=(*opa)[i];
            obj=new CMPI_Object(new CIMObjectPath(op));
            arraySetElementAt(nar,i,(CMPIValue*)&obj,CMPI_ref);
         }
      }
      return nar;
   }

}

static CMPIEnumerationFT objEnumeration_FT={
     CMPICurrentVersion,
     enumRelease,
     enumClone,
     enumGetNext,
     enumHasNext,
     enumToArray,
};

static CMPIEnumerationFT instEnumeration_FT={
     CMPICurrentVersion,
     enumRelease,
     enumClone,
     enumGetNext,
     enumHasNext,
     enumToArray,
};

static CMPIEnumerationFT opEnumeration_FT={
     CMPICurrentVersion,
     enumRelease,
     enumClone,
     enumGetNext,
     enumHasNext,
     enumToArray,
};

CMPIEnumerationFT *CMPI_ObjEnumeration_Ftab=&objEnumeration_FT;
CMPIEnumerationFT *CMPI_InstEnumeration_Ftab=&instEnumeration_FT;
CMPIEnumerationFT *CMPI_OpEnumeration_Ftab=&opEnumeration_FT;

CMPI_ObjEnumeration::CMPI_ObjEnumeration(Array<CIMObject>* oa) {
   cursor=0;
   max=oa->size();
   hdl=(void*)oa;
   ft=CMPI_ObjEnumeration_Ftab;
}
CMPI_InstEnumeration::CMPI_InstEnumeration(Array<CIMInstance>* ia) {
   cursor=0;
   max=ia->size();
   hdl=(void*)ia;
   ft=CMPI_InstEnumeration_Ftab;
}

CMPI_OpEnumeration::CMPI_OpEnumeration(Array<CIMObjectPath>* opa) {
   cursor=0;
   max=opa->size();
   hdl=(void*)opa;
   ft=CMPI_OpEnumeration_Ftab;
}

PEGASUS_NAMESPACE_END