LockInfoCacheDelta.h

Go to the documentation of this file.

 
#pragma once
#include "catapult/cache/CacheMixinAliases.h"
#include "catapult/cache/IdentifierGroupCacheUtils.h"
#include "catapult/cache/ReadOnlyViewSupplier.h"
#include "catapult/deltaset/BaseSetDelta.h"
 
namespace catapult { namespace cache {
 
    template<typename TDescriptor, typename TCacheTypes>
    struct LockInfoCacheDeltaMixins : public PatriciaTreeCacheMixins<typename TCacheTypes::PrimaryTypes::BaseSetDeltaType, TDescriptor> {
        using Touch = HeightBasedTouchMixin<
            typename TCacheTypes::PrimaryTypes::BaseSetDeltaType,
            typename TCacheTypes::HeightGroupingTypes::BaseSetDeltaType>;
        using Pruning = HeightBasedPruningMixin<
            typename TCacheTypes::PrimaryTypes::BaseSetDeltaType,
            typename TCacheTypes::HeightGroupingTypes::BaseSetDeltaType>;
    };
 
    template<typename TDescriptor, typename TCacheTypes>
    class BasicLockInfoCacheDelta
            : public utils::MoveOnly
            , public LockInfoCacheDeltaMixins<TDescriptor, TCacheTypes>::Size
            , public LockInfoCacheDeltaMixins<TDescriptor, TCacheTypes>::Contains
            , public LockInfoCacheDeltaMixins<TDescriptor, TCacheTypes>::ConstAccessor
            , public LockInfoCacheDeltaMixins<TDescriptor, TCacheTypes>::MutableAccessor
            , public LockInfoCacheDeltaMixins<TDescriptor, TCacheTypes>::PatriciaTreeDelta
            , public LockInfoCacheDeltaMixins<TDescriptor, TCacheTypes>::ActivePredicate
            , public LockInfoCacheDeltaMixins<TDescriptor, TCacheTypes>::BasicInsertRemove
            , public LockInfoCacheDeltaMixins<TDescriptor, TCacheTypes>::Touch
            , public LockInfoCacheDeltaMixins<TDescriptor, TCacheTypes>::Pruning
            , public LockInfoCacheDeltaMixins<TDescriptor, TCacheTypes>::DeltaElements {
    public:
        using ReadOnlyView = typename TCacheTypes::CacheReadOnlyType;
 
    public:
        explicit BasicLockInfoCacheDelta(const typename TCacheTypes::BaseSetDeltaPointers& lockInfoSets)
                : LockInfoCacheDeltaMixins<TDescriptor, TCacheTypes>::Size(*lockInfoSets.pPrimary)
                , LockInfoCacheDeltaMixins<TDescriptor, TCacheTypes>::Contains(*lockInfoSets.pPrimary)
                , LockInfoCacheDeltaMixins<TDescriptor, TCacheTypes>::ConstAccessor(*lockInfoSets.pPrimary)
                , LockInfoCacheDeltaMixins<TDescriptor, TCacheTypes>::MutableAccessor(*lockInfoSets.pPrimary)
                , LockInfoCacheDeltaMixins<TDescriptor, TCacheTypes>::PatriciaTreeDelta(*lockInfoSets.pPrimary, lockInfoSets.pPatriciaTree)
                , LockInfoCacheDeltaMixins<TDescriptor, TCacheTypes>::ActivePredicate(*lockInfoSets.pPrimary)
                , LockInfoCacheDeltaMixins<TDescriptor, TCacheTypes>::BasicInsertRemove(*lockInfoSets.pPrimary)
                , LockInfoCacheDeltaMixins<TDescriptor, TCacheTypes>::Touch(*lockInfoSets.pPrimary, *lockInfoSets.pHeightGrouping)
                , LockInfoCacheDeltaMixins<TDescriptor, TCacheTypes>::Pruning(*lockInfoSets.pPrimary, *lockInfoSets.pHeightGrouping)
                , LockInfoCacheDeltaMixins<TDescriptor, TCacheTypes>::DeltaElements(*lockInfoSets.pPrimary)
                , m_pDelta(lockInfoSets.pPrimary)
                , m_pHeightGroupingDelta(lockInfoSets.pHeightGrouping)
        {}
 
    public:
        using LockInfoCacheDeltaMixins<TDescriptor, TCacheTypes>::ConstAccessor::find;
        using LockInfoCacheDeltaMixins<TDescriptor, TCacheTypes>::MutableAccessor::find;
 
    public:
        void insert(const typename TDescriptor::ValueType& value) {
            LockInfoCacheDeltaMixins<TDescriptor, TCacheTypes>::BasicInsertRemove::insert(value);
            AddIdentifierWithGroup(*m_pHeightGroupingDelta, value.Height, TDescriptor::GetKeyFromValue(value));
        }
 
        void remove(const typename TDescriptor::KeyType& key) {
            auto iter = m_pDelta->find(key);
            const auto* pLockInfo = iter.get();
            if (!!pLockInfo)
                RemoveIdentifierWithGroup(*m_pHeightGroupingDelta, pLockInfo->Height, key);
 
            LockInfoCacheDeltaMixins<TDescriptor, TCacheTypes>::BasicInsertRemove::remove(key);
        }
 
        void processUnusedExpiredLocks(Height height, const consumer<const typename TDescriptor::ValueType>& consumer) const {
            ForEachIdentifierWithGroup(utils::as_const(*m_pDelta), *m_pHeightGroupingDelta, height, [consumer](const auto& lockInfo) {
                if (state::LockStatus::Unused == lockInfo.Status)
                    consumer(lockInfo);
            });
        }
 
    private:
        typename TCacheTypes::PrimaryTypes::BaseSetDeltaPointerType m_pDelta;
        typename TCacheTypes::HeightGroupingTypes::BaseSetDeltaPointerType m_pHeightGroupingDelta;
    };
 
    template<typename TDescriptor, typename TCacheTypes, typename TBasicView = BasicLockInfoCacheDelta<TDescriptor, TCacheTypes>>
    class LockInfoCacheDelta : public ReadOnlyViewSupplier<TBasicView> {
    public:
        explicit LockInfoCacheDelta(const typename TCacheTypes::BaseSetDeltaPointers& lockInfoSets)
                : ReadOnlyViewSupplier<TBasicView>(lockInfoSets)
        {}
    };
}}