diff options
author | Luck <git@lucko.me> | 2024-07-29 22:54:12 +0100 |
---|---|---|
committer | Luck <git@lucko.me> | 2024-07-29 22:54:12 +0100 |
commit | 1fb00b191cb3efd5b44d18fd2730ac6683626d67 (patch) | |
tree | 04d02538d8afbf9e9867c81e3768ebe4bc66c5d0 /spark-common/src/test/java/me/lucko/spark/common/heapdump | |
parent | 6e7cc883d2d716bfcfcf871956f2acb995474d2d (diff) | |
download | spark-1fb00b191cb3efd5b44d18fd2730ac6683626d67.tar.gz spark-1fb00b191cb3efd5b44d18fd2730ac6683626d67.tar.bz2 spark-1fb00b191cb3efd5b44d18fd2730ac6683626d67.zip |
Add more automated tests
Diffstat (limited to 'spark-common/src/test/java/me/lucko/spark/common/heapdump')
-rw-r--r-- | spark-common/src/test/java/me/lucko/spark/common/heapdump/HeapDumpSummaryTest.java | 18 |
1 files changed, 17 insertions, 1 deletions
diff --git a/spark-common/src/test/java/me/lucko/spark/common/heapdump/HeapDumpSummaryTest.java b/spark-common/src/test/java/me/lucko/spark/common/heapdump/HeapDumpSummaryTest.java index 42492d1..b2bb384 100644 --- a/spark-common/src/test/java/me/lucko/spark/common/heapdump/HeapDumpSummaryTest.java +++ b/spark-common/src/test/java/me/lucko/spark/common/heapdump/HeapDumpSummaryTest.java @@ -20,9 +20,14 @@ package me.lucko.spark.common.heapdump; +import me.lucko.spark.proto.SparkHeapProtos; import me.lucko.spark.test.TestClass; +import me.lucko.spark.test.plugin.TestCommandSender; +import me.lucko.spark.test.plugin.TestSparkPlugin; import org.junit.jupiter.api.Test; +import org.junit.jupiter.api.io.TempDir; +import java.nio.file.Path; import java.util.List; import static org.junit.jupiter.api.Assertions.assertEquals; @@ -31,7 +36,7 @@ import static org.junit.jupiter.api.Assertions.assertNotNull; public class HeapDumpSummaryTest { @Test - public void testHeapDumpSummary() throws Exception { + public void testHeapDumpSummary(@TempDir Path directory) throws Exception { TestClass testClass1 = new TestClass(); TestClass testClass2 = new TestClass(); @@ -42,6 +47,17 @@ public class HeapDumpSummaryTest { assertNotNull(thisClassEntry); assertEquals(2, thisClassEntry.getInstances()); assertEquals(32, thisClassEntry.getBytes()); + + SparkHeapProtos.HeapData proto; + try (TestSparkPlugin plugin = new TestSparkPlugin(directory)) { + proto = dump.toProto(plugin.platform(), TestCommandSender.INSTANCE.toData()); + } + assertNotNull(proto); + + SparkHeapProtos.HeapEntry protoEntry = proto.getEntriesList().stream().filter(entry -> entry.getType().equals(TestClass.class.getName())).findAny().orElse(null); + assertNotNull(protoEntry); + assertEquals(2, protoEntry.getInstances()); + assertEquals(32, protoEntry.getSize()); } } |