Skip to content

Commit 9c82443

Browse files
initialize TransportVersion statically
1 parent 3578515 commit 9c82443

File tree

3 files changed

+7
-8
lines changed

3 files changed

+7
-8
lines changed

server/src/main/java/org/elasticsearch/monitor/os/OsStats.java

Lines changed: 5 additions & 6 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.common.io.stream.StreamInput;
1716
import org.elasticsearch.common.io.stream.StreamOutput;
1817
import org.elasticsearch.common.io.stream.Writeable;
@@ -120,7 +119,9 @@ public XContentBuilder toXContent(XContentBuilder builder, Params params) throws
120119

121120
public static class Cpu implements Writeable, ToXContentFragment {
122121

123-
private static final String AVAILABLE_PROCESSORS_TRANSPORT_VERSION = "available_processors_in_os_stats";
122+
private static final TransportVersion AVAILABLE_PROCESSORS_TRANSPORT_VERSION = TransportVersion.fromName(
123+
"available_processors_in_os_stats"
124+
);
124125

125126
private final short percent;
126127
private final double[] loadAverage;
@@ -139,9 +140,7 @@ public Cpu(StreamInput in) throws IOException {
139140
} else {
140141
this.loadAverage = null;
141142
}
142-
this.availableProcessors = in.getTransportVersion().supports(TransportVersion.fromName(AVAILABLE_PROCESSORS_TRANSPORT_VERSION))
143-
? in.readInt()
144-
: 0;
143+
this.availableProcessors = in.getTransportVersion().supports(AVAILABLE_PROCESSORS_TRANSPORT_VERSION) ? in.readInt() : 0;
145144
}
146145

147146
@Override
@@ -153,7 +152,7 @@ public void writeTo(StreamOutput out) throws IOException {
153152
out.writeBoolean(true);
154153
out.writeDoubleArray(loadAverage);
155154
}
156-
if (out.getTransportVersion().supports(TransportVersion.fromName(AVAILABLE_PROCESSORS_TRANSPORT_VERSION))) {
155+
if (out.getTransportVersion().supports(AVAILABLE_PROCESSORS_TRANSPORT_VERSION)) {
157156
out.writeInt(availableProcessors);
158157
}
159158
}
Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1 +1 @@
1-
9191000
1+
9192000
Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1 +1 @@
1-
add_cross_cluster_api_key_signature,9191000
1+
available_processors_in_os_stats,9192000

0 commit comments

Comments
 (0)