public class org.apache.activemq.leveldb.LevelDBClient extends java.lang.Object
{
public final org.apache.activemq.leveldb.LevelDBStore org$apache$activemq$leveldb$LevelDBClient$$store;
private final org.fusesource.hawtdispatch.DispatchQueue dispatchQueue;
private org.apache.activemq.leveldb.RecordLog log;
private org.apache.activemq.leveldb.LevelDBClient$RichDB index;
private org.apache.activemq.leveldb.LevelDBClient$RichDB plist;
private org.iq.leveldb.Options indexOptions;
private long lastIndexSnapshotPos;
private final java.util.concurrent.locks.ReentrantReadWriteLock snapshotRwLock;
private org.iq.leveldb.DBFactory factory;
private final scala.collection.mutable.HashMap logRefs;
private java.util.TreeMap recoveryLogs;
private final scala.collection.mutable.HashMap collectionMeta;
private java.util.concurrent.ExecutorService writeExecutor;
private org.iq.leveldb.WriteBatch replay_write_batch;
private long indexRecoveryPosition;
private long stored_wal_append_position;
private final org.apache.activemq.leveldb.util.TimeMetric max_write_message_latency;
private final org.apache.activemq.leveldb.util.TimeMetric max_write_enqueue_latency;
private final org.apache.activemq.leveldb.util.TimeMetric max_index_write_latency;
public static void trace(java.lang.Throwable)
{
java.lang.Throwable v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @parameter: java.lang.Throwable;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: void trace(java.lang.Throwable)>(v);
return;
}
public static void trace(java.lang.Throwable, scala.Function, scala.collection.Seq)
{
java.lang.Throwable v;
scala.collection.Seq v;
scala.Function v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @parameter: java.lang.Throwable;
v := @parameter: scala.Function;
v := @parameter: scala.collection.Seq;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: void trace(java.lang.Throwable,scala.Function,scala.collection.Seq)>(v, v, v);
return;
}
public static void trace(scala.Function, scala.collection.Seq)
{
scala.Function v;
org.apache.activemq.leveldb.LevelDBClient$ v;
scala.collection.Seq v;
v := @parameter: scala.Function;
v := @parameter: scala.collection.Seq;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: void trace(scala.Function,scala.collection.Seq)>(v, v);
return;
}
public static void debug(java.lang.Throwable)
{
java.lang.Throwable v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @parameter: java.lang.Throwable;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: void debug(java.lang.Throwable)>(v);
return;
}
public static void debug(java.lang.Throwable, scala.Function, scala.collection.Seq)
{
java.lang.Throwable v;
scala.collection.Seq v;
scala.Function v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @parameter: java.lang.Throwable;
v := @parameter: scala.Function;
v := @parameter: scala.collection.Seq;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: void debug(java.lang.Throwable,scala.Function,scala.collection.Seq)>(v, v, v);
return;
}
public static void debug(scala.Function, scala.collection.Seq)
{
scala.Function v;
org.apache.activemq.leveldb.LevelDBClient$ v;
scala.collection.Seq v;
v := @parameter: scala.Function;
v := @parameter: scala.collection.Seq;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: void debug(scala.Function,scala.collection.Seq)>(v, v);
return;
}
public static void info(java.lang.Throwable)
{
java.lang.Throwable v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @parameter: java.lang.Throwable;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: void info(java.lang.Throwable)>(v);
return;
}
public static void info(java.lang.Throwable, scala.Function, scala.collection.Seq)
{
java.lang.Throwable v;
scala.collection.Seq v;
scala.Function v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @parameter: java.lang.Throwable;
v := @parameter: scala.Function;
v := @parameter: scala.collection.Seq;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: void info(java.lang.Throwable,scala.Function,scala.collection.Seq)>(v, v, v);
return;
}
public static void info(scala.Function, scala.collection.Seq)
{
scala.Function v;
org.apache.activemq.leveldb.LevelDBClient$ v;
scala.collection.Seq v;
v := @parameter: scala.Function;
v := @parameter: scala.collection.Seq;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: void info(scala.Function,scala.collection.Seq)>(v, v);
return;
}
public static void warn(java.lang.Throwable)
{
java.lang.Throwable v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @parameter: java.lang.Throwable;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: void warn(java.lang.Throwable)>(v);
return;
}
public static void warn(java.lang.Throwable, scala.Function, scala.collection.Seq)
{
java.lang.Throwable v;
scala.collection.Seq v;
scala.Function v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @parameter: java.lang.Throwable;
v := @parameter: scala.Function;
v := @parameter: scala.collection.Seq;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: void warn(java.lang.Throwable,scala.Function,scala.collection.Seq)>(v, v, v);
return;
}
public static void warn(scala.Function, scala.collection.Seq)
{
scala.Function v;
org.apache.activemq.leveldb.LevelDBClient$ v;
scala.collection.Seq v;
v := @parameter: scala.Function;
v := @parameter: scala.collection.Seq;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: void warn(scala.Function,scala.collection.Seq)>(v, v);
return;
}
public static void error(java.lang.Throwable)
{
java.lang.Throwable v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @parameter: java.lang.Throwable;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: void error(java.lang.Throwable)>(v);
return;
}
public static void error(java.lang.Throwable, scala.Function, scala.collection.Seq)
{
java.lang.Throwable v;
scala.collection.Seq v;
scala.Function v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @parameter: java.lang.Throwable;
v := @parameter: scala.Function;
v := @parameter: scala.collection.Seq;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: void error(java.lang.Throwable,scala.Function,scala.collection.Seq)>(v, v, v);
return;
}
public static void error(scala.Function, scala.collection.Seq)
{
scala.Function v;
org.apache.activemq.leveldb.LevelDBClient$ v;
scala.collection.Seq v;
v := @parameter: scala.Function;
v := @parameter: scala.collection.Seq;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: void error(scala.Function,scala.collection.Seq)>(v, v);
return;
}
public static void org$apache$activemq$leveldb$util$Log$_setter_$log_$eq(org.slf4j.Logger)
{
org.slf4j.Logger v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @parameter: org.slf4j.Logger;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: void org$apache$activemq$leveldb$util$Log$_setter_$log_$eq(org.slf4j.Logger)>(v);
return;
}
public static void copyIndex(java.io.File, java.io.File)
{
java.io.File v, v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @parameter: java.io.File;
v := @parameter: java.io.File;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: void copyIndex(java.io.File,java.io.File)>(v, v);
return;
}
public static scala.collection.immutable.TreeMap find_sequence_files(java.io.File, java.lang.String)
{
scala.collection.immutable.TreeMap v;
java.lang.String v;
java.io.File v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @parameter: java.io.File;
v := @parameter: java.lang.String;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: scala.collection.immutable.TreeMap find_sequence_files(java.io.File,java.lang.String)>(v, v);
return v;
}
public static java.io.File create_sequence_file(java.io.File, long, java.lang.String)
{
long v;
java.lang.String v;
java.io.File v, v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @parameter: java.io.File;
v := @parameter: long;
v := @parameter: java.lang.String;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: java.io.File create_sequence_file(java.io.File,long,java.lang.String)>(v, v, v);
return v;
}
public static byte[] bytes(java.lang.String)
{
byte[] v;
java.lang.String v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @parameter: java.lang.String;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: byte[] bytes(java.lang.String)>(v);
return v;
}
public static scala.Tuple decodeEntryKey(byte[])
{
byte[] v;
scala.Tuple v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @parameter: byte[];
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: scala.Tuple decodeEntryKey(byte[])>(v);
return v;
}
public static byte[] encodeEntryKey(byte, long, org.fusesource.hawtbuf.Buffer)
{
byte[] v;
byte v;
long v;
org.fusesource.hawtbuf.Buffer v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @parameter: byte;
v := @parameter: long;
v := @parameter: org.fusesource.hawtbuf.Buffer;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: byte[] encodeEntryKey(byte,long,org.fusesource.hawtbuf.Buffer)>(v, v, v);
return v;
}
public static byte[] encodeEntryKey(byte, long, long)
{
byte[] v;
byte v;
long v, v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @parameter: byte;
v := @parameter: long;
v := @parameter: long;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: byte[] encodeEntryKey(byte,long,long)>(v, v, v);
return v;
}
public static long decodeLong(byte[])
{
byte[] v;
long v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @parameter: byte[];
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: long decodeLong(byte[])>(v);
return v;
}
public static long decodeLong(org.fusesource.hawtbuf.Buffer)
{
long v;
org.fusesource.hawtbuf.Buffer v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @parameter: org.fusesource.hawtbuf.Buffer;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: long decodeLong(org.fusesource.hawtbuf.Buffer)>(v);
return v;
}
public static scala.Tuple decodeLongKey(byte[])
{
byte[] v;
scala.Tuple v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @parameter: byte[];
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: scala.Tuple decodeLongKey(byte[])>(v);
return v;
}
public static byte[] encodeLongKey(byte, long)
{
byte[] v;
byte v;
long v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @parameter: byte;
v := @parameter: long;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: byte[] encodeLongKey(byte,long)>(v, v);
return v;
}
public static long decodeVLong(byte[])
{
byte[] v;
long v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @parameter: byte[];
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: long decodeVLong(byte[])>(v);
return v;
}
public static byte[] encodeVLong(long)
{
byte[] v;
long v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @parameter: long;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: byte[] encodeVLong(long)>(v);
return v;
}
public static org.fusesource.hawtbuf.Buffer encodeLong(long)
{
long v;
org.fusesource.hawtbuf.Buffer v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @parameter: long;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: org.fusesource.hawtbuf.Buffer encodeLong(long)>(v);
return v;
}
public static scala.Tuple decodeLongLong(byte[])
{
byte[] v;
scala.Tuple v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @parameter: byte[];
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: scala.Tuple decodeLongLong(byte[])>(v);
return v;
}
public static org.fusesource.hawtbuf.Buffer encodeLongLong(long, long)
{
long v, v;
org.fusesource.hawtbuf.Buffer v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @parameter: long;
v := @parameter: long;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: org.fusesource.hawtbuf.Buffer encodeLongLong(long,long)>(v, v);
return v;
}
public static scala.Tuple decodeLocator(byte[])
{
byte[] v;
scala.Tuple v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @parameter: byte[];
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: scala.Tuple decodeLocator(byte[])>(v);
return v;
}
public static scala.Tuple decodeLocator(org.fusesource.hawtbuf.Buffer)
{
scala.Tuple v;
org.fusesource.hawtbuf.Buffer v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @parameter: org.fusesource.hawtbuf.Buffer;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: scala.Tuple decodeLocator(org.fusesource.hawtbuf.Buffer)>(v);
return v;
}
public static byte[] encodeLocator(long, int)
{
byte[] v;
int v;
long v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @parameter: long;
v := @parameter: int;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: byte[] encodeLocator(long,int)>(v, v);
return v;
}
public static org.apache.activemq.leveldb.record.EntryKey$Buffer decodeEntryKeyRecord(org.fusesource.hawtbuf.Buffer)
{
org.apache.activemq.leveldb.record.EntryKey$Buffer v;
org.fusesource.hawtbuf.Buffer v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @parameter: org.fusesource.hawtbuf.Buffer;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.record.EntryKey$Buffer decodeEntryKeyRecord(org.fusesource.hawtbuf.Buffer)>(v);
return v;
}
public static byte[] encodeEntryKeyRecord(org.apache.activemq.leveldb.record.EntryKey$Buffer)
{
org.apache.activemq.leveldb.record.EntryKey$Buffer v;
byte[] v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @parameter: org.apache.activemq.leveldb.record.EntryKey$Buffer;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: byte[] encodeEntryKeyRecord(org.apache.activemq.leveldb.record.EntryKey$Buffer)>(v);
return v;
}
public static org.apache.activemq.leveldb.record.EntryRecord$Buffer decodeEntryRecord(org.fusesource.hawtbuf.Buffer)
{
org.apache.activemq.leveldb.record.EntryRecord$Buffer v;
org.fusesource.hawtbuf.Buffer v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @parameter: org.fusesource.hawtbuf.Buffer;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.record.EntryRecord$Buffer decodeEntryRecord(org.fusesource.hawtbuf.Buffer)>(v);
return v;
}
public static org.fusesource.hawtbuf.Buffer encodeEntryRecord(org.apache.activemq.leveldb.record.EntryRecord$Buffer)
{
org.apache.activemq.leveldb.record.EntryRecord$Buffer v;
org.fusesource.hawtbuf.Buffer v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @parameter: org.apache.activemq.leveldb.record.EntryRecord$Buffer;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: org.fusesource.hawtbuf.Buffer encodeEntryRecord(org.apache.activemq.leveldb.record.EntryRecord$Buffer)>(v);
return v;
}
public static org.apache.activemq.leveldb.record.CollectionKey$Buffer decodeCollectionKeyRecord(org.fusesource.hawtbuf.Buffer)
{
org.apache.activemq.leveldb.record.CollectionKey$Buffer v;
org.fusesource.hawtbuf.Buffer v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @parameter: org.fusesource.hawtbuf.Buffer;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.record.CollectionKey$Buffer decodeCollectionKeyRecord(org.fusesource.hawtbuf.Buffer)>(v);
return v;
}
public static byte[] encodeCollectionKeyRecord(org.apache.activemq.leveldb.record.CollectionKey$Buffer)
{
byte[] v;
org.apache.activemq.leveldb.record.CollectionKey$Buffer v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @parameter: org.apache.activemq.leveldb.record.CollectionKey$Buffer;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: byte[] encodeCollectionKeyRecord(org.apache.activemq.leveldb.record.CollectionKey$Buffer)>(v);
return v;
}
public static org.apache.activemq.leveldb.record.CollectionRecord$Buffer decodeCollectionRecord(org.fusesource.hawtbuf.Buffer)
{
org.apache.activemq.leveldb.record.CollectionRecord$Buffer v;
org.fusesource.hawtbuf.Buffer v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @parameter: org.fusesource.hawtbuf.Buffer;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.record.CollectionRecord$Buffer decodeCollectionRecord(org.fusesource.hawtbuf.Buffer)>(v);
return v;
}
public static byte[] encodeCollectionRecord(org.apache.activemq.leveldb.record.CollectionRecord$Buffer)
{
byte[] v;
org.apache.activemq.leveldb.record.CollectionRecord$Buffer v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @parameter: org.apache.activemq.leveldb.record.CollectionRecord$Buffer;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: byte[] encodeCollectionRecord(org.apache.activemq.leveldb.record.CollectionRecord$Buffer)>(v);
return v;
}
public static org.fusesource.hawtbuf.Buffer toBuffer(byte[])
{
byte[] v;
org.fusesource.hawtbuf.Buffer v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @parameter: byte[];
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: org.fusesource.hawtbuf.Buffer toBuffer(byte[])>(v);
return v;
}
public static byte[] toByteArray(org.fusesource.hawtbuf.Buffer)
{
byte[] v;
org.fusesource.hawtbuf.Buffer v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @parameter: org.fusesource.hawtbuf.Buffer;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: byte[] toByteArray(org.fusesource.hawtbuf.Buffer)>(v);
return v;
}
public static java.lang.String INDEX_SUFFIX()
{
java.lang.String v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: java.lang.String INDEX_SUFFIX()>();
return v;
}
public static java.lang.String LOG_SUFFIX()
{
java.lang.String v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: java.lang.String LOG_SUFFIX()>();
return v;
}
public static byte LOG_UPDATE_ENTRY()
{
byte v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: byte LOG_UPDATE_ENTRY()>();
return v;
}
public static byte LOG_TRACE()
{
byte v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: byte LOG_TRACE()>();
return v;
}
public static byte LOG_DATA()
{
byte v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: byte LOG_DATA()>();
return v;
}
public static byte LOG_REMOVE_ENTRY()
{
byte v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: byte LOG_REMOVE_ENTRY()>();
return v;
}
public static byte LOG_ADD_ENTRY()
{
byte v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: byte LOG_ADD_ENTRY()>();
return v;
}
public static byte LOG_REMOVE_COLLECTION()
{
byte v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: byte LOG_REMOVE_COLLECTION()>();
return v;
}
public static byte LOG_ADD_COLLECTION()
{
byte v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: byte LOG_ADD_COLLECTION()>();
return v;
}
public static byte[] ENTRY_PREFIX_ARRAY()
{
byte[] v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: byte[] ENTRY_PREFIX_ARRAY()>();
return v;
}
public static byte ENTRY_PREFIX()
{
byte v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: byte ENTRY_PREFIX()>();
return v;
}
public static byte[] COLLECTION_PREFIX_ARRAY()
{
byte[] v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: byte[] COLLECTION_PREFIX_ARRAY()>();
return v;
}
public static byte COLLECTION_PREFIX()
{
byte v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: byte COLLECTION_PREFIX()>();
return v;
}
public static org.fusesource.hawtbuf.AsciiBuffer ACK_POSITION()
{
org.fusesource.hawtbuf.AsciiBuffer v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: org.fusesource.hawtbuf.AsciiBuffer ACK_POSITION()>();
return v;
}
public static byte[] FALSE()
{
byte[] v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: byte[] FALSE()>();
return v;
}
public static byte[] TRUE()
{
byte[] v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: byte[] TRUE()>();
return v;
}
public static byte[] COLLECTION_META_KEY()
{
byte[] v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: byte[] COLLECTION_META_KEY()>();
return v;
}
public static byte[] PRODUCER_IDS_INDEX_KEY()
{
byte[] v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: byte[] PRODUCER_IDS_INDEX_KEY()>();
return v;
}
public static byte[] LOGS_INDEX_KEY()
{
byte[] v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: byte[] LOGS_INDEX_KEY()>();
return v;
}
public static byte[] LOG_REF_INDEX_KEY()
{
byte[] v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: byte[] LOG_REF_INDEX_KEY()>();
return v;
}
public static byte[] DIRTY_INDEX_KEY()
{
byte[] v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: byte[] DIRTY_INDEX_KEY()>();
return v;
}
public static org.iq.leveldb.WriteOptions PLIST_WRITE_OPTIONS()
{
org.iq.leveldb.WriteOptions v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: org.iq.leveldb.WriteOptions PLIST_WRITE_OPTIONS()>();
return v;
}
public static java.util.concurrent.ThreadPoolExecutor THREAD_POOL()
{
java.util.concurrent.ThreadPoolExecutor v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: java.util.concurrent.ThreadPoolExecutor THREAD_POOL()>();
return v;
}
public static long THREAD_POOL_STACK_SIZE()
{
long v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: long THREAD_POOL_STACK_SIZE()>();
return v;
}
public static int STORE_SCHEMA_VERSION()
{
int v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: int STORE_SCHEMA_VERSION()>();
return v;
}
public static java.lang.String STORE_SCHEMA_PREFIX()
{
java.lang.String v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: java.lang.String STORE_SCHEMA_PREFIX()>();
return v;
}
public org.fusesource.hawtdispatch.DispatchQueue dispatchQueue()
{
org.fusesource.hawtdispatch.DispatchQueue v;
org.apache.activemq.leveldb.LevelDBClient v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v = v.<org.apache.activemq.leveldb.LevelDBClient: org.fusesource.hawtdispatch.DispatchQueue dispatchQueue>;
return v;
}
public java.io.File directory()
{
org.apache.activemq.leveldb.LevelDBClient v;
org.apache.activemq.leveldb.LevelDBStore v;
java.io.File v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v = v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.LevelDBStore org$apache$activemq$leveldb$LevelDBClient$$store>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: java.io.File directory()>();
return v;
}
public java.io.File logDirectory()
{
scala.Option$ v;
org.apache.activemq.leveldb.LevelDBClient v;
java.lang.Object v;
org.apache.activemq.leveldb.LevelDBStore v;
scala.Option v;
java.io.File v;
org.apache.activemq.leveldb.LevelDBClient$$anonfun$logDirectory$1 v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v = <scala.Option$: scala.Option$ MODULE$>;
v = v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.LevelDBStore org$apache$activemq$leveldb$LevelDBClient$$store>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: java.io.File logDirectory()>();
v = virtualinvoke v.<scala.Option$: scala.Option apply(java.lang.Object)>(v);
v = new org.apache.activemq.leveldb.LevelDBClient$$anonfun$logDirectory$1;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anonfun$logDirectory$1: void <init>(org.apache.activemq.leveldb.LevelDBClient)>(v);
v = virtualinvoke v.<scala.Option: java.lang.Object getOrElse(scala.Function)>(v);
return v;
}
public boolean sync()
{
org.apache.activemq.leveldb.LevelDBClient v;
org.apache.activemq.leveldb.LevelDBStore v;
boolean v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v = v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.LevelDBStore org$apache$activemq$leveldb$LevelDBClient$$store>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: boolean sync()>();
return v;
}
public boolean verifyChecksums()
{
org.apache.activemq.leveldb.LevelDBClient v;
org.apache.activemq.leveldb.LevelDBStore v;
boolean v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v = v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.LevelDBStore org$apache$activemq$leveldb$LevelDBClient$$store>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: boolean verifyChecksums()>();
return v;
}
public org.apache.activemq.leveldb.RecordLog log()
{
org.apache.activemq.leveldb.LevelDBClient v;
org.apache.activemq.leveldb.RecordLog v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v = v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.RecordLog log>;
return v;
}
public void log_$eq(org.apache.activemq.leveldb.RecordLog)
{
org.apache.activemq.leveldb.LevelDBClient v;
org.apache.activemq.leveldb.RecordLog v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v := @parameter: org.apache.activemq.leveldb.RecordLog;
v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.RecordLog log> = v;
return;
}
public org.apache.activemq.leveldb.LevelDBClient$RichDB index()
{
org.apache.activemq.leveldb.LevelDBClient$RichDB v;
org.apache.activemq.leveldb.LevelDBClient v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v = v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.LevelDBClient$RichDB index>;
return v;
}
public void index_$eq(org.apache.activemq.leveldb.LevelDBClient$RichDB)
{
org.apache.activemq.leveldb.LevelDBClient$RichDB v;
org.apache.activemq.leveldb.LevelDBClient v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v := @parameter: org.apache.activemq.leveldb.LevelDBClient$RichDB;
v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.LevelDBClient$RichDB index> = v;
return;
}
public org.apache.activemq.leveldb.LevelDBClient$RichDB plist()
{
org.apache.activemq.leveldb.LevelDBClient$RichDB v;
org.apache.activemq.leveldb.LevelDBClient v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v = v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.LevelDBClient$RichDB plist>;
return v;
}
public void plist_$eq(org.apache.activemq.leveldb.LevelDBClient$RichDB)
{
org.apache.activemq.leveldb.LevelDBClient$RichDB v;
org.apache.activemq.leveldb.LevelDBClient v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v := @parameter: org.apache.activemq.leveldb.LevelDBClient$RichDB;
v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.LevelDBClient$RichDB plist> = v;
return;
}
public org.iq.leveldb.Options indexOptions()
{
org.iq.leveldb.Options v;
org.apache.activemq.leveldb.LevelDBClient v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v = v.<org.apache.activemq.leveldb.LevelDBClient: org.iq.leveldb.Options indexOptions>;
return v;
}
public void indexOptions_$eq(org.iq.leveldb.Options)
{
org.iq.leveldb.Options v;
org.apache.activemq.leveldb.LevelDBClient v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v := @parameter: org.iq.leveldb.Options;
v.<org.apache.activemq.leveldb.LevelDBClient: org.iq.leveldb.Options indexOptions> = v;
return;
}
public long lastIndexSnapshotPos()
{
long v;
org.apache.activemq.leveldb.LevelDBClient v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v = v.<org.apache.activemq.leveldb.LevelDBClient: long lastIndexSnapshotPos>;
return v;
}
public void lastIndexSnapshotPos_$eq(long)
{
long v;
org.apache.activemq.leveldb.LevelDBClient v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v := @parameter: long;
v.<org.apache.activemq.leveldb.LevelDBClient: long lastIndexSnapshotPos> = v;
return;
}
public java.util.concurrent.locks.ReentrantReadWriteLock snapshotRwLock()
{
java.util.concurrent.locks.ReentrantReadWriteLock v;
org.apache.activemq.leveldb.LevelDBClient v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v = v.<org.apache.activemq.leveldb.LevelDBClient: java.util.concurrent.locks.ReentrantReadWriteLock snapshotRwLock>;
return v;
}
public org.iq.leveldb.DBFactory factory()
{
org.apache.activemq.leveldb.LevelDBClient v;
org.iq.leveldb.DBFactory v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v = v.<org.apache.activemq.leveldb.LevelDBClient: org.iq.leveldb.DBFactory factory>;
return v;
}
public void factory_$eq(org.iq.leveldb.DBFactory)
{
org.apache.activemq.leveldb.LevelDBClient v;
org.iq.leveldb.DBFactory v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v := @parameter: org.iq.leveldb.DBFactory;
v.<org.apache.activemq.leveldb.LevelDBClient: org.iq.leveldb.DBFactory factory> = v;
return;
}
public scala.collection.mutable.HashMap logRefs()
{
org.apache.activemq.leveldb.LevelDBClient v;
scala.collection.mutable.HashMap v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v = v.<org.apache.activemq.leveldb.LevelDBClient: scala.collection.mutable.HashMap logRefs>;
return v;
}
public java.util.TreeMap recoveryLogs()
{
org.apache.activemq.leveldb.LevelDBClient v;
java.util.TreeMap v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v = v.<org.apache.activemq.leveldb.LevelDBClient: java.util.TreeMap recoveryLogs>;
return v;
}
public void recoveryLogs_$eq(java.util.TreeMap)
{
org.apache.activemq.leveldb.LevelDBClient v;
java.util.TreeMap v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v := @parameter: java.util.TreeMap;
v.<org.apache.activemq.leveldb.LevelDBClient: java.util.TreeMap recoveryLogs> = v;
return;
}
public scala.collection.mutable.HashMap collectionMeta()
{
org.apache.activemq.leveldb.LevelDBClient v;
scala.collection.mutable.HashMap v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v = v.<org.apache.activemq.leveldb.LevelDBClient: scala.collection.mutable.HashMap collectionMeta>;
return v;
}
public java.io.File plistIndexFile()
{
org.apache.activemq.leveldb.LevelDBClient v;
org.apache.activemq.leveldb.util.FileSupport$ v;
org.apache.activemq.leveldb.util.FileSupport$RichFile v;
java.io.File v, v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v = <org.apache.activemq.leveldb.util.FileSupport$: org.apache.activemq.leveldb.util.FileSupport$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: java.io.File directory()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.util.FileSupport$: org.apache.activemq.leveldb.util.FileSupport$RichFile toRichFile(java.io.File)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.util.FileSupport$RichFile: java.io.File $div(java.lang.String)>("plist.index");
return v;
}
public java.io.File dirtyIndexFile()
{
org.apache.activemq.leveldb.LevelDBClient v;
org.apache.activemq.leveldb.util.FileSupport$ v;
org.apache.activemq.leveldb.util.FileSupport$RichFile v;
java.io.File v, v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v = <org.apache.activemq.leveldb.util.FileSupport$: org.apache.activemq.leveldb.util.FileSupport$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: java.io.File directory()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.util.FileSupport$: org.apache.activemq.leveldb.util.FileSupport$RichFile toRichFile(java.io.File)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.util.FileSupport$RichFile: java.io.File $div(java.lang.String)>("dirty.index");
return v;
}
public java.io.File tempIndexFile()
{
org.apache.activemq.leveldb.LevelDBClient v;
org.apache.activemq.leveldb.util.FileSupport$ v;
org.apache.activemq.leveldb.util.FileSupport$RichFile v;
java.io.File v, v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v = <org.apache.activemq.leveldb.util.FileSupport$: org.apache.activemq.leveldb.util.FileSupport$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: java.io.File directory()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.util.FileSupport$: org.apache.activemq.leveldb.util.FileSupport$RichFile toRichFile(java.io.File)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.util.FileSupport$RichFile: java.io.File $div(java.lang.String)>("temp.index");
return v;
}
public java.io.File snapshotIndexFile(long)
{
org.apache.activemq.leveldb.LevelDBClient v;
long v;
java.io.File v, v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v := @parameter: long;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: java.io.File directory()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: java.io.File create_sequence_file(java.io.File,long,java.lang.String)>(v, v, ".index");
return v;
}
public long size()
{
org.apache.activemq.leveldb.LevelDBClient v;
int v;
long v, v;
org.apache.activemq.leveldb.LevelDBStore v;
scala.collection.mutable.HashMap v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: scala.collection.mutable.HashMap logRefs()>();
v = virtualinvoke v.<scala.collection.mutable.HashMap: int size()>();
v = v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.LevelDBStore org$apache$activemq$leveldb$LevelDBClient$$store>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: long logSize()>();
v = v * v;
return v;
}
public org.apache.activemq.leveldb.RecordLog createLog()
{
org.apache.activemq.leveldb.LevelDBClient v;
org.apache.activemq.leveldb.RecordLog v;
java.io.File v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v = new org.apache.activemq.leveldb.RecordLog;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: java.io.File logDirectory()>();
specialinvoke v.<org.apache.activemq.leveldb.RecordLog: void <init>(java.io.File,java.lang.String)>(v, ".log");
return v;
}
public java.util.concurrent.ExecutorService writeExecutor()
{
org.apache.activemq.leveldb.LevelDBClient v;
java.util.concurrent.ExecutorService v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v = v.<org.apache.activemq.leveldb.LevelDBClient: java.util.concurrent.ExecutorService writeExecutor>;
return v;
}
public void writeExecutor_$eq(java.util.concurrent.ExecutorService)
{
org.apache.activemq.leveldb.LevelDBClient v;
java.util.concurrent.ExecutorService v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v := @parameter: java.util.concurrent.ExecutorService;
v.<org.apache.activemq.leveldb.LevelDBClient: java.util.concurrent.ExecutorService writeExecutor> = v;
return;
}
public void writeExecutorExec(scala.Function)
{
org.fusesource.hawtdispatch.package$RichExecutor v;
org.apache.activemq.leveldb.LevelDBClient v;
org.fusesource.hawtdispatch.package$ v;
scala.Function v;
java.util.concurrent.ExecutorService v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v := @parameter: scala.Function;
v = <org.fusesource.hawtdispatch.package$: org.fusesource.hawtdispatch.package$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: java.util.concurrent.ExecutorService writeExecutor()>();
v = virtualinvoke v.<org.fusesource.hawtdispatch.package$: org.fusesource.hawtdispatch.package$RichExecutor ExecutorWrapper(java.util.concurrent.Executor)>(v);
virtualinvoke v.<org.fusesource.hawtdispatch.package$RichExecutor: void apply(scala.Function)>(v);
return;
}
public void storeTrace(java.lang.String, boolean)
{
org.apache.activemq.leveldb.RecordLog v;
java.util.Date v;
java.text.SimpleDateFormat v;
org.apache.activemq.leveldb.LevelDBClient v;
org.apache.activemq.leveldb.LevelDBClient$$anonfun$storeTrace$1 v;
java.lang.String v, v;
boolean v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v := @parameter: java.lang.String;
v := @parameter: boolean;
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: void assert_write_thread_executing()>();
v = new java.text.SimpleDateFormat;
specialinvoke v.<java.text.SimpleDateFormat: void <init>(java.lang.String)>("dd/MMM/yyyy:HH:mm::ss Z");
v = new java.util.Date;
specialinvoke v.<java.util.Date: void <init>()>();
v = virtualinvoke v.<java.text.SimpleDateFormat: java.lang.String format(java.util.Date)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.RecordLog log()>();
v = new org.apache.activemq.leveldb.LevelDBClient$$anonfun$storeTrace$1;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anonfun$storeTrace$1: void <init>(org.apache.activemq.leveldb.LevelDBClient,java.lang.String,boolean,java.lang.String)>(v, v, v, v);
virtualinvoke v.<org.apache.activemq.leveldb.RecordLog: java.lang.Object appender(scala.Function)>(v);
return;
}
public java.lang.Object might_fail(scala.Function)
{
java.lang.Throwable v;
scala.runtime.Nothing$ v, v;
scala.Function v;
java.io.IOException v, v;
org.apache.activemq.leveldb.LevelDBClient v;
java.lang.Object v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v := @parameter: scala.Function;
label:
v = interfaceinvoke v.<scala.Function0: java.lang.Object apply()>();
label:
return v;
label:
v := @caughtexception;
v = staticinvoke <org.apache.activemq.util.IOExceptionSupport: java.io.IOException create(java.lang.Throwable)>(v);
v = specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient: scala.runtime.Nothing$ handleFailure$1(java.io.IOException)>(v);
throw v;
label:
v := @caughtexception;
v = specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient: scala.runtime.Nothing$ handleFailure$1(java.io.IOException)>(v);
throw v;
catch java.io.IOException from label to label with label;
catch java.lang.Throwable from label to label with label;
}
public void start()
{
org.apache.activemq.leveldb.RecordLog v, v, v, v;
long v, v;
scala.Option v;
org.apache.activemq.leveldb.LevelDBClient v;
java.util.TreeMap v, v;
org.apache.activemq.leveldb.LevelDBClient$$anonfun$start$1 v;
java.lang.Object v;
boolean v, v, v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: void init()>();
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: void replay_init()>();
v = new org.apache.activemq.leveldb.LevelDBClient$$anonfun$start$1;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anonfun$start$1: void <init>(org.apache.activemq.leveldb.LevelDBClient)>(v);
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: java.lang.Object might_fail(scala.Function)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: long lastIndexSnapshotPos()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.RecordLog log()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.RecordLog: scala.Option log_info(long)>(v);
v = virtualinvoke v.<scala.Option: boolean isEmpty()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.RecordLog log()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.RecordLog: java.util.TreeMap log_infos()>();
v = virtualinvoke v.<java.util.TreeMap: boolean isEmpty()>();
if v != 0 goto label;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.RecordLog log()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.RecordLog: java.util.TreeMap log_infos()>();
v = virtualinvoke v.<java.util.TreeMap: java.lang.Object firstKey()>();
v = staticinvoke <scala.runtime.BoxesRunTime: long unboxToLong(java.lang.Object)>(v);
label:
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.RecordLog log()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.RecordLog: long appender_limit()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: boolean replay_from$default$3()>();
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: void replay_from(long,long,boolean)>(v, v, v);
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: void replay_write_batch_$eq(org.iq.leveldb.WriteBatch)>(null);
return;
}
public void assert_write_thread_executing()
{
org.apache.activemq.leveldb.LevelDBClient v;
scala.Predef$ v;
java.lang.Thread v;
java.lang.Class v;
boolean v, v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v = <scala.Predef$: scala.Predef$ MODULE$>;
v = staticinvoke <java.lang.Thread: java.lang.Thread currentThread()>();
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
if v == null goto label;
v = virtualinvoke v.<java.lang.Object: boolean equals(java.lang.Object)>(class "Lorg/apache/activemq/leveldb/LevelDBClient$WriteThread;");
if v == 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
virtualinvoke v.<scala.Predef$: void assert(boolean)>(v);
return;
}
public void init()
{
org.apache.activemq.leveldb.RecordLog v, v, v;
java.lang.Integer v;
scala.collection.mutable.ArrayOps v, v, v;
org.apache.activemq.leveldb.LevelDBStore v, v, v, v, v, v, v, v, v;
java.lang.Exception v, v;
org.iq.leveldb.Options v, v, v, v, v, v, v, v, v, v;
scala.collection.immutable.StringOps v, v;
org.apache.activemq.leveldb.LevelDBClient$ v, v;
java.lang.Throwable v;
java.lang.Object[] v, v;
scala.reflect.ClassTag v, v;
long v, v;
scala.collection.mutable.StringBuilder v, v, v, v, v, v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.iq.leveldb.CompressionType v;
scala.collection.mutable.WrappedArray v, v;
org.iq.leveldb.DBFactory v, v;
java.io.File v, v, v;
org.apache.activemq.leveldb.LevelDBClient v;
org.apache.activemq.leveldb.LevelDBClient$$anon$3 v;
org.apache.activemq.leveldb.LevelDBClient$$anon$4 v;
boolean v, v, v, v, v, v, v;
scala.Array$ v, v;
scala.collection.generic.CanBuildFrom v, v;
java.lang.String[] v;
scala.Predef$ v, v, v, v, v, v, v;
int v, v, v, v, v, v;
org.apache.activemq.leveldb.util.FileSupport$ v, v, v;
org.apache.activemq.leveldb.util.FileSupport$RichFile v, v, v;
java.util.concurrent.ExecutorService v;
scala.Option v;
scala.reflect.ClassTag$ v, v;
org.apache.activemq.leveldb.LevelDBClient$$anonfun$init$6 v;
org.apache.activemq.leveldb.LevelDBClient$$anonfun$init$4 v;
org.apache.activemq.leveldb.LevelDBClient$$anonfun$init$5 v;
org.apache.activemq.leveldb.LevelDBClient$$anonfun$init$2 v;
org.apache.activemq.leveldb.LevelDBClient$$anonfun$init$3 v;
org.apache.activemq.leveldb.LevelDBClient$$anonfun$init$1 v;
java.lang.Class v, v;
java.lang.Object v, v, v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: java.io.File directory()>();
virtualinvoke v.<java.io.File: boolean mkdirs()>();
v = <org.apache.activemq.leveldb.util.FileSupport$: org.apache.activemq.leveldb.util.FileSupport$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: java.io.File directory()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.util.FileSupport$: org.apache.activemq.leveldb.util.FileSupport$RichFile toRichFile(java.io.File)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.util.FileSupport$RichFile: java.io.File $div(java.lang.String)>("store-version.txt");
v = virtualinvoke v.<java.io.File: boolean exists()>();
if v == 0 goto label;
label:
v = <org.apache.activemq.leveldb.util.FileSupport$: org.apache.activemq.leveldb.util.FileSupport$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.util.FileSupport$: org.apache.activemq.leveldb.util.FileSupport$RichFile toRichFile(java.io.File)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.util.FileSupport$RichFile: java.lang.String readText$default$1()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.util.FileSupport$RichFile: java.lang.String readText(java.lang.String)>(v);
v = virtualinvoke v.<java.lang.String: java.lang.String trim()>();
v = virtualinvoke v.<java.lang.String: boolean startsWith(java.lang.String)>("activemq_leveldb_store:");
if v == 0 goto label;
v = new scala.collection.immutable.StringOps;
v = <scala.Predef$: scala.Predef$ MODULE$>;
v = new scala.collection.immutable.StringOps;
v = <scala.Predef$: scala.Predef$ MODULE$>;
v = virtualinvoke v.<scala.Predef$: java.lang.String augmentString(java.lang.String)>(v);
specialinvoke v.<scala.collection.immutable.StringOps: void <init>(java.lang.String)>(v);
v = virtualinvoke v.<scala.collection.immutable.StringOps: java.lang.String stripPrefix(java.lang.String)>("activemq_leveldb_store:");
v = virtualinvoke v.<scala.Predef$: java.lang.String augmentString(java.lang.String)>(v);
specialinvoke v.<scala.collection.immutable.StringOps: void <init>(java.lang.String)>(v);
v = virtualinvoke v.<scala.collection.immutable.StringOps: int toInt()>();
goto label;
label:
v = (int) -1;
v = v;
label:
tableswitch(v)
{
case 1: goto label;
default: goto label;
};
label:
v = new java.lang.Exception;
specialinvoke v.<java.lang.Exception: void <init>(java.lang.String)>("Cannot open the store.  It\'s schema version is not supported.");
throw v;
label:
v = <org.apache.activemq.leveldb.util.FileSupport$: org.apache.activemq.leveldb.util.FileSupport$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.util.FileSupport$: org.apache.activemq.leveldb.util.FileSupport$RichFile toRichFile(java.io.File)>(v);
v = new scala.collection.mutable.StringBuilder;
specialinvoke v.<scala.collection.mutable.StringBuilder: void <init>()>();
v = virtualinvoke v.<scala.collection.mutable.StringBuilder: scala.collection.mutable.StringBuilder append(java.lang.Object)>("activemq_leveldb_store:");
v = staticinvoke <scala.runtime.BoxesRunTime: java.lang.Integer boxToInteger(int)>(1);
v = virtualinvoke v.<scala.collection.mutable.StringBuilder: scala.collection.mutable.StringBuilder append(java.lang.Object)>(v);
v = virtualinvoke v.<scala.collection.mutable.StringBuilder: java.lang.String toString()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.util.FileSupport$RichFile: java.lang.String writeText$default$2()>();
virtualinvoke v.<org.apache.activemq.leveldb.util.FileSupport$RichFile: void writeText(java.lang.String,java.lang.String)>(v, v);
v = new org.apache.activemq.leveldb.LevelDBClient$$anon$3;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anon$3: void <init>(org.apache.activemq.leveldb.LevelDBClient)>(v);
v = staticinvoke <java.util.concurrent.Executors: java.util.concurrent.ExecutorService newFixedThreadPool(int,java.util.concurrent.ThreadFactory)>(1, v);
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: void writeExecutor_$eq(java.util.concurrent.ExecutorService)>(v);
v = v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.LevelDBStore org$apache$activemq$leveldb$LevelDBClient$$store>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: java.lang.String indexFactory()>();
v = <scala.Predef$: scala.Predef$ MODULE$>;
v = <scala.Predef$: scala.Predef$ MODULE$>;
v = <scala.Predef$: scala.Predef$ MODULE$>;
v = virtualinvoke v.<java.lang.String: java.lang.String[] split(java.lang.String)>("(,|\\s)+");
v = virtualinvoke v.<scala.Predef$: scala.collection.mutable.ArrayOps refArrayOps(java.lang.Object[])>(v);
v = new org.apache.activemq.leveldb.LevelDBClient$$anonfun$init$2;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anonfun$init$2: void <init>(org.apache.activemq.leveldb.LevelDBClient)>(v);
v = <scala.Array$: scala.Array$ MODULE$>;
v = <scala.reflect.ClassTag$: scala.reflect.ClassTag$ MODULE$>;
v = virtualinvoke v.<scala.reflect.ClassTag$: scala.reflect.ClassTag apply(java.lang.Class)>(class "Ljava/lang/String;");
v = virtualinvoke v.<scala.Array$: scala.collection.generic.CanBuildFrom canBuildFrom(scala.reflect.ClassTag)>(v);
v = interfaceinvoke v.<scala.collection.mutable.ArrayOps: java.lang.Object map(scala.Function,scala.collection.generic.CanBuildFrom)>(v, v);
v = virtualinvoke v.<scala.Predef$: scala.collection.mutable.ArrayOps refArrayOps(java.lang.Object[])>(v);
v = new org.apache.activemq.leveldb.LevelDBClient$$anonfun$init$3;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anonfun$init$3: void <init>(org.apache.activemq.leveldb.LevelDBClient)>(v);
v = <scala.Array$: scala.Array$ MODULE$>;
v = <scala.reflect.ClassTag$: scala.reflect.ClassTag$ MODULE$>;
v = virtualinvoke v.<scala.reflect.ClassTag$: scala.reflect.ClassTag apply(java.lang.Class)>(class "Lorg/iq80/leveldb/DBFactory;");
v = virtualinvoke v.<scala.Array$: scala.collection.generic.CanBuildFrom canBuildFrom(scala.reflect.ClassTag)>(v);
v = interfaceinvoke v.<scala.collection.mutable.ArrayOps: java.lang.Object flatMap(scala.Function,scala.collection.generic.CanBuildFrom)>(v, v);
v = virtualinvoke v.<scala.Predef$: scala.collection.mutable.ArrayOps refArrayOps(java.lang.Object[])>(v);
v = interfaceinvoke v.<scala.collection.mutable.ArrayOps: scala.Option headOption()>();
v = new org.apache.activemq.leveldb.LevelDBClient$$anonfun$init$4;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anonfun$init$4: void <init>(org.apache.activemq.leveldb.LevelDBClient,java.lang.String)>(v, v);
v = virtualinvoke v.<scala.Option: java.lang.Object getOrElse(scala.Function)>(v);
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: void factory_$eq(org.iq.leveldb.DBFactory)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: org.iq.leveldb.DBFactory factory()>();
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: java.lang.String getName()>();
if v == null goto label;
v = virtualinvoke v.<java.lang.Object: boolean equals(java.lang.Object)>("org.iq.leveldb.impl.Iq80DBFactory");
if v == 0 goto label;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = new org.apache.activemq.leveldb.LevelDBClient$$anonfun$init$5;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anonfun$init$5: void <init>(org.apache.activemq.leveldb.LevelDBClient)>(v);
v = <scala.Predef$: scala.Predef$ MODULE$>;
v = newarray (java.lang.Object)[0];
v = virtualinvoke v.<scala.Predef$: scala.collection.mutable.WrappedArray genericWrapArray(java.lang.Object)>(v);
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: void info(scala.Function,scala.collection.Seq)>(v, v);
label:
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: org.iq.leveldb.DBFactory factory()>();
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: java.lang.String getName()>();
if v == null goto label;
v = virtualinvoke v.<java.lang.Object: boolean equals(java.lang.Object)>("org.fusesource.leveldbjni.JniDBFactory");
if v == 0 goto label;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = new org.apache.activemq.leveldb.LevelDBClient$$anonfun$init$6;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anonfun$init$6: void <init>(org.apache.activemq.leveldb.LevelDBClient)>(v);
v = <scala.Predef$: scala.Predef$ MODULE$>;
v = newarray (java.lang.Object)[0];
v = virtualinvoke v.<scala.Predef$: scala.collection.mutable.WrappedArray genericWrapArray(java.lang.Object)>(v);
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: void info(scala.Function,scala.collection.Seq)>(v, v);
label:
v = new org.iq.leveldb.Options;
specialinvoke v.<org.iq.leveldb.Options: void <init>()>();
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: void indexOptions_$eq(org.iq.leveldb.Options)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: org.iq.leveldb.Options indexOptions()>();
virtualinvoke v.<org.iq.leveldb.Options: org.iq.leveldb.Options createIfMissing(boolean)>(1);
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: org.iq.leveldb.Options indexOptions()>();
v = v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.LevelDBStore org$apache$activemq$leveldb$LevelDBClient$$store>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: int indexMaxOpenFiles()>();
virtualinvoke v.<org.iq.leveldb.Options: org.iq.leveldb.Options maxOpenFiles(int)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: org.iq.leveldb.Options indexOptions()>();
v = v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.LevelDBStore org$apache$activemq$leveldb$LevelDBClient$$store>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: int indexBlockRestartInterval()>();
virtualinvoke v.<org.iq.leveldb.Options: org.iq.leveldb.Options blockRestartInterval(int)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: org.iq.leveldb.Options indexOptions()>();
v = v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.LevelDBStore org$apache$activemq$leveldb$LevelDBClient$$store>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: boolean paranoidChecks()>();
virtualinvoke v.<org.iq.leveldb.Options: org.iq.leveldb.Options paranoidChecks(boolean)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: org.iq.leveldb.Options indexOptions()>();
v = v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.LevelDBStore org$apache$activemq$leveldb$LevelDBClient$$store>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: int indexWriteBufferSize()>();
virtualinvoke v.<org.iq.leveldb.Options: org.iq.leveldb.Options writeBufferSize(int)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: org.iq.leveldb.Options indexOptions()>();
v = v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.LevelDBStore org$apache$activemq$leveldb$LevelDBClient$$store>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: int indexBlockSize()>();
virtualinvoke v.<org.iq.leveldb.Options: org.iq.leveldb.Options blockSize(int)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: org.iq.leveldb.Options indexOptions()>();
v = v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.LevelDBStore org$apache$activemq$leveldb$LevelDBClient$$store>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: java.lang.String indexCompression()>();
v = virtualinvoke v.<java.lang.String: java.lang.String toLowerCase()>();
v = "snappy";
v = virtualinvoke v.<java.lang.Object: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = <org.iq.leveldb.CompressionType: org.iq.leveldb.CompressionType SNAPPY>;
goto label;
label:
v = "none";
v = virtualinvoke v.<java.lang.Object: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = <org.iq.leveldb.CompressionType: org.iq.leveldb.CompressionType NONE>;
goto label;
label:
v = <org.iq.leveldb.CompressionType: org.iq.leveldb.CompressionType SNAPPY>;
label:
virtualinvoke v.<org.iq.leveldb.Options: org.iq.leveldb.Options compressionType(org.iq.leveldb.CompressionType)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: org.iq.leveldb.Options indexOptions()>();
v = v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.LevelDBStore org$apache$activemq$leveldb$LevelDBClient$$store>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: long indexCacheSize()>();
virtualinvoke v.<org.iq.leveldb.Options: org.iq.leveldb.Options cacheSize(long)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: org.iq.leveldb.Options indexOptions()>();
v = new org.apache.activemq.leveldb.LevelDBClient$$anon$4;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anon$4: void <init>(org.apache.activemq.leveldb.LevelDBClient)>(v);
virtualinvoke v.<org.iq.leveldb.Options: org.iq.leveldb.Options logger(org.iq.leveldb.Logger)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.RecordLog createLog()>();
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: void log_$eq(org.apache.activemq.leveldb.RecordLog)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.RecordLog log()>();
v = v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.LevelDBStore org$apache$activemq$leveldb$LevelDBClient$$store>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: long logSize()>();
virtualinvoke v.<org.apache.activemq.leveldb.RecordLog: void logSize_$eq(long)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.RecordLog log()>();
v = new org.apache.activemq.leveldb.LevelDBClient$$anonfun$init$1;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anonfun$init$1: void <init>(org.apache.activemq.leveldb.LevelDBClient)>(v);
virtualinvoke v.<org.apache.activemq.leveldb.RecordLog: void on_log_rotate_$eq(scala.Function)>(v);
return;
label:
v := @caughtexception;
v = new java.lang.Exception;
v = new scala.collection.mutable.StringBuilder;
specialinvoke v.<scala.collection.mutable.StringBuilder: void <init>()>();
v = virtualinvoke v.<scala.collection.mutable.StringBuilder: scala.collection.mutable.StringBuilder append(java.lang.Object)>("Unexpected version file format: ");
v = virtualinvoke v.<scala.collection.mutable.StringBuilder: scala.collection.mutable.StringBuilder append(java.lang.Object)>(v);
v = virtualinvoke v.<scala.collection.mutable.StringBuilder: java.lang.String toString()>();
specialinvoke v.<java.lang.Exception: void <init>(java.lang.String)>(v);
throw v;
catch java.lang.Throwable from label to label with label;
}
public void post_log_rotate()
{
org.fusesource.hawtdispatch.package$RichExecutor v;
org.apache.activemq.leveldb.LevelDBClient v;
org.apache.activemq.leveldb.LevelDBClient$$anonfun$post_log_rotate$1 v;
org.fusesource.hawtdispatch.package$ v;
java.util.concurrent.ExecutorService v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v = <org.fusesource.hawtdispatch.package$: org.fusesource.hawtdispatch.package$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: java.util.concurrent.ExecutorService writeExecutor()>();
v = virtualinvoke v.<org.fusesource.hawtdispatch.package$: org.fusesource.hawtdispatch.package$RichExecutor ExecutorWrapper(java.util.concurrent.Executor)>(v);
v = new org.apache.activemq.leveldb.LevelDBClient$$anonfun$post_log_rotate$1;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anonfun$post_log_rotate$1: void <init>(org.apache.activemq.leveldb.LevelDBClient)>(v);
virtualinvoke v.<org.fusesource.hawtdispatch.package$RichExecutor: void apply(scala.Function)>(v);
return;
}
public void replay_init()
{
long v;
org.apache.activemq.leveldb.LevelDBClient v;
org.apache.activemq.leveldb.util.FileSupport$ v;
org.apache.activemq.leveldb.util.FileSupport$RichFile v;
scala.collection.Map v;
scala.collection.immutable.TreeMap v;
scala.Option v, v;
java.io.File v, v;
org.apache.activemq.leveldb.LevelDBClient$$anonfun$replay_init$5 v;
org.apache.activemq.leveldb.LevelDBClient$$anonfun$replay_init$4 v;
java.lang.Object v, v;
scala.runtime.ObjectRef v;
org.apache.activemq.leveldb.LevelDBClient$$anonfun$replay_init$1 v;
org.apache.activemq.leveldb.LevelDBClient$$anonfun$replay_init$3 v;
org.apache.activemq.leveldb.LevelDBClient$ v;
org.apache.activemq.leveldb.LevelDBClient$$anonfun$replay_init$2 v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: java.io.File directory()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: scala.collection.immutable.TreeMap find_sequence_files(java.io.File,java.lang.String)>(v, ".index");
v = virtualinvoke v.<scala.collection.immutable.TreeMap: scala.Option lastOption()>();
v = staticinvoke <scala.runtime.ObjectRef: scala.runtime.ObjectRef create(java.lang.Object)>(v);
v = v.<scala.runtime.ObjectRef: java.lang.Object elem>;
v = new org.apache.activemq.leveldb.LevelDBClient$$anonfun$replay_init$3;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anonfun$replay_init$3: void <init>(org.apache.activemq.leveldb.LevelDBClient)>(v);
v = virtualinvoke v.<scala.Option: scala.Option map(scala.Function)>(v);
v = new org.apache.activemq.leveldb.LevelDBClient$$anonfun$replay_init$1;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anonfun$replay_init$1: void <init>(org.apache.activemq.leveldb.LevelDBClient)>(v);
v = virtualinvoke v.<scala.Option: java.lang.Object getOrElse(scala.Function)>(v);
v = staticinvoke <scala.runtime.BoxesRunTime: long unboxToLong(java.lang.Object)>(v);
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: void lastIndexSnapshotPos_$eq(long)>(v);
v = new org.apache.activemq.leveldb.LevelDBClient$$anonfun$replay_init$4;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anonfun$replay_init$4: void <init>(org.apache.activemq.leveldb.LevelDBClient)>(v);
v = virtualinvoke v.<scala.collection.immutable.TreeMap: scala.collection.Map filterNot(scala.Function)>(v);
v = new org.apache.activemq.leveldb.LevelDBClient$$anonfun$replay_init$5;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anonfun$replay_init$5: void <init>(org.apache.activemq.leveldb.LevelDBClient)>(v);
virtualinvoke v.<scala.collection.immutable.TreeMap: void foreach(scala.Function)>(v);
v = <org.apache.activemq.leveldb.util.FileSupport$: org.apache.activemq.leveldb.util.FileSupport$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: java.io.File tempIndexFile()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.util.FileSupport$: org.apache.activemq.leveldb.util.FileSupport$RichFile toRichFile(java.io.File)>(v);
virtualinvoke v.<org.apache.activemq.leveldb.util.FileSupport$RichFile: void recursiveDelete()>();
v = new org.apache.activemq.leveldb.LevelDBClient$$anonfun$replay_init$2;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anonfun$replay_init$2: void <init>(org.apache.activemq.leveldb.LevelDBClient,scala.runtime.ObjectRef)>(v, v);
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: java.lang.Object might_fail(scala.Function)>(v);
return;
}
public org.iq.leveldb.WriteBatch replay_write_batch()
{
org.iq.leveldb.WriteBatch v;
org.apache.activemq.leveldb.LevelDBClient v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v = v.<org.apache.activemq.leveldb.LevelDBClient: org.iq.leveldb.WriteBatch replay_write_batch>;
return v;
}
public void replay_write_batch_$eq(org.iq.leveldb.WriteBatch)
{
org.iq.leveldb.WriteBatch v;
org.apache.activemq.leveldb.LevelDBClient v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v := @parameter: org.iq.leveldb.WriteBatch;
v.<org.apache.activemq.leveldb.LevelDBClient: org.iq.leveldb.WriteBatch replay_write_batch> = v;
return;
}
public long indexRecoveryPosition()
{
long v;
org.apache.activemq.leveldb.LevelDBClient v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v = v.<org.apache.activemq.leveldb.LevelDBClient: long indexRecoveryPosition>;
return v;
}
public void indexRecoveryPosition_$eq(long)
{
long v;
org.apache.activemq.leveldb.LevelDBClient v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v := @parameter: long;
v.<org.apache.activemq.leveldb.LevelDBClient: long indexRecoveryPosition> = v;
return;
}
public void replay_from(long, long, boolean)
{
org.iq.leveldb.WriteBatch v, v;
org.iq.leveldb.DB v;
java.lang.Object[] v;
long v, v;
org.apache.activemq.leveldb.LevelDBClient v;
java.lang.Long v, v;
scala.Predef$ v;
boolean v;
org.apache.activemq.leveldb.LevelDBClient$RichDB v;
scala.collection.mutable.WrappedArray v;
org.apache.activemq.leveldb.LevelDBClient$$anonfun$replay_from$1 v;
org.apache.activemq.leveldb.LevelDBClient$$anonfun$replay_from$2 v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v := @parameter: long;
v := @parameter: long;
v := @parameter: boolean;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = new org.apache.activemq.leveldb.LevelDBClient$$anonfun$replay_from$2;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anonfun$replay_from$2: void <init>(org.apache.activemq.leveldb.LevelDBClient)>(v);
v = <scala.Predef$: scala.Predef$ MODULE$>;
v = newarray (java.lang.Object)[2];
v = staticinvoke <scala.runtime.BoxesRunTime: java.lang.Long boxToLong(long)>(v);
v[0] = v;
v = staticinvoke <scala.runtime.BoxesRunTime: java.lang.Long boxToLong(long)>(v);
v[1] = v;
v = virtualinvoke v.<scala.Predef$: scala.collection.mutable.WrappedArray genericWrapArray(java.lang.Object)>(v);
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: void debug(scala.Function,scala.collection.Seq)>(v, v);
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: org.iq.leveldb.WriteBatch replay_write_batch()>();
if v != null goto label;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.LevelDBClient$RichDB index()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$RichDB: org.iq.leveldb.DB db()>();
v = interfaceinvoke v.<org.iq.leveldb.DB: org.iq.leveldb.WriteBatch createWriteBatch()>();
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: void replay_write_batch_$eq(org.iq.leveldb.WriteBatch)>(v);
label:
v = new org.apache.activemq.leveldb.LevelDBClient$$anonfun$replay_from$1;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anonfun$replay_from$1: void <init>(org.apache.activemq.leveldb.LevelDBClient,long,long,boolean)>(v, v, v, v);
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: java.lang.Object might_fail(scala.Function)>(v);
return;
}
public boolean replay_from$default$3()
{
org.apache.activemq.leveldb.LevelDBClient v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
return 1;
}
public void org$apache$activemq$leveldb$LevelDBClient$$logRefDecrement(long)
{
org.apache.activemq.leveldb.LevelDBClient v;
org.apache.activemq.leveldb.LevelDBClient$$anonfun$org$apache$activemq$leveldb$LevelDBClient$$logRefDecrement$1 v;
org.apache.activemq.leveldb.RecordLog$LogInfo v;
long v;
scala.Option v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v := @parameter: long;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.RecordLog$LogInfo logRefKey$default$2()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: scala.Option logRefKey(long,org.apache.activemq.leveldb.RecordLog$LogInfo)>(v, v);
v = new org.apache.activemq.leveldb.LevelDBClient$$anonfun$org$apache$activemq$leveldb$LevelDBClient$$logRefDecrement$1;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anonfun$org$apache$activemq$leveldb$LevelDBClient$$logRefDecrement$1: void <init>(org.apache.activemq.leveldb.LevelDBClient,long)>(v, v);
virtualinvoke v.<scala.Option: void foreach(scala.Function)>(v);
return;
}
public void org$apache$activemq$leveldb$LevelDBClient$$logRefIncrement(long)
{
org.apache.activemq.leveldb.LevelDBClient v;
org.apache.activemq.leveldb.LevelDBClient$$anonfun$org$apache$activemq$leveldb$LevelDBClient$$logRefIncrement$1 v;
org.apache.activemq.leveldb.RecordLog$LogInfo v;
long v;
scala.Option v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v := @parameter: long;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.RecordLog$LogInfo logRefKey$default$2()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: scala.Option logRefKey(long,org.apache.activemq.leveldb.RecordLog$LogInfo)>(v, v);
v = new org.apache.activemq.leveldb.LevelDBClient$$anonfun$org$apache$activemq$leveldb$LevelDBClient$$logRefIncrement$1;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anonfun$org$apache$activemq$leveldb$LevelDBClient$$logRefIncrement$1: void <init>(org.apache.activemq.leveldb.LevelDBClient)>(v);
virtualinvoke v.<scala.Option: void foreach(scala.Function)>(v);
return;
}
public scala.Option logRefKey(long, org.apache.activemq.leveldb.RecordLog$LogInfo)
{
java.lang.Object[] v;
org.apache.activemq.leveldb.RecordLog v;
long v, v;
scala.Option$ v;
org.apache.activemq.leveldb.LevelDBClient v;
java.lang.Long v, v;
scala.Predef$ v;
boolean v;
scala.collection.mutable.WrappedArray v;
org.apache.activemq.leveldb.LevelDBClient$$anonfun$2 v;
scala.Some v;
org.apache.activemq.leveldb.RecordLog$LogInfo v;
scala.Option v, v, v;
org.apache.activemq.leveldb.LevelDBClient$$anonfun$logRefKey$1 v;
java.util.TreeMap v, v;
java.lang.Object v, v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v := @parameter: long;
v := @parameter: org.apache.activemq.leveldb.RecordLog$LogInfo;
if v != null goto label;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: java.util.TreeMap recoveryLogs()>();
if v != null goto label;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.RecordLog log()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.RecordLog: scala.Option log_info(long)>(v);
v = new org.apache.activemq.leveldb.LevelDBClient$$anonfun$2;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anonfun$2: void <init>(org.apache.activemq.leveldb.LevelDBClient)>(v);
v = virtualinvoke v.<scala.Option: scala.Option map(scala.Function)>(v);
goto label;
label:
v = <scala.Option$: scala.Option$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: java.util.TreeMap recoveryLogs()>();
v = staticinvoke <scala.runtime.BoxesRunTime: java.lang.Long boxToLong(long)>(v);
v = virtualinvoke v.<java.util.TreeMap: java.lang.Object floorKey(java.lang.Object)>(v);
v = virtualinvoke v.<scala.Option$: scala.Option apply(java.lang.Object)>(v);
label:
v = v;
v = virtualinvoke v.<scala.Option: boolean isDefined()>();
if v != 0 goto label;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = new org.apache.activemq.leveldb.LevelDBClient$$anonfun$logRefKey$1;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anonfun$logRefKey$1: void <init>(org.apache.activemq.leveldb.LevelDBClient,long)>(v, v);
v = <scala.Predef$: scala.Predef$ MODULE$>;
v = newarray (java.lang.Object)[0];
v = virtualinvoke v.<scala.Predef$: scala.collection.mutable.WrappedArray genericWrapArray(java.lang.Object)>(v);
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: void warn(scala.Function,scala.collection.Seq)>(v, v);
label:
v = v;
goto label;
label:
v = new scala.Some;
v = v;
v = virtualinvoke v.<org.apache.activemq.leveldb.RecordLog$LogInfo: long position()>();
v = staticinvoke <scala.runtime.BoxesRunTime: java.lang.Long boxToLong(long)>(v);
specialinvoke v.<scala.Some: void <init>(java.lang.Object)>(v);
label:
return v;
}
public org.apache.activemq.leveldb.RecordLog$LogInfo logRefKey$default$2()
{
org.apache.activemq.leveldb.LevelDBClient v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
return null;
}
public void org$apache$activemq$leveldb$LevelDBClient$$collectionDecrementSize(long)
{
org.apache.activemq.leveldb.LevelDBClient v;
java.lang.Long v;
org.apache.activemq.leveldb.LevelDBClient$$anonfun$org$apache$activemq$leveldb$LevelDBClient$$collectionDecrementSize$1 v;
long v;
scala.Option v;
scala.collection.mutable.HashMap v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v := @parameter: long;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: scala.collection.mutable.HashMap collectionMeta()>();
v = staticinvoke <scala.runtime.BoxesRunTime: java.lang.Long boxToLong(long)>(v);
v = virtualinvoke v.<scala.collection.mutable.HashMap: scala.Option get(java.lang.Object)>(v);
v = new org.apache.activemq.leveldb.LevelDBClient$$anonfun$org$apache$activemq$leveldb$LevelDBClient$$collectionDecrementSize$1;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anonfun$org$apache$activemq$leveldb$LevelDBClient$$collectionDecrementSize$1: void <init>(org.apache.activemq.leveldb.LevelDBClient)>(v);
virtualinvoke v.<scala.Option: void foreach(scala.Function)>(v);
return;
}
public void org$apache$activemq$leveldb$LevelDBClient$$collectionIncrementSize(long, byte[])
{
org.apache.activemq.leveldb.LevelDBClient$$anonfun$org$apache$activemq$leveldb$LevelDBClient$$collectionIncrementSize$1 v;
byte[] v;
org.apache.activemq.leveldb.LevelDBClient v;
java.lang.Long v;
long v;
scala.Option v;
scala.collection.mutable.HashMap v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v := @parameter: long;
v := @parameter: byte[];
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: scala.collection.mutable.HashMap collectionMeta()>();
v = staticinvoke <scala.runtime.BoxesRunTime: java.lang.Long boxToLong(long)>(v);
v = virtualinvoke v.<scala.collection.mutable.HashMap: scala.Option get(java.lang.Object)>(v);
v = new org.apache.activemq.leveldb.LevelDBClient$$anonfun$org$apache$activemq$leveldb$LevelDBClient$$collectionIncrementSize$1;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anonfun$org$apache$activemq$leveldb$LevelDBClient$$collectionIncrementSize$1: void <init>(org.apache.activemq.leveldb.LevelDBClient,byte[])>(v, v);
virtualinvoke v.<scala.Option: void foreach(scala.Function)>(v);
return;
}
private void storeCounters()
{
byte[] v, v, v, v;
org.apache.activemq.leveldb.RecordLog v;
org.apache.activemq.ActiveMQMessageAuditNoSync v;
long[] v;
org.apache.activemq.leveldb.LevelDBClient v;
scala.collection.mutable.HashMap v, v;
org.apache.activemq.leveldb.LevelDBStore v;
org.apache.activemq.leveldb.DBManager v;
org.apache.activemq.leveldb.LevelDBClient$ v, v, v, v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: byte[] LOG_REF_INDEX_KEY()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: scala.collection.mutable.HashMap logRefs()>();
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient: void storeMap$1(byte[],scala.collection.mutable.HashMap)>(v, v);
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: byte[] COLLECTION_META_KEY()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: scala.collection.mutable.HashMap collectionMeta()>();
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient: void storeMap$1(byte[],scala.collection.mutable.HashMap)>(v, v);
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: byte[] LOGS_INDEX_KEY()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.RecordLog log()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.RecordLog: long[] log_file_positions()>();
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient: void storeList$1(byte[],long[])>(v, v);
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: byte[] PRODUCER_IDS_INDEX_KEY()>();
v = v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.LevelDBStore org$apache$activemq$leveldb$LevelDBClient$$store>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.leveldb.DBManager db()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: org.apache.activemq.ActiveMQMessageAuditNoSync producerSequenceIdTracker()>();
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient: void storeObject$1(byte[],java.lang.Object)>(v, v);
return;
}
public void org$apache$activemq$leveldb$LevelDBClient$$loadCounters()
{
byte[] v, v, v, v;
org.apache.activemq.leveldb.LevelDBClient$$anonfun$org$apache$activemq$leveldb$LevelDBClient$$loadCounters$1 v;
org.apache.activemq.leveldb.LevelDBClient$$anonfun$org$apache$activemq$leveldb$LevelDBClient$$loadCounters$2 v;
scala.Option v, v;
org.apache.activemq.leveldb.LevelDBClient v;
scala.collection.mutable.HashMap v, v;
org.apache.activemq.leveldb.LevelDBClient$ v, v, v, v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: byte[] LOG_REF_INDEX_KEY()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: scala.collection.mutable.HashMap logRefs()>();
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient: void loadMap$1(byte[],scala.collection.mutable.HashMap)>(v, v);
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: byte[] COLLECTION_META_KEY()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: scala.collection.mutable.HashMap collectionMeta()>();
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient: void loadMap$1(byte[],scala.collection.mutable.HashMap)>(v, v);
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: byte[] LOGS_INDEX_KEY()>();
v = specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient: scala.Option loadList$1(byte[])>(v);
v = new org.apache.activemq.leveldb.LevelDBClient$$anonfun$org$apache$activemq$leveldb$LevelDBClient$$loadCounters$1;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anonfun$org$apache$activemq$leveldb$LevelDBClient$$loadCounters$1: void <init>(org.apache.activemq.leveldb.LevelDBClient)>(v);
virtualinvoke v.<scala.Option: void foreach(scala.Function)>(v);
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: byte[] PRODUCER_IDS_INDEX_KEY()>();
v = specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient: scala.Option loadObject$1(byte[])>(v);
v = new org.apache.activemq.leveldb.LevelDBClient$$anonfun$org$apache$activemq$leveldb$LevelDBClient$$loadCounters$2;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anonfun$org$apache$activemq$leveldb$LevelDBClient$$loadCounters$2: void <init>(org.apache.activemq.leveldb.LevelDBClient)>(v);
virtualinvoke v.<scala.Option: void foreach(scala.Function)>(v);
return;
}
public long stored_wal_append_position()
{
long v;
org.apache.activemq.leveldb.LevelDBClient v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v = v.<org.apache.activemq.leveldb.LevelDBClient: long stored_wal_append_position>;
return v;
}
public void stored_wal_append_position_$eq(long)
{
long v;
org.apache.activemq.leveldb.LevelDBClient v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v := @parameter: long;
v.<org.apache.activemq.leveldb.LevelDBClient: long stored_wal_append_position> = v;
return;
}
public synchronized long wal_append_position()
{
org.apache.activemq.leveldb.LevelDBClient v;
org.apache.activemq.leveldb.RecordLog v, v, v;
long v;
boolean v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.RecordLog log()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.RecordLog log()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.RecordLog: boolean isOpen()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.RecordLog log()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.RecordLog: long appender_limit()>();
goto label;
label:
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: long stored_wal_append_position()>();
label:
return v;
}
public synchronized void dirty_stop()
{
org.apache.activemq.leveldb.LevelDBClient$$anonfun$dirty_stop$2 v;
org.apache.activemq.leveldb.LevelDBClient$$anonfun$dirty_stop$1 v;
org.apache.activemq.leveldb.LevelDBClient$$anonfun$dirty_stop$4 v;
org.apache.activemq.leveldb.LevelDBClient v;
org.apache.activemq.leveldb.LevelDBClient$$anonfun$dirty_stop$3 v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v = new org.apache.activemq.leveldb.LevelDBClient$$anonfun$dirty_stop$1;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anonfun$dirty_stop$1: void <init>(org.apache.activemq.leveldb.LevelDBClient)>(v);
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient: void ingorefailure$1(scala.Function)>(v);
v = new org.apache.activemq.leveldb.LevelDBClient$$anonfun$dirty_stop$2;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anonfun$dirty_stop$2: void <init>(org.apache.activemq.leveldb.LevelDBClient)>(v);
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient: void ingorefailure$1(scala.Function)>(v);
v = new org.apache.activemq.leveldb.LevelDBClient$$anonfun$dirty_stop$3;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anonfun$dirty_stop$3: void <init>(org.apache.activemq.leveldb.LevelDBClient)>(v);
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient: void ingorefailure$1(scala.Function)>(v);
v = new org.apache.activemq.leveldb.LevelDBClient$$anonfun$dirty_stop$4;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anonfun$dirty_stop$4: void <init>(org.apache.activemq.leveldb.LevelDBClient)>(v);
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient: void ingorefailure$1(scala.Function)>(v);
return;
}
public void stop()
{
byte[] v, v;
org.apache.activemq.leveldb.RecordLog v, v, v, v;
java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock v, v, v;
org.apache.activemq.leveldb.LevelDBClient v;
boolean v;
org.apache.activemq.leveldb.LevelDBClient$$anonfun$stop$1 v;
org.apache.activemq.leveldb.LevelDBClient$ v, v, v;
java.lang.Throwable v, v, v;
java.lang.Object[] v;
long v;
java.util.concurrent.locks.ReentrantReadWriteLock v, v, v;
scala.Predef$ v;
java.util.concurrent.ExecutorService v, v;
org.apache.activemq.leveldb.LevelDBClient$RichDB v, v, v, v, v;
scala.collection.mutable.WrappedArray v;
org.iq.leveldb.WriteOptions v, v;
scala.runtime.BoxedUnit v, v, v, v;
java.util.concurrent.TimeUnit v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v = null;
entermonitor v;
label:
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: java.util.concurrent.ExecutorService writeExecutor()>();
if v != null goto label;
v = <scala.runtime.BoxedUnit: scala.runtime.BoxedUnit UNIT>;
goto label;
label:
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: java.util.concurrent.ExecutorService writeExecutor()>();
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: void writeExecutor_$eq(java.util.concurrent.ExecutorService)>(null);
v = <scala.runtime.BoxedUnit: scala.runtime.BoxedUnit UNIT>;
label:
exitmonitor v;
label:
if v == null goto label;
interfaceinvoke v.<java.util.concurrent.ExecutorService: void shutdown()>();
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit SECONDS>;
interfaceinvoke v.<java.util.concurrent.ExecutorService: boolean awaitTermination(long,java.util.concurrent.TimeUnit)>(60L, v);
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: java.util.concurrent.locks.ReentrantReadWriteLock snapshotRwLock()>();
v = virtualinvoke v.<java.util.concurrent.locks.ReentrantReadWriteLock: java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock writeLock()>();
virtualinvoke v.<java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock: void lock()>();
label:
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.LevelDBClient$RichDB index()>();
if v == null goto label;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient: void storeCounters()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.LevelDBClient$RichDB index()>();
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: byte[] DIRTY_INDEX_KEY()>();
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: byte[] FALSE()>();
v = new org.iq.leveldb.WriteOptions;
specialinvoke v.<org.iq.leveldb.WriteOptions: void <init>()>();
v = virtualinvoke v.<org.iq.leveldb.WriteOptions: org.iq.leveldb.WriteOptions sync(boolean)>(1);
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$RichDB: void put(byte[],byte[],org.iq.leveldb.WriteOptions)>(v, v, v);
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.LevelDBClient$RichDB index()>();
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$RichDB: void close()>();
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: void index_$eq(org.apache.activemq.leveldb.LevelDBClient$RichDB)>(null);
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = new org.apache.activemq.leveldb.LevelDBClient$$anonfun$stop$1;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anonfun$stop$1: void <init>(org.apache.activemq.leveldb.LevelDBClient)>(v);
v = <scala.Predef$: scala.Predef$ MODULE$>;
v = newarray (java.lang.Object)[0];
v = virtualinvoke v.<scala.Predef$: scala.collection.mutable.WrappedArray genericWrapArray(java.lang.Object)>(v);
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: void debug(scala.Function,scala.collection.Seq)>(v, v);
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: void copyDirtyIndexToSnapshot()>();
label:
entermonitor v;
label:
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.RecordLog log()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.RecordLog log()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.RecordLog: boolean isOpen()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.RecordLog log()>();
virtualinvoke v.<org.apache.activemq.leveldb.RecordLog: void close()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.RecordLog log()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.RecordLog: long appender_limit()>();
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: void stored_wal_append_position_$eq(long)>(v);
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: void log_$eq(org.apache.activemq.leveldb.RecordLog)>(null);
v = <scala.runtime.BoxedUnit: scala.runtime.BoxedUnit UNIT>;
goto label;
label:
v = <scala.runtime.BoxedUnit: scala.runtime.BoxedUnit UNIT>;
label:
exitmonitor v;
label:
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.LevelDBClient$RichDB plist()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.LevelDBClient$RichDB plist()>();
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$RichDB: void close()>();
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: void plist_$eq(org.apache.activemq.leveldb.LevelDBClient$RichDB)>(null);
label:
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: java.util.concurrent.locks.ReentrantReadWriteLock snapshotRwLock()>();
v = virtualinvoke v.<java.util.concurrent.locks.ReentrantReadWriteLock: java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock writeLock()>();
virtualinvoke v.<java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock: void unlock()>();
label:
return;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
v := @caughtexception;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: java.util.concurrent.locks.ReentrantReadWriteLock snapshotRwLock()>();
v = virtualinvoke v.<java.util.concurrent.locks.ReentrantReadWriteLock: java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock writeLock()>();
virtualinvoke v.<java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock: void unlock()>();
throw v;
catch java.lang.Throwable 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 java.lang.Object usingIndex(scala.Function)
{
java.lang.Throwable v;
org.apache.activemq.leveldb.LevelDBClient v;
java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock v;
scala.Function v;
java.lang.Object v;
java.util.concurrent.locks.ReentrantReadWriteLock v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v := @parameter: scala.Function;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: java.util.concurrent.locks.ReentrantReadWriteLock snapshotRwLock()>();
v = virtualinvoke v.<java.util.concurrent.locks.ReentrantReadWriteLock: java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock readLock()>();
virtualinvoke v.<java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock: void lock()>();
label:
v = interfaceinvoke v.<scala.Function0: java.lang.Object apply()>();
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;
catch java.lang.Throwable from label to label with label;
}
public java.lang.Object might_fail_using_index(scala.Function)
{
org.apache.activemq.leveldb.LevelDBClient$$anonfun$might_fail_using_index$1 v;
org.apache.activemq.leveldb.LevelDBClient v;
scala.Function v;
java.lang.Object v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v := @parameter: scala.Function;
v = new org.apache.activemq.leveldb.LevelDBClient$$anonfun$might_fail_using_index$1;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anonfun$might_fail_using_index$1: void <init>(org.apache.activemq.leveldb.LevelDBClient,scala.Function)>(v, v);
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: java.lang.Object might_fail(scala.Function)>(v);
return v;
}
public void suspend()
{
org.apache.activemq.leveldb.LevelDBClient$RichDB v, v;
byte[] v, v;
org.iq.leveldb.DB v;
org.iq.leveldb.WriteOptions v, v;
java.util.concurrent.locks.ReentrantReadWriteLock v;
java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock v;
org.apache.activemq.leveldb.LevelDBClient v;
org.apache.activemq.leveldb.LevelDBClient$ v, v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: java.util.concurrent.locks.ReentrantReadWriteLock snapshotRwLock()>();
v = virtualinvoke v.<java.util.concurrent.locks.ReentrantReadWriteLock: java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock writeLock()>();
virtualinvoke v.<java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock: void lock()>();
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient: void storeCounters()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.LevelDBClient$RichDB index()>();
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: byte[] DIRTY_INDEX_KEY()>();
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: byte[] FALSE()>();
v = new org.iq.leveldb.WriteOptions;
specialinvoke v.<org.iq.leveldb.WriteOptions: void <init>()>();
v = virtualinvoke v.<org.iq.leveldb.WriteOptions: org.iq.leveldb.WriteOptions sync(boolean)>(1);
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$RichDB: void put(byte[],byte[],org.iq.leveldb.WriteOptions)>(v, v, v);
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.LevelDBClient$RichDB index()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$RichDB: org.iq.leveldb.DB db()>();
interfaceinvoke v.<org.iq.leveldb.DB: void suspendCompactions()>();
return;
}
public void resume()
{
org.apache.activemq.leveldb.LevelDBClient$RichDB v;
org.iq.leveldb.DB v;
org.apache.activemq.leveldb.LevelDBClient v;
java.util.concurrent.locks.ReentrantReadWriteLock v;
java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.LevelDBClient$RichDB index()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$RichDB: org.iq.leveldb.DB db()>();
interfaceinvoke v.<org.iq.leveldb.DB: void resumeCompactions()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: java.util.concurrent.locks.ReentrantReadWriteLock snapshotRwLock()>();
v = virtualinvoke v.<java.util.concurrent.locks.ReentrantReadWriteLock: java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock writeLock()>();
virtualinvoke v.<java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock: void unlock()>();
return;
}
public long nextIndexSnapshotPos()
{
long v;
org.apache.activemq.leveldb.LevelDBClient v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: long wal_append_position()>();
return v;
}
public void copyDirtyIndexToSnapshot()
{
org.apache.activemq.leveldb.LevelDBClient v;
byte v;
long v, v, v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: long nextIndexSnapshotPos()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: long lastIndexSnapshotPos()>();
v = v cmp v;
if v != 0 goto label;
return;
label:
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: long nextIndexSnapshotPos()>();
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: void copyDirtyIndexToSnapshot(long)>(v);
return;
}
public void copyDirtyIndexToSnapshot(long)
{
scala.collection.mutable.WrappedArray v;
java.lang.Object[] v;
long v;
java.io.File v, v, v;
org.apache.activemq.leveldb.LevelDBClient v;
scala.Predef$ v;
org.apache.activemq.leveldb.LevelDBClient$$anonfun$copyDirtyIndexToSnapshot$1 v;
org.apache.activemq.leveldb.LevelDBClient$ v, v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v := @parameter: long;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = new org.apache.activemq.leveldb.LevelDBClient$$anonfun$copyDirtyIndexToSnapshot$1;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anonfun$copyDirtyIndexToSnapshot$1: void <init>(org.apache.activemq.leveldb.LevelDBClient,long)>(v, v);
v = <scala.Predef$: scala.Predef$ MODULE$>;
v = newarray (java.lang.Object)[0];
v = virtualinvoke v.<scala.Predef$: scala.collection.mutable.WrappedArray genericWrapArray(java.lang.Object)>(v);
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: void debug(scala.Function,scala.collection.Seq)>(v, v);
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: java.io.File tempIndexFile()>();
virtualinvoke v.<java.io.File: boolean mkdirs()>();
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: java.io.File dirtyIndexFile()>();
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: void copyIndex(java.io.File,java.io.File)>(v, v);
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: java.io.File snapshotIndexFile(long)>(v);
virtualinvoke v.<java.io.File: boolean renameTo(java.io.File)>(v);
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: void replaceLatestSnapshotDirectory(long)>(v);
return;
}
public void replaceLatestSnapshotDirectory(long)
{
org.apache.activemq.leveldb.LevelDBClient v;
long v, v;
org.apache.activemq.leveldb.util.FileSupport$ v;
org.apache.activemq.leveldb.util.FileSupport$RichFile v;
java.io.File v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v := @parameter: long;
v = <org.apache.activemq.leveldb.util.FileSupport$: org.apache.activemq.leveldb.util.FileSupport$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: long lastIndexSnapshotPos()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: java.io.File snapshotIndexFile(long)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.util.FileSupport$: org.apache.activemq.leveldb.util.FileSupport$RichFile toRichFile(java.io.File)>(v);
virtualinvoke v.<org.apache.activemq.leveldb.util.FileSupport$RichFile: void recursiveDelete()>();
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: void lastIndexSnapshotPos_$eq(long)>(v);
return;
}
public void snapshotIndex(boolean)
{
java.lang.Throwable v;
org.apache.activemq.leveldb.RecordLog$LogAppender v;
org.apache.activemq.leveldb.LevelDBClient v;
org.apache.activemq.leveldb.RecordLog v;
boolean v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v := @parameter: boolean;
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: void suspend()>();
label:
if v == 0 goto label;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.RecordLog log()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.RecordLog: org.apache.activemq.leveldb.RecordLog$LogAppender current_appender()>();
virtualinvoke v.<org.apache.activemq.leveldb.RecordLog$LogAppender: void force()>();
label:
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: void copyDirtyIndexToSnapshot()>();
label:
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: void resume()>();
return;
label:
v := @caughtexception;
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: void resume()>();
throw v;
catch java.lang.Throwable from label to label with label;
}
public boolean snapshotIndex$default$1()
{
org.apache.activemq.leveldb.LevelDBClient v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
return 0;
}
public void purge()
{
java.lang.Throwable v;
org.apache.activemq.leveldb.LevelDBClient v;
org.apache.activemq.leveldb.RecordLog v;
org.apache.activemq.leveldb.LevelDBClient$$anonfun$purge$1 v, v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: void suspend()>();
label:
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.RecordLog log()>();
virtualinvoke v.<org.apache.activemq.leveldb.RecordLog: void close()>();
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: void locked_purge()>();
label:
v = new org.apache.activemq.leveldb.LevelDBClient$$anonfun$purge$1;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anonfun$purge$1: void <init>(org.apache.activemq.leveldb.LevelDBClient)>(v);
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: java.lang.Object might_fail(scala.Function)>(v);
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: void resume()>();
return;
label:
v := @caughtexception;
v = new org.apache.activemq.leveldb.LevelDBClient$$anonfun$purge$1;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anonfun$purge$1: void <init>(org.apache.activemq.leveldb.LevelDBClient)>(v);
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: java.lang.Object might_fail(scala.Function)>(v);
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: void resume()>();
throw v;
catch java.lang.Throwable from label to label with label;
}
public void locked_purge()
{
java.io.File v, v;
org.apache.activemq.leveldb.LevelDBClient v;
org.apache.activemq.leveldb.LevelDBClient$$anonfun$locked_purge$1 v;
scala.Predef$ v, v;
scala.collection.mutable.ArrayOps v, v;
org.apache.activemq.leveldb.LevelDBClient$$anonfun$locked_purge$2 v;
org.apache.activemq.leveldb.util.FileSupport$ v, v;
org.apache.activemq.leveldb.util.FileSupport$RichFile v, v;
java.io.File[] v, v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v = <scala.Predef$: scala.Predef$ MODULE$>;
v = <org.apache.activemq.leveldb.util.FileSupport$: org.apache.activemq.leveldb.util.FileSupport$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: java.io.File logDirectory()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.util.FileSupport$: org.apache.activemq.leveldb.util.FileSupport$RichFile toRichFile(java.io.File)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.util.FileSupport$RichFile: java.io.File[] list_files()>();
v = virtualinvoke v.<scala.Predef$: scala.collection.mutable.ArrayOps refArrayOps(java.lang.Object[])>(v);
v = new org.apache.activemq.leveldb.LevelDBClient$$anonfun$locked_purge$1;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anonfun$locked_purge$1: void <init>(org.apache.activemq.leveldb.LevelDBClient)>(v);
interfaceinvoke v.<scala.collection.mutable.ArrayOps: void foreach(scala.Function)>(v);
v = <scala.Predef$: scala.Predef$ MODULE$>;
v = <org.apache.activemq.leveldb.util.FileSupport$: org.apache.activemq.leveldb.util.FileSupport$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: java.io.File directory()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.util.FileSupport$: org.apache.activemq.leveldb.util.FileSupport$RichFile toRichFile(java.io.File)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.util.FileSupport$RichFile: java.io.File[] list_files()>();
v = virtualinvoke v.<scala.Predef$: scala.collection.mutable.ArrayOps refArrayOps(java.lang.Object[])>(v);
v = new org.apache.activemq.leveldb.LevelDBClient$$anonfun$locked_purge$2;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anonfun$locked_purge$2: void <init>(org.apache.activemq.leveldb.LevelDBClient)>(v);
interfaceinvoke v.<scala.collection.mutable.ArrayOps: void foreach(scala.Function)>(v);
return;
}
public scala.Option addCollection(org.apache.activemq.leveldb.record.CollectionRecord$Buffer)
{
byte[] v;
long v, v;
scala.Option v;
org.fusesource.hawtbuf.Buffer v;
org.apache.activemq.leveldb.LevelDBClient v;
org.apache.activemq.leveldb.record.CollectionRecord$Buffer v;
byte v;
java.lang.Long v;
org.apache.activemq.leveldb.LevelDBClient$CollectionMeta v;
org.apache.activemq.leveldb.LevelDBClient$$anonfun$addCollection$1 v;
scala.collection.mutable.HashMap v;
org.apache.activemq.leveldb.LevelDBClient$ v, v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v := @parameter: org.apache.activemq.leveldb.record.CollectionRecord$Buffer;
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: void assert_write_thread_executing()>();
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: byte COLLECTION_PREFIX()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.record.CollectionRecord$Buffer: long getKey()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: byte[] encodeLongKey(byte,long)>(v, v);
v = virtualinvoke v.<org.apache.activemq.leveldb.record.CollectionRecord$Buffer: org.fusesource.hawtbuf.Buffer toUnframedBuffer()>();
v = new org.apache.activemq.leveldb.LevelDBClient$$anonfun$addCollection$1;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anonfun$addCollection$1: void <init>(org.apache.activemq.leveldb.LevelDBClient,byte[],org.fusesource.hawtbuf.Buffer)>(v, v, v);
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: java.lang.Object might_fail_using_index(scala.Function)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: scala.collection.mutable.HashMap collectionMeta()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.record.CollectionRecord$Buffer: long getKey()>();
v = staticinvoke <scala.runtime.BoxesRunTime: java.lang.Long boxToLong(long)>(v);
v = new org.apache.activemq.leveldb.LevelDBClient$CollectionMeta;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$CollectionMeta: void <init>()>();
v = virtualinvoke v.<scala.collection.mutable.HashMap: scala.Option put(java.lang.Object,java.lang.Object)>(v, v);
return v;
}
public long getLogAppendPosition()
{
long v;
org.apache.activemq.leveldb.LevelDBClient v;
org.apache.activemq.leveldb.RecordLog v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.RecordLog log()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.RecordLog: long appender_limit()>();
return v;
}
public scala.collection.Seq listCollections()
{
org.apache.activemq.leveldb.LevelDBClient$$anonfun$listCollections$1 v;
org.apache.activemq.leveldb.LevelDBClient v;
scala.collection.mutable.ListBuffer v;
scala.collection.GenTraversable v;
scala.collection.mutable.ListBuffer$ v;
scala.collection.immutable.Nil$ v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v = <scala.collection.mutable.ListBuffer$: scala.collection.mutable.ListBuffer$ MODULE$>;
v = <scala.collection.immutable.Nil$: scala.collection.immutable.Nil$ MODULE$>;
v = virtualinvoke v.<scala.collection.mutable.ListBuffer$: scala.collection.GenTraversable apply(scala.collection.Seq)>(v);
v = new org.apache.activemq.leveldb.LevelDBClient$$anonfun$listCollections$1;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anonfun$listCollections$1: void <init>(org.apache.activemq.leveldb.LevelDBClient,scala.collection.mutable.ListBuffer)>(v, v);
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: java.lang.Object might_fail_using_index(scala.Function)>(v);
return v;
}
public void removeCollection(long)
{
byte[] v, v, v;
long v;
org.apache.activemq.leveldb.LevelDBClient v;
byte v, v;
java.lang.Long v;
org.apache.activemq.leveldb.LevelDBClient$$anonfun$removeCollection$1 v;
scala.collection.mutable.HashMap v;
org.apache.activemq.leveldb.LevelDBClient$ v, v, v, v, v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v := @parameter: long;
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: void assert_write_thread_executing()>();
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: byte COLLECTION_PREFIX()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: byte[] encodeLongKey(byte,long)>(v, v);
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: byte[] encodeVLong(long)>(v);
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: byte ENTRY_PREFIX()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: byte[] encodeLongKey(byte,long)>(v, v);
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: scala.collection.mutable.HashMap collectionMeta()>();
v = staticinvoke <scala.runtime.BoxesRunTime: java.lang.Long boxToLong(long)>(v);
virtualinvoke v.<scala.collection.mutable.HashMap: scala.Option remove(java.lang.Object)>(v);
v = new org.apache.activemq.leveldb.LevelDBClient$$anonfun$removeCollection$1;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anonfun$removeCollection$1: void <init>(org.apache.activemq.leveldb.LevelDBClient,byte[],byte[],byte[])>(v, v, v, v);
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: java.lang.Object might_fail_using_index(scala.Function)>(v);
return;
}
public void collectionEmpty(long)
{
byte[] v, v, v;
long v;
org.apache.activemq.leveldb.LevelDBClient v;
byte v, v;
java.lang.Long v;
scala.collection.mutable.HashMap v;
org.apache.activemq.leveldb.LevelDBClient$$anonfun$3 v;
org.apache.activemq.leveldb.LevelDBClient$$anonfun$collectionEmpty$1 v;
java.lang.Object v;
org.apache.activemq.leveldb.LevelDBClient$ v, v, v, v, v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v := @parameter: long;
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: void assert_write_thread_executing()>();
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: byte COLLECTION_PREFIX()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: byte[] encodeLongKey(byte,long)>(v, v);
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: byte[] encodeVLong(long)>(v);
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: byte ENTRY_PREFIX()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: byte[] encodeLongKey(byte,long)>(v, v);
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: scala.collection.mutable.HashMap collectionMeta()>();
v = staticinvoke <scala.runtime.BoxesRunTime: java.lang.Long boxToLong(long)>(v);
v = new org.apache.activemq.leveldb.LevelDBClient$$anonfun$3;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anonfun$3: void <init>(org.apache.activemq.leveldb.LevelDBClient)>(v);
v = virtualinvoke v.<scala.collection.mutable.HashMap: java.lang.Object getOrElseUpdate(java.lang.Object,scala.Function)>(v, v);
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$CollectionMeta: void size_$eq(long)>(0L);
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$CollectionMeta: void last_key_$eq(byte[])>(null);
v = new org.apache.activemq.leveldb.LevelDBClient$$anonfun$collectionEmpty$1;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anonfun$collectionEmpty$1: void <init>(org.apache.activemq.leveldb.LevelDBClient,byte[],byte[],byte[])>(v, v, v, v);
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: java.lang.Object might_fail_using_index(scala.Function)>(v);
return;
}
public int decodeQueueEntryMeta(org.apache.activemq.leveldb.record.EntryRecord$Getter)
{
org.apache.activemq.leveldb.LevelDBClient v;
org.fusesource.hawtbuf.DataByteArrayInputStream v;
int v, v;
org.apache.activemq.leveldb.record.EntryRecord$Getter v;
org.fusesource.hawtbuf.Buffer v;
boolean v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v := @parameter: org.apache.activemq.leveldb.record.EntryRecord$Getter;
v = interfaceinvoke v.<org.apache.activemq.leveldb.record.EntryRecord$Getter: boolean hasMeta()>();
if v == 0 goto label;
v = new org.fusesource.hawtbuf.DataByteArrayInputStream;
v = interfaceinvoke v.<org.apache.activemq.leveldb.record.EntryRecord$Getter: org.fusesource.hawtbuf.Buffer getMeta()>();
specialinvoke v.<org.fusesource.hawtbuf.DataByteArrayInputStream: void <init>(org.fusesource.hawtbuf.Buffer)>(v);
v = virtualinvoke v.<org.fusesource.hawtbuf.DataByteArrayInputStream: int readVarInt()>();
tableswitch(v)
{
case 1: goto label;
default: goto label;
};
label:
v = virtualinvoke v.<org.fusesource.hawtbuf.DataByteArrayInputStream: int readVarInt()>();
return v;
label:
return 0;
}
public int getDeliveryCounter(long, long)
{
byte[] v;
scala.runtime.IntRef v;
org.apache.activemq.leveldb.LevelDBClient$$anonfun$getDeliveryCounter$1 v;
long v, v;
org.iq.leveldb.ReadOptions v;
org.fusesource.hawtbuf.Buffer v;
org.apache.activemq.leveldb.LevelDBClient v;
byte v;
int v;
boolean v;
org.apache.activemq.leveldb.LevelDBClient$ v, v, v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v := @parameter: long;
v := @parameter: long;
v = new org.iq.leveldb.ReadOptions;
specialinvoke v.<org.iq.leveldb.ReadOptions: void <init>()>();
virtualinvoke v.<org.iq.leveldb.ReadOptions: org.iq.leveldb.ReadOptions fillCache(boolean)>(1);
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: boolean verifyChecksums()>();
virtualinvoke v.<org.iq.leveldb.ReadOptions: org.iq.leveldb.ReadOptions verifyChecksums(boolean)>(v);
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: byte ENTRY_PREFIX()>();
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: org.fusesource.hawtbuf.Buffer encodeLong(long)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: byte[] encodeEntryKey(byte,long,org.fusesource.hawtbuf.Buffer)>(v, v, v);
v = staticinvoke <scala.runtime.IntRef: scala.runtime.IntRef create(int)>(0);
v = new org.apache.activemq.leveldb.LevelDBClient$$anonfun$getDeliveryCounter$1;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anonfun$getDeliveryCounter$1: void <init>(org.apache.activemq.leveldb.LevelDBClient,org.iq.leveldb.ReadOptions,byte[],scala.runtime.IntRef)>(v, v, v, v);
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: java.lang.Object might_fail_using_index(scala.Function)>(v);
v = v.<scala.runtime.IntRef: int elem>;
return v;
}
public void queueCursor(long, long, long, scala.Function)
{
scala.Function v;
long v, v, v;
org.fusesource.hawtbuf.Buffer v, v;
org.apache.activemq.leveldb.LevelDBClient v;
org.apache.activemq.leveldb.LevelDBClient$$anonfun$queueCursor$1 v;
org.apache.activemq.leveldb.LevelDBClient$ v, v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v := @parameter: long;
v := @parameter: long;
v := @parameter: long;
v := @parameter: scala.Function;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: org.fusesource.hawtbuf.Buffer encodeLong(long)>(v);
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: org.fusesource.hawtbuf.Buffer encodeLong(long)>(v);
v = new org.apache.activemq.leveldb.LevelDBClient$$anonfun$queueCursor$1;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anonfun$queueCursor$1: void <init>(org.apache.activemq.leveldb.LevelDBClient,long,scala.Function)>(v, v, v);
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: void collectionCursor(long,org.fusesource.hawtbuf.Buffer,org.fusesource.hawtbuf.Buffer,scala.Function)>(v, v, v, v);
return;
}
public void transactionCursor(long, scala.Function)
{
org.apache.activemq.leveldb.LevelDBClient$$anonfun$transactionCursor$1 v;
scala.Function v;
long v;
org.fusesource.hawtbuf.Buffer v, v;
org.apache.activemq.leveldb.LevelDBClient v;
org.apache.activemq.leveldb.LevelDBClient$ v, v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v := @parameter: long;
v := @parameter: scala.Function;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: org.fusesource.hawtbuf.Buffer encodeLong(long)>(0L);
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: org.fusesource.hawtbuf.Buffer encodeLong(long)>(9223372036854775807L);
v = new org.apache.activemq.leveldb.LevelDBClient$$anonfun$transactionCursor$1;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anonfun$transactionCursor$1: void <init>(org.apache.activemq.leveldb.LevelDBClient,long,scala.Function)>(v, v, v);
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: void collectionCursor(long,org.fusesource.hawtbuf.Buffer,org.fusesource.hawtbuf.Buffer,scala.Function)>(v, v, v, v);
return;
}
public long getAckPosition(long)
{
org.apache.activemq.leveldb.LevelDBClient v;
org.apache.activemq.leveldb.LevelDBClient$$anonfun$getAckPosition$1 v;
java.lang.Object v;
long v, v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v := @parameter: long;
v = new org.apache.activemq.leveldb.LevelDBClient$$anonfun$getAckPosition$1;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anonfun$getAckPosition$1: void <init>(org.apache.activemq.leveldb.LevelDBClient,long)>(v, v);
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: java.lang.Object might_fail_using_index(scala.Function)>(v);
v = staticinvoke <scala.runtime.BoxesRunTime: long unboxToLong(java.lang.Object)>(v);
return v;
}
public org.apache.activemq.command.Message getMessage(java.lang.Object)
{
org.apache.activemq.leveldb.RecordLog v;
long v;
org.fusesource.hawtbuf.Buffer v;
org.apache.activemq.leveldb.LevelDBClient v;
scala.Predef$ v;
int v;
boolean v, v, v;
scala.Some v;
scala.MatchError v;
org.apache.activemq.leveldb.LevelDBClient$$anonfun$getMessage$2 v;
scala.Option v, v;
org.apache.activemq.leveldb.LevelDBClient$$anonfun$getMessage$1 v;
java.lang.Object v, v, v;
org.apache.activemq.leveldb.LevelDBClient$$anonfun$4 v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v := @parameter: java.lang.Object;
v = <scala.Predef$: scala.Predef$ MODULE$>;
if v != null goto label;
v = 0;
goto label;
label:
v = 1;
label:
virtualinvoke v.<scala.Predef$: void assert(boolean)>(v);
v = v instanceof org.apache.activemq.leveldb.MessageRecord;
if v == 0 goto label;
v = new scala.Some;
v = virtualinvoke v.<org.apache.activemq.leveldb.MessageRecord: org.fusesource.hawtbuf.Buffer data()>();
specialinvoke v.<scala.Some: void <init>(java.lang.Object)>(v);
v = v;
goto label;
label:
v = v instanceof org.apache.activemq.leveldb.DataLocator;
if v == 0 goto label;
v = virtualinvoke v.<org.apache.activemq.leveldb.DataLocator: long pos()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.DataLocator: int len()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.RecordLog log()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.RecordLog: scala.Option read(long,int)>(v, v);
v = new org.apache.activemq.leveldb.LevelDBClient$$anonfun$4;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anonfun$4: void <init>(org.apache.activemq.leveldb.LevelDBClient)>(v);
v = virtualinvoke v.<scala.Option: scala.Option map(scala.Function)>(v);
label:
v = new org.apache.activemq.leveldb.LevelDBClient$$anonfun$getMessage$1;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anonfun$getMessage$1: void <init>(org.apache.activemq.leveldb.LevelDBClient)>(v);
v = virtualinvoke v.<scala.Option: scala.Option map(scala.Function)>(v);
v = new org.apache.activemq.leveldb.LevelDBClient$$anonfun$getMessage$2;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anonfun$getMessage$2: void <init>(org.apache.activemq.leveldb.LevelDBClient)>(v);
v = virtualinvoke v.<scala.Option: java.lang.Object getOrElse(scala.Function)>(v);
return v;
label:
v = new scala.MatchError;
specialinvoke v.<scala.MatchError: void <init>(java.lang.Object)>(v);
throw v;
}
public org.apache.activemq.command.Message decodeMessage(org.fusesource.hawtbuf.Buffer)
{
byte[] v;
org.apache.activemq.leveldb.LevelDBStore v, v;
org.fusesource.hawtbuf.Buffer v, v;
org.apache.activemq.leveldb.LevelDBClient v;
org.apache.activemq.openwire.OpenWireFormat v;
int v, v;
java.lang.Object v;
org.apache.activemq.leveldb.package$ v;
org.apache.activemq.leveldb.package$SnappyTrait v;
org.apache.activemq.util.ByteSequence v;
boolean v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v := @parameter: org.fusesource.hawtbuf.Buffer;
v = v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.LevelDBStore org$apache$activemq$leveldb$LevelDBClient$$store>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: boolean snappyCompressLogs()>();
if v == 0 goto label;
v = <org.apache.activemq.leveldb.package$: org.apache.activemq.leveldb.package$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.package$: org.apache.activemq.leveldb.package$SnappyTrait Snappy()>();
v = interfaceinvoke v.<org.apache.activemq.leveldb.package$SnappyTrait: org.fusesource.hawtbuf.Buffer uncompress(org.fusesource.hawtbuf.Buffer)>(v);
goto label;
label:
v = v;
label:
v = v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.LevelDBStore org$apache$activemq$leveldb$LevelDBClient$$store>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.openwire.OpenWireFormat wireFormat()>();
v = new org.apache.activemq.util.ByteSequence;
v = v.<org.fusesource.hawtbuf.Buffer: byte[] data>;
v = v.<org.fusesource.hawtbuf.Buffer: int offset>;
v = v.<org.fusesource.hawtbuf.Buffer: int length>;
specialinvoke v.<org.apache.activemq.util.ByteSequence: void <init>(byte[],int,int)>(v, v, v);
v = virtualinvoke v.<org.apache.activemq.openwire.OpenWireFormat: java.lang.Object unmarshal(org.apache.activemq.util.ByteSequence)>(v);
return v;
}
public void collectionCursor(long, org.fusesource.hawtbuf.Buffer, org.fusesource.hawtbuf.Buffer, scala.Function)
{
byte[] v, v;
long v;
scala.Function v;
org.iq.leveldb.ReadOptions v;
org.fusesource.hawtbuf.Buffer v, v;
org.apache.activemq.leveldb.LevelDBClient v;
org.apache.activemq.leveldb.LevelDBClient$$anonfun$collectionCursor$1 v;
byte v, v;
boolean v;
org.apache.activemq.leveldb.LevelDBClient$ v, v, v, v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v := @parameter: long;
v := @parameter: org.fusesource.hawtbuf.Buffer;
v := @parameter: org.fusesource.hawtbuf.Buffer;
v := @parameter: scala.Function;
v = new org.iq.leveldb.ReadOptions;
specialinvoke v.<org.iq.leveldb.ReadOptions: void <init>()>();
virtualinvoke v.<org.iq.leveldb.ReadOptions: org.iq.leveldb.ReadOptions fillCache(boolean)>(1);
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: boolean verifyChecksums()>();
virtualinvoke v.<org.iq.leveldb.ReadOptions: org.iq.leveldb.ReadOptions verifyChecksums(boolean)>(v);
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: byte ENTRY_PREFIX()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: byte[] encodeEntryKey(byte,long,org.fusesource.hawtbuf.Buffer)>(v, v, v);
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: byte ENTRY_PREFIX()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: byte[] encodeEntryKey(byte,long,org.fusesource.hawtbuf.Buffer)>(v, v, v);
v = new org.apache.activemq.leveldb.LevelDBClient$$anonfun$collectionCursor$1;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anonfun$collectionCursor$1: void <init>(org.apache.activemq.leveldb.LevelDBClient,scala.Function,org.iq.leveldb.ReadOptions,byte[],byte[])>(v, v, v, v, v);
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: java.lang.Object might_fail_using_index(scala.Function)>(v);
return;
}
public long collectionSize(long)
{
long v, v;
scala.Option v, v;
org.apache.activemq.leveldb.LevelDBClient$$anonfun$collectionSize$1 v;
org.apache.activemq.leveldb.LevelDBClient$$anonfun$collectionSize$2 v;
org.apache.activemq.leveldb.LevelDBClient v;
java.lang.Long v;
java.lang.Object v;
scala.collection.mutable.HashMap v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v := @parameter: long;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: scala.collection.mutable.HashMap collectionMeta()>();
v = staticinvoke <scala.runtime.BoxesRunTime: java.lang.Long boxToLong(long)>(v);
v = virtualinvoke v.<scala.collection.mutable.HashMap: scala.Option get(java.lang.Object)>(v);
v = new org.apache.activemq.leveldb.LevelDBClient$$anonfun$collectionSize$2;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anonfun$collectionSize$2: void <init>(org.apache.activemq.leveldb.LevelDBClient)>(v);
v = virtualinvoke v.<scala.Option: scala.Option map(scala.Function)>(v);
v = new org.apache.activemq.leveldb.LevelDBClient$$anonfun$collectionSize$1;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anonfun$collectionSize$1: void <init>(org.apache.activemq.leveldb.LevelDBClient)>(v);
v = virtualinvoke v.<scala.Option: java.lang.Object getOrElse(scala.Function)>(v);
v = staticinvoke <scala.runtime.BoxesRunTime: long unboxToLong(java.lang.Object)>(v);
return v;
}
public boolean collectionIsEmpty(long)
{
scala.runtime.BooleanRef v;
byte[] v;
org.apache.activemq.leveldb.LevelDBClient$$anonfun$collectionIsEmpty$1 v;
long v;
org.apache.activemq.leveldb.LevelDBClient v;
byte v;
boolean v;
org.apache.activemq.leveldb.LevelDBClient$ v, v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v := @parameter: long;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: byte ENTRY_PREFIX()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: byte[] encodeLongKey(byte,long)>(v, v);
v = staticinvoke <scala.runtime.BooleanRef: scala.runtime.BooleanRef create(boolean)>(1);
v = new org.apache.activemq.leveldb.LevelDBClient$$anonfun$collectionIsEmpty$1;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anonfun$collectionIsEmpty$1: void <init>(org.apache.activemq.leveldb.LevelDBClient,byte[],scala.runtime.BooleanRef)>(v, v, v);
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: java.lang.Object might_fail_using_index(scala.Function)>(v);
v = v.<scala.runtime.BooleanRef: boolean elem>;
return v;
}
public org.apache.activemq.leveldb.util.TimeMetric max_write_message_latency()
{
org.apache.activemq.leveldb.util.TimeMetric v;
org.apache.activemq.leveldb.LevelDBClient v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v = v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.util.TimeMetric max_write_message_latency>;
return v;
}
public org.apache.activemq.leveldb.util.TimeMetric max_write_enqueue_latency()
{
org.apache.activemq.leveldb.util.TimeMetric v;
org.apache.activemq.leveldb.LevelDBClient v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v = v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.util.TimeMetric max_write_enqueue_latency>;
return v;
}
public org.apache.activemq.leveldb.util.TimeMetric max_index_write_latency()
{
org.apache.activemq.leveldb.util.TimeMetric v;
org.apache.activemq.leveldb.LevelDBClient v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v = v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.util.TimeMetric max_index_write_latency>;
return v;
}
public void store(org.apache.activemq.leveldb.DelayableUOW[])
{
org.apache.activemq.leveldb.LevelDBClient v;
org.apache.activemq.leveldb.DelayableUOW[] v;
org.apache.activemq.leveldb.LevelDBClient$$anonfun$store$1 v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v := @parameter: org.apache.activemq.leveldb.DelayableUOW[];
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: void assert_write_thread_executing()>();
v = new org.apache.activemq.leveldb.LevelDBClient$$anonfun$store$1;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anonfun$store$1: void <init>(org.apache.activemq.leveldb.LevelDBClient,org.apache.activemq.leveldb.DelayableUOW[])>(v, v);
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: java.lang.Object might_fail_using_index(scala.Function)>(v);
return;
}
public boolean storeTrace$default$2()
{
org.apache.activemq.leveldb.LevelDBClient v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
return 0;
}
public boolean write_uows(org.apache.activemq.leveldb.DelayableUOW[], org.apache.activemq.leveldb.RecordLog$LogAppender, org.iq.leveldb.WriteBatch)
{
org.iq.leveldb.WriteBatch v;
scala.runtime.BooleanRef v;
org.apache.activemq.leveldb.util.TimeMetric v, v;
org.apache.activemq.leveldb.LevelDBClient$$anonfun$write_uows$1 v;
org.apache.activemq.leveldb.RecordLog$LogAppender v;
org.apache.activemq.leveldb.DelayableUOW[] v;
long v, v;
org.apache.activemq.leveldb.LevelDBClient v;
scala.Predef$ v;
scala.runtime.LongRef v, v;
scala.collection.mutable.ArrayOps v;
boolean v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v := @parameter: org.apache.activemq.leveldb.DelayableUOW[];
v := @parameter: org.apache.activemq.leveldb.RecordLog$LogAppender;
v := @parameter: org.iq.leveldb.WriteBatch;
v = staticinvoke <scala.runtime.BooleanRef: scala.runtime.BooleanRef create(boolean)>(0);
v = staticinvoke <scala.runtime.LongRef: scala.runtime.LongRef create(long)>(0L);
v = staticinvoke <scala.runtime.LongRef: scala.runtime.LongRef create(long)>(0L);
v = <scala.Predef$: scala.Predef$ MODULE$>;
v = virtualinvoke v.<scala.Predef$: scala.collection.mutable.ArrayOps refArrayOps(java.lang.Object[])>(v);
v = new org.apache.activemq.leveldb.LevelDBClient$$anonfun$write_uows$1;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anonfun$write_uows$1: void <init>(org.apache.activemq.leveldb.LevelDBClient,org.apache.activemq.leveldb.RecordLog$LogAppender,org.iq.leveldb.WriteBatch,scala.runtime.BooleanRef,scala.runtime.LongRef,scala.runtime.LongRef)>(v, v, v, v, v, v);
interfaceinvoke v.<scala.collection.mutable.ArrayOps: void foreach(scala.Function)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.util.TimeMetric max_write_message_latency()>();
v = v.<scala.runtime.LongRef: long elem>;
virtualinvoke v.<org.apache.activemq.leveldb.util.TimeMetric: void add(long)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.util.TimeMetric max_write_enqueue_latency()>();
v = v.<scala.runtime.LongRef: long elem>;
virtualinvoke v.<org.apache.activemq.leveldb.util.TimeMetric: void add(long)>(v);
v = v.<scala.runtime.BooleanRef: boolean elem>;
return v;
}
public scala.collection.Seq getCollectionEntries(long, long, long)
{
org.apache.activemq.leveldb.LevelDBClient$$anonfun$getCollectionEntries$1 v;
scala.collection.mutable.ListBuffer v;
long v, v, v;
org.iq.leveldb.ReadOptions v;
org.apache.activemq.leveldb.LevelDBClient v;
java.lang.Object v;
scala.collection.GenTraversable v;
scala.collection.mutable.ListBuffer$ v;
scala.runtime.ObjectRef v;
boolean v;
scala.collection.immutable.Nil$ v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v := @parameter: long;
v := @parameter: long;
v := @parameter: long;
v = <scala.collection.mutable.ListBuffer$: scala.collection.mutable.ListBuffer$ MODULE$>;
v = <scala.collection.immutable.Nil$: scala.collection.immutable.Nil$ MODULE$>;
v = virtualinvoke v.<scala.collection.mutable.ListBuffer$: scala.collection.GenTraversable apply(scala.collection.Seq)>(v);
v = staticinvoke <scala.runtime.ObjectRef: scala.runtime.ObjectRef create(java.lang.Object)>(v);
v = new org.iq.leveldb.ReadOptions;
specialinvoke v.<org.iq.leveldb.ReadOptions: void <init>()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: boolean verifyChecksums()>();
virtualinvoke v.<org.iq.leveldb.ReadOptions: org.iq.leveldb.ReadOptions verifyChecksums(boolean)>(v);
virtualinvoke v.<org.iq.leveldb.ReadOptions: org.iq.leveldb.ReadOptions fillCache(boolean)>(1);
v = new org.apache.activemq.leveldb.LevelDBClient$$anonfun$getCollectionEntries$1;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anonfun$getCollectionEntries$1: void <init>(org.apache.activemq.leveldb.LevelDBClient,long,long,long,scala.runtime.ObjectRef,org.iq.leveldb.ReadOptions)>(v, v, v, v, v, v);
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: java.lang.Object might_fail_using_index(scala.Function)>(v);
v = v.<scala.runtime.ObjectRef: java.lang.Object elem>;
return v;
}
public long getLastQueueEntrySeq(long)
{
long v, v;
scala.Option v, v;
org.apache.activemq.leveldb.LevelDBClient v;
java.lang.Object v;
org.apache.activemq.leveldb.LevelDBClient$$anonfun$getLastQueueEntrySeq$1 v;
org.apache.activemq.leveldb.LevelDBClient$$anonfun$getLastQueueEntrySeq$2 v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v := @parameter: long;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: scala.Option getLastCollectionEntryKey(long)>(v);
v = new org.apache.activemq.leveldb.LevelDBClient$$anonfun$getLastQueueEntrySeq$2;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anonfun$getLastQueueEntrySeq$2: void <init>(org.apache.activemq.leveldb.LevelDBClient)>(v);
v = virtualinvoke v.<scala.Option: scala.Option map(scala.Function)>(v);
v = new org.apache.activemq.leveldb.LevelDBClient$$anonfun$getLastQueueEntrySeq$1;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anonfun$getLastQueueEntrySeq$1: void <init>(org.apache.activemq.leveldb.LevelDBClient)>(v);
v = virtualinvoke v.<scala.Option: java.lang.Object getOrElse(scala.Function)>(v);
v = staticinvoke <scala.runtime.BoxesRunTime: long unboxToLong(java.lang.Object)>(v);
return v;
}
public scala.Option getLastCollectionEntryKey(long)
{
long v;
scala.Option v, v, v;
org.apache.activemq.leveldb.LevelDBClient v;
java.lang.Long v;
org.apache.activemq.leveldb.LevelDBClient$$anonfun$getLastCollectionEntryKey$1 v;
org.apache.activemq.leveldb.LevelDBClient$$anonfun$getLastCollectionEntryKey$2 v;
scala.collection.mutable.HashMap v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v := @parameter: long;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: scala.collection.mutable.HashMap collectionMeta()>();
v = staticinvoke <scala.runtime.BoxesRunTime: java.lang.Long boxToLong(long)>(v);
v = virtualinvoke v.<scala.collection.mutable.HashMap: scala.Option get(java.lang.Object)>(v);
v = new org.apache.activemq.leveldb.LevelDBClient$$anonfun$getLastCollectionEntryKey$1;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anonfun$getLastCollectionEntryKey$1: void <init>(org.apache.activemq.leveldb.LevelDBClient)>(v);
v = virtualinvoke v.<scala.Option: scala.Option flatMap(scala.Function)>(v);
v = new org.apache.activemq.leveldb.LevelDBClient$$anonfun$getLastCollectionEntryKey$2;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anonfun$getLastCollectionEntryKey$2: void <init>(org.apache.activemq.leveldb.LevelDBClient)>(v);
v = virtualinvoke v.<scala.Option: scala.Option map(scala.Function)>(v);
return v;
}
private void detect_if_compact_needed()
{
long v, v, v, v;
org.apache.activemq.leveldb.LevelDBClient v;
byte v, v, v;
int v, v;
org.apache.activemq.leveldb.util.FileSupport$ v;
org.apache.activemq.leveldb.util.FileSupport$RichFile v;
scala.collection.mutable.HashMap v;
double v;
org.apache.activemq.leveldb.LevelDBClient$RichDB v, v;
scala.collection.immutable.List v;
org.apache.activemq.leveldb.LevelDBStore v, v;
java.io.File v;
org.apache.activemq.leveldb.LevelDBClient$$anonfun$detect_if_compact_needed$1 v;
org.apache.activemq.leveldb.LevelDBClient$$anonfun$detect_if_compact_needed$2 v;
org.apache.activemq.leveldb.LevelDBClient$$anonfun$detect_if_compact_needed$3 v;
scala.runtime.LongRef v, v;
float v;
scala.collection.generic.FilterMonadic v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v = v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.LevelDBStore org$apache$activemq$leveldb$LevelDBClient$$store>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: int autoCompactionRatio()>();
if v > 0 goto label;
return;
label:
v = staticinvoke <scala.runtime.LongRef: scala.runtime.LongRef create(long)>(0L);
v = <org.apache.activemq.leveldb.util.FileSupport$: org.apache.activemq.leveldb.util.FileSupport$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: java.io.File dirtyIndexFile()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.util.FileSupport$: org.apache.activemq.leveldb.util.FileSupport$RichFile toRichFile(java.io.File)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.util.FileSupport$RichFile: scala.collection.immutable.List recursiveList()>();
v = new org.apache.activemq.leveldb.LevelDBClient$$anonfun$detect_if_compact_needed$1;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anonfun$detect_if_compact_needed$1: void <init>(org.apache.activemq.leveldb.LevelDBClient,scala.runtime.LongRef)>(v, v);
virtualinvoke v.<scala.collection.immutable.List: void foreach(scala.Function)>(v);
v = staticinvoke <scala.runtime.LongRef: scala.runtime.LongRef create(long)>(0L);
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: scala.collection.mutable.HashMap logRefs()>();
v = new org.apache.activemq.leveldb.LevelDBClient$$anonfun$detect_if_compact_needed$2;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anonfun$detect_if_compact_needed$2: void <init>(org.apache.activemq.leveldb.LevelDBClient)>(v);
v = virtualinvoke v.<scala.collection.mutable.HashMap: scala.collection.generic.FilterMonadic withFilter(scala.Function)>(v);
v = new org.apache.activemq.leveldb.LevelDBClient$$anonfun$detect_if_compact_needed$3;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anonfun$detect_if_compact_needed$3: void <init>(org.apache.activemq.leveldb.LevelDBClient,scala.runtime.LongRef)>(v, v);
interfaceinvoke v.<scala.collection.generic.FilterMonadic: void foreach(scala.Function)>(v);
v = v.<scala.runtime.LongRef: long elem>;
v = v cmp 41943040L;
if v <= 0 goto label;
v = v.<scala.runtime.LongRef: long elem>;
v = v cmp 0L;
if v <= 0 goto label;
v = v.<scala.runtime.LongRef: long elem>;
v = v * 1.0;
v = v.<scala.runtime.LongRef: long elem>;
v = v / v;
v = v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.LevelDBStore org$apache$activemq$leveldb$LevelDBClient$$store>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: int autoCompactionRatio()>();
v = v cmpl v;
if v <= 0 goto label;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.LevelDBClient$RichDB index()>();
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$RichDB: void compact_needed_$eq(boolean)>(1);
goto label;
label:
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.LevelDBClient$RichDB index()>();
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$RichDB: void compact_needed_$eq(boolean)>(1);
label:
return;
}
public void gc(scala.collection.Seq)
{
org.apache.activemq.leveldb.RecordLog v, v;
org.apache.activemq.leveldb.LevelDBClient v;
scala.collection.JavaConversions$ v;
boolean v, v;
scala.collection.Seq v, v;
org.apache.activemq.leveldb.RecordLog$LogInfo v;
java.util.Set v;
scala.collection.Set v;
scala.collection.immutable.Set v;
org.apache.activemq.leveldb.LevelDBClient$ v;
scala.collection.generic.FilterMonadic v;
scala.runtime.RichLong$ v;
org.apache.activemq.leveldb.LevelDBClient$$anonfun$gc$5 v;
java.lang.Object[] v;
org.apache.activemq.leveldb.LevelDBClient$$anonfun$gc$4 v;
java.lang.Double v;
long v, v, v, v, v, v, v, v, v;
scala.Predef$ v, v;
org.apache.activemq.leveldb.LevelDBClient$$anonfun$gc$3 v;
org.apache.activemq.leveldb.LevelDBClient$$anonfun$gc$2 v;
org.apache.activemq.leveldb.LevelDBClient$$anonfun$gc$1 v;
scala.collection.mutable.HashMap v, v;
double v;
org.apache.activemq.leveldb.LevelDBClient$RichDB v, v;
scala.collection.mutable.WrappedArray v;
org.apache.activemq.leveldb.LevelDBClient$$anonfun$1 v;
scala.runtime.BoxedUnit v;
scala.Option v;
java.io.File v;
scala.collection.mutable.Set v;
scala.collection.generic.Subtractable v;
java.util.TreeMap v;
scala.runtime.LongRef v;
java.lang.Object v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v := @parameter: scala.collection.Seq;
v = interfaceinvoke v.<scala.collection.Seq: boolean isEmpty()>();
if v == 0 goto label;
v = <scala.runtime.BoxedUnit: scala.runtime.BoxedUnit UNIT>;
goto label;
label:
v = new org.apache.activemq.leveldb.LevelDBClient$$anonfun$gc$1;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anonfun$gc$1: void <init>(org.apache.activemq.leveldb.LevelDBClient,scala.collection.Seq)>(v, v);
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: java.lang.Object might_fail_using_index(scala.Function)>(v);
label:
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient: void detect_if_compact_needed()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.LevelDBClient$RichDB index()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$RichDB: boolean compact_needed()>();
if v == 0 goto label;
v = staticinvoke <java.lang.System: long nanoTime()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.LevelDBClient$RichDB index()>();
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$RichDB: void compact()>();
v = staticinvoke <java.lang.System: long nanoTime()>();
v = v - v;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = new org.apache.activemq.leveldb.LevelDBClient$$anonfun$gc$3;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anonfun$gc$3: void <init>(org.apache.activemq.leveldb.LevelDBClient)>(v);
v = <scala.Predef$: scala.Predef$ MODULE$>;
v = newarray (java.lang.Object)[2];
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: java.io.File dirtyIndexFile()>();
v[0] = v;
v = v / 1000000.0;
v = staticinvoke <scala.runtime.BoxesRunTime: java.lang.Double boxToDouble(double)>(v);
v[1] = v;
v = virtualinvoke v.<scala.Predef$: scala.collection.mutable.WrappedArray genericWrapArray(java.lang.Object)>(v);
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: void info(scala.Function,scala.collection.Seq)>(v, v);
label:
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: scala.collection.mutable.HashMap logRefs()>();
v = virtualinvoke v.<scala.collection.mutable.HashMap: scala.collection.Seq toSeq()>();
v = new org.apache.activemq.leveldb.LevelDBClient$$anonfun$gc$4;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anonfun$gc$4: void <init>(org.apache.activemq.leveldb.LevelDBClient)>(v);
v = interfaceinvoke v.<scala.collection.Seq: scala.collection.generic.FilterMonadic withFilter(scala.Function)>(v);
v = new org.apache.activemq.leveldb.LevelDBClient$$anonfun$gc$5;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anonfun$gc$5: void <init>(org.apache.activemq.leveldb.LevelDBClient)>(v);
interfaceinvoke v.<scala.collection.generic.FilterMonadic: void foreach(scala.Function)>(v);
v = <scala.collection.JavaConversions$: scala.collection.JavaConversions$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.RecordLog log()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.RecordLog: java.util.TreeMap log_infos()>();
v = virtualinvoke v.<java.util.TreeMap: java.util.Set keySet()>();
v = virtualinvoke v.<scala.collection.JavaConversions$: scala.collection.mutable.Set asScalaSet(java.util.Set)>(v);
v = interfaceinvoke v.<scala.collection.mutable.Set: scala.collection.immutable.Set toSet()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: scala.collection.mutable.HashMap logRefs()>();
v = virtualinvoke v.<scala.collection.mutable.HashMap: scala.collection.Set keySet()>();
v = interfaceinvoke v.<scala.collection.immutable.Set: scala.collection.generic.Subtractable $minus$minus(scala.collection.GenTraversableOnce)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: long oldest_retained_snapshot()>();
v = staticinvoke <scala.runtime.LongRef: scala.runtime.LongRef create(long)>(v);
v = <scala.runtime.RichLong$: scala.runtime.RichLong$ MODULE$>;
v = <scala.Predef$: scala.Predef$ MODULE$>;
v = v.<scala.runtime.LongRef: long elem>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.RecordLog$LogInfo logRefKey$default$2()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: scala.Option logRefKey(long,org.apache.activemq.leveldb.RecordLog$LogInfo)>(v, v);
v = new org.apache.activemq.leveldb.LevelDBClient$$anonfun$1;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anonfun$1: void <init>(org.apache.activemq.leveldb.LevelDBClient,scala.runtime.LongRef)>(v, v);
v = virtualinvoke v.<scala.Option: java.lang.Object getOrElse(scala.Function)>(v);
v = staticinvoke <scala.runtime.BoxesRunTime: long unboxToLong(java.lang.Object)>(v);
v = virtualinvoke v.<scala.Predef$: long longWrapper(long)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.RecordLog log()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.RecordLog: long appender_start()>();
v = virtualinvoke v.<scala.runtime.RichLong$: long min$extension(long,long)>(v, v);
v = new org.apache.activemq.leveldb.LevelDBClient$$anonfun$gc$2;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anonfun$gc$2: void <init>(org.apache.activemq.leveldb.LevelDBClient,long)>(v, v);
interfaceinvoke v.<scala.collection.immutable.Set: void foreach(scala.Function)>(v);
return;
}
public long oldest_retained_snapshot()
{
long v;
org.apache.activemq.leveldb.LevelDBClient v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: long lastIndexSnapshotPos()>();
return v;
}
public void removePlist(long)
{
org.apache.activemq.leveldb.LevelDBClient v;
java.lang.Long v;
long v;
org.apache.activemq.leveldb.LevelDBClient$$anonfun$removePlist$1 v;
org.fusesource.hawtbuf.Buffer v;
scala.collection.mutable.HashMap v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v := @parameter: long;
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: org.fusesource.hawtbuf.Buffer encodeLong(long)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: scala.collection.mutable.HashMap collectionMeta()>();
v = staticinvoke <scala.runtime.BoxesRunTime: java.lang.Long boxToLong(long)>(v);
virtualinvoke v.<scala.collection.mutable.HashMap: scala.Option remove(java.lang.Object)>(v);
v = new org.apache.activemq.leveldb.LevelDBClient$$anonfun$removePlist$1;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anonfun$removePlist$1: void <init>(org.apache.activemq.leveldb.LevelDBClient,org.fusesource.hawtbuf.Buffer)>(v, v);
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: java.lang.Object might_fail(scala.Function)>(v);
return;
}
public void plistPut(byte[], byte[])
{
org.apache.activemq.leveldb.LevelDBClient$RichDB v;
byte[] v, v;
org.iq.leveldb.WriteOptions v;
org.apache.activemq.leveldb.LevelDBClient v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v := @parameter: byte[];
v := @parameter: byte[];
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.LevelDBClient$RichDB plist()>();
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: org.iq.leveldb.WriteOptions PLIST_WRITE_OPTIONS()>();
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$RichDB: void put(byte[],byte[],org.iq.leveldb.WriteOptions)>(v, v, v);
return;
}
public void plistDelete(byte[])
{
org.apache.activemq.leveldb.LevelDBClient$RichDB v;
byte[] v;
org.iq.leveldb.WriteOptions v;
org.apache.activemq.leveldb.LevelDBClient v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v := @parameter: byte[];
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.LevelDBClient$RichDB plist()>();
v = <org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: org.iq.leveldb.WriteOptions PLIST_WRITE_OPTIONS()>();
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$RichDB: void delete(byte[],org.iq.leveldb.WriteOptions)>(v, v);
return;
}
public scala.Option plistGet(byte[])
{
org.apache.activemq.leveldb.LevelDBClient$RichDB v;
byte[] v;
org.apache.activemq.leveldb.LevelDBClient v;
org.iq.leveldb.ReadOptions v;
scala.Option v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v := @parameter: byte[];
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.LevelDBClient$RichDB plist()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$RichDB: org.iq.leveldb.ReadOptions get$default$2()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$RichDB: scala.Option get(byte[],org.iq.leveldb.ReadOptions)>(v, v);
return v;
}
public org.iq.leveldb.DBIterator plistIterator()
{
org.apache.activemq.leveldb.LevelDBClient$RichDB v;
org.iq.leveldb.DB v;
org.apache.activemq.leveldb.LevelDBClient v;
org.iq.leveldb.DBIterator v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.LevelDBClient$RichDB plist()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$RichDB: org.iq.leveldb.DB db()>();
v = interfaceinvoke v.<org.iq.leveldb.DB: org.iq.leveldb.DBIterator iterator()>();
return v;
}
private final scala.runtime.Nothing$ handleFailure$1(java.io.IOException)
{
org.apache.activemq.broker.BrokerService v, v;
java.io.IOException v;
org.apache.activemq.leveldb.LevelDBStore v, v;
org.apache.activemq.leveldb.LevelDBClient v;
org.apache.activemq.leveldb.LevelDBClient$$anon$2 v;
org.apache.activemq.broker.SuppressReplyException v;
java.lang.Object v;
scala.runtime.ObjectRef v;
boolean v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v := @parameter: java.io.IOException;
v = staticinvoke <scala.runtime.ObjectRef: scala.runtime.ObjectRef create(java.lang.Object)>(v);
v = v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.LevelDBStore org$apache$activemq$leveldb$LevelDBClient$$store>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.broker.BrokerService broker_service()>();
if v == null goto label;
v = new org.apache.activemq.leveldb.LevelDBClient$$anon$2;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anon$2: void <init>(org.apache.activemq.leveldb.LevelDBClient,java.io.IOException,scala.runtime.ObjectRef)>(v, v, v);
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anon$2: void start()>();
label:
v = v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.LevelDBStore org$apache$activemq$leveldb$LevelDBClient$$store>;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.broker.BrokerService broker_service()>();
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: boolean isStopping()>();
if v == 0 goto label;
label:
v = new org.apache.activemq.broker.SuppressReplyException;
v = v.<scala.runtime.ObjectRef: java.lang.Object elem>;
specialinvoke v.<org.apache.activemq.broker.SuppressReplyException: void <init>(java.lang.Throwable)>(v);
throw v;
label:
staticinvoke <java.lang.Thread: void sleep(long)>(100L);
goto label;
}
private final void storeMap$1(byte[], scala.collection.mutable.HashMap)
{
java.lang.Throwable v;
org.apache.activemq.leveldb.LevelDBClient$RichDB v;
byte[] v, v;
org.iq.leveldb.WriteOptions v;
org.fusesource.hawtbuf.ByteArrayOutputStream v;
org.apache.activemq.leveldb.LevelDBClient v;
org.apache.activemq.leveldb.LevelDBClient$$anonfun$storeMap$1$2 v;
org.apache.activemq.leveldb.LevelDBClient$$anonfun$storeMap$1$1 v;
int v;
java.io.ObjectOutputStream v;
scala.collection.mutable.HashMap v;
scala.collection.generic.FilterMonadic v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v := @parameter: byte[];
v := @parameter: scala.collection.mutable.HashMap;
v = new org.fusesource.hawtbuf.ByteArrayOutputStream;
specialinvoke v.<org.fusesource.hawtbuf.ByteArrayOutputStream: void <init>()>();
v = new java.io.ObjectOutputStream;
specialinvoke v.<java.io.ObjectOutputStream: void <init>(java.io.OutputStream)>(v);
v = virtualinvoke v.<scala.collection.mutable.HashMap: int size()>();
virtualinvoke v.<java.io.ObjectOutputStream: void writeInt(int)>(v);
v = new org.apache.activemq.leveldb.LevelDBClient$$anonfun$storeMap$1$1;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anonfun$storeMap$1$1: void <init>(org.apache.activemq.leveldb.LevelDBClient)>(v);
v = virtualinvoke v.<scala.collection.mutable.HashMap: scala.collection.generic.FilterMonadic withFilter(scala.Function)>(v);
v = new org.apache.activemq.leveldb.LevelDBClient$$anonfun$storeMap$1$2;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anonfun$storeMap$1$2: void <init>(org.apache.activemq.leveldb.LevelDBClient,java.io.ObjectOutputStream)>(v, v);
interfaceinvoke v.<scala.collection.generic.FilterMonadic: void foreach(scala.Function)>(v);
virtualinvoke v.<java.io.ObjectOutputStream: void close()>();
label:
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.LevelDBClient$RichDB index()>();
v = virtualinvoke v.<org.fusesource.hawtbuf.ByteArrayOutputStream: byte[] toByteArray()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$RichDB: org.iq.leveldb.WriteOptions put$default$3()>();
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$RichDB: void put(byte[],byte[],org.iq.leveldb.WriteOptions)>(v, v, v);
label:
return;
label:
v := @caughtexception;
throw v;
catch java.lang.Throwable from label to label with label;
}
private final void storeList$1(byte[], long[])
{
java.lang.Throwable v;
org.apache.activemq.leveldb.LevelDBClient$RichDB v;
byte[] v, v;
org.iq.leveldb.WriteOptions v;
org.fusesource.hawtbuf.ByteArrayOutputStream v;
long[] v;
org.apache.activemq.leveldb.LevelDBClient v;
scala.Predef$ v, v;
int v;
org.apache.activemq.leveldb.LevelDBClient$$anonfun$storeList$1$1 v;
java.io.ObjectOutputStream v;
scala.collection.mutable.ArrayOps v, v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v := @parameter: byte[];
v := @parameter: long[];
v = new org.fusesource.hawtbuf.ByteArrayOutputStream;
specialinvoke v.<org.fusesource.hawtbuf.ByteArrayOutputStream: void <init>()>();
v = new java.io.ObjectOutputStream;
specialinvoke v.<java.io.ObjectOutputStream: void <init>(java.io.OutputStream)>(v);
v = <scala.Predef$: scala.Predef$ MODULE$>;
v = virtualinvoke v.<scala.Predef$: scala.collection.mutable.ArrayOps longArrayOps(long[])>(v);
v = interfaceinvoke v.<scala.collection.mutable.ArrayOps: int size()>();
virtualinvoke v.<java.io.ObjectOutputStream: void writeInt(int)>(v);
v = <scala.Predef$: scala.Predef$ MODULE$>;
v = virtualinvoke v.<scala.Predef$: scala.collection.mutable.ArrayOps longArrayOps(long[])>(v);
v = new org.apache.activemq.leveldb.LevelDBClient$$anonfun$storeList$1$1;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anonfun$storeList$1$1: void <init>(org.apache.activemq.leveldb.LevelDBClient,java.io.ObjectOutputStream)>(v, v);
interfaceinvoke v.<scala.collection.mutable.ArrayOps: void foreach(scala.Function)>(v);
virtualinvoke v.<java.io.ObjectOutputStream: void close()>();
label:
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.LevelDBClient$RichDB index()>();
v = virtualinvoke v.<org.fusesource.hawtbuf.ByteArrayOutputStream: byte[] toByteArray()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$RichDB: org.iq.leveldb.WriteOptions put$default$3()>();
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$RichDB: void put(byte[],byte[],org.iq.leveldb.WriteOptions)>(v, v, v);
label:
return;
label:
v := @caughtexception;
throw v;
catch java.lang.Throwable from label to label with label;
}
private final void storeObject$1(byte[], java.lang.Object)
{
org.apache.activemq.leveldb.LevelDBClient$RichDB v;
byte[] v, v;
org.iq.leveldb.WriteOptions v;
org.fusesource.hawtbuf.ByteArrayOutputStream v;
org.apache.activemq.leveldb.LevelDBClient v;
java.io.ObjectOutputStream v;
java.lang.Object v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v := @parameter: byte[];
v := @parameter: java.lang.Object;
v = new org.fusesource.hawtbuf.ByteArrayOutputStream;
specialinvoke v.<org.fusesource.hawtbuf.ByteArrayOutputStream: void <init>()>();
v = new java.io.ObjectOutputStream;
specialinvoke v.<java.io.ObjectOutputStream: void <init>(java.io.OutputStream)>(v);
virtualinvoke v.<java.io.ObjectOutputStream: void writeObject(java.lang.Object)>(v);
virtualinvoke v.<java.io.ObjectOutputStream: void close()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.LevelDBClient$RichDB index()>();
v = virtualinvoke v.<org.fusesource.hawtbuf.ByteArrayOutputStream: byte[] toByteArray()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$RichDB: org.iq.leveldb.WriteOptions put$default$3()>();
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$RichDB: void put(byte[],byte[],org.iq.leveldb.WriteOptions)>(v, v, v);
return;
}
private final void loadMap$1(byte[], scala.collection.mutable.HashMap)
{
org.apache.activemq.leveldb.LevelDBClient$RichDB v;
byte[] v;
org.apache.activemq.leveldb.LevelDBClient v;
org.iq.leveldb.ReadOptions v;
scala.Option v;
org.apache.activemq.leveldb.LevelDBClient$$anonfun$loadMap$1$1 v;
scala.collection.mutable.HashMap v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v := @parameter: byte[];
v := @parameter: scala.collection.mutable.HashMap;
virtualinvoke v.<scala.collection.mutable.HashMap: void clear()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.LevelDBClient$RichDB index()>();
v = new org.iq.leveldb.ReadOptions;
specialinvoke v.<org.iq.leveldb.ReadOptions: void <init>()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$RichDB: scala.Option get(byte[],org.iq.leveldb.ReadOptions)>(v, v);
v = new org.apache.activemq.leveldb.LevelDBClient$$anonfun$loadMap$1$1;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anonfun$loadMap$1$1: void <init>(org.apache.activemq.leveldb.LevelDBClient,scala.collection.mutable.HashMap)>(v, v);
virtualinvoke v.<scala.Option: void foreach(scala.Function)>(v);
return;
}
private final scala.Option loadList$1(byte[])
{
org.apache.activemq.leveldb.LevelDBClient$RichDB v;
byte[] v;
org.apache.activemq.leveldb.LevelDBClient v;
org.apache.activemq.leveldb.LevelDBClient$$anonfun$loadList$1$1 v;
org.iq.leveldb.ReadOptions v;
scala.Option v, v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v := @parameter: byte[];
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.LevelDBClient$RichDB index()>();
v = new org.iq.leveldb.ReadOptions;
specialinvoke v.<org.iq.leveldb.ReadOptions: void <init>()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$RichDB: scala.Option get(byte[],org.iq.leveldb.ReadOptions)>(v, v);
v = new org.apache.activemq.leveldb.LevelDBClient$$anonfun$loadList$1$1;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anonfun$loadList$1$1: void <init>(org.apache.activemq.leveldb.LevelDBClient)>(v);
v = virtualinvoke v.<scala.Option: scala.Option map(scala.Function)>(v);
return v;
}
private final scala.Option loadObject$1(byte[])
{
org.apache.activemq.leveldb.LevelDBClient$RichDB v;
byte[] v;
org.apache.activemq.leveldb.LevelDBClient v;
org.apache.activemq.leveldb.LevelDBClient$$anonfun$loadObject$1$1 v;
org.iq.leveldb.ReadOptions v;
scala.Option v, v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v := @parameter: byte[];
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.LevelDBClient$RichDB index()>();
v = new org.iq.leveldb.ReadOptions;
specialinvoke v.<org.iq.leveldb.ReadOptions: void <init>()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$RichDB: scala.Option get(byte[],org.iq.leveldb.ReadOptions)>(v, v);
v = new org.apache.activemq.leveldb.LevelDBClient$$anonfun$loadObject$1$1;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anonfun$loadObject$1$1: void <init>(org.apache.activemq.leveldb.LevelDBClient)>(v);
v = virtualinvoke v.<scala.Option: scala.Option map(scala.Function)>(v);
return v;
}
private final void ingorefailure$1(scala.Function)
{
scala.Function v;
org.apache.activemq.leveldb.LevelDBClient v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v := @parameter: scala.Function;
interfaceinvoke v.<scala.Function0: void apply$mcV$sp()>();
return;
}
public void <init>(org.apache.activemq.leveldb.LevelDBStore)
{
org.apache.activemq.leveldb.util.TimeMetric v, v, v;
org.fusesource.hawtdispatch.DispatchQueue v;
java.util.concurrent.locks.ReentrantReadWriteLock v;
org.apache.activemq.leveldb.LevelDBStore v;
org.apache.activemq.leveldb.LevelDBClient v;
org.fusesource.hawtdispatch.package$ v;
scala.collection.mutable.HashMap$ v, v;
scala.collection.GenMap v, v;
scala.collection.immutable.Nil$ v, v;
v := @this: org.apache.activemq.leveldb.LevelDBClient;
v := @parameter: org.apache.activemq.leveldb.LevelDBStore;
v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.LevelDBStore org$apache$activemq$leveldb$LevelDBClient$$store> = v;
specialinvoke v.<java.lang.Object: void <init>()>();
v = <org.fusesource.hawtdispatch.package$: org.fusesource.hawtdispatch.package$ MODULE$>;
v = virtualinvoke v.<org.fusesource.hawtdispatch.package$: org.fusesource.hawtdispatch.DispatchQueue createQueue(java.lang.String)>("leveldb");
v.<org.apache.activemq.leveldb.LevelDBClient: org.fusesource.hawtdispatch.DispatchQueue dispatchQueue> = v;
v = new java.util.concurrent.locks.ReentrantReadWriteLock;
specialinvoke v.<java.util.concurrent.locks.ReentrantReadWriteLock: void <init>(boolean)>(1);
v.<org.apache.activemq.leveldb.LevelDBClient: java.util.concurrent.locks.ReentrantReadWriteLock snapshotRwLock> = v;
v = <scala.collection.mutable.HashMap$: scala.collection.mutable.HashMap$ MODULE$>;
v = <scala.collection.immutable.Nil$: scala.collection.immutable.Nil$ MODULE$>;
v = virtualinvoke v.<scala.collection.mutable.HashMap$: scala.collection.GenMap apply(scala.collection.Seq)>(v);
v.<org.apache.activemq.leveldb.LevelDBClient: scala.collection.mutable.HashMap logRefs> = v;
v = <scala.collection.mutable.HashMap$: scala.collection.mutable.HashMap$ MODULE$>;
v = <scala.collection.immutable.Nil$: scala.collection.immutable.Nil$ MODULE$>;
v = virtualinvoke v.<scala.collection.mutable.HashMap$: scala.collection.GenMap apply(scala.collection.Seq)>(v);
v.<org.apache.activemq.leveldb.LevelDBClient: scala.collection.mutable.HashMap collectionMeta> = v;
v.<org.apache.activemq.leveldb.LevelDBClient: org.iq.leveldb.WriteBatch replay_write_batch> = null;
v.<org.apache.activemq.leveldb.LevelDBClient: long indexRecoveryPosition> = 0L;
v.<org.apache.activemq.leveldb.LevelDBClient: long stored_wal_append_position> = 0L;
v = new org.apache.activemq.leveldb.util.TimeMetric;
specialinvoke v.<org.apache.activemq.leveldb.util.TimeMetric: void <init>()>();
v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.util.TimeMetric max_write_message_latency> = v;
v = new org.apache.activemq.leveldb.util.TimeMetric;
specialinvoke v.<org.apache.activemq.leveldb.util.TimeMetric: void <init>()>();
v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.util.TimeMetric max_write_enqueue_latency> = v;
v = new org.apache.activemq.leveldb.util.TimeMetric;
specialinvoke v.<org.apache.activemq.leveldb.util.TimeMetric: void <init>()>();
v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.util.TimeMetric max_index_write_latency> = v;
return;
}
}