mirror of
https://github.com/netbirdio/netbird.git
synced 2024-12-13 10:21:10 +01:00
fix bool
This commit is contained in:
parent
22126d0484
commit
8ac4a0a1e1
@ -245,11 +245,9 @@ func (s *GRPCServer) sendUpdate(ctx context.Context, accountID string, peerKey w
|
|||||||
}
|
}
|
||||||
|
|
||||||
func (s *GRPCServer) cancelPeerRoutines(ctx context.Context, accountID string, peer *nbpeer.Peer, sessionID string) {
|
func (s *GRPCServer) cancelPeerRoutines(ctx context.Context, accountID string, peer *nbpeer.Peer, sessionID string) {
|
||||||
|
ok := s.peersUpdateManager.CloseChannel(ctx, peer.ID, sessionID)
|
||||||
bool1 := s.peersUpdateManager.CloseChannel(ctx, peer.ID, sessionID)
|
if ok {
|
||||||
if bool1 {
|
|
||||||
_ = s.accountManager.OnPeerDisconnected(ctx, accountID, peer.Key)
|
_ = s.accountManager.OnPeerDisconnected(ctx, accountID, peer.Key)
|
||||||
|
|
||||||
s.secretsManager.CancelRefresh(sessionID)
|
s.secretsManager.CancelRefresh(sessionID)
|
||||||
s.ephemeralManager.OnPeerDisconnected(ctx, peer)
|
s.ephemeralManager.OnPeerDisconnected(ctx, peer)
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user