diff --git a/collections/src/test/java/net/kuujo/copycat/collections/AsyncMapTest.java b/collections/src/test/java/net/kuujo/copycat/collections/AsyncMapTest.java index 3feaeb7358..5435e075de 100644 --- a/collections/src/test/java/net/kuujo/copycat/collections/AsyncMapTest.java +++ b/collections/src/test/java/net/kuujo/copycat/collections/AsyncMapTest.java @@ -33,7 +33,7 @@ public class AsyncMapTest extends ConcurrentTestCase { public void testAsyncMapPutGet() throws Throwable { TestCluster> cluster = TestCluster.of((uri, config) -> AsyncMap.create("test", uri, config, new AsyncMapConfig().withLog(new BufferedLog()))); cluster.open().thenRun(this::resume); - await(5000); + await(15000); AsyncMap map = cluster.activeResources().iterator().next(); map.put("foo", "Hello world!").thenRun(() -> { map.get("foo").thenAccept(result -> { diff --git a/core/src/main/java/net/kuujo/copycat/internal/PassiveState.java b/core/src/main/java/net/kuujo/copycat/internal/PassiveState.java index c0d0b18b2d..ffda23940c 100644 --- a/core/src/main/java/net/kuujo/copycat/internal/PassiveState.java +++ b/core/src/main/java/net/kuujo/copycat/internal/PassiveState.java @@ -98,7 +98,7 @@ private void sync() { Random random = new Random(); List randomMembers = new ArrayList<>(3); for (int i = 0; i < Math.min(activeMembers.size(), 3); i++) { - randomMembers.add(activeMembers.get(random.nextInt(Math.min(activeMembers.size(), 2)))); + randomMembers.add(activeMembers.get(random.nextInt(Math.min(activeMembers.size(), 3)))); } // Increment the local member version in the vector clock. diff --git a/core/src/main/java/net/kuujo/copycat/internal/cluster/AbstractCluster.java b/core/src/main/java/net/kuujo/copycat/internal/cluster/AbstractCluster.java index 74b0ca5994..4fc9a3d432 100644 --- a/core/src/main/java/net/kuujo/copycat/internal/cluster/AbstractCluster.java +++ b/core/src/main/java/net/kuujo/copycat/internal/cluster/AbstractCluster.java @@ -243,7 +243,7 @@ private Collection getGossipMembers() { // Create a random list of three active members. Collection randomMembers = new HashSet<>(3); for (int i = 0; i < Math.min(activeMembers.size(), 3); i++) { - randomMembers.add(activeMembers.get(random.nextInt(Math.min(activeMembers.size(), 2)))); + randomMembers.add(activeMembers.get(random.nextInt(Math.min(activeMembers.size(), 3)))); } return randomMembers; }