Fixing issue with query flooding

2014-07-10 10:58:39 -07:00
parent 70462deb06
commit decec489d7
1 changed files with 4 additions and 1 deletions
--- a/client.go
+++ b/client.go
@@ -217,7 +217,10 @@ func (c *client) query(params *QueryParam) error {
 			}

 			// Check if this entry is complete
-			if inp.complete() && !inp.sent {
+			if inp.complete() {
+				if inp.sent {
+					continue
+				}
 				inp.sent = true
 				select {
 				case params.Entries <- inp: