mirror of
https://github.com/xtaci/kcp-go.git
synced 2024-04-21 12:32:15 +00:00
update fastack alg
This commit is contained in:
@@ -780,7 +780,7 @@ func (kcp *KCP) flush() {
|
||||
lost = true
|
||||
lostSegs++
|
||||
} else if segment.fastack >= resent &&
|
||||
_itimediff(current, segment.ts) >= kcp.rx_srtt { // fast retransmit
|
||||
_itimediff(current, segment.ts) >= int32(kcp.rx_rto) { // fast retransmit
|
||||
needsend = true
|
||||
segment.xmit++
|
||||
segment.fastack = 0
|
||||
@@ -788,7 +788,7 @@ func (kcp *KCP) flush() {
|
||||
change++
|
||||
fastRetransSegs++
|
||||
} else if segment.fastack > 0 && newSegsCount == 0 &&
|
||||
_itimediff(current, segment.ts) >= kcp.rx_srtt { // early retransmit
|
||||
_itimediff(current, segment.ts) >= int32(kcp.rx_rto) { // early retransmit
|
||||
needsend = true
|
||||
segment.xmit++
|
||||
segment.fastack = 0
|
||||
|
||||
Reference in New Issue
Block a user