svn commit: r771927 - in /incubator/cassandra/trunk/src/java/org/apache/cassandra/db: ColumnFamilyStore.java ColumnFamilyStoreMBean.java

[jbellis]

Author: jbellis
Date: Tue May  5 16:56:55 2009
New Revision: 771927

URL: http://svn.apache.org/viewvc?rev=771927&view=rev
Log:
This patch adds ColumnFamilyStore.forceflush to the mbean so that it can be 
activated through the management agent.  patch by Eric Evans; reviewed by 
jbellis for CASSANDRA-34

Modified:
    
incubator/cassandra/trunk/src/java/org/apache/cassandra/db/ColumnFamilyStore.java
    
incubator/cassandra/trunk/src/java/org/apache/cassandra/db/ColumnFamilyStoreMBean.java

Modified: 
incubator/cassandra/trunk/src/java/org/apache/cassandra/db/ColumnFamilyStore.java
URL: 
http://svn.apache.org/viewvc/incubator/cassandra/trunk/src/java/org/apache/cassandra/db/ColumnFamilyStore.java?rev=771927&r1=771926&r2=771927&view=diff
==============================================================================
--- 
incubator/cassandra/trunk/src/java/org/apache/cassandra/db/ColumnFamilyStore.java
 (original)
+++ 
incubator/cassandra/trunk/src/java/org/apache/cassandra/db/ColumnFamilyStore.java
 Tue May  5 16:56:55 2009
@@ -425,7 +425,7 @@
         binaryMemtable_.get().put(key, buffer);
     }
 
-    void forceFlush() throws IOException
+    public void forceFlush()
     {
         memtable_.get().forceflush();
     }

Modified: 
incubator/cassandra/trunk/src/java/org/apache/cassandra/db/ColumnFamilyStoreMBean.java
URL: 
http://svn.apache.org/viewvc/incubator/cassandra/trunk/src/java/org/apache/cassandra/db/ColumnFamilyStoreMBean.java?rev=771927&r1=771926&r2=771927&view=diff
==============================================================================
--- 
incubator/cassandra/trunk/src/java/org/apache/cassandra/db/ColumnFamilyStoreMBean.java
 (original)
+++ 
incubator/cassandra/trunk/src/java/org/apache/cassandra/db/ColumnFamilyStoreMBean.java
 Tue May  5 16:56:55 2009
@@ -53,4 +53,9 @@
      * @return the number of tasks waiting to run on the memtable executor
      */
     public int getMemtableTasks();
+    
+    /**
+     * Triggers an immediate memtable flush.
+     */
+    public void forceFlush();
 }