---

rmBaseArray.h

Go to the documentation of this file.

#ifndef __rmBaseArray_h
#define __rmBaseArray_h

#include <map>
#include "rmClientError.h"
#include <stdio.h>
#include <uuid/uuid.h>
#include "rmClientTypes.h"

class IBaseAccessor
{
  public: 

    virtual int getInteger32(RMAttribute aName, unsigned long aID, long & aValue) = 0;
    virtual int setInteger32(RMAttribute aName, unsigned long aID, long aValue) = 0;

    virtual int getUnsigned(RMAttribute aName, unsigned long aID, unsigned long & aValue) = 0;

    virtual int setUnsigned(RMAttribute aName, unsigned long aID, unsigned long aValue) = 0;

    virtual int getUnsigned64(RMAttribute aName, unsigned long aID, u_int64_t & aValue) = 0;

    virtual int setUnsigned64(RMAttribute aName, unsigned long aID, u_int64_t aValue) = 0;

    virtual int getUUIDString(RMAttribute aName, unsigned long aID, char * aUUIDStr) = 0;

    virtual int setUUIDString(RMAttribute aName, unsigned long aID, char * aUUIDStr) = 0;

    virtual int getUUID(RMAttribute aName, unsigned long aID, uuid_t aUUID) = 0;

    virtual int getString(RMAttribute aName, unsigned long aID, char * & aBuf) = 0;

    virtual int setString(RMAttribute aName, unsigned long aID, char * aBuf) = 0;
    virtual int getBinary(RMAttribute aName, unsigned long aID, char * & aBuf, unsigned long & aLength) = 0;

    virtual int addDefaultElement(unsigned long aID) = 0;

    virtual int removeElement(unsigned long aID) = 0;

    virtual unsigned long getNewId(void) = 0;

    virtual int findExactId(unsigned long aID) = 0;

    virtual int getNextId(unsigned long aID, unsigned long & aNextID) = 0;

    virtual size_t getCount() const = 0;
 };

template<class T> 
class rmBaseArray : public IBaseAccessor
{
  public: 
    rmBaseArray() : mMaxId(1) {mPos = mElementArray.begin();}
    virtual ~rmBaseArray(){}

    rmBaseArray(unsigned long aStartupID) : mMaxId(aStartupID), mPos(mElementArray.begin()){}

    virtual size_t getCount() const {return mElementArray.size();} 

    virtual T * getElement(unsigned long aID);

    virtual const T * getConstElement(unsigned long aID) 
    {
      return getElement(aID);
    }

    virtual int addElement(const T & aElement, unsigned long aID);

    virtual int newElement(const T & aElement, unsigned long & aID);

    virtual int addDefaultElement(unsigned long aID);
  
    virtual int removeElement(unsigned long aID);

    virtual int modifyElement(unsigned long aID, const T & aElement);

    virtual unsigned long getNewId(void) 
    {
      return mMaxId;
    }
    
    virtual unsigned long getMaxId(void) const
    {
      return mMaxId;
    }

    virtual int findId(unsigned long aID, map<unsigned long, T>::iterator * aPos = 0); 

    virtual int getNextId(unsigned long aID, unsigned long & aNextID);

    virtual int init(){return RMCLIENT_SUCCESS;}

    virtual bool elementIsReady(const T & aElement) const
    {
      return false;
    }

    virtual int getInteger32(RMAttribute aName, unsigned long aID, long & aValue) 
    {
      return RMCLIENT_ERROR_NOT_IMPLEMENTED;
    }

    virtual int setInteger32(RMAttribute aName, unsigned long aID, long aValue) 
    {
      return RMCLIENT_ERROR_NOT_IMPLEMENTED;
    }

    virtual int getUnsigned(RMAttribute aName, unsigned long aID, unsigned long & aValue) 
    {
      return RMCLIENT_ERROR_NOT_IMPLEMENTED;
    }

    virtual int setUnsigned(RMAttribute aName, unsigned long aID, unsigned long aValue) 
    {
      return RMCLIENT_ERROR_NOT_IMPLEMENTED;
    }

    virtual int getUnsigned64(RMAttribute aName, unsigned long aID, u_int64_t & aValue) 
    {
      return RMCLIENT_ERROR_NOT_IMPLEMENTED;
    }

    virtual int setUnsigned64(RMAttribute aName, unsigned long aID, u_int64_t aValue) 
    {
      return RMCLIENT_ERROR_NOT_IMPLEMENTED;
    }

    virtual int getUUIDString(RMAttribute aName, unsigned long aID, char * aUUIDStr) 
    {
      return RMCLIENT_ERROR_NOT_IMPLEMENTED;
    }

    virtual int setUUIDString(RMAttribute aName, unsigned long aID, char * aUUIDStr) 
    {
      return RMCLIENT_ERROR_NOT_IMPLEMENTED;
    }

    virtual int getUUID(RMAttribute aName, unsigned long aID, uuid_t aUUID) 
    {
      return RMCLIENT_ERROR_NOT_IMPLEMENTED;
    }

    virtual int getString(RMAttribute aName, unsigned long aID, char * & aBuf) 
    {
      return RMCLIENT_ERROR_NOT_IMPLEMENTED;
    }

    virtual int setString(RMAttribute aName, unsigned long aID, char * aBuf) 
    {
      return RMCLIENT_ERROR_NOT_IMPLEMENTED;
    }

    virtual int getBinary(RMAttribute aName, unsigned long aID, char * & aBuf, unsigned long & aLength) 
    {
      return RMCLIENT_ERROR_NOT_IMPLEMENTED;
    }

    virtual int findExactId(unsigned long aID)
    {
      return findId(aID);
    }

   /*
    virtual int updateStatus(T & aElement);

    virtual int setStatus(T & aElement, unsigned long aID, long aStatus);
    */

  protected:
  // private:

    map<unsigned long, T> mElementArray;

    unsigned long mMaxId;
 
    map<unsigned long, T>::iterator mPos;
};

template<class T> T *
rmBaseArray<T>::getElement(unsigned long aID) 
{
  int ret;
  map<unsigned long, T>::iterator pos;

  ret = findId(aID, &pos);
  if(ret)
    return NULL;
  else 
    return &(pos->second);
}

template<class T> int
rmBaseArray<T>::addElement(const T & aElement, unsigned long aID)
{
  if (aID > mMaxId)
    return RMCLIENT_ERROR_BASE_ID;

  if((mElementArray.insert(make_pair(aID, aElement))).second) {

    // test if the id is already in use, if so, increament and try again.
    map<unsigned long, T>::iterator pos;
    do {
      mMaxId++;

      // in case mMaxId wrapps around, we don't want the id number equal to 0.
      if(mMaxId == 0)
        mMaxId++;

      pos = mElementArray.find(mMaxId);
      if(pos == mElementArray.end())
        break;


    } while (1);


    return RMCLIENT_SUCCESS;
  }
  else 
    return RMCLIENT_ERROR_BASE_INSERT;
}

template<class T> int
rmBaseArray<T>::newElement(const T & aElement, unsigned long & aID)
{
  unsigned long id;
  id = getNewId();

  aID = id;

  return addElement(aElement, id);
}

template<class T> int
rmBaseArray<T>::addDefaultElement(unsigned long aID)
{
  T element;

  memset(&element, 0, sizeof(T));

  return addElement(element, aID);
}

template<class T> int
rmBaseArray<T>::removeElement(unsigned long aID)
{
  int ret;
  map<unsigned long, T>::iterator pos;

  ret = findId(aID, &pos);
  if(ret)
    return ret;

  mElementArray.erase(pos);
  mPos = mElementArray.begin();

  return RMCLIENT_SUCCESS;
}

template<class T> int
rmBaseArray<T>::modifyElement(unsigned long aID, const T & aElement)
{
  int ret;
  map<unsigned long, T>::iterator pos;

  ret = findId(aID, &pos);
  if(ret)
    return ret;

  pos->second = aElement;

  return RMCLIENT_SUCCESS;
}

template<class T> int
rmBaseArray<T>::findId(unsigned long aID, map<unsigned long, T>::iterator * aPos = 0) 
{
  if(mPos != mElementArray.end() && mPos->first == aID) {
    if(aPos) 
      *aPos = mPos;
    return RMCLIENT_SUCCESS;
  }

  map<unsigned long, T>::iterator pos;

  pos = mElementArray.find(aID);

  if(pos != mElementArray.end()) {
    mPos = pos;
    if(aPos)
      *aPos = pos;
    return RMCLIENT_SUCCESS;
  }

  return RMCLIENT_ERROR_BASE_ID;
}

template<class T> int
rmBaseArray<T>::getNextId(unsigned long aID, unsigned long & aNextID) 
{
  aNextID = 0;

  map<unsigned long, T>::iterator pos;

  pos = mElementArray.upper_bound(aID);

  mPos = pos;

  if(pos == mElementArray.end())
    return RMCLIENT_ERROR_BASE_ID;

  aNextID = pos->first;

  return RMCLIENT_SUCCESS;
}

/*
template<class T> int
rmBaseArray<T>::updateStatus(T & aElement)
{
  if(elementIsReady(aElement)) {
    if(aElement.status != ACTIVE)
      aElement.status = NOTINSERVICE;
  }
  else 
    aElement.status = NOTREADY;

  return RMCLIENT_SUCCESS;
}

template<class T> int
rmBaseArray<T>::setStatus(T & aElement, unsigned long aID, long aStatus)
{
  if(aStatus != ACTIVE && aStatus != NOTINSERVICE)
    return RMCLIENT_ERROR_NOSUCHVALUE;

  if(aElement.status == NOTREADY)
    return RMCLIENT_ERROR_STATE;

  aElement.status = aStatus;
  return RMCLIENT_SUCCESS;
}
*/


#endif // __rmBaseArray_h

---