diff --git a/dht/i_partitioner_fwd.hh b/dht/i_partitioner_fwd.hh index b6e8f39b1c..bd12b34e92 100644 --- a/dht/i_partitioner_fwd.hh +++ b/dht/i_partitioner_fwd.hh @@ -10,6 +10,7 @@ #pragma once #include #include "interval.hh" +#include "utils/chunked_vector.hh" namespace sstables { @@ -29,7 +30,7 @@ using partition_range = interval; using token_range = interval; using partition_range_vector = std::vector; -using token_range_vector = std::vector; +using token_range_vector = utils::chunked_vector; class decorated_key; diff --git a/idl/streaming.idl.hh b/idl/streaming.idl.hh index 03d4dc16d0..8f3433eec4 100644 --- a/idl/streaming.idl.hh +++ b/idl/streaming.idl.hh @@ -37,7 +37,7 @@ class stream_request { sstring keyspace; // For compatibility with <= 1.5, we use wrapping ranges // (though we never send wraparounds; only allow receiving them) - std::vector> ranges_compat(); + utils::chunked_vector> ranges_compat(); std::vector column_families; }; diff --git a/message/messaging_service.hh b/message/messaging_service.hh index a1ddf9e195..2f04487664 100644 --- a/message/messaging_service.hh +++ b/message/messaging_service.hh @@ -25,6 +25,7 @@ #include "gms/gossip_address_map.hh" #include "tasks/types.hh" #include "utils/advanced_rpc_compressor.hh" +#include "utils/chunked_vector.hh" #include #include @@ -74,7 +75,7 @@ namespace dht { class ring_position; using partition_range = interval; using token_range = interval; - using token_range_vector = std::vector; + using token_range_vector = utils::chunked_vector; } namespace query { diff --git a/partition_range_compat.hh b/partition_range_compat.hh index a2351b1c3e..9e4c2b7be1 100644 --- a/partition_range_compat.hh +++ b/partition_range_compat.hh @@ -20,10 +20,16 @@ using wrapping_partition_range = wrapping_interval; // unwraps a vector of wrapping ranges into a vector of nonwrapping ranges // if the vector happens to be sorted by the left bound, it remains sorted -template -std::vector> -unwrap(std::vector>&& v, Comparator&& cmp) { - std::vector> ret; +template