GuanM/hysteria
1
0
Fork 0
mirror of https://github.com/cedar2025/hysteria.git synced 2025-06-15 08:59:54 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

feat(server): IPv6 only mode

Browse Source 
fix #168
This commit is contained in:
Haruue Icymoon 2021-12-09 18:38:35 +08:00
parent d7bda39f9e
commit 476e045451
No known key found for this signature in database
GPG Key ID: F6083B28CBCBC148
3 changed files with 19 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
cmd/config.go
View File

@ -46,6 +46,7 @@ type serverConfig struct {
ReceiveWindowClient uint64 `json:"recv_window_client"` ReceiveWindowClient uint64 `json:"recv_window_client"`
MaxConnClient int `json:"max_conn_client"` MaxConnClient int `json:"max_conn_client"`
DisableMTUDiscovery bool `json:"disable_mtu_discovery"` DisableMTUDiscovery bool `json:"disable_mtu_discovery"`
IPv6Only bool `json:"ipv6_only"`
} }
func (c *serverConfig) Check() error { func (c *serverConfig) Check() error {

4
cmd/server.go
View File

@ -128,6 +128,10 @@ func server(config *serverConfig) {
if len(config.Obfs) > 0 { if len(config.Obfs) > 0 {
obfuscator = obfs.NewXPlusObfuscator([]byte(config.Obfs)) obfuscator = obfs.NewXPlusObfuscator([]byte(config.Obfs))
} }
// IPv6 only mode
if config.IPv6Only {
transport.DefaultTransport = transport.IPv6OnlyTransport
}
// ACL // ACL
var aclEngine *acl.Engine var aclEngine *acl.Engine
if len(config.ACL) > 0 { if len(config.ACL) > 0 {

14
pkg/transport/transport.go
View File

@ -22,6 +22,12 @@ var DefaultTransport Transport = &defaultTransport{
Timeout: 8 * time.Second, Timeout: 8 * time.Second,
} }
var IPv6OnlyTransport Transport = &ipv6OnlyTransport{
defaultTransport{
Timeout: 8 * time.Second,
},
}
type defaultTransport struct { type defaultTransport struct {
Timeout time.Duration Timeout time.Duration
} }
@ -67,3 +73,11 @@ func (t *defaultTransport) LocalListenTCP(laddr *net.TCPAddr) (*net.TCPListener,
func (t *defaultTransport) LocalListenUDP(laddr *net.UDPAddr) (*net.UDPConn, error) { func (t *defaultTransport) LocalListenUDP(laddr *net.UDPAddr) (*net.UDPConn, error) {
return net.ListenUDP("udp", laddr) return net.ListenUDP("udp", laddr)
} }
type ipv6OnlyTransport struct {
defaultTransport
}
func (t *ipv6OnlyTransport) LocalResolveIPAddr(address string) (*net.IPAddr, error) {
return net.ResolveIPAddr("ip6", address)
}