This is an automated email from the ASF dual-hosted git repository. liubao pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/servicecomb-java-chassis.git
commit 478901a0cd952f0617255956267e8cb75eca365d Author: zyl <[email protected]> AuthorDate: Wed Jan 13 11:22:19 2021 +0800 SCB-2178 Improve algorithm of loadBalance strage WeightedResponse #补充恢复后的测试场景。 --- .../loadbalance/TestWeightedResponseTimeRuleExt.java | 13 +++++++++++++ 1 file changed, 13 insertions(+) diff --git a/handlers/handler-loadbalance/src/test/java/org/apache/servicecomb/loadbalance/TestWeightedResponseTimeRuleExt.java b/handlers/handler-loadbalance/src/test/java/org/apache/servicecomb/loadbalance/TestWeightedResponseTimeRuleExt.java index fe02642..9011f66 100644 --- a/handlers/handler-loadbalance/src/test/java/org/apache/servicecomb/loadbalance/TestWeightedResponseTimeRuleExt.java +++ b/handlers/handler-loadbalance/src/test/java/org/apache/servicecomb/loadbalance/TestWeightedResponseTimeRuleExt.java @@ -79,6 +79,19 @@ public class TestWeightedResponseTimeRuleExt { double percent = (double) server1.get() / (server2.get() + server1.get()); System.out.println("percent" + percent); Assert.assertEquals("actually percent: " + percent, 0.50d < percent, percent < 0.90d); + server1.set(0); + server2.set(0); + Thread.sleep(1000); + for (int i = 0; i < 2000; i++) { + if (rule.choose(servers, invocation).toString().equals("server 0")) { + server1.incrementAndGet(); + } else { + server2.incrementAndGet(); + } + } + percent = (double) server1.get() / (server2.get() + server1.get()); + System.out.println("percent" + percent); + Assert.assertEquals(0.50d, percent,0); } @Test
