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

fix(p2p): tcp sync: unlock of unlocked mutex

Browse Source
This commit is contained in:
源文雨
2025-02-21 00:56:15 +09:00
parent a52f9aa2c0
commit dbe990cac8
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -459,7 +459,8 @@ 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 || len(conn.subs) > 0) && !conn.cplk.TryLock() { locked := conn.cplk.TryLock()
if !locked && (!conn.suberr || len(conn.subs) > 0) {
if config.ShowDebugLog { if config.ShowDebugLog {
logrus.Debug("[tcp] try sub write to", tcpep) logrus.Debug("[tcp] try sub write to", tcpep)
} }