From 31ca7b731df41b01f9281aeb9b147cf2ff1373f4 Mon Sep 17 00:00:00 2001 From: xtaci Date: Tue, 23 Apr 2019 11:59:03 +0800 Subject: [PATCH] rename typeFEC->typeParity --- fec.go | 4 ++-- fec_test.go | 2 +- sess.go | 4 ++-- 3 files changed, 5 insertions(+), 5 deletions(-) diff --git a/fec.go b/fec.go index dde2e42..277800a 100644 --- a/fec.go +++ b/fec.go @@ -11,7 +11,7 @@ const ( fecHeaderSize = 6 fecHeaderSizePlus2 = fecHeaderSize + 2 // plus 2B data size typeData = 0xf1 - typeFEC = 0xf2 + typeParity = 0xf2 ) // fecPacket is a decoded FEC packet @@ -298,7 +298,7 @@ func (enc *fecEncoder) markData(data []byte) { func (enc *fecEncoder) markParity(data []byte) { binary.LittleEndian.PutUint32(data, enc.next) - binary.LittleEndian.PutUint16(data[4:], typeFEC) + binary.LittleEndian.PutUint16(data[4:], typeParity) // sequence wrap will only happen at parity shard enc.next = (enc.next + 1) % enc.paws } diff --git a/fec_test.go b/fec_test.go index ec55926..fffc69b 100644 --- a/fec_test.go +++ b/fec_test.go @@ -20,7 +20,7 @@ func BenchmarkFECDecode(b *testing.B) { pkt := make([]byte, payLoad) binary.LittleEndian.PutUint32(pkt, uint32(i)) if i%(dataSize+paritySize) >= dataSize { - binary.LittleEndian.PutUint16(pkt[4:], typeFEC) + binary.LittleEndian.PutUint16(pkt[4:], typeParity) } else { binary.LittleEndian.PutUint16(pkt[4:], typeData) } diff --git a/sess.go b/sess.go index 8b8cc3d..690337f 100644 --- a/sess.go +++ b/sess.go @@ -554,8 +554,8 @@ func (s *UDPSession) kcpInput(data []byte) { if s.fecDecoder != nil { if len(data) > fecHeaderSize { // must be larger than fec header size f := fecPacket(data) - if f.flag() == typeData || f.flag() == typeFEC { // header check - if f.flag() == typeFEC { + if f.flag() == typeData || f.flag() == typeParity { // header check + if f.flag() == typeParity { fecParityShards++ } recovers := s.fecDecoder.decode(f)