Skip to content

Commit 4a54ffe

Browse files
authored
Remove unused method SolrCloudManager.request() and cleanup DelegatingCloudManager (#3599)
1 parent a5872de commit 4a54ffe

File tree

3 files changed

+5
-31
lines changed

3 files changed

+5
-31
lines changed

solr/solrj-zookeeper/src/java/org/apache/solr/client/solrj/cloud/DelegatingCloudManager.java

Lines changed: 5 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -17,8 +17,6 @@
1717
package org.apache.solr.client.solrj.cloud;
1818

1919
import java.io.IOException;
20-
import org.apache.solr.client.solrj.SolrRequest;
21-
import org.apache.solr.client.solrj.SolrResponse;
2220
import org.apache.solr.client.solrj.impl.CloudSolrClient;
2321
import org.apache.solr.client.solrj.impl.ClusterStateProvider;
2422
import org.apache.solr.common.util.ObjectCache;
@@ -27,10 +25,11 @@
2725
/** Base class for overriding some behavior of {@link SolrCloudManager}. */
2826
public class DelegatingCloudManager implements SolrCloudManager {
2927
protected final SolrCloudManager delegate;
30-
private ObjectCache objectCache = new ObjectCache();
31-
private TimeSource timeSource = TimeSource.NANO_TIME;
3228

3329
public DelegatingCloudManager(SolrCloudManager delegate) {
30+
if (delegate == null) {
31+
throw new IllegalArgumentException("delegate cannot be null");
32+
}
3433
this.delegate = delegate;
3534
}
3635

@@ -56,7 +55,7 @@ public DistribStateManager getDistribStateManager() {
5655

5756
@Override
5857
public ObjectCache getObjectCache() {
59-
return delegate == null ? objectCache : delegate.getObjectCache();
58+
return delegate.getObjectCache();
6059
}
6160

6261
@Override
@@ -66,12 +65,7 @@ public boolean isClosed() {
6665

6766
@Override
6867
public TimeSource getTimeSource() {
69-
return delegate == null ? timeSource : delegate.getTimeSource();
70-
}
71-
72-
@Override
73-
public <T extends SolrResponse> T request(SolrRequest<T> req) throws IOException {
74-
return delegate.request(req);
68+
return delegate.getTimeSource();
7569
}
7670

7771
@Override

solr/solrj-zookeeper/src/java/org/apache/solr/client/solrj/cloud/SolrCloudManager.java

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -18,8 +18,6 @@
1818
package org.apache.solr.client.solrj.cloud;
1919

2020
import java.io.IOException;
21-
import org.apache.solr.client.solrj.SolrRequest;
22-
import org.apache.solr.client.solrj.SolrResponse;
2321
import org.apache.solr.client.solrj.impl.CloudSolrClient;
2422
import org.apache.solr.client.solrj.impl.ClusterStateProvider;
2523
import org.apache.solr.common.SolrCloseable;
@@ -51,7 +49,4 @@ default ClusterState getClusterState() throws IOException {
5149
ObjectCache getObjectCache();
5250

5351
TimeSource getTimeSource();
54-
55-
@Deprecated
56-
<T extends SolrResponse> T request(SolrRequest<T> req) throws IOException;
5752
}

solr/solrj-zookeeper/src/java/org/apache/solr/client/solrj/impl/SolrClientCloudManager.java

Lines changed: 0 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -17,11 +17,7 @@
1717

1818
package org.apache.solr.client.solrj.impl;
1919

20-
import java.io.IOException;
2120
import java.lang.invoke.MethodHandles;
22-
import org.apache.solr.client.solrj.SolrRequest;
23-
import org.apache.solr.client.solrj.SolrResponse;
24-
import org.apache.solr.client.solrj.SolrServerException;
2521
import org.apache.solr.client.solrj.cloud.DistribStateManager;
2622
import org.apache.solr.client.solrj.cloud.NodeStateProvider;
2723
import org.apache.solr.client.solrj.cloud.SolrCloudManager;
@@ -103,17 +99,6 @@ public DistribStateManager getDistribStateManager() {
10399
return stateManager;
104100
}
105101

106-
@Override
107-
public <T extends SolrResponse> T request(SolrRequest<T> req) throws IOException {
108-
try {
109-
return req.process(cloudSolrClient);
110-
} catch (SolrServerException e) {
111-
throw new IOException(e);
112-
}
113-
}
114-
115-
private static final byte[] EMPTY = new byte[0];
116-
117102
public SolrZkClient getZkClient() {
118103
return zkClient;
119104
}

0 commit comments

Comments
 (0)