public abstract class org.apache.zookeeper.server.command.AbstractFourLetterCommand extends java.lang.Object
{
private static final org.slf4j.Logger LOG;
public static final java.lang.String ZK_NOT_SERVING;
protected java.io.PrintWriter pw;
protected org.apache.zookeeper.server.ServerCnxn serverCnxn;
protected org.apache.zookeeper.server.ZooKeeperServer zkServer;
protected org.apache.zookeeper.server.ServerCnxnFactory factory;
public void <init>(java.io.PrintWriter, org.apache.zookeeper.server.ServerCnxn)
{
java.io.PrintWriter v;
org.apache.zookeeper.server.ServerCnxn v;
org.apache.zookeeper.server.command.AbstractFourLetterCommand v;
v := @this: org.apache.zookeeper.server.command.AbstractFourLetterCommand;
v := @parameter: java.io.PrintWriter;
v := @parameter: org.apache.zookeeper.server.ServerCnxn;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.zookeeper.server.command.AbstractFourLetterCommand: java.io.PrintWriter pw> = v;
v.<org.apache.zookeeper.server.command.AbstractFourLetterCommand: org.apache.zookeeper.server.ServerCnxn serverCnxn> = v;
return;
}
public void start()
{
org.apache.zookeeper.server.command.AbstractFourLetterCommand v;
v := @this: org.apache.zookeeper.server.command.AbstractFourLetterCommand;
virtualinvoke v.<org.apache.zookeeper.server.command.AbstractFourLetterCommand: void run()>();
return;
}
public void run()
{
java.io.PrintWriter v, v, v;
java.lang.Throwable v;
org.slf4j.Logger v;
java.io.IOException v;
org.apache.zookeeper.server.command.AbstractFourLetterCommand v;
org.apache.zookeeper.server.ServerCnxn v, v, v;
v := @this: org.apache.zookeeper.server.command.AbstractFourLetterCommand;
label:
virtualinvoke v.<org.apache.zookeeper.server.command.AbstractFourLetterCommand: void commandRun()>();
label:
v = v.<org.apache.zookeeper.server.command.AbstractFourLetterCommand: org.apache.zookeeper.server.ServerCnxn serverCnxn>;
v = v.<org.apache.zookeeper.server.command.AbstractFourLetterCommand: java.io.PrintWriter pw>;
virtualinvoke v.<org.apache.zookeeper.server.ServerCnxn: void cleanupWriterSocket(java.io.PrintWriter)>(v);
goto label;
label:
v := @caughtexception;
v = <org.apache.zookeeper.server.command.AbstractFourLetterCommand: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Throwable)>("Error in running command ", v);
label:
v = v.<org.apache.zookeeper.server.command.AbstractFourLetterCommand: org.apache.zookeeper.server.ServerCnxn serverCnxn>;
v = v.<org.apache.zookeeper.server.command.AbstractFourLetterCommand: java.io.PrintWriter pw>;
virtualinvoke v.<org.apache.zookeeper.server.ServerCnxn: void cleanupWriterSocket(java.io.PrintWriter)>(v);
goto label;
label:
v := @caughtexception;
v = v.<org.apache.zookeeper.server.command.AbstractFourLetterCommand: org.apache.zookeeper.server.ServerCnxn serverCnxn>;
v = v.<org.apache.zookeeper.server.command.AbstractFourLetterCommand: java.io.PrintWriter pw>;
virtualinvoke v.<org.apache.zookeeper.server.ServerCnxn: void cleanupWriterSocket(java.io.PrintWriter)>(v);
throw v;
label:
return;
catch java.io.IOException from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
}
public void setZkServer(org.apache.zookeeper.server.ZooKeeperServer)
{
org.apache.zookeeper.server.ZooKeeperServer v;
org.apache.zookeeper.server.command.AbstractFourLetterCommand v;
v := @this: org.apache.zookeeper.server.command.AbstractFourLetterCommand;
v := @parameter: org.apache.zookeeper.server.ZooKeeperServer;
v.<org.apache.zookeeper.server.command.AbstractFourLetterCommand: org.apache.zookeeper.server.ZooKeeperServer zkServer> = v;
return;
}
boolean isZKServerRunning()
{
org.apache.zookeeper.server.ZooKeeperServer v, v;
org.apache.zookeeper.server.command.AbstractFourLetterCommand v;
boolean v, v;
v := @this: org.apache.zookeeper.server.command.AbstractFourLetterCommand;
v = v.<org.apache.zookeeper.server.command.AbstractFourLetterCommand: org.apache.zookeeper.server.ZooKeeperServer zkServer>;
if v == null goto label;
v = v.<org.apache.zookeeper.server.command.AbstractFourLetterCommand: org.apache.zookeeper.server.ZooKeeperServer zkServer>;
v = virtualinvoke v.<org.apache.zookeeper.server.ZooKeeperServer: boolean isRunning()>();
if v == 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public void setFactory(org.apache.zookeeper.server.ServerCnxnFactory)
{
org.apache.zookeeper.server.ServerCnxnFactory v;
org.apache.zookeeper.server.command.AbstractFourLetterCommand v;
v := @this: org.apache.zookeeper.server.command.AbstractFourLetterCommand;
v := @parameter: org.apache.zookeeper.server.ServerCnxnFactory;
v.<org.apache.zookeeper.server.command.AbstractFourLetterCommand: org.apache.zookeeper.server.ServerCnxnFactory factory> = v;
return;
}
public abstract void commandRun() throws java.io.IOException;
static void <clinit>()
{
org.slf4j.Logger v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Lorg/apache/zookeeper/server/command/AbstractFourLetterCommand;");
<org.apache.zookeeper.server.command.AbstractFourLetterCommand: org.slf4j.Logger LOG> = v;
return;
}
}