Skip to content

Commit

Permalink
SCB-2641 Increase waiting time for slow CI
Browse files Browse the repository at this point in the history
  • Loading branch information
@coolbeevip @WillemJiang
coolbeevip authored and WillemJiang committed Jul 30, 2022
1 parent 62676a1 commit fbffe45
Showing 1 changed file with 12 additions and 12 deletions.
24 changes: 12 additions & 12 deletions ...rc/test/java/org/apache/servicecomb/pack/alpha/spec/saga/akka/it/SagaIntegrationTest.java
View file
Expand Up @@ -99,7 +99,7 @@ public void successfulTest() {
SagaEventSender.successfulEvents(globalTxId, localTxId_1, localTxId_2, localTxId_3).stream().forEach( event -> {
memoryActorEventChannel.send(event);
});
await().atMost(60, SECONDS).until(() -> {
await().atMost(120, SECONDS).until(() -> {
SagaData sagaData = SagaDataExtension.SAGA_DATA_EXTENSION_PROVIDER.get(system)
.getLastSagaData();
return sagaData != null && sagaData.isTerminated()
Expand Down Expand Up @@ -127,7 +127,7 @@ public void firstTxAbortedEventTest() {
memoryActorEventChannel.send(event);
});

await().atMost(60, SECONDS).until(() -> {
await().atMost(120, SECONDS).until(() -> {
SagaData sagaData = SagaDataExtension.SAGA_DATA_EXTENSION_PROVIDER.get(system).getLastSagaData();
return sagaData !=null && sagaData.isTerminated() && sagaData.getLastState()==SagaActorState.COMPENSATED;
});
Expand All @@ -146,7 +146,7 @@ public void middleTxAbortedEventTest() {
SagaEventSender.middleTxAbortedEvents(globalTxId, localTxId_1, localTxId_2).stream().forEach( event -> {
memoryActorEventChannel.send(event);
});
await().atMost(60, SECONDS).until(() -> {
await().atMost(120, SECONDS).until(() -> {
SagaData sagaData = SagaDataExtension.SAGA_DATA_EXTENSION_PROVIDER.get(system).getLastSagaData();
return sagaData !=null && sagaData.isTerminated() && sagaData.getLastState()==SagaActorState.COMPENSATED;
});
Expand All @@ -167,7 +167,7 @@ public void lastTxAbortedEventTest() {
SagaEventSender.lastTxAbortedEvents(globalTxId, localTxId_1, localTxId_2, localTxId_3).stream().forEach( event -> {
memoryActorEventChannel.send(event);
});
await().atMost(60, SECONDS).until(() -> {
await().atMost(120, SECONDS).until(() -> {
SagaData sagaData = SagaDataExtension.SAGA_DATA_EXTENSION_PROVIDER.get(system).getLastSagaData();
return sagaData !=null && sagaData.isTerminated() && sagaData.getLastState()==SagaActorState.COMPENSATED;
});
Expand All @@ -189,7 +189,7 @@ public void sagaAbortedEventBeforeTxComponsitedEventTest() {
SagaEventSender.sagaAbortedEventBeforeTxComponsitedEvents(globalTxId, localTxId_1, localTxId_2, localTxId_3).stream().forEach( event -> {
memoryActorEventChannel.send(event);
});
await().atMost(60, SECONDS).until(() -> {
await().atMost(120, SECONDS).until(() -> {
SagaData sagaData = SagaDataExtension.SAGA_DATA_EXTENSION_PROVIDER.get(system).getLastSagaData();
return sagaData !=null && sagaData.isTerminated() && sagaData.getLastState()==SagaActorState.COMPENSATED;
});
Expand All @@ -211,7 +211,7 @@ public void receivedRemainingEventAfterFirstTxAbortedEventTest() {
SagaEventSender.receivedRemainingEventAfterFirstTxAbortedEvents(globalTxId, localTxId_1, localTxId_2, localTxId_3).stream().forEach( event -> {
memoryActorEventChannel.send(event);
});
await().atMost(60, SECONDS).until(() -> {
await().atMost(120, SECONDS).until(() -> {
SagaData sagaData = SagaDataExtension.SAGA_DATA_EXTENSION_PROVIDER.get(system).getLastSagaData();
return sagaData !=null && sagaData.isTerminated() && sagaData.getLastState()==SagaActorState.COMPENSATED;
});
Expand All @@ -233,7 +233,7 @@ public void sagaAbortedEventAfterAllTxEndedTest() {
SagaEventSender.sagaAbortedEventAfterAllTxEndedsEvents(globalTxId, localTxId_1, localTxId_2, localTxId_3).stream().forEach( event -> {
memoryActorEventChannel.send(event);
});
await().atMost(60, SECONDS).until(() -> {
await().atMost(120, SECONDS).until(() -> {
SagaData sagaData = SagaDataExtension.SAGA_DATA_EXTENSION_PROVIDER.get(system).getLastSagaData();
return sagaData !=null && sagaData.isTerminated() && sagaData.getLastState()==SagaActorState.COMPENSATED;
});
Expand All @@ -255,7 +255,7 @@ public void omegaSendSagaTimeoutEventTest() {
SagaEventSender.omegaSendSagaTimeoutEvents(globalTxId, localTxId_1, localTxId_2, localTxId_3).stream().forEach( event -> {
memoryActorEventChannel.send(event);
});
await().atMost(60, SECONDS).until(() -> {
await().atMost(120, SECONDS).until(() -> {
SagaData sagaData = SagaDataExtension.SAGA_DATA_EXTENSION_PROVIDER.get(system).getLastSagaData();
return sagaData !=null && sagaData.isTerminated() && sagaData.getLastState()==SagaActorState.SUSPENDED;
});
Expand All @@ -278,7 +278,7 @@ public void sagaActorTriggerTimeoutTest() {
SagaEventSender.sagaActorTriggerTimeoutEvents(globalTxId, localTxId_1, localTxId_2, localTxId_3, timeout).stream().forEach( event -> {
memoryActorEventChannel.send(event);
});
await().atMost(timeout + 60, SECONDS).until(() -> {
await().atMost(timeout + 120, SECONDS).until(() -> {
SagaData sagaData = SagaDataExtension.SAGA_DATA_EXTENSION_PROVIDER.get(system).getLastSagaData();
return sagaData !=null && sagaData.isTerminated() && sagaData.getLastState()==SagaActorState.SUSPENDED;
});
Expand Down Expand Up @@ -322,7 +322,7 @@ public void successfulWithTxConcurrentCrossTest() {
SagaEventSender.successfulWithTxConcurrentCrossEvents(globalTxId, localTxId_1, localTxId_2, localTxId_3).stream().forEach( event -> {
memoryActorEventChannel.send(event);
});
await().atMost(60, SECONDS).until(() -> {
await().atMost(120, SECONDS).until(() -> {
SagaData sagaData = SagaDataExtension.SAGA_DATA_EXTENSION_PROVIDER.get(system).getLastSagaData();
return sagaData !=null && sagaData.isTerminated() && sagaData.getLastState()==SagaActorState.COMMITTED;
});
Expand All @@ -344,15 +344,15 @@ public void lastTxAbortedEventWithTxConcurrentTest() {
SagaEventSender.lastTxAbortedEventWithTxConcurrentEvents(globalTxId, localTxId_1, localTxId_2, localTxId_3).stream().forEach( event -> {
memoryActorEventChannel.send(event);
});
await().atMost(60, SECONDS).until(() -> {
await().atMost(120, SECONDS).until(() -> {
SagaData sagaData = SagaDataExtension.SAGA_DATA_EXTENSION_PROVIDER.get(system).getLastSagaData();
return sagaData !=null && sagaData.isTerminated() && sagaData.getLastState()==SagaActorState.COMPENSATED;
});
SagaData sagaData = SagaDataExtension.SAGA_DATA_EXTENSION_PROVIDER.get(system).getLastSagaData();
assertNotNull(sagaData.getBeginTime());
assertNotNull(sagaData.getEndTime());
assertEquals(sagaData.getTxEntities().size(),3);
await().atMost(60, SECONDS).until(() -> {
await().atMost(120, SECONDS).until(() -> {
return sagaData.getTxEntities().get(localTxId_1) != null
&& sagaData.getTxEntities().get(localTxId_2) != null
&& sagaData.getTxEntities().get(localTxId_3) != null;
Expand Down

0 comments on commit fbffe45

Please sign in to comment.