p2p(ticdc): fix panic issue when peer is not found (#9355) (#9475)

close #9354
pingcap · Aug 2, 2023 · 462cff4 · 462cff4
1 parent e68b679
commit 462cff4
Showing 1 changed file with 1 addition and 0 deletions.
diff --git 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)
 }