fumiama/WireGold
1
0
Fork 0
mirror of https://github.com/fumiama/WireGold.git synced 2026-06-21 19:13:20 +08:00
Code Activity

feat(p2p): add tcp fast fail except

Browse Source
This commit is contained in:
源文雨
2024-08-07 23:03:06 +08:00
parent aa6f5ee100
commit d577ae2e16
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
gold/p2p/tcp/tcp.go
View File

@@ -447,7 +447,7 @@ func (conn *Conn) WriteToPeer(b []byte, ep p2p.EndPoint) (n int, err error) {
if len(b) >= 65536 { if len(b) >= 65536 {
return 0, errors.New("data size " + strconv.Itoa(len(b)) + " is too large") return 0, errors.New("data size " + strconv.Itoa(len(b)) + " is too large")
} }
if !conn.suberr && !conn.cplk.TryLock() { if (!conn.suberr || len(conn.subs) > 0) && !conn.cplk.TryLock() {
logrus.Infoln("[tcp] try sub write") logrus.Infoln("[tcp] try sub write")
n, err = conn.writeToPeer(b, tcpep, true) // try sub write n, err = conn.writeToPeer(b, tcpep, true) // try sub write
if err == nil { if err == nil {