[jboss-cvs] JBoss Messaging SVN: r7182 - trunk/src/main/org/jboss/messaging/core/asyncio/impl.

[jboss-cvs-commits at lists.jboss.org]

Author: timfox
Date: 2009-06-03 10:09:02 -0400 (Wed, 03 Jun 2009)
New Revision: 7182

Modified:
   trunk/src/main/org/jboss/messaging/core/asyncio/impl/TimedBuffer.java
Log:
more aio stuff

Modified: trunk/src/main/org/jboss/messaging/core/asyncio/impl/TimedBuffer.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/asyncio/impl/TimedBuffer.java	2009-06-03 14:06:16 UTC (rev 7181)
+++ trunk/src/main/org/jboss/messaging/core/asyncio/impl/TimedBuffer.java	2009-06-03 14:09:02 UTC (rev 7182)
@@ -102,8 +102,6 @@
       timerThread.start();
       
       started = true;
-      
-      log.info("started timed buffer");
    }
 
    public synchronized void stop()
@@ -127,8 +125,6 @@
       }
       
       started = false;
-      
-      log.info("stopped timedbuffer");
    }
 
    public void lock()
@@ -238,8 +234,7 @@
       {
          lock.lock();
          try
-         {
-            // log.info("** flushing because of timer");
+         {            
             flush();
          }
          finally
@@ -255,25 +250,14 @@
    {
       private volatile boolean closed = false;
 
-      private TokenBucketLimiter limiter = new TokenBucketLimiterImpl(4000, false);
-
       public void run()
       {
          while (!closed)
-         {
-            // log.info(System.identityHashCode(this) + " firing");
+         {            
             checkTimer();
 
-            // try
-            // {
-            // Thread.sleep(1);
-            // }
-            // catch (InterruptedException ignore)
-            // {
-            // }
-
-            // limiter.limit();
-
+            //TODO - this yield is temporary
+            
             Thread.yield();
          }
       }