github-mirrors/VictoriaMetrics
1
0
Fork 0
mirror of https://github.com/VictoriaMetrics/VictoriaMetrics.git synced 2024-11-21 14:44:00 +00:00
Code Issues Projects Releases Packages Wiki Activity

lib/netutil: use IPv6 for both listening and dialing if -enabledTCP6 is set

Browse source 
Updates https://github.com/VictoriaMetrics/VictoriaMetrics/issues/244
This commit is contained in:
Aliaksandr Valialkin 2019-12-01 02:52:22 +02:00
parent 811b7a8303
commit 761645b20a
1 changed files with 10 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

16
lib/netutil/tcplistener.go
View file

@ -9,18 +9,14 @@ import (
"github.com/VictoriaMetrics/metrics" "github.com/VictoriaMetrics/metrics"
) )
var enableTCP6 = flag.Bool("enableTCP6", false, "Whether to enable listening for IPv6 TCP ports. By default only IPv4 TCP ports are listened") var enableTCP6 = flag.Bool("enableTCP6", false, "Whether to enable IPv6 for listening and dialing. By default only IPv4 TCP is used")
// NewTCPListener returns new TCP listener for the given addr. // NewTCPListener returns new TCP listener for the given addr.
// //
// name is used for exported metrics. Each listener in the program must have // name is used for exported metrics. Each listener in the program must have
// distinct name. // distinct name.
func NewTCPListener(name, addr string) (*TCPListener, error) { func NewTCPListener(name, addr string) (*TCPListener, error) {
network := "tcp4" network := getNetwork()
if *enableTCP6 {
// Enable listening on both tcp4 and tcp6
network = "tcp"
}
ln, err := net.Listen(network, addr) ln, err := net.Listen(network, addr)
if err != nil { if err != nil {
return nil, err return nil, err
@ -35,6 +31,14 @@ func NewTCPListener(name, addr string) (*TCPListener, error) {
return tln, err return tln, err
} }
func getNetwork() string {
if *enableTCP6 {
// Enable both tcp4 and tcp6
return "tcp"
}
return "tcp4"
}
// TCPListener listens for the addr passed to NewTCPListener. // TCPListener listens for the addr passed to NewTCPListener.
// //
// It also gathers various stats for the accepted connections. // It also gathers various stats for the accepted connections.