diff --git a/kcp.go b/kcp.go index be33917..4a6520e 100644 --- a/kcp.go +++ b/kcp.go @@ -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