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 691df4d95a

This commit is contained in:
Alex.F 2025-09-03 09:46:17 +00:00 committed by GitHub
parent 691df4d95a b481480cf1
commit 1e1000fb91
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> { 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>> { async fn commit(mut self) -> Result<Option<Timestamp>> {
debug!("committing"); debug!("committing");
@ -1281,6 +1286,8 @@ impl<PdC: PdClient> Committer<PdC> {
return Ok(min_commit_ts); return Ok(min_commit_ts);
} }
self.filter_out_check_not_exists_mutations();
let commit_ts = if self.options.async_commit { let commit_ts = if self.options.async_commit {
// FIXME: min_commit_ts == 0 => fallback to normal 2PC // FIXME: min_commit_ts == 0 => fallback to normal 2PC
min_commit_ts.unwrap() min_commit_ts.unwrap()