summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorAnu Engineer <aengineer@apache.org>2018-06-01 12:54:47 -0700
committerAnu Engineer <aengineer@apache.org>2018-06-01 12:54:47 -0700
commit19560bb70421fda094f3f2af09e67501099b7ab7 (patch)
tree2af9dfbf3aa89988d518970f74f927843d402af2
parent6b21a599fbd53e3d6113fcd9a984f6ac59ccd302 (diff)
HDDS-137. Cleanup Hdds-ozone CheckStyle Issues.
Contributed by Anu Engineer.
-rw-r--r--hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/helpers/ContainerData.java3
-rw-r--r--hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/impl/ContainerManagerImpl.java8
-rw-r--r--hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/impl/KeyManagerImpl.java12
-rw-r--r--hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/transport/server/ratis/ContainerStateMachine.java3
-rw-r--r--hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/utils/ContainerCache.java6
-rw-r--r--hadoop-hdds/container-service/src/test/java/org/apache/hadoop/ozone/container/common/package-info.java22
6 files changed, 43 insertions, 11 deletions
diff --git a/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/helpers/ContainerData.java b/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/helpers/ContainerData.java
index d1746f2bde..020f45d589 100644
--- a/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/helpers/ContainerData.java
+++ b/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/helpers/ContainerData.java
@@ -285,7 +285,8 @@ public class ContainerData {
*
* @return String Name.
*/
- // TODO: check the ContainerCache class to see if we are using the ContainerID instead.
+ // TODO: check the ContainerCache class to see if
+ // we are using the ContainerID instead.
/*
public String getName() {
return getContainerID();
diff --git a/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/impl/ContainerManagerImpl.java b/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/impl/ContainerManagerImpl.java
index af47015324..b09d324e2f 100644
--- a/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/impl/ContainerManagerImpl.java
+++ b/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/impl/ContainerManagerImpl.java
@@ -314,7 +314,8 @@ public class ContainerManagerImpl implements ContainerManager {
writeLock();
try {
if (containerMap.containsKey(containerData.getContainerID())) {
- LOG.debug("container already exists. {}", containerData.getContainerID());
+ LOG.debug("container already exists. {}",
+ containerData.getContainerID());
throw new StorageContainerException("container already exists.",
CONTAINER_EXISTS);
}
@@ -595,7 +596,8 @@ public class ContainerManagerImpl implements ContainerManager {
@Override
public void updateContainer(long containerID, ContainerData data,
boolean forceUpdate) throws StorageContainerException {
- Preconditions.checkState(containerID >= 0, "Container ID cannot be negative.");
+ Preconditions.checkState(containerID >= 0,
+ "Container ID cannot be negative.");
Preconditions.checkNotNull(data, "Container data cannot be null");
FileOutputStream containerStream = null;
DigestOutputStream dos = null;
@@ -711,7 +713,7 @@ public class ContainerManagerImpl implements ContainerManager {
}
/**
- * Returns LifeCycle State of the container
+ * Returns LifeCycle State of the container.
* @param containerID - Id of the container
* @return LifeCycle State of the container
* @throws StorageContainerException
diff --git a/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/impl/KeyManagerImpl.java b/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/impl/KeyManagerImpl.java
index 0ca73545f6..40ae1c70a7 100644
--- a/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/impl/KeyManagerImpl.java
+++ b/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/impl/KeyManagerImpl.java
@@ -72,8 +72,10 @@ public class KeyManagerImpl implements KeyManager {
*/
@Override
public void putKey(KeyData data) throws IOException {
- Preconditions.checkNotNull(data, "KeyData cannot be null for put operation.");
- Preconditions.checkState(data.getContainerID() >= 0, "Container ID cannot be negative");
+ Preconditions.checkNotNull(data,
+ "KeyData cannot be null for put operation.");
+ Preconditions.checkState(data.getContainerID() >= 0,
+ "Container ID cannot be negative");
containerManager.readLock();
try {
// We are not locking the key manager since LevelDb serializes all actions
@@ -169,8 +171,10 @@ public class KeyManagerImpl implements KeyManager {
public List<KeyData> listKey(
long containerID, long startLocalID, int count)
throws IOException {
- Preconditions.checkState(containerID >= 0, "Container ID cannot be negative");
- Preconditions.checkState(startLocalID >= 0, "startLocal ID cannot be negative");
+ Preconditions.checkState(containerID >= 0,
+ "Container ID cannot be negative");
+ Preconditions.checkState(startLocalID >= 0,
+ "startLocal ID cannot be negative");
Preconditions.checkArgument(count > 0,
"Count must be a positive number.");
ContainerData cData = containerManager.readContainer(containerID);
diff --git a/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/transport/server/ratis/ContainerStateMachine.java b/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/transport/server/ratis/ContainerStateMachine.java
index 56c52bb80e..176407d66d 100644
--- a/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/transport/server/ratis/ContainerStateMachine.java
+++ b/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/transport/server/ratis/ContainerStateMachine.java
@@ -265,7 +265,8 @@ public class ContainerStateMachine extends BaseStateMachine {
Message message = runCommand(requestProto);
if (cmdType == ContainerProtos.Type.CreateContainer) {
long containerID =
- requestProto.getCreateContainer().getContainerData().getContainerID();
+ requestProto.getCreateContainer()
+ .getContainerData().getContainerID();
createContainerFutureMap.remove(containerID).complete(message);
}
return CompletableFuture.completedFuture(message);
diff --git a/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/utils/ContainerCache.java b/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/utils/ContainerCache.java
index 4d9c690311..7f611b92bc 100644
--- a/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/utils/ContainerCache.java
+++ b/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/utils/ContainerCache.java
@@ -125,7 +125,8 @@ public final class ContainerCache extends LRUMap {
*/
public MetadataStore getDB(long containerID, String containerDBPath)
throws IOException {
- Preconditions.checkState(containerID >= 0, "Container ID cannot be negative.");
+ Preconditions.checkState(containerID >= 0,
+ "Container ID cannot be negative.");
lock.lock();
try {
MetadataStore db = (MetadataStore) this.get(containerID);
@@ -153,7 +154,8 @@ public final class ContainerCache extends LRUMap {
* @param containerID - ID of the container.
*/
public void removeDB(long containerID) {
- Preconditions.checkState(containerID >= 0, "Container ID cannot be negative.");
+ Preconditions.checkState(containerID >= 0,
+ "Container ID cannot be negative.");
lock.lock();
try {
MetadataStore db = (MetadataStore)this.get(containerID);
diff --git a/hadoop-hdds/container-service/src/test/java/org/apache/hadoop/ozone/container/common/package-info.java b/hadoop-hdds/container-service/src/test/java/org/apache/hadoop/ozone/container/common/package-info.java
new file mode 100644
index 0000000000..ca3d29dada
--- /dev/null
+++ b/hadoop-hdds/container-service/src/test/java/org/apache/hadoop/ozone/container/common/package-info.java
@@ -0,0 +1,22 @@
+/*
+ * 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
+ *
+ * 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.
+ *
+ */
+/**
+ * SCM Testing and Mocking Utils.
+ */
+package org.apache.hadoop.ozone.container.common; \ No newline at end of file