Skip to content

Commit

Permalink
Some docs
Browse files Browse the repository at this point in the history
  • Loading branch information
andreidan committed Dec 4, 2023
1 parent c8eb07c commit a1353f0
Showing 1 changed file with 8 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -62,6 +62,10 @@ public Request(StreamInput in) throws IOException {
this.diskHealthInfo = in.readOptionalWriteable(DiskHealthInfo::new);
this.dslHealthInfo = in.readOptionalWriteable(DataStreamLifecycleHealthInfo::new);
} else {
// BWC for pre-8.12 the disk health info was mandatory. Evolving this request has proven tricky however we've made use of
// waiting for all nodes to be on the {@link TransportVersions.HEALTH_INFO_ENRICHED_WITH_DSL_STATUS} transport version
// before sending any requests to update the health info that'd break the pre HEALTH_INFO_ENRICHED_WITH_DSL_STATUS
// transport invariant of always having a disk health information in the request
this.diskHealthInfo = new DiskHealthInfo(in);
this.dslHealthInfo = null;
}
Expand Down Expand Up @@ -92,6 +96,10 @@ public void writeTo(StreamOutput out) throws IOException {
out.writeOptionalWriteable(diskHealthInfo);
out.writeOptionalWriteable(dslHealthInfo);
} else {
// BWC for pre-8.12 the disk health info was mandatory. Evolving this request has proven tricky however we've made use of
// waiting for all nodes to be on the {@link TransportVersions.HEALTH_INFO_ENRICHED_WITH_DSL_STATUS} transport version
// before sending any requests to update the health info that'd break the pre HEALTH_INFO_ENRICHED_WITH_DSL_STATUS
// transport invariant of always having a disk health information in the request
diskHealthInfo.writeTo(out);
}
}
Expand Down

0 comments on commit a1353f0

Please sign in to comment.