public class oadd.org.apache.zookeeper.server.ZKDatabase extends java.lang.Object
{
private static final org.slf4j.Logger LOG;
protected oadd.org.apache.zookeeper.server.DataTree dataTree;
protected java.util.concurrent.ConcurrentHashMap sessionsWithTimeouts;
protected oadd.org.apache.zookeeper.server.persistence.FileTxnSnapLog snapLog;
protected long minCommittedLog;
protected long maxCommittedLog;
public static final java.lang.String SNAPSHOT_SIZE_FACTOR;
public static final double DEFAULT_SNAPSHOT_SIZE_FACTOR;
private double snapshotSizeFactor;
public static final int commitLogCount;
protected static int commitLogBuffer;
protected java.util.LinkedList committedLog;
protected java.util.concurrent.locks.ReentrantReadWriteLock logLock;
private volatile boolean initialized;
private final oadd.org.apache.zookeeper.server.persistence.FileTxnSnapLog$PlayBackListener commitProposalPlaybackListener;
public void <init>(oadd.org.apache.zookeeper.server.persistence.FileTxnSnapLog)
{
java.lang.Double v, v, v;
java.util.concurrent.locks.ReentrantReadWriteLock v;
oadd.org.apache.zookeeper.server.DataTree v;
byte v;
java.lang.String v, v;
java.util.LinkedList v;
oadd.org.apache.zookeeper.server.persistence.FileTxnSnapLog v;
double v, v, v;
org.slf4j.Logger v, v, v;
java.util.concurrent.ConcurrentHashMap v;
java.lang.NumberFormatException v;
oadd.org.apache.zookeeper.server.ZKDatabase$1 v;
oadd.org.apache.zookeeper.server.ZKDatabase v;
v := @this: oadd.org.apache.zookeeper.server.ZKDatabase;
v := @parameter: oadd.org.apache.zookeeper.server.persistence.FileTxnSnapLog;
specialinvoke v.<java.lang.Object: void <init>()>();
v = new java.util.LinkedList;
specialinvoke v.<java.util.LinkedList: void <init>()>();
v.<oadd.org.apache.zookeeper.server.ZKDatabase: java.util.LinkedList committedLog> = v;
v = new java.util.concurrent.locks.ReentrantReadWriteLock;
specialinvoke v.<java.util.concurrent.locks.ReentrantReadWriteLock: void <init>()>();
v.<oadd.org.apache.zookeeper.server.ZKDatabase: java.util.concurrent.locks.ReentrantReadWriteLock logLock> = v;
v.<oadd.org.apache.zookeeper.server.ZKDatabase: boolean initialized> = 0;
v = new oadd.org.apache.zookeeper.server.ZKDatabase$1;
specialinvoke v.<oadd.org.apache.zookeeper.server.ZKDatabase$1: void <init>(oadd.org.apache.zookeeper.server.ZKDatabase)>(v);
v.<oadd.org.apache.zookeeper.server.ZKDatabase: oadd.org.apache.zookeeper.server.persistence.FileTxnSnapLog$PlayBackListener commitProposalPlaybackListener> = v;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.ZKDatabase: oadd.org.apache.zookeeper.server.DataTree createDataTree()>();
v.<oadd.org.apache.zookeeper.server.ZKDatabase: oadd.org.apache.zookeeper.server.DataTree dataTree> = v;
v = new java.util.concurrent.ConcurrentHashMap;
specialinvoke v.<java.util.concurrent.ConcurrentHashMap: void <init>()>();
v.<oadd.org.apache.zookeeper.server.ZKDatabase: java.util.concurrent.ConcurrentHashMap sessionsWithTimeouts> = v;
v.<oadd.org.apache.zookeeper.server.ZKDatabase: oadd.org.apache.zookeeper.server.persistence.FileTxnSnapLog snapLog> = v;
label:
v = staticinvoke <java.lang.Double: java.lang.String toString(double)>(0.33);
v = staticinvoke <java.lang.System: java.lang.String getProperty(java.lang.String,java.lang.String)>("zookeeper.snapshotSizeFactor", v);
v = staticinvoke <java.lang.Double: double parseDouble(java.lang.String)>(v);
v.<oadd.org.apache.zookeeper.server.ZKDatabase: double snapshotSizeFactor> = v;
v = v.<oadd.org.apache.zookeeper.server.ZKDatabase: double snapshotSizeFactor>;
v = v cmpl 1.0;
if v <= 0 goto label;
v.<oadd.org.apache.zookeeper.server.ZKDatabase: double snapshotSizeFactor> = 0.33;
v = <oadd.org.apache.zookeeper.server.ZKDatabase: org.slf4j.Logger LOG>;
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(0.33);
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String,java.lang.Object,java.lang.Object)>("The configured {} is invalid, going to use the default {}", "zookeeper.snapshotSizeFactor", v);
label:
goto label;
label:
v := @caughtexception;
v = <oadd.org.apache.zookeeper.server.ZKDatabase: org.slf4j.Logger LOG>;
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(0.33);
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Object,java.lang.Object)>("Error parsing {}, using default value {}", "zookeeper.snapshotSizeFactor", v);
v.<oadd.org.apache.zookeeper.server.ZKDatabase: double snapshotSizeFactor> = 0.33;
label:
v = <oadd.org.apache.zookeeper.server.ZKDatabase: org.slf4j.Logger LOG>;
v = v.<oadd.org.apache.zookeeper.server.ZKDatabase: double snapshotSizeFactor>;
v = staticinvoke <java.lang.Double: java.lang.Double valueOf(double)>(v);
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object,java.lang.Object)>("{} = {}", "zookeeper.snapshotSizeFactor", v);
return;
catch java.lang.NumberFormatException from label to label with label;
}
public boolean isInitialized()
{
oadd.org.apache.zookeeper.server.ZKDatabase v;
boolean v;
v := @this: oadd.org.apache.zookeeper.server.ZKDatabase;
v = v.<oadd.org.apache.zookeeper.server.ZKDatabase: boolean initialized>;
return v;
}
public void clear()
{
java.lang.Throwable v;
java.util.concurrent.ConcurrentHashMap v;
oadd.org.apache.zookeeper.server.ZKDatabase v;
java.util.concurrent.locks.ReentrantReadWriteLock v;
java.util.LinkedList v;
java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock v;
oadd.org.apache.zookeeper.server.DataTree v;
v := @this: oadd.org.apache.zookeeper.server.ZKDatabase;
v.<oadd.org.apache.zookeeper.server.ZKDatabase: long minCommittedLog> = 0L;
v.<oadd.org.apache.zookeeper.server.ZKDatabase: long maxCommittedLog> = 0L;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.ZKDatabase: oadd.org.apache.zookeeper.server.DataTree createDataTree()>();
v.<oadd.org.apache.zookeeper.server.ZKDatabase: oadd.org.apache.zookeeper.server.DataTree dataTree> = v;
v = v.<oadd.org.apache.zookeeper.server.ZKDatabase: java.util.concurrent.ConcurrentHashMap sessionsWithTimeouts>;
virtualinvoke v.<java.util.concurrent.ConcurrentHashMap: void clear()>();
v = v.<oadd.org.apache.zookeeper.server.ZKDatabase: java.util.concurrent.locks.ReentrantReadWriteLock logLock>;
v = virtualinvoke v.<java.util.concurrent.locks.ReentrantReadWriteLock: java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock writeLock()>();
label:
virtualinvoke v.<java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock: void lock()>();
v = v.<oadd.org.apache.zookeeper.server.ZKDatabase: java.util.LinkedList committedLog>;
virtualinvoke v.<java.util.LinkedList: void clear()>();
label:
virtualinvoke v.<java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock: void unlock()>();
goto label;
label:
v := @caughtexception;
virtualinvoke v.<java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock: void unlock()>();
throw v;
label:
v.<oadd.org.apache.zookeeper.server.ZKDatabase: boolean initialized> = 0;
return;
catch java.lang.Throwable from label to label with label;
}
public oadd.org.apache.zookeeper.server.DataTree getDataTree()
{
oadd.org.apache.zookeeper.server.ZKDatabase v;
oadd.org.apache.zookeeper.server.DataTree v;
v := @this: oadd.org.apache.zookeeper.server.ZKDatabase;
v = v.<oadd.org.apache.zookeeper.server.ZKDatabase: oadd.org.apache.zookeeper.server.DataTree dataTree>;
return v;
}
public long getmaxCommittedLog()
{
oadd.org.apache.zookeeper.server.ZKDatabase v;
long v;
v := @this: oadd.org.apache.zookeeper.server.ZKDatabase;
v = v.<oadd.org.apache.zookeeper.server.ZKDatabase: long maxCommittedLog>;
return v;
}
public long getminCommittedLog()
{
oadd.org.apache.zookeeper.server.ZKDatabase v;
long v;
v := @this: oadd.org.apache.zookeeper.server.ZKDatabase;
v = v.<oadd.org.apache.zookeeper.server.ZKDatabase: long minCommittedLog>;
return v;
}
public java.util.concurrent.locks.ReentrantReadWriteLock getLogLock()
{
oadd.org.apache.zookeeper.server.ZKDatabase v;
java.util.concurrent.locks.ReentrantReadWriteLock v;
v := @this: oadd.org.apache.zookeeper.server.ZKDatabase;
v = v.<oadd.org.apache.zookeeper.server.ZKDatabase: java.util.concurrent.locks.ReentrantReadWriteLock logLock>;
return v;
}
public synchronized java.util.List getCommittedLog()
{
java.lang.Throwable v;
java.util.concurrent.locks.ReentrantReadWriteLock v, v;
java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock v;
int v;
oadd.org.apache.zookeeper.server.ZKDatabase v;
java.util.LinkedList v, v, v;
v := @this: oadd.org.apache.zookeeper.server.ZKDatabase;
v = v.<oadd.org.apache.zookeeper.server.ZKDatabase: java.util.concurrent.locks.ReentrantReadWriteLock logLock>;
v = virtualinvoke v.<java.util.concurrent.locks.ReentrantReadWriteLock: java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock readLock()>();
v = v.<oadd.org.apache.zookeeper.server.ZKDatabase: java.util.concurrent.locks.ReentrantReadWriteLock logLock>;
v = virtualinvoke v.<java.util.concurrent.locks.ReentrantReadWriteLock: int getReadHoldCount()>();
if v > 0 goto label;
label:
virtualinvoke v.<java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock: void lock()>();
v = new java.util.LinkedList;
v = v.<oadd.org.apache.zookeeper.server.ZKDatabase: java.util.LinkedList committedLog>;
specialinvoke v.<java.util.LinkedList: void <init>(java.util.Collection)>(v);
label:
virtualinvoke v.<java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock: void unlock()>();
return v;
label:
v := @caughtexception;
virtualinvoke v.<java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock: void unlock()>();
throw v;
label:
v = v.<oadd.org.apache.zookeeper.server.ZKDatabase: java.util.LinkedList committedLog>;
return v;
catch java.lang.Throwable from label to label with label;
}
public long getDataTreeLastProcessedZxid()
{
oadd.org.apache.zookeeper.server.ZKDatabase v;
long v;
oadd.org.apache.zookeeper.server.DataTree v;
v := @this: oadd.org.apache.zookeeper.server.ZKDatabase;
v = v.<oadd.org.apache.zookeeper.server.ZKDatabase: oadd.org.apache.zookeeper.server.DataTree dataTree>;
v = v.<oadd.org.apache.zookeeper.server.DataTree: long lastProcessedZxid>;
return v;
}
public java.util.Collection getSessions()
{
oadd.org.apache.zookeeper.server.ZKDatabase v;
oadd.org.apache.zookeeper.server.DataTree v;
java.util.Collection v;
v := @this: oadd.org.apache.zookeeper.server.ZKDatabase;
v = v.<oadd.org.apache.zookeeper.server.ZKDatabase: oadd.org.apache.zookeeper.server.DataTree dataTree>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.DataTree: java.util.Collection getSessions()>();
return v;
}
public java.util.concurrent.ConcurrentHashMap getSessionWithTimeOuts()
{
java.util.concurrent.ConcurrentHashMap v;
oadd.org.apache.zookeeper.server.ZKDatabase v;
v := @this: oadd.org.apache.zookeeper.server.ZKDatabase;
v = v.<oadd.org.apache.zookeeper.server.ZKDatabase: java.util.concurrent.ConcurrentHashMap sessionsWithTimeouts>;
return v;
}
public long loadDataBase() throws java.io.IOException
{
java.util.concurrent.ConcurrentHashMap v;
oadd.org.apache.zookeeper.server.ZKDatabase v;
long v;
oadd.org.apache.zookeeper.server.DataTree v;
oadd.org.apache.zookeeper.server.persistence.FileTxnSnapLog v;
oadd.org.apache.zookeeper.server.persistence.FileTxnSnapLog$PlayBackListener v;
v := @this: oadd.org.apache.zookeeper.server.ZKDatabase;
v = v.<oadd.org.apache.zookeeper.server.ZKDatabase: oadd.org.apache.zookeeper.server.persistence.FileTxnSnapLog snapLog>;
v = v.<oadd.org.apache.zookeeper.server.ZKDatabase: oadd.org.apache.zookeeper.server.DataTree dataTree>;
v = v.<oadd.org.apache.zookeeper.server.ZKDatabase: java.util.concurrent.ConcurrentHashMap sessionsWithTimeouts>;
v = v.<oadd.org.apache.zookeeper.server.ZKDatabase: oadd.org.apache.zookeeper.server.persistence.FileTxnSnapLog$PlayBackListener commitProposalPlaybackListener>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.persistence.FileTxnSnapLog: long restore(oadd.org.apache.zookeeper.server.DataTree,java.util.Map,oadd.org.apache.zookeeper.server.persistence.FileTxnSnapLog$PlayBackListener)>(v, v, v);
v.<oadd.org.apache.zookeeper.server.ZKDatabase: boolean initialized> = 1;
return v;
}
public long fastForwardDataBase() throws java.io.IOException
{
java.util.concurrent.ConcurrentHashMap v;
oadd.org.apache.zookeeper.server.ZKDatabase v;
long v;
oadd.org.apache.zookeeper.server.DataTree v;
oadd.org.apache.zookeeper.server.persistence.FileTxnSnapLog v;
oadd.org.apache.zookeeper.server.persistence.FileTxnSnapLog$PlayBackListener v;
v := @this: oadd.org.apache.zookeeper.server.ZKDatabase;
v = v.<oadd.org.apache.zookeeper.server.ZKDatabase: oadd.org.apache.zookeeper.server.persistence.FileTxnSnapLog snapLog>;
v = v.<oadd.org.apache.zookeeper.server.ZKDatabase: oadd.org.apache.zookeeper.server.DataTree dataTree>;
v = v.<oadd.org.apache.zookeeper.server.ZKDatabase: java.util.concurrent.ConcurrentHashMap sessionsWithTimeouts>;
v = v.<oadd.org.apache.zookeeper.server.ZKDatabase: oadd.org.apache.zookeeper.server.persistence.FileTxnSnapLog$PlayBackListener commitProposalPlaybackListener>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.persistence.FileTxnSnapLog: long fastForwardFromEdits(oadd.org.apache.zookeeper.server.DataTree,java.util.Map,oadd.org.apache.zookeeper.server.persistence.FileTxnSnapLog$PlayBackListener)>(v, v, v);
v.<oadd.org.apache.zookeeper.server.ZKDatabase: boolean initialized> = 1;
return v;
}
private void addCommittedProposal(oadd.org.apache.zookeeper.txn.TxnHeader, oadd.org.apache.jute.Record)
{
oadd.org.apache.jute.Record v;
oadd.org.apache.zookeeper.server.Request v;
int v, v;
oadd.org.apache.zookeeper.server.ZKDatabase v;
long v;
oadd.org.apache.zookeeper.txn.TxnHeader v;
v := @this: oadd.org.apache.zookeeper.server.ZKDatabase;
v := @parameter: oadd.org.apache.zookeeper.txn.TxnHeader;
v := @parameter: oadd.org.apache.jute.Record;
v = new oadd.org.apache.zookeeper.server.Request;
v = virtualinvoke v.<oadd.org.apache.zookeeper.txn.TxnHeader: int getCxid()>();
v = virtualinvoke v.<oadd.org.apache.zookeeper.txn.TxnHeader: int getType()>();
v = virtualinvoke v.<oadd.org.apache.zookeeper.txn.TxnHeader: long getZxid()>();
specialinvoke v.<oadd.org.apache.zookeeper.server.Request: void <init>(long,int,int,oadd.org.apache.zookeeper.txn.TxnHeader,oadd.org.apache.jute.Record,long)>(0L, v, v, v, v, v);
virtualinvoke v.<oadd.org.apache.zookeeper.server.ZKDatabase: void addCommittedProposal(oadd.org.apache.zookeeper.server.Request)>(v);
return;
}
public void addCommittedProposal(oadd.org.apache.zookeeper.server.Request)
{
java.lang.Throwable v;
oadd.org.apache.zookeeper.server.quorum.Leader$Proposal v;
byte[] v;
oadd.org.apache.zookeeper.server.quorum.QuorumPacket v, v, v;
long v, v, v, v, v;
java.util.concurrent.locks.ReentrantReadWriteLock v;
java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock v;
int v;
java.util.LinkedList v, v, v, v, v;
boolean v;
oadd.org.apache.zookeeper.server.Request v;
oadd.org.apache.zookeeper.server.ZKDatabase v;
java.lang.Object v;
v := @this: oadd.org.apache.zookeeper.server.ZKDatabase;
v := @parameter: oadd.org.apache.zookeeper.server.Request;
v = v.<oadd.org.apache.zookeeper.server.ZKDatabase: java.util.concurrent.locks.ReentrantReadWriteLock logLock>;
v = virtualinvoke v.<java.util.concurrent.locks.ReentrantReadWriteLock: java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock writeLock()>();
label:
virtualinvoke v.<java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock: void lock()>();
v = v.<oadd.org.apache.zookeeper.server.ZKDatabase: java.util.LinkedList committedLog>;
v = virtualinvoke v.<java.util.LinkedList: int size()>();
if v <= 500 goto label;
v = v.<oadd.org.apache.zookeeper.server.ZKDatabase: java.util.LinkedList committedLog>;
virtualinvoke v.<java.util.LinkedList: java.lang.Object removeFirst()>();
v = v.<oadd.org.apache.zookeeper.server.ZKDatabase: java.util.LinkedList committedLog>;
v = virtualinvoke v.<java.util.LinkedList: java.lang.Object getFirst()>();
v = v.<oadd.org.apache.zookeeper.server.quorum.Leader$Proposal: oadd.org.apache.zookeeper.server.quorum.QuorumPacket packet>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.QuorumPacket: long getZxid()>();
v.<oadd.org.apache.zookeeper.server.ZKDatabase: long minCommittedLog> = v;
label:
v = v.<oadd.org.apache.zookeeper.server.ZKDatabase: java.util.LinkedList committedLog>;
v = virtualinvoke v.<java.util.LinkedList: boolean isEmpty()>();
if v == 0 goto label;
v = v.<oadd.org.apache.zookeeper.server.Request: long zxid>;
v.<oadd.org.apache.zookeeper.server.ZKDatabase: long minCommittedLog> = v;
v = v.<oadd.org.apache.zookeeper.server.Request: long zxid>;
v.<oadd.org.apache.zookeeper.server.ZKDatabase: long maxCommittedLog> = v;
label:
v = staticinvoke <oadd.org.apache.zookeeper.server.util.SerializeUtils: byte[] serializeRequest(oadd.org.apache.zookeeper.server.Request)>(v);
v = new oadd.org.apache.zookeeper.server.quorum.QuorumPacket;
v = v.<oadd.org.apache.zookeeper.server.Request: long zxid>;
specialinvoke v.<oadd.org.apache.zookeeper.server.quorum.QuorumPacket: void <init>(int,long,byte[],java.util.List)>(2, v, v, null);
v = new oadd.org.apache.zookeeper.server.quorum.Leader$Proposal;
specialinvoke v.<oadd.org.apache.zookeeper.server.quorum.Leader$Proposal: void <init>()>();
v.<oadd.org.apache.zookeeper.server.quorum.Leader$Proposal: oadd.org.apache.zookeeper.server.quorum.QuorumPacket packet> = v;
v.<oadd.org.apache.zookeeper.server.quorum.Leader$Proposal: oadd.org.apache.zookeeper.server.Request request> = v;
v = v.<oadd.org.apache.zookeeper.server.ZKDatabase: java.util.LinkedList committedLog>;
virtualinvoke v.<java.util.LinkedList: boolean add(java.lang.Object)>(v);
v = v.<oadd.org.apache.zookeeper.server.quorum.Leader$Proposal: oadd.org.apache.zookeeper.server.quorum.QuorumPacket packet>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.quorum.QuorumPacket: long getZxid()>();
v.<oadd.org.apache.zookeeper.server.ZKDatabase: long maxCommittedLog> = v;
label:
virtualinvoke v.<java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock: void unlock()>();
goto label;
label:
v := @caughtexception;
virtualinvoke v.<java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock: void unlock()>();
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
public boolean isTxnLogSyncEnabled()
{
org.slf4j.Logger v, v;
byte v;
oadd.org.apache.zookeeper.server.ZKDatabase v;
java.lang.String v;
boolean v, v;
double v, v;
v := @this: oadd.org.apache.zookeeper.server.ZKDatabase;
v = v.<oadd.org.apache.zookeeper.server.ZKDatabase: double snapshotSizeFactor>;
v = v cmpl 0.0;
if v < 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
v = v;
if v == 0 goto label;
v = <oadd.org.apache.zookeeper.server.ZKDatabase: org.slf4j.Logger LOG>;
v = v.<oadd.org.apache.zookeeper.server.ZKDatabase: double snapshotSizeFactor>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (double)>(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[])>("On disk txn sync enabled with snapshotSizeFactor \u0001");
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>(v);
goto label;
label:
v = <oadd.org.apache.zookeeper.server.ZKDatabase: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>("On disk txn sync disabled");
label:
return v;
}
public long calculateTxnLogSizeLimit()
{
org.slf4j.Logger v;
java.io.IOException v;
long v;
java.io.File v;
oadd.org.apache.zookeeper.server.ZKDatabase v;
oadd.org.apache.zookeeper.server.persistence.FileTxnSnapLog v;
double v, v;
v := @this: oadd.org.apache.zookeeper.server.ZKDatabase;
v = 0L;
label:
v = v.<oadd.org.apache.zookeeper.server.ZKDatabase: oadd.org.apache.zookeeper.server.persistence.FileTxnSnapLog snapLog>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.persistence.FileTxnSnapLog: java.io.File findMostRecentSnapshot()>();
if v == null goto label;
v = virtualinvoke v.<java.io.File: long length()>();
label:
goto label;
label:
v := @caughtexception;
v = <oadd.org.apache.zookeeper.server.ZKDatabase: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String)>("Unable to get size of most recent snapshot");
label:
v = v.<oadd.org.apache.zookeeper.server.ZKDatabase: double snapshotSizeFactor>;
v = v * v;
return v;
catch java.io.IOException from label to label with label;
}
public java.util.Iterator getProposalsFromTxnLog(long, long)
{
long v, v, v, v;
byte v, v, v, v;
java.lang.String v, v;
oadd.org.apache.zookeeper.server.persistence.FileTxnSnapLog v;
org.slf4j.Logger v, v, v, v, v;
java.io.IOException v, v;
oadd.org.apache.zookeeper.txn.TxnHeader v, v;
oadd.org.apache.zookeeper.server.ZKDatabase v;
oadd.org.apache.zookeeper.server.persistence.TxnLog$TxnIterator v;
oadd.org.apache.zookeeper.server.TxnLogProposalIterator v, v, v, v, v;
v := @this: oadd.org.apache.zookeeper.server.ZKDatabase;
v := @parameter: long;
v := @parameter: long;
v = v cmp 0L;
if v >= 0 goto label;
v = <oadd.org.apache.zookeeper.server.ZKDatabase: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>("Negative size limit - retrieving proposal via txnlog is disabled");
v = <oadd.org.apache.zookeeper.server.TxnLogProposalIterator: oadd.org.apache.zookeeper.server.TxnLogProposalIterator EMPTY_ITERATOR>;
return v;
label:
v = null;
label:
v = v.<oadd.org.apache.zookeeper.server.ZKDatabase: oadd.org.apache.zookeeper.server.persistence.FileTxnSnapLog snapLog>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.persistence.FileTxnSnapLog: oadd.org.apache.zookeeper.server.persistence.TxnLog$TxnIterator readTxnLog(long,boolean)>(v, 0);
v = interfaceinvoke v.<oadd.org.apache.zookeeper.server.persistence.TxnLog$TxnIterator: oadd.org.apache.zookeeper.txn.TxnHeader getHeader()>();
if v == null goto label;
v = interfaceinvoke v.<oadd.org.apache.zookeeper.server.persistence.TxnLog$TxnIterator: oadd.org.apache.zookeeper.txn.TxnHeader getHeader()>();
v = virtualinvoke v.<oadd.org.apache.zookeeper.txn.TxnHeader: long getZxid()>();
v = v cmp v;
if v <= 0 goto label;
v = <oadd.org.apache.zookeeper.server.ZKDatabase: org.slf4j.Logger LOG>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (long)>(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[])>("Unable to find proposals from txnlog for zxid: \u0001");
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String)>(v);
interfaceinvoke v.<oadd.org.apache.zookeeper.server.persistence.TxnLog$TxnIterator: void close()>();
v = <oadd.org.apache.zookeeper.server.TxnLogProposalIterator: oadd.org.apache.zookeeper.server.TxnLogProposalIterator EMPTY_ITERATOR>;
label:
return v;
label:
v = v cmp 0L;
if v <= 0 goto label;
v = interfaceinvoke v.<oadd.org.apache.zookeeper.server.persistence.TxnLog$TxnIterator: long getStorageSize()>();
v = v cmp v;
if v <= 0 goto label;
v = <oadd.org.apache.zookeeper.server.ZKDatabase: org.slf4j.Logger LOG>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (long,long)>(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[])>("Txnlog size: \u exceeds sizeLimit: \u0001");
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>(v);
interfaceinvoke v.<oadd.org.apache.zookeeper.server.persistence.TxnLog$TxnIterator: void close()>();
v = <oadd.org.apache.zookeeper.server.TxnLogProposalIterator: oadd.org.apache.zookeeper.server.TxnLogProposalIterator EMPTY_ITERATOR>;
label:
return v;
label:
v := @caughtexception;
v = <oadd.org.apache.zookeeper.server.ZKDatabase: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Throwable)>("Unable to read txnlog from disk", v);
label:
if v == null goto label;
interfaceinvoke v.<oadd.org.apache.zookeeper.server.persistence.TxnLog$TxnIterator: void close()>();
label:
goto label;
label:
v := @caughtexception;
v = <oadd.org.apache.zookeeper.server.ZKDatabase: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String,java.lang.Throwable)>("Error closing file iterator", v);
label:
v = <oadd.org.apache.zookeeper.server.TxnLogProposalIterator: oadd.org.apache.zookeeper.server.TxnLogProposalIterator EMPTY_ITERATOR>;
return v;
label:
v = new oadd.org.apache.zookeeper.server.TxnLogProposalIterator;
specialinvoke v.<oadd.org.apache.zookeeper.server.TxnLogProposalIterator: void <init>(oadd.org.apache.zookeeper.server.persistence.TxnLog$TxnIterator)>(v);
return v;
catch java.io.IOException from label to label with label;
catch java.io.IOException from label to label with label;
catch java.io.IOException from label to label with label;
}
public java.util.List aclForNode(oadd.org.apache.zookeeper.server.DataNode)
{
java.util.List v;
oadd.org.apache.zookeeper.server.DataNode v;
oadd.org.apache.zookeeper.server.ZKDatabase v;
oadd.org.apache.zookeeper.server.DataTree v;
v := @this: oadd.org.apache.zookeeper.server.ZKDatabase;
v := @parameter: oadd.org.apache.zookeeper.server.DataNode;
v = v.<oadd.org.apache.zookeeper.server.ZKDatabase: oadd.org.apache.zookeeper.server.DataTree dataTree>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.DataTree: java.util.List getACL(oadd.org.apache.zookeeper.server.DataNode)>(v);
return v;
}
public void removeCnxn(oadd.org.apache.zookeeper.server.ServerCnxn)
{
oadd.org.apache.zookeeper.server.ZKDatabase v;
oadd.org.apache.zookeeper.server.DataTree v;
oadd.org.apache.zookeeper.server.ServerCnxn v;
v := @this: oadd.org.apache.zookeeper.server.ZKDatabase;
v := @parameter: oadd.org.apache.zookeeper.server.ServerCnxn;
v = v.<oadd.org.apache.zookeeper.server.ZKDatabase: oadd.org.apache.zookeeper.server.DataTree dataTree>;
virtualinvoke v.<oadd.org.apache.zookeeper.server.DataTree: void removeCnxn(oadd.org.apache.zookeeper.Watcher)>(v);
return;
}
public void killSession(long, long)
{
oadd.org.apache.zookeeper.server.ZKDatabase v;
long v, v;
oadd.org.apache.zookeeper.server.DataTree v;
v := @this: oadd.org.apache.zookeeper.server.ZKDatabase;
v := @parameter: long;
v := @parameter: long;
v = v.<oadd.org.apache.zookeeper.server.ZKDatabase: oadd.org.apache.zookeeper.server.DataTree dataTree>;
virtualinvoke v.<oadd.org.apache.zookeeper.server.DataTree: void killSession(long,long)>(v, v);
return;
}
public void dumpEphemerals(java.io.PrintWriter)
{
java.io.PrintWriter v;
oadd.org.apache.zookeeper.server.ZKDatabase v;
oadd.org.apache.zookeeper.server.DataTree v;
v := @this: oadd.org.apache.zookeeper.server.ZKDatabase;
v := @parameter: java.io.PrintWriter;
v = v.<oadd.org.apache.zookeeper.server.ZKDatabase: oadd.org.apache.zookeeper.server.DataTree dataTree>;
virtualinvoke v.<oadd.org.apache.zookeeper.server.DataTree: void dumpEphemerals(java.io.PrintWriter)>(v);
return;
}
public java.util.Map getEphemerals()
{
oadd.org.apache.zookeeper.server.ZKDatabase v;
oadd.org.apache.zookeeper.server.DataTree v;
java.util.Map v;
v := @this: oadd.org.apache.zookeeper.server.ZKDatabase;
v = v.<oadd.org.apache.zookeeper.server.ZKDatabase: oadd.org.apache.zookeeper.server.DataTree dataTree>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.DataTree: java.util.Map getEphemerals()>();
return v;
}
public int getNodeCount()
{
int v;
oadd.org.apache.zookeeper.server.ZKDatabase v;
oadd.org.apache.zookeeper.server.DataTree v;
v := @this: oadd.org.apache.zookeeper.server.ZKDatabase;
v = v.<oadd.org.apache.zookeeper.server.ZKDatabase: oadd.org.apache.zookeeper.server.DataTree dataTree>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.DataTree: int getNodeCount()>();
return v;
}
public java.util.Set getEphemerals(long)
{
java.util.Set v;
oadd.org.apache.zookeeper.server.ZKDatabase v;
long v;
oadd.org.apache.zookeeper.server.DataTree v;
v := @this: oadd.org.apache.zookeeper.server.ZKDatabase;
v := @parameter: long;
v = v.<oadd.org.apache.zookeeper.server.ZKDatabase: oadd.org.apache.zookeeper.server.DataTree dataTree>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.DataTree: java.util.Set getEphemerals(long)>(v);
return v;
}
public void setlastProcessedZxid(long)
{
oadd.org.apache.zookeeper.server.ZKDatabase v;
long v;
oadd.org.apache.zookeeper.server.DataTree v;
v := @this: oadd.org.apache.zookeeper.server.ZKDatabase;
v := @parameter: long;
v = v.<oadd.org.apache.zookeeper.server.ZKDatabase: oadd.org.apache.zookeeper.server.DataTree dataTree>;
v.<oadd.org.apache.zookeeper.server.DataTree: long lastProcessedZxid> = v;
return;
}
public oadd.org.apache.zookeeper.server.DataTree$ProcessTxnResult processTxn(oadd.org.apache.zookeeper.txn.TxnHeader, oadd.org.apache.jute.Record)
{
oadd.org.apache.jute.Record v;
oadd.org.apache.zookeeper.server.DataTree$ProcessTxnResult v;
oadd.org.apache.zookeeper.server.ZKDatabase v;
oadd.org.apache.zookeeper.txn.TxnHeader v;
oadd.org.apache.zookeeper.server.DataTree v;
v := @this: oadd.org.apache.zookeeper.server.ZKDatabase;
v := @parameter: oadd.org.apache.zookeeper.txn.TxnHeader;
v := @parameter: oadd.org.apache.jute.Record;
v = v.<oadd.org.apache.zookeeper.server.ZKDatabase: oadd.org.apache.zookeeper.server.DataTree dataTree>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.DataTree: oadd.org.apache.zookeeper.server.DataTree$ProcessTxnResult processTxn(oadd.org.apache.zookeeper.txn.TxnHeader,oadd.org.apache.jute.Record)>(v, v);
return v;
}
public oadd.org.apache.zookeeper.data.Stat statNode(java.lang.String, oadd.org.apache.zookeeper.server.ServerCnxn) throws oadd.org.apache.zookeeper.KeeperException$NoNodeException
{
oadd.org.apache.zookeeper.server.ServerCnxn v;
oadd.org.apache.zookeeper.server.ZKDatabase v;
java.lang.String v;
oadd.org.apache.zookeeper.server.DataTree v;
oadd.org.apache.zookeeper.data.Stat v;
v := @this: oadd.org.apache.zookeeper.server.ZKDatabase;
v := @parameter: java.lang.String;
v := @parameter: oadd.org.apache.zookeeper.server.ServerCnxn;
v = v.<oadd.org.apache.zookeeper.server.ZKDatabase: oadd.org.apache.zookeeper.server.DataTree dataTree>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.DataTree: oadd.org.apache.zookeeper.data.Stat statNode(java.lang.String,oadd.org.apache.zookeeper.Watcher)>(v, v);
return v;
}
public oadd.org.apache.zookeeper.server.DataNode getNode(java.lang.String)
{
oadd.org.apache.zookeeper.server.DataNode v;
oadd.org.apache.zookeeper.server.ZKDatabase v;
java.lang.String v;
oadd.org.apache.zookeeper.server.DataTree v;
v := @this: oadd.org.apache.zookeeper.server.ZKDatabase;
v := @parameter: java.lang.String;
v = v.<oadd.org.apache.zookeeper.server.ZKDatabase: oadd.org.apache.zookeeper.server.DataTree dataTree>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.DataTree: oadd.org.apache.zookeeper.server.DataNode getNode(java.lang.String)>(v);
return v;
}
public byte[] getData(java.lang.String, oadd.org.apache.zookeeper.data.Stat, oadd.org.apache.zookeeper.Watcher) throws oadd.org.apache.zookeeper.KeeperException$NoNodeException
{
byte[] v;
oadd.org.apache.zookeeper.Watcher v;
oadd.org.apache.zookeeper.server.ZKDatabase v;
java.lang.String v;
oadd.org.apache.zookeeper.server.DataTree v;
oadd.org.apache.zookeeper.data.Stat v;
v := @this: oadd.org.apache.zookeeper.server.ZKDatabase;
v := @parameter: java.lang.String;
v := @parameter: oadd.org.apache.zookeeper.data.Stat;
v := @parameter: oadd.org.apache.zookeeper.Watcher;
v = v.<oadd.org.apache.zookeeper.server.ZKDatabase: oadd.org.apache.zookeeper.server.DataTree dataTree>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.DataTree: byte[] getData(java.lang.String,oadd.org.apache.zookeeper.data.Stat,oadd.org.apache.zookeeper.Watcher)>(v, v, v);
return v;
}
public void setWatches(long, java.util.List, java.util.List, java.util.List, oadd.org.apache.zookeeper.Watcher)
{
java.util.List v, v, v;
oadd.org.apache.zookeeper.Watcher v;
oadd.org.apache.zookeeper.server.ZKDatabase v;
long v;
oadd.org.apache.zookeeper.server.DataTree v;
v := @this: oadd.org.apache.zookeeper.server.ZKDatabase;
v := @parameter: long;
v := @parameter: java.util.List;
v := @parameter: java.util.List;
v := @parameter: java.util.List;
v := @parameter: oadd.org.apache.zookeeper.Watcher;
v = v.<oadd.org.apache.zookeeper.server.ZKDatabase: oadd.org.apache.zookeeper.server.DataTree dataTree>;
virtualinvoke v.<oadd.org.apache.zookeeper.server.DataTree: void setWatches(long,java.util.List,java.util.List,java.util.List,oadd.org.apache.zookeeper.Watcher)>(v, v, v, v, v);
return;
}
public java.util.List getACL(java.lang.String, oadd.org.apache.zookeeper.data.Stat) throws oadd.org.apache.zookeeper.KeeperException$NoNodeException
{
java.util.List v;
oadd.org.apache.zookeeper.server.ZKDatabase v;
java.lang.String v;
oadd.org.apache.zookeeper.server.DataTree v;
oadd.org.apache.zookeeper.data.Stat v;
v := @this: oadd.org.apache.zookeeper.server.ZKDatabase;
v := @parameter: java.lang.String;
v := @parameter: oadd.org.apache.zookeeper.data.Stat;
v = v.<oadd.org.apache.zookeeper.server.ZKDatabase: oadd.org.apache.zookeeper.server.DataTree dataTree>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.DataTree: java.util.List getACL(java.lang.String,oadd.org.apache.zookeeper.data.Stat)>(v, v);
return v;
}
public java.util.List getChildren(java.lang.String, oadd.org.apache.zookeeper.data.Stat, oadd.org.apache.zookeeper.Watcher) throws oadd.org.apache.zookeeper.KeeperException$NoNodeException
{
java.util.List v;
oadd.org.apache.zookeeper.Watcher v;
oadd.org.apache.zookeeper.server.ZKDatabase v;
java.lang.String v;
oadd.org.apache.zookeeper.server.DataTree v;
oadd.org.apache.zookeeper.data.Stat v;
v := @this: oadd.org.apache.zookeeper.server.ZKDatabase;
v := @parameter: java.lang.String;
v := @parameter: oadd.org.apache.zookeeper.data.Stat;
v := @parameter: oadd.org.apache.zookeeper.Watcher;
v = v.<oadd.org.apache.zookeeper.server.ZKDatabase: oadd.org.apache.zookeeper.server.DataTree dataTree>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.DataTree: java.util.List getChildren(java.lang.String,oadd.org.apache.zookeeper.data.Stat,oadd.org.apache.zookeeper.Watcher)>(v, v, v);
return v;
}
public boolean isSpecialPath(java.lang.String)
{
oadd.org.apache.zookeeper.server.ZKDatabase v;
java.lang.String v;
oadd.org.apache.zookeeper.server.DataTree v;
boolean v;
v := @this: oadd.org.apache.zookeeper.server.ZKDatabase;
v := @parameter: java.lang.String;
v = v.<oadd.org.apache.zookeeper.server.ZKDatabase: oadd.org.apache.zookeeper.server.DataTree dataTree>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.DataTree: boolean isSpecialPath(java.lang.String)>(v);
return v;
}
public int getAclSize()
{
int v;
oadd.org.apache.zookeeper.server.ZKDatabase v;
oadd.org.apache.zookeeper.server.DataTree v;
v := @this: oadd.org.apache.zookeeper.server.ZKDatabase;
v = v.<oadd.org.apache.zookeeper.server.ZKDatabase: oadd.org.apache.zookeeper.server.DataTree dataTree>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.DataTree: int aclCacheSize()>();
return v;
}
public boolean truncateLog(long) throws java.io.IOException
{
oadd.org.apache.zookeeper.server.ZKDatabase v;
long v;
oadd.org.apache.zookeeper.server.persistence.FileTxnSnapLog v;
boolean v;
v := @this: oadd.org.apache.zookeeper.server.ZKDatabase;
v := @parameter: long;
virtualinvoke v.<oadd.org.apache.zookeeper.server.ZKDatabase: void clear()>();
v = v.<oadd.org.apache.zookeeper.server.ZKDatabase: oadd.org.apache.zookeeper.server.persistence.FileTxnSnapLog snapLog>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.persistence.FileTxnSnapLog: boolean truncateLog(long)>(v);
if v != 0 goto label;
return 0;
label:
virtualinvoke v.<oadd.org.apache.zookeeper.server.ZKDatabase: long loadDataBase()>();
return 1;
}
public void deserializeSnapshot(oadd.org.apache.jute.InputArchive) throws java.io.IOException
{
java.util.concurrent.ConcurrentHashMap v;
oadd.org.apache.zookeeper.server.ZKDatabase v;
oadd.org.apache.jute.InputArchive v;
oadd.org.apache.zookeeper.server.DataTree v;
v := @this: oadd.org.apache.zookeeper.server.ZKDatabase;
v := @parameter: oadd.org.apache.jute.InputArchive;
virtualinvoke v.<oadd.org.apache.zookeeper.server.ZKDatabase: void clear()>();
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.ZKDatabase: oadd.org.apache.zookeeper.server.DataTree getDataTree()>();
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.ZKDatabase: java.util.concurrent.ConcurrentHashMap getSessionWithTimeOuts()>();
staticinvoke <oadd.org.apache.zookeeper.server.util.SerializeUtils: void deserializeSnapshot(oadd.org.apache.zookeeper.server.DataTree,oadd.org.apache.jute.InputArchive,java.util.Map)>(v, v, v);
v.<oadd.org.apache.zookeeper.server.ZKDatabase: boolean initialized> = 1;
return;
}
public void serializeSnapshot(oadd.org.apache.jute.OutputArchive) throws java.io.IOException, java.lang.InterruptedException
{
oadd.org.apache.jute.OutputArchive v;
java.util.concurrent.ConcurrentHashMap v;
oadd.org.apache.zookeeper.server.ZKDatabase v;
oadd.org.apache.zookeeper.server.DataTree v;
v := @this: oadd.org.apache.zookeeper.server.ZKDatabase;
v := @parameter: oadd.org.apache.jute.OutputArchive;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.ZKDatabase: oadd.org.apache.zookeeper.server.DataTree getDataTree()>();
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.ZKDatabase: java.util.concurrent.ConcurrentHashMap getSessionWithTimeOuts()>();
staticinvoke <oadd.org.apache.zookeeper.server.util.SerializeUtils: void serializeSnapshot(oadd.org.apache.zookeeper.server.DataTree,oadd.org.apache.jute.OutputArchive,java.util.Map)>(v, v, v);
return;
}
public boolean append(oadd.org.apache.zookeeper.server.Request) throws java.io.IOException
{
oadd.org.apache.zookeeper.server.Request v;
oadd.org.apache.zookeeper.server.ZKDatabase v;
oadd.org.apache.zookeeper.server.persistence.FileTxnSnapLog v;
boolean v;
v := @this: oadd.org.apache.zookeeper.server.ZKDatabase;
v := @parameter: oadd.org.apache.zookeeper.server.Request;
v = v.<oadd.org.apache.zookeeper.server.ZKDatabase: oadd.org.apache.zookeeper.server.persistence.FileTxnSnapLog snapLog>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.persistence.FileTxnSnapLog: boolean append(oadd.org.apache.zookeeper.server.Request)>(v);
return v;
}
public void rollLog() throws java.io.IOException
{
oadd.org.apache.zookeeper.server.ZKDatabase v;
oadd.org.apache.zookeeper.server.persistence.FileTxnSnapLog v;
v := @this: oadd.org.apache.zookeeper.server.ZKDatabase;
v = v.<oadd.org.apache.zookeeper.server.ZKDatabase: oadd.org.apache.zookeeper.server.persistence.FileTxnSnapLog snapLog>;
virtualinvoke v.<oadd.org.apache.zookeeper.server.persistence.FileTxnSnapLog: void rollLog()>();
return;
}
public void commit() throws java.io.IOException
{
oadd.org.apache.zookeeper.server.ZKDatabase v;
oadd.org.apache.zookeeper.server.persistence.FileTxnSnapLog v;
v := @this: oadd.org.apache.zookeeper.server.ZKDatabase;
v = v.<oadd.org.apache.zookeeper.server.ZKDatabase: oadd.org.apache.zookeeper.server.persistence.FileTxnSnapLog snapLog>;
virtualinvoke v.<oadd.org.apache.zookeeper.server.persistence.FileTxnSnapLog: void commit()>();
return;
}
public void close() throws java.io.IOException
{
oadd.org.apache.zookeeper.server.ZKDatabase v;
oadd.org.apache.zookeeper.server.persistence.FileTxnSnapLog v;
v := @this: oadd.org.apache.zookeeper.server.ZKDatabase;
v = v.<oadd.org.apache.zookeeper.server.ZKDatabase: oadd.org.apache.zookeeper.server.persistence.FileTxnSnapLog snapLog>;
virtualinvoke v.<oadd.org.apache.zookeeper.server.persistence.FileTxnSnapLog: void close()>();
return;
}
public synchronized void initConfigInZKDatabase(oadd.org.apache.zookeeper.server.quorum.flexible.QuorumVerifier)
{
java.io.PrintStream v;
byte[] v;
oadd.org.apache.zookeeper.server.DataNode v;
org.slf4j.Logger v;
oadd.org.apache.zookeeper.server.quorum.flexible.QuorumVerifier v;
long v, v;
oadd.org.apache.zookeeper.KeeperException$NoNodeException v;
oadd.org.apache.zookeeper.server.DataTree v, v, v;
int v;
oadd.org.apache.zookeeper.server.ZKDatabase v;
java.lang.String v;
v := @this: oadd.org.apache.zookeeper.server.ZKDatabase;
v := @parameter: oadd.org.apache.zookeeper.server.quorum.flexible.QuorumVerifier;
if v != null goto label;
return;
label:
v = v.<oadd.org.apache.zookeeper.server.ZKDatabase: oadd.org.apache.zookeeper.server.DataTree dataTree>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.DataTree: oadd.org.apache.zookeeper.server.DataNode getNode(java.lang.String)>("/zookeeper/config");
if v != null goto label;
v = <oadd.org.apache.zookeeper.server.ZKDatabase: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String)>("configuration znode missing (should only happen during upgrade), creating the node");
v = v.<oadd.org.apache.zookeeper.server.ZKDatabase: oadd.org.apache.zookeeper.server.DataTree dataTree>;
virtualinvoke v.<oadd.org.apache.zookeeper.server.DataTree: void addConfigNode()>();
label:
v = v.<oadd.org.apache.zookeeper.server.ZKDatabase: oadd.org.apache.zookeeper.server.DataTree dataTree>;
v = interfaceinvoke v.<oadd.org.apache.zookeeper.server.quorum.flexible.QuorumVerifier: java.lang.String toString()>();
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
v = interfaceinvoke v.<oadd.org.apache.zookeeper.server.quorum.flexible.QuorumVerifier: long getVersion()>();
v = staticinvoke <oadd.org.apache.zookeeper.common.Time: long currentWallTime()>();
v = (int) -1;
virtualinvoke v.<oadd.org.apache.zookeeper.server.DataTree: oadd.org.apache.zookeeper.data.Stat setData(java.lang.String,byte[],int,long,long)>("/zookeeper/config", v, v, v, v);
label:
goto label;
label:
v := @caughtexception;
v = <java.lang.System: java.io.PrintStream out>;
virtualinvoke v.<java.io.PrintStream: void println(java.lang.String)>("configuration node missing - should not happen");
label:
return;
catch oadd.org.apache.zookeeper.KeeperException$NoNodeException from label to label with label;
}
public void setSnapshotSizeFactor(double)
{
oadd.org.apache.zookeeper.server.ZKDatabase v;
double v;
v := @this: oadd.org.apache.zookeeper.server.ZKDatabase;
v := @parameter: double;
v.<oadd.org.apache.zookeeper.server.ZKDatabase: double snapshotSizeFactor> = v;
return;
}
public boolean containsWatcher(java.lang.String, oadd.org.apache.zookeeper.Watcher$WatcherType, oadd.org.apache.zookeeper.Watcher)
{
oadd.org.apache.zookeeper.Watcher v;
oadd.org.apache.zookeeper.server.ZKDatabase v;
java.lang.String v;
oadd.org.apache.zookeeper.server.DataTree v;
oadd.org.apache.zookeeper.Watcher$WatcherType v;
boolean v;
v := @this: oadd.org.apache.zookeeper.server.ZKDatabase;
v := @parameter: java.lang.String;
v := @parameter: oadd.org.apache.zookeeper.Watcher$WatcherType;
v := @parameter: oadd.org.apache.zookeeper.Watcher;
v = v.<oadd.org.apache.zookeeper.server.ZKDatabase: oadd.org.apache.zookeeper.server.DataTree dataTree>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.DataTree: boolean containsWatcher(java.lang.String,oadd.org.apache.zookeeper.Watcher$WatcherType,oadd.org.apache.zookeeper.Watcher)>(v, v, v);
return v;
}
public boolean removeWatch(java.lang.String, oadd.org.apache.zookeeper.Watcher$WatcherType, oadd.org.apache.zookeeper.Watcher)
{
oadd.org.apache.zookeeper.Watcher v;
oadd.org.apache.zookeeper.server.ZKDatabase v;
java.lang.String v;
oadd.org.apache.zookeeper.server.DataTree v;
oadd.org.apache.zookeeper.Watcher$WatcherType v;
boolean v;
v := @this: oadd.org.apache.zookeeper.server.ZKDatabase;
v := @parameter: java.lang.String;
v := @parameter: oadd.org.apache.zookeeper.Watcher$WatcherType;
v := @parameter: oadd.org.apache.zookeeper.Watcher;
v = v.<oadd.org.apache.zookeeper.server.ZKDatabase: oadd.org.apache.zookeeper.server.DataTree dataTree>;
v = virtualinvoke v.<oadd.org.apache.zookeeper.server.DataTree: boolean removeWatch(java.lang.String,oadd.org.apache.zookeeper.Watcher$WatcherType,oadd.org.apache.zookeeper.Watcher)>(v, v, v);
return v;
}
public oadd.org.apache.zookeeper.server.DataTree createDataTree()
{
oadd.org.apache.zookeeper.server.ZKDatabase v;
oadd.org.apache.zookeeper.server.DataTree v;
v := @this: oadd.org.apache.zookeeper.server.ZKDatabase;
v = new oadd.org.apache.zookeeper.server.DataTree;
specialinvoke v.<oadd.org.apache.zookeeper.server.DataTree: void <init>()>();
return v;
}
static void <clinit>()
{
org.slf4j.Logger v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Loadd/org/apache/zookeeper/server/ZKDatabase;");
<oadd.org.apache.zookeeper.server.ZKDatabase: org.slf4j.Logger LOG> = v;
<oadd.org.apache.zookeeper.server.ZKDatabase: int commitLogBuffer> = 700;
return;
}
}