Change several RMI calls from closures to static methods.
Project: http://git-wip-us.apache.org/repos/asf/geode/repo Commit: http://git-wip-us.apache.org/repos/asf/geode/commit/73ba47d4 Tree: http://git-wip-us.apache.org/repos/asf/geode/tree/73ba47d4 Diff: http://git-wip-us.apache.org/repos/asf/geode/diff/73ba47d4 Branch: refs/heads/master Commit: 73ba47d468b2c5567fef2ec1c1a6d9bba850d39c Parents: 988dca8 Author: Galen O'Sullivan <[email protected]> Authored: Fri Dec 16 15:20:00 2016 -0800 Committer: Udo Kohlmeyer <[email protected]> Committed: Tue Jan 24 10:13:26 2017 -0800 ---------------------------------------------------------------------- .../cache/FixedPRSinglehopDUnitTest.java | 32 ++++++++++---------- 1 file changed, 16 insertions(+), 16 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/geode/blob/73ba47d4/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 3e42414..0d269bc 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 @@ -297,18 +297,18 @@ public class FixedPRSinglehopDUnitTest extends JUnit4CacheTestCase { // 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) - && (server2.invoke(() -> FixedPRSinglehopDUnitTest.primaryBucketsOnServer()) == 3)); + () -> (server1.invoke(FixedPRSinglehopDUnitTest::primaryBucketsOnServer) == 6) + && (server2.invoke(FixedPRSinglehopDUnitTest::primaryBucketsOnServer) == 3)); // TODO: Verify that all the fpa's are in the map - server1.invoke(() -> FixedPRSinglehopDUnitTest.printView()); - server2.invoke(() -> FixedPRSinglehopDUnitTest.printView()); + server1.invoke(FixedPRSinglehopDUnitTest::printView); + server2.invoke(FixedPRSinglehopDUnitTest::printView); int totalBucketOnServer = 0; totalBucketOnServer += - (Integer) server1.invoke(() -> FixedPRSinglehopDUnitTest.primaryBucketsOnServer()); + (Integer) server1.invoke(FixedPRSinglehopDUnitTest::primaryBucketsOnServer); totalBucketOnServer += - (Integer) server2.invoke(() -> FixedPRSinglehopDUnitTest.primaryBucketsOnServer()); + (Integer) server2.invoke(FixedPRSinglehopDUnitTest::primaryBucketsOnServer); verifyMetadata(totalBucketOnServer, 1); updateIntoSinglePRFor3Qs(); @@ -326,25 +326,25 @@ 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) - && (server2.invoke(() -> FixedPRSinglehopDUnitTest.primaryBucketsOnServer()) == 3) - && (server4.invoke(() -> FixedPRSinglehopDUnitTest.primaryBucketsOnServer()) == 6)); + () -> (server1.invoke(FixedPRSinglehopDUnitTest::primaryBucketsOnServer) == 3) + && (server2.invoke(FixedPRSinglehopDUnitTest::primaryBucketsOnServer) == 3) + && (server4.invoke(FixedPRSinglehopDUnitTest::primaryBucketsOnServer) == 6)); getFromPartitionedRegions(); - server1.invoke(() -> FixedPRSinglehopDUnitTest.printView()); - server2.invoke(() -> FixedPRSinglehopDUnitTest.printView()); - server4.invoke(() -> FixedPRSinglehopDUnitTest.printView()); + server1.invoke(FixedPRSinglehopDUnitTest::printView); + server2.invoke(FixedPRSinglehopDUnitTest::printView); + server4.invoke(FixedPRSinglehopDUnitTest::printView); totalBucketOnServer = 0; totalBucketOnServer += - (Integer) server1.invoke(() -> FixedPRSinglehopDUnitTest.primaryBucketsOnServer()); + (Integer) server1.invoke(FixedPRSinglehopDUnitTest::primaryBucketsOnServer); totalBucketOnServer += - (Integer) server2.invoke(() -> FixedPRSinglehopDUnitTest.primaryBucketsOnServer()); + (Integer) server2.invoke(FixedPRSinglehopDUnitTest::primaryBucketsOnServer); totalBucketOnServer += - (Integer) server4.invoke(() -> FixedPRSinglehopDUnitTest.primaryBucketsOnServer()); + (Integer) server4.invoke(FixedPRSinglehopDUnitTest::primaryBucketsOnServer); updateIntoSinglePR(); } finally { - server3.invoke(() -> FixedPRSinglehopDUnitTest.stopLocator()); + server3.invoke(FixedPRSinglehopDUnitTest::stopLocator); } }
