From 462cff43625fb333585e86b1bd3201cf972b888b Mon Sep 17 00:00:00 2001 From: Ti Chi Robot Date: Wed, 2 Aug 2023 09:28:07 +0800 Subject: [PATCH] p2p(ticdc): fix panic issue when peer is not found (#9355) (#9475) close pingcap/tiflow#9354 --- pkg/p2p/server.go | 1 + 1 file changed, 1 insertion(+) diff --git a/pkg/p2p/server.go b/pkg/p2p/server.go index 7bcf2c87a77..207f9bf9a97 100755 --- a/pkg/p2p/server.go +++ b/pkg/p2p/server.go @@ -378,6 +378,7 @@ func (m *MessageServer) deregisterPeerByID(ctx context.Context, peerID string) { m.peerLock.Unlock() if !ok { log.Warn("peer not found", zap.String("peerID", peerID)) + return } m.deregisterPeer(ctx, peer, nil) }