Mirroristas/etcd
2
0
Fork 0
mirror of https://github.com/etcd-io/etcd.git synced 2024-09-27 06:25:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

embed: explicitly define unix network

Browse Source
This commit is contained in:
Sam Batschelet
2018-02-25 19:52:38 -05:00
parent 367b21c898
commit 2e4f856389
2 changed files with 15 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
embed/etcd.go
View File

@@ -428,12 +428,13 @@ func startClientListeners(cfg *Config) (sctxs map[string]*serveCtx, err error) {
return nil, fmt.Errorf("TLS key/cert (--cert-file, --key-file) must be provided for client url %s with HTTPs scheme", u.String())
}
proto := "tcp"
network := "tcp"
addr := u.Host
if u.Scheme == "unix" || u.Scheme == "unixs" {
proto = "unix"
network = "unix"
addr = u.Host + u.Path
}
sctx.network = network
sctx.secure = u.Scheme == "https" || u.Scheme == "unixs"
sctx.insecure = !sctx.secure
@@ -443,7 +444,7 @@ func startClientListeners(cfg *Config) (sctxs map[string]*serveCtx, err error) {
continue
}
if sctx.l, err = net.Listen(proto, addr); err != nil {
if sctx.l, err = net.Listen(network, addr); err != nil {
return nil, err
}
// net.Listener will rewrite ipv4 0.0.0.0 to ipv6 [::], breaking
@@ -457,8 +458,8 @@ func startClientListeners(cfg *Config) (sctxs map[string]*serveCtx, err error) {
sctx.l = transport.LimitListener(sctx.l, int(fdLimit-reservedInternalFDNum))
}
if proto == "tcp" {
if sctx.l, err = transport.NewKeepAliveListener(sctx.l, "tcp", nil); err != nil {
if network == "tcp" {
if sctx.l, err = transport.NewKeepAliveListener(sctx.l, network, nil); err != nil {
return nil, err
}
}