From 46623c00a86f0aa1f1697b3d2804cbcb78eea0ea Mon Sep 17 00:00:00 2001 From: Cenk Alti Date: Mon, 24 Mar 2014 18:41:48 -0700 Subject: [PATCH] fix(main): fix ready notifier --- etcd/etcd.go | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/etcd/etcd.go b/etcd/etcd.go index cf39e7932..12d2f30c1 100644 --- a/etcd/etcd.go +++ b/etcd/etcd.go @@ -185,6 +185,9 @@ func (e *Etcd) Run() { peerTLSConfig := server.TLSServerConfig(e.Config.PeerTLSInfo()) etcdTLSConfig := server.TLSServerConfig(e.Config.EtcdTLSInfo()) + log.Infof("peer server [name %s, listen on %s, advertised url %s]", e.PeerServer.Config.Name, e.Config.Peer.BindAddr, e.PeerServer.Config.URL) + e.peerListener = server.NewListener(psConfig.Scheme, e.Config.Peer.BindAddr, e.Config.PeerTLSInfo()) + peerServerClosed := make(chan bool) go func() { // Starting peer server should be followed close by listening on its port @@ -205,7 +208,7 @@ func (e *Etcd) Run() { }() log.Infof("etcd server [name %s, listen on %s, advertised url %s]", e.Server.Name, e.Config.BindAddr, e.Server.URL()) - e.listener = server.NewListener(e.Config.EtcdTLSInfo().Scheme(), e.Config.BindAddr, e.Config.EtcdTLSInfo()) + e.listener = server.NewListener(e.Config.EtcdTLSInfo().Scheme(), e.Config.BindAddr, etcdTLSConfig) close(e.readyC) // etcd server is ready to accept connections, notify waiters.