Skip to content

Commit f38f458

Browse files
committed
Added test on repeated start stop of cluster instance
1 parent ef0c501 commit f38f458

File tree

1 file changed

+11
-7
lines changed

1 file changed

+11
-7
lines changed

cluster/src/test/java/io/scalecube/cluster/ClusterTest.java

Lines changed: 11 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -39,32 +39,36 @@ public void testStartStopRepeatedly() throws Exception {
3939
// Start seed node
4040
Cluster seedNode =
4141
new ClusterImpl()
42-
.gossip(opts -> opts.gossipInterval(1))
43-
.failureDetector(opts -> opts.pingInterval(1))
44-
.membership(opts -> opts.syncInterval(1))
42+
.gossip(opts -> opts.gossipInterval(100))
43+
.failureDetector(opts -> opts.pingInterval(100))
44+
.membership(opts -> opts.syncInterval(100))
4545
.transport(opts -> opts.host(address.host()).port(address.port()))
4646
.transport(opts -> opts.connectTimeout(CONNECT_TIMEOUT))
4747
.startAwait();
4848

4949
Cluster otherNode =
5050
new ClusterImpl()
5151
.membership(opts -> opts.seedMembers(address))
52-
.gossip(opts -> opts.gossipInterval(1))
53-
.failureDetector(opts -> opts.pingInterval(1))
54-
.membership(opts -> opts.syncInterval(1))
52+
.gossip(opts -> opts.gossipInterval(100))
53+
.failureDetector(opts -> opts.pingInterval(100))
54+
.membership(opts -> opts.syncInterval(100))
5555
.transport(opts -> opts.connectTimeout(CONNECT_TIMEOUT))
5656
.startAwait();
5757

5858
assertEquals(2, seedNode.members().size());
5959
assertEquals(2, otherNode.members().size());
6060

61-
for (int i = 0; i < 15; i++) {
61+
for (int i = 0; i < 10; i++) {
6262
seedNode.shutdown();
6363
seedNode.onShutdown().then(Mono.delay(Duration.ofMillis(100))).block();
6464

6565
seedNode =
6666
new ClusterImpl()
67+
.gossip(opts -> opts.gossipInterval(100))
68+
.failureDetector(opts -> opts.pingInterval(100))
69+
.membership(opts -> opts.syncInterval(100))
6770
.transport(opts -> opts.host(address.host()).port(address.port()))
71+
.transport(opts -> opts.connectTimeout(CONNECT_TIMEOUT))
6872
.startAwait();
6973

7074
TimeUnit.SECONDS.sleep(1);

0 commit comments

Comments
 (0)