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

Use default TTL only 

Signed-off-by: Yilin Chen <sticnarf@gmail.com>
This commit is contained in:
Yilin Chen 2019-08-29 00:45:53 +08:00
parent b13a99dd30
commit 0f93a3c756
1 changed files with 5 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
src/transaction/transaction.rs
View File

@ -190,6 +190,9 @@ impl Transaction {
}
}
/// The default TTL of a lock in milliseconds
const DEFAULT_LOCK_TTL: u64 = 3000;
#[derive(new)]
struct TwoPhaseCommitter {
mutations: Vec<kvrpcpb::Mutation>,
@ -225,7 +228,8 @@ impl TwoPhaseCommitter {
async fn prewrite(&mut self) -> Result<()> {
let primary_lock = self.mutations[0].key.clone().into();
let lock_ttl = calculate_ttl(&self.mutations);
// TODO: calculate TTL for big transactions
let lock_ttl = DEFAULT_LOCK_TTL;
new_prewrite_request(
self.mutations.clone(),
primary_lock,
@ -280,10 +284,3 @@ impl TwoPhaseCommitter {
.await
}
}
fn calculate_ttl(mutations: &[kvrpcpb::Mutation]) -> u64 {
mutations
.iter()
.map(|mutation| mutation.key.len() + mutation.value.len())
.sum::<usize>() as u64
}