Author: gtully Date: Thu Feb 5 21:15:13 2009 New Revision: 741293 URL: http://svn.apache.org/viewvc?rev=741293&view=rev Log: add a little more info to flush
Modified: activemq/trunk/kahadb/src/main/java/org/apache/kahadb/page/PageFile.java Modified: activemq/trunk/kahadb/src/main/java/org/apache/kahadb/page/PageFile.java URL: http://svn.apache.org/viewvc/activemq/trunk/kahadb/src/main/java/org/apache/kahadb/page/PageFile.java?rev=741293&r1=741292&r2=741293&view=diff ============================================================================== --- activemq/trunk/kahadb/src/main/java/org/apache/kahadb/page/PageFile.java (original) +++ activemq/trunk/kahadb/src/main/java/org/apache/kahadb/page/PageFile.java Thu Feb 5 21:15:13 2009 @@ -444,7 +444,13 @@ } } try { + int size = writes.size(); + long start = System.currentTimeMillis(); checkpointLatch.await(); + long end = System.currentTimeMillis(); + if( end-start > 100 ) { + LOG.warn("KahaDB PageFile flush: " + size + " queued writes, latch wait took "+(end-start)); + } } catch (InterruptedException e) { throw new InterruptedIOException(); }