Spring/spring-statemachine
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Tweak ZookeeperStateMachineEnsembleTests await times

Browse Source
This commit is contained in:
Janne Valkealahti
2015-08-15 23:03:56 +01:00
parent 781c2e62fd
commit ad3c082670
1 changed files with 14 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

28
spring-statemachine-zookeeper/src/test/java/org/springframework/statemachine/zookeeper/ZookeeperStateMachineEnsembleTests.java
View File

@@ -256,7 +256,7 @@ public class ZookeeperStateMachineEnsembleTests extends AbstractZookeeperTests {
new HashMap<String, Object>(), new DefaultExtendedState()));
}
assertThat(listener.eventLatch.await(3, TimeUnit.SECONDS), is(true));
assertThat(listener.eventLatch.await(10, TimeUnit.SECONDS), is(true));
assertThat(listener.events.size(), is(10));
for (int i = 0; i < 10; i++) {
@@ -300,9 +300,9 @@ public class ZookeeperStateMachineEnsembleTests extends AbstractZookeeperTests {
new HashMap<String, Object>(), new DefaultExtendedState()));
}
assertThat(listener1.eventLatch.await(3, TimeUnit.SECONDS), is(true));
assertThat(listener1.eventLatch.await(10, TimeUnit.SECONDS), is(true));
assertThat(listener1.events.size(), is(10));
assertThat(listener2.eventLatch.await(3, TimeUnit.SECONDS), is(true));
assertThat(listener2.eventLatch.await(10, TimeUnit.SECONDS), is(true));
assertThat(listener2.events.size(), is(10));
for (int i = 0; i < 10; i++) {
@@ -362,9 +362,9 @@ public class ZookeeperStateMachineEnsembleTests extends AbstractZookeeperTests {
assertThat(((StateMachineException)e).contains(KeeperException.BadVersionException.class), is(true));
} else {
// miracle happened and no cas error, well then check events
assertThat(listener1.eventLatch.await(3, TimeUnit.SECONDS), is(true));
assertThat(listener1.eventLatch.await(10, TimeUnit.SECONDS), is(true));
assertThat(listener1.events.size(), is(10));
assertThat(listener2.eventLatch.await(3, TimeUnit.SECONDS), is(true));
assertThat(listener2.eventLatch.await(10, TimeUnit.SECONDS), is(true));
assertThat(listener2.events.size(), is(10));
for (int i = 0; i < 10; i++) {
@@ -412,9 +412,9 @@ public class ZookeeperStateMachineEnsembleTests extends AbstractZookeeperTests {
ensemble2.setState(new DefaultStateMachineContext<String, String>("S" + i, "E" + i,
new HashMap<String, Object>(), new DefaultExtendedState()));
}
assertThat(listener1.eventLatch.await(3, TimeUnit.SECONDS), is(true));
assertThat(listener1.eventLatch.await(10, TimeUnit.SECONDS), is(true));
assertThat(listener1.events.size(), is(1));
assertThat(listener2.eventLatch.await(3, TimeUnit.SECONDS), is(true));
assertThat(listener2.eventLatch.await(10, TimeUnit.SECONDS), is(true));
assertThat(listener2.events.size(), is(1));
}
}
@@ -447,7 +447,7 @@ public class ZookeeperStateMachineEnsembleTests extends AbstractZookeeperTests {
Thread.sleep(500);
}
assertThat(listener.eventLatch.await(3, TimeUnit.SECONDS), is(true));
assertThat(listener.eventLatch.await(10, TimeUnit.SECONDS), is(true));
assertThat(listener.events.size(), is(10));
for (int i = 0; i < 10; i++) {
@@ -492,9 +492,9 @@ public class ZookeeperStateMachineEnsembleTests extends AbstractZookeeperTests {
Thread.sleep(500);
}
assertThat(listener1.eventLatch.await(3, TimeUnit.SECONDS), is(true));
assertThat(listener1.eventLatch.await(10, TimeUnit.SECONDS), is(true));
assertThat(listener1.events.size(), is(10));
assertThat(listener2.eventLatch.await(3, TimeUnit.SECONDS), is(true));
assertThat(listener2.eventLatch.await(10, TimeUnit.SECONDS), is(true));
assertThat(listener2.events.size(), is(10));
for (int i = 0; i < 10; i++) {
@@ -539,9 +539,9 @@ public class ZookeeperStateMachineEnsembleTests extends AbstractZookeeperTests {
new HashMap<String, Object>(), new DefaultExtendedState()));
}
assertThat(listener1.eventLatch.await(3, TimeUnit.SECONDS), is(true));
assertThat(listener1.eventLatch.await(10, TimeUnit.SECONDS), is(true));
assertThat(listener1.events.size(), is(9));
assertThat(listener2.eventLatch.await(3, TimeUnit.SECONDS), is(true));
assertThat(listener2.eventLatch.await(10, TimeUnit.SECONDS), is(true));
assertThat(listener2.events.size(), is(9));
for (int i = 0; i < 9; i++) {
@@ -558,9 +558,9 @@ public class ZookeeperStateMachineEnsembleTests extends AbstractZookeeperTests {
new HashMap<String, Object>(), new DefaultExtendedState()));
}
assertThat(listener1.eventLatch.await(3, TimeUnit.SECONDS), is(true));
assertThat(listener1.eventLatch.await(10, TimeUnit.SECONDS), is(true));
assertThat(listener1.events.size(), is(1));
assertThat(listener2.eventLatch.await(3, TimeUnit.SECONDS), is(true));
assertThat(listener2.eventLatch.await(10, TimeUnit.SECONDS), is(true));
assertThat(listener2.events.size(), is(1));
for (int i = 0; i < 1; i++) {