* @return the number of cleaned items
*/
public int clean(boolean onlyOld) {
- return clean(onlyOld, dir);
+ long ms = System.currentTimeMillis();
+
+ tracer.trace("Cleaning cache from old files...");
+
+ int num = clean(onlyOld, dir, -1);
+
+ tracer.trace(num + "cache items cleaned in "
+ + (System.currentTimeMillis() - ms) + " ms");
+
+ return num;
}
/**
* resources
* @param cacheDir
* the cache directory to clean
+ * @param limit
+ * stop after limit files deleted, or -1 for unlimited
*
* @return the number of cleaned items
*/
- private int clean(boolean onlyOld, File cacheDir) {
+ private int clean(boolean onlyOld, File cacheDir, int limit) {
int num = 0;
File[] files = cacheDir.listFiles();
if (files != null) {
for (File file : files) {
+ if (limit >= 0 && num >= limit) {
+ return num;
+ }
+
if (file.isDirectory()) {
- num += clean(onlyOld, file);
+ num += clean(onlyOld, file, limit);
+ file.delete(); // only if empty
} else {
if (!onlyOld || isOld(file, true)) {
if (file.delete()) {
* @param allowTooOld
* allow files even if they are considered too old
* @param stable
- * a stable file (that dones't change too often) -- parameter
- * used to check if the file is too old to keep or not
+ * a stable file (that doesn't change too often) -- parameter
+ * used to check if the file is too old to keep or not in the
+ * cache
*
* @return the opened resource if found, NULL if not
*/
/**
* Save the given resource to the cache.
+ * <p>
+ * Will also clean the {@link Cache} from old files.
*
* @param in
* the input data
* in case of I/O error
*/
private void save(InputStream in, File cached) throws IOException {
+ // We delete AFTER so not to remove the subdir we will use...
IOUtils.write(in, cached);
+ clean(true, dir, 10);
}
/**