mirrors/scylladb
1
0
Fork 0
mirror of https://github.com/scylladb/scylladb.git synced 2026-05-31 20:16:43 +00:00
Code Issues Packages Projects Releases Wiki Activity

strong_consistency: skip read_barrier() for non-linearizable reads

Browse Source 
Non-linearizable reads (CL=ONE) no longer call read_barrier() before
querying the local replica. This is safe because state_machine::apply()
only writes to the table after raft commit, so a local read without
read_barrier cannot see uncommitted data — just potentially stale data
which is acceptable for CL=ONE semantics.
This commit is contained in:
Wojciech Mitros
2026-04-29 22:10:04 +02:00
parent d07692a7ff
commit afa2ef6816
1 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
service/strong_consistency/coordinator.cc
View File

@@ -447,10 +447,12 @@ auto coordinator::query(schema_ptr schema,
}
// We're either a raft leader or it's a non-linearizable read. In both cases we can directly execute the read on this replica.
co_await utils::get_local_injector().inject("sc_coordinator_wait_before_query_read_barrier",
utils::wait_for_message(5min));
if (rtype == read_type::linearizable) {
co_await utils::get_local_injector().inject("sc_coordinator_wait_before_query_read_barrier",
utils::wait_for_message(5min));
co_await op.raft_server.server().read_barrier(&aoe.abort_source());
co_await op.raft_server.server().read_barrier(&aoe.abort_source());
}
auto [result, cache_temp] = co_await _db.query(schema, cmd,
query::result_options::only_result(), ranges, trace_state, timeout);