Skip to content

Commit 1ca338d

Browse files
authored
Remove more deprecated master classes (#17166)
Signed-off-by: Andrew Ross <andrross@amazon.com>
1 parent c5ab162 commit 1ca338d

17 files changed

+22
-451
lines changed

server/src/internalClusterTest/java/org/opensearch/remotestore/RemoteRestoreSnapshotIT.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -1143,7 +1143,7 @@ public void testConcurrentSnapshotV2CreateOperation_MasterChange() throws Except
11431143
.cluster()
11441144
.prepareCreateSnapshot(snapshotRepoName, snapshotName)
11451145
.setWaitForCompletion(true)
1146-
.setMasterNodeTimeout(TimeValue.timeValueSeconds(60))
1146+
.setClusterManagerNodeTimeout(TimeValue.timeValueSeconds(60))
11471147
.get();
11481148

11491149
} catch (Exception ignored) {}

server/src/main/java/org/opensearch/action/support/clustermanager/ClusterManagerNodeOperationRequestBuilder.java

-22
Original file line numberDiff line numberDiff line change
@@ -63,17 +63,6 @@ public final RequestBuilder setClusterManagerNodeTimeout(TimeValue timeout) {
6363
return (RequestBuilder) this;
6464
}
6565

66-
/**
67-
* Sets the cluster-manager node timeout in case the cluster-manager has not yet been discovered.
68-
*
69-
* @deprecated As of 2.1, because supporting inclusive language, replaced by {@link #setClusterManagerNodeTimeout(TimeValue)}
70-
*/
71-
@SuppressWarnings("unchecked")
72-
@Deprecated
73-
public final RequestBuilder setMasterNodeTimeout(TimeValue timeout) {
74-
return setClusterManagerNodeTimeout(timeout);
75-
}
76-
7766
/**
7867
* Sets the cluster-manager node timeout in case the cluster-manager has not yet been discovered.
7968
*/
@@ -82,15 +71,4 @@ public final RequestBuilder setClusterManagerNodeTimeout(String timeout) {
8271
request.clusterManagerNodeTimeout(timeout);
8372
return (RequestBuilder) this;
8473
}
85-
86-
/**
87-
* Sets the cluster-manager node timeout in case the cluster-manager has not yet been discovered.
88-
*
89-
* @deprecated As of 2.1, because supporting inclusive language, replaced by {@link #setClusterManagerNodeTimeout(String)}
90-
*/
91-
@SuppressWarnings("unchecked")
92-
@Deprecated
93-
public final RequestBuilder setMasterNodeTimeout(String timeout) {
94-
return setClusterManagerNodeTimeout(timeout);
95-
}
9674
}

server/src/main/java/org/opensearch/cluster/LocalNodeMasterListener.java

-76
This file was deleted.

server/src/main/java/org/opensearch/cluster/MasterNodeChangePredicate.java

-53
This file was deleted.

server/src/main/java/org/opensearch/cluster/NotMasterException.java

-57
This file was deleted.

server/src/main/java/org/opensearch/cluster/coordination/NoMasterBlockService.java

-50
This file was deleted.

server/src/main/java/org/opensearch/cluster/coordination/UnsafeBootstrapMasterCommand.java

-47
This file was deleted.

server/src/main/java/org/opensearch/cluster/service/ClusterApplierService.java

-10
Original file line numberDiff line numberDiff line change
@@ -43,7 +43,6 @@
4343
import org.opensearch.cluster.ClusterStateObserver;
4444
import org.opensearch.cluster.ClusterStateTaskConfig;
4545
import org.opensearch.cluster.LocalNodeClusterManagerListener;
46-
import org.opensearch.cluster.LocalNodeMasterListener;
4746
import org.opensearch.cluster.NodeConnectionsService;
4847
import org.opensearch.cluster.TimeoutClusterStateListener;
4948
import org.opensearch.cluster.metadata.ProcessClusterEventTimeoutException;
@@ -308,15 +307,6 @@ public void addLocalNodeClusterManagerListener(LocalNodeClusterManagerListener l
308307
addListener(listener);
309308
}
310309

311-
/**
312-
* Add a listener for on/off local node cluster-manager events
313-
* @deprecated As of 2.1, because supporting inclusive language, replaced by {@link #addLocalNodeClusterManagerListener}
314-
*/
315-
@Deprecated
316-
public void addLocalNodeMasterListener(LocalNodeMasterListener listener) {
317-
addLocalNodeClusterManagerListener(listener);
318-
}
319-
320310
/**
321311
* Adds a cluster state listener that is expected to be removed during a short period of time.
322312
* If provided, the listener will be notified once a specific time has elapsed.

0 commit comments

Comments
 (0)