libre.sh/keycloak-scim
4
0
Fork 0
Code Issues 15 Pull requests Releases 1 Activity Actions

diagnostic: add a thread dump on failure (#29749)

Browse source 
Signed-off-by: Steve Hawkins <shawkins@redhat.com>
This commit is contained in:
Steven Hawkins 2024-05-21 12:22:11 -04:00 committed by GitHub
parent 97cd5f3b8d
commit a74b084d9d
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 30 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

31
operator/src/test/java/org/keycloak/operator/testsuite/integration/BaseOperatorTest.java
View file

@ -34,7 +34,9 @@ import io.fabric8.kubernetes.client.ConfigBuilder;
import io.fabric8.kubernetes.client.KubernetesClient;
import io.fabric8.kubernetes.client.KubernetesClientBuilder;
import io.fabric8.kubernetes.client.KubernetesClientException;
import io.fabric8.kubernetes.client.dsl.ExecWatch;
import io.fabric8.kubernetes.client.dsl.Loggable;
import io.fabric8.kubernetes.client.dsl.PodResource;
import io.fabric8.kubernetes.client.dsl.Resource;
import io.fabric8.kubernetes.client.utils.Serialization;
import io.javaoperatorsdk.operator.Operator;
@ -68,6 +70,7 @@ import org.keycloak.operator.crds.v2alpha1.realmimport.KeycloakRealmImport;
import org.keycloak.operator.testsuite.utils.K8sUtils;
import org.opentest4j.TestAbortedException;
import java.io.ByteArrayOutputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
@ -76,6 +79,7 @@ import java.lang.reflect.Method;
import java.net.HttpURLConnection;
import java.net.MalformedURLException;
import java.net.URL;
import java.nio.charset.StandardCharsets;
import java.time.Duration;
import java.util.Comparator;
import java.util.LinkedHashMap;
@ -401,11 +405,36 @@ public class BaseOperatorTest implements QuarkusTestAfterEachCallback {
if (statefulSet != null) {
Log.warnf("Keycloak \"%s\" StatefulSet status %s", kc.getMetadata().getName(), Serialization.asYaml(statefulSet.getStatus()));
k8sclient.pods().withLabels(statefulSet.getSpec().getSelector().getMatchLabels()).list()
.getItems().stream().forEach(pod -> logFailed(k8sclient.pods().resource(pod), Pod::getStatus));
.getItems().stream().map(pod -> k8sclient.pods().resource(pod)).forEach(p -> {
logFailed(p, Pod::getStatus);
threadDump(p);
});
}
});
}
private void threadDump(PodResource pr) {
int exitCode = -1;
Exception ex = null;
String output = null;
Pod pod = pr.item();
try {
ByteArrayOutputStream baos = new ByteArrayOutputStream();
ExecWatch execWatch = pr.writingOutput(baos).withReadyWaitTimeout(0).exec("sh", "-c", "jcmd 1 Thread.print");
exitCode = execWatch.exitCode().get(1, TimeUnit.MINUTES);
output = baos.toString(StandardCharsets.UTF_8);
if (exitCode == 0) {
Log.info("Thread dump for " + pod.getMetadata().getName() + ": " + output);
}
} catch (Exception e) {
ex = e;
}
if (exitCode != 0) {
Log.warn("A thread dump was not successful for " + pod.getMetadata().getName()
+ ", exit code " + exitCode + " output: " + output, ex);
}
}
private void logEvents() {
List<Event> recentEventList = k8sclient.resources(Event.class).list().getItems();