Skip to content

Commit 7f41867

Browse files
jdconradjdconrad
authored
Migrate transport versions 9108_000 through 9086_000 (#135819) (#135849)
Note some versions in between have already been migrated. ES-12334
1 parent 545048c commit 7f41867

File tree

32 files changed

+124
-86
lines changed

32 files changed

+124
-86
lines changed

‎server/src/main/java/org/elasticsearch/TransportVersions.java‎

Lines changed: 0 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -181,8 +181,6 @@ static TransportVersion def(int id) {
181181
public static final TransportVersion REMOVE_ALL_APPLICABLE_SELECTOR_9_0 = def(9_000_0_05);
182182
public static final TransportVersion BYTE_SIZE_VALUE_ALWAYS_USES_BYTES_90 = def(9_000_0_06);
183183
public static final TransportVersion RETRY_ILM_ASYNC_ACTION_REQUIRE_ERROR_90 = def(9_000_0_07);
184-
public static final TransportVersion RE_REMOVE_MIN_COMPATIBLE_SHARD_NODE_90 = def(9_000_0_08);
185-
public static final TransportVersion STORED_SCRIPT_CONTENT_LENGTH_90 = def(9_000_0_09);
186184
public static final TransportVersion COHERE_BIT_EMBEDDING_TYPE_SUPPORT_ADDED = def(9_001_0_00);
187185
public static final TransportVersion REMOVE_SNAPSHOT_FAILURES = def(9_002_0_00);
188186
public static final TransportVersion TRANSPORT_STATS_HANDLING_TIME_REQUIRED = def(9_003_0_00);
@@ -200,9 +198,7 @@ static TransportVersion def(int id) {
200198
public static final TransportVersion ESQL_SERIALIZE_SOURCE_FUNCTIONS_WARNINGS = def(9_016_0_00);
201199
public static final TransportVersion ESQL_DRIVER_NODE_DESCRIPTION = def(9_017_0_00);
202200
public static final TransportVersion MULTI_PROJECT = def(9_018_0_00);
203-
public static final TransportVersion STORED_SCRIPT_CONTENT_LENGTH = def(9_019_0_00);
204201
public static final TransportVersion JINA_AI_EMBEDDING_TYPE_SUPPORT_ADDED = def(9_020_0_00);
205-
public static final TransportVersion RE_REMOVE_MIN_COMPATIBLE_SHARD_NODE = def(9_021_0_00);
206202
public static final TransportVersion UNASSIGENEDINFO_RESHARD_ADDED = def(9_022_0_00);
207203
public static final TransportVersion MAX_OPERATION_SIZE_REJECTIONS_ADDED = def(9_024_0_00);
208204
public static final TransportVersion RETRY_ILM_ASYNC_ACTION_REQUIRE_ERROR = def(9_025_0_00);
@@ -252,14 +248,6 @@ static TransportVersion def(int id) {
252248
public static final TransportVersion ESQL_TIME_SERIES_SOURCE_STATUS = def(9_076_0_00);
253249
public static final TransportVersion NODES_STATS_SUPPORTS_MULTI_PROJECT = def(9_079_0_00);
254250
public static final TransportVersion ESQL_LIMIT_ROW_SIZE = def(9_085_0_00);
255-
public static final TransportVersion SNAPSHOT_INDEX_SHARD_STATUS_MISSING_STATS = def(9_093_0_00);
256-
public static final TransportVersion SEARCH_LOAD_PER_INDEX_STATS = def(9_095_0_00);
257-
public static final TransportVersion HEAP_USAGE_IN_CLUSTER_INFO = def(9_096_0_00);
258-
public static final TransportVersion PROJECT_DELETION_GLOBAL_BLOCK = def(9_098_0_00);
259-
public static final TransportVersion SECURITY_CLOUD_API_KEY_REALM_AND_TYPE = def(9_099_0_00);
260-
public static final TransportVersion STATE_PARAM_GET_SNAPSHOT = def(9_100_0_00);
261-
public static final TransportVersion PROJECT_ID_IN_SNAPSHOTS_DELETIONS_AND_REPO_CLEANUP = def(9_101_0_00);
262-
public static final TransportVersion CLUSTER_STATE_PROJECTS_SETTINGS = def(9_108_0_00);
263251

264252
/*
265253
* STOP! READ THIS FIRST! No, really,

‎server/src/main/java/org/elasticsearch/action/admin/cluster/snapshots/get/GetSnapshotsRequest.java‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -42,7 +42,7 @@ public class GetSnapshotsRequest extends MasterNodeRequest<GetSnapshotsRequest>
4242
public static final boolean DEFAULT_VERBOSE_MODE = true;
4343

4444
private static final TransportVersion INDICES_FLAG_VERSION = TransportVersions.V_8_3_0;
45-
private static final TransportVersion STATE_FLAG_VERSION = TransportVersions.STATE_PARAM_GET_SNAPSHOT;
45+
private static final TransportVersion STATE_FLAG_VERSION = TransportVersion.fromName("state_param_get_snapshot");
4646

4747
public static final int NO_LIMIT = -1;
4848

@@ -124,7 +124,7 @@ public GetSnapshotsRequest(StreamInput in) throws IOException {
124124
if (in.getTransportVersion().onOrAfter(INDICES_FLAG_VERSION)) {
125125
includeIndexNames = in.readBoolean();
126126
}
127-
if (in.getTransportVersion().onOrAfter(STATE_FLAG_VERSION)) {
127+
if (in.getTransportVersion().supports(STATE_FLAG_VERSION)) {
128128
states = in.readEnumSet(SnapshotState.class);
129129
} else {
130130
states = EnumSet.allOf(SnapshotState.class);
@@ -148,7 +148,7 @@ public void writeTo(StreamOutput out) throws IOException {
148148
if (out.getTransportVersion().onOrAfter(INDICES_FLAG_VERSION)) {
149149
out.writeBoolean(includeIndexNames);
150150
}
151-
if (out.getTransportVersion().onOrAfter(STATE_FLAG_VERSION)) {
151+
if (out.getTransportVersion().supports(STATE_FLAG_VERSION)) {
152152
out.writeEnumSet(states);
153153
} else if (states.equals(EnumSet.allOf(SnapshotState.class)) == false) {
154154
final var errorString = "GetSnapshotsRequest [states] field is not supported on all nodes in the cluster";

‎server/src/main/java/org/elasticsearch/action/admin/cluster/snapshots/status/SnapshotIndexShardStatus.java‎

Lines changed: 7 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -9,6 +9,7 @@
99

1010
package org.elasticsearch.action.admin.cluster.snapshots.status;
1111

12+
import org.elasticsearch.TransportVersion;
1213
import org.elasticsearch.action.support.broadcast.BroadcastShardResponse;
1314
import org.elasticsearch.common.Strings;
1415
import org.elasticsearch.common.io.stream.StreamInput;
@@ -22,10 +23,12 @@
2223
import java.io.IOException;
2324
import java.util.Objects;
2425

25-
import static org.elasticsearch.TransportVersions.SNAPSHOT_INDEX_SHARD_STATUS_MISSING_STATS;
26-
2726
public class SnapshotIndexShardStatus extends BroadcastShardResponse implements ToXContentFragment {
2827

28+
private static final TransportVersion SNAPSHOT_INDEX_SHARD_STATUS_MISSING_STATS = TransportVersion.fromName(
29+
"snapshot_index_shard_status_missing_stats"
30+
);
31+
2932
private final SnapshotIndexShardStage stage;
3033

3134
private final SnapshotStats stats;
@@ -42,7 +45,7 @@ public SnapshotIndexShardStatus(StreamInput in) throws IOException {
4245
stats = new SnapshotStats(in);
4346
nodeId = in.readOptionalString();
4447
failure = in.readOptionalString();
45-
if (in.getTransportVersion().onOrAfter(SNAPSHOT_INDEX_SHARD_STATUS_MISSING_STATS)) {
48+
if (in.getTransportVersion().supports(SNAPSHOT_INDEX_SHARD_STATUS_MISSING_STATS)) {
4649
description = in.readOptionalString();
4750
}
4851
}
@@ -159,7 +162,7 @@ public void writeTo(StreamOutput out) throws IOException {
159162
stats.writeTo(out);
160163
out.writeOptionalString(nodeId);
161164
out.writeOptionalString(failure);
162-
if (out.getTransportVersion().onOrAfter(SNAPSHOT_INDEX_SHARD_STATUS_MISSING_STATS)) {
165+
if (out.getTransportVersion().supports(SNAPSHOT_INDEX_SHARD_STATUS_MISSING_STATS)) {
163166
out.writeOptionalString(description);
164167
}
165168
}

‎server/src/main/java/org/elasticsearch/action/admin/cluster/snapshots/status/SnapshotStats.java‎

Lines changed: 7 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -9,6 +9,7 @@
99

1010
package org.elasticsearch.action.admin.cluster.snapshots.status;
1111

12+
import org.elasticsearch.TransportVersion;
1213
import org.elasticsearch.common.Strings;
1314
import org.elasticsearch.common.io.stream.StreamInput;
1415
import org.elasticsearch.common.io.stream.StreamOutput;
@@ -21,10 +22,12 @@
2122

2223
import java.io.IOException;
2324

24-
import static org.elasticsearch.TransportVersions.SNAPSHOT_INDEX_SHARD_STATUS_MISSING_STATS;
25-
2625
public class SnapshotStats implements Writeable, ToXContentObject {
2726

27+
private static final TransportVersion SNAPSHOT_INDEX_SHARD_STATUS_MISSING_STATS = TransportVersion.fromName(
28+
"snapshot_index_shard_status_missing_stats"
29+
);
30+
2831
private long startTime;
2932
private long time;
3033
private int incrementalFileCount;
@@ -38,7 +41,7 @@ public class SnapshotStats implements Writeable, ToXContentObject {
3841

3942
SnapshotStats(StreamInput in) throws IOException {
4043
// We use a boolean to indicate if the stats are present (true) or missing (false), to skip writing all the values if missing.
41-
if (in.getTransportVersion().onOrAfter(SNAPSHOT_INDEX_SHARD_STATUS_MISSING_STATS) && in.readBoolean() == false) {
44+
if (in.getTransportVersion().supports(SNAPSHOT_INDEX_SHARD_STATUS_MISSING_STATS) && in.readBoolean() == false) {
4245
startTime = 0L;
4346
time = 0L;
4447
incrementalFileCount = -1;
@@ -156,7 +159,7 @@ public long getProcessedSize() {
156159

157160
@Override
158161
public void writeTo(StreamOutput out) throws IOException {
159-
if (out.getTransportVersion().onOrAfter(SNAPSHOT_INDEX_SHARD_STATUS_MISSING_STATS)) {
162+
if (out.getTransportVersion().supports(SNAPSHOT_INDEX_SHARD_STATUS_MISSING_STATS)) {
160163
// We use a boolean to indicate if the stats are present (true) or missing (false), to skip writing all the values if missing.
161164
if (isMissingStats()) {
162165
out.writeBoolean(false);

‎server/src/main/java/org/elasticsearch/action/admin/cluster/snapshots/status/TransportSnapshotsStatusAction.java‎

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,6 @@
1212
import org.apache.logging.log4j.LogManager;
1313
import org.apache.logging.log4j.Logger;
1414
import org.elasticsearch.TransportVersion;
15-
import org.elasticsearch.TransportVersions;
1615
import org.elasticsearch.action.ActionListener;
1716
import org.elasticsearch.action.ActionType;
1817
import org.elasticsearch.action.support.ActionFilters;
@@ -73,6 +72,10 @@ public class TransportSnapshotsStatusAction extends TransportMasterNodeAction<Sn
7372
public static final ActionType<SnapshotsStatusResponse> TYPE = new ActionType<>("cluster:admin/snapshot/status");
7473
private static final Logger logger = LogManager.getLogger(TransportSnapshotsStatusAction.class);
7574

75+
private static final TransportVersion SNAPSHOT_INDEX_SHARD_STATUS_MISSING_STATS = TransportVersion.fromName(
76+
"snapshot_index_shard_status_missing_stats"
77+
);
78+
7679
private final RepositoriesService repositoriesService;
7780

7881
private final NodeClient client;
@@ -270,7 +273,7 @@ void buildResponse(
270273
// When processing currently running snapshots, instead of reading the statistics from the repository, which can be
271274
// expensive, we choose instead to provide a message to the caller explaining why the stats are missing and the API
272275
// that can be used to load them once the snapshot has completed.
273-
if (minTransportVersion.onOrAfter(TransportVersions.SNAPSHOT_INDEX_SHARD_STATUS_MISSING_STATS)) {
276+
if (minTransportVersion.supports(SNAPSHOT_INDEX_SHARD_STATUS_MISSING_STATS)) {
274277
shardStatus = SnapshotIndexShardStatus.forDoneButMissingStats(shardId, """
275278
Snapshot shard stats missing from a currently running snapshot due to a node leaving the cluster after \
276279
completing the shard snapshot; retry once the snapshot has completed to load all shard stats from the \

‎server/src/main/java/org/elasticsearch/action/admin/cluster/storedscripts/PutStoredScriptRequest.java‎

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -9,7 +9,7 @@
99

1010
package org.elasticsearch.action.admin.cluster.storedscripts;
1111

12-
import org.elasticsearch.TransportVersions;
12+
import org.elasticsearch.TransportVersion;
1313
import org.elasticsearch.action.ActionRequestValidationException;
1414
import org.elasticsearch.action.support.master.AcknowledgedRequest;
1515
import org.elasticsearch.common.Strings;
@@ -32,6 +32,8 @@
3232

3333
public class PutStoredScriptRequest extends AcknowledgedRequest<PutStoredScriptRequest> implements ToXContentFragment {
3434

35+
private static final TransportVersion STORED_SCRIPT_CONTENT_LENGTH = TransportVersion.fromName("stored_script_content_length");
36+
3537
@Nullable
3638
private final String id;
3739

@@ -45,8 +47,7 @@ public class PutStoredScriptRequest extends AcknowledgedRequest<PutStoredScriptR
4547
public PutStoredScriptRequest(StreamInput in) throws IOException {
4648
super(in);
4749
id = in.readOptionalString();
48-
if (in.getTransportVersion().isPatchFrom(TransportVersions.STORED_SCRIPT_CONTENT_LENGTH_90)
49-
|| in.getTransportVersion().onOrAfter(TransportVersions.STORED_SCRIPT_CONTENT_LENGTH)) {
50+
if (in.getTransportVersion().supports(STORED_SCRIPT_CONTENT_LENGTH)) {
5051
contentLength = in.readVInt();
5152
} else {
5253
BytesReference content = in.readBytesReference();
@@ -106,8 +107,7 @@ public StoredScriptSource source() {
106107
public void writeTo(StreamOutput out) throws IOException {
107108
super.writeTo(out);
108109
out.writeOptionalString(id);
109-
if (out.getTransportVersion().isPatchFrom(TransportVersions.STORED_SCRIPT_CONTENT_LENGTH_90)
110-
|| out.getTransportVersion().onOrAfter(TransportVersions.STORED_SCRIPT_CONTENT_LENGTH)) {
110+
if (out.getTransportVersion().supports(STORED_SCRIPT_CONTENT_LENGTH)) {
111111
out.writeVInt(contentLength);
112112
} else {
113113
// generate a bytes reference of the correct size (the content isn't actually used in 8.18)

‎server/src/main/java/org/elasticsearch/action/search/SearchRequest.java‎

Lines changed: 7 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -9,6 +9,7 @@
99

1010
package org.elasticsearch.action.search;
1111

12+
import org.elasticsearch.TransportVersion;
1213
import org.elasticsearch.TransportVersions;
1314
import org.elasticsearch.Version;
1415
import org.elasticsearch.action.ActionRequestValidationException;
@@ -63,6 +64,10 @@ public class SearchRequest extends LegacyActionRequest implements IndicesRequest
6364

6465
private static final long DEFAULT_ABSOLUTE_START_MILLIS = -1;
6566

67+
private static final TransportVersion RE_REMOVE_MIN_COMPATIBLE_SHARD_NODE = TransportVersion.fromName(
68+
"re_remove_min_compatible_shard_node"
69+
);
70+
6671
private final String localClusterAlias;
6772
private final long absoluteStartMillis;
6873
private final boolean finalReduce;
@@ -258,8 +263,7 @@ public SearchRequest(StreamInput in) throws IOException {
258263
finalReduce = true;
259264
}
260265
ccsMinimizeRoundtrips = in.readBoolean();
261-
if ((in.getTransportVersion().isPatchFrom(TransportVersions.RE_REMOVE_MIN_COMPATIBLE_SHARD_NODE_90) == false
262-
&& in.getTransportVersion().before(TransportVersions.RE_REMOVE_MIN_COMPATIBLE_SHARD_NODE)) && in.readBoolean()) {
266+
if (in.getTransportVersion().supports(RE_REMOVE_MIN_COMPATIBLE_SHARD_NODE) == false && in.readBoolean()) {
263267
Version.readVersion(in); // and drop on the floor
264268
}
265269
waitForCheckpoints = in.readMap(StreamInput::readLongArray);
@@ -303,8 +307,7 @@ public void writeTo(StreamOutput out, boolean skipIndices) throws IOException {
303307
out.writeBoolean(finalReduce);
304308
}
305309
out.writeBoolean(ccsMinimizeRoundtrips);
306-
if ((out.getTransportVersion().isPatchFrom(TransportVersions.RE_REMOVE_MIN_COMPATIBLE_SHARD_NODE_90) == false
307-
&& out.getTransportVersion().before(TransportVersions.RE_REMOVE_MIN_COMPATIBLE_SHARD_NODE))) {
310+
if (out.getTransportVersion().supports(RE_REMOVE_MIN_COMPATIBLE_SHARD_NODE) == false) {
308311
out.writeBoolean(false);
309312
}
310313
out.writeMap(waitForCheckpoints, StreamOutput::writeLongArray);

‎server/src/main/java/org/elasticsearch/cluster/ClusterInfo.java‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,6 @@
1010
package org.elasticsearch.cluster;
1111

1212
import org.elasticsearch.TransportVersion;
13-
import org.elasticsearch.TransportVersions;
1413
import org.elasticsearch.cluster.routing.ExpectedShardSizeEstimator;
1514
import org.elasticsearch.cluster.routing.RecoverySource;
1615
import org.elasticsearch.cluster.routing.ShardRouting;
@@ -50,6 +49,7 @@ public class ClusterInfo implements ChunkedToXContent, Writeable, ExpectedShardS
5049

5150
public static final ClusterInfo EMPTY = new ClusterInfo();
5251

52+
private static final TransportVersion HEAP_USAGE_IN_CLUSTER_INFO = TransportVersion.fromName("heap_usage_in_cluster_info");
5353
private static final TransportVersion NODE_USAGE_STATS_FOR_THREAD_POOLS_IN_CLUSTER_INFO = TransportVersion.fromName(
5454
"node_usage_stats_for_thread_pools_in_cluster_info"
5555
);
@@ -119,7 +119,7 @@ public ClusterInfo(StreamInput in) throws IOException {
119119
this.shardDataSetSizes = in.readImmutableMap(ShardId::new, StreamInput::readLong);
120120
this.dataPath = in.readImmutableMap(NodeAndShard::new, StreamInput::readString);
121121
this.reservedSpace = in.readImmutableMap(NodeAndPath::new, ReservedSpace::new);
122-
if (in.getTransportVersion().onOrAfter(TransportVersions.HEAP_USAGE_IN_CLUSTER_INFO)) {
122+
if (in.getTransportVersion().supports(HEAP_USAGE_IN_CLUSTER_INFO)) {
123123
this.estimatedHeapUsages = in.readImmutableMap(EstimatedHeapUsage::new);
124124
} else {
125125
this.estimatedHeapUsages = Map.of();
@@ -149,7 +149,7 @@ public void writeTo(StreamOutput out) throws IOException {
149149
out.writeMap(this.shardDataSetSizes, StreamOutput::writeWriteable, StreamOutput::writeLong);
150150
out.writeMap(this.dataPath, StreamOutput::writeWriteable, StreamOutput::writeString);
151151
out.writeMap(this.reservedSpace);
152-
if (out.getTransportVersion().onOrAfter(TransportVersions.HEAP_USAGE_IN_CLUSTER_INFO)) {
152+
if (out.getTransportVersion().supports(HEAP_USAGE_IN_CLUSTER_INFO)) {
153153
out.writeMap(this.estimatedHeapUsages, StreamOutput::writeWriteable);
154154
}
155155
if (out.getTransportVersion().supports(NODE_USAGE_STATS_FOR_THREAD_POOLS_IN_CLUSTER_INFO)) {

‎server/src/main/java/org/elasticsearch/cluster/RepositoryCleanupInProgress.java‎

Lines changed: 6 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -23,8 +23,6 @@
2323
import java.util.List;
2424
import java.util.Objects;
2525

26-
import static org.elasticsearch.TransportVersions.PROJECT_ID_IN_SNAPSHOTS_DELETIONS_AND_REPO_CLEANUP;
27-
2826
/**
2927
* A repository cleanup request entry. Part of the cluster state.
3028
*/
@@ -34,6 +32,10 @@ public final class RepositoryCleanupInProgress extends AbstractNamedDiffable<Clu
3432

3533
public static final String TYPE = "repository_cleanup";
3634

35+
private static final TransportVersion PROJECT_ID_IN_SNAPSHOTS_DELETIONS_AND_REPO_CLEANUP = TransportVersion.fromName(
36+
"project_id_in_snapshots_deletions_and_repo_cleanup"
37+
);
38+
3739
private final List<Entry> entries;
3840

3941
public static RepositoryCleanupInProgress get(ClusterState state) {
@@ -114,7 +116,7 @@ public TransportVersion getMinimalSupportedVersion() {
114116
public record Entry(ProjectId projectId, String repository, long repositoryStateId) implements Writeable, RepositoryOperation {
115117

116118
public static Entry readFrom(StreamInput in) throws IOException {
117-
final ProjectId projectId = in.getTransportVersion().onOrAfter(PROJECT_ID_IN_SNAPSHOTS_DELETIONS_AND_REPO_CLEANUP)
119+
final ProjectId projectId = in.getTransportVersion().supports(PROJECT_ID_IN_SNAPSHOTS_DELETIONS_AND_REPO_CLEANUP)
118120
? ProjectId.readFrom(in)
119121
: ProjectId.DEFAULT;
120122
return new Entry(projectId, in.readString(), in.readLong());
@@ -137,7 +139,7 @@ public String repository() {
137139

138140
@Override
139141
public void writeTo(StreamOutput out) throws IOException {
140-
if (out.getTransportVersion().onOrAfter(PROJECT_ID_IN_SNAPSHOTS_DELETIONS_AND_REPO_CLEANUP)) {
142+
if (out.getTransportVersion().supports(PROJECT_ID_IN_SNAPSHOTS_DELETIONS_AND_REPO_CLEANUP)) {
141143
projectId.writeTo(out);
142144
} else {
143145
if (ProjectId.DEFAULT.equals(projectId) == false) {

‎server/src/main/java/org/elasticsearch/cluster/SnapshotDeletionsInProgress.java‎

Lines changed: 6 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -33,8 +33,6 @@
3333
import java.util.List;
3434
import java.util.Set;
3535

36-
import static org.elasticsearch.TransportVersions.PROJECT_ID_IN_SNAPSHOTS_DELETIONS_AND_REPO_CLEANUP;
37-
3836
/**
3937
* Represents the in-progress snapshot deletions in the cluster state.
4038
*/
@@ -44,6 +42,10 @@ public class SnapshotDeletionsInProgress extends AbstractNamedDiffable<Custom> i
4442

4543
public static final String TYPE = "snapshot_deletions";
4644

45+
private static final TransportVersion PROJECT_ID_IN_SNAPSHOTS_DELETIONS_AND_REPO_CLEANUP = TransportVersion.fromName(
46+
"project_id_in_snapshots_deletions_and_repo_cleanup"
47+
);
48+
4749
// the list of snapshot deletion request entries
4850
private final List<Entry> entries;
4951

@@ -246,7 +248,7 @@ public Entry(
246248

247249
@SuppressForbidden(reason = "using a private constructor within the same file")
248250
public static Entry readFrom(StreamInput in) throws IOException {
249-
final ProjectId projectId = in.getTransportVersion().onOrAfter(PROJECT_ID_IN_SNAPSHOTS_DELETIONS_AND_REPO_CLEANUP)
251+
final ProjectId projectId = in.getTransportVersion().supports(PROJECT_ID_IN_SNAPSHOTS_DELETIONS_AND_REPO_CLEANUP)
250252
? ProjectId.readFrom(in)
251253
: ProjectId.DEFAULT;
252254
return new Entry(
@@ -288,7 +290,7 @@ public Entry withRepoGen(long repoGen) {
288290

289291
@Override
290292
public void writeTo(StreamOutput out) throws IOException {
291-
if (out.getTransportVersion().onOrAfter(PROJECT_ID_IN_SNAPSHOTS_DELETIONS_AND_REPO_CLEANUP)) {
293+
if (out.getTransportVersion().supports(PROJECT_ID_IN_SNAPSHOTS_DELETIONS_AND_REPO_CLEANUP)) {
292294
projectId.writeTo(out);
293295
} else {
294296
if (ProjectId.DEFAULT.equals(projectId) == false) {

0 commit comments

Comments
 (0)