mirror of
https://gitclone.com/github.com/MetaCubeX/Clash.Meta
synced 2025-04-24 20:28:11 +08:00
parent
b50071ed37
commit
e59c35a308
@ -212,6 +212,9 @@ func (c *ObfsUDPHopClientPacketConn) ReadFrom(b []byte) (int, net.Addr, error) {
|
|||||||
func (c *ObfsUDPHopClientPacketConn) WriteTo(b []byte, addr net.Addr) (int, error) {
|
func (c *ObfsUDPHopClientPacketConn) WriteTo(b []byte, addr net.Addr) (int, error) {
|
||||||
c.connMutex.RLock()
|
c.connMutex.RLock()
|
||||||
defer c.connMutex.RUnlock()
|
defer c.connMutex.RUnlock()
|
||||||
|
if c.closed {
|
||||||
|
return 0, net.ErrClosed
|
||||||
|
}
|
||||||
/*
|
/*
|
||||||
// Check if the address is the server address
|
// Check if the address is the server address
|
||||||
if addr.String() != c.serverAddr.String() {
|
if addr.String() != c.serverAddr.String() {
|
||||||
@ -237,6 +240,7 @@ func (c *ObfsUDPHopClientPacketConn) Close() error {
|
|||||||
err := c.currentConn.Close()
|
err := c.currentConn.Close()
|
||||||
close(c.closeChan)
|
close(c.closeChan)
|
||||||
c.closed = true
|
c.closed = true
|
||||||
|
c.serverAddrs = nil // For GC
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user