Shikong/Clash.Meta
1
0
Fork 0
mirror of https://gitclone.com/github.com/MetaCubeX/Clash.Meta synced 2025-04-27 05:38:03 +08:00
Code Issues Packages Projects Releases Wiki Activity

Fix: ss udp return error when addr parse failed

Browse Source
This commit is contained in:
Dreamacro 2020-03-01 01:46:02 +08:00
parent e81b88fb94
commit 814bd05315
2 changed files with 8 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
adapters/outbound/shadowsocks.go
View File

@ -4,6 +4,7 @@ import (
"context" "context"
"crypto/tls" "crypto/tls"
"encoding/json" "encoding/json"
"errors"
"fmt" "fmt"
"net" "net"
"strconv" "strconv"
@ -209,7 +210,12 @@ func (spc *ssPacketConn) ReadFrom(b []byte) (int, net.Addr, error) {
if e != nil { if e != nil {
return 0, nil, e return 0, nil, e
} }
addr := socks5.SplitAddr(b[:n]) addr := socks5.SplitAddr(b[:n])
if addr == nil {
return 0, nil, errors.New("parse addr error")
}
copy(b, b[len(addr):]) copy(b, b[len(addr):])
return n - len(addr), addr.UDPAddr(), e return n - len(addr), addr.UDPAddr(), e
} }

5
adapters/outbound/socks5.go
View File

@ -161,7 +161,7 @@ func (uc *socksPacketConn) WriteWithMetadata(p []byte, metadata *C.Metadata) (n
} }
func (uc *socksPacketConn) ReadFrom(b []byte) (int, net.Addr, error) { func (uc *socksPacketConn) ReadFrom(b []byte) (int, net.Addr, error) {
n, a, e := uc.PacketConn.ReadFrom(b) n, _, e := uc.PacketConn.ReadFrom(b)
if e != nil { if e != nil {
return 0, nil, e return 0, nil, e
} }
@ -170,9 +170,8 @@ func (uc *socksPacketConn) ReadFrom(b []byte) (int, net.Addr, error) {
return 0, nil, err return 0, nil, err
} }
// due to DecodeUDPPacket is mutable, record addr length // due to DecodeUDPPacket is mutable, record addr length
addrLength := len(addr)
copy(b, payload) copy(b, payload)
return n - addrLength - 3, a, nil return n - len(addr) - 3, addr.UDPAddr(), nil
} }
func (uc *socksPacketConn) Close() error { func (uc *socksPacketConn) Close() error {