@@ -444,8 +444,6 @@ impl LighthouseService for Arc<Lighthouse> {
444
444
. requester
445
445
. ok_or_else ( || return Status :: invalid_argument ( "missing requester" ) ) ?;
446
446
447
- let requester_id = requester. replica_id . clone ( ) ;
448
- let requester_copy = requester. clone ( ) ;
449
447
info ! ( "got quorum request for replica {}" , & requester. replica_id) ;
450
448
451
449
let mut rx = {
@@ -460,7 +458,7 @@ impl LighthouseService for Arc<Lighthouse> {
460
458
requester. replica_id . clone ( ) ,
461
459
QuorumMemberDetails {
462
460
joined : Instant :: now ( ) ,
463
- member : requester,
461
+ member : requester. clone ( ) ,
464
462
} ,
465
463
) ;
466
464
let rx = state. channel . subscribe ( ) ;
@@ -479,21 +477,21 @@ impl LighthouseService for Arc<Lighthouse> {
479
477
if current_quorum
480
478
. participants
481
479
. iter ( )
482
- . any ( |p| p. replica_id == requester_id )
480
+ . any ( |p| p. replica_id == requester . replica_id )
483
481
{
484
482
break current_quorum;
485
483
}
486
484
487
485
// Only continue the loop if the replica is not in the quorum
488
486
let mut state = self . state . lock ( ) . await ;
489
487
state. participants . insert (
490
- requester_id . clone ( ) ,
488
+ requester . replica_id . clone ( ) ,
491
489
QuorumMemberDetails {
492
490
joined : Instant :: now ( ) ,
493
- member : requester_copy . clone ( ) ,
491
+ member : requester . clone ( ) ,
494
492
} ,
495
493
) ;
496
- info ! ( "Replica {} not in quorum, retrying" , requester_id ) ;
494
+ info ! ( "Replica {} not in quorum, retrying" , & requester . replica_id ) ;
497
495
} ;
498
496
499
497
let reply = LighthouseQuorumResponse {
0 commit comments