jakarta-jcs-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From asm...@apache.org
Subject cvs commit: jakarta-turbine-jcs/src/java/org/apache/jcs/engine CacheEventQueue.java
Date Fri, 16 Jul 2004 01:29:20 GMT
asmuts      2004/07/15 18:29:20

  Modified:    src/java/org/apache/jcs/engine CacheEventQueue.java
  Log:
  logging on recreation
  
  Revision  Changes    Path
  1.11      +36 -1     jakarta-turbine-jcs/src/java/org/apache/jcs/engine/CacheEventQueue.java
  
  Index: CacheEventQueue.java
  ===================================================================
  RCS file: /home/cvs/jakarta-turbine-jcs/src/java/org/apache/jcs/engine/CacheEventQueue.java,v
  retrieving revision 1.10
  retrieving revision 1.11
  diff -u -r1.10 -r1.11
  --- CacheEventQueue.java	12 Jun 2004 02:34:13 -0000	1.10
  +++ CacheEventQueue.java	16 Jul 2004 01:29:20 -0000	1.11
  @@ -46,7 +46,7 @@
     // time to wait for an event before snuffing the background thread
     // if the queue is empty.
     // make configurable later
  -  private int waitToDieMillis = 60000;
  +  private int waitToDieMillis = 10000;
   
     private ICacheListener listener;
     private long listenerId;
  @@ -305,6 +305,7 @@
             destroyed = false;
             processorThread = new QProcessor( this );
             processorThread.start();
  +          log.info( "Cache event queue created: " + this );
           }
           else
           {
  @@ -347,6 +348,40 @@
         return value;
       }
     }
  +
  +
  +  public String getStats()
  +  {
  +    StringBuffer buf = new StringBuffer();
  +    buf.append( "\n -------------------------" );
  +    buf.append( "\n Cache Event Queue:" );
  +    buf.append( "\n working = " + this.working );
  +    buf.append( "\n isAlive() = " + this.isAlive() );
  +    buf.append( "\n isEmpty() = " + this.isEmpty() );
  +
  +    int size = 0;
  +    synchronized (queueLock)
  +    {
  +      // wait until there is something to read
  +      if (head == tail)
  +      {
  +        size = 0;
  +      }
  +      else
  +      {
  +          Node n = head;
  +          while ( n != null )
  +          {
  +            n = n.next;
  +            size++;
  +          }
  +      }
  +
  +      buf.append( "\n size = " + size );
  +    }
  +    return buf.toString();
  +  }
  +
   
     ///////////////////////////// Inner classes /////////////////////////////
   
  
  
  

---------------------------------------------------------------------
To unsubscribe, e-mail: turbine-jcs-dev-unsubscribe@jakarta.apache.org
For additional commands, e-mail: turbine-jcs-dev-help@jakarta.apache.org


Mime
View raw message