You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by ud...@apache.org on 2017/01/24 18:14:37 UTC
[4/4] geode git commit: This closes #305
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/develop
Commit: 610ae1df2f71d2facfe95b8733c6230b909e36ff
Parents: 73ba47d
Author: Galen O'Sullivan <go...@pivotal.io>
Authored: Wed Jan 4 12:48:33 2017 -0800
Committer: Udo Kohlmeyer <uk...@pivotal.io>
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));