Add new big testcase

Author: laeubi

bundles/org.eclipse.osgi.tests/src/org/eclipse/osgi/tests/container/TestModuleContainer.java

@@ -1093,7 +1093,7 @@ public void testSubstitutableExports03() throws BundleException, IOException {
 
 		List<ModuleWire> providedWiresF = wiringF.getProvidedModuleWires(PackageNamespace.PACKAGE_NAMESPACE);
 		assertEquals("Wrong number of provided wires: " + providedWiresF, 0, providedWiresF.size());
-		assertSucessfulWith(report, 3, 1, 1, 1);
+		assertSucessfulWith(report, 3, 1, 1, 1); // TODO why this got worse? Do we need to respect resolve order?
 	}
 
 	@Test
@@ -4391,6 +4391,46 @@ public void testSubstitutionPackageResolution() throws Exception {
 		assertSucessfulWith(result, 2, 2, 1, 0); // TODO why became this worse?
 	}
 
+	@Test
+	public void testLargeSet() throws Exception {
+		ResolutionReport result = resolveModuleDatabaseDump("big", TimeUnit.MINUTES.toSeconds(5));
+		assertSucessfulWith(result, 117, 344, 1, 172);
+	}
+
+	private ResolutionReport resolveModuleDatabaseDump(String testSetName, long batchTimeoutSeconds) throws Exception {
+		URL entry = getBundle().getEntry("/test_files/containerTests/" + testSetName + ".state");
+		assertNotNull("can't find test set: " + testSetName, entry);
+		int maxThreads = Math.max(Runtime.getRuntime().availableProcessors() - 1, 1);
+		BlockingQueue<Runnable> queue = new SynchronousQueue<>();
+		ThreadFactory threadFactory = r -> {
+			Thread t = new Thread(r, "Resolver thread - UNIT TEST"); //$NON-NLS-1$
+			t.setDaemon(true);
+			return t;
+		};
+		ScheduledExecutorService watchDog = Executors.newSingleThreadScheduledExecutor();
+		RejectedExecutionHandler rejectHandler = (r, exe) -> r.run();
+		ExecutorService executor = new ThreadPoolExecutor(0, maxThreads, 1, TimeUnit.SECONDS, queue, threadFactory,
+				rejectHandler);
+		ScheduledExecutorService timeoutExecutor = new ScheduledThreadPoolExecutor(1);
+		Map<String, String> configuration = new HashMap<>();
+		configuration.put(EquinoxConfiguration.PROP_RESOLVER_BATCH_TIMEOUT,
+				Long.toString(TimeUnit.SECONDS.toMillis(batchTimeoutSeconds)));
+		DummyContainerAdaptor adaptor = new DummyContainerAdaptor(new DummyCollisionHook(false), configuration,
+				new DummyResolverHookFactory(), new DummyDebugOptions(Collections.emptyMap()));
+		adaptor.setResolverExecutor(executor);
+		adaptor.setTimeoutExecutor(timeoutExecutor);
+		try (DataInputStream stream = new DataInputStream(entry.openStream())) {
+			adaptor.getDatabase().load(stream);
+		}
+		ModuleContainer container = adaptor.getContainer();
+		AtomicBoolean timeout = new AtomicBoolean();
+		ScheduledFuture<?> watch = watchDog.schedule(() -> timeout.set(true), batchTimeoutSeconds, TimeUnit.SECONDS);
+		ResolutionReport report = container.resolve(container.getModules(), true);
+		watch.cancel(true);
+		assertFalse("Resolve operation timed out!", timeout.get());
+		return report;
+	}
+
 	private ResolutionReport resolveTestSet(String testSetName) throws Exception {
 		Enumeration<URL> entries = getBundle().findEntries("/test_files/containerTests/" + testSetName, "*.MF", false);
 		Map<Long, String> manifests = new TreeMap<>();