Change version check from Version.CURRENT to Version.V_3_0_0

Signed-off-by: Bhumika Saini <[email protected]>
opensearch-project · Oct 11, 2023 · a0323f8 · a0323f8
1 parent 86ba32a
commit a0323f8
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 5 deletions.
diff --git a/server/src/main/java/org/opensearch/index/ReplicationStats.java b/server/src/main/java/org/opensearch/index/ReplicationStats.java
@@ -47,7 +47,7 @@ public ReplicationStats(StreamInput in) throws IOException {
         this.totalBytesBehind = in.readVLong();
         this.maxReplicationLag = in.readVLong();
         // TODO: change to V_2_11_0 on main after backport to 2.x
-        if (in.getVersion().onOrAfter(Version.CURRENT)) {
+        if (in.getVersion().onOrAfter(Version.V_3_0_0)) {
             this.totalRejections = in.readVLong();
             this.shardId = in.readOptionalWriteable(ShardId::new);
         }
@@ -62,7 +62,6 @@ public void add(ReplicationStats other) {
             maxBytesBehind = Math.max(other.maxBytesBehind, maxBytesBehind);
             totalBytesBehind += other.totalBytesBehind;
             maxReplicationLag = Math.max(other.maxReplicationLag, maxReplicationLag);
-            // TODO
             if (this.shardId != other.shardId) {
                 totalRejections += other.totalRejections;
             }
@@ -91,7 +90,7 @@ public void writeTo(StreamOutput out) throws IOException {
         out.writeVLong(totalBytesBehind);
         out.writeVLong(maxReplicationLag);
         // TODO: change to V_2_11_0 on main after backport to 2.x
-        if (out.getVersion().onOrAfter(Version.CURRENT)) {
+        if (out.getVersion().onOrAfter(Version.V_3_0_0)) {
             out.writeVLong(totalRejections);
             out.writeOptionalWriteable(shardId);
         }

diff --git a/server/src/main/java/org/opensearch/index/remote/RemoteSegmentStats.java b/server/src/main/java/org/opensearch/index/remote/RemoteSegmentStats.java
@@ -96,7 +96,7 @@ public RemoteSegmentStats(StreamInput in) throws IOException {
         totalUploadTime = in.readLong();
         totalDownloadTime = in.readLong();
         // TODO: change to V_2_11_0 on main after backport to 2.x
-        if (in.getVersion().onOrAfter(Version.CURRENT)) {
+        if (in.getVersion().onOrAfter(Version.V_3_0_0)) {
             totalRejections = in.readVLong();
         }
     }
@@ -261,7 +261,7 @@ public void writeTo(StreamOutput out) throws IOException {
         out.writeLong(totalUploadTime);
         out.writeLong(totalDownloadTime);
         // TODO: change to V_2_11_0 on main after backport to 2.x
-        if (out.getVersion().onOrAfter(Version.CURRENT)) {
+        if (out.getVersion().onOrAfter(Version.V_3_0_0)) {
             out.writeVLong(totalRejections);
         }
     }