yggdrasil-network/yggdrasil-go
1
0
Fork 0
mirror of https://github.com/yggdrasil-network/yggdrasil-go.git synced 2025-04-28 22:25:07 +03:00
Code Issues Projects Releases Packages Wiki Activity Actions

Dialer timeout equals 5sec for ctl requests

Browse source
This commit is contained in:
vadym 2022-12-07 18:48:44 +02:00
parent ff4f587f00
commit 552cc014d9
1 changed files with 5 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

9
cmd/meshctl/main.go
View file

@ -13,12 +13,12 @@ import (
"strings" "strings"
"time" "time"
"github.com/olekukonko/tablewriter"
"github.com/RiV-chain/RiV-mesh/src/admin" "github.com/RiV-chain/RiV-mesh/src/admin"
"github.com/RiV-chain/RiV-mesh/src/core" "github.com/RiV-chain/RiV-mesh/src/core"
"github.com/RiV-chain/RiV-mesh/src/multicast" "github.com/RiV-chain/RiV-mesh/src/multicast"
"github.com/RiV-chain/RiV-mesh/src/tun" "github.com/RiV-chain/RiV-mesh/src/tun"
"github.com/RiV-chain/RiV-mesh/src/version" "github.com/RiV-chain/RiV-mesh/src/version"
"github.com/olekukonko/tablewriter"
) )
func main() { func main() {
@ -58,21 +58,22 @@ func run() int {
var conn net.Conn var conn net.Conn
u, err := url.Parse(cmdLineEnv.endpoint) u, err := url.Parse(cmdLineEnv.endpoint)
d := net.Dialer{Timeout: 5000 * time.Millisecond}
if err == nil { if err == nil {
switch strings.ToLower(u.Scheme) { switch strings.ToLower(u.Scheme) {
case "unix": case "unix":
logger.Println("Connecting to UNIX socket", cmdLineEnv.endpoint[7:]) logger.Println("Connecting to UNIX socket", cmdLineEnv.endpoint[7:])
conn, err = net.Dial("unix", cmdLineEnv.endpoint[7:]) conn, err = d.Dial("unix", cmdLineEnv.endpoint[7:])
case "tcp": case "tcp":
logger.Println("Connecting to TCP socket", u.Host) logger.Println("Connecting to TCP socket", u.Host)
conn, err = net.Dial("tcp", u.Host) conn, err = d.Dial("tcp", u.Host)
default: default:
logger.Println("Unknown protocol or malformed address - check your endpoint") logger.Println("Unknown protocol or malformed address - check your endpoint")
err = errors.New("protocol not supported") err = errors.New("protocol not supported")
} }
} else { } else {
logger.Println("Connecting to TCP socket", u.Host) logger.Println("Connecting to TCP socket", u.Host)
conn, err = net.Dial("tcp", cmdLineEnv.endpoint) conn, err = d.Dial("tcp", cmdLineEnv.endpoint)
} }
if err != nil { if err != nil {
panic(err) panic(err)