File tree Expand file tree Collapse file tree 2 files changed +3
-7
lines changed Expand file tree Collapse file tree 2 files changed +3
-7
lines changed Original file line number Diff line number Diff line change @@ -278,6 +278,8 @@ impl Client {
278
278
range : impl Into < BoundRange > ,
279
279
batch_size : u32 ,
280
280
) -> Result < Vec < crate :: proto:: kvrpcpb:: LockInfo > > {
281
+ use crate :: request:: TruncateKeyspace ;
282
+
281
283
let range = range. into ( ) . encode_keyspace ( self . keyspace , KeyMode :: Txn ) ;
282
284
let req = new_scan_lock_request ( range, safepoint, batch_size) ;
283
285
let plan = crate :: request:: PlanBuilder :: new ( self . pd . clone ( ) , self . keyspace , req)
Original file line number Diff line number Diff line change @@ -24,17 +24,11 @@ const REGION_SPLIT_TIME_LIMIT: Duration = Duration::from_secs(15);
24
24
25
25
// Delete all entries in TiKV to leave a clean space for following tests.
26
26
pub async fn clear_tikv ( ) {
27
- // DEFAULT_REGION_BACKOFF is not long enough for CI environment. So set a longer backoff.
28
- let backoff = tikv_client:: Backoff :: no_jitter_backoff ( 100 , 30000 , 20 ) ;
29
27
let raw_client =
30
28
RawClient :: new_with_config ( pd_addrs ( ) , Config :: default ( ) . with_default_keyspace ( ) )
31
29
. await
32
30
. unwrap ( ) ;
33
- raw_client
34
- // .with_backoff(backoff.clone())
35
- . delete_range ( ..)
36
- . await
37
- . unwrap ( ) ;
31
+ raw_client. delete_range ( ..) . await . unwrap ( ) ;
38
32
39
33
let txn_client =
40
34
TransactionClient :: new_with_config ( pd_addrs ( ) , Config :: default ( ) . with_default_keyspace ( ) )
You can’t perform that action at this time.
0 commit comments