From 16b0610a85511a53829cdaab922b99b5a3f69433 Mon Sep 17 00:00:00 2001 From: xtaci Date: Fri, 5 Jan 2024 22:32:14 +0800 Subject: [PATCH] remove unused param --- fec.go | 2 +- fec_test.go | 2 +- sess.go | 4 ++-- 3 files changed, 4 insertions(+), 4 deletions(-) diff --git a/fec.go b/fec.go index 7d43543..e2a4ab6 100644 --- a/fec.go +++ b/fec.go @@ -288,7 +288,7 @@ type ( } ) -func newFECEncoder(dataShards, parityShards, offset, minRTO int) *fecEncoder { +func newFECEncoder(dataShards, parityShards, offset int) *fecEncoder { if dataShards <= 0 || parityShards <= 0 { return nil } diff --git a/fec_test.go b/fec_test.go index 46a6a45..56c35a1 100644 --- a/fec_test.go +++ b/fec_test.go @@ -35,7 +35,7 @@ func BenchmarkFECEncode(b *testing.B) { b.ReportAllocs() b.SetBytes(payLoad) - encoder := newFECEncoder(dataSize, paritySize, 0, 200) + encoder := newFECEncoder(dataSize, paritySize, 0) for i := 0; i < b.N; i++ { data := make([]byte, payLoad) encoder.encode(data, 200) diff --git a/sess.go b/sess.go index a4a1b45..227d99b 100644 --- a/sess.go +++ b/sess.go @@ -154,9 +154,9 @@ func newUDPSession(conv uint32, dataShards, parityShards int, l *Listener, conn // FEC codec initialization sess.fecDecoder = newFECDecoder(dataShards, parityShards) if sess.block != nil { - sess.fecEncoder = newFECEncoder(dataShards, parityShards, cryptHeaderSize, IKCP_RTO_DEF) + sess.fecEncoder = newFECEncoder(dataShards, parityShards, cryptHeaderSize) } else { - sess.fecEncoder = newFECEncoder(dataShards, parityShards, 0, IKCP_RTO_DEF) + sess.fecEncoder = newFECEncoder(dataShards, parityShards, 0) } // calculate additional header size introduced by FEC and encryption