github/kcp-go
4
0
Fork 0
mirror of https://github.com/xtaci/kcp-go.git synced 2024-04-21 12:32:15 +00:00
Code Issues Releases Wiki Activity

remove unused param

Browse Source
This commit is contained in:
xtaci
2024-01-05 22:32:14 +08:00
parent 631cae2218
commit 16b0610a85
3 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
fec.go
+1 -1
View File
@@ -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
}
fec_test.go
+1 -1
View File
@@ -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)
sess.go
+2 -2
View File
@@ -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