diff --git a/embed/etcd.go b/embed/etcd.go index b6f3cc19e..4f62e72df 100644 --- a/embed/etcd.go +++ b/embed/etcd.go @@ -127,7 +127,9 @@ func StartEtcd(inCfg *Config) (e *Etcd, err error) { e.errc = make(chan error, len(e.Peers)+len(e.Clients)+2*len(e.sctxs)) e.Server.Start() - e.serve() + if err = e.serve(); err != nil { + return + } <-e.Server.ReadyNotify() return }