Merge pull request #131 from caozhipan/fix-activeQPS-zero

解决activeQPS=0
fagongzi · May 7, 2019 · e5c7b88 · e5c7b88
2 parents fc6f4b8 + 990cced
commit e5c7b88
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/pkg/proxy/dispatcher_meta.go b/pkg/proxy/dispatcher_meta.go
@@ -277,10 +277,14 @@ func (r *dispatcher) refreshAllQPS() {
 }
 
 func (r *dispatcher) refreshQPS(value int64) int64 {
+	activeQPS := value
 	if len(r.proxies) > 0 {
-		return value / int64(len(r.proxies))
+		activeQPS = value / int64(len(r.proxies))
 	}
-	return value
+	if activeQPS <= 0 {
+		activeQPS = 1
+	}
+	return activeQPS
 }
 
 func (r *dispatcher) addServer(svr *metapb.Server) error {