mirror of https://github.com/apache/activemq.git
add a little more info to flush
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@741293 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
8262ef7903
commit
f0af62f64d
|
@ -444,7 +444,13 @@ public class PageFile {
|
|||
}
|
||||
}
|
||||
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();
|
||||
}
|
||||
|
|
Loading…
Reference in New Issue