From c7cfd94ae230bbbfe81caf6072dcad613c5a5f41 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E6=BA=90=E6=96=87=E9=9B=A8?=
 <41315874+fumiama@users.noreply.github.com>
Date: Thu, 8 Aug 2024 13:35:04 +0800
Subject: [PATCH] fix(p2p): tcp sub conn add close write

---
 gold/p2p/tcp/tcp.go | 9 +++++++++
 1 file changed, 9 insertions(+)

diff --git a/gold/p2p/tcp/tcp.go b/gold/p2p/tcp/tcp.go
index 9aa9c7e..3457a1c 100644
--- 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:]