Add transport version

Author: ankikuma

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

@@ -219,6 +219,7 @@ static TransportVersion def(int id) {
     public static final TransportVersion REPO_ANALYSIS_COPY_BLOB = def(9_048_00_0);
     public static final TransportVersion AMAZON_BEDROCK_TASK_SETTINGS = def(9_049_00_0);
     public static final TransportVersion ESQL_REPORT_SHARD_PARTITIONING = def(9_050_00_0);
+    public static final TransportVersion WRITE_LOAD_INCLUDES_BUFFER_WRITES = def(9_051_00_0);
 
     /*
      * STOP! READ THIS FIRST! No, really,

server/src/main/java/org/elasticsearch/index/shard/IndexingStats.java

@@ -27,6 +27,7 @@
 
 import static org.elasticsearch.TransportVersions.INDEXING_STATS_INCLUDES_RECENT_WRITE_LOAD;
 import static org.elasticsearch.TransportVersions.INDEX_STATS_AND_METADATA_INCLUDE_PEAK_WRITE_LOAD;
+import static org.elasticsearch.TransportVersions.WRITE_LOAD_INCLUDES_BUFFER_WRITES;
 
 public class IndexingStats implements Writeable, ToXContentFragment {
 
@@ -76,7 +77,7 @@ public Stats(StreamInput in) throws IOException {
                 // When getting stats from an older version which doesn't have the recent indexing load, better to fall back to the
                 // unweighted write load, rather that assuming zero load:
                 recentIndexingLoad = totalActiveTimeInNanos > 0
-                    ? (double) totalIndexingLoadSinceShardStartedInNanos / totalActiveTimeInNanos
+                    ? (double) totalIndexingTimeSinceShardStartedInNanos / totalActiveTimeInNanos
                     : 0;
             }
             if (in.getTransportVersion().onOrAfter(INDEX_STATS_AND_METADATA_INCLUDE_PEAK_WRITE_LOAD)) {
@@ -88,6 +89,13 @@ public Stats(StreamInput in) throws IOException {
                     ? (double) totalIndexingTimeSinceShardStartedInNanos / totalActiveTimeInNanos
                     : 0;
             }
+            if (in.getTransportVersion().onOrAfter(WRITE_LOAD_INCLUDES_BUFFER_WRITES)) {
+                totalIndexingLoadSinceShardStartedInNanos = in.readLong();
+            } else {
+                // When getting stats from an older version which doesn't have the more accurate indexing load, better to fall back to the
+                // indexing time, rather that assuming zero load:
+                totalIndexingLoadSinceShardStartedInNanos = totalActiveTimeInNanos > 0 ? totalIndexingTimeSinceShardStartedInNanos : 0;
+            }
         }
 
         public Stats(
@@ -300,6 +308,9 @@ public void writeTo(StreamOutput out) throws IOException {
             if (out.getTransportVersion().onOrAfter(INDEX_STATS_AND_METADATA_INCLUDE_PEAK_WRITE_LOAD)) {
                 out.writeDouble(peakIndexingLoad);
             }
+            if (out.getTransportVersion().onOrAfter(WRITE_LOAD_INCLUDES_BUFFER_WRITES)) {
+                out.writeLong(totalIndexingLoadSinceShardStartedInNanos);
+            }
         }
 
         @Override