You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by kl...@apache.org on 2017/05/31 20:51:25 UTC
[40/47] geode git commit: Fix spotless format
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/409b59b9
Tree: http://git-wip-us.apache.org/repos/asf/geode/tree/409b59b9
Diff: http://git-wip-us.apache.org/repos/asf/geode/diff/409b59b9
Branch: refs/heads/feature/GEODE-2632-18
Commit: 409b59b9f2ac1b438ff1cd73cfef7682dc930358
Parents: 8d1b670
Author: Kirk Lund <kl...@apache.org>
Authored: Wed May 24 16:43:01 2017 -0700
Committer: Kirk Lund <kl...@apache.org>
Committed: Wed May 31 13:25:44 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/409b59b9/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/409b59b9/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;