Added stream serialization logic for new min/max file descriptors

Relates to elastic#4681
mute · Jan 10, 2014 · 861e44f · 861e44f
1 parent e979f9c
commit 861e44f
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/src/main/java/org/elasticsearch/action/admin/cluster/stats/ClusterStatsNodes.java b/src/main/java/org/elasticsearch/action/admin/cluster/stats/ClusterStatsNodes.java
@@ -448,13 +448,21 @@ public void readFrom(StreamInput in) throws IOException {
             count = in.readVInt();
             cpuPercent = in.readVInt();
             totalOpenFileDescriptors = in.readVLong();
+            if (in.getVersion().onOrAfter(Version.V_0_90_10)) {
+                minOpenFileDescriptors = in.readVLong();
+                maxOpenFileDescriptors = in.readVLong();
+            }
         }
 
         @Override
         public void writeTo(StreamOutput out) throws IOException {
             out.writeVInt(count);
             out.writeVInt(cpuPercent);
             out.writeVLong(totalOpenFileDescriptors);
+            if (out.getVersion().onOrAfter(Version.V_0_90_10)) {
+                out.writeVLong(minOpenFileDescriptors);
+                out.writeVLong(maxOpenFileDescriptors);
+            }
         }
 
         public static ProcessStats readStats(StreamInput in) throws IOException {