From 3e84e4cb4486e5de8736717a63f3f4e37ab6cbea Mon Sep 17 00:00:00 2001 From: v2ray Date: Sat, 2 Jul 2016 11:33:34 +0200 Subject: [PATCH] rename acklist --- transport/internet/kcp/kcp.go | 2 +- transport/internet/kcp/receiving.go | 12 ++++++------ 2 files changed, 7 insertions(+), 7 deletions(-) diff --git a/transport/internet/kcp/kcp.go b/transport/internet/kcp/kcp.go index 81924990..4996f3bf 100644 --- a/transport/internet/kcp/kcp.go +++ b/transport/internet/kcp/kcp.go @@ -46,7 +46,7 @@ type KCP struct { snd_buf *SendingWindow rcv_buf *ReceivingWindow - acklist *ACKList + acklist *AckList fastresend int32 congestionControl bool diff --git a/transport/internet/kcp/receiving.go b/transport/internet/kcp/receiving.go index a64ac1b9..dda22395 100644 --- a/transport/internet/kcp/receiving.go +++ b/transport/internet/kcp/receiving.go @@ -148,15 +148,15 @@ func (this *ReceivingQueue) Close() { close(this.queue) } -type ACKList struct { +type AckList struct { kcp *KCP timestamps []uint32 numbers []uint32 nextFlush []uint32 } -func NewACKList(kcp *KCP) *ACKList { - return &ACKList{ +func NewACKList(kcp *KCP) *AckList { + return &AckList{ kcp: kcp, timestamps: make([]uint32, 0, 32), numbers: make([]uint32, 0, 32), @@ -164,13 +164,13 @@ func NewACKList(kcp *KCP) *ACKList { } } -func (this *ACKList) Add(number uint32, timestamp uint32) { +func (this *AckList) Add(number uint32, timestamp uint32) { this.timestamps = append(this.timestamps, timestamp) this.numbers = append(this.numbers, number) this.nextFlush = append(this.nextFlush, 0) } -func (this *ACKList) Clear(una uint32) { +func (this *AckList) Clear(una uint32) { count := 0 for i := 0; i < len(this.numbers); i++ { if this.numbers[i] >= una { @@ -189,7 +189,7 @@ func (this *ACKList) Clear(una uint32) { } } -func (this *ACKList) Flush() bool { +func (this *AckList) Flush() bool { seg := &ACKSegment{ Conv: this.kcp.conv, ReceivingNext: this.kcp.rcv_nxt,