BaseSetCommitPolicy.h

Go to the documentation of this file.

 
#pragma once
#include "DeltaElements.h"
#include "catapult/exceptions.h"
 
namespace catapult { namespace deltaset {
 
    template<typename TKeyTraits, typename TStorageSet, typename TMemorySet>
    void UpdateSet(TStorageSet& elements, const DeltaElements<TMemorySet>& deltas) {
        if (!deltas.Added.empty())
            elements.insert(deltas.Added.cbegin(), deltas.Added.cend());
 
        for (const auto& element : deltas.Copied) {
            auto iter = elements.find(TKeyTraits::ToKey(element));
            if (elements.cend() == iter)
                CATAPULT_THROW_INVALID_ARGUMENT("element not found, cannot update");
 
            iter = elements.erase(iter);
            elements.insert(iter, element);
        }
 
        for (const auto& element : deltas.Removed)
            elements.erase(TKeyTraits::ToKey(element));
    }
 
    template<typename TSetTraits>
    struct BaseSetCommitPolicy {
        static void Update(typename TSetTraits::SetType& elements, const DeltaElements<typename TSetTraits::MemorySetType>& deltas) {
            UpdateSet<typename TSetTraits::KeyTraits>(elements, deltas);
        }
    };
}}