From c472316fb387bcaa5cd08a65665355936f70a5c1 Mon Sep 17 00:00:00 2001 From: Goutham Veeramachaneni Date: Fri, 16 Jun 2017 16:57:22 +0530 Subject: [PATCH] Check done before every rule evaluation. Signed-off-by: Goutham Veeramachaneni --- rules/manager.go | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/rules/manager.go b/rules/manager.go index a72cfe777f..b9f22b6d57 100644 --- a/rules/manager.go +++ b/rules/manager.go @@ -285,6 +285,12 @@ func typeForRule(r Rule) ruleType { // Eval runs a single evaluation cycle in which all rules are evaluated sequentially. func (g *Group) Eval(ts time.Time) { for i, rule := range g.rules { + select { + case <-g.done: + return + default: + } + rtyp := string(typeForRule(rule)) func(i int, rule Rule) {