7x31
/
anylink
mirror of https://github.com/bjdgyc/anylink.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

优化压缩的代码

This commit is contained in:
lanrenwo 2023-02-16 14:35:55 +08:00
parent 768e137ff9
commit 9533ecd6c5
2 changed files with 8 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
server/handler/link_cstp.go
View File

@ -72,15 +72,14 @@ func LinkCstp(conn net.Conn, bufRW *bufio.ReadWriter, cSess *sessdata.ConnSessio
continue
}
dst := getByteFull()
n, err = cSess.CstpPickCmp.Uncompress(pl.Data[8:], (*dst)[8:])
nn, err := cSess.CstpPickCmp.Uncompress(pl.Data[8:], *dst)
if err != nil {
putByte(dst)
base.Debug("cstp decompress error", n)
base.Error("cstp decompress error", err, nn)
continue
}
copy((*dst)[:8], pl.Data[:8])
binary.BigEndian.PutUint16((*dst)[4:6], uint16(n))
pl.Data = append(pl.Data[:0], (*dst)[:n+8]...)
binary.BigEndian.PutUint16(pl.Data[4:6], uint16(nn))
pl.Data = append(pl.Data[:8], (*dst)[:nn]...)
putByte(dst)
fallthrough
case 0x00: // DATA

9
server/handler/link_dtls.go
View File

@ -74,16 +74,15 @@ func LinkDtls(conn net.Conn, cSess *sessdata.ConnSession) {
continue
}
dst := getByteFull()
n, err = cSess.DtlsPickCmp.Uncompress(pl.Data[1:], (*dst)[1:])
nn, err := cSess.DtlsPickCmp.Uncompress(pl.Data[1:], *dst)
if err != nil {
base.Debug("dtls decompress error, size is ", n)
putByte(dst)
base.Error("dtls decompress error", err, n)
continue
}
n = n + 1
pl.Data = append(pl.Data[:0], (*dst)[:n]...)
pl.Data = append(pl.Data[:1], (*dst)[:nn]...)
putByte(dst)
n = nn + 1
fallthrough
case 0x00: // DATA
// 去除数据头