github/kcp-go
4
0
Fork 0
mirror of https://github.com/xtaci/kcp-go.git synced 2024-04-21 12:32:15 +00:00
Code Issues Releases Wiki Activity

use latest ack as rtt compute and simpify logic

Browse Source
This commit is contained in:
xtaci
2019-01-08 22:14:11 +08:00
parent 2ee8f10cc2
commit 9be9a335bb
1 changed files with 3 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
kcp.go
+3 -8
View File
@@ -497,7 +497,7 @@ func (kcp *KCP) Input(data []byte, regular, ackNoDelay bool) int {
return -1
}
var latest uint32 // latest packet
var latest uint32 // the latest ack packet
var flag int
var inSegs uint64
@@ -540,14 +540,9 @@ func (kcp *KCP) Input(data []byte, regular, ackNoDelay bool) int {
if cmd == IKCP_CMD_ACK {
kcp.parse_ack(sn)
// stricter check of fastack
kcp.parse_fastack(sn, ts)
if flag == 0 {
flag = 1
latest = ts
} else if _itimediff(ts, latest) > 0 {
latest = ts
}
flag |= 1
latest = ts
} else if cmd == IKCP_CMD_PUSH {
repeat := true
if _itimediff(sn, kcp.rcv_nxt+kcp.rcv_wnd) < 0 {