mirror of
https://github.com/MetaCubeX/mihomo.git
synced 2025-12-20 00:50:06 +08:00
9e57b298bf
Some checks failed
Test / test (1.20, ubuntu-latest) (push) Failing after 1s
Test / test (1.21, ubuntu-latest) (push) Failing after 1s
Test / test (1.22, ubuntu-latest) (push) Failing after 1s
Test / test (1.23, ubuntu-latest) (push) Failing after 1s
Test / test (1.24, ubuntu-latest) (push) Failing after 1s
Trigger CMFA Update / trigger-CMFA-update (push) Failing after 1s
Test / test (1.20, macos-13) (push) Has been cancelled
Test / test (1.20, macos-latest) (push) Has been cancelled
Test / test (1.20, ubuntu-24.04-arm) (push) Has been cancelled
Test / test (1.20, windows-latest) (push) Has been cancelled
Test / test (1.21, macos-13) (push) Has been cancelled
Test / test (1.21, macos-latest) (push) Has been cancelled
Test / test (1.21, ubuntu-24.04-arm) (push) Has been cancelled
Test / test (1.21, windows-latest) (push) Has been cancelled
Test / test (1.22, macos-13) (push) Has been cancelled
Test / test (1.22, macos-latest) (push) Has been cancelled
Test / test (1.22, ubuntu-24.04-arm) (push) Has been cancelled
Test / test (1.22, windows-latest) (push) Has been cancelled
Test / test (1.23, macos-13) (push) Has been cancelled
Test / test (1.23, macos-latest) (push) Has been cancelled
Test / test (1.23, ubuntu-24.04-arm) (push) Has been cancelled
Test / test (1.23, windows-latest) (push) Has been cancelled
Test / test (1.24, macos-13) (push) Has been cancelled
Test / test (1.24, macos-latest) (push) Has been cancelled
Test / test (1.24, ubuntu-24.04-arm) (push) Has been cancelled
Test / test (1.24, windows-latest) (push) Has been cancelled
78 lines
1.6 KiB
Go
78 lines
1.6 KiB
Go
package packet
|
|
|
|
import (
|
|
"net"
|
|
|
|
"github.com/metacubex/sing/common/buf"
|
|
"github.com/metacubex/sing/common/bufio"
|
|
M "github.com/metacubex/sing/common/metadata"
|
|
N "github.com/metacubex/sing/common/network"
|
|
)
|
|
|
|
type SingPacketConn = N.NetPacketConn
|
|
|
|
type EnhanceSingPacketConn interface {
|
|
SingPacketConn
|
|
EnhancePacketConn
|
|
}
|
|
|
|
type enhanceSingPacketConn struct {
|
|
SingPacketConn
|
|
packetReadWaiter N.PacketReadWaiter
|
|
}
|
|
|
|
func (c *enhanceSingPacketConn) WaitReadFrom() (data []byte, put func(), addr net.Addr, err error) {
|
|
var buff *buf.Buffer
|
|
var dest M.Socksaddr
|
|
rwOptions := N.ReadWaitOptions{}
|
|
if c.packetReadWaiter != nil {
|
|
c.packetReadWaiter.InitializeReadWaiter(rwOptions)
|
|
buff, dest, err = c.packetReadWaiter.WaitReadPacket()
|
|
} else {
|
|
buff = rwOptions.NewPacketBuffer()
|
|
dest, err = c.SingPacketConn.ReadPacket(buff)
|
|
if buff != nil {
|
|
rwOptions.PostReturn(buff)
|
|
}
|
|
}
|
|
if dest.IsFqdn() {
|
|
addr = dest
|
|
} else {
|
|
addr = dest.UDPAddr()
|
|
}
|
|
if err != nil {
|
|
buff.Release()
|
|
return
|
|
}
|
|
if buff == nil {
|
|
return
|
|
}
|
|
if buff.IsEmpty() {
|
|
buff.Release()
|
|
return
|
|
}
|
|
data = buff.Bytes()
|
|
put = buff.Release
|
|
return
|
|
}
|
|
|
|
func (c *enhanceSingPacketConn) Upstream() any {
|
|
return c.SingPacketConn
|
|
}
|
|
|
|
func (c *enhanceSingPacketConn) WriterReplaceable() bool {
|
|
return true
|
|
}
|
|
|
|
func (c *enhanceSingPacketConn) ReaderReplaceable() bool {
|
|
return true
|
|
}
|
|
|
|
func newEnhanceSingPacketConn(conn SingPacketConn) *enhanceSingPacketConn {
|
|
epc := &enhanceSingPacketConn{SingPacketConn: conn}
|
|
if readWaiter, isReadWaiter := bufio.CreatePacketReadWaiter(conn); isReadWaiter {
|
|
epc.packetReadWaiter = readWaiter
|
|
}
|
|
return epc
|
|
}
|