From 03ff6836861b732ef66762eb91045d30011f6b36 Mon Sep 17 00:00:00 2001 From: v2ray Date: Mon, 4 Jul 2016 14:17:11 +0200 Subject: [PATCH] rename process ack segment --- transport/internet/kcp/kcp.go | 2 +- transport/internet/kcp/sending.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/transport/internet/kcp/kcp.go b/transport/internet/kcp/kcp.go index 39985a97b..3e806f1e6 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 97cb3fbe5..e08bfeb45 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 }