[incubator-servicecomb-saga] 04/06: SCB-164 added waiting for async update to fix random test failures

[se...@apache.org]

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

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

commit 822e2182646095ebeeba99179467613ce6bc2ba9
Author: seanyinx <se...@huawei.com>
AuthorDate: Wed Jan 10 08:56:57 2018 +0800

    SCB-164 added waiting for async update to fix random test failures
    
    Signed-off-by: seanyinx <se...@huawei.com>
---
 .../org/apache/servicecomb/saga/alpha/server/AlphaIntegrationTest.java  | 2 +-
 .../saga/omega/connector/grpc/LoadBalancedClusterMessageSenderTest.java | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/alpha/alpha-server/src/test/java/org/apache/servicecomb/saga/alpha/server/AlphaIntegrationTest.java b/alpha/alpha-server/src/test/java/org/apache/servicecomb/saga/alpha/server/AlphaIntegrationTest.java
index 21e46cd..4997c00 100644
--- a/alpha/alpha-server/src/test/java/org/apache/servicecomb/saga/alpha/server/AlphaIntegrationTest.java
+++ b/alpha/alpha-server/src/test/java/org/apache/servicecomb/saga/alpha/server/AlphaIntegrationTest.java
@@ -149,7 +149,7 @@ public class AlphaIntegrationTest {
         omegaCallbacks.get(serviceConfig.getServiceName()).containsKey(serviceConfig.getInstanceId()),
         is(false));
 
-    assertThat(compensateResponseObserver.isCompleted(), is(true));
+    await().atMost(1, SECONDS).until(compensateResponseObserver::isCompleted);
   }
 
   @Test
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 22867d1..78dce6b 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
@@ -250,7 +250,7 @@ public class LoadBalancedClusterMessageSenderTest {
     messageSender.send(event);
     messageSender.send(event);
 
-    assertThat(eventsMap.get(8080).size(), is(3));
+    await().atMost(1, SECONDS).until(() -> eventsMap.get(8080).size() == 3);
     assertThat(eventsMap.get(8090).size(), is(1));
   }
 

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