diff options
| author | Lee Clagett <code@leeclagett.com> | 2026-03-14 12:24:55 -0400 |
|---|---|---|
| committer | Lee *!* Clagett <code@leeclagett.com> | 2026-04-27 17:57:21 -0400 |
| commit | 54229196bd11913ef0ac2c44b9f090cf619d29d8 (patch) | |
| tree | 1ba50b674dade4470bd69779e06ef9cba3c05618 /src/serialization/container.h | |
| parent | 23b420a992417abb6131b3d152d7e32adf224351 (diff) | |
| download | monzero-core-54229196bd11913ef0ac2c44b9f090cf619d29d8.tar.gz monzero-core-54229196bd11913ef0ac2c44b9f090cf619d29d8.tar.xz monzero-core-54229196bd11913ef0ac2c44b9f090cf619d29d8.zip | |
Improve unpack reserve handling
Diffstat (limited to 'src/serialization/container.h')
| -rw-r--r-- | src/serialization/container.h | 34 |
1 files changed, 31 insertions, 3 deletions
diff --git a/src/serialization/container.h b/src/serialization/container.h index c64549c1e..7ba4d307f 100644 --- a/src/serialization/container.h +++ b/src/serialization/container.h @@ -28,6 +28,12 @@ // // Parts of this file are originally copyright (c) 2012-2013 The Cryptonote developers +#include <algorithm> +#include <cstdint> +#include <cstddef> +#include <limits> +#include <type_traits> + namespace serialization { namespace detail @@ -57,8 +63,30 @@ namespace serialization return true; } - template <typename C> - void do_reserve(C &c, size_t N) {} + //! @brief Reserve space for N elements if applicable for container. + template<typename... C> + void do_reserve(const C&...) {} + template<typename C> + auto do_reserve(C &c, std::size_t N, std::size_t B) -> decltype(c.reserve(N)) + { + using T = typename C::value_type; + + static constexpr std::size_t max_compression_ratio = + is_blob_type<T>::type::value ? 1 : + use_container_varint<T>() ? sizeof(T) : + (std::is_same<T, char>::value || std::is_same<T, unsigned char>::value) ? 1: + 4; // default + + // max compression ratio for upfront memory usage + B /= sizeof(T); + B = std::max(std::size_t(1), B); + if (std::numeric_limits<std::size_t>::max() / max_compression_ratio <= B) + B = std::numeric_limits<std::size_t>::max(); + else + B *= max_compression_ratio; + + return c.reserve(std::min(N, B)); + } } } @@ -77,7 +105,7 @@ bool do_serialize_container(Archive<false> &ar, C &v) return false; } - ::serialization::detail::do_reserve(v, cnt); + ::serialization::detail::do_reserve(v, cnt, ar.remaining_bytes()); for (size_t i = 0; i < cnt; i++) { if (i > 0) |
