Repository: geode Updated Branches: refs/heads/feature/GEODE-2632-17 00b9eb87e -> 5cf271d22
Fix spotless format Project: http://git-wip-us.apache.org/repos/asf/geode/repo Commit: http://git-wip-us.apache.org/repos/asf/geode/commit/5cf271d2 Tree: http://git-wip-us.apache.org/repos/asf/geode/tree/5cf271d2 Diff: http://git-wip-us.apache.org/repos/asf/geode/diff/5cf271d2 Branch: refs/heads/feature/GEODE-2632-17 Commit: 5cf271d2220516bf132a655180ab0ffa7ff5e1fd Parents: 00b9eb8 Author: Kirk Lund <[email protected]> Authored: Wed May 24 16:43:01 2017 -0700 Committer: Kirk Lund <[email protected]> Committed: Wed May 24 16:43:01 2017 -0700 ---------------------------------------------------------------------- .../cache/ha/BlockingHARegionJUnitTest.java | 18 ++++++++++------ .../SerializableErrorCollector.java | 22 +++++++++----------- 2 files changed, 22 insertions(+), 18 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/geode/blob/5cf271d2/geode-core/src/test/java/org/apache/geode/internal/cache/ha/BlockingHARegionJUnitTest.java ---------------------------------------------------------------------- diff --git a/geode-core/src/test/java/org/apache/geode/internal/cache/ha/BlockingHARegionJUnitTest.java b/geode-core/src/test/java/org/apache/geode/internal/cache/ha/BlockingHARegionJUnitTest.java index 3c1adc3..1534192 100755 --- a/geode-core/src/test/java/org/apache/geode/internal/cache/ha/BlockingHARegionJUnitTest.java +++ b/geode-core/src/test/java/org/apache/geode/internal/cache/ha/BlockingHARegionJUnitTest.java @@ -48,7 +48,8 @@ import org.apache.geode.test.junit.rules.serializable.SerializableErrorCollector * #40314: Filled up queue causes all publishers to block * * <p> - * #37627: In case of out of order messages, (sequence Id violation), in spite of HARQ not full, the capacity (putPermits) of the HARQ exhausted. + * #37627: In case of out of order messages, (sequence Id violation), in spite of HARQ not full, the + * capacity (putPermits) of the HARQ exhausted. */ @Category({IntegrationTest.class, ClientSubscriptionTest.class}) public class BlockingHARegionJUnitTest { @@ -117,7 +118,8 @@ public class BlockingHARegionJUnitTest { @Test public void testBoundedPuts() throws Exception { this.queueAttributes.setBlockingQueueCapacity(1); - HARegionQueue hrq = getHARegionQueueInstance(REGION, this.cache, this.queueAttributes, BLOCKING_HA_QUEUE, false); + HARegionQueue hrq = getHARegionQueueInstance(REGION, this.cache, this.queueAttributes, + BLOCKING_HA_QUEUE, false); hrq.setPrimary(true); // fix for 40314 - capacity constraint is checked for primary only startDoPuts(hrq, 1000); @@ -135,7 +137,8 @@ public class BlockingHARegionJUnitTest { @Test public void testPutBeingBlocked() throws Exception { this.queueAttributes.setBlockingQueueCapacity(1); - HARegionQueue hrq = getHARegionQueueInstance(REGION, this.cache, this.queueAttributes, BLOCKING_HA_QUEUE, false); + HARegionQueue hrq = getHARegionQueueInstance(REGION, this.cache, this.queueAttributes, + BLOCKING_HA_QUEUE, false); hrq.setPrimary(true); // fix for 40314 - capacity constraint is checked for primary only Thread doPuts = startDoPuts(hrq, 2); @@ -160,7 +163,8 @@ public class BlockingHARegionJUnitTest { @Test public void testConcurrentPutsNotExceedingLimit() throws Exception { this.queueAttributes.setBlockingQueueCapacity(10000); - HARegionQueue hrq = getHARegionQueueInstance(REGION, this.cache, this.queueAttributes, BLOCKING_HA_QUEUE, false); + HARegionQueue hrq = getHARegionQueueInstance(REGION, this.cache, this.queueAttributes, + BLOCKING_HA_QUEUE, false); hrq.setPrimary(true); // fix for 40314 - capacity constraint is checked for primary only Thread doPuts1 = startDoPuts(hrq, 20000, 1); @@ -191,7 +195,8 @@ public class BlockingHARegionJUnitTest { @Test public void testConcurrentPutsTakesNotExceedingLimit() throws Exception { this.queueAttributes.setBlockingQueueCapacity(10000); - HARegionQueue hrq = getHARegionQueueInstance(REGION, this.cache, this.queueAttributes, BLOCKING_HA_QUEUE, false); + HARegionQueue hrq = getHARegionQueueInstance(REGION, this.cache, this.queueAttributes, + BLOCKING_HA_QUEUE, false); hrq.setPrimary(true); // fix for 40314 - capacity constraint is checked for primary only Thread doPuts1 = startDoPuts(hrq, 40000, 1); @@ -234,7 +239,8 @@ public class BlockingHARegionJUnitTest { public void testHARQMaxCapacity_Bug37627() throws Exception { this.queueAttributes.setBlockingQueueCapacity(1); this.queueAttributes.setExpiryTime(180); - HARegionQueue hrq = getHARegionQueueInstance(REGION, this.cache, this.queueAttributes, BLOCKING_HA_QUEUE, false); + HARegionQueue hrq = getHARegionQueueInstance(REGION, this.cache, this.queueAttributes, + BLOCKING_HA_QUEUE, false); hrq.setPrimary(true); // fix for 40314 - capacity constraint is checked for primary only EventID event1 = new EventID(new byte[] {1}, 1, 2); // violation http://git-wip-us.apache.org/repos/asf/geode/blob/5cf271d2/geode-junit/src/main/java/org/apache/geode/test/junit/rules/serializable/SerializableErrorCollector.java ---------------------------------------------------------------------- diff --git a/geode-junit/src/main/java/org/apache/geode/test/junit/rules/serializable/SerializableErrorCollector.java b/geode-junit/src/main/java/org/apache/geode/test/junit/rules/serializable/SerializableErrorCollector.java index 0abfdaf..5557f1b 100644 --- a/geode-junit/src/main/java/org/apache/geode/test/junit/rules/serializable/SerializableErrorCollector.java +++ b/geode-junit/src/main/java/org/apache/geode/test/junit/rules/serializable/SerializableErrorCollector.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;
