Merge pull request #2446 from neonstalwart/queriesExecuted-stat

count each executed query in queriesExecuted stat
2015-04-29 13:08:48 -07:00 · 2015-04-29 13:08:48 -07:00 · 23e3407b6d
parent 53292d2a32 cb2fe96ba0
commit 23e3407b6d
1 changed files with 2 additions and 1 deletions
--- a/server.go
+++ b/server.go
@ -2257,6 +2257,8 @@ func (s *Server) ExecuteQuery(q *influxql.Query, database string, user *User, ch
 					break
 				}
 			}
+
+			s.stats.Inc("queriesExecuted")
 		}

 		// if there was an error send results that the remaining statements weren't executed
@ -2264,7 +2266,6 @@ func (s *Server) ExecuteQuery(q *influxql.Query, database string, user *User, ch
 			results <- &Result{Err: ErrNotExecuted}
 		}

-		s.stats.Inc("queriesExecuted")
 		close(results)
 	}()