Fixes #910

Pool eligibility was not calculated properly for concurrency count > 1
intelsdi-x · May 12, 2016 · 079ba51 · 079ba51
1 parent 1d87e72
commit 079ba51
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/control/strategy/pool.go b/control/strategy/pool.go
@@ -270,8 +270,9 @@ func (p *pool) Eligible() bool {
 		return false
 	}
 
-	should := p.SubscriptionCount() / p.concurrencyCount
-	if should > p.Count() && should <= p.max {
+	should := p.SubscriptionCount() > p.concurrencyCount*p.Count()
+	// Check if pool is eligible and number of plugins is less than maximum allowed
+	if should && p.Count() < p.max {
 		return true
 	}