You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by ab...@apache.org on 2016/12/02 01:43:56 UTC
[13/31] incubator-geode git commit: GEODE-1931: Spotless
GEODE-1931: Spotless
Project: http://git-wip-us.apache.org/repos/asf/incubator-geode/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-geode/commit/6eb62eb7
Tree: http://git-wip-us.apache.org/repos/asf/incubator-geode/tree/6eb62eb7
Diff: http://git-wip-us.apache.org/repos/asf/incubator-geode/diff/6eb62eb7
Branch: refs/heads/feature/GEODE-2156
Commit: 6eb62eb7f8f6f2b0f812cb8462982ef7a1bcaa64
Parents: f4439fc
Author: Udo Kohlmeyer <uk...@pivotal.io>
Authored: Thu Dec 1 07:45:09 2016 -0800
Committer: Udo Kohlmeyer <uk...@pivotal.io>
Committed: Thu Dec 1 07:45:25 2016 -0800
----------------------------------------------------------------------
.../geode/distributed/LocatorDUnitTest.java | 34 ++++++++++----------
1 file changed, 17 insertions(+), 17 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/6eb62eb7/geode-core/src/test/java/org/apache/geode/distributed/LocatorDUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/org/apache/geode/distributed/LocatorDUnitTest.java b/geode-core/src/test/java/org/apache/geode/distributed/LocatorDUnitTest.java
index 3b8c406..9715b73 100644
--- a/geode-core/src/test/java/org/apache/geode/distributed/LocatorDUnitTest.java
+++ b/geode-core/src/test/java/org/apache/geode/distributed/LocatorDUnitTest.java
@@ -1812,21 +1812,21 @@ public class LocatorDUnitTest extends JUnit4DistributedTestCase {
}
}
});
- vm3.invoke("Start locator on " + port2,()->{
- File logFile = new File("");
- try {
- Properties props = new Properties();
- props.setProperty(MCAST_PORT, String.valueOf(mcastport));
- props.setProperty(LOCATORS, locators);
- props.setProperty(LOG_LEVEL, LogWriterUtils.getDUnitLogLevel());
- props.setProperty(MCAST_TTL, "0");
- props.setProperty(ENABLE_NETWORK_PARTITION_DETECTION, "true");
- props.setProperty(ENABLE_CLUSTER_CONFIGURATION, "false");
- addDSProps(props);
- Locator.startLocatorAndDS(port2, logFile, null, props);
- } catch (IOException ex) {
- org.apache.geode.test.dunit.Assert.fail("While starting locator on port " + port2, ex);
- }
+ vm3.invoke("Start locator on " + port2, () -> {
+ File logFile = new File("");
+ try {
+ Properties props = new Properties();
+ props.setProperty(MCAST_PORT, String.valueOf(mcastport));
+ props.setProperty(LOCATORS, locators);
+ props.setProperty(LOG_LEVEL, LogWriterUtils.getDUnitLogLevel());
+ props.setProperty(MCAST_TTL, "0");
+ props.setProperty(ENABLE_NETWORK_PARTITION_DETECTION, "true");
+ props.setProperty(ENABLE_CLUSTER_CONFIGURATION, "false");
+ addDSProps(props);
+ Locator.startLocatorAndDS(port2, logFile, null, props);
+ } catch (IOException ex) {
+ org.apache.geode.test.dunit.Assert.fail("While starting locator on port " + port2, ex);
+ }
});
SerializableRunnable connect = new SerializableRunnable("Connect to " + locators) {
@@ -1977,7 +1977,7 @@ public class LocatorDUnitTest extends JUnit4DistributedTestCase {
Locator locator = Locator.startLocatorAndDS(port1, logFile, p);
try {
- vm0.invoke(()->DistributedSystem.connect(p));
+ vm0.invoke(() -> DistributedSystem.connect(p));
LogWriterUtils.getLogWriter().info("Stopping locator");
locator.stop();
@@ -1985,7 +1985,7 @@ public class LocatorDUnitTest extends JUnit4DistributedTestCase {
LogWriterUtils.getLogWriter().info("Starting locator");
locator = Locator.startLocatorAndDS(port1, logFile, p);
- vm0.invoke("disconnect",()->DistributedSystem.connect(p).disconnect());
+ vm0.invoke("disconnect", () -> DistributedSystem.connect(p).disconnect());
} finally {
locator.stop();