fix(p2p): tcp sub conn add close write

fumiama · Aug 8, 2024 · c7cfd94 · c7cfd94
1 parent 4a2b6c3
commit c7cfd94
Showing 1 changed file with 9 additions and 0 deletions.
diff --git a/gold/p2p/tcp/tcp.go b/gold/p2p/tcp/tcp.go
@@ -137,6 +137,15 @@ func (conn *Conn) accept() {
 }
 
 func delsubs(i int, subs []*subconn) []*subconn {
+	tcpconn := subs[i].conn
+	err := tcpconn.CloseWrite()
+	if config.ShowDebugLog {
+		if err != nil {
+			logrus.Debugln("[tcp] close sub write from", tcpconn.LocalAddr(), "to", tcpconn.RemoteAddr(), "err:", err)
+		} else {
+			logrus.Debugln("[tcp] close sub write from", tcpconn.LocalAddr(), "to", tcpconn.RemoteAddr())
+		}
+	}
 	switch i {
 	case 0:
 		subs = subs[1:]