add
This commit is contained in:
parent
b15faae234
commit
ba76acaf87
@ -238,6 +238,7 @@ func (p *Client) AcceptTcpConn(conn *net.TCPConn) {
|
|||||||
}
|
}
|
||||||
if n > 0 {
|
if n > 0 {
|
||||||
clientConn.fm.WriteSendBuffer(bytes[:n])
|
clientConn.fm.WriteSendBuffer(bytes[:n])
|
||||||
|
tcpActiveRecvTime = now
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -277,6 +278,7 @@ func (p *Client) AcceptTcpConn(conn *net.TCPConn) {
|
|||||||
}
|
}
|
||||||
if n > 0 {
|
if n > 0 {
|
||||||
clientConn.fm.SkipRecvBuffer(n)
|
clientConn.fm.SkipRecvBuffer(n)
|
||||||
|
tcpActiveSendTime = now
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Loading…
x
Reference in New Issue
Block a user