diff --git a/transport/internet/kcp/kcp.go b/transport/internet/kcp/kcp.go index 39985a97..3e806f1e 100644 --- a/transport/internet/kcp/kcp.go +++ b/transport/internet/kcp/kcp.go @@ -151,7 +151,7 @@ func (kcp *KCP) Input(data []byte) int { kcp.lastPayloadTime = kcp.current case *AckSegment: kcp.HandleOption(seg.Opt) - kcp.sendingWorker.ProcessAckSegment(seg) + kcp.sendingWorker.ProcessSegment(seg) kcp.lastPayloadTime = kcp.current case *CmdOnlySegment: kcp.HandleOption(seg.Opt) diff --git a/transport/internet/kcp/sending.go b/transport/internet/kcp/sending.go index 97cb3fbe..e08bfeb4 100644 --- a/transport/internet/kcp/sending.go +++ b/transport/internet/kcp/sending.go @@ -273,7 +273,7 @@ func (this *SendingWorker) ProcessAck(number uint32) { this.FindFirstUnacknowledged() } -func (this *SendingWorker) ProcessAckSegment(seg *AckSegment) { +func (this *SendingWorker) ProcessSegment(seg *AckSegment) { if this.remoteNextNumber < seg.ReceivingWindow { this.remoteNextNumber = seg.ReceivingWindow }