apps/kubevpn
1
0
Fork 0
mirror of https://github.com/kubenetworks/kubevpn.git synced 2025-12-24 11:51:13 +08:00
Code Issues Packages Projects Releases Wiki Activity

avoid tcp to send multiple small package

Browse Source
This commit is contained in:
p_caiwfeng
2022-04-07 14:03:08 +08:00
parent 6d5597c977
commit 008b228746
1 changed files with 6 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
core/udpovertcp.go
View File

@@ -43,13 +43,10 @@ func readDatagramPacket(r io.Reader, b []byte) (*datagramPacket, error) {
}
func (addr *datagramPacket) Write(w io.Writer) error {
b := make([]byte, 2)
binary.BigEndian.PutUint16(b[:], uint16(len(addr.Data)))
if _, err := w.Write(b); err != nil {
return err
}
if _, err := w.Write(addr.Data); err != nil {
return err
}
return nil
b := LPool.Get().([]byte)
defer LPool.Put(b)
binary.BigEndian.PutUint16(b[:2], uint16(len(addr.Data)))
n := copy(b[2:], addr.Data)
_, err := w.Write(b[:n+2])
return err
}