From ff34f7683f9faefd185e1afdc873c112e4343fde Mon Sep 17 00:00:00 2001 From: xtaci Date: Fri, 9 Oct 2020 15:18:00 +0800 Subject: [PATCH] fix test --- fec.go | 1 + fec_test.go | 2 +- sess_test.go | 2 +- 3 files changed, 3 insertions(+), 2 deletions(-) diff --git a/fec.go b/fec.go index 576e45f..1e33319 100644 --- a/fec.go +++ b/fec.go @@ -110,6 +110,7 @@ func (dec *fecDecoder) decode(in fecPacket) (recovered [][]byte) { dec.codec = codec dec.decodeCache = make([][]byte, dec.shardSize) dec.flagCache = make([]bool, dec.shardSize) + //log.Println("autotune to :", dec.dataShards, dec.parityShards) } } diff --git a/fec_test.go b/fec_test.go index fffc69b..59b64ac 100644 --- a/fec_test.go +++ b/fec_test.go @@ -10,7 +10,7 @@ func BenchmarkFECDecode(b *testing.B) { const dataSize = 10 const paritySize = 3 const payLoad = 1500 - decoder := newFECDecoder(1024, dataSize, paritySize) + decoder := newFECDecoder(dataSize, paritySize) b.ReportAllocs() b.SetBytes(payLoad) for i := 0; i < b.N; i++ { diff --git a/sess_test.go b/sess_test.go index 8c223d5..c3f9889 100644 --- a/sess_test.go +++ b/sess_test.go @@ -34,7 +34,7 @@ func dialEcho(port int) (*UDPSession, error) { //block, _ := NewTEABlockCrypt(pass[:16]) //block, _ := NewAESBlockCrypt(pass) block, _ := NewSalsa20BlockCrypt(pass) - sess, err := DialWithOptions(fmt.Sprintf("127.0.0.1:%v", port), block, 10, 3) + sess, err := DialWithOptions(fmt.Sprintf("127.0.0.1:%v", port), block, 10, 1) if err != nil { panic(err) }