mirrors/wireproxy
1
0
Fork 0
mirror of https://github.com/whyvl/wireproxy.git synced 2025-04-29 19:01:42 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

fix stupid mistakes

Browse source
This commit is contained in:
octeep 2022-10-07 13:47:06 +01:00 • committed by octeep
parent 2c8b0d7b9b
commit bffb13f4c3
1 changed files with 3 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

6
tunnel.go
View file

@ -141,16 +141,16 @@ func (d *VirtualTun) TCPHandle(s *socks5.Server, c *net.TCPConn, r *socks5.Reque
d.natEntryToMappedPort.Set(srcAddr, entry, 0) d.natEntryToMappedPort.Set(srcAddr, entry, 0)
go func() { go func() {
buf := make([]byte, 65536) buf := make([]byte, 65536)
var b [65507]byte for n, from, err := conn.ReadFrom(buf); err == nil; n, from, err = conn.ReadFrom(buf) {
for n, from, err := conn.ReadFrom(buf); err == nil; {
a, addr, port, err := socks5.ParseAddress(from.String()) a, addr, port, err := socks5.ParseAddress(from.String())
if err != nil { if err != nil {
log.Println(err) log.Println(err)
break break
} }
d.natEntryToMappedPort.Set(srcAddr, entry, 0) d.natEntryToMappedPort.Set(srcAddr, entry, 0)
d1 := socks5.NewDatagram(a, addr, port, b[0:n]) d1 := socks5.NewDatagram(a, addr, port, buf[0:n])
if _, err := s.UDPConn.WriteToUDP(d1.Bytes(), caddr); err != nil { if _, err := s.UDPConn.WriteToUDP(d1.Bytes(), caddr); err != nil {
log.Println(err)
break break
} }
} }