fix full topic sync accumjulation

nsqio · Feb 6, 2018 · 9c0bd91 · 9c0bd91
1 parent c53f30f
commit 9c0bd91
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/nsqd/lookup.go b/nsqd/lookup.go
@@ -29,6 +29,7 @@ func connectCallback(n *NSQD, hostname string, syncTopicChan chan *lookupPeer) f
 		resp, err := lp.Command(cmd)
 		if err != nil {
 			n.logf("LOOKUPD(%s): ERROR %s - %s", lp, cmd, err)
+			return
 		} else if bytes.Equal(resp, []byte("E_INVALID")) {
 			n.logf("LOOKUPD(%s): lookupd returned %s", lp, resp)
 		} else {