Skip to content

Commit 8f63927

Browse files
author
Andrey Ershov
committed
resolveVotingTombstonesAndCheckMaximum
1 parent 4454009 commit 8f63927

File tree

3 files changed

+6
-6
lines changed

3 files changed

+6
-6
lines changed

server/src/main/java/org/elasticsearch/action/admin/cluster/configuration/AddVotingTombstonesRequest.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -84,7 +84,7 @@ Set<VotingTombstone> resolveVotingTombstones(ClusterState currentState) {
8484
return resolvedNodes;
8585
}
8686

87-
Set<VotingTombstone> resolveVotingTombstones(ClusterState currentState, int maxTombstoneCount, String maximumSettingKey) {
87+
Set<VotingTombstone> resolveVotingTombstonesAndCheckMaximum(ClusterState currentState, int maxTombstoneCount, String maximumSettingKey) {
8888
final Set<VotingTombstone> resolvedNodes = resolveVotingTombstones(currentState);
8989

9090
final int oldTombstoneCount = currentState.getVotingTombstones().size();

server/src/main/java/org/elasticsearch/action/admin/cluster/configuration/TransportAddVotingTombstonesAction.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -146,7 +146,7 @@ public void onTimeout(TimeValue timeout) {
146146
}
147147

148148
private static Set<VotingTombstone> resolveVotingTombstonesAndCheckMaximum(AddVotingTombstonesRequest request, ClusterState state) {
149-
return request.resolveVotingTombstones(state,
149+
return request.resolveVotingTombstonesAndCheckMaximum(state,
150150
MAXIMUM_VOTING_TOMBSTONES_SETTING.get(state.metaData().settings()), MAXIMUM_VOTING_TOMBSTONES_SETTING.getKey());
151151
}
152152

server/src/test/java/org/elasticsearch/action/admin/cluster/configuration/AddVotingTombstonesRequestTests.java

+4-4
Original file line numberDiff line numberDiff line change
@@ -99,17 +99,17 @@ public void testResolveAndCheckMaximum() {
9999
.coordinationMetaData(CoordinationMetaData.builder().addVotingTombstone(otherNode1Tombstone).build()));
100100
final ClusterState clusterState = builder.build();
101101

102-
assertThat(makeRequest().resolveVotingTombstones(clusterState, 3, "setting.name"),
102+
assertThat(makeRequest().resolveVotingTombstonesAndCheckMaximum(clusterState, 3, "setting.name"),
103103
containsInAnyOrder(localNodeTombstone, otherNode2Tombstone));
104-
assertThat(makeRequest("_local").resolveVotingTombstones(clusterState, 2, "setting.name"),
104+
assertThat(makeRequest("_local").resolveVotingTombstonesAndCheckMaximum(clusterState, 2, "setting.name"),
105105
contains(localNodeTombstone));
106106

107107
assertThat(expectThrows(IllegalArgumentException.class,
108-
() -> makeRequest().resolveVotingTombstones(clusterState, 2, "setting.name")).getMessage(),
108+
() -> makeRequest().resolveVotingTombstonesAndCheckMaximum(clusterState, 2, "setting.name")).getMessage(),
109109
equalTo("add voting tombstones request for [] would add [2] voting tombstones to the existing [1] which would exceed the " +
110110
"maximum of [2] set by [setting.name]"));
111111
assertThat(expectThrows(IllegalArgumentException.class,
112-
() -> makeRequest("_local").resolveVotingTombstones(clusterState, 1, "setting.name")).getMessage(),
112+
() -> makeRequest("_local").resolveVotingTombstonesAndCheckMaximum(clusterState, 1, "setting.name")).getMessage(),
113113
equalTo("add voting tombstones request for [_local] would add [1] voting tombstones to the existing [1] which would exceed " +
114114
"the maximum of [1] set by [setting.name]"));
115115
}

0 commit comments

Comments
 (0)