tikv
/
client-rust
mirror of https://github.com/tikv/client-rust.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Merge b481480cf1 into 7c78aadf44

This commit is contained in:
Alex.F 2025-05-22 21:45:41 +08:00 committed by GitHub
parent 7c78aadf44 b481480cf1
commit a0ec3b8241
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 7 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/transaction/transaction.rs
View File

@ -1265,6 +1265,11 @@ struct Committer<PdC: PdClient = PdRpcClient> {
}
impl<PdC: PdClient> Committer<PdC> {
// CheckNotExists is checked in the prewrite phase and should not appear in the commit phase.
fn filter_out_check_not_exists_mutations(&mut self) {
self.mutations.retain(|m| m.op() != Op::CheckNotExists)
}
async fn commit(mut self) -> Result<Option<Timestamp>> {
debug!("committing");
@ -1281,6 +1286,8 @@ impl<PdC: PdClient> Committer<PdC> {
return Ok(min_commit_ts);
}
self.filter_out_check_not_exists_mutations();
let commit_ts = if self.options.async_commit {
// FIXME: min_commit_ts == 0 => fallback to normal 2PC
min_commit_ts.unwrap()