From 2ed5548a6f8984fbd9244d102c2f90a045e9e4f9 Mon Sep 17 00:00:00 2001 From: esrrhs Date: Sat, 26 Oct 2019 17:08:06 +0800 Subject: [PATCH] add --- client.go | 4 ++++ server.go | 4 ++++ 2 files changed, 8 insertions(+) diff --git a/client.go b/client.go index f6585db..601406d 100644 --- a/client.go +++ b/client.go @@ -262,6 +262,8 @@ func (p *Client) AcceptTcpConn(conn *net.TCPConn) { p.sendPacket++ p.sendPacketSize += (uint64)(len(mb)) } + } else { + time.Sleep(time.Millisecond * 10) } if clientConn.fm.GetRecvBufferSize() > 0 { @@ -280,6 +282,8 @@ func (p *Client) AcceptTcpConn(conn *net.TCPConn) { clientConn.fm.SkipRecvBuffer(n) tcpActiveSendTime = now } + } else { + time.Sleep(time.Millisecond * 10) } diffrecv := now.Sub(clientConn.activeRecvTime) diff --git a/server.go b/server.go index 900cf18..9e8e61a 100644 --- a/server.go +++ b/server.go @@ -227,6 +227,8 @@ func (p *Server) RecvTCP(conn *ServerConn, id string, src *net.IPAddr) { p.sendPacket++ p.sendPacketSize += (uint64)(len(mb)) } + } else { + time.Sleep(time.Millisecond * 10) } if conn.fm.GetRecvBufferSize() > 0 { @@ -245,6 +247,8 @@ func (p *Server) RecvTCP(conn *ServerConn, id string, src *net.IPAddr) { conn.fm.SkipRecvBuffer(n) tcpActiveSendTime = now } + } else { + time.Sleep(time.Millisecond * 10) } diffrecv := now.Sub(conn.activeRecvTime)