public class org.apache.zookeeper.server.Request extends java.lang.Object
{
public static final org.apache.zookeeper.server.Request requestOfDeath;
private static volatile boolean staleConnectionCheck;
private static volatile boolean staleLatencyCheck;
public final long sessionId;
public final int cxid;
public final int type;
public final java.nio.ByteBuffer request;
public final org.apache.zookeeper.server.ServerCnxn cnxn;
private org.apache.zookeeper.txn.TxnHeader hdr;
private org.apache.jute.Record txn;
public long zxid;
public final java.util.List authInfo;
public final long createTime;
public long prepQueueStartTime;
public long prepStartTime;
public long commitProcQueueStartTime;
public long commitRecvTime;
public long syncQueueStartTime;
public long requestThrottleQueueTime;
private java.lang.Object owner;
private org.apache.zookeeper.KeeperException e;
public org.apache.zookeeper.server.quorum.flexible.QuorumVerifier qv;
private org.apache.zookeeper.txn.TxnDigest txnDigest;
private boolean isThrottledFlag;
private boolean isLocalSession;
private int largeRequestSize;
public void <init>(org.apache.zookeeper.server.ServerCnxn, long, int, int, java.nio.ByteBuffer, java.util.List)
{
long v, v;
java.nio.ByteBuffer v;
org.apache.zookeeper.server.Request v;
java.util.List v;
int v, v, v;
org.apache.zookeeper.server.ServerCnxn v;
v := @this: org.apache.zookeeper.server.Request;
v := @parameter: org.apache.zookeeper.server.ServerCnxn;
v := @parameter: long;
v := @parameter: int;
v := @parameter: int;
v := @parameter: java.nio.ByteBuffer;
v := @parameter: java.util.List;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.zookeeper.server.Request: long zxid> = -1L;
v = staticinvoke <org.apache.zookeeper.common.Time: long currentElapsedTime()>();
v.<org.apache.zookeeper.server.Request: long createTime> = v;
v.<org.apache.zookeeper.server.Request: long prepQueueStartTime> = -1L;
v.<org.apache.zookeeper.server.Request: long prepStartTime> = -1L;
v.<org.apache.zookeeper.server.Request: long commitProcQueueStartTime> = -1L;
v.<org.apache.zookeeper.server.Request: long commitRecvTime> = -1L;
v.<org.apache.zookeeper.server.Request: org.apache.zookeeper.server.quorum.flexible.QuorumVerifier qv> = null;
v.<org.apache.zookeeper.server.Request: boolean isThrottledFlag> = 0;
v.<org.apache.zookeeper.server.Request: boolean isLocalSession> = 0;
v = (int) -1;
v.<org.apache.zookeeper.server.Request: int largeRequestSize> = v;
v.<org.apache.zookeeper.server.Request: org.apache.zookeeper.server.ServerCnxn cnxn> = v;
v.<org.apache.zookeeper.server.Request: long sessionId> = v;
v.<org.apache.zookeeper.server.Request: int cxid> = v;
v.<org.apache.zookeeper.server.Request: int type> = v;
v.<org.apache.zookeeper.server.Request: java.nio.ByteBuffer request> = v;
v.<org.apache.zookeeper.server.Request: java.util.List authInfo> = v;
return;
}
public void <init>(long, int, int, org.apache.zookeeper.txn.TxnHeader, org.apache.jute.Record, long)
{
long v, v, v;
org.apache.jute.Record v;
org.apache.zookeeper.txn.TxnHeader v;
org.apache.zookeeper.server.Request v;
int v, v, v;
v := @this: org.apache.zookeeper.server.Request;
v := @parameter: long;
v := @parameter: int;
v := @parameter: int;
v := @parameter: org.apache.zookeeper.txn.TxnHeader;
v := @parameter: org.apache.jute.Record;
v := @parameter: long;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.zookeeper.server.Request: long zxid> = -1L;
v = staticinvoke <org.apache.zookeeper.common.Time: long currentElapsedTime()>();
v.<org.apache.zookeeper.server.Request: long createTime> = v;
v.<org.apache.zookeeper.server.Request: long prepQueueStartTime> = -1L;
v.<org.apache.zookeeper.server.Request: long prepStartTime> = -1L;
v.<org.apache.zookeeper.server.Request: long commitProcQueueStartTime> = -1L;
v.<org.apache.zookeeper.server.Request: long commitRecvTime> = -1L;
v.<org.apache.zookeeper.server.Request: org.apache.zookeeper.server.quorum.flexible.QuorumVerifier qv> = null;
v.<org.apache.zookeeper.server.Request: boolean isThrottledFlag> = 0;
v.<org.apache.zookeeper.server.Request: boolean isLocalSession> = 0;
v = (int) -1;
v.<org.apache.zookeeper.server.Request: int largeRequestSize> = v;
v.<org.apache.zookeeper.server.Request: long sessionId> = v;
v.<org.apache.zookeeper.server.Request: int cxid> = v;
v.<org.apache.zookeeper.server.Request: int type> = v;
v.<org.apache.zookeeper.server.Request: org.apache.zookeeper.txn.TxnHeader hdr> = v;
v.<org.apache.zookeeper.server.Request: org.apache.jute.Record txn> = v;
v.<org.apache.zookeeper.server.Request: long zxid> = v;
v.<org.apache.zookeeper.server.Request: java.nio.ByteBuffer request> = null;
v.<org.apache.zookeeper.server.Request: org.apache.zookeeper.server.ServerCnxn cnxn> = null;
v.<org.apache.zookeeper.server.Request: java.util.List authInfo> = null;
return;
}
public boolean isThrottled()
{
org.apache.zookeeper.server.Request v;
boolean v;
v := @this: org.apache.zookeeper.server.Request;
v = v.<org.apache.zookeeper.server.Request: boolean isThrottledFlag>;
return v;
}
public void setIsThrottled(boolean)
{
org.apache.zookeeper.server.Request v;
boolean v;
v := @this: org.apache.zookeeper.server.Request;
v := @parameter: boolean;
v.<org.apache.zookeeper.server.Request: boolean isThrottledFlag> = v;
return;
}
public boolean isThrottlable()
{
org.apache.zookeeper.server.Request v;
int v, v, v, v, v;
boolean v;
v := @this: org.apache.zookeeper.server.Request;
v = v.<org.apache.zookeeper.server.Request: int type>;
if v == 11 goto label;
v = v.<org.apache.zookeeper.server.Request: int type>;
v = (int) -11;
if v == v goto label;
v = v.<org.apache.zookeeper.server.Request: int type>;
v = (int) -10;
if v == v goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public boolean isLocalSession()
{
org.apache.zookeeper.server.Request v;
boolean v;
v := @this: org.apache.zookeeper.server.Request;
v = v.<org.apache.zookeeper.server.Request: boolean isLocalSession>;
return v;
}
public void setLocalSession(boolean)
{
org.apache.zookeeper.server.Request v;
boolean v;
v := @this: org.apache.zookeeper.server.Request;
v := @parameter: boolean;
v.<org.apache.zookeeper.server.Request: boolean isLocalSession> = v;
return;
}
public void setLargeRequestSize(int)
{
int v;
org.apache.zookeeper.server.Request v;
v := @this: org.apache.zookeeper.server.Request;
v := @parameter: int;
v.<org.apache.zookeeper.server.Request: int largeRequestSize> = v;
return;
}
public int getLargeRequestSize()
{
int v;
org.apache.zookeeper.server.Request v;
v := @this: org.apache.zookeeper.server.Request;
v = v.<org.apache.zookeeper.server.Request: int largeRequestSize>;
return v;
}
public java.lang.Object getOwner()
{
org.apache.zookeeper.server.Request v;
java.lang.Object v;
v := @this: org.apache.zookeeper.server.Request;
v = v.<org.apache.zookeeper.server.Request: java.lang.Object owner>;
return v;
}
public void setOwner(java.lang.Object)
{
org.apache.zookeeper.server.Request v;
java.lang.Object v;
v := @this: org.apache.zookeeper.server.Request;
v := @parameter: java.lang.Object;
v.<org.apache.zookeeper.server.Request: java.lang.Object owner> = v;
return;
}
public org.apache.zookeeper.txn.TxnHeader getHdr()
{
org.apache.zookeeper.server.Request v;
org.apache.zookeeper.txn.TxnHeader v;
v := @this: org.apache.zookeeper.server.Request;
v = v.<org.apache.zookeeper.server.Request: org.apache.zookeeper.txn.TxnHeader hdr>;
return v;
}
public void setHdr(org.apache.zookeeper.txn.TxnHeader)
{
org.apache.zookeeper.server.Request v;
org.apache.zookeeper.txn.TxnHeader v;
v := @this: org.apache.zookeeper.server.Request;
v := @parameter: org.apache.zookeeper.txn.TxnHeader;
v.<org.apache.zookeeper.server.Request: org.apache.zookeeper.txn.TxnHeader hdr> = v;
return;
}
public org.apache.jute.Record getTxn()
{
org.apache.zookeeper.server.Request v;
org.apache.jute.Record v;
v := @this: org.apache.zookeeper.server.Request;
v = v.<org.apache.zookeeper.server.Request: org.apache.jute.Record txn>;
return v;
}
public void setTxn(org.apache.jute.Record)
{
org.apache.zookeeper.server.Request v;
org.apache.jute.Record v;
v := @this: org.apache.zookeeper.server.Request;
v := @parameter: org.apache.jute.Record;
v.<org.apache.zookeeper.server.Request: org.apache.jute.Record txn> = v;
return;
}
public org.apache.zookeeper.server.ServerCnxn getConnection()
{
org.apache.zookeeper.server.Request v;
org.apache.zookeeper.server.ServerCnxn v;
v := @this: org.apache.zookeeper.server.Request;
v = v.<org.apache.zookeeper.server.Request: org.apache.zookeeper.server.ServerCnxn cnxn>;
return v;
}
public static boolean getStaleLatencyCheck()
{
boolean v;
v = <org.apache.zookeeper.server.Request: boolean staleLatencyCheck>;
return v;
}
public static void setStaleLatencyCheck(boolean)
{
boolean v;
v := @parameter: boolean;
<org.apache.zookeeper.server.Request: boolean staleLatencyCheck> = v;
return;
}
public static boolean getStaleConnectionCheck()
{
boolean v;
v = <org.apache.zookeeper.server.Request: boolean staleConnectionCheck>;
return v;
}
public static void setStaleConnectionCheck(boolean)
{
boolean v;
v := @parameter: boolean;
<org.apache.zookeeper.server.Request: boolean staleConnectionCheck> = v;
return;
}
public boolean isStale()
{
long v, v, v;
byte v;
int v, v, v;
org.apache.zookeeper.server.ServerCnxn v, v, v, v;
boolean v, v, v, v, v;
org.apache.zookeeper.server.Request v;
v := @this: org.apache.zookeeper.server.Request;
v = v.<org.apache.zookeeper.server.Request: org.apache.zookeeper.server.ServerCnxn cnxn>;
if v != null goto label;
return 0;
label:
v = v.<org.apache.zookeeper.server.Request: int type>;
v = (int) -11;
if v != v goto label;
return 0;
label:
v = <org.apache.zookeeper.server.Request: boolean staleConnectionCheck>;
if v == 0 goto label;
v = v.<org.apache.zookeeper.server.Request: org.apache.zookeeper.server.ServerCnxn cnxn>;
v = virtualinvoke v.<org.apache.zookeeper.server.ServerCnxn: boolean isStale()>();
if v != 0 goto label;
v = v.<org.apache.zookeeper.server.Request: org.apache.zookeeper.server.ServerCnxn cnxn>;
v = virtualinvoke v.<org.apache.zookeeper.server.ServerCnxn: boolean isInvalid()>();
if v == 0 goto label;
label:
return 1;
label:
v = <org.apache.zookeeper.server.Request: boolean staleLatencyCheck>;
if v == 0 goto label;
v = staticinvoke <org.apache.zookeeper.common.Time: long currentElapsedTime()>();
v = v.<org.apache.zookeeper.server.Request: long createTime>;
v = v - v;
v = v.<org.apache.zookeeper.server.Request: org.apache.zookeeper.server.ServerCnxn cnxn>;
v = virtualinvoke v.<org.apache.zookeeper.server.ServerCnxn: int getSessionTimeout()>();
v = v cmp v;
if v <= 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
label:
return 0;
}
public boolean mustDrop()
{
org.apache.zookeeper.server.Request v;
org.apache.zookeeper.server.ServerCnxn v, v;
boolean v, v;
v := @this: org.apache.zookeeper.server.Request;
v = v.<org.apache.zookeeper.server.Request: org.apache.zookeeper.server.ServerCnxn cnxn>;
if v == null goto label;
v = v.<org.apache.zookeeper.server.Request: org.apache.zookeeper.server.ServerCnxn cnxn>;
v = virtualinvoke v.<org.apache.zookeeper.server.ServerCnxn: boolean isInvalid()>();
if v == 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
static boolean isValid(int)
{
int v;
v := @parameter: int;
tableswitch(v)
{
case -11: goto label;
case -10: goto label;
case -9: goto label;
case -8: goto label;
case -7: goto label;
case -6: goto label;
case -5: goto label;
case -4: goto label;
case -3: goto label;
case -2: goto label;
case -1: goto label;
case 0: goto label;
case 1: goto label;
case 2: goto label;
case 3: goto label;
case 4: goto label;
case 5: goto label;
case 6: goto label;
case 7: goto label;
case 8: goto label;
case 9: goto label;
case 10: goto label;
case 11: goto label;
case 12: goto label;
case 13: goto label;
case 14: goto label;
case 15: goto label;
case 16: goto label;
case 17: goto label;
case 18: goto label;
case 19: goto label;
case 20: goto label;
case 21: goto label;
case 22: goto label;
case 23: goto label;
case 24: goto label;
case 25: goto label;
case 26: goto label;
case 27: goto label;
case 28: goto label;
case 29: goto label;
case 30: goto label;
case 31: goto label;
case 32: goto label;
case 33: goto label;
case 34: goto label;
case 35: goto label;
case 36: goto label;
case 37: goto label;
case 38: goto label;
case 39: goto label;
case 40: goto label;
case 41: goto label;
case 42: goto label;
case 43: goto label;
case 44: goto label;
case 45: goto label;
case 46: goto label;
case 47: goto label;
case 48: goto label;
case 49: goto label;
case 50: goto label;
case 51: goto label;
case 52: goto label;
case 53: goto label;
case 54: goto label;
case 55: goto label;
case 56: goto label;
case 57: goto label;
case 58: goto label;
case 59: goto label;
case 60: goto label;
case 61: goto label;
case 62: goto label;
case 63: goto label;
case 64: goto label;
case 65: goto label;
case 66: goto label;
case 67: goto label;
case 68: goto label;
case 69: goto label;
case 70: goto label;
case 71: goto label;
case 72: goto label;
case 73: goto label;
case 74: goto label;
case 75: goto label;
case 76: goto label;
case 77: goto label;
case 78: goto label;
case 79: goto label;
case 80: goto label;
case 81: goto label;
case 82: goto label;
case 83: goto label;
case 84: goto label;
case 85: goto label;
case 86: goto label;
case 87: goto label;
case 88: goto label;
case 89: goto label;
case 90: goto label;
case 91: goto label;
case 92: goto label;
case 93: goto label;
case 94: goto label;
case 95: goto label;
case 96: goto label;
case 97: goto label;
case 98: goto label;
case 99: goto label;
case 100: goto label;
case 101: goto label;
case 102: goto label;
case 103: goto label;
case 104: goto label;
case 105: goto label;
case 106: goto label;
case 107: goto label;
default: goto label;
};
label:
return 0;
label:
return 1;
label:
return 0;
}
public boolean isQuorum()
{
org.apache.zookeeper.server.Request v;
int v;
boolean v, v;
v := @this: org.apache.zookeeper.server.Request;
v = v.<org.apache.zookeeper.server.Request: int type>;
lookupswitch(v)
{
case -11: goto label;
case -10: goto label;
case -1: goto label;
case 1: goto label;
case 2: goto label;
case 3: goto label;
case 4: goto label;
case 5: goto label;
case 6: goto label;
case 7: goto label;
case 8: goto label;
case 12: goto label;
case 13: goto label;
case 14: goto label;
case 15: goto label;
case 16: goto label;
case 19: goto label;
case 20: goto label;
case 21: goto label;
case 22: goto label;
case 103: goto label;
case 104: goto label;
case 107: goto label;
default: goto label;
};
label:
return 0;
label:
return 1;
label:
v = v.<org.apache.zookeeper.server.Request: boolean isLocalSession>;
if v != 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
label:
return 0;
}
public static java.lang.String op2String(int)
{
int v;
java.lang.String v;
v := @parameter: int;
tableswitch(v)
{
case -11: goto label;
case -10: goto label;
case -9: goto label;
case -8: goto label;
case -7: goto label;
case -6: goto label;
case -5: goto label;
case -4: goto label;
case -3: goto label;
case -2: goto label;
case -1: goto label;
case 0: goto label;
case 1: goto label;
case 2: goto label;
case 3: goto label;
case 4: goto label;
case 5: goto label;
case 6: goto label;
case 7: goto label;
case 8: goto label;
case 9: goto label;
case 10: goto label;
case 11: goto label;
case 12: goto label;
case 13: goto label;
case 14: goto label;
case 15: goto label;
case 16: goto label;
case 17: goto label;
case 18: goto label;
case 19: goto label;
case 20: goto label;
case 21: goto label;
case 22: goto label;
case 23: goto label;
case 24: goto label;
case 25: goto label;
case 26: goto label;
case 27: goto label;
case 28: goto label;
case 29: goto label;
case 30: goto label;
case 31: goto label;
case 32: goto label;
case 33: goto label;
case 34: goto label;
case 35: goto label;
case 36: goto label;
case 37: goto label;
case 38: goto label;
case 39: goto label;
case 40: goto label;
case 41: goto label;
case 42: goto label;
case 43: goto label;
case 44: goto label;
case 45: goto label;
case 46: goto label;
case 47: goto label;
case 48: goto label;
case 49: goto label;
case 50: goto label;
case 51: goto label;
case 52: goto label;
case 53: goto label;
case 54: goto label;
case 55: goto label;
case 56: goto label;
case 57: goto label;
case 58: goto label;
case 59: goto label;
case 60: goto label;
case 61: goto label;
case 62: goto label;
case 63: goto label;
case 64: goto label;
case 65: goto label;
case 66: goto label;
case 67: goto label;
case 68: goto label;
case 69: goto label;
case 70: goto label;
case 71: goto label;
case 72: goto label;
case 73: goto label;
case 74: goto label;
case 75: goto label;
case 76: goto label;
case 77: goto label;
case 78: goto label;
case 79: goto label;
case 80: goto label;
case 81: goto label;
case 82: goto label;
case 83: goto label;
case 84: goto label;
case 85: goto label;
case 86: goto label;
case 87: goto label;
case 88: goto label;
case 89: goto label;
case 90: goto label;
case 91: goto label;
case 92: goto label;
case 93: goto label;
case 94: goto label;
case 95: goto label;
case 96: goto label;
case 97: goto label;
case 98: goto label;
case 99: goto label;
case 100: goto label;
case 101: goto label;
case 102: goto label;
case 103: goto label;
case 104: goto label;
case 105: goto label;
case 106: goto label;
case 107: goto label;
default: goto label;
};
label:
return "notification";
label:
return "create";
label:
return "delete";
label:
return "exists";
label:
return "getData";
label:
return "setData";
label:
return "getACL";
label:
return "setACL";
label:
return "getChildren";
label:
return "sync";
label:
return "ping";
label:
return "getChildren2";
label:
return "check";
label:
return "multi";
label:
return "create2";
label:
return "reconfig";
label:
return "checkWatches";
label:
return "removeWatches";
label:
return "createContainer";
label:
return "deleteContainer";
label:
return "createTtl";
label:
return "multiRead";
label:
return "auth";
label:
return "setWatches";
label:
return "setWatches2";
label:
return "sasl";
label:
return "getEphemerals";
label:
return "getAllChildrenNumber";
label:
return "createSession";
label:
return "closeSession";
label:
return "error";
label:
return "whoAmI";
label:
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("unknown \u0001");
return v;
}
public java.lang.String toString()
{
byte[] v;
java.nio.ByteBuffer v, v, v, v;
java.lang.Exception v;
org.apache.zookeeper.server.Request v;
java.lang.StringBuilder v, v, v, v, v, v, v, v, v, v, v;
long v, v;
java.nio.charset.Charset v;
int v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.String v, v, v, v, v, v, v, v;
org.apache.zookeeper.txn.TxnHeader v, v, v, v;
v := @this: org.apache.zookeeper.server.Request;
v = new java.lang.StringBuilder;
specialinvoke v.<java.lang.StringBuilder: void <init>()>();
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>("sessionid:0x");
v = v.<org.apache.zookeeper.server.Request: long sessionId>;
v = staticinvoke <java.lang.Long: java.lang.String toHexString(long)>(v);
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(" type:");
v = v.<org.apache.zookeeper.server.Request: int type>;
v = staticinvoke <org.apache.zookeeper.server.Request: java.lang.String op2String(int)>(v);
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(" cxid:0x");
v = v.<org.apache.zookeeper.server.Request: int cxid>;
v = staticinvoke <java.lang.Long: java.lang.String toHexString(long)>(v);
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(" zxid:0x");
v = v.<org.apache.zookeeper.server.Request: org.apache.zookeeper.txn.TxnHeader hdr>;
if v != null goto label;
v = -2L;
goto label;
label:
v = v.<org.apache.zookeeper.server.Request: org.apache.zookeeper.txn.TxnHeader hdr>;
v = virtualinvoke v.<org.apache.zookeeper.txn.TxnHeader: long getZxid()>();
label:
v = staticinvoke <java.lang.Long: java.lang.String toHexString(long)>(v);
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(" txntype:");
v = v.<org.apache.zookeeper.server.Request: org.apache.zookeeper.txn.TxnHeader hdr>;
if v != null goto label;
v = "unknown";
goto label;
label:
v = v.<org.apache.zookeeper.server.Request: org.apache.zookeeper.txn.TxnHeader hdr>;
v = virtualinvoke v.<org.apache.zookeeper.txn.TxnHeader: int getType()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001");
label:
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
v = "n/a";
v = v.<org.apache.zookeeper.server.Request: int type>;
v = (int) -10;
if v == v goto label;
v = v.<org.apache.zookeeper.server.Request: int type>;
if v == 101 goto label;
v = v.<org.apache.zookeeper.server.Request: int type>;
if v == 105 goto label;
v = v.<org.apache.zookeeper.server.Request: int type>;
v = (int) -11;
if v == v goto label;
v = v.<org.apache.zookeeper.server.Request: java.nio.ByteBuffer request>;
if v == null goto label;
v = v.<org.apache.zookeeper.server.Request: java.nio.ByteBuffer request>;
v = virtualinvoke v.<java.nio.ByteBuffer: int remaining()>();
if v < 4 goto label;
label:
v = v.<org.apache.zookeeper.server.Request: java.nio.ByteBuffer request>;
v = virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer asReadOnlyBuffer()>();
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer clear()>();
v = virtualinvoke v.<java.nio.ByteBuffer: int getInt()>();
if v < 0 goto label;
if v >= 4096 goto label;
v = virtualinvoke v.<java.nio.ByteBuffer: int remaining()>();
if v < v goto label;
v = newarray (byte)[v];
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer get(byte[])>(v);
v = new java.lang.String;
v = <java.nio.charset.StandardCharsets: java.nio.charset.Charset UTF_8>;
specialinvoke v.<java.lang.String: void <init>(byte[],java.nio.charset.Charset)>(v, v);
v = v;
label:
goto label;
label:
v := @caughtexception;
label:
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(" reqpath:");
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.String toString()>();
return v;
catch java.lang.Exception from label to label with label;
}
public void setException(org.apache.zookeeper.KeeperException)
{
org.apache.zookeeper.server.Request v;
org.apache.zookeeper.KeeperException v;
v := @this: org.apache.zookeeper.server.Request;
v := @parameter: org.apache.zookeeper.KeeperException;
v.<org.apache.zookeeper.server.Request: org.apache.zookeeper.KeeperException e> = v;
return;
}
public org.apache.zookeeper.KeeperException getException()
{
org.apache.zookeeper.server.Request v;
org.apache.zookeeper.KeeperException v;
v := @this: org.apache.zookeeper.server.Request;
v = v.<org.apache.zookeeper.server.Request: org.apache.zookeeper.KeeperException e>;
return v;
}
public void logLatency(org.apache.zookeeper.metrics.Summary)
{
org.apache.zookeeper.server.Request v;
long v;
org.apache.zookeeper.metrics.Summary v;
v := @this: org.apache.zookeeper.server.Request;
v := @parameter: org.apache.zookeeper.metrics.Summary;
v = staticinvoke <org.apache.zookeeper.common.Time: long currentWallTime()>();
virtualinvoke v.<org.apache.zookeeper.server.Request: void logLatency(org.apache.zookeeper.metrics.Summary,long)>(v, v);
return;
}
public void logLatency(org.apache.zookeeper.metrics.Summary, long)
{
long v, v, v;
org.apache.zookeeper.txn.TxnHeader v, v;
org.apache.zookeeper.metrics.Summary v;
org.apache.zookeeper.server.Request v;
byte v;
v := @this: org.apache.zookeeper.server.Request;
v := @parameter: org.apache.zookeeper.metrics.Summary;
v := @parameter: long;
v = v.<org.apache.zookeeper.server.Request: org.apache.zookeeper.txn.TxnHeader hdr>;
if v == null goto label;
v = v.<org.apache.zookeeper.server.Request: org.apache.zookeeper.txn.TxnHeader hdr>;
v = virtualinvoke v.<org.apache.zookeeper.txn.TxnHeader: long getTime()>();
v = v - v;
v = v cmp 0L;
if v < 0 goto label;
interfaceinvoke v.<org.apache.zookeeper.metrics.Summary: void add(long)>(v);
label:
return;
}
public void logLatency(org.apache.zookeeper.metrics.SummarySet, java.lang.String, long)
{
long v, v, v;
org.apache.zookeeper.txn.TxnHeader v, v;
org.apache.zookeeper.metrics.SummarySet v;
org.apache.zookeeper.server.Request v;
byte v;
java.lang.String v;
v := @this: org.apache.zookeeper.server.Request;
v := @parameter: org.apache.zookeeper.metrics.SummarySet;
v := @parameter: java.lang.String;
v := @parameter: long;
v = v.<org.apache.zookeeper.server.Request: org.apache.zookeeper.txn.TxnHeader hdr>;
if v == null goto label;
v = v.<org.apache.zookeeper.server.Request: org.apache.zookeeper.txn.TxnHeader hdr>;
v = virtualinvoke v.<org.apache.zookeeper.txn.TxnHeader: long getTime()>();
v = v - v;
v = v cmp 0L;
if v < 0 goto label;
interfaceinvoke v.<org.apache.zookeeper.metrics.SummarySet: void add(java.lang.String,long)>(v, v);
label:
return;
}
public void logLatency(org.apache.zookeeper.metrics.SummarySet, java.lang.String)
{
org.apache.zookeeper.server.Request v;
long v;
java.lang.String v;
org.apache.zookeeper.metrics.SummarySet v;
v := @this: org.apache.zookeeper.server.Request;
v := @parameter: org.apache.zookeeper.metrics.SummarySet;
v := @parameter: java.lang.String;
v = staticinvoke <org.apache.zookeeper.common.Time: long currentWallTime()>();
virtualinvoke v.<org.apache.zookeeper.server.Request: void logLatency(org.apache.zookeeper.metrics.SummarySet,java.lang.String,long)>(v, v, v);
return;
}
public java.lang.String getUsersForAudit()
{
org.apache.zookeeper.server.Request v;
java.util.List v;
java.lang.String v;
v := @this: org.apache.zookeeper.server.Request;
v = v.<org.apache.zookeeper.server.Request: java.util.List authInfo>;
v = staticinvoke <org.apache.zookeeper.server.util.AuthUtil: java.lang.String getUsers(java.util.List)>(v);
return v;
}
public org.apache.zookeeper.txn.TxnDigest getTxnDigest()
{
org.apache.zookeeper.server.Request v;
org.apache.zookeeper.txn.TxnDigest v;
v := @this: org.apache.zookeeper.server.Request;
v = v.<org.apache.zookeeper.server.Request: org.apache.zookeeper.txn.TxnDigest txnDigest>;
return v;
}
public void setTxnDigest(org.apache.zookeeper.txn.TxnDigest)
{
org.apache.zookeeper.server.Request v;
org.apache.zookeeper.txn.TxnDigest v;
v := @this: org.apache.zookeeper.server.Request;
v := @parameter: org.apache.zookeeper.txn.TxnDigest;
v.<org.apache.zookeeper.server.Request: org.apache.zookeeper.txn.TxnDigest txnDigest> = v;
return;
}
public boolean isFromLearner()
{
org.apache.zookeeper.server.Request v;
java.lang.Object v;
boolean v;
v := @this: org.apache.zookeeper.server.Request;
v = v.<org.apache.zookeeper.server.Request: java.lang.Object owner>;
v = v instanceof org.apache.zookeeper.server.quorum.LearnerHandler;
return v;
}
static void <clinit>()
{
org.apache.zookeeper.server.Request v;
java.lang.String v, v;
boolean v, v;
v = new org.apache.zookeeper.server.Request;
specialinvoke v.<org.apache.zookeeper.server.Request: void <init>(org.apache.zookeeper.server.ServerCnxn,long,int,int,java.nio.ByteBuffer,java.util.List)>(null, 0L, 0, 0, null, null);
<org.apache.zookeeper.server.Request: org.apache.zookeeper.server.Request requestOfDeath> = v;
v = staticinvoke <java.lang.System: java.lang.String getProperty(java.lang.String,java.lang.String)>("zookeeper.request_stale_connection_check", "true");
v = staticinvoke <java.lang.Boolean: boolean parseBoolean(java.lang.String)>(v);
<org.apache.zookeeper.server.Request: boolean staleConnectionCheck> = v;
v = staticinvoke <java.lang.System: java.lang.String getProperty(java.lang.String,java.lang.String)>("zookeeper.request_stale_latency_check", "false");
v = staticinvoke <java.lang.Boolean: boolean parseBoolean(java.lang.String)>(v);
<org.apache.zookeeper.server.Request: boolean staleLatencyCheck> = v;
return;
}
}