This is an automated email from the ASF dual-hosted git repository.

epugh pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/solr.git


The following commit(s) were added to refs/heads/main by this push:
     new b21b86c374a SOLR-10461: move setAliveCheckInterval from clients into 
Builder (#1250)
b21b86c374a is described below

commit b21b86c374a0b72877986de41bdafafce8b490a6
Author: Alex <[email protected]>
AuthorDate: Sat Dec 24 13:57:04 2022 -0800

    SOLR-10461: move setAliveCheckInterval from clients into Builder (#1250)
    
    Set missing defaults on builder.
---
 solr/CHANGES.txt                                                      | 2 +-
 .../src/java/org/apache/solr/client/solrj/impl/LBHttp2SolrClient.java | 4 +++-
 .../src/java/org/apache/solr/client/solrj/impl/LBHttpSolrClient.java  | 4 +++-
 .../src/java/org/apache/solr/client/solrj/impl/LBSolrClient.java      | 3 +--
 4 files changed, 8 insertions(+), 5 deletions(-)

diff --git a/solr/CHANGES.txt b/solr/CHANGES.txt
index fd104124821..1e84d3e546b 100644
--- a/solr/CHANGES.txt
+++ b/solr/CHANGES.txt
@@ -94,7 +94,7 @@ Improvements
   direct setter setRetryExpiryTime on cloud SolrClients. (Eric Pugh)
 
 * SOLR-10461: Introduce Builder setter for aliveCheckInterval on load balanced 
SolrClients.  Deprecated 
-  direct setter setAliveCheckInterval on SolrClients. (Eric Pugh, David Smiley)
+  direct setter setAliveCheckInterval on SolrClients. (Eric Pugh, David 
Smiley, Alex Deparvu)
 
 * SOLR-10462: Introduce Builder setter for pollQueueTime on 
ConcurrentUpdateHttp2SolrClient.  Deprecated 
   direct setter setPollQueueTime on ConcurrentUpdateHttp2SolrClient. (Eric 
Pugh)
diff --git 
a/solr/solrj/src/java/org/apache/solr/client/solrj/impl/LBHttp2SolrClient.java 
b/solr/solrj/src/java/org/apache/solr/client/solrj/impl/LBHttp2SolrClient.java
index f6710cc45a4..04b1800ab94 100644
--- 
a/solr/solrj/src/java/org/apache/solr/client/solrj/impl/LBHttp2SolrClient.java
+++ 
b/solr/solrj/src/java/org/apache/solr/client/solrj/impl/LBHttp2SolrClient.java
@@ -299,9 +299,11 @@ public class LBHttp2SolrClient extends LBSolrClient {
   }
 
   public static class Builder {
+
+    public static final int CHECK_INTERVAL = 60 * 1000; // 1 minute between 
checks
     private final Http2SolrClient http2Client;
     private final String[] baseSolrUrls;
-    private int aliveCheckInterval;
+    private int aliveCheckInterval = CHECK_INTERVAL;
 
     public Builder(Http2SolrClient http2Client, String... baseSolrUrls) {
       this.http2Client = http2Client;
diff --git 
a/solr/solrj/src/java/org/apache/solr/client/solrj/impl/LBHttpSolrClient.java 
b/solr/solrj/src/java/org/apache/solr/client/solrj/impl/LBHttpSolrClient.java
index 8df40dfc8f6..8b321f8e1f8 100644
--- 
a/solr/solrj/src/java/org/apache/solr/client/solrj/impl/LBHttpSolrClient.java
+++ 
b/solr/solrj/src/java/org/apache/solr/client/solrj/impl/LBHttpSolrClient.java
@@ -180,9 +180,11 @@ public class LBHttpSolrClient extends LBSolrClient {
 
   /** Constructs {@link LBHttpSolrClient} instances from provided 
configuration. */
   public static class Builder extends SolrClientBuilder<Builder> {
+
+    public static final int CHECK_INTERVAL = 60 * 1000; // 1 minute between 
checks
     protected final List<String> baseSolrUrls;
     protected HttpSolrClient.Builder httpSolrClientBuilder;
-    private int aliveCheckInterval;
+    private int aliveCheckInterval = CHECK_INTERVAL;
 
     public Builder() {
       this.baseSolrUrls = new ArrayList<>();
diff --git 
a/solr/solrj/src/java/org/apache/solr/client/solrj/impl/LBSolrClient.java 
b/solr/solrj/src/java/org/apache/solr/client/solrj/impl/LBSolrClient.java
index 27143fef288..59141fb03f9 100644
--- a/solr/solrj/src/java/org/apache/solr/client/solrj/impl/LBSolrClient.java
+++ b/solr/solrj/src/java/org/apache/solr/client/solrj/impl/LBSolrClient.java
@@ -62,7 +62,6 @@ public abstract class LBSolrClient extends SolrClient {
   // defaults
   protected static final Set<Integer> RETRY_CODES =
       new HashSet<>(Arrays.asList(404, 403, 503, 500));
-  private static final int CHECK_INTERVAL = 60 * 1000; // 1 minute between 
checks
   private static final int NONSTANDARD_PING_LIMIT =
       5; // number of times we'll ping dead servers not in the server list
 
@@ -78,7 +77,7 @@ public abstract class LBSolrClient extends SolrClient {
 
   private volatile ScheduledExecutorService aliveCheckExecutor;
 
-  protected int aliveCheckInterval = CHECK_INTERVAL;
+  protected int aliveCheckInterval = LBHttpSolrClient.Builder.CHECK_INTERVAL;
   private final AtomicInteger counter = new AtomicInteger(-1);
 
   private static final SolrQuery solrQuery = new SolrQuery("*:*");

Reply via email to