You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@lucene.apache.org by ma...@apache.org on 2020/09/21 15:07:30 UTC
[lucene-solr] branch reference_impl_dev updated: @865 Threads
almost finished lining up to the flute.
This is an automated email from the ASF dual-hosted git repository.
markrmiller pushed a commit to branch reference_impl_dev
in repository https://gitbox.apache.org/repos/asf/lucene-solr.git
The following commit(s) were added to refs/heads/reference_impl_dev by this push:
new 6413ad0 @865 Threads almost finished lining up to the flute.
6413ad0 is described below
commit 6413ad03a790c75e54c8f03d3e310d51fd946e87
Author: markrmiller@gmail.com <ma...@gmail.com>
AuthorDate: Mon Sep 21 10:06:33 2020 -0500
@865 Threads almost finished lining up to the flute.
---
.../src/java/org/apache/solr/client/solrj/impl/Http2SolrClient.java | 4 +---
solr/test-framework/src/java/org/apache/solr/SolrTestCase.java | 5 -----
2 files changed, 1 insertion(+), 8 deletions(-)
diff --git a/solr/solrj/src/java/org/apache/solr/client/solrj/impl/Http2SolrClient.java b/solr/solrj/src/java/org/apache/solr/client/solrj/impl/Http2SolrClient.java
index 02d719b..abf331d 100644
--- a/solr/solrj/src/java/org/apache/solr/client/solrj/impl/Http2SolrClient.java
+++ b/solr/solrj/src/java/org/apache/solr/client/solrj/impl/Http2SolrClient.java
@@ -233,9 +233,7 @@ public class Http2SolrClient extends SolrClient {
log.debug("Create Http2SolrClient with HTTP/1.1 transport");
}
SolrHttpClientTransportOverHTTP transport = new SolrHttpClientTransportOverHTTP(1);
- transport.getHttpClient().setIdleTimeout(idleTimeout);
httpClient = new HttpClient(transport, sslContextFactory);
- if (builder.maxConnectionsPerHost != null) httpClient.setMaxConnectionsPerDestination(builder.maxConnectionsPerHost);
} else {
log.debug("Create Http2SolrClient with HTTP/2 transport");
HTTP2Client http2client = new HTTP2Client();
@@ -245,7 +243,6 @@ public class Http2SolrClient extends SolrClient {
http2client.setInputBufferSize(16384);
HttpClientTransportOverHTTP2 transport = new HttpClientTransportOverHTTP2(http2client);
httpClient = new SolrInternalHttpClient(transport, sslContextFactory);
- if (builder.maxConnectionsPerHost != null) httpClient.setMaxConnectionsPerDestination(builder.maxConnectionsPerHost);
}
try {
@@ -260,6 +257,7 @@ public class Http2SolrClient extends SolrClient {
httpClient.setStrictEventOrdering(strictEventOrdering);
httpClient.setConnectBlocking(false);
httpClient.setFollowRedirects(false);
+ if (builder.maxConnectionsPerHost != null) httpClient.setMaxConnectionsPerDestination(builder.maxConnectionsPerHost);
httpClient.setMaxRequestsQueuedPerDestination(100000);
httpClient.setUserAgentField(new HttpField(HttpHeader.USER_AGENT, AGENT));
httpClient.setIdleTimeout(idleTimeout);
diff --git a/solr/test-framework/src/java/org/apache/solr/SolrTestCase.java b/solr/test-framework/src/java/org/apache/solr/SolrTestCase.java
index ba3aba2..eb00157 100644
--- a/solr/test-framework/src/java/org/apache/solr/SolrTestCase.java
+++ b/solr/test-framework/src/java/org/apache/solr/SolrTestCase.java
@@ -185,11 +185,6 @@ public class SolrTestCase extends LuceneTestCase {
System.setProperty("org.eclipse.jetty.util.log.class", "org.apache.logging.log4j.appserver.jetty.Log4j2Logger");
- // we do this because threads can be finished, but waiting
- // for an idle timeout or in a TERMINATED state, and we don't
- // want to wait for them - in prod these threads are daemon
- interruptThreadsOnTearDown("ParWork", false);
-
if (!SysStats.getSysStats().isAlive()) {
SysStats.reStartSysStats();
}