public class org.apache.zookeeper.server.util.SerializeUtils extends java.lang.Object
{
private static final org.slf4j.Logger LOG;
public void <init>()
{
org.apache.zookeeper.server.util.SerializeUtils v;
v := @this: org.apache.zookeeper.server.util.SerializeUtils;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public static org.apache.zookeeper.server.TxnLogEntry deserializeTxn(byte[]) throws java.io.IOException
{
byte[] v, v;
org.apache.zookeeper.txn.SetDataTxn v;
org.apache.zookeeper.txn.CreateSessionTxn v;
java.io.ByteArrayInputStream v;
org.apache.zookeeper.txn.CreateTxn v;
boolean v, v, v;
org.apache.zookeeper.txn.CreateTTLTxn v;
java.io.EOFException v, v;
java.util.List v;
org.apache.zookeeper.txn.DeleteTxn v;
org.apache.zookeeper.txn.CreateContainerTxn v;
org.apache.zookeeper.txn.SetACLTxn v;
org.apache.zookeeper.txn.TxnDigest v, v;
org.apache.zookeeper.txn.CreateTxnV0 v;
int v, v, v, v, v, v, v;
java.lang.String v, v;
org.apache.zookeeper.txn.MultiTxn v;
java.io.IOException v;
org.apache.zookeeper.txn.TxnHeader v;
org.apache.jute.BinaryInputArchive v;
org.apache.zookeeper.server.TxnLogEntry v;
org.apache.zookeeper.txn.ErrorTxn v;
org.apache.zookeeper.txn.CloseSessionTxn v, v;
java.lang.Object v;
v := @parameter: byte[];
v = new org.apache.zookeeper.txn.TxnHeader;
specialinvoke v.<org.apache.zookeeper.txn.TxnHeader: void <init>()>();
v = new java.io.ByteArrayInputStream;
specialinvoke v.<java.io.ByteArrayInputStream: void <init>(byte[])>(v);
v = staticinvoke <org.apache.jute.BinaryInputArchive: org.apache.jute.BinaryInputArchive getArchive(java.io.InputStream)>(v);
virtualinvoke v.<org.apache.zookeeper.txn.TxnHeader: void deserialize(org.apache.jute.InputArchive,java.lang.String)>(v, "hdr");
v = virtualinvoke v.<java.io.ByteArrayInputStream: int available()>();
virtualinvoke v.<java.io.ByteArrayInputStream: void mark(int)>(v);
v = virtualinvoke v.<org.apache.zookeeper.txn.TxnHeader: int getType()>();
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;
default: goto label;
};
label:
v = new org.apache.zookeeper.txn.CreateSessionTxn;
specialinvoke v.<org.apache.zookeeper.txn.CreateSessionTxn: void <init>()>();
v = v;
goto label;
label:
v = staticinvoke <org.apache.zookeeper.server.ZooKeeperServer: boolean isCloseSessionTxnEnabled()>();
if v == 0 goto label;
v = new org.apache.zookeeper.txn.CloseSessionTxn;
v = v;
specialinvoke v.<org.apache.zookeeper.txn.CloseSessionTxn: void <init>()>();
goto label;
label:
v = null;
label:
v = v;
goto label;
label:
v = new org.apache.zookeeper.txn.CreateTxn;
specialinvoke v.<org.apache.zookeeper.txn.CreateTxn: void <init>()>();
v = v;
goto label;
label:
v = new org.apache.zookeeper.txn.CreateTTLTxn;
specialinvoke v.<org.apache.zookeeper.txn.CreateTTLTxn: void <init>()>();
v = v;
goto label;
label:
v = new org.apache.zookeeper.txn.CreateContainerTxn;
specialinvoke v.<org.apache.zookeeper.txn.CreateContainerTxn: void <init>()>();
v = v;
goto label;
label:
v = new org.apache.zookeeper.txn.DeleteTxn;
specialinvoke v.<org.apache.zookeeper.txn.DeleteTxn: void <init>()>();
v = v;
goto label;
label:
v = new org.apache.zookeeper.txn.SetDataTxn;
specialinvoke v.<org.apache.zookeeper.txn.SetDataTxn: void <init>()>();
v = v;
goto label;
label:
v = new org.apache.zookeeper.txn.SetACLTxn;
specialinvoke v.<org.apache.zookeeper.txn.SetACLTxn: void <init>()>();
v = v;
goto label;
label:
v = new org.apache.zookeeper.txn.ErrorTxn;
specialinvoke v.<org.apache.zookeeper.txn.ErrorTxn: void <init>()>();
v = v;
goto label;
label:
v = new org.apache.zookeeper.txn.MultiTxn;
specialinvoke v.<org.apache.zookeeper.txn.MultiTxn: void <init>()>();
v = v;
goto label;
label:
v = new java.io.IOException;
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[])>("Unsupported Txn with type=\u0001");
specialinvoke v.<java.io.IOException: void <init>(java.lang.String)>(v);
throw v;
label:
if v == null goto label;
label:
interfaceinvoke v.<org.apache.jute.Record: void deserialize(org.apache.jute.InputArchive,java.lang.String)>(v, "txn");
label:
goto label;
label:
v := @caughtexception;
v = virtualinvoke v.<org.apache.zookeeper.txn.TxnHeader: int getType()>();
if v != 1 goto label;
virtualinvoke v.<java.io.ByteArrayInputStream: void reset()>();
v = new org.apache.zookeeper.txn.CreateTxnV0;
specialinvoke v.<org.apache.zookeeper.txn.CreateTxnV0: void <init>()>();
virtualinvoke v.<org.apache.zookeeper.txn.CreateTxnV0: void deserialize(org.apache.jute.InputArchive,java.lang.String)>(v, "txn");
v = virtualinvoke v.<org.apache.zookeeper.txn.CreateTxnV0: java.lang.String getPath()>();
virtualinvoke v.<org.apache.zookeeper.txn.CreateTxn: void setPath(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.zookeeper.txn.CreateTxnV0: byte[] getData()>();
virtualinvoke v.<org.apache.zookeeper.txn.CreateTxn: void setData(byte[])>(v);
v = virtualinvoke v.<org.apache.zookeeper.txn.CreateTxnV0: java.util.List getAcl()>();
virtualinvoke v.<org.apache.zookeeper.txn.CreateTxn: void setAcl(java.util.List)>(v);
v = virtualinvoke v.<org.apache.zookeeper.txn.CreateTxnV0: boolean getEphemeral()>();
virtualinvoke v.<org.apache.zookeeper.txn.CreateTxn: void setEphemeral(boolean)>(v);
v = (int) -1;
virtualinvoke v.<org.apache.zookeeper.txn.CreateTxn: void setParentCVersion(int)>(v);
goto label;
label:
v = virtualinvoke v.<org.apache.zookeeper.txn.TxnHeader: int getType()>();
v = (int) -11;
if v != v goto label;
v = null;
goto label;
label:
throw v;
label:
v = null;
v = staticinvoke <org.apache.zookeeper.server.ZooKeeperServer: boolean isDigestEnabled()>();
if v == 0 goto label;
v = new org.apache.zookeeper.txn.TxnDigest;
specialinvoke v.<org.apache.zookeeper.txn.TxnDigest: void <init>()>();
v = v;
label:
virtualinvoke v.<org.apache.zookeeper.txn.TxnDigest: void deserialize(org.apache.jute.InputArchive,java.lang.String)>(v, "digest");
label:
goto label;
label:
v := @caughtexception;
v = null;
label:
v = new org.apache.zookeeper.server.TxnLogEntry;
specialinvoke v.<org.apache.zookeeper.server.TxnLogEntry: void <init>(org.apache.jute.Record,org.apache.zookeeper.txn.TxnHeader,org.apache.zookeeper.txn.TxnDigest)>(v, v, v);
return v;
catch java.io.EOFException from label to label with label;
catch java.io.EOFException from label to label with label;
}
public static void deserializeSnapshot(org.apache.zookeeper.server.DataTree, org.apache.jute.InputArchive, java.util.Map) throws java.io.IOException
{
org.slf4j.Logger v, v;
org.apache.jute.InputArchive v;
long v;
java.lang.Integer v;
java.lang.Long v;
java.util.Map v;
int v, v;
org.apache.zookeeper.server.DataTree v;
java.lang.String v;
boolean v;
v := @parameter: org.apache.zookeeper.server.DataTree;
v := @parameter: org.apache.jute.InputArchive;
v := @parameter: java.util.Map;
v = interfaceinvoke v.<org.apache.jute.InputArchive: int readInt(java.lang.String)>("count");
label:
if v <= 0 goto label;
v = interfaceinvoke v.<org.apache.jute.InputArchive: long readLong(java.lang.String)>("id");
v = interfaceinvoke v.<org.apache.jute.InputArchive: int readInt(java.lang.String)>("timeout");
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = <org.apache.zookeeper.server.util.SerializeUtils: org.slf4j.Logger LOG>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isTraceEnabled()>();
if v == 0 goto label;
v = <org.apache.zookeeper.server.util.SerializeUtils: org.slf4j.Logger LOG>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (long,int)>(v, 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[])>("loadData --- session in archive: \u with timeout: \u0001");
staticinvoke <org.apache.zookeeper.server.ZooTrace: void logTraceMessage(org.slf4j.Logger,long,java.lang.String)>(v, 32L, v);
label:
v = v - 1;
goto label;
label:
virtualinvoke v.<org.apache.zookeeper.server.DataTree: void deserialize(org.apache.jute.InputArchive,java.lang.String)>(v, "tree");
return;
}
public static void serializeSnapshot(org.apache.zookeeper.server.DataTree, org.apache.jute.OutputArchive, java.util.Map) throws java.io.IOException
{
java.util.Iterator v;
java.util.Set v;
java.util.HashMap v;
long v;
java.util.Map v;
int v, v;
org.apache.jute.OutputArchive v;
org.apache.zookeeper.server.DataTree v;
java.lang.Object v, v, v;
boolean v;
v := @parameter: org.apache.zookeeper.server.DataTree;
v := @parameter: org.apache.jute.OutputArchive;
v := @parameter: java.util.Map;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>(java.util.Map)>(v);
v = virtualinvoke v.<java.util.HashMap: int size()>();
interfaceinvoke v.<org.apache.jute.OutputArchive: void writeInt(int,java.lang.String)>(v, "count");
v = virtualinvoke v.<java.util.HashMap: java.util.Set entrySet()>();
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getKey()>();
v = virtualinvoke v.<java.lang.Long: long longValue()>();
interfaceinvoke v.<org.apache.jute.OutputArchive: void writeLong(long,java.lang.String)>(v, "id");
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
interfaceinvoke v.<org.apache.jute.OutputArchive: void writeInt(int,java.lang.String)>(v, "timeout");
goto label;
label:
virtualinvoke v.<org.apache.zookeeper.server.DataTree: void serialize(org.apache.jute.OutputArchive,java.lang.String)>(v, "tree");
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/util/SerializeUtils;");
<org.apache.zookeeper.server.util.SerializeUtils: org.slf4j.Logger LOG> = v;
return;
}
}