SagerNet/sing
1
0
Fork 0
mirror of https://github.com/SagerNet/sing.git synced 2025-04-05 12:57:38 +03:00
Code Issues Projects Releases Packages Wiki Activity Actions

Fix write cached packets

Browse source
This commit is contained in:
世界 2023-05-01 12:41:32 +08:00
parent 7662278795
commit 8365dd48a1
No known key found for this signature in database
GPG key ID: CD109927C34A63C4
1 changed files with 1 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

3
common/bufio/copy.go
View file

@ -413,7 +413,6 @@ func CopyPacketWithPool(destinationConn N.PacketWriter, source N.PacketReader, r
func WritePacketWithPool(destinationConn N.PacketWriter, packetBuffers []*N.PacketBuffer) (n int64, err error) { func WritePacketWithPool(destinationConn N.PacketWriter, packetBuffers []*N.PacketBuffer) (n int64, err error) {
frontHeadroom := N.CalculateFrontHeadroom(destinationConn) frontHeadroom := N.CalculateFrontHeadroom(destinationConn)
rearHeadroom := N.CalculateRearHeadroom(destinationConn) rearHeadroom := N.CalculateRearHeadroom(destinationConn)
var destination M.Socksaddr
for _, packetBuffer := range packetBuffers { for _, packetBuffer := range packetBuffers {
buffer := buf.NewPacket() buffer := buf.NewPacket()
readBufferRaw := buffer.Slice() readBufferRaw := buffer.Slice()
@ -426,7 +425,7 @@ func WritePacketWithPool(destinationConn N.PacketWriter, packetBuffers []*N.Pack
} }
dataLen := readBuffer.Len() dataLen := readBuffer.Len()
buffer.Resize(readBuffer.Start(), dataLen) buffer.Resize(readBuffer.Start(), dataLen)
err = destinationConn.WritePacket(buffer, destination) err = destinationConn.WritePacket(buffer, packetBuffer.Destination)
if err != nil { if err != nil {
buffer.Release() buffer.Release()
return return