sockopt_linux.go 1.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142
  1. // +build linux
  2. package tcp
  3. import (
  4. "syscall"
  5. "v2ray.com/core/app/log"
  6. "v2ray.com/core/common/net"
  7. "v2ray.com/core/transport/internet"
  8. )
  9. const SO_ORIGINAL_DST = 80
  10. func GetOriginalDestination(conn internet.Connection) (net.Destination, error) {
  11. sysrawconn, f := conn.(syscall.Conn)
  12. if !f {
  13. return net.Destination{}, newError("unable to get syscall.Conn")
  14. }
  15. rawConn, err := sysrawconn.SyscallConn()
  16. if err != nil {
  17. return net.Destination{}, newError("failed to get sys fd").Base(err)
  18. }
  19. var dest net.Destination
  20. err = rawConn.Control(func(fd uintptr) {
  21. addr, err := syscall.GetsockoptIPv6Mreq(int(fd), syscall.IPPROTO_IP, SO_ORIGINAL_DST)
  22. if err != nil {
  23. log.Trace(newError("failed to call getsockopt").Base(err))
  24. return
  25. }
  26. ip := net.IPAddress(addr.Multiaddr[4:8])
  27. port := uint16(addr.Multiaddr[2])<<8 + uint16(addr.Multiaddr[3])
  28. dest = net.TCPDestination(ip, net.Port(port))
  29. })
  30. if err != nil {
  31. return net.Destination{}, newError("failed to control connection").Base(err)
  32. }
  33. if !dest.IsValid() {
  34. return net.Destination{}, newError("failed to call getsockopt")
  35. }
  36. return dest, nil
  37. }