ems/boco/src/main/java/org/onap/vfc/nfvo/emsdriver/commons/utils/Gunzip.java

   1 /**
   2  * Copyright 2017 CMCC Technologies Co., Ltd
   3  * <p>
   4  * Licensed under the Apache License, Version 2.0 (the "License");
   5  * you may not use this file except in compliance with the License.
   6  * You may obtain a copy of the License at
   7  * <p>
   8  * http://www.apache.org/licenses/LICENSE-2.0
   9  * <p>
  10  * Unless required by applicable law or agreed to in writing, software
  11  * distributed under the License is distributed on an "AS IS" BASIS,
  12  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  13  * See the License for the specific language governing permissions and
  14  * limitations under the License.
  15  */
  16 package org.onap.vfc.nfvo.emsdriver.commons.utils;
  17
  18 import java.io.*;
  19 import java.util.zip.GZIPInputStream;
  20
  21 public class Gunzip {
  22
  23         /**
  24          *
  25          */
  26         public void unCompress(String gzFileName, String toFile) throws IOException {
  27                 GZIPInputStream gzIn = null;
  28                 FileOutputStream fileOutput = null;
  29                 FileInputStream gzInput = new FileInputStream(gzFileName);
  30                 try {
  31                         gzIn = new GZIPInputStream(gzInput);
  32                         File tofile = new File(toFile);
  33                         enable(tofile);
  34                         fileOutput = new FileOutputStream(tofile, false);
  35
  36                         moveBytes(gzIn, fileOutput, -1, -1, 1024);
  37                 } finally {
  38                         if (gzIn != null) {
  39                                 gzIn.close();
  40                         }
  41                         if (fileOutput != null) {
  42                                 fileOutput.close();
  43                         }
  44
  45                 }
  46
  47         }
  48
  49         private void enable(File tofile) throws IOException {
  50                 if (!tofile.exists()) {
  51                         String parentPath = tofile.getParent();
  52                         if (parentPath != null)
  53                                 new File(parentPath).mkdirs();
  54                         tofile.createNewFile();
  55                 }
  56         }
  57
  58         public long moveBytes(InputStream input, OutputStream output, long off, long len, int bufsize) throws IOException {
  59                 long skipped=0;
  60                 if (off > 0)
  61                         skipped = input.skip(off); // check if skipped is same as off
  62
  63                 long totalNum = 0;
  64                 byte[] buf = new byte[bufsize];
  65
  66                 while (true) {
  67                         if (len > 0 && (len - totalNum) <= 0)
  68                                 break;
  69
  70                         else if (len > 0 && bufsize > (len - totalNum))
  71                                 bufsize = (int) (len - totalNum);
  72
  73                         int readNum = input.read(buf, 0, bufsize);
  74                         if (readNum <= 0)
  75                                 break;
  76
  77                         output.write(buf, 0, readNum);
  78                         totalNum += readNum;
  79                 }
  80                 buf = null;
  81                 return totalNum;
  82         }
  83
  84 }