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() {
