http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/e0212110/geode-core/src/test/java/org/apache/geode/test/dunit/rules/WhichVMs.java ---------------------------------------------------------------------- diff --git a/geode-core/src/test/java/org/apache/geode/test/dunit/rules/WhichVMs.java b/geode-core/src/test/java/org/apache/geode/test/dunit/rules/WhichVMs.java index 4ee6020..1048f2e 100644 --- a/geode-core/src/test/java/org/apache/geode/test/dunit/rules/WhichVMs.java +++ b/geode-core/src/test/java/org/apache/geode/test/dunit/rules/WhichVMs.java @@ -1,18 +1,16 @@ /* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at + * Licensed to the Apache Software Foundation (ASF) under one or more contributor license + * agreements. See the NOTICE file distributed with this work for additional information regarding + * copyright ownership. The ASF licenses this file to You under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance with the License. You may obtain a + * copy of the License at * - * http://www.apache.org/licenses/LICENSE-2.0 + * http://www.apache.org/licenses/LICENSE-2.0 * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. + * Unless required by applicable law or agreed to in writing, software distributed under the License + * is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express + * or implied. See the License for the specific language governing permissions and limitations under + * the License. */ package org.apache.geode.test.dunit.rules; @@ -25,22 +23,23 @@ import java.io.Serializable; * * TODO: add ability to specify order */ -public class WhichVMs implements Serializable{ +public class WhichVMs implements Serializable { private boolean controllerVM; private boolean everyVM; private boolean locatorVM; - public WhichVMs() { - } + public WhichVMs() {} public WhichVMs addControllerVM() { this.controllerVM = true; return this; } + public WhichVMs addEveryVM() { this.everyVM = true; return this; } + public WhichVMs addLocatorVM() { this.locatorVM = true; return this; @@ -49,9 +48,11 @@ public class WhichVMs implements Serializable{ public boolean controllerVM() { return this.controllerVM; } + public boolean everyVM() { return this.everyVM; } + public boolean locatorVM() { return this.locatorVM; }
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/e0212110/geode-core/src/test/java/org/apache/geode/test/dunit/rules/tests/DistributedTestRuleTest.java ---------------------------------------------------------------------- diff --git a/geode-core/src/test/java/org/apache/geode/test/dunit/rules/tests/DistributedTestRuleTest.java b/geode-core/src/test/java/org/apache/geode/test/dunit/rules/tests/DistributedTestRuleTest.java index 8352db2..7dded64 100644 --- a/geode-core/src/test/java/org/apache/geode/test/dunit/rules/tests/DistributedTestRuleTest.java +++ b/geode-core/src/test/java/org/apache/geode/test/dunit/rules/tests/DistributedTestRuleTest.java @@ -1,18 +1,16 @@ /* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at + * Licensed to the Apache Software Foundation (ASF) under one or more contributor license + * agreements. See the NOTICE file distributed with this work for additional information regarding + * copyright ownership. The ASF licenses this file to You under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance with the License. You may obtain a + * copy of the License at * - * http://www.apache.org/licenses/LICENSE-2.0 + * http://www.apache.org/licenses/LICENSE-2.0 * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. + * Unless required by applicable law or agreed to in writing, software distributed under the License + * is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express + * or implied. See the License for the specific language governing permissions and limitations under + * the License. */ package org.apache.geode.test.dunit.rules.tests; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/e0212110/geode-core/src/test/java/org/apache/geode/test/dunit/standalone/DUnitLauncher.java ---------------------------------------------------------------------- diff --git a/geode-core/src/test/java/org/apache/geode/test/dunit/standalone/DUnitLauncher.java b/geode-core/src/test/java/org/apache/geode/test/dunit/standalone/DUnitLauncher.java index 5c0bbdb..11f572b 100644 --- a/geode-core/src/test/java/org/apache/geode/test/dunit/standalone/DUnitLauncher.java +++ b/geode-core/src/test/java/org/apache/geode/test/dunit/standalone/DUnitLauncher.java @@ -83,7 +83,8 @@ public class DUnitLauncher { private static final int LOCATOR_VM_NUM = -2; static final long STARTUP_TIMEOUT = 120 * 1000; - private static final String STARTUP_TIMEOUT_MESSAGE = "VMs did not start up within " + (STARTUP_TIMEOUT/1000) + " seconds"; + private static final String STARTUP_TIMEOUT_MESSAGE = + "VMs did not start up within " + (STARTUP_TIMEOUT / 1000) + " seconds"; private static final String SUSPECT_FILENAME = "dunit_suspect.log"; private static File DUNIT_SUSPECT_FILE; @@ -201,8 +202,8 @@ public class DUnitLauncher { // Create a VM for the locator processManager.launchVM(LOCATOR_VM_NUM); - //wait for the VM to start up - if(!processManager.waitForVMs(STARTUP_TIMEOUT)) { + // wait for the VM to start up + if (!processManager.waitForVMs(STARTUP_TIMEOUT)) { throw new RuntimeException("VMs did not start up within 30 seconds"); } @@ -216,8 +217,8 @@ public class DUnitLauncher { processManager.launchVM(i); } - //wait for the VMS to start up - if(!processManager.waitForVMs(STARTUP_TIMEOUT)) { + // wait for the VMS to start up + if (!processManager.waitForVMs(STARTUP_TIMEOUT)) { throw new RuntimeException("VMs did not start up within 30 seconds"); } http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/e0212110/geode-junit/src/main/java/org/apache/geode/test/junit/rules/UseJacksonForJsonPathRule.java ---------------------------------------------------------------------- diff --git a/geode-junit/src/main/java/org/apache/geode/test/junit/rules/UseJacksonForJsonPathRule.java b/geode-junit/src/main/java/org/apache/geode/test/junit/rules/UseJacksonForJsonPathRule.java index 03d5a60..c7c326a 100644 --- a/geode-junit/src/main/java/org/apache/geode/test/junit/rules/UseJacksonForJsonPathRule.java +++ b/geode-junit/src/main/java/org/apache/geode/test/junit/rules/UseJacksonForJsonPathRule.java @@ -1,18 +1,16 @@ /* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at + * Licensed to the Apache Software Foundation (ASF) under one or more contributor license + * agreements. See the NOTICE file distributed with this work for additional information regarding + * copyright ownership. The ASF licenses this file to You under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance with the License. You may obtain a + * copy of the License at * - * http://www.apache.org/licenses/LICENSE-2.0 + * http://www.apache.org/licenses/LICENSE-2.0 * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. + * Unless required by applicable law or agreed to in writing, software distributed under the License + * is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express + * or implied. See the License for the specific language governing permissions and limitations under + * the License. */ package org.apache.geode.test.junit.rules; @@ -32,7 +30,9 @@ import org.apache.geode.test.junit.rules.serializable.SerializableExternalResour /** * JUnit Rule that configures json-path to use the {@code JacksonJsonProvider} * - * <p>UseJacksonForJsonPathRule can be used in tests that need to use json-path-assert: + * <p> + * UseJacksonForJsonPathRule can be used in tests that need to use json-path-assert: + * * <pre> * {@literal @}ClassRule * public static UseJacksonForJsonPathRule useJacksonForJsonPathRule = new UseJacksonForJsonPathRule(); @@ -45,7 +45,7 @@ import org.apache.geode.test.junit.rules.serializable.SerializableExternalResour * } * </pre> */ -@SuppressWarnings({ "serial", "unused" }) +@SuppressWarnings({"serial", "unused"}) public class UseJacksonForJsonPathRule extends SerializableExternalResource { private boolean hadDefaults; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/e0212110/geode-junit/src/main/java/org/apache/geode/test/junit/rules/serializable/SerializableExternalResource.java ---------------------------------------------------------------------- diff --git a/geode-junit/src/main/java/org/apache/geode/test/junit/rules/serializable/SerializableExternalResource.java b/geode-junit/src/main/java/org/apache/geode/test/junit/rules/serializable/SerializableExternalResource.java index 75f4575..be561df 100755 --- a/geode-junit/src/main/java/org/apache/geode/test/junit/rules/serializable/SerializableExternalResource.java +++ b/geode-junit/src/main/java/org/apache/geode/test/junit/rules/serializable/SerializableExternalResource.java @@ -23,7 +23,8 @@ import org.junit.runners.model.Statement; /** * Serializable subclass of {@link org.junit.rules.ExternalResource ExternalResource}. */ -public abstract class SerializableExternalResource extends ExternalResource implements SerializableTestRule { +public abstract class SerializableExternalResource extends ExternalResource + implements SerializableTestRule { public Statement apply(Statement base, Description description) { return statement(base); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/e0212110/geode-junit/src/main/java/org/apache/geode/test/junit/rules/serializable/SerializableStatement.java ---------------------------------------------------------------------- diff --git a/geode-junit/src/main/java/org/apache/geode/test/junit/rules/serializable/SerializableStatement.java b/geode-junit/src/main/java/org/apache/geode/test/junit/rules/serializable/SerializableStatement.java index 3f07421..9251e83 100644 --- a/geode-junit/src/main/java/org/apache/geode/test/junit/rules/serializable/SerializableStatement.java +++ b/geode-junit/src/main/java/org/apache/geode/test/junit/rules/serializable/SerializableStatement.java @@ -1,18 +1,16 @@ /* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at + * Licensed to the Apache Software Foundation (ASF) under one or more contributor license + * agreements. See the NOTICE file distributed with this work for additional information regarding + * copyright ownership. The ASF licenses this file to You under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance with the License. You may obtain a + * copy of the License at * - * http://www.apache.org/licenses/LICENSE-2.0 + * http://www.apache.org/licenses/LICENSE-2.0 * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. + * Unless required by applicable law or agreed to in writing, software distributed under the License + * is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express + * or implied. See the License for the specific language governing permissions and limitations under + * the License. */ package org.apache.geode.test.junit.rules.serializable; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/e0212110/geode-lucene/src/test/java/org/apache/geode/cache/lucene/internal/management/LuceneManagementDUnitTest.java ---------------------------------------------------------------------- diff --git a/geode-lucene/src/test/java/org/apache/geode/cache/lucene/internal/management/LuceneManagementDUnitTest.java b/geode-lucene/src/test/java/org/apache/geode/cache/lucene/internal/management/LuceneManagementDUnitTest.java index 27582a7..478fe67 100644 --- a/geode-lucene/src/test/java/org/apache/geode/cache/lucene/internal/management/LuceneManagementDUnitTest.java +++ b/geode-lucene/src/test/java/org/apache/geode/cache/lucene/internal/management/LuceneManagementDUnitTest.java @@ -148,7 +148,8 @@ public class LuceneManagementDUnitTest extends ManagementTestBase { } private LuceneServiceMXBean getMBean() { - ObjectName objectName = MBeanJMXAdapter.getCacheServiceMBeanName(getSystem().getDistributedMember(), "LuceneService"); + ObjectName objectName = MBeanJMXAdapter + .getCacheServiceMBeanName(getSystem().getDistributedMember(), "LuceneService"); assertNotNull(getManagementService().getMBeanInstance(objectName, LuceneServiceMXBean.class)); return getManagementService().getMBeanInstance(objectName, LuceneServiceMXBean.class); } @@ -179,12 +180,13 @@ public class LuceneManagementDUnitTest extends ManagementTestBase { private void createIndexes(String regionName, int numIndexes) { LuceneService luceneService = LuceneServiceProvider.get(getCache()); - for (int i=0; i<numIndexes; i++) { - luceneService.createIndex(INDEX_NAME+"_"+i, regionName, "field"+i); + for (int i = 0; i < numIndexes; i++) { + luceneService.createIndex(INDEX_NAME + "_" + i, regionName, "field" + i); } } - private void verifyAllMBeanIndexMetrics(String regionName, int numRegionIndexes, int numTotalIndexes) { + private void verifyAllMBeanIndexMetrics(String regionName, int numRegionIndexes, + int numTotalIndexes) { LuceneServiceMXBean mbean = getMBean(); verifyMBeanIndexMetrics(mbean, regionName, numRegionIndexes, numTotalIndexes); } @@ -209,7 +211,7 @@ public class LuceneManagementDUnitTest extends ManagementTestBase { } private void putEntries(String regionName, int numEntries) { - for (int i=0; i<numEntries; i++) { + for (int i = 0; i < numEntries; i++) { Region region = getCache().getRegion(regionName); String key = String.valueOf(i); Object value = new TestObject(key); @@ -219,7 +221,8 @@ public class LuceneManagementDUnitTest extends ManagementTestBase { private void queryEntries(String regionName, String indexName) throws LuceneQueryException { LuceneService service = LuceneServiceProvider.get(getCache()); - LuceneQuery query = service.createLuceneQueryFactory().create(indexName, regionName, "field0:0", null); + LuceneQuery query = + service.createLuceneQueryFactory().create(indexName, regionName, "field0:0", null); query.findValues(); }