CkptContainer.h

Go to the documentation of this file.

#ifndef CKPTCONTAINER_H_
#define CKPTCONTAINER_H_

#include <memory>
#include <saAis.h>
#include <saCkpt.h>
#include "CkptObject.h"
#include "CkptRawDAO.h"

enum CkptRetentionPolicy { 
    CKPT_RETAIN, 
    CKPT_RELEASE 
    };

class CkptContainer {
 public:
 CkptContainer(std::string containerName,
               unsigned long maxObjects,
               unsigned long maxObjectSize,
               CkptRetentionPolicy rPolicy=CKPT_RELEASE);

 ~CkptContainer();

 unsigned long size();

 CkptObject* get(CkptObjectKey *key);
 
 CkptObject* get(CkptObjectKey &key);

 CkptRC persist(CkptObject *obj, bool overwriteExisting=true);

 CkptRC remove(CkptObject *obj);

 CkptRC commit(CkptObject *obj);

 bool isValid() { return _valid; }

 CkptRC setRetentionPolicy(CkptRetentionPolicy rPolicy);
  
private:
 std::string             _containerName;    
 SaNameT                 _checkpointName;   
 SaCkptHandleT           _serviceHandle;    
 SaCkptCheckpointHandleT _checkpointHandle; 
 unsigned long           _maxObjectSize;    
 bool                    _valid;            
 DAOInterfaceFactory*    _daoFactory;       
};

template <class T>
class CkptSimpleContainer : public CkptContainer {
public:
   CkptSimpleContainer(std::string containerName,
                       unsigned long maxObjects,
                       unsigned long maxObjectSize,
                       CkptRetentionPolicy rPolicy=CKPT_RELEASE)
       : CkptContainer(containerName,maxObjects,maxObjectSize, rPolicy) { }

    T* get(CkptObjectKey *key) {
        return (T*)CkptContainer::get(key);
    }
    T* get(CkptObjectKey &key) {
        return (T*)CkptContainer::get(key);
    }
};

#endif /*CKPTCONTAINER_H_*/

---