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

psalagnac 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 4a54ffe1048 Remove unused method SolrCloudManager.request() and 
cleanup DelegatingCloudManager (#3599)
4a54ffe1048 is described below

commit 4a54ffe10485c1f996e3a09b8171e2b3671fe99c
Author: Pierre Salagnac <[email protected]>
AuthorDate: Mon Sep 1 21:29:54 2025 +0200

    Remove unused method SolrCloudManager.request() and cleanup 
DelegatingCloudManager (#3599)
---
 .../solr/client/solrj/cloud/DelegatingCloudManager.java  | 16 +++++-----------
 .../apache/solr/client/solrj/cloud/SolrCloudManager.java |  5 -----
 .../solr/client/solrj/impl/SolrClientCloudManager.java   | 15 ---------------
 3 files changed, 5 insertions(+), 31 deletions(-)

diff --git 
a/solr/solrj-zookeeper/src/java/org/apache/solr/client/solrj/cloud/DelegatingCloudManager.java
 
b/solr/solrj-zookeeper/src/java/org/apache/solr/client/solrj/cloud/DelegatingCloudManager.java
index e5c46301bbd..5e2fc61a0ce 100644
--- 
a/solr/solrj-zookeeper/src/java/org/apache/solr/client/solrj/cloud/DelegatingCloudManager.java
+++ 
b/solr/solrj-zookeeper/src/java/org/apache/solr/client/solrj/cloud/DelegatingCloudManager.java
@@ -17,8 +17,6 @@
 package org.apache.solr.client.solrj.cloud;
 
 import java.io.IOException;
-import org.apache.solr.client.solrj.SolrRequest;
-import org.apache.solr.client.solrj.SolrResponse;
 import org.apache.solr.client.solrj.impl.CloudSolrClient;
 import org.apache.solr.client.solrj.impl.ClusterStateProvider;
 import org.apache.solr.common.util.ObjectCache;
@@ -27,10 +25,11 @@ import org.apache.solr.common.util.TimeSource;
 /** Base class for overriding some behavior of {@link SolrCloudManager}. */
 public class DelegatingCloudManager implements SolrCloudManager {
   protected final SolrCloudManager delegate;
-  private ObjectCache objectCache = new ObjectCache();
-  private TimeSource timeSource = TimeSource.NANO_TIME;
 
   public DelegatingCloudManager(SolrCloudManager delegate) {
+    if (delegate == null) {
+      throw new IllegalArgumentException("delegate cannot be null");
+    }
     this.delegate = delegate;
   }
 
@@ -56,7 +55,7 @@ public class DelegatingCloudManager implements 
SolrCloudManager {
 
   @Override
   public ObjectCache getObjectCache() {
-    return delegate == null ? objectCache : delegate.getObjectCache();
+    return delegate.getObjectCache();
   }
 
   @Override
@@ -66,12 +65,7 @@ public class DelegatingCloudManager implements 
SolrCloudManager {
 
   @Override
   public TimeSource getTimeSource() {
-    return delegate == null ? timeSource : delegate.getTimeSource();
-  }
-
-  @Override
-  public <T extends SolrResponse> T request(SolrRequest<T> req) throws 
IOException {
-    return delegate.request(req);
+    return delegate.getTimeSource();
   }
 
   @Override
diff --git 
a/solr/solrj-zookeeper/src/java/org/apache/solr/client/solrj/cloud/SolrCloudManager.java
 
b/solr/solrj-zookeeper/src/java/org/apache/solr/client/solrj/cloud/SolrCloudManager.java
index e38b029af81..6822419efe2 100644
--- 
a/solr/solrj-zookeeper/src/java/org/apache/solr/client/solrj/cloud/SolrCloudManager.java
+++ 
b/solr/solrj-zookeeper/src/java/org/apache/solr/client/solrj/cloud/SolrCloudManager.java
@@ -18,8 +18,6 @@
 package org.apache.solr.client.solrj.cloud;
 
 import java.io.IOException;
-import org.apache.solr.client.solrj.SolrRequest;
-import org.apache.solr.client.solrj.SolrResponse;
 import org.apache.solr.client.solrj.impl.CloudSolrClient;
 import org.apache.solr.client.solrj.impl.ClusterStateProvider;
 import org.apache.solr.common.SolrCloseable;
@@ -51,7 +49,4 @@ public interface SolrCloudManager extends SolrCloseable {
   ObjectCache getObjectCache();
 
   TimeSource getTimeSource();
-
-  @Deprecated
-  <T extends SolrResponse> T request(SolrRequest<T> req) throws IOException;
 }
diff --git 
a/solr/solrj-zookeeper/src/java/org/apache/solr/client/solrj/impl/SolrClientCloudManager.java
 
b/solr/solrj-zookeeper/src/java/org/apache/solr/client/solrj/impl/SolrClientCloudManager.java
index 1732791bf54..30afd6bed57 100644
--- 
a/solr/solrj-zookeeper/src/java/org/apache/solr/client/solrj/impl/SolrClientCloudManager.java
+++ 
b/solr/solrj-zookeeper/src/java/org/apache/solr/client/solrj/impl/SolrClientCloudManager.java
@@ -17,11 +17,7 @@
 
 package org.apache.solr.client.solrj.impl;
 
-import java.io.IOException;
 import java.lang.invoke.MethodHandles;
-import org.apache.solr.client.solrj.SolrRequest;
-import org.apache.solr.client.solrj.SolrResponse;
-import org.apache.solr.client.solrj.SolrServerException;
 import org.apache.solr.client.solrj.cloud.DistribStateManager;
 import org.apache.solr.client.solrj.cloud.NodeStateProvider;
 import org.apache.solr.client.solrj.cloud.SolrCloudManager;
@@ -103,17 +99,6 @@ public class SolrClientCloudManager implements 
SolrCloudManager {
     return stateManager;
   }
 
-  @Override
-  public <T extends SolrResponse> T request(SolrRequest<T> req) throws 
IOException {
-    try {
-      return req.process(cloudSolrClient);
-    } catch (SolrServerException e) {
-      throw new IOException(e);
-    }
-  }
-
-  private static final byte[] EMPTY = new byte[0];
-
   public SolrZkClient getZkClient() {
     return zkClient;
   }

Reply via email to