File tree Expand file tree Collapse file tree 2 files changed +5
-5
lines changed Expand file tree Collapse file tree 2 files changed +5
-5
lines changed Original file line number Diff line number Diff line change @@ -577,15 +577,15 @@ where
577577 return Ok ( result) ;
578578 }
579579
580- if self . backoff . is_none ( ) {
580+ if clone . backoff . is_none ( ) {
581581 return Err ( Error :: ResolveLockError ( locks) ) ;
582582 }
583583
584- let pd_client = self . pd_client . clone ( ) ;
584+ let pd_client = clone . pd_client . clone ( ) ;
585585 let live_locks =
586- resolve_locks ( locks, self . timestamp . clone ( ) , pd_client. clone ( ) ) . await ?;
586+ resolve_locks ( locks, clone . timestamp . clone ( ) , pd_client. clone ( ) ) . await ?;
587587 if live_locks. is_empty ( ) {
588- result = self . inner . execute ( ) . await ?;
588+ result = clone . inner . execute ( ) . await ?;
589589 } else {
590590 match clone. backoff . next_delay_duration ( ) {
591591 None => return Err ( Error :: ResolveLockError ( live_locks) ) ,
Original file line number Diff line number Diff line change @@ -120,7 +120,7 @@ pub async fn resolve_locks(
120120 . insert ( cleaned_region) ;
121121 }
122122 }
123- info ! ( "resolved locks , live_locks: {:?}" , live_locks) ;
123+ info ! ( "resolved_locks , live_locks: {:?}" , live_locks) ;
124124 Ok ( live_locks)
125125}
126126
You can’t perform that action at this time.
0 commit comments