hcq/oceanbase
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

[CP] Auto Refresh/Broadcast Tablet Location

Browse Source 
Co-authored-by: LeonChaoHi <15201161716@163.com>
This commit is contained in:
tino247
2023-11-28 07:42:23 +00:00
committed by ob-robot
parent 0f9db0eb53
commit fa81dbabe1
35 changed files with 2746 additions and 65 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
mittest/simple_server/test_location_service.cpp
View File

@ -362,10 +362,11 @@ TEST_F(TestLocationService, test_clear_tablet_ls_cache)
ASSERT_TRUE(cache_size == cache_size_before_renew);
// test 1 million cache clear
const bool update_only = false;
for (int64_t i = 0; i < 1000000; ++i) {
ObTabletLSCache cache;
ASSERT_EQ(OB_SUCCESS, cache.init(tenant_id, ObTabletID(i+300000), ObLSID(1002), ObClockGenerator::getClock(), 1));
ASSERT_EQ(OB_SUCCESS, tablet_ls_service->inner_cache_.update(cache));
ASSERT_EQ(OB_SUCCESS, tablet_ls_service->inner_cache_.update(cache, update_only));
}
cache_size = tablet_ls_service->inner_cache_.size();
ASSERT_TRUE(1000000 == cache_size - cache_size_before_renew);

3
mittest/simple_server/test_tablet_autoinc_mgr.cpp
View File

@ -192,8 +192,9 @@ TEST_F(TestTabletAutoincMgr, test_lob_tablet_autoinc_location_cache)
ASSERT_EQ(OB_SUCCESS, task.result_);
// restore old tablet ls cache
const bool update_only = false;
for (int64_t i = 0; i < old_tablet_ls_cache.count(); i++) {
ASSERT_EQ(OB_SUCCESS, tablet_ls_service->update_cache_(old_tablet_ls_cache.at(i)));
ASSERT_EQ(OB_SUCCESS, tablet_ls_service->update_cache(old_tablet_ls_cache.at(i), update_only));
}
// remove source ls and clear src ls cache