[servicecomb-pack] 35/42: SCB-1368 Update test cases timeout for CI

[ningjiang]

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/servicecomb-pack.git

commit 814d2bb660ef6e1d93736148c7fd31d22806040d
Author: Lei Zhang <coolbee...@gmail.com>
AuthorDate: Fri Sep 27 21:17:38 2019 +0800

    SCB-1368 Update test cases timeout for CI
---
 .../pack/alpha/fsm/SagaIntegrationTest.java        | 24 +++++++++++-----------
 1 file changed, 12 insertions(+), 12 deletions(-)

diff --git 
a/alpha/alpha-fsm/src/test/java/org/apache/servicecomb/pack/alpha/fsm/SagaIntegrationTest.java
 
b/alpha/alpha-fsm/src/test/java/org/apache/servicecomb/pack/alpha/fsm/SagaIntegrationTest.java
index 508be9f..59cf828 100644
--- 
a/alpha/alpha-fsm/src/test/java/org/apache/servicecomb/pack/alpha/fsm/SagaIntegrationTest.java
+++ 
b/alpha/alpha-fsm/src/test/java/org/apache/servicecomb/pack/alpha/fsm/SagaIntegrationTest.java
@@ -82,7 +82,7 @@ public class SagaIntegrationTest {
     SagaEventSender.successfulEvents(globalTxId, localTxId_1, localTxId_2, 
localTxId_3).stream().forEach( event -> {
       memoryActorEventChannel.send(event);
     });
-    await().atMost(2, SECONDS).until(() -> {
+    await().atMost(10, SECONDS).until(() -> {
       SagaData sagaData = 
SagaDataExtension.SAGA_DATA_EXTENSION_PROVIDER.get(system)
           .getLastSagaData();
       return sagaData != null && sagaData.isTerminated()
@@ -110,7 +110,7 @@ public class SagaIntegrationTest {
       memoryActorEventChannel.send(event);
     });
 
-    await().atMost(2, SECONDS).until(() -> {
+    await().atMost(10, SECONDS).until(() -> {
       SagaData sagaData = 
SagaDataExtension.SAGA_DATA_EXTENSION_PROVIDER.get(system).getLastSagaData();
       return sagaData !=null && sagaData.isTerminated() && 
sagaData.getLastState()==SagaActorState.COMPENSATED;
     });
@@ -129,7 +129,7 @@ public class SagaIntegrationTest {
     SagaEventSender.middleTxAbortedEvents(globalTxId, localTxId_1, 
localTxId_2).stream().forEach( event -> {
       memoryActorEventChannel.send(event);
     });
-    await().atMost(2, SECONDS).until(() -> {
+    await().atMost(10, SECONDS).until(() -> {
       SagaData sagaData = 
SagaDataExtension.SAGA_DATA_EXTENSION_PROVIDER.get(system).getLastSagaData();
       return sagaData !=null && sagaData.isTerminated() && 
sagaData.getLastState()==SagaActorState.COMPENSATED;
     });
@@ -150,7 +150,7 @@ public class SagaIntegrationTest {
     SagaEventSender.lastTxAbortedEvents(globalTxId, localTxId_1, localTxId_2, 
localTxId_3).stream().forEach( event -> {
       memoryActorEventChannel.send(event);
     });
-    await().atMost(2, SECONDS).until(() -> {
+    await().atMost(10, SECONDS).until(() -> {
       SagaData sagaData = 
SagaDataExtension.SAGA_DATA_EXTENSION_PROVIDER.get(system).getLastSagaData();
       return sagaData !=null && sagaData.isTerminated() && 
sagaData.getLastState()==SagaActorState.COMPENSATED;
     });
@@ -172,7 +172,7 @@ public class SagaIntegrationTest {
     SagaEventSender.sagaAbortedEventBeforeTxComponsitedEvents(globalTxId, 
localTxId_1, localTxId_2, localTxId_3).stream().forEach( event -> {
       memoryActorEventChannel.send(event);
     });
-    await().atMost(2, SECONDS).until(() -> {
+    await().atMost(10, SECONDS).until(() -> {
       SagaData sagaData = 
SagaDataExtension.SAGA_DATA_EXTENSION_PROVIDER.get(system).getLastSagaData();
       return sagaData !=null && sagaData.isTerminated() && 
sagaData.getLastState()==SagaActorState.COMPENSATED;
     });
@@ -194,7 +194,7 @@ public class SagaIntegrationTest {
     
SagaEventSender.receivedRemainingEventAfterFirstTxAbortedEvents(globalTxId, 
localTxId_1, localTxId_2, localTxId_3).stream().forEach( event -> {
       memoryActorEventChannel.send(event);
     });
-    await().atMost(2, SECONDS).until(() -> {
+    await().atMost(10, SECONDS).until(() -> {
       SagaData sagaData = 
SagaDataExtension.SAGA_DATA_EXTENSION_PROVIDER.get(system).getLastSagaData();
       return sagaData !=null && sagaData.isTerminated() && 
sagaData.getLastState()==SagaActorState.COMPENSATED;
     });
@@ -216,7 +216,7 @@ public class SagaIntegrationTest {
     SagaEventSender.sagaAbortedEventAfterAllTxEndedsEvents(globalTxId, 
localTxId_1, localTxId_2, localTxId_3).stream().forEach( event -> {
       memoryActorEventChannel.send(event);
     });
-    await().atMost(2, SECONDS).until(() -> {
+    await().atMost(10, SECONDS).until(() -> {
       SagaData sagaData = 
SagaDataExtension.SAGA_DATA_EXTENSION_PROVIDER.get(system).getLastSagaData();
       return sagaData !=null && sagaData.isTerminated() && 
sagaData.getLastState()==SagaActorState.COMPENSATED;
     });
@@ -238,7 +238,7 @@ public class SagaIntegrationTest {
     SagaEventSender.omegaSendSagaTimeoutEvents(globalTxId, localTxId_1, 
localTxId_2, localTxId_3).stream().forEach( event -> {
       memoryActorEventChannel.send(event);
     });
-    await().atMost(2, SECONDS).until(() -> {
+    await().atMost(10, SECONDS).until(() -> {
       SagaData sagaData = 
SagaDataExtension.SAGA_DATA_EXTENSION_PROVIDER.get(system).getLastSagaData();
       return sagaData !=null && sagaData.isTerminated() && 
sagaData.getLastState()==SagaActorState.SUSPENDED;
     });
@@ -261,7 +261,7 @@ public class SagaIntegrationTest {
     SagaEventSender.sagaActorTriggerTimeoutEvents(globalTxId, localTxId_1, 
localTxId_2, localTxId_3, timeout).stream().forEach( event -> {
       memoryActorEventChannel.send(event);
     });
-    await().atMost(timeout + 2, SECONDS).until(() -> {
+    await().atMost(timeout + 10, SECONDS).until(() -> {
       SagaData sagaData = 
SagaDataExtension.SAGA_DATA_EXTENSION_PROVIDER.get(system).getLastSagaData();
       return sagaData !=null && sagaData.isTerminated() && 
sagaData.getLastState()==SagaActorState.SUSPENDED;
     });
@@ -283,7 +283,7 @@ public class SagaIntegrationTest {
     SagaEventSender.successfulWithTxConcurrentEvents(globalTxId, localTxId_1, 
localTxId_2, localTxId_3).stream().forEach( event -> {
       memoryActorEventChannel.send(event);
     });
-    await().atMost(2, SECONDS).until(() -> {
+    await().atMost(10, SECONDS).until(() -> {
       SagaData sagaData = 
SagaDataExtension.SAGA_DATA_EXTENSION_PROVIDER.get(system).getLastSagaData();
       return sagaData !=null && sagaData.isTerminated() && 
sagaData.getLastState()==SagaActorState.COMMITTED;
     });
@@ -305,7 +305,7 @@ public class SagaIntegrationTest {
     SagaEventSender.successfulWithTxConcurrentCrossEvents(globalTxId, 
localTxId_1, localTxId_2, localTxId_3).stream().forEach( event -> {
       memoryActorEventChannel.send(event);
     });
-    await().atMost(2, SECONDS).until(() -> {
+    await().atMost(10, SECONDS).until(() -> {
       SagaData sagaData = 
SagaDataExtension.SAGA_DATA_EXTENSION_PROVIDER.get(system).getLastSagaData();
       return sagaData !=null && sagaData.isTerminated() && 
sagaData.getLastState()==SagaActorState.COMMITTED;
     });
@@ -327,7 +327,7 @@ public class SagaIntegrationTest {
     SagaEventSender.lastTxAbortedEventWithTxConcurrentEvents(globalTxId, 
localTxId_1, localTxId_2, localTxId_3).stream().forEach( event -> {
       memoryActorEventChannel.send(event);
     });
-    await().atMost(2, SECONDS).until(() -> {
+    await().atMost(10, SECONDS).until(() -> {
       SagaData sagaData = 
SagaDataExtension.SAGA_DATA_EXTENSION_PROVIDER.get(system).getLastSagaData();
       return sagaData !=null && sagaData.isTerminated() && 
sagaData.getLastState()==SagaActorState.COMPENSATED;
     });