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

implement HasLocks for PrewriteRequest 

Signed-off-by: Yilin Chen <sticnarf@gmail.com>
This commit is contained in:
Yilin Chen 2019-08-28 01:50:13 +08:00
parent 72159356dc
commit be019226de
1 changed files with 9 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/transaction/requests.rs
View File

@ -352,6 +352,15 @@ impl KvRequest for kvrpcpb::PrewriteRequest {
} }
} }
impl HasLocks for kvrpcpb::PrewriteResponse {
fn take_locks(&mut self) -> Vec<kvrpcpb::LockInfo> {
self.errors
.iter_mut()
.filter_map(|error| error.locked.take())
.collect()
}
}
pub fn new_prewrite_request( pub fn new_prewrite_request(
mutations: Vec<kvrpcpb::Mutation>, mutations: Vec<kvrpcpb::Mutation>,
primary_lock: Key, primary_lock: Key,
@ -482,7 +491,6 @@ pub fn new_batch_rollback_request(
req req
} }
dummy_impl_has_locks!(PrewriteResponse);
dummy_impl_has_locks!(CommitResponse); dummy_impl_has_locks!(CommitResponse);
dummy_impl_has_locks!(CleanupResponse); dummy_impl_has_locks!(CleanupResponse);
dummy_impl_has_locks!(BatchRollbackResponse); dummy_impl_has_locks!(BatchRollbackResponse);