Xray-core/transport/internet/udp/dialer.go

27 lines
706 B
Go
Raw Permalink Normal View History

2020-11-25 14:01:53 +03:00
package udp
import (
"context"
2020-12-04 04:36:16 +03:00
"github.com/xtls/xray-core/common"
"github.com/xtls/xray-core/common/net"
"github.com/xtls/xray-core/transport/internet"
"github.com/xtls/xray-core/transport/internet/stat"
2020-11-25 14:01:53 +03:00
)
func init() {
common.Must(internet.RegisterTransportDialer(protocolName,
func(ctx context.Context, dest net.Destination, streamSettings *internet.MemoryStreamConfig) (stat.Connection, error) {
2020-11-25 14:01:53 +03:00
var sockopt *internet.SocketConfig
if streamSettings != nil {
sockopt = streamSettings.SocketSettings
}
conn, err := internet.DialSystem(ctx, dest, sockopt)
if err != nil {
return nil, err
}
// TODO: handle dialer options
return stat.Connection(conn), nil
2020-11-25 14:01:53 +03:00
}))
}