[incubator-servicecomb-saga] 04/07: SCB-168 made latency significant enough to pass test

[ni...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

ningjiang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-servicecomb-saga.git

commit 55296894828597f90140707e988e050f85f55d6b
Author: seanyinx <se...@huawei.com>
AuthorDate: Mon Jan 8 16:25:36 2018 +0800

    SCB-168 made latency significant enough to pass test
    
    Signed-off-by: seanyinx <se...@huawei.com>
---
 .../connector/grpc/LoadBalancedClusterMessageSenderTest.java     | 9 ++++-----
 1 file changed, 4 insertions(+), 5 deletions(-)

diff --git a/omega/omega-connector/omega-connector-grpc/src/test/java/org/apache/servicecomb/saga/omega/connector/grpc/LoadBalancedClusterMessageSenderTest.java b/omega/omega-connector/omega-connector-grpc/src/test/java/org/apache/servicecomb/saga/omega/connector/grpc/LoadBalancedClusterMessageSenderTest.java
index dc75663..1868f31 100644
--- a/omega/omega-connector/omega-connector-grpc/src/test/java/org/apache/servicecomb/saga/omega/connector/grpc/LoadBalancedClusterMessageSenderTest.java
+++ b/omega/omega-connector/omega-connector-grpc/src/test/java/org/apache/servicecomb/saga/omega/connector/grpc/LoadBalancedClusterMessageSenderTest.java
@@ -22,8 +22,6 @@ import static com.seanyinx.github.unit.scaffolding.Randomness.uniquify;
 import static java.util.concurrent.TimeUnit.SECONDS;
 import static org.awaitility.Awaitility.await;
 import static org.hamcrest.Matchers.contains;
-import static org.hamcrest.Matchers.greaterThanOrEqualTo;
-import static org.hamcrest.Matchers.lessThanOrEqualTo;
 import static org.hamcrest.core.Is.is;
 import static org.junit.Assert.assertThat;
 import static org.junit.Assert.fail;
@@ -75,7 +73,7 @@ public class LoadBalancedClusterMessageSenderTest {
 
   private static final Map<Integer, Integer> delays = new HashMap<Integer, Integer>() {{
     put(8080, 0);
-    put(8090, 100);
+    put(8090, 500);
   }};
 
   private static final Map<Integer, Set<String>> connected = new HashMap<Integer, Set<String>>() {{
@@ -222,9 +220,10 @@ public class LoadBalancedClusterMessageSenderTest {
     // but now we only send to the one with lowest latency
     messageSender.send(event);
     messageSender.send(event);
+    messageSender.send(event);
 
-    assertThat(eventsOn8080.size(), greaterThanOrEqualTo(2));
-    assertThat(eventsOn8090.size(), lessThanOrEqualTo(1));
+    assertThat(eventsOn8080.size(), is(3));
+    assertThat(eventsOn8090.size(), is(1));
   }
 
   @Test

-- 
To stop receiving notification emails like this one, please contact
"commits@servicecomb.apache.org" <co...@servicecomb.apache.org>.