refactor duplicated functions

Author: chiacyu

hadoop-ozone/client/src/main/java/org/apache/hadoop/ozone/client/checksum/BaseFileChecksumHelper.java

@@ -156,8 +156,6 @@ protected void setChecksumType(ContainerProtos.ChecksumType type) {
   protected abstract AbstractBlockChecksumComputer getBlockChecksumComputer(List<ContainerProtos.ChunkInfo> chunkInfos,
       long blockLength);
 
-  protected abstract String populateBlockChecksumBuf(ByteBuffer blockChecksumByteBuffer) throws IOException;
-
   protected abstract List<ContainerProtos.ChunkInfo> getChunkInfos(
       OmKeyLocationInfo keyLocationInfo) throws IOException;
 
@@ -167,6 +165,39 @@ protected ByteBuffer getBlockChecksumFromChunkChecksums(AbstractBlockChecksumCom
     return blockChecksumComputer.getOutByteBuffer();
   }
 
+  /**
+   * Parses out the raw blockChecksum bytes from {@code checksumData} byte
+   * buffer according to the blockChecksumType and populates the cumulative
+   * blockChecksumBuf with it.
+   *
+   * @return a debug-string representation of the parsed checksum if
+   *     debug is enabled, otherwise null.
+   */
+
+  protected String populateBlockChecksumBuf(ByteBuffer blockChecksumByteBuffer) throws IOException{
+    String blockChecksumForDebug = null;
+    switch (getCombineMode()) {
+    case MD5MD5CRC:
+      final MD5Hash md5 = new MD5Hash(blockChecksumByteBuffer.array());
+      md5.write(getBlockChecksumBuf());
+      if (LOG.isDebugEnabled()) {
+        blockChecksumForDebug = md5.toString();
+      }
+      break;
+    case COMPOSITE_CRC:
+      byte[] crcBytes = blockChecksumByteBuffer.array();
+      if (LOG.isDebugEnabled()) {
+        blockChecksumForDebug = CrcUtil.toSingleCrcString(crcBytes);
+      }
+      getBlockChecksumBuf().write(crcBytes);
+      break;
+    default:
+      throw new IOException(
+          "Unknown combine mode: " + getCombineMode());
+    }
+    return blockChecksumForDebug;
+  };
+
   /**
    * Compute block checksums block by block and append the raw bytes of the
    * block checksums into getBlockChecksumBuf().

hadoop-ozone/client/src/main/java/org/apache/hadoop/ozone/client/checksum/ECFileChecksumHelper.java

@@ -60,33 +60,6 @@ protected AbstractBlockChecksumComputer getBlockChecksumComputer(List<ContainerP
     return new ECBlockChecksumComputer(chunkInfos, getKeyInfo(), blockLength);
   }
 
-  @Override
-  protected String populateBlockChecksumBuf(
-      ByteBuffer blockChecksumByteBuffer) throws IOException {
-    String blockChecksumForDebug = null;
-    switch (getCombineMode()) {
-    case MD5MD5CRC:
-      final MD5Hash md5 = new MD5Hash(blockChecksumByteBuffer.array());
-      md5.write(getBlockChecksumBuf());
-      if (LOG.isDebugEnabled()) {
-        blockChecksumForDebug = md5.toString();
-      }
-      break;
-    case COMPOSITE_CRC:
-      byte[] crcBytes = blockChecksumByteBuffer.array();
-      if (LOG.isDebugEnabled()) {
-        blockChecksumForDebug = CrcUtil.toSingleCrcString(crcBytes);
-      }
-      getBlockChecksumBuf().write(crcBytes);
-      break;
-    default:
-      throw new IOException(
-          "Unknown combine mode: " + getCombineMode());
-    }
-
-    return blockChecksumForDebug;
-  }
-
   @Override
   protected List<ContainerProtos.ChunkInfo> getChunkInfos(OmKeyLocationInfo
                                                               keyLocationInfo) throws IOException {

hadoop-ozone/client/src/main/java/org/apache/hadoop/ozone/client/checksum/ReplicatedFileChecksumHelper.java

@@ -107,48 +107,4 @@ protected List<ContainerProtos.ChunkInfo> getChunkInfos(
 
     return chunks;
   }
-
-  /**
-   * Parses out the raw blockChecksum bytes from {@code checksumData} byte
-   * buffer according to the blockChecksumType and populates the cumulative
-   * blockChecksumBuf with it.
-   *
-   * @return a debug-string representation of the parsed checksum if
-   *     debug is enabled, otherwise null.
-   */
-  @Override
-  protected String populateBlockChecksumBuf(ByteBuffer checksumData)
-      throws IOException {
-    String blockChecksumForDebug = null;
-    switch (getCombineMode()) {
-    case MD5MD5CRC:
-      //read md5
-      final MD5Hash md5 = new MD5Hash(checksumData.array());
-      md5.write(getBlockChecksumBuf());
-      if (LOG.isDebugEnabled()) {
-        blockChecksumForDebug = md5.toString();
-      }
-      break;
-    case COMPOSITE_CRC:
-      // TODO: abort if chunk checksum type is not CRC32/CRC32C
-      //BlockChecksumType returnedType = PBHelperClient.convert(
-      //    checksumData.getBlockChecksumOptions().getBlockChecksumType());
-      /*if (returnedType != BlockChecksumType.COMPOSITE_CRC) {
-        throw new IOException(String.format(
-            "Unexpected blockChecksumType '%s', expecting COMPOSITE_CRC",
-            returnedType));
-      }*/
-      byte[] crcBytes = checksumData.array();
-      if (LOG.isDebugEnabled()) {
-        blockChecksumForDebug = CrcUtil.toMultiCrcString(crcBytes);
-      }
-      getBlockChecksumBuf().write(crcBytes);
-      break;
-    default:
-      throw new IOException(
-          "Unknown combine mode: " + getCombineMode());
-    }
-
-    return blockChecksumForDebug;
-  }
 }