diff options
author | Luck <git@lucko.me> | 2024-09-08 17:36:41 +0100 |
---|---|---|
committer | Luck <git@lucko.me> | 2024-09-08 17:36:41 +0100 |
commit | f06de5761a5dee3c809ab9c6ebae6f052c55f7eb (patch) | |
tree | 6ca475910de3ffabbeb4cf28fc15fec8e31eb8fe /spark-common/src | |
parent | 8986c711cef445650ceef832a3ac999819cd06a0 (diff) | |
download | spark-f06de5761a5dee3c809ab9c6ebae6f052c55f7eb.tar.gz spark-f06de5761a5dee3c809ab9c6ebae6f052c55f7eb.tar.bz2 spark-f06de5761a5dee3c809ab9c6ebae6f052c55f7eb.zip |
Include memory stats in ws updates
Diffstat (limited to 'spark-common/src')
-rw-r--r-- | spark-common/src/main/java/me/lucko/spark/common/platform/PlatformStatisticsProvider.java | 38 |
1 files changed, 18 insertions, 20 deletions
diff --git a/spark-common/src/main/java/me/lucko/spark/common/platform/PlatformStatisticsProvider.java b/spark-common/src/main/java/me/lucko/spark/common/platform/PlatformStatisticsProvider.java index a17c924..e8401fc 100644 --- a/spark-common/src/main/java/me/lucko/spark/common/platform/PlatformStatisticsProvider.java +++ b/spark-common/src/main/java/me/lucko/spark/common/platform/PlatformStatisticsProvider.java @@ -146,34 +146,32 @@ public class PlatformStatisticsProvider { return builder.build(); } - public PlatformStatistics getPlatformStatistics(Map<String, GarbageCollectorStatistics> startingGcStatistics, boolean detailed) { + public PlatformStatistics getPlatformStatistics(Map<String, GarbageCollectorStatistics> startingGcStatistics, boolean includeWorldStatistics) { PlatformStatistics.Builder builder = PlatformStatistics.newBuilder(); PlatformStatistics.Memory.Builder memory = PlatformStatistics.Memory.newBuilder() .setHeap(memoryUsageProto(ManagementFactory.getMemoryMXBean().getHeapMemoryUsage())) .setNonHeap(memoryUsageProto(ManagementFactory.getMemoryMXBean().getNonHeapMemoryUsage())); - if (detailed) { - List<MemoryPoolMXBean> memoryPoolMXBeans = ManagementFactory.getMemoryPoolMXBeans(); - for (MemoryPoolMXBean memoryPool : memoryPoolMXBeans) { - if (memoryPool.getType() != MemoryType.HEAP) { - continue; - } + List<MemoryPoolMXBean> memoryPoolMXBeans = ManagementFactory.getMemoryPoolMXBeans(); + for (MemoryPoolMXBean memoryPool : memoryPoolMXBeans) { + if (memoryPool.getType() != MemoryType.HEAP) { + continue; + } - MemoryUsage usage = memoryPool.getUsage(); - MemoryUsage collectionUsage = memoryPool.getCollectionUsage(); + MemoryUsage usage = memoryPool.getUsage(); + MemoryUsage collectionUsage = memoryPool.getCollectionUsage(); - if (usage.getMax() == -1) { - usage = new MemoryUsage(usage.getInit(), usage.getUsed(), usage.getCommitted(), usage.getCommitted()); - } - - memory.addPools(PlatformStatistics.Memory.MemoryPool.newBuilder() - .setName(memoryPool.getName()) - .setUsage(memoryUsageProto(usage)) - .setCollectionUsage(memoryUsageProto(collectionUsage)) - .build() - ); + if (usage.getMax() == -1) { + usage = new MemoryUsage(usage.getInit(), usage.getUsed(), usage.getCommitted(), usage.getCommitted()); } + + memory.addPools(PlatformStatistics.Memory.MemoryPool.newBuilder() + .setName(memoryPool.getName()) + .setUsage(memoryUsageProto(usage)) + .setCollectionUsage(memoryUsageProto(collectionUsage)) + .build() + ); } builder.setMemory(memory.build()); @@ -240,7 +238,7 @@ public class PlatformStatisticsProvider { : PlatformStatistics.OnlineMode.OFFLINE ); - if (detailed) { + if (includeWorldStatistics) { try { WorldStatisticsProvider worldStatisticsProvider = new WorldStatisticsProvider( new AsyncWorldInfoProvider(this.platform, this.platform.getPlugin().createWorldInfoProvider()) |