diff options
Diffstat (limited to 'cpp/src/Freeze/ObjectStore.h')
| -rw-r--r-- | cpp/src/Freeze/ObjectStore.h | 206 |
1 files changed, 0 insertions, 206 deletions
diff --git a/cpp/src/Freeze/ObjectStore.h b/cpp/src/Freeze/ObjectStore.h deleted file mode 100644 index 3c8ca7cdb29..00000000000 --- a/cpp/src/Freeze/ObjectStore.h +++ /dev/null @@ -1,206 +0,0 @@ -// ********************************************************************** -// -// Copyright (c) 2003-2015 ZeroC, Inc. All rights reserved. -// -// This copy of Ice is licensed to you under the terms described in the -// ICE_LICENSE file included in this distribution. -// -// ********************************************************************** - -#ifndef FREEZE_OBJECT_STORE_H -#define FREEZE_OBJECT_STORE_H - -#include <Ice/Ice.h> -#include <Ice/Identity.h> -#include <Freeze/DB.h> -#include <Freeze/EvictorStorage.h> -#include <Freeze/Index.h> -#include <Freeze/TransactionI.h> -#include <IceUtil/Cache.h> - -#include <vector> -#include <list> -#include <db_cxx.h> - -namespace Freeze -{ - -template<class T> class EvictorI; - -class EvictorIBase; - -class ObjectStoreBase -{ -public: - - ObjectStoreBase(const std::string&, const std::string&, bool, EvictorIBase*, - const std::vector<IndexPtr>&, bool); - - virtual ~ObjectStoreBase(); - - const Ice::ObjectPtr& sampleServant() const; - - bool dbHasObject(const Ice::Identity&, const TransactionIPtr&) const; - void save(Dbt&, Dbt&, Ice::Byte, DbTxn*); - - // - // This base class encapsulates a BasicStream, which allows us to avoid - // making any extra copies of marshaled data when updating the database. - // - class Marshaler - { - public: - - Marshaler(const Ice::CommunicatorPtr&, const Ice::EncodingVersion&); - - void getDbt(Dbt&) const; - - protected: - - IceInternal::BasicStream _os; - }; - - class KeyMarshaler : public Marshaler - { - public: - - KeyMarshaler(const Ice::Identity&, const Ice::CommunicatorPtr&, const Ice::EncodingVersion&); - }; - - class ValueMarshaler : public Marshaler - { - public: - - ValueMarshaler(const ObjectRecord&, const Ice::CommunicatorPtr&, const Ice::EncodingVersion&, bool); - }; - - static void unmarshal(Ice::Identity&, const Key&, const Ice::CommunicatorPtr&, const Ice::EncodingVersion&); - static void unmarshal(ObjectRecord&, const Value&, const Ice::CommunicatorPtr&, const Ice::EncodingVersion&, bool); - - bool load(const Ice::Identity&, const TransactionIPtr&, ObjectRecord&); - void update(const Ice::Identity&, const ObjectRecord&, const TransactionIPtr&); - - bool insert(const Ice::Identity&, const ObjectRecord&, const TransactionIPtr&); - bool remove(const Ice::Identity&, const TransactionIPtr&); - - EvictorIBase* evictor() const; - - // - // For IndexI and Iterator - // - Db* db() const; - const std::string& dbName() const; - - const Ice::CommunicatorPtr& communicator() const; - const Ice::EncodingVersion& encoding() const; - const std::string& facet() const; - bool keepStats() const; - -protected: - - bool loadImpl(const Ice::Identity&, ObjectRecord&); - -private: - - IceUtil::UniquePtr<Db> _db; - std::string _facet; - std::string _dbName; - EvictorIBase* _evictor; - std::vector<IndexPtr> _indices; - Ice::CommunicatorPtr _communicator; - Ice::EncodingVersion _encoding; - Ice::ObjectPtr _sampleServant; - bool _keepStats; -}; - - -template<class T> -class ObjectStore : public ObjectStoreBase, public IceUtil::Cache<Ice::Identity, T> -{ - public: - - ObjectStore(const std::string& facet, const std::string facetType, - bool createDb, EvictorIBase* evictor, - const std::vector<IndexPtr>& indices = std::vector<IndexPtr>(), - bool populateEmptyIndices = false) : - ObjectStoreBase(facet, facetType, createDb, evictor, indices, populateEmptyIndices) - { - } - - using ObjectStoreBase::load; - - typedef IceUtil::Cache<Ice::Identity, T> Cache; - -protected: - - virtual IceUtil::Handle<T> - load(const Ice::Identity& ident) - { - ObjectRecord rec; - if(loadImpl(ident, rec)) - { - return new T(rec, *this); - } - else - { - return 0; - } - } - - virtual void - pinned(const IceUtil::Handle<T>& element, typename Cache::Position p) - { - element->init(p); - } -}; - -// -// Inline member function definitions -// - -inline Db* -ObjectStoreBase::db() const -{ - return _db.get(); -} - -inline const Ice::CommunicatorPtr& -ObjectStoreBase::communicator() const -{ - return _communicator; -} - -inline const Ice::EncodingVersion& -ObjectStoreBase::encoding() const -{ - return _encoding; -} - -inline EvictorIBase* -ObjectStoreBase::evictor() const -{ - return _evictor; -} - -inline const std::string& -ObjectStoreBase::facet() const -{ - return _facet; -} - -inline bool -ObjectStoreBase::keepStats() const -{ - return _keepStats; -} - -inline const Ice::ObjectPtr& -ObjectStoreBase::sampleServant() const -{ - return _sampleServant; -} - -} - -#endif - |