File tree Expand file tree Collapse file tree 2 files changed +4
-5
lines changed Expand file tree Collapse file tree 2 files changed +4
-5
lines changed Original file line number Diff line number Diff line change 92
92
//! # })}
93
93
//! ```
94
94
95
- #![ feature( explicit_generic_args_with_impl_trait) ]
96
95
#[ macro_use]
97
96
pub mod request;
98
97
#[ macro_use]
Original file line number Diff line number Diff line change @@ -25,9 +25,9 @@ const RESOLVE_LOCK_RETRY_LIMIT: usize = 10;
25
25
/// the key. We first use `CleanupRequest` to let the status of the primary lock converge and get
26
26
/// its status (committed or rolled back). Then, we use the status of its primary lock to determine
27
27
/// the status of the other keys in the same transaction.
28
- pub async fn resolve_locks < T : PdClient > (
28
+ pub async fn resolve_locks (
29
29
locks : Vec < kvrpcpb:: LockInfo > ,
30
- pd_client : Arc < T > ,
30
+ pd_client : Arc < impl PdClient > ,
31
31
) -> Result < bool > {
32
32
debug ! ( "resolving locks" ) ;
33
33
let ts = pd_client. clone ( ) . get_timestamp ( ) . await ?;
@@ -89,11 +89,11 @@ pub async fn resolve_locks<T: PdClient>(
89
89
Ok ( !has_live_locks)
90
90
}
91
91
92
- async fn resolve_lock_with_retry < T : PdClient > (
92
+ async fn resolve_lock_with_retry (
93
93
#[ allow( clippy:: ptr_arg) ] key : & Vec < u8 > ,
94
94
start_version : u64 ,
95
95
commit_version : u64 ,
96
- pd_client : Arc < T > ,
96
+ pd_client : Arc < impl PdClient > ,
97
97
) -> Result < RegionVerId > {
98
98
debug ! ( "resolving locks with retry" ) ;
99
99
// FIXME: Add backoff
You can’t perform that action at this time.
0 commit comments