You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by gt...@apache.org on 2009/02/05 22:15:14 UTC
svn commit: r741293 -
/activemq/trunk/kahadb/src/main/java/org/apache/kahadb/page/PageFile.java
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();
}