From cfd93d7753822301d530231910bf05664a4f4888 Mon Sep 17 00:00:00 2001 From: Todd Gruben Date: Mon, 23 Jun 2014 18:01:43 -0500 Subject: [PATCH] bad check --- core/etcd.go | 23 +---------------------- 1 file changed, 1 insertion(+), 22 deletions(-) diff --git a/core/etcd.go b/core/etcd.go index b2ac1b0fb..b57033a18 100644 --- a/core/etcd.go +++ b/core/etcd.go @@ -38,11 +38,6 @@ func (self *TopologyMapper) Setup() { } //need to lock the world for _, node := range flatten(resp.Node) { - if len(node.Value) < 5 { - log.Println("No GUID skipping") - log.Println(spew.Sdump(node)) - continue - } err := self.handlenode(node) if err != nil { log.Println(err) @@ -68,11 +63,6 @@ func (self *TopologyMapper) Run() { for resp := range receiver { switch resp.Action { case "set": - if len(resp.Node.Value) < 5 { - log.Println("No GUID skipping set") - log.Println(spew.Sdump(resp)) - continue - } self.handlenode(resp.Node) case "delete": self.remove_fragment(resp.Node) @@ -437,12 +427,6 @@ func (self *ProcessMapper) Run() { response, err := self.service.Etcd.Get(path, false, true) for _, node := range flatten(response.Node) { - if len(node.Value) < 5 { - log.Println("No GUID skipping run") - log.Println(spew.Sdump(node)) - continue - } - err := self.handlenode(node) if err != nil { spew.Dump(node) @@ -462,12 +446,7 @@ func (self *ProcessMapper) Run() { for response = range receiver { switch response.Action { case "set": - if len(response.Node.Value) > 5 { - self.handlenode(response.Node) - } else { - log.Println("No GUID skipping") - log.Println(spew.Sdump(response)) - } + self.handlenode(response.Node) } // TODO: handle deletes }