Coverage Report

 /*
  * 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.
  */
 
 package org.apache.giraph.utils;
 
 import com.google.common.base.Charsets;
 import com.google.common.io.Closeables;
 import com.google.common.io.Files;
 import org.apache.hadoop.conf.Configuration;
 import org.apache.hadoop.fs.FileSystem;
 import org.apache.hadoop.fs.Path;
 
 import java.io.File;
 import java.io.FileFilter;
 import java.io.IOException;
 import java.io.Writer;
 
 /**
  * Helper class for filesystem operations during testing
  */
 public class FileUtils {
 
   /**
    * Utility class should not be instantiatable
    */
   private FileUtils() {
   }
 
   /**
    * Create a temporary folder that will be removed after the test.
    *
    * @param vertexClass Used for generating the folder name.
    * @return File object for the directory.
    */
   public static File createTestDir(Class<?> vertexClass)
     throws IOException {
     String systemTmpDir = System.getProperty("java.io.tmpdir");
     long simpleRandomLong = (long) (Long.MAX_VALUE * Math.random());
     File testTempDir = new File(systemTmpDir, "giraph-" +
         vertexClass.getSimpleName() + '-' + simpleRandomLong);
     if (!testTempDir.mkdir()) {
       throw new IOException("Could not create " + testTempDir);
     }
     testTempDir.deleteOnExit();
     return testTempDir;
   }
 
   /**
    * Make a temporary file.
    *
    * @param parent Parent directory.
    * @param name File name.
    * @return File object to temporary file.
    * @throws IOException
    */
   public static File createTempFile(File parent, String name)
     throws IOException {
     return createTestTempFileOrDir(parent, name, false);
   }
 
   /**
    * Make a temporary directory.
    *
    * @param parent Parent directory.
    * @param name Directory name.
    * @return File object to temporary file.
    * @throws IOException
    */
   public static File createTempDir(File parent, String name)
     throws IOException {
     File dir = createTestTempFileOrDir(parent, name, true);
     dir.delete();
     return dir;
   }
 
   /**
    * Create a test temp file or directory.
    *
    * @param parent Parent directory
    * @param name Name of file
    * @param dir Is directory?
    * @return File object
    * @throws IOException
    */
   public static File createTestTempFileOrDir(File parent, String name,
     boolean dir) throws IOException {
     File f = new File(parent, name);
     f.deleteOnExit();
     if (dir && !f.mkdirs()) {
       throw new IOException("Could not make directory " + f);
     }
     return f;
   }
 
   /**
    * Write lines to a file.
    *
    * @param file File to write lines to
    * @param lines Strings written to the file
    * @throws IOException
    */
   public static void writeLines(File file, String... lines)
     throws IOException {
     Writer writer = Files.newWriter(file, Charsets.UTF_8);
     try {
       for (String line : lines) {
         writer.write(line);
         writer.write('\n');
       }
     } finally {
       Closeables.closeQuietly(writer);
     }
   }
 
   /**
    * Recursively delete a directory
    *
    * @param dir Directory to delete
    */
   public static void delete(File dir) {
     if (dir != null) {
       new DeletingVisitor().accept(dir);
     }
   }
 
   /**
    * Deletes files.
    */
   private static class DeletingVisitor implements FileFilter {
     @Override
     public boolean accept(File f) {
       if (!f.isFile()) {
         f.listFiles(this);
       }
       f.delete();
       return false;
     }
   }
 
   /**
    * Helper method to remove a path if it exists.
    *
    * @param conf Configuration to load FileSystem from
    * @param path Path to remove
    * @throws IOException
    */
   public static void deletePath(Configuration conf, String path)
     throws IOException {
     deletePath(conf, new Path(path));
   }
 
   /**
    * Helper method to remove a path if it exists.
    *
    * @param conf Configuration to load FileSystem from
    * @param path Path to remove
    * @throws IOException
    */
   public static void deletePath(Configuration conf, Path path)
     throws IOException {
     FileSystem fs = FileSystem.get(conf);
     fs.delete(path, true);
   }
 }

1		/*
2		* Licensed to the Apache Software Foundation (ASF) under one
3		* or more contributor license agreements. See the NOTICE file
4		* distributed with this work for additional information
5		* regarding copyright ownership. The ASF licenses this file
6		* to you under the Apache License, Version 2.0 (the
7		* "License"); you may not use this file except in compliance
8		* with the License. You may obtain a copy of the License at
9		*
10		* http://www.apache.org/licenses/LICENSE-2.0
11		*
12		* Unless required by applicable law or agreed to in writing, software
13		* distributed under the License is distributed on an "AS IS" BASIS,
14		* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
15		* See the License for the specific language governing permissions and
16		* limitations under the License.
17		*/
18
19		package org.apache.giraph.utils;
20
21		import com.google.common.base.Charsets;
22		import com.google.common.io.Closeables;
23		import com.google.common.io.Files;
24		import org.apache.hadoop.conf.Configuration;
25		import org.apache.hadoop.fs.FileSystem;
26		import org.apache.hadoop.fs.Path;
27
28		import java.io.File;
29		import java.io.FileFilter;
30		import java.io.IOException;
31		import java.io.Writer;
32
33		/**
34		* Helper class for filesystem operations during testing
35		*/
36		public class FileUtils {
37
38		/**
39		* Utility class should not be instantiatable
40		*/
41	0	private FileUtils() {
42	0	}
43
44		/**
45		* Create a temporary folder that will be removed after the test.
46		*
47		* @param vertexClass Used for generating the folder name.
48		* @return File object for the directory.
49		*/
50		public static File createTestDir(Class<?> vertexClass)
51		throws IOException {
52	3	String systemTmpDir = System.getProperty("java.io.tmpdir");
53	3	long simpleRandomLong = (long) (Long.MAX_VALUE * Math.random());
54	3	File testTempDir = new File(systemTmpDir, "giraph-" +
55		vertexClass.getSimpleName() + '-' + simpleRandomLong);
56	3	if (!testTempDir.mkdir()) {
57	0	throw new IOException("Could not create " + testTempDir);
58		}
59	3	testTempDir.deleteOnExit();
60	3	return testTempDir;
61		}
62
63		/**
64		* Make a temporary file.
65		*
66		* @param parent Parent directory.
67		* @param name File name.
68		* @return File object to temporary file.
69		* @throws IOException
70		*/
71		public static File createTempFile(File parent, String name)
72		throws IOException {
73	3	return createTestTempFileOrDir(parent, name, false);
74		}
75
76		/**
77		* Make a temporary directory.
78		*
79		* @param parent Parent directory.
80		* @param name Directory name.
81		* @return File object to temporary file.
82		* @throws IOException
83		*/
84		public static File createTempDir(File parent, String name)
85		throws IOException {
86	12	File dir = createTestTempFileOrDir(parent, name, true);
87	12	dir.delete();
88	12	return dir;
89		}
90
91		/**
92		* Create a test temp file or directory.
93		*
94		* @param parent Parent directory
95		* @param name Name of file
96		* @param dir Is directory?
97		* @return File object
98		* @throws IOException
99		*/
100		public static File createTestTempFileOrDir(File parent, String name,
101		boolean dir) throws IOException {
102	15	File f = new File(parent, name);
103	15	f.deleteOnExit();
104	15	if (dir && !f.mkdirs()) {
105	0	throw new IOException("Could not make directory " + f);
106		}
107	15	return f;
108		}
109
110		/**
111		* Write lines to a file.
112		*
113		* @param file File to write lines to
114		* @param lines Strings written to the file
115		* @throws IOException
116		*/
117		public static void writeLines(File file, String... lines)
118		throws IOException {
119	3	Writer writer = Files.newWriter(file, Charsets.UTF_8);
120		try {
121	33	for (String line : lines) {
122	30	writer.write(line);
123	30	writer.write('\n');
124		}
125		} finally {
126	3	Closeables.closeQuietly(writer);
127	3	}
128	3	}
129
130		/**
131		* Recursively delete a directory
132		*
133		* @param dir Directory to delete
134		*/
135		public static void delete(File dir) {
136	3	if (dir != null) {
137	3	new DeletingVisitor().accept(dir);
138		}
139	3	}
140
141		/**
142		* Deletes files.
143		*/
144	6	private static class DeletingVisitor implements FileFilter {
145		@Override
146		public boolean accept(File f) {
147	33	if (!f.isFile()) {
148	12	f.listFiles(this);
149		}
150	33	f.delete();
151	33	return false;
152		}
153		}
154
155		/**
156		* Helper method to remove a path if it exists.
157		*
158		* @param conf Configuration to load FileSystem from
159		* @param path Path to remove
160		* @throws IOException
161		*/
162		public static void deletePath(Configuration conf, String path)
163		throws IOException {
164	0	deletePath(conf, new Path(path));
165	0	}
166
167		/**
168		* Helper method to remove a path if it exists.
169		*
170		* @param conf Configuration to load FileSystem from
171		* @param path Path to remove
172		* @throws IOException
173		*/
174		public static void deletePath(Configuration conf, Path path)
175		throws IOException {
176	120	FileSystem fs = FileSystem.get(conf);
177	120	fs.delete(path, true);
178	120	}
179		}