From c210e289bf3fa427ad79b2d3464bbd6516a5c011 Mon Sep 17 00:00:00 2001 From: JaySon-Huang Date: Thu, 11 May 2023 16:00:09 +0800 Subject: [PATCH] Remove deprecated split region param Signed-off-by: JaySon-Huang --- src/kv/Cluster.cc | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/src/kv/Cluster.cc b/src/kv/Cluster.cc index 94b79ff..a27b0d9 100644 --- a/src/kv/Cluster.cc +++ b/src/kv/Cluster.cc @@ -13,18 +13,18 @@ void Cluster::splitRegion(const std::string & split_key) auto loc = region_cache->locateKey(bo, split_key); RegionClient client(this, loc.region); kvrpcpb::SplitRegionRequest req; - req.set_split_key(split_key); + *req.mutable_split_keys()->Add() = split_key; kvrpcpb::SplitRegionResponse resp; client.sendReqToRegion(bo, req, &resp); if (resp.has_region_error()) { throw Exception(resp.region_error().message(), RegionUnavailable); } - auto lr = resp.left(); - auto rr = resp.right(); region_cache->dropRegion(loc.region); - region_cache->getRegionByID(bo, RegionVerID(lr.id(), lr.region_epoch().conf_ver(), lr.region_epoch().version())); - region_cache->getRegionByID(bo, RegionVerID(rr.id(), rr.region_epoch().conf_ver(), rr.region_epoch().version())); + for (const auto & r : resp.regions()) + { + region_cache->getRegionByID(bo, RegionVerID{r.id(), r.region_epoch().conf_ver(), r.region_epoch().version()}); + } } void Cluster::startBackgroundTasks()