do not update_ack() when the input packet is recovered from FEC

kcp.go

@@ -464,7 +464,7 @@ func (kcp *KCP) parse_data(newseg *Segment) {
 }
 
 // Input when you received a low level packet (eg. UDP packet), call it
-func (kcp *KCP) Input(data []byte) int {
+func (kcp *KCP) Input(data []byte, update_ack bool) int {
 	una := kcp.snd_una
 	if len(data) < IKCP_OVERHEAD {
 		return -1
@@ -507,7 +507,7 @@ func (kcp *KCP) Input(data []byte) int {
 		kcp.shrink_buf()
 
 		if cmd == IKCP_CMD_ACK {
-			if _itimediff(kcp.current, ts) >= 0 {
+			if update_ack && _itimediff(kcp.current, ts) >= 0 {
 				kcp.update_ack(_itimediff(kcp.current, ts))
 			}
 			kcp.parse_ack(sn)

kcp_test.go

@@ -205,7 +205,7 @@ func test(mode int) {
 				break
 			}
 			// 如果 p2收到udp，则作为下层协议输入到kcp2
-			kcp2.Input(buffer[:hr])
+			kcp2.Input(buffer[:hr], true)
 		}
 
 		// 处理虚拟网络：检测是否有udp包从p2->p1
@@ -215,7 +215,7 @@ func test(mode int) {
 				break
 			}
 			// 如果 p1收到udp，则作为下层协议输入到kcp1
-			kcp1.Input(buffer[:hr])
+			kcp1.Input(buffer[:hr], true)
 			//println("@@@@", hr, r)
 		}
 

sess.go

@@ -533,7 +533,7 @@ func (s *UDPSession) kcpInput(data []byte) {
 					sz := binary.LittleEndian.Uint16(recovers[k])
 					if int(sz) <= len(recovers[k]) && sz >= 2 {
 						s.kcp.current = currentMs()
-						s.kcp.Input(recovers[k][2:sz])
+						s.kcp.Input(recovers[k][2:sz], false)
 						atomic.AddUint64(&DefaultSnmp.FECRecovered, 1)
 					} else {
 						atomic.AddUint64(&DefaultSnmp.FECErrs, 1)
@@ -543,12 +543,12 @@ func (s *UDPSession) kcpInput(data []byte) {
 		}
 		if f.flag == typeData {
 			s.kcp.current = currentMs()
-			s.kcp.Input(data[fecHeaderSizePlus2:])
+			s.kcp.Input(data[fecHeaderSizePlus2:], true)
 		}
 
 	} else {
 		s.kcp.current = currentMs()
-		s.kcp.Input(data)
+		s.kcp.Input(data, true)
 	}
 
 	if s.ackNoDelay {