Attempt to fix something 4

dice-group · Jul 5, 2024 · 858fc80 · 858fc80
1 parent f910cec
commit 858fc80
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 3 deletions.
diff --git a/src/main/java/org/aksw/iguana/cc/worker/impl/SPARQLProtocolWorker.java b/src/main/java/org/aksw/iguana/cc/worker/impl/SPARQLProtocolWorker.java
@@ -132,7 +132,7 @@ public static void initHttpClient(int threadCount) {
                 .setMaxConnTotal(threadCount * 1000)
                 .setMaxConnPerRoute(threadCount * 1000)
                 .setPoolConcurrencyPolicy(PoolConcurrencyPolicy.LAX)
-                .setConnPoolPolicy(PoolReusePolicy.LIFO)
+                .setConnPoolPolicy(PoolReusePolicy.FIFO)
                 .setDefaultConnectionConfig(org.apache.hc.client5.http.config.ConnectionConfig.custom()
                         .setConnectTimeout(Timeout.ofSeconds(5))
                         .setValidateAfterInactivity(TimeValue.ofSeconds(5))

diff --git a/src/test/java/org/aksw/iguana/cc/worker/impl/SPARQLProtocolWorkerTest.java b/src/test/java/org/aksw/iguana/cc/worker/impl/SPARQLProtocolWorkerTest.java
@@ -46,7 +46,14 @@ public class SPARQLProtocolWorkerTest {
 
     @RegisterExtension
     public static WireMockExtension wm = WireMockExtension.newInstance()
-            .options(new WireMockConfiguration().useChunkedTransferEncoding(Options.ChunkedEncodingPolicy.NEVER).dynamicPort().notifier(new ConsoleNotifier(false)))
+            .options(new WireMockConfiguration()
+                    .useChunkedTransferEncoding(Options.ChunkedEncodingPolicy.NEVER)
+                    .dynamicPort()
+                    .notifier(new ConsoleNotifier(false))
+                    .containerThreads(10)
+                    .asynchronousResponseEnabled(true)
+                    .asynchronousResponseThreads(10)
+                    .timeout(10000))
             .failOnUnmatchedRequests(true)
             .build();
 
@@ -228,7 +235,7 @@ public void testCompletionTargets(HttpWorker.CompletionTarget target) throws URI
                 queryHandler,
                 target,
                 connection,
-                Duration.parse("PT20S"),
+                Duration.parse("PT360S"),
                 "application/sparql-results+json",
                 RequestFactory.RequestType.POST_URL_ENC_QUERY,
                 false