fix(p2p): close receive on certain errors

fumiama · Aug 8, 2024 · 4a2b6c3 · 4a2b6c3
1 parent d5d7a94
commit 4a2b6c3
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/gold/p2p/tcp/tcp.go b/gold/p2p/tcp/tcp.go
@@ -242,8 +242,11 @@ func (conn *Conn) receive(tcpconn *net.TCPConn, hasvalidated bool) {
 			if config.ShowDebugLog {
 				logrus.Debugln("[tcp] recv from", ep, "err:", err)
 			}
-			_ = tcpconn.CloseRead()
-			return
+			if errors.Is(err, net.ErrClosed) || errors.Is(err, io.ErrClosedPipe) {
+				_ = tcpconn.CloseRead()
+				return
+			}
+			continue
 		}
 		if r.pckt.typ >= packetTypeTop {
 			if config.ShowDebugLog {