Skip to content

Commit

Permalink
Add todos to update version
Browse files Browse the repository at this point in the history
Signed-off-by: Lakshya Taragi <[email protected]>
  • Loading branch information
ltaragi committed Sep 23, 2024
1 parent fd373da commit a706f7d
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -247,6 +247,7 @@ public NodeStats(StreamInput in) throws IOException {
} else {
nodeCacheStats = null;
}
// TODO: change version to V_2_18_0
if (in.getVersion().onOrAfter(Version.CURRENT)) {
remoteStoreNodeStats = in.readOptionalWriteable(RemoteStoreNodeStats::new);
} else {
Expand Down Expand Up @@ -541,6 +542,7 @@ public void writeTo(StreamOutput out) throws IOException {
if (out.getVersion().onOrAfter(Version.V_2_14_0)) {
out.writeOptionalWriteable(nodeCacheStats);
}
// TODO: change version to V_2_18_0
if (out.getVersion().onOrAfter(Version.CURRENT)) {
out.writeOptionalWriteable(remoteStoreNodeStats);
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -41,13 +41,15 @@ public long getLastSuccessfulFetchOfPinnedTimestamps() {
}

public RemoteStoreNodeStats(StreamInput in) throws IOException {
// TODO: change version to V_2_18_0
if (in.getVersion().onOrAfter(Version.CURRENT) && RemoteStoreSettings.isPinnedTimestampsEnabled()) {
this.lastSuccessfulFetchOfPinnedTimestamps = in.readOptionalLong();
}
}

@Override
public void writeTo(StreamOutput out) throws IOException {
// TODO: change version to V_2_18_0
if (out.getVersion().onOrAfter(Version.CURRENT) && RemoteStoreSettings.isPinnedTimestampsEnabled()) {
out.writeOptionalLong(this.lastSuccessfulFetchOfPinnedTimestamps);
}
Expand Down

0 comments on commit a706f7d

Please sign in to comment.