From b740c1a61a13e5e2b1ee095dc57986561b98f5b6 Mon Sep 17 00:00:00 2001 From: Renan DelValle Date: Mon, 22 Aug 2016 12:43:53 -0700 Subject: [PATCH] Small bug fix. Can't close a connection that doesn't exist --- zk.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/zk.go b/zk.go index 4fd09bb..48b18e2 100644 --- a/zk.go +++ b/zk.go @@ -39,13 +39,15 @@ type ServiceInstance struct { func LeaderFromZK(cluster Cluster) (string, error) { endpoints := strings.Split(cluster.ZK, ",") + //TODO (rdelvalle): When enabling debugging, change logger here c, _, err := zk.Connect(endpoints, time.Second*10, zk.WithoutLogger()) - defer c.Close() if err != nil { return "", errors.Wrap(err, "Failed to connect to Zookeeper at "+cluster.ZK) } + defer c.Close() + children, _, _, err := c.ChildrenW(cluster.SchedZKPath) if err != nil { return "", errors.Wrapf(err, "Path %s doesn't exist on Zookeeper ", cluster.SchedZKPath)