SLING-5547 Update sling-mock-oak to Sling API 2.11 and Oak 1.3.15
git-svn-id: https://svn.apache.org/repos/asf/sling/trunk/testing/mocks/sling-mock-oak@1731778 13f79535-47bb-0310-9956-ffa450edef68
diff --git a/src/main/java/org/apache/sling/testing/mock/sling/oak/OakMockSlingRepository.java b/src/main/java/org/apache/sling/testing/mock/sling/oak/OakMockSlingRepository.java
index cd6133a..45f7094 100644
--- a/src/main/java/org/apache/sling/testing/mock/sling/oak/OakMockSlingRepository.java
+++ b/src/main/java/org/apache/sling/testing/mock/sling/oak/OakMockSlingRepository.java
@@ -18,6 +18,7 @@
*/
package org.apache.sling.testing.mock.sling.oak;
+import java.lang.reflect.Field;
import java.util.concurrent.Executor;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
@@ -42,6 +43,8 @@
import org.apache.sling.jcr.api.SlingRepository;
import org.osgi.framework.BundleContext;
import org.osgi.service.component.ComponentContext;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
@Component
@Service(SlingRepository.class)
@@ -54,6 +57,8 @@
private ExecutorService executor;
private ScheduledExecutorService scheduledExecutor;
+ private static final Logger log = LoggerFactory.getLogger(OakMockSlingRepository.class);
+
@Activate
protected void activate(BundleContext bundleContext) {
executor = Executors.newSingleThreadExecutor();
@@ -77,12 +82,26 @@
@Deactivate
protected void deactivate(ComponentContext componentContext) {
- // shutdown OAK JCR repository
- ((JackrabbitRepository)repository).shutdown();
-
// shutdown executors
+ // force immediate shutdown for all executors without waiting for tasks for completion - we're only in unit tests!
executor.shutdownNow();
scheduledExecutor.shutdownNow();
+ shutdownExecutorService(repository, "scheduledExecutor");
+
+ // shutdown OAK JCR repository
+ ((JackrabbitRepository)repository).shutdown();
+ }
+
+ private void shutdownExecutorService(Object instance, String fieldName) {
+ try {
+ Field executorField = instance.getClass().getDeclaredField(fieldName);
+ executorField.setAccessible(true);
+ ExecutorService executor = (ExecutorService)executorField.get(instance);
+ executor.shutdownNow();
+ }
+ catch (Throwable ex) {
+ log.error("Potential Memory leak: Unable to shutdown executor service from field '" + fieldName + "' in " + instance, ex);
+ }
}
public String getDescriptor(String key) {