Skip to content

Commit cbd5adb

Browse files
committed
no need for volatile read
1 parent a193584 commit cbd5adb

File tree

1 file changed

+2
-4
lines changed

1 file changed

+2
-4
lines changed

server/src/main/java/org/elasticsearch/cluster/InternalClusterInfoService.java

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -471,10 +471,8 @@ private void callListeners() {
471471
}
472472

473473
private ClusterInfo updateAndGetCurrentClusterInfo() {
474-
final IndicesStatsSummary indicesStatsSummary = this.indicesStatsSummary; // single volatile read
475474
final Map<String, EstimatedHeapUsage> estimatedHeapUsages = new HashMap<>();
476-
final var currentMaxHeapPerNode = this.maxHeapPerNode; // Make sure we use a consistent view
477-
currentMaxHeapPerNode.forEach((nodeId, maxHeapSize) -> {
475+
maxHeapPerNode.forEach((nodeId, maxHeapSize) -> {
478476
final Long estimatedHeapUsage = estimatedHeapUsagePerNode.get(nodeId);
479477
if (estimatedHeapUsage != null) {
480478
estimatedHeapUsages.put(nodeId, new EstimatedHeapUsage(nodeId, maxHeapSize.getBytes(), estimatedHeapUsage));
@@ -490,7 +488,7 @@ private ClusterInfo updateAndGetCurrentClusterInfo() {
490488
estimatedHeapUsages,
491489
nodeThreadPoolUsageStatsPerNode,
492490
indicesStatsSummary.shardWriteLoads(),
493-
currentMaxHeapPerNode
491+
maxHeapPerNode
494492
);
495493
currentClusterInfo = newClusterInfo;
496494
return newClusterInfo;

0 commit comments

Comments
 (0)