Create filestore directory on startup

James Moger

2015-11-19 e41e8f8c3bc9f5edab1d271464364f95620ece8c

 src/main/java/com/gitblit/utils/CompressionUtils.java

@@ -15,6 +15,7 @@
 */

package com.gitblit.utils;



import java.io.ByteArrayOutputStream;

import java.io.IOException;

import java.io.OutputStream;

import java.text.MessageFormat;

@@ -27,7 +28,6 @@
import org.apache.commons.compress.archivers.zip.ZipArchiveOutputStream;

import org.apache.commons.compress.compressors.CompressorException;

import org.apache.commons.compress.compressors.CompressorStreamFactory;

import org.apache.wicket.util.io.ByteArrayOutputStream;

import org.eclipse.jgit.lib.Constants;

import org.eclipse.jgit.lib.FileMode;

import org.eclipse.jgit.lib.MutableObjectId;

@@ -43,9 +43,9 @@


/**

 * Collection of static methods for retrieving information from a repository.

 * 
 *

 * @author James Moger

 * 
 *

 */

public class CompressionUtils {



@@ -53,7 +53,7 @@


   /**

    * Log an error message and exception.

    * 
    *

    * @param t

    * @param repository

    *            if repository is not null it MUST be the {0} parameter in the

@@ -77,7 +77,7 @@
   /**

    * Zips the contents of the tree at the (optionally) specified revision and

    * the (optionally) specified basepath to the supplied outputstream.

    * 
    *

    * @param repository

    * @param basePath

    *            if unspecified, entire repository is assumed.

@@ -132,16 +132,16 @@
      } catch (IOException e) {

         error(e, repository, "{0} failed to zip files from commit {1}", commit.getName());

      } finally {

         tw.release();

         tw.close();

         rw.dispose();

      }

      return success;

   }

	


   /**

    * tar the contents of the tree at the (optionally) specified revision and

    * the (optionally) specified basepath to the supplied outputstream.

    * 
    *

    * @param repository

    * @param basePath

    *            if unspecified, entire repository is assumed.

@@ -155,11 +155,11 @@
         OutputStream os) {

      return tar(null, repository, basePath, objectId, os);

   }

	


   /**

    * tar.gz the contents of the tree at the (optionally) specified revision and

    * the (optionally) specified basepath to the supplied outputstream.

    * 
    *

    * @param repository

    * @param basePath

    *            if unspecified, entire repository is assumed.

@@ -173,11 +173,11 @@
         OutputStream os) {

      return tar(CompressorStreamFactory.GZIP, repository, basePath, objectId, os);

   }

	


   /**

    * tar.xz the contents of the tree at the (optionally) specified revision and

    * the (optionally) specified basepath to the supplied outputstream.

    * 
    *

    * @param repository

    * @param basePath

    *            if unspecified, entire repository is assumed.

@@ -191,11 +191,11 @@
         OutputStream os) {

      return tar(CompressorStreamFactory.XZ, repository, basePath, objectId, os);

   }

	


   /**

    * tar.bzip2 the contents of the tree at the (optionally) specified revision and

    * the (optionally) specified basepath to the supplied outputstream.

    * 
    *

    * @param repository

    * @param basePath

    *            if unspecified, entire repository is assumed.

@@ -207,15 +207,15 @@
    */

   public static boolean bzip2(Repository repository, String basePath, String objectId,

         OutputStream os) {

		


      return tar(CompressorStreamFactory.BZIP2, repository, basePath, objectId, os);

   }

	


   /**

    * Compresses/archives the contents of the tree at the (optionally)

    * specified revision and the (optionally) specified basepath to the

    * supplied outputstream.

    * 
    *

    * @param algorithm

    *            compression algorithm for tar (optional)

    * @param repository

@@ -233,7 +233,7 @@
      if (commit == null) {

         return false;

      }

		


      OutputStream cos = os;

      if (!StringUtils.isEmpty(algorithm)) {

         try {

@@ -264,7 +264,7 @@
               continue;

            }

            tw.getObjectId(id, 0);

				


            ObjectLoader loader = repository.open(id);

            if (FileMode.SYMLINK == mode) {

               TarArchiveEntry entry = new TarArchiveEntry(tw.getPathString(),TarArchiveEntry.LF_SYMLINK);

@@ -279,7 +279,7 @@
               entry.setMode(mode.getBits());

               entry.setModTime(modified);

               entry.setSize(loader.getSize());

               tos.putArchiveEntry(entry);					
               tos.putArchiveEntry(entry);

               loader.copyTo(tos);

               tos.closeArchiveEntry();

            }

@@ -291,7 +291,7 @@
      } catch (IOException e) {

         error(e, repository, "{0} failed to {1} stream files from commit {2}", algorithm, commit.getName());

      } finally {

         tw.release();

         tw.close();

         rw.dispose();

      }

      return success;