geode-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From kl...@apache.org
Subject [08/26] geode git commit: Change several RMI calls from closures to static methods.
Date Tue, 24 Jan 2017 22:05:09 GMT
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/feature/GEODE-1930-2
Commit: 73ba47d468b2c5567fef2ec1c1a6d9bba850d39c
Parents: 988dca8
Author: Galen O'Sullivan <gosullivan@pivotal.io>
Authored: Fri Dec 16 15:20:00 2016 -0800
Committer: Udo Kohlmeyer <ukohlmeyer@pivotal.io>
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);
     }
   }
 


Mime
View raw message