[jbosscache-commits] JBoss Cache SVN: r7883 - core/branches/flat/src/main/java/org/horizon/loader/file.

[jbosscache-commits at lists.jboss.org]

Author: adriancole
Date: 2009-03-08 17:02:07 -0400 (Sun, 08 Mar 2009)
New Revision: 7883

Modified:
   core/branches/flat/src/main/java/org/horizon/loader/file/FileCacheStore.java
Log:
modified to allow for extension

Modified: core/branches/flat/src/main/java/org/horizon/loader/file/FileCacheStore.java
===================================================================
--- core/branches/flat/src/main/java/org/horizon/loader/file/FileCacheStore.java	2009-03-08 21:01:16 UTC (rev 7882)
+++ core/branches/flat/src/main/java/org/horizon/loader/file/FileCacheStore.java	2009-03-08 21:02:07 UTC (rev 7883)
@@ -33,6 +33,13 @@
    Marshaller marshaller;
    File root;
 
+   /**
+    * @return root directory where all files for this {@link org.horizon.loader.CacheStore CacheStore} are written.
+    */
+   public File getRoot() {
+      return root;
+   }
+
    public void init(CacheLoaderConfig config, Cache cache, Marshaller m) {
       super.init(config, cache, m);
       this.config = (FileCacheStoreConfig) config;
@@ -43,7 +50,6 @@
    protected Set<StoredEntry> loadAllLockSafe() throws CacheLoaderException {
       Set<StoredEntry> result = new HashSet<StoredEntry>();
       for (File bucketFile : root.listFiles()) {
-         String bucketName = bucketFile.getName();
          Bucket bucket = loadBucket(bucketFile);
          if (bucket != null) {
             if (bucket.removeExpiredEntries()) {
@@ -155,7 +161,7 @@
       saveBucket(bucket);
    }
 
-   public final void saveBucket(Bucket b) throws CacheLoaderException {
+   public void saveBucket(Bucket b) throws CacheLoaderException {
       File f = new File(root, b.getBucketName());
       if (f.exists()) {
          if (!f.delete()) log.warn("Had problems removing file {0}", f);