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/08/17 23:11:36 UTC
[lucene-solr] 06/49: @520 Set max queued per dest to the default
value of 1024.
This is an automated email from the ASF dual-hosted git repository.
markrmiller pushed a commit to branch reference_impl
in repository https://gitbox.apache.org/repos/asf/lucene-solr.git
commit 9e8145305d86b7916e234c195bfa3ed0b86a38e1
Author: markrmiller@gmail.com <ma...@gmail.com>
AuthorDate: Tue Aug 11 23:11:03 2020 -0500
@520 Set max queued per dest to the default value of 1024.
---
.../src/java/org/apache/solr/client/solrj/impl/Http2SolrClient.java | 4 ++--
1 file changed, 2 insertions(+), 2 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 bbeefb1..78cdb48 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
@@ -232,9 +232,10 @@ public class Http2SolrClient extends SolrClient {
httpClient.setStrictEventOrdering(false);
httpClient.setConnectBlocking(false);
httpClient.setFollowRedirects(false);
- httpClient.setMaxRequestsQueuedPerDestination(asyncTracker.getMaxRequestsQueuedPerDestination());
+ httpClient.setMaxRequestsQueuedPerDestination(1024);
httpClient.setUserAgentField(new HttpField(HttpHeader.USER_AGENT, AGENT));
httpClient.setIdleTimeout(idleTimeout);
+ httpClient.setTCPNoDelay(true);
if (builder.connectionTimeout != null) httpClient.setConnectTimeout(builder.connectionTimeout);
httpClient.start();
} catch (Exception e) {
@@ -254,7 +255,6 @@ public class Http2SolrClient extends SolrClient {
closer.collect(() -> {
try {
httpClient.stop();
- //httpClientExecutor.close();
} catch (InterruptedException e) {
ParWork.propegateInterrupt(e);
} catch (Exception e) {