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

Minor fixes

Browse source
This commit is contained in:
世界 2024-03-25 01:53:37 +08:00
parent 3c842cd21e
commit f846946810
No known key found for this signature in database
GPG key ID: CD109927C34A63C4
6 changed files with 21 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

5
hysteria/packet.go
View file

@ -400,6 +400,11 @@ func (d *udpDefragger) feed(m *udpMessage) *udpMessage {
} }
item.messages = nil item.messages = nil
return newMessage return newMessage
} else {
newMessage.release()
for _, message := range item.messages {
message.releaseMessage()
}
} }
item.messages = nil item.messages = nil
return nil return nil

4
hysteria/packet_wait.go
View file

@ -20,11 +20,11 @@ func (c *udpPacketConn) WaitReadPacket() (buffer *buf.Buffer, destination M.Sock
if c.readWaitOptions.NeedHeadroom() { if c.readWaitOptions.NeedHeadroom() {
buffer = c.readWaitOptions.NewPacketBuffer() buffer = c.readWaitOptions.NewPacketBuffer()
_, err = buffer.Write(p.data.Bytes()) _, err = buffer.Write(p.data.Bytes())
p.releaseMessage()
if err != nil { if err != nil {
buffer.Release() buffer.Release()
return nil, M.Socksaddr{}, err return
} }
p.releaseMessage()
c.readWaitOptions.PostReturn(buffer) c.readWaitOptions.PostReturn(buffer)
} else { } else {
buffer = p.data buffer = p.data

5
hysteria2/packet.go
View file

@ -392,6 +392,11 @@ func (d *udpDefragger) feed(m *udpMessage) *udpMessage {
} }
item.messages = nil item.messages = nil
return newMessage return newMessage
} else {
newMessage.releaseMessage()
for _, message := range item.messages {
message.releaseMessage()
}
} }
item.messages = nil item.messages = nil
return nil return nil

4
hysteria2/packet_wait.go
View file

@ -20,11 +20,11 @@ func (c *udpPacketConn) WaitReadPacket() (buffer *buf.Buffer, destination M.Sock
if c.readWaitOptions.NeedHeadroom() { if c.readWaitOptions.NeedHeadroom() {
buffer = c.readWaitOptions.NewPacketBuffer() buffer = c.readWaitOptions.NewPacketBuffer()
_, err = buffer.Write(p.data.Bytes()) _, err = buffer.Write(p.data.Bytes())
p.releaseMessage()
if err != nil { if err != nil {
buffer.Release() buffer.Release()
return nil, M.Socksaddr{}, err return
} }
p.releaseMessage()
c.readWaitOptions.PostReturn(buffer) c.readWaitOptions.PostReturn(buffer)
} else { } else {
buffer = p.data buffer = p.data

5
tuic/packet.go
View file

@ -437,6 +437,11 @@ func (d *udpDefragger) feed(m *udpMessage) *udpMessage {
} }
item.messages = nil item.messages = nil
return newMessage return newMessage
} else {
newMessage.releaseMessage()
for _, message := range item.messages {
message.releaseMessage()
}
} }
item.messages = nil item.messages = nil
return nil return nil

4
tuic/packet_wait.go
View file

@ -19,12 +19,12 @@ func (c *udpPacketConn) WaitReadPacket() (buffer *buf.Buffer, destination M.Sock
destination = p.destination destination = p.destination
if c.readWaitOptions.NeedHeadroom() { if c.readWaitOptions.NeedHeadroom() {
buffer = c.readWaitOptions.NewPacketBuffer() buffer = c.readWaitOptions.NewPacketBuffer()
p.releaseMessage()
_, err = buffer.Write(p.data.Bytes()) _, err = buffer.Write(p.data.Bytes())
if err != nil { if err != nil {
buffer.Release() buffer.Release()
return nil, M.Socksaddr{}, err return
} }
p.releaseMessage()
c.readWaitOptions.PostReturn(buffer) c.readWaitOptions.PostReturn(buffer)
} else { } else {
buffer = p.data buffer = p.data