You are viewing a plain text version of this content. The canonical link for it is here.
Posted to oak-commits@jackrabbit.apache.org by md...@apache.org on 2015/07/07 16:15:15 UTC
svn commit: r1689685 -
/jackrabbit/oak/trunk/oak-core/src/test/java/org/apache/jackrabbit/oak/plugins/segment/SegmentCompactionIT.java
Author: mduerig
Date: Tue Jul 7 14:15:15 2015
New Revision: 1689685
URL: http://svn.apache.org/r1689685
Log:
OAK-2849: Improve revision gc on SegmentMK
SegmentCompactionIT improvement: configurable core pool size and expose via MBean
Modified:
jackrabbit/oak/trunk/oak-core/src/test/java/org/apache/jackrabbit/oak/plugins/segment/SegmentCompactionIT.java
Modified: jackrabbit/oak/trunk/oak-core/src/test/java/org/apache/jackrabbit/oak/plugins/segment/SegmentCompactionIT.java
URL: http://svn.apache.org/viewvc/jackrabbit/oak/trunk/oak-core/src/test/java/org/apache/jackrabbit/oak/plugins/segment/SegmentCompactionIT.java?rev=1689685&r1=1689684&r2=1689685&view=diff
==============================================================================
--- jackrabbit/oak/trunk/oak-core/src/test/java/org/apache/jackrabbit/oak/plugins/segment/SegmentCompactionIT.java (original)
+++ jackrabbit/oak/trunk/oak-core/src/test/java/org/apache/jackrabbit/oak/plugins/segment/SegmentCompactionIT.java Tue Jul 7 14:15:15 2015
@@ -53,7 +53,6 @@ import java.util.Set;
import java.util.concurrent.Callable;
import java.util.concurrent.CancellationException;
import java.util.concurrent.ScheduledThreadPoolExecutor;
-import java.util.concurrent.TimeUnit;
import javax.annotation.Nonnull;
import javax.management.InstanceAlreadyExistsException;
@@ -271,12 +270,12 @@ public class SegmentCompactionIT {
}
private void scheduleSizeMonitor() {
- scheduler.schedule(new Runnable() {
+ scheduler.scheduleAtFixedRate(new Runnable() {
@Override
public void run() {
fileStoreSize = fileStore.size();
}
- }, 1, TimeUnit.MINUTES);
+ }, 1, 1, MINUTES);
}
private synchronized void scheduleCompactor() {