updated etcd client

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)
 		}

deps.json

@@ -6,7 +6,7 @@
     },
     "etcd": {
         "repo": "github.com/coreos/go-etcd/etcd",
-        "version": "7745cfd7f8e619cc9e6be450238e6253a57a227f",
+        "version": "2af7a9525b09fb715b215a1fb852dd4814ef52b5",
         "type": "git"
     },
     "gkvlite": {