fix smooth weighted roundrobin

smallnest · Nov 19, 2020 · f8b91ca · f8b91ca
1 parent e532ba1
commit f8b91ca
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/client/smooth-weighted-round-robin.go b/client/smooth-weighted-round-robin.go
@@ -29,6 +29,9 @@ func nextWeighted(servers []*Weighted) (best *Weighted) {
 
 		w.CurrentWeight += w.EffectiveWeight
 		total += w.EffectiveWeight
+		if w.EffectiveWeight < w.Weight {
+			w.EffectiveWeight++
+		}
 
 		if best == nil || w.CurrentWeight > best.CurrentWeight {
 			best = w