CacheChangesSerializer.h

Go to the documentation of this file.

 
#pragma once
#include "CacheChanges.h"
#include "catapult/io/PodIoUtils.h"
#include "catapult/io/Stream.h"
#include <vector>
 
namespace catapult { namespace cache {
 
    template<typename TSerializer, typename TCacheDelta, typename TValue>
    void WriteCacheChanges(const SingleCacheChangesT<TCacheDelta, TValue>& changes, io::OutputStream& outputStream) {
        auto writeAllFrom = [&outputStream](const auto& source) {
            for (const auto* pValue : source)
                TSerializer::Save(*pValue, outputStream);
        };
 
        const auto& addedElements = changes.addedElements();
        const auto& removedElements = changes.removedElements();
        const auto& modifiedElements = changes.modifiedElements();
 
        io::Write64(outputStream, addedElements.size());
        io::Write64(outputStream, removedElements.size());
        io::Write64(outputStream, modifiedElements.size());
 
        writeAllFrom(addedElements);
        writeAllFrom(removedElements);
        writeAllFrom(modifiedElements);
    }
 
    template<typename TSerializer, typename TValue>
    void ReadCacheChanges(io::InputStream& inputStream, MemoryCacheChangesT<TValue>& changes) {
        auto readAllInto = [&inputStream](auto& dest, auto count) {
            for (auto i = 0u; i < count; ++i)
                dest.push_back(TSerializer::Load(inputStream));
        };
 
        auto numAdded = io::Read64(inputStream);
        auto numRemoved = io::Read64(inputStream);
        auto numCopied = io::Read64(inputStream);
 
        readAllInto(changes.Added, numAdded);
        readAllInto(changes.Removed, numRemoved);
        readAllInto(changes.Copied, numCopied);
    }
}}