Skip to content

Various fixes and improvements for recent Java and Jenkins versions #2

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
dwnusbaum wants to merge 3 commits into
base: master
Choose a base branch
from
Open

Various fixes and improvements for recent Java and Jenkins versions #2

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
c39ca8d
Update to standalone heaplib dependency
dwnusbaum Sep 10, 2025
471296a
https://github.com/jenkinsci/workflow-api-plugin/pull/370
dwnusbaum Sep 19, 2025
257bd6e
Print addresses as hex and include address of object related to Workf…
dwnusbaum Sep 19, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 2 additions & 2 deletions pom.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -7,8 +7,8 @@
<dependencies>
<dependency> <!-- https://github.com/aragozin/jvm-tools/tree/master/hprof-heap -->
<groupId>org.gridkit.jvmtool</groupId>
<artifactId>hprof-heap</artifactId>
<version>0.8.1</version>
<artifactId>heaplib</artifactId>
<version>0.2</version>
</dependency>
</dependencies>
<properties>
Expand Down
46 changes: 33 additions & 13 deletions src/main/java/Main.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -19,20 +19,33 @@ public static void main(String[] args) throws Exception {
Heap heap = HeapFactory.createFastHeap(dump);
System.err.println();
System.err.print("Looking for builds thought be running according to FlowExecutionList...");
JavaClass felC = heap.getJavaClassByName("org.jenkinsci.plugins.workflow.flow.FlowExecutionList");
List<Instance> fels = felC.getInstances();
if (fels.size() != 1) {
throw new IllegalStateException("unexpected FlowExecutionList count: " + fels);
Instance fel = null;
JavaClass feldsC = heap.getJavaClassByName("org.jenkinsci.plugins.workflow.flow.FlowExecutionList$DefaultStorage");
if (feldsC != null) {
List<Instance> feldss = feldsC.getInstances();
if (feldss.size() != 1) {
throw new IllegalStateException("unexpected FlowExecutionList$DefaultStorage count: " + feldss);
}
fel = feldss.get(0);
} else {
JavaClass felC = heap.getJavaClassByName("org.jenkinsci.plugins.workflow.flow.FlowExecutionList");
List<Instance> fels = felC.getInstances();
if (fels.size() != 1) {
throw new IllegalStateException("unexpected FlowExecutionList count: " + fels);
}
fel = fels.get(0);
}
if (fel == null) {
throw new IllegalStateException("FlowExecutionList custom storage not supported");
}
Instance fel = fels.get(0);
Instance list = HeapWalker.valueOf(fel, "runningTasks.core"); // ArrayList
ObjectArrayInstance elementsA = HeapWalker.valueOf(list, "elementData"); // TODO docs claim this would return Object[], but CONVERTERS does not actually do that
List<Instance> elements = elementsA.getValues();
int size = HeapWalker.valueOf(list, "size");
Set<Build> listed = new TreeSet<>();
for (int i = 0; i < size; i++) {
System.err.print(".");
Build b = Build.of(elements.get(i));
Build b = Build.of(elements.get(i), fel);
if (!listed.add(b)) {
System.err.print("(duplicated " + b + ")");
}
Expand All @@ -48,7 +61,7 @@ public static void main(String[] args) throws Exception {
if (owner == null) {
continue; // running something else, fine
}
Build b = Build.of(owner);
Build b = Build.of(owner, ooe);
if (listed.contains(b)) {
continue; // actually running, fine
}
Expand All @@ -64,7 +77,7 @@ public static void main(String[] args) throws Exception {
for (Instance ctg : heap.getJavaClassByName("org.jenkinsci.plugins.workflow.cps.CpsThreadGroup").getInstances()) {
System.err.print(".");
Instance owner = HeapWalker.valueOf(ctg, "execution.owner");
Build b = Build.of(owner);
Build b = Build.of(owner, ctg);
Integer scriptSize = HeapWalker.valueOf(ctg, "scripts.size"); // TreeMap
if (scriptSize == null) {
System.err.print("(possibly broken " + b + ")");
Expand Down Expand Up @@ -117,7 +130,7 @@ public static void main(String[] args) throws Exception {
Set<Build> leaked = new TreeSet<>();
for (Instance cgstl : heap.getJavaClassByName("org.jenkinsci.plugins.workflow.cps.CpsGroovyShell$TimingLoader").getInstances()) {
System.err.print(".");
Build b = Build.of(HeapWalker.valueOf(cgstl, "execution.owner"));
Build b = Build.of(HeapWalker.valueOf(cgstl, "execution.owner"), cgstl);
if (listed.contains(b)) {
continue; // actually running, fine
}
Expand All @@ -131,24 +144,31 @@ public static void main(String[] args) throws Exception {
leaked.forEach(System.err::println);
}
static class Build implements Comparable<Build> {
static Build of(Instance owner) { // WorkflowRun$Owner
static Build of(Instance owner, Instance related) { // WorkflowRun$Owner
Instance run = HeapWalker.valueOf(owner, "run");
return new Build(HeapWalker.valueOf(owner, "job"), Integer.parseInt(HeapWalker.valueOf(owner, "id")), run == null ? null : run.getInstanceId());
return new Build(
HeapWalker.valueOf(owner, "job"),
Integer.parseInt(HeapWalker.valueOf(owner, "id")),
run == null ? null : run.getInstanceId(),
related == null ? null : related.getInstanceId());
}
final String job;
final int num;
final Long id; // Heap address
Build(String job, int num, Long id) {
final Long relatedId; // Heap address of whatever object was used to find the WorkflowRun object
Build(String job, int num, Long id, Long relatedId) {
this.job = job;
this.num = num;
this.id = id;
this.relatedId = relatedId;
}
@Override public int compareTo(Build o) {
int c = job.compareTo(o.job);
return c != 0 ? c : num - o.num;
}
@Override public String toString() {
return job + " #" + num + (id == null ? "" : "@" + id);
String relatedString = relatedId == null ? "" : " (via: 0x" + Long.toHexString(relatedId) + ")";
return job + " #" + num + (id == null ? "" : "@0x" + Long.toHexString(id)) + relatedString;
}
@Override public int hashCode() {
return job.hashCode() ^ num;
Expand Down