org.apache.storm.daemon

Class DirectoryCleaner

java.lang.Object

org.apache.storm.daemon.DirectoryCleaner

public class DirectoryCleaner
extends Object

Provide methods to help Logviewer to clean up files in directories and to get a list of files without worrying about excessive memory usage.

Constructor Summary

Constructors

Constructor and Description
DirectoryCleaner()

Method Summary

Modifier and Type	Method and Description
int	deleteOldestWhileTooLarge(List<File> dirs, long quota, boolean for_per_dir, Set<String> active_dirs) If totalSize of files exceeds the either the per-worker quota or global quota, Logviewer deletes oldest inactive log files in a worker directory or in all worker dirs.
static List<File>	getFilesForDir(File dir)
DirectoryStream<Path>	getStreamForDirectory(File dir)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DirectoryCleaner

public DirectoryCleaner()

Method Detail

getStreamForDirectory

public DirectoryStream<Path> getStreamForDirectory(File dir)
                                            throws IOException

Throws:

IOException

deleteOldestWhileTooLarge

public int deleteOldestWhileTooLarge(List<File> dirs,
                                     long quota,
                                     boolean for_per_dir,
                                     Set<String> active_dirs)
                              throws IOException

If totalSize of files exceeds the either the per-worker quota or global quota, Logviewer deletes oldest inactive log files in a worker directory or in all worker dirs. We use the parameter for_per_dir to switch between the two deletion modes.

Parameters:

dirs - the list of directories to be scanned for deletion

quota - the per-dir quota or the total quota for the all directories

for_per_dir - if true, deletion happens for a single dir; otherwise, for all directories globally

active_dirs - only for global deletion, we want to skip the active logs in active_dirs

Returns:

number of files deleted

Throws:

IOException

getFilesForDir

public static List<File> getFilesForDir(File dir)
                                 throws IOException

Throws:

IOException