From de2081fa1951eae079954f0a33068beccf2549dd Mon Sep 17 00:00:00 2001 From: Chanwit Kaewkasi Date: Tue, 6 Jan 2015 19:09:00 +0700 Subject: [PATCH] skip ErrNodeExists for node registration Signed-off-by: Chanwit Kaewkasi --- discovery/zookeeper/zookeeper.go | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/discovery/zookeeper/zookeeper.go b/discovery/zookeeper/zookeeper.go index d02cdf544d..292d766830 100644 --- a/discovery/zookeeper/zookeeper.go +++ b/discovery/zookeeper/zookeeper.go @@ -76,5 +76,9 @@ func (s *ZkDiscoveryService) Watch(callback discovery.WatchCallback) { func (s *ZkDiscoveryService) Register(addr string) error { _, err := s.conn.Create(path.Join(s.path, "/"+addr), []byte(addr), 0, zk.WorldACL(zk.PermAll)) - return err + if err != zk.ErrNodeExists { + return err + } else { + return nil + } }