class org.apache.kafkaesqueesqueesque.common.utils.Shell$ShellTimeoutTimerTask extends java.util.TimerTask
{
private final org.apache.kafkaesqueesqueesque.common.utils.Shell shell;
public void <init>(org.apache.kafkaesqueesqueesque.common.utils.Shell)
{
org.apache.kafkaesqueesqueesque.common.utils.Shell$ShellTimeoutTimerTask v;
org.apache.kafkaesqueesqueesque.common.utils.Shell v;
v := @this: org.apache.kafkaesqueesqueesque.common.utils.Shell$ShellTimeoutTimerTask;
v := @parameter: org.apache.kafkaesqueesqueesque.common.utils.Shell;
specialinvoke v.<java.util.TimerTask: void <init>()>();
v.<org.apache.kafkaesqueesqueesque.common.utils.Shell$ShellTimeoutTimerTask: org.apache.kafkaesqueesqueesque.common.utils.Shell shell> = v;
return;
}
public void run()
{
org.apache.kafkaesqueesqueesque.common.utils.Shell$ShellTimeoutTimerTask v;
java.lang.Process v;
org.apache.kafkaesqueesqueesque.common.utils.Shell v, v;
java.util.concurrent.atomic.AtomicBoolean v;
java.lang.Exception v;
boolean v;
v := @this: org.apache.kafkaesqueesqueesque.common.utils.Shell$ShellTimeoutTimerTask;
v = v.<org.apache.kafkaesqueesqueesque.common.utils.Shell$ShellTimeoutTimerTask: org.apache.kafkaesqueesqueesque.common.utils.Shell shell>;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.utils.Shell: java.lang.Process process()>();
label:
virtualinvoke v.<java.lang.Process: int exitValue()>();
label:
goto label;
label:
v := @caughtexception;
if v == null goto label;
v = v.<org.apache.kafkaesqueesqueesque.common.utils.Shell$ShellTimeoutTimerTask: org.apache.kafkaesqueesqueesque.common.utils.Shell shell>;
v = v.<org.apache.kafkaesqueesqueesque.common.utils.Shell: java.util.concurrent.atomic.AtomicBoolean completed>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: boolean get()>();
if v != 0 goto label;
virtualinvoke v.<java.lang.Process: void destroy()>();
label:
return;
catch java.lang.Exception from label to label with label;
}
}