This closes #305
Project: http://git-wip-us.apache.org/repos/asf/geode/repo Commit: http://git-wip-us.apache.org/repos/asf/geode/commit/610ae1df Tree: http://git-wip-us.apache.org/repos/asf/geode/tree/610ae1df Diff: http://git-wip-us.apache.org/repos/asf/geode/diff/610ae1df Branch: refs/heads/master Commit: 610ae1df2f71d2facfe95b8733c6230b909e36ff Parents: 73ba47d Author: Galen O'Sullivan <[email protected]> Authored: Wed Jan 4 12:48:33 2017 -0800 Committer: Udo Kohlmeyer <[email protected]> Committed: Tue Jan 24 10:13:27 2017 -0800 ---------------------------------------------------------------------- .../geode/internal/cache/FixedPRSinglehopDUnitTest.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/geode/blob/610ae1df/geode-core/src/test/java/org/apache/geode/internal/cache/FixedPRSinglehopDUnitTest.java ---------------------------------------------------------------------- diff --git a/geode-core/src/test/java/org/apache/geode/internal/cache/FixedPRSinglehopDUnitTest.java b/geode-core/src/test/java/org/apache/geode/internal/cache/FixedPRSinglehopDUnitTest.java index 0d269bc..8c6d8b2 100644 --- a/geode-core/src/test/java/org/apache/geode/internal/cache/FixedPRSinglehopDUnitTest.java +++ b/geode-core/src/test/java/org/apache/geode/internal/cache/FixedPRSinglehopDUnitTest.java @@ -296,8 +296,8 @@ public class FixedPRSinglehopDUnitTest extends JUnit4CacheTestCase { getFromPartitionedRegionsFor3Qs(); // Server 1 is actually primary for both Q1 and Q2, since there is no FPA server with // primary set to true. - Awaitility.await().atMost(15, TimeUnit.SECONDS).until( - () -> (server1.invoke(FixedPRSinglehopDUnitTest::primaryBucketsOnServer) == 6) + Awaitility.await().atMost(15, TimeUnit.SECONDS) + .until(() -> (server1.invoke(FixedPRSinglehopDUnitTest::primaryBucketsOnServer) == 6) && (server2.invoke(FixedPRSinglehopDUnitTest::primaryBucketsOnServer) == 3)); // TODO: Verify that all the fpa's are in the map @@ -325,8 +325,8 @@ public class FixedPRSinglehopDUnitTest extends JUnit4CacheTestCase { putIntoPartitionedRegions(); // Wait to make sure that the buckets have actually moved. - Awaitility.await().atMost(15, TimeUnit.SECONDS).until( - () -> (server1.invoke(FixedPRSinglehopDUnitTest::primaryBucketsOnServer) == 3) + Awaitility.await().atMost(15, TimeUnit.SECONDS) + .until(() -> (server1.invoke(FixedPRSinglehopDUnitTest::primaryBucketsOnServer) == 3) && (server2.invoke(FixedPRSinglehopDUnitTest::primaryBucketsOnServer) == 3) && (server4.invoke(FixedPRSinglehopDUnitTest::primaryBucketsOnServer) == 6));
