From decec489d7885d111d55ea4d41581d0dfbd7f046 Mon Sep 17 00:00:00 2001 From: Armon Dadgar Date: Thu, 10 Jul 2014 10:58:39 -0700 Subject: [PATCH] Fixing issue with query flooding --- client.go | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/client.go b/client.go index d8e67ea..358d138 100644 --- 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: