activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r961186 - /activemq/sandbox/activemq-apollo-actor/activemq-hawtdb/src/main/scala/org/apache/activemq/broker/store/hawtdb/HawtDBClient.scala
Date Wed, 07 Jul 2010 04:14:56 GMT
Author: chirino
Date: Wed Jul  7 04:14:56 2010
New Revision: 961186

URL: http://svn.apache.org/viewvc?rev=961186&view=rev
Log:
enable the periodic flush

Modified:
    activemq/sandbox/activemq-apollo-actor/activemq-hawtdb/src/main/scala/org/apache/activemq/broker/store/hawtdb/HawtDBClient.scala

Modified: activemq/sandbox/activemq-apollo-actor/activemq-hawtdb/src/main/scala/org/apache/activemq/broker/store/hawtdb/HawtDBClient.scala
URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/activemq-hawtdb/src/main/scala/org/apache/activemq/broker/store/hawtdb/HawtDBClient.scala?rev=961186&r1=961185&r2=961186&view=diff
==============================================================================
--- activemq/sandbox/activemq-apollo-actor/activemq-hawtdb/src/main/scala/org/apache/activemq/broker/store/hawtdb/HawtDBClient.scala
(original)
+++ activemq/sandbox/activemq-apollo-actor/activemq-hawtdb/src/main/scala/org/apache/activemq/broker/store/hawtdb/HawtDBClient.scala
Wed Jul  7 04:14:56 2010
@@ -145,7 +145,7 @@ class HawtDBClient(hawtDBStore: HawtDBSt
     }
   }
 
-  val schedual_version = new AtomicInteger()
+  val schedule_version = new AtomicInteger()
 
   def start(onComplete:Runnable) = {
     lock {
@@ -215,14 +215,14 @@ class HawtDBClient(hawtDBStore: HawtDBSt
 
       recover(onComplete)
 
-      // Schedual periodic jobs.. they keep executing while schedual_version remains the
same.
-      schedualCleanup(schedual_version.get())
-      // schedualFlush(schedual_version.get())
+      // Schedule periodic jobs.. they keep executing while schedule_version remains the
same.
+      scheduleCleanup(schedule_version.get())
+      scheduleFlush(schedule_version.get())
     }
   }
 
   def stop() = {
-    schedual_version.incrementAndGet
+    schedule_version.incrementAndGet
     journal.close
     pageFileFactory.close
     lockFile.unlock
@@ -936,12 +936,12 @@ class HawtDBClient(hawtDBStore: HawtDBSt
   //
   /////////////////////////////////////////////////////////////////////
 
-  def schedualFlush(version:Int): Unit = {
+  def scheduleFlush(version:Int): Unit = {
     def try_flush() = {
-      if (version == schedual_version.get) {
+      if (version == schedule_version.get) {
         hawtDBStore.executor_pool {
           flush
-          schedualFlush(version)
+          scheduleFlush(version)
         }
       }
     }
@@ -957,14 +957,14 @@ class HawtDBClient(hawtDBStore: HawtDBSt
     }
   }
 
-  def schedualCleanup(version:Int): Unit = {
+  def scheduleCleanup(version:Int): Unit = {
     def try_cleanup() = {
-      if (version == schedual_version.get) {
+      if (version == schedule_version.get) {
         hawtDBStore.executor_pool {
           withTx {tx =>
             cleanup(tx)
           }
-          schedualCleanup(version)
+          scheduleCleanup(version)
         }
       }
     }



Mime
View raw message