yanistyle/sing-box-extended
1
0
Fork 0
mirror of https://github.com/shtorm-7/sing-box-extended.git synced 2026-07-18 21:44:16 +03:00
Code Issues Packages Projects Releases Wiki Activity

Fix concurrent write

Browse Source
This commit is contained in:
世界
2022-09-13 10:16:10 +08:00
parent a5163e3e3c
commit 925fbca363
20 changed files with 128 additions and 58 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
inbound/default_udp.go
View File

@@ -203,17 +203,12 @@ func (s *myInboundPacketAdapter) Upstream() any {
}
func (s *myInboundPacketAdapter) WritePacket(buffer *buf.Buffer, destination M.Socksaddr) error {
s.packetAccess.RLock()
defer s.packetAccess.RUnlock()
select {
case s.packetOutbound <- &myInboundPacket{buffer, destination}:
return nil
case <-s.packetOutboundClosed:
return os.ErrClosed
default:
}
s.packetOutbound <- &myInboundPacket{buffer, destination}
return nil
}
func (s *myInboundPacketAdapter) Close() error {