Author: jbellis
Date: Thu Aug 11 19:43:13 2011
New Revision: 1156772

URL: http://svn.apache.org/viewvc?rev=1156772&view=rev
Log:
cache invalidate removes saved cache files
patch by Ed Capriolo; reviewed by jbellis for CASSANDRA-2325

Modified:
    cassandra/branches/cassandra-0.8/CHANGES.txt
    
cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/db/ColumnFamilyStore.java

Modified: cassandra/branches/cassandra-0.8/CHANGES.txt
URL: 
http://svn.apache.org/viewvc/cassandra/branches/cassandra-0.8/CHANGES.txt?rev=1156772&r1=1156771&r2=1156772&view=diff
==============================================================================
--- cassandra/branches/cassandra-0.8/CHANGES.txt (original)
+++ cassandra/branches/cassandra-0.8/CHANGES.txt Thu Aug 11 19:43:13 2011
@@ -3,6 +3,7 @@
  * include column name in validation failure exceptions (CASSANDRA-2849)
  * make sure truncate clears out the commitlog so replay won't re-
    populate with truncated data (CASSANDRA-2950)
+ * cache invalidate removes saved cache files (CASSANDRA-2325)
 
 
 0.8.4

Modified: 
cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/db/ColumnFamilyStore.java
URL: 
http://svn.apache.org/viewvc/cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/db/ColumnFamilyStore.java?rev=1156772&r1=1156771&r2=1156772&view=diff
==============================================================================
--- 
cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/db/ColumnFamilyStore.java
 (original)
+++ 
cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/db/ColumnFamilyStore.java
 Thu Aug 11 19:43:13 2011
@@ -1767,11 +1767,15 @@ public class ColumnFamilyStore implement
     public void invalidateRowCache()
     {
         rowCache.clear();
+        if (rowCache.getCachePath().exists())
+            rowCache.getCachePath().delete();
     }
 
     public void invalidateKeyCache()
     {
         keyCache.clear();
+        if (keyCache.getCachePath().exists())
+            keyCache.getCachePath().delete();
     }
 
     public int getRowCacheCapacity()


Reply via email to