mirrors/scylladb
1
0
Fork 0
mirror of https://github.com/scylladb/scylladb.git synced 2026-05-29 11:10:40 +00:00
Code Issues Packages Projects Releases Wiki Activity

tablets: read_tablet_transition_stage: read from base table

Browse Source 
When reading tablet information from system.tablets we need to read it
from the base table, if exists.
This commit is contained in:
Michael Litvak
2025-03-26 13:26:28 +02:00
parent ff9a3c9528
commit 064ac25ff9
1 changed files with 13 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
replica/tablets.cc
View File

@@ -910,7 +910,20 @@ lw_shared_ptr<sstables::sstable_set> make_tablet_sstable_set(schema_ptr s, const
return tablet_sstable_set::make(std::move(s), sgm, tmap);
}
future<std::optional<table_id>> read_base_table(cql3::query_processor& qp, table_id tid) {
auto rs = co_await qp.execute_internal("select * from system.tablets where table_id = ?",
{tid.uuid()}, cql3::query_processor::cache_internal::no);
if (rs->empty() || !rs->front().has("base_table")) {
co_return std::nullopt;
}
co_return table_id(rs->front().get_as<utils::UUID>("base_table"));
}
future<std::optional<tablet_transition_stage>> read_tablet_transition_stage(cql3::query_processor& qp, table_id tid, dht::token last_token) {
if (auto base_table = co_await read_base_table(qp, tid)) {
tid = *base_table;
}
auto rs = co_await qp.execute_internal("select stage from system.tablets where table_id = ? and last_token = ?",
{tid.uuid(), dht::token::to_int64(last_token)}, cql3::query_processor::cache_internal::no);
if (rs->empty() || !rs->one().has("stage")) {