LockInfoBaseSets.h

Go to the documentation of this file.

 
#pragma once
#include "LockInfoCacheTypes.h"
#include "catapult/cache/CachePatriciaTree.h"
#include "catapult/cache/PatriciaTreeEncoderAdapters.h"
#include "catapult/tree/BasePatriciaTree.h"
 
namespace catapult { namespace cache {
 
    template<typename TDescriptor>
    using LockInfoPatriciaTree = tree::BasePatriciaTree<
        SerializerHashedKeyEncoder<typename TDescriptor::Serializer>,
        PatriciaTreeRdbDataSource,
        utils::ArrayHasher<typename TDescriptor::KeyType>>;
 
    template<typename TCacheTypes, typename TDescriptor>
    struct LockInfoBaseSetDeltaPointers {
        typename TCacheTypes::PrimaryTypes::BaseSetDeltaPointerType pPrimary;
        typename TCacheTypes::HeightGroupingTypes::BaseSetDeltaPointerType pHeightGrouping;
        std::shared_ptr<typename TDescriptor::PatriciaTree::DeltaType> pPatriciaTree;
    };
 
    template<typename TCacheTypes, typename TDescriptor, typename TBaseSetDeltaPointers>
    struct LockInfoBaseSets : public CacheDatabaseMixin {
    public:
        using IsOrderedSet = std::false_type;
 
    public:
        explicit LockInfoBaseSets(const CacheConfiguration& config)
                : CacheDatabaseMixin(config, { "default", "height_grouping" })
                , Primary(GetContainerMode(config), database(), 0)
                , HeightGrouping(GetContainerMode(config), database(), 1)
                , PatriciaTree(hasPatriciaTreeSupport(), database(), 2)
        {}
 
    public:
        typename TCacheTypes::PrimaryTypes::BaseSetType Primary;
        typename TCacheTypes::HeightGroupingTypes::BaseSetType HeightGrouping;
        CachePatriciaTree<typename TDescriptor::PatriciaTree> PatriciaTree;
 
    public:
        TBaseSetDeltaPointers rebase() {
            TBaseSetDeltaPointers deltaPointers;
            deltaPointers.pPrimary = Primary.rebase();
            deltaPointers.pHeightGrouping = HeightGrouping.rebase();
            deltaPointers.pPatriciaTree = PatriciaTree.rebase();
            return deltaPointers;
        }
 
        TBaseSetDeltaPointers rebaseDetached() const {
            TBaseSetDeltaPointers deltaPointers;
            deltaPointers.pPrimary = Primary.rebaseDetached();
            deltaPointers.pHeightGrouping = HeightGrouping.rebaseDetached();
            deltaPointers.pPatriciaTree = PatriciaTree.rebaseDetached();
            return deltaPointers;
        }
 
        void commit() {
            Primary.commit();
            HeightGrouping.commit();
            PatriciaTree.commit();
            flush();
        }
    };
}}