diff --git a/src/v/cluster/metadata_dissemination_handler.cc b/src/v/cluster/metadata_dissemination_handler.cc index e0e09e0d680fb..61d0319984a0d 100644 --- a/src/v/cluster/metadata_dissemination_handler.cc +++ b/src/v/cluster/metadata_dissemination_handler.cc @@ -49,12 +49,12 @@ metadata_dissemination_handler::update_leadership_v2( ss::future metadata_dissemination_handler::do_update_leadership( - fragmented_vector leaders) { + chunked_vector leaders) { vlog(clusterlog.trace, "Received a metadata update"); co_await ss::parallel_for_each( boost::irange(0, ss::smp::count), [this, leaders = std::move(leaders)](ss::shard_id shard) { - fragmented_vector local_leaders; + chunked_vector local_leaders; local_leaders.reserve(leaders.size()); std::copy( leaders.begin(), leaders.end(), std::back_inserter(local_leaders)); diff --git a/src/v/cluster/metadata_dissemination_handler.h b/src/v/cluster/metadata_dissemination_handler.h index 400eb1a9e6f78..bde7b0b0ad682 100644 --- a/src/v/cluster/metadata_dissemination_handler.h +++ b/src/v/cluster/metadata_dissemination_handler.h @@ -47,7 +47,7 @@ class metadata_dissemination_handler private: ss::future - do_update_leadership(fragmented_vector); + do_update_leadership(chunked_vector); ss::sharded& _leaders; }; // namespace cluster diff --git a/src/v/cluster/metadata_dissemination_service.cc b/src/v/cluster/metadata_dissemination_service.cc index 28e1258658adf..392479b0bab51 100644 --- a/src/v/cluster/metadata_dissemination_service.cc +++ b/src/v/cluster/metadata_dissemination_service.cc @@ -395,7 +395,7 @@ ss::future<> metadata_dissemination_service::update_leaders_with_health_report( ss::future<> metadata_dissemination_service::dispatch_one_update( model::node_id target_id, update_retry_meta& meta) { // copy updates to make retries possible - fragmented_vector updates; + chunked_vector updates; updates.reserve(meta.updates.size()); std::copy( meta.updates.begin(), meta.updates.end(), std::back_inserter(updates)); diff --git a/src/v/cluster/metadata_dissemination_types.h b/src/v/cluster/metadata_dissemination_types.h index 077cacc73eec0..fcf318c70be34 100644 --- a/src/v/cluster/metadata_dissemination_types.h +++ b/src/v/cluster/metadata_dissemination_types.h @@ -104,7 +104,7 @@ struct update_leadership_request_v2 serde::compat_version<0>> { using rpc_adl_exempt = std::true_type; static constexpr int8_t version = 0; - fragmented_vector leaders; + chunked_vector leaders; update_leadership_request_v2() noexcept = default; @@ -119,7 +119,7 @@ struct update_leadership_request_v2 }; update_leadership_request_v2 copy() const { - fragmented_vector leaders_cp; + chunked_vector leaders_cp; leaders_cp.reserve(leaders.size()); std::copy( leaders.begin(), leaders.end(), std::back_inserter(leaders_cp)); @@ -134,7 +134,7 @@ struct update_leadership_request_v2 } explicit update_leadership_request_v2( - fragmented_vector leaders) + chunked_vector leaders) : leaders(std::move(leaders)) {} auto serde_fields() { return std::tie(leaders); }