eburet-oss/sing-tun-lx
2
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Skip forward for cast addresses

Browse source
This commit is contained in:
世界 2022-09-16 15:34:59 +08:00
parent 0e80d729a3
commit 0032242c96
No known key found for this signature in database
GPG key ID: CD109927C34A63C4
1 changed files with 13 additions and 9 deletions
Download patch file Download diff file Expand all files Collapse all files

22
system.go
View file

@ -246,7 +246,9 @@ func (s *System) processIPv6(packet clashtcpip.IPv6Packet) error {
func (s *System) processIPv4TCP(packet clashtcpip.IPv4Packet, header clashtcpip.TCPPacket) error { func (s *System) processIPv4TCP(packet clashtcpip.IPv4Packet, header clashtcpip.TCPPacket) error {
source := netip.AddrPortFrom(packet.SourceIP(), header.SourcePort()) source := netip.AddrPortFrom(packet.SourceIP(), header.SourcePort())
destination := netip.AddrPortFrom(packet.DestinationIP(), header.DestinationPort()) destination := netip.AddrPortFrom(packet.DestinationIP(), header.DestinationPort())
if source.Addr() == s.inet4ServerAddress && source.Port() == s.tcpPort { if !destination.Addr().IsGlobalUnicast() {
return common.Error(s.tun.Write(packet))
} else if source.Addr() == s.inet4ServerAddress && source.Port() == s.tcpPort {
session := s.tcpNat.LookupBack(destination.Port()) session := s.tcpNat.LookupBack(destination.Port())
if session == nil { if session == nil {
return E.New("ipv4: tcp: session not found: ", destination.Port()) return E.New("ipv4: tcp: session not found: ", destination.Port())
@ -270,7 +272,9 @@ func (s *System) processIPv4TCP(packet clashtcpip.IPv4Packet, header clashtcpip.
func (s *System) processIPv6TCP(packet clashtcpip.IPv6Packet, header clashtcpip.TCPPacket) error { func (s *System) processIPv6TCP(packet clashtcpip.IPv6Packet, header clashtcpip.TCPPacket) error {
source := netip.AddrPortFrom(packet.SourceIP(), header.SourcePort()) source := netip.AddrPortFrom(packet.SourceIP(), header.SourcePort())
destination := netip.AddrPortFrom(packet.DestinationIP(), header.DestinationPort()) destination := netip.AddrPortFrom(packet.DestinationIP(), header.DestinationPort())
if source.Addr() == s.inet6ServerAddress && source.Port() == s.tcpPort6 { if !destination.Addr().IsGlobalUnicast() {
return common.Error(s.tun.Write(packet))
} else if source.Addr() == s.inet6ServerAddress && source.Port() == s.tcpPort6 {
session := s.tcpNat.LookupBack(destination.Port()) session := s.tcpNat.LookupBack(destination.Port())
if session == nil { if session == nil {
return E.New("ipv6: tcp: session not found: ", destination.Port()) return E.New("ipv6: tcp: session not found: ", destination.Port())
@ -298,13 +302,13 @@ func (s *System) processIPv4UDP(packet clashtcpip.IPv4Packet, header clashtcpip.
if packet.FragmentOffset() != 0 { if packet.FragmentOffset() != 0 {
return E.New("ipv4: udp: fragment dropped") return E.New("ipv4: udp: fragment dropped")
} }
data := buf.As(header.Payload())
if data.Len() == 0 {
return nil
}
source := netip.AddrPortFrom(packet.SourceIP(), header.SourcePort()) source := netip.AddrPortFrom(packet.SourceIP(), header.SourcePort())
destination := netip.AddrPortFrom(packet.DestinationIP(), header.DestinationPort()) destination := netip.AddrPortFrom(packet.DestinationIP(), header.DestinationPort())
if !destination.Addr().IsGlobalUnicast() || destination.Addr().IsMulticast() { if !destination.Addr().IsGlobalUnicast() {
return common.Error(s.tun.Write(packet))
}
data := buf.As(header.Payload())
if data.Len() == 0 {
return nil return nil
} }
metadata := M.Metadata{ metadata := M.Metadata{
@ -321,8 +325,8 @@ func (s *System) processIPv4UDP(packet clashtcpip.IPv4Packet, header clashtcpip.
func (s *System) processIPv6UDP(packet clashtcpip.IPv6Packet, header clashtcpip.UDPPacket) error { func (s *System) processIPv6UDP(packet clashtcpip.IPv6Packet, header clashtcpip.UDPPacket) error {
source := netip.AddrPortFrom(packet.SourceIP(), header.SourcePort()) source := netip.AddrPortFrom(packet.SourceIP(), header.SourcePort())
destination := netip.AddrPortFrom(packet.DestinationIP(), header.DestinationPort()) destination := netip.AddrPortFrom(packet.DestinationIP(), header.DestinationPort())
if !destination.Addr().IsGlobalUnicast() || destination.Addr().IsMulticast() { if !destination.Addr().IsGlobalUnicast() {
return nil return common.Error(s.tun.Write(packet))
} }
data := buf.As(header.Payload()) data := buf.As(header.Payload())
if data.Len() == 0 { if data.Len() == 0 {