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

Tweak tests for being more reliable

Browse Source 
- For #76, try to make sure that join is fully done
  before continue sending events.
This commit is contained in:
Janne Valkealahti
2015-08-15 17:23:57 +01:00
parent d7f5f9f573
commit 5e2ac9dd84
1 changed files with 38 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -244,9 +244,11 @@ public class ZookeeperStateMachineEnsembleTests extends AbstractZookeeperTests {
TestEnsembleListener listener = new TestEnsembleListener();
ensemble.addEnsembleListener(listener);
ensemble.afterPropertiesSet();
ensemble.start();
ensemble.join(new TestStateMachine());
assertThat(listener.joinedLatch.await(3, TimeUnit.SECONDS), is(true));
listener.reset(0, 10);
for (int i = 0; i < 10; i++) {
@@ -285,6 +287,11 @@ public class ZookeeperStateMachineEnsembleTests extends AbstractZookeeperTests {
ensemble2.afterPropertiesSet();
ensemble2.start();
ensemble1.join(new TestStateMachine());
assertThat(listener1.joinedLatch.await(3, TimeUnit.SECONDS), is(true));
ensemble2.join(new TestStateMachine());
assertThat(listener2.joinedLatch.await(3, TimeUnit.SECONDS), is(true));
listener1.reset(0, 10);
listener2.reset(0, 10);
@@ -327,6 +334,11 @@ public class ZookeeperStateMachineEnsembleTests extends AbstractZookeeperTests {
ensemble2.afterPropertiesSet();
ensemble2.start();
ensemble1.join(new TestStateMachine());
assertThat(listener1.joinedLatch.await(3, TimeUnit.SECONDS), is(true));
ensemble2.join(new TestStateMachine());
assertThat(listener2.joinedLatch.await(3, TimeUnit.SECONDS), is(true));
listener1.reset(0, 10);
listener2.reset(0, 10);
@@ -385,6 +397,11 @@ public class ZookeeperStateMachineEnsembleTests extends AbstractZookeeperTests {
ensemble2.afterPropertiesSet();
ensemble2.start();
ensemble1.join(new TestStateMachine());
assertThat(listener1.joinedLatch.await(3, TimeUnit.SECONDS), is(true));
ensemble2.join(new TestStateMachine());
assertThat(listener2.joinedLatch.await(3, TimeUnit.SECONDS), is(true));
for (int i = 0; i < 10; i++) {
listener1.reset(0, 1);
listener2.reset(0, 1);
@@ -418,6 +435,10 @@ public class ZookeeperStateMachineEnsembleTests extends AbstractZookeeperTests {
ensemble.afterPropertiesSet();
ensemble.start();
ensemble.join(new TestStateMachine());
assertThat(listener.joinedLatch.await(3, TimeUnit.SECONDS), is(true));
listener.reset(0, 10);
for (int i = 0; i < 10; i++) {
@@ -456,6 +477,12 @@ public class ZookeeperStateMachineEnsembleTests extends AbstractZookeeperTests {
ensemble1.start();
ensemble2.afterPropertiesSet();
ensemble2.start();
ensemble1.join(new TestStateMachine());
assertThat(listener1.joinedLatch.await(3, TimeUnit.SECONDS), is(true));
ensemble2.join(new TestStateMachine());
assertThat(listener2.joinedLatch.await(3, TimeUnit.SECONDS), is(true));
listener1.reset(0, 10);
listener2.reset(0, 10);
@@ -498,6 +525,12 @@ public class ZookeeperStateMachineEnsembleTests extends AbstractZookeeperTests {
ensemble1.start();
ensemble2.afterPropertiesSet();
ensemble2.start();
ensemble1.join(new TestStateMachine());
assertThat(listener1.joinedLatch.await(3, TimeUnit.SECONDS), is(true));
ensemble2.join(new TestStateMachine());
assertThat(listener2.joinedLatch.await(3, TimeUnit.SECONDS), is(true));
listener1.reset(0, 9);
listener2.reset(0, 9);
@@ -550,6 +583,10 @@ public class ZookeeperStateMachineEnsembleTests extends AbstractZookeeperTests {
ensemble.afterPropertiesSet();
ensemble.start();
ensemble.join(new TestStateMachine());
assertThat(listener.joinedLatch.await(3, TimeUnit.SECONDS), is(true));
listener.reset(0, 10, 1);
// this is a bit of a hack to test things like this