From 6bd377ebe2801120d128b858c8fb14d9abf1f653 Mon Sep 17 00:00:00 2001 From: Todd Gruben Date: Tue, 31 Mar 2015 18:32:21 +0000 Subject: [PATCH] updated etcd client --- core/etcd.go | 2 +- deps.json | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/core/etcd.go b/core/etcd.go index c90fc31d0..72faba57f 100644 --- a/core/etcd.go +++ b/core/etcd.go @@ -52,13 +52,13 @@ func (self *TopologyMapper) Setup() { func (self *TopologyMapper) Run() { receiver := make(chan *etcd.Response) - stop := make(chan bool) go func() { // TODO: add some terminating measure // TODO: use modindex to make sure watch catches everything for { ns := self.namespace + "/db" log.Warn(" ETCD watcher:", ns) + stop := make(chan bool) resp, err := self.service.Etcd.Watch(ns, 0, true, receiver, stop) log.Warn("TopologyMapper ETCD watcher", resp, err) } diff --git a/deps.json b/deps.json index be82cea88..22ef96c74 100644 --- a/deps.json +++ b/deps.json @@ -6,7 +6,7 @@ }, "etcd": { "repo": "github.com/coreos/go-etcd/etcd", - "version": "7745cfd7f8e619cc9e6be450238e6253a57a227f", + "version": "2af7a9525b09fb715b215a1fb852dd4814ef52b5", "type": "git" }, "gkvlite": {