Package org.apache.cassandra.utils

Class JVMStabilityInspector

java.lang.Object

org.apache.cassandra.utils.JVMStabilityInspector

public final class JVMStabilityInspector
extends Object

Responsible for deciding whether to kill the JVM if it gets in an "unstable" state (think OOM).

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	JVMStabilityInspector.Killer
static interface	JVMStabilityInspector.OnKillHook	This class is usually used to avoid JVM exit when running junit tests.

Field Summary

Fields

Modifier and Type	Field	Description
static JVMStabilityInspector.OnKillHook	killerHook

Method Summary

Modifier and Type	Method	Description
static void	inspectCommitLogThrowable(Throwable t)
static void	inspectThrowable(Throwable t)	Certain Throwables and Exceptions represent "Die" conditions for the server.
static void	inspectThrowable(Throwable t, Consumer<Throwable> fn, boolean isUncaughtException)
static void	killCurrentJVM(Throwable t, boolean quiet)
static JVMStabilityInspector.Killer	replaceKiller(JVMStabilityInspector.Killer newKiller)
static void	uncaughtException(Thread thread, Throwable t)
static void	userFunctionTimeout(Throwable t)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

killerHook

public static JVMStabilityInspector.OnKillHook killerHook

Method Details

uncaughtException

public static void uncaughtException(Thread thread,
 Throwable t)

inspectThrowable

public static void inspectThrowable(Throwable t)
                             throws OutOfMemoryError

Certain Throwables and Exceptions represent "Die" conditions for the server. This recursively checks the input Throwable's cause hierarchy until null.

Parameters:

t - The Throwable to check for server-stop conditions

Throws:

OutOfMemoryError

inspectCommitLogThrowable

public static void inspectCommitLogThrowable(Throwable t)

inspectThrowable

public static void inspectThrowable(Throwable t,
 Consumer<Throwable> fn,
 boolean isUncaughtException)
                             throws OutOfMemoryError

Throws:

OutOfMemoryError

killCurrentJVM

public static void killCurrentJVM(Throwable t,
 boolean quiet)

userFunctionTimeout

public static void userFunctionTimeout(Throwable t)

replaceKiller

public static JVMStabilityInspector.Killer replaceKiller(JVMStabilityInspector.Killer newKiller)