diff --git a/app/vminsert/graphite/server.go b/app/vminsert/graphite/server.go index 38abb5afe..f93404dd2 100644 --- a/app/vminsert/graphite/server.go +++ b/app/vminsert/graphite/server.go @@ -10,6 +10,7 @@ import ( "github.com/VictoriaMetrics/VictoriaMetrics/lib/auth" "github.com/VictoriaMetrics/VictoriaMetrics/lib/bytesutil" "github.com/VictoriaMetrics/VictoriaMetrics/lib/logger" + "github.com/VictoriaMetrics/VictoriaMetrics/lib/netutil" "github.com/VictoriaMetrics/metrics" ) @@ -24,7 +25,7 @@ var ( // Serve starts graphite server on the given addr. func Serve(addr string) { logger.Infof("starting TCP Graphite server at %q", addr) - lnTCP, err := net.Listen("tcp4", addr) + lnTCP, err := netutil.NewTCPListener("graphite", addr) if err != nil { logger.Fatalf("cannot start TCP Graphite server at %q: %s", addr, err) } diff --git a/app/vminsert/opentsdb/server.go b/app/vminsert/opentsdb/server.go index d39f524b3..302c1fde2 100644 --- a/app/vminsert/opentsdb/server.go +++ b/app/vminsert/opentsdb/server.go @@ -10,6 +10,7 @@ import ( "github.com/VictoriaMetrics/VictoriaMetrics/lib/auth" "github.com/VictoriaMetrics/VictoriaMetrics/lib/bytesutil" "github.com/VictoriaMetrics/VictoriaMetrics/lib/logger" + "github.com/VictoriaMetrics/VictoriaMetrics/lib/netutil" "github.com/VictoriaMetrics/metrics" ) @@ -24,7 +25,7 @@ var ( // Serve starts OpenTSDB collector on the given addr. func Serve(addr string) { logger.Infof("starting TCP OpenTSDB collector at %q", addr) - lnTCP, err := net.Listen("tcp4", addr) + lnTCP, err := netutil.NewTCPListener("opentsdb", addr) if err != nil { logger.Fatalf("cannot start TCP OpenTSDB collector at %q: %s", addr, err) }