public class org.apache.zookeeper.server.quorum.LeaderRequestProcessor extends java.lang.Object implements org.apache.zookeeper.server.RequestProcessor
{
private static final org.slf4j.Logger LOG;
private final org.apache.zookeeper.server.quorum.LeaderZooKeeperServer lzks;
private final org.apache.zookeeper.server.RequestProcessor nextProcessor;
public void <init>(org.apache.zookeeper.server.quorum.LeaderZooKeeperServer, org.apache.zookeeper.server.RequestProcessor)
{
org.apache.zookeeper.server.quorum.LeaderRequestProcessor v;
org.apache.zookeeper.server.quorum.LeaderZooKeeperServer v;
org.apache.zookeeper.server.RequestProcessor v;
v := @this: org.apache.zookeeper.server.quorum.LeaderRequestProcessor;
v := @parameter: org.apache.zookeeper.server.quorum.LeaderZooKeeperServer;
v := @parameter: org.apache.zookeeper.server.RequestProcessor;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.zookeeper.server.quorum.LeaderRequestProcessor: org.apache.zookeeper.server.quorum.LeaderZooKeeperServer lzks> = v;
v.<org.apache.zookeeper.server.quorum.LeaderRequestProcessor: org.apache.zookeeper.server.RequestProcessor nextProcessor> = v;
return;
}
public void processRequest(org.apache.zookeeper.server.Request) throws org.apache.zookeeper.server.RequestProcessor$RequestProcessorException
{
org.apache.zookeeper.server.quorum.LeaderRequestProcessor v;
org.apache.zookeeper.KeeperException$Code v;
int v, v;
org.apache.zookeeper.server.RequestProcessor v, v;
boolean v;
org.slf4j.Logger v, v, v;
org.apache.zookeeper.KeeperException v;
java.io.IOException v;
org.apache.zookeeper.txn.TxnHeader v, v;
org.apache.zookeeper.server.Request v, v;
org.apache.zookeeper.server.quorum.LeaderZooKeeperServer v, v;
org.apache.zookeeper.txn.ErrorTxn v;
v := @this: org.apache.zookeeper.server.quorum.LeaderRequestProcessor;
v := @parameter: org.apache.zookeeper.server.Request;
v = v.<org.apache.zookeeper.server.quorum.LeaderRequestProcessor: org.apache.zookeeper.server.quorum.LeaderZooKeeperServer lzks>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.LeaderZooKeeperServer: boolean authWriteRequest(org.apache.zookeeper.server.Request)>(v);
if v != 0 goto label;
return;
label:
v = null;
label:
v = v.<org.apache.zookeeper.server.quorum.LeaderRequestProcessor: org.apache.zookeeper.server.quorum.LeaderZooKeeperServer lzks>;
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.LeaderZooKeeperServer: org.apache.zookeeper.server.Request checkUpgradeSession(org.apache.zookeeper.server.Request)>(v);
label:
goto label;
label:
v := @caughtexception;
v = virtualinvoke v.<org.apache.zookeeper.server.Request: org.apache.zookeeper.txn.TxnHeader getHdr()>();
if v == null goto label;
v = <org.apache.zookeeper.server.quorum.LeaderRequestProcessor: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>("Updating header");
v = virtualinvoke v.<org.apache.zookeeper.server.Request: org.apache.zookeeper.txn.TxnHeader getHdr()>();
v = (int) -1;
virtualinvoke v.<org.apache.zookeeper.txn.TxnHeader: void setType(int)>(v);
v = new org.apache.zookeeper.txn.ErrorTxn;
v = virtualinvoke v.<org.apache.zookeeper.KeeperException: org.apache.zookeeper.KeeperException$Code code()>();
v = virtualinvoke v.<org.apache.zookeeper.KeeperException$Code: int intValue()>();
specialinvoke v.<org.apache.zookeeper.txn.ErrorTxn: void <init>(int)>(v);
virtualinvoke v.<org.apache.zookeeper.server.Request: void setTxn(org.apache.jute.Record)>(v);
label:
virtualinvoke v.<org.apache.zookeeper.server.Request: void setException(org.apache.zookeeper.KeeperException)>(v);
v = <org.apache.zookeeper.server.quorum.LeaderRequestProcessor: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String,java.lang.Throwable)>("Error creating upgrade request", v);
goto label;
label:
v := @caughtexception;
v = <org.apache.zookeeper.server.quorum.LeaderRequestProcessor: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Throwable)>("Unexpected error in upgrade", v);
label:
if v == null goto label;
v = v.<org.apache.zookeeper.server.quorum.LeaderRequestProcessor: org.apache.zookeeper.server.RequestProcessor nextProcessor>;
interfaceinvoke v.<org.apache.zookeeper.server.RequestProcessor: void processRequest(org.apache.zookeeper.server.Request)>(v);
label:
v = v.<org.apache.zookeeper.server.quorum.LeaderRequestProcessor: org.apache.zookeeper.server.RequestProcessor nextProcessor>;
interfaceinvoke v.<org.apache.zookeeper.server.RequestProcessor: void processRequest(org.apache.zookeeper.server.Request)>(v);
return;
catch org.apache.zookeeper.KeeperException from label to label with label;
catch java.io.IOException from label to label with label;
}
public void shutdown()
{
org.apache.zookeeper.server.quorum.LeaderRequestProcessor v;
org.slf4j.Logger v;
org.apache.zookeeper.server.RequestProcessor v;
v := @this: org.apache.zookeeper.server.quorum.LeaderRequestProcessor;
v = <org.apache.zookeeper.server.quorum.LeaderRequestProcessor: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>("Shutting down");
v = v.<org.apache.zookeeper.server.quorum.LeaderRequestProcessor: org.apache.zookeeper.server.RequestProcessor nextProcessor>;
interfaceinvoke v.<org.apache.zookeeper.server.RequestProcessor: void shutdown()>();
return;
}
static void <clinit>()
{
org.slf4j.Logger v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Lorg/apache/zookeeper/server/quorum/LeaderRequestProcessor;");
<org.apache.zookeeper.server.quorum.LeaderRequestProcessor: org.slf4j.Logger LOG> = v;
return;
}
}