2017-07-13 21:55:41 +08:00
|
|
|
package main
|
|
|
|
|
|
|
|
import "net"
|
|
|
|
|
|
|
|
// direct proxy
|
|
|
|
type direct struct {
|
|
|
|
}
|
|
|
|
|
|
|
|
// Direct proxy
|
2017-07-30 01:54:19 +08:00
|
|
|
var Direct = &direct{}
|
2017-07-13 21:55:41 +08:00
|
|
|
|
2017-08-23 16:35:39 +08:00
|
|
|
func (d *direct) Addr() string { return "DIRECT" }
|
2017-07-13 21:55:41 +08:00
|
|
|
|
|
|
|
func (d *direct) Dial(network, addr string) (net.Conn, error) {
|
2018-01-12 20:11:21 +08:00
|
|
|
if network == "uot" {
|
|
|
|
network = "udp"
|
|
|
|
}
|
2017-07-13 21:55:41 +08:00
|
|
|
c, err := net.Dial(network, addr)
|
|
|
|
if c, ok := c.(*net.TCPConn); ok {
|
|
|
|
c.SetKeepAlive(true)
|
|
|
|
}
|
|
|
|
return c, err
|
|
|
|
}
|
2017-08-23 17:45:57 +08:00
|
|
|
|
2018-01-12 20:11:21 +08:00
|
|
|
func (d *direct) DialUDP(network, addr string) (net.PacketConn, error) {
|
|
|
|
uAddr, err := net.ResolveUDPAddr(network, addr)
|
|
|
|
if err != nil {
|
|
|
|
logf("ResolveUDPAddr error: %s", err)
|
|
|
|
return nil, err
|
|
|
|
}
|
|
|
|
|
|
|
|
return net.DialUDP("udp", nil, uAddr)
|
|
|
|
}
|
|
|
|
|
2017-08-23 17:45:57 +08:00
|
|
|
func (d *direct) NextDialer(dstAddr string) Dialer { return d }
|