public final class org.apache.activemq.leveldb.LevelDBClient$ extends java.lang.Object implements org.apache.activemq.leveldb.util.Log
{
public static final org.apache.activemq.leveldb.LevelDBClient$ MODULE$;
private final java.lang.String STORE_SCHEMA_PREFIX;
private final int STORE_SCHEMA_VERSION;
private final long THREAD_POOL_STACK_SIZE;
private final java.util.concurrent.ThreadPoolExecutor THREAD_POOL;
private final org.iq.leveldb.WriteOptions PLIST_WRITE_OPTIONS;
private final byte[] DIRTY_INDEX_KEY;
private final byte[] LOG_REF_INDEX_KEY;
private final byte[] LOGS_INDEX_KEY;
private final byte[] PRODUCER_IDS_INDEX_KEY;
private final byte[] COLLECTION_META_KEY;
private final byte[] TRUE;
private final byte[] FALSE;
private final org.fusesource.hawtbuf.AsciiBuffer ACK_POSITION;
private final byte COLLECTION_PREFIX;
private final byte[] COLLECTION_PREFIX_ARRAY;
private final byte ENTRY_PREFIX;
private final byte[] ENTRY_PREFIX_ARRAY;
private final byte LOG_ADD_COLLECTION;
private final byte LOG_REMOVE_COLLECTION;
private final byte LOG_ADD_ENTRY;
private final byte LOG_REMOVE_ENTRY;
private final byte LOG_DATA;
private final byte LOG_TRACE;
private final byte LOG_UPDATE_ENTRY;
private final java.lang.String LOG_SUFFIX;
private final java.lang.String INDEX_SUFFIX;
private final org.slf4j.Logger log;
public static void <clinit>()
{
org.apache.activemq.leveldb.LevelDBClient$ v;
v = new org.apache.activemq.leveldb.LevelDBClient$;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: void <init>()>();
return;
}
public org.slf4j.Logger log()
{
org.slf4j.Logger v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @this: org.apache.activemq.leveldb.LevelDBClient$;
v = v.<org.apache.activemq.leveldb.LevelDBClient$: org.slf4j.Logger log>;
return v;
}
public void org$apache$activemq$leveldb$util$Log$_setter_$log_$eq(org.slf4j.Logger)
{
org.slf4j.Logger v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @this: org.apache.activemq.leveldb.LevelDBClient$;
v := @parameter: org.slf4j.Logger;
v.<org.apache.activemq.leveldb.LevelDBClient$: org.slf4j.Logger log> = v;
return;
}
public void error(scala.Function, scala.collection.Seq)
{
scala.Function v;
org.apache.activemq.leveldb.LevelDBClient$ v;
scala.collection.Seq v;
v := @this: org.apache.activemq.leveldb.LevelDBClient$;
v := @parameter: scala.Function;
v := @parameter: scala.collection.Seq;
staticinvoke <org.apache.activemq.leveldb.util.Log$class: void error(org.apache.activemq.leveldb.util.Log,scala.Function,scala.collection.Seq)>(v, v, v);
return;
}
public 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 := @this: org.apache.activemq.leveldb.LevelDBClient$;
v := @parameter: java.lang.Throwable;
v := @parameter: scala.Function;
v := @parameter: scala.collection.Seq;
staticinvoke <org.apache.activemq.leveldb.util.Log$class: void error(org.apache.activemq.leveldb.util.Log,java.lang.Throwable,scala.Function,scala.collection.Seq)>(v, v, v, v);
return;
}
public void error(java.lang.Throwable)
{
java.lang.Throwable v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @this: org.apache.activemq.leveldb.LevelDBClient$;
v := @parameter: java.lang.Throwable;
staticinvoke <org.apache.activemq.leveldb.util.Log$class: void error(org.apache.activemq.leveldb.util.Log,java.lang.Throwable)>(v, v);
return;
}
public void warn(scala.Function, scala.collection.Seq)
{
scala.Function v;
org.apache.activemq.leveldb.LevelDBClient$ v;
scala.collection.Seq v;
v := @this: org.apache.activemq.leveldb.LevelDBClient$;
v := @parameter: scala.Function;
v := @parameter: scala.collection.Seq;
staticinvoke <org.apache.activemq.leveldb.util.Log$class: void warn(org.apache.activemq.leveldb.util.Log,scala.Function,scala.collection.Seq)>(v, v, v);
return;
}
public 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 := @this: org.apache.activemq.leveldb.LevelDBClient$;
v := @parameter: java.lang.Throwable;
v := @parameter: scala.Function;
v := @parameter: scala.collection.Seq;
staticinvoke <org.apache.activemq.leveldb.util.Log$class: void warn(org.apache.activemq.leveldb.util.Log,java.lang.Throwable,scala.Function,scala.collection.Seq)>(v, v, v, v);
return;
}
public void warn(java.lang.Throwable)
{
java.lang.Throwable v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @this: org.apache.activemq.leveldb.LevelDBClient$;
v := @parameter: java.lang.Throwable;
staticinvoke <org.apache.activemq.leveldb.util.Log$class: void warn(org.apache.activemq.leveldb.util.Log,java.lang.Throwable)>(v, v);
return;
}
public void info(scala.Function, scala.collection.Seq)
{
scala.Function v;
org.apache.activemq.leveldb.LevelDBClient$ v;
scala.collection.Seq v;
v := @this: org.apache.activemq.leveldb.LevelDBClient$;
v := @parameter: scala.Function;
v := @parameter: scala.collection.Seq;
staticinvoke <org.apache.activemq.leveldb.util.Log$class: void info(org.apache.activemq.leveldb.util.Log,scala.Function,scala.collection.Seq)>(v, v, v);
return;
}
public 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 := @this: org.apache.activemq.leveldb.LevelDBClient$;
v := @parameter: java.lang.Throwable;
v := @parameter: scala.Function;
v := @parameter: scala.collection.Seq;
staticinvoke <org.apache.activemq.leveldb.util.Log$class: void info(org.apache.activemq.leveldb.util.Log,java.lang.Throwable,scala.Function,scala.collection.Seq)>(v, v, v, v);
return;
}
public void info(java.lang.Throwable)
{
java.lang.Throwable v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @this: org.apache.activemq.leveldb.LevelDBClient$;
v := @parameter: java.lang.Throwable;
staticinvoke <org.apache.activemq.leveldb.util.Log$class: void info(org.apache.activemq.leveldb.util.Log,java.lang.Throwable)>(v, v);
return;
}
public void debug(scala.Function, scala.collection.Seq)
{
scala.Function v;
org.apache.activemq.leveldb.LevelDBClient$ v;
scala.collection.Seq v;
v := @this: org.apache.activemq.leveldb.LevelDBClient$;
v := @parameter: scala.Function;
v := @parameter: scala.collection.Seq;
staticinvoke <org.apache.activemq.leveldb.util.Log$class: void debug(org.apache.activemq.leveldb.util.Log,scala.Function,scala.collection.Seq)>(v, v, v);
return;
}
public 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 := @this: org.apache.activemq.leveldb.LevelDBClient$;
v := @parameter: java.lang.Throwable;
v := @parameter: scala.Function;
v := @parameter: scala.collection.Seq;
staticinvoke <org.apache.activemq.leveldb.util.Log$class: void debug(org.apache.activemq.leveldb.util.Log,java.lang.Throwable,scala.Function,scala.collection.Seq)>(v, v, v, v);
return;
}
public void debug(java.lang.Throwable)
{
java.lang.Throwable v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @this: org.apache.activemq.leveldb.LevelDBClient$;
v := @parameter: java.lang.Throwable;
staticinvoke <org.apache.activemq.leveldb.util.Log$class: void debug(org.apache.activemq.leveldb.util.Log,java.lang.Throwable)>(v, v);
return;
}
public void trace(scala.Function, scala.collection.Seq)
{
scala.Function v;
org.apache.activemq.leveldb.LevelDBClient$ v;
scala.collection.Seq v;
v := @this: org.apache.activemq.leveldb.LevelDBClient$;
v := @parameter: scala.Function;
v := @parameter: scala.collection.Seq;
staticinvoke <org.apache.activemq.leveldb.util.Log$class: void trace(org.apache.activemq.leveldb.util.Log,scala.Function,scala.collection.Seq)>(v, v, v);
return;
}
public 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 := @this: org.apache.activemq.leveldb.LevelDBClient$;
v := @parameter: java.lang.Throwable;
v := @parameter: scala.Function;
v := @parameter: scala.collection.Seq;
staticinvoke <org.apache.activemq.leveldb.util.Log$class: void trace(org.apache.activemq.leveldb.util.Log,java.lang.Throwable,scala.Function,scala.collection.Seq)>(v, v, v, v);
return;
}
public void trace(java.lang.Throwable)
{
java.lang.Throwable v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @this: org.apache.activemq.leveldb.LevelDBClient$;
v := @parameter: java.lang.Throwable;
staticinvoke <org.apache.activemq.leveldb.util.Log$class: void trace(org.apache.activemq.leveldb.util.Log,java.lang.Throwable)>(v, v);
return;
}
public final java.lang.String STORE_SCHEMA_PREFIX()
{
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @this: org.apache.activemq.leveldb.LevelDBClient$;
return "activemq_leveldb_store:";
}
public final int STORE_SCHEMA_VERSION()
{
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @this: org.apache.activemq.leveldb.LevelDBClient$;
return 1;
}
public final long THREAD_POOL_STACK_SIZE()
{
long v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @this: org.apache.activemq.leveldb.LevelDBClient$;
v = v.<org.apache.activemq.leveldb.LevelDBClient$: long THREAD_POOL_STACK_SIZE>;
return v;
}
public final java.util.concurrent.ThreadPoolExecutor THREAD_POOL()
{
java.util.concurrent.ThreadPoolExecutor v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @this: org.apache.activemq.leveldb.LevelDBClient$;
v = v.<org.apache.activemq.leveldb.LevelDBClient$: java.util.concurrent.ThreadPoolExecutor THREAD_POOL>;
return v;
}
public org.iq.leveldb.WriteOptions PLIST_WRITE_OPTIONS()
{
org.iq.leveldb.WriteOptions v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @this: org.apache.activemq.leveldb.LevelDBClient$;
v = v.<org.apache.activemq.leveldb.LevelDBClient$: org.iq.leveldb.WriteOptions PLIST_WRITE_OPTIONS>;
return v;
}
public final byte[] DIRTY_INDEX_KEY()
{
byte[] v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @this: org.apache.activemq.leveldb.LevelDBClient$;
v = v.<org.apache.activemq.leveldb.LevelDBClient$: byte[] DIRTY_INDEX_KEY>;
return v;
}
public final byte[] LOG_REF_INDEX_KEY()
{
byte[] v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @this: org.apache.activemq.leveldb.LevelDBClient$;
v = v.<org.apache.activemq.leveldb.LevelDBClient$: byte[] LOG_REF_INDEX_KEY>;
return v;
}
public final byte[] LOGS_INDEX_KEY()
{
byte[] v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @this: org.apache.activemq.leveldb.LevelDBClient$;
v = v.<org.apache.activemq.leveldb.LevelDBClient$: byte[] LOGS_INDEX_KEY>;
return v;
}
public final byte[] PRODUCER_IDS_INDEX_KEY()
{
byte[] v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @this: org.apache.activemq.leveldb.LevelDBClient$;
v = v.<org.apache.activemq.leveldb.LevelDBClient$: byte[] PRODUCER_IDS_INDEX_KEY>;
return v;
}
public final byte[] COLLECTION_META_KEY()
{
byte[] v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @this: org.apache.activemq.leveldb.LevelDBClient$;
v = v.<org.apache.activemq.leveldb.LevelDBClient$: byte[] COLLECTION_META_KEY>;
return v;
}
public final byte[] TRUE()
{
byte[] v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @this: org.apache.activemq.leveldb.LevelDBClient$;
v = v.<org.apache.activemq.leveldb.LevelDBClient$: byte[] TRUE>;
return v;
}
public final byte[] FALSE()
{
byte[] v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @this: org.apache.activemq.leveldb.LevelDBClient$;
v = v.<org.apache.activemq.leveldb.LevelDBClient$: byte[] FALSE>;
return v;
}
public final org.fusesource.hawtbuf.AsciiBuffer ACK_POSITION()
{
org.fusesource.hawtbuf.AsciiBuffer v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @this: org.apache.activemq.leveldb.LevelDBClient$;
v = v.<org.apache.activemq.leveldb.LevelDBClient$: org.fusesource.hawtbuf.AsciiBuffer ACK_POSITION>;
return v;
}
public final byte COLLECTION_PREFIX()
{
byte v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @this: org.apache.activemq.leveldb.LevelDBClient$;
v = v.<org.apache.activemq.leveldb.LevelDBClient$: byte COLLECTION_PREFIX>;
return v;
}
public final byte[] COLLECTION_PREFIX_ARRAY()
{
byte[] v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @this: org.apache.activemq.leveldb.LevelDBClient$;
v = v.<org.apache.activemq.leveldb.LevelDBClient$: byte[] COLLECTION_PREFIX_ARRAY>;
return v;
}
public final byte ENTRY_PREFIX()
{
byte v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @this: org.apache.activemq.leveldb.LevelDBClient$;
v = v.<org.apache.activemq.leveldb.LevelDBClient$: byte ENTRY_PREFIX>;
return v;
}
public final byte[] ENTRY_PREFIX_ARRAY()
{
byte[] v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @this: org.apache.activemq.leveldb.LevelDBClient$;
v = v.<org.apache.activemq.leveldb.LevelDBClient$: byte[] ENTRY_PREFIX_ARRAY>;
return v;
}
public final byte LOG_ADD_COLLECTION()
{
byte v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @this: org.apache.activemq.leveldb.LevelDBClient$;
v = v.<org.apache.activemq.leveldb.LevelDBClient$: byte LOG_ADD_COLLECTION>;
return v;
}
public final byte LOG_REMOVE_COLLECTION()
{
byte v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @this: org.apache.activemq.leveldb.LevelDBClient$;
v = v.<org.apache.activemq.leveldb.LevelDBClient$: byte LOG_REMOVE_COLLECTION>;
return v;
}
public final byte LOG_ADD_ENTRY()
{
byte v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @this: org.apache.activemq.leveldb.LevelDBClient$;
v = v.<org.apache.activemq.leveldb.LevelDBClient$: byte LOG_ADD_ENTRY>;
return v;
}
public final byte LOG_REMOVE_ENTRY()
{
byte v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @this: org.apache.activemq.leveldb.LevelDBClient$;
v = v.<org.apache.activemq.leveldb.LevelDBClient$: byte LOG_REMOVE_ENTRY>;
return v;
}
public final byte LOG_DATA()
{
byte v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @this: org.apache.activemq.leveldb.LevelDBClient$;
v = v.<org.apache.activemq.leveldb.LevelDBClient$: byte LOG_DATA>;
return v;
}
public final byte LOG_TRACE()
{
byte v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @this: org.apache.activemq.leveldb.LevelDBClient$;
v = v.<org.apache.activemq.leveldb.LevelDBClient$: byte LOG_TRACE>;
return v;
}
public final byte LOG_UPDATE_ENTRY()
{
byte v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @this: org.apache.activemq.leveldb.LevelDBClient$;
v = v.<org.apache.activemq.leveldb.LevelDBClient$: byte LOG_UPDATE_ENTRY>;
return v;
}
public final java.lang.String LOG_SUFFIX()
{
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @this: org.apache.activemq.leveldb.LevelDBClient$;
return ".log";
}
public final java.lang.String INDEX_SUFFIX()
{
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @this: org.apache.activemq.leveldb.LevelDBClient$;
return ".index";
}
public byte[] toByteArray(org.fusesource.hawtbuf.Buffer)
{
byte[] v;
org.fusesource.hawtbuf.Buffer v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @this: org.apache.activemq.leveldb.LevelDBClient$;
v := @parameter: org.fusesource.hawtbuf.Buffer;
v = virtualinvoke v.<org.fusesource.hawtbuf.Buffer: byte[] toByteArray()>();
return v;
}
public org.fusesource.hawtbuf.Buffer toBuffer(byte[])
{
byte[] v;
org.fusesource.hawtbuf.Buffer v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @this: org.apache.activemq.leveldb.LevelDBClient$;
v := @parameter: byte[];
v = new org.fusesource.hawtbuf.Buffer;
specialinvoke v.<org.fusesource.hawtbuf.Buffer: void <init>(byte[])>(v);
return v;
}
public 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 := @this: org.apache.activemq.leveldb.LevelDBClient$;
v := @parameter: org.apache.activemq.leveldb.record.CollectionRecord$Buffer;
v = virtualinvoke v.<org.apache.activemq.leveldb.record.CollectionRecord$Buffer: byte[] toUnframedByteArray()>();
return v;
}
public org.apache.activemq.leveldb.record.CollectionRecord$Buffer decodeCollectionRecord(org.fusesource.hawtbuf.Buffer)
{
org.apache.activemq.leveldb.record.CollectionRecord$Buffer v;
org.apache.activemq.leveldb.record.CollectionRecord v;
org.fusesource.hawtbuf.Buffer v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @this: org.apache.activemq.leveldb.LevelDBClient$;
v := @parameter: org.fusesource.hawtbuf.Buffer;
v = <org.apache.activemq.leveldb.record.CollectionRecord: org.apache.activemq.leveldb.record.CollectionRecord FACTORY>;
v = virtualinvoke v.<org.apache.activemq.leveldb.record.CollectionRecord: org.apache.activemq.leveldb.record.CollectionRecord$Buffer parseUnframed(org.fusesource.hawtbuf.Buffer)>(v);
return v;
}
public 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 := @this: org.apache.activemq.leveldb.LevelDBClient$;
v := @parameter: org.apache.activemq.leveldb.record.CollectionKey$Buffer;
v = virtualinvoke v.<org.apache.activemq.leveldb.record.CollectionKey$Buffer: byte[] toUnframedByteArray()>();
return v;
}
public org.apache.activemq.leveldb.record.CollectionKey$Buffer decodeCollectionKeyRecord(org.fusesource.hawtbuf.Buffer)
{
org.apache.activemq.leveldb.record.CollectionKey$Buffer v;
org.apache.activemq.leveldb.record.CollectionKey v;
org.fusesource.hawtbuf.Buffer v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @this: org.apache.activemq.leveldb.LevelDBClient$;
v := @parameter: org.fusesource.hawtbuf.Buffer;
v = <org.apache.activemq.leveldb.record.CollectionKey: org.apache.activemq.leveldb.record.CollectionKey FACTORY>;
v = virtualinvoke v.<org.apache.activemq.leveldb.record.CollectionKey: org.apache.activemq.leveldb.record.CollectionKey$Buffer parseUnframed(org.fusesource.hawtbuf.Buffer)>(v);
return v;
}
public 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 := @this: org.apache.activemq.leveldb.LevelDBClient$;
v := @parameter: org.apache.activemq.leveldb.record.EntryRecord$Buffer;
v = virtualinvoke v.<org.apache.activemq.leveldb.record.EntryRecord$Buffer: org.fusesource.hawtbuf.Buffer toUnframedBuffer()>();
return v;
}
public 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.record.EntryRecord v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @this: org.apache.activemq.leveldb.LevelDBClient$;
v := @parameter: org.fusesource.hawtbuf.Buffer;
v = <org.apache.activemq.leveldb.record.EntryRecord: org.apache.activemq.leveldb.record.EntryRecord FACTORY>;
v = virtualinvoke v.<org.apache.activemq.leveldb.record.EntryRecord: org.apache.activemq.leveldb.record.EntryRecord$Buffer parseUnframed(org.fusesource.hawtbuf.Buffer)>(v);
return v;
}
public 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 := @this: org.apache.activemq.leveldb.LevelDBClient$;
v := @parameter: org.apache.activemq.leveldb.record.EntryKey$Buffer;
v = virtualinvoke v.<org.apache.activemq.leveldb.record.EntryKey$Buffer: byte[] toUnframedByteArray()>();
return v;
}
public org.apache.activemq.leveldb.record.EntryKey$Buffer decodeEntryKeyRecord(org.fusesource.hawtbuf.Buffer)
{
org.apache.activemq.leveldb.record.EntryKey v;
org.apache.activemq.leveldb.record.EntryKey$Buffer v;
org.fusesource.hawtbuf.Buffer v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @this: org.apache.activemq.leveldb.LevelDBClient$;
v := @parameter: org.fusesource.hawtbuf.Buffer;
v = <org.apache.activemq.leveldb.record.EntryKey: org.apache.activemq.leveldb.record.EntryKey FACTORY>;
v = virtualinvoke v.<org.apache.activemq.leveldb.record.EntryKey: org.apache.activemq.leveldb.record.EntryKey$Buffer parseUnframed(org.fusesource.hawtbuf.Buffer)>(v);
return v;
}
public byte[] encodeLocator(long, int)
{
byte[] v;
org.fusesource.hawtbuf.DataByteArrayOutputStream v;
long v;
int v, v, v, v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @this: org.apache.activemq.leveldb.LevelDBClient$;
v := @parameter: long;
v := @parameter: int;
v = new org.fusesource.hawtbuf.DataByteArrayOutputStream;
v = staticinvoke <org.fusesource.hawtbuf.AbstractVarIntSupport: int computeVarLongSize(long)>(v);
v = staticinvoke <org.fusesource.hawtbuf.AbstractVarIntSupport: int computeVarIntSize(int)>(v);
v = v + v;
specialinvoke v.<org.fusesource.hawtbuf.DataByteArrayOutputStream: void <init>(int)>(v);
virtualinvoke v.<org.fusesource.hawtbuf.DataByteArrayOutputStream: void writeVarLong(long)>(v);
virtualinvoke v.<org.fusesource.hawtbuf.DataByteArrayOutputStream: void writeVarInt(int)>(v);
v = virtualinvoke v.<org.fusesource.hawtbuf.DataByteArrayOutputStream: byte[] getData()>();
return v;
}
public scala.Tuple decodeLocator(org.fusesource.hawtbuf.Buffer)
{
org.fusesource.hawtbuf.DataByteArrayInputStream v;
int v;
scala.Tuple2$mcJI$sp v;
long v;
org.fusesource.hawtbuf.Buffer v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @this: org.apache.activemq.leveldb.LevelDBClient$;
v := @parameter: org.fusesource.hawtbuf.Buffer;
v = new org.fusesource.hawtbuf.DataByteArrayInputStream;
specialinvoke v.<org.fusesource.hawtbuf.DataByteArrayInputStream: void <init>(org.fusesource.hawtbuf.Buffer)>(v);
v = new scala.Tuple2$mcJI$sp;
v = virtualinvoke v.<org.fusesource.hawtbuf.DataByteArrayInputStream: long readVarLong()>();
v = virtualinvoke v.<org.fusesource.hawtbuf.DataByteArrayInputStream: int readVarInt()>();
specialinvoke v.<scala.Tuple2$mcJI$sp: void <init>(long,int)>(v, v);
return v;
}
public scala.Tuple decodeLocator(byte[])
{
byte[] v;
org.fusesource.hawtbuf.DataByteArrayInputStream v;
int v;
scala.Tuple2$mcJI$sp v;
long v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @this: org.apache.activemq.leveldb.LevelDBClient$;
v := @parameter: byte[];
v = new org.fusesource.hawtbuf.DataByteArrayInputStream;
specialinvoke v.<org.fusesource.hawtbuf.DataByteArrayInputStream: void <init>(byte[])>(v);
v = new scala.Tuple2$mcJI$sp;
v = virtualinvoke v.<org.fusesource.hawtbuf.DataByteArrayInputStream: long readVarLong()>();
v = virtualinvoke v.<org.fusesource.hawtbuf.DataByteArrayInputStream: int readVarInt()>();
specialinvoke v.<scala.Tuple2$mcJI$sp: void <init>(long,int)>(v, v);
return v;
}
public org.fusesource.hawtbuf.Buffer encodeLongLong(long, long)
{
org.fusesource.hawtbuf.DataByteArrayOutputStream v;
long v, v;
org.fusesource.hawtbuf.Buffer v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @this: org.apache.activemq.leveldb.LevelDBClient$;
v := @parameter: long;
v := @parameter: long;
v = new org.fusesource.hawtbuf.DataByteArrayOutputStream;
specialinvoke v.<org.fusesource.hawtbuf.DataByteArrayOutputStream: void <init>(int)>(8);
virtualinvoke v.<org.fusesource.hawtbuf.DataByteArrayOutputStream: void writeLong(long)>(v);
virtualinvoke v.<org.fusesource.hawtbuf.DataByteArrayOutputStream: void writeLong(long)>(v);
v = virtualinvoke v.<org.fusesource.hawtbuf.DataByteArrayOutputStream: org.fusesource.hawtbuf.Buffer toBuffer()>();
return v;
}
public scala.Tuple decodeLongLong(byte[])
{
byte[] v;
org.fusesource.hawtbuf.DataByteArrayInputStream v;
long v, v;
scala.Tuple2$mcJJ$sp v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @this: org.apache.activemq.leveldb.LevelDBClient$;
v := @parameter: byte[];
v = new org.fusesource.hawtbuf.DataByteArrayInputStream;
specialinvoke v.<org.fusesource.hawtbuf.DataByteArrayInputStream: void <init>(byte[])>(v);
v = new scala.Tuple2$mcJJ$sp;
v = virtualinvoke v.<org.fusesource.hawtbuf.DataByteArrayInputStream: long readLong()>();
v = virtualinvoke v.<org.fusesource.hawtbuf.DataByteArrayInputStream: long readLong()>();
specialinvoke v.<scala.Tuple2$mcJJ$sp: void <init>(long,long)>(v, v);
return v;
}
public org.fusesource.hawtbuf.Buffer encodeLong(long)
{
org.fusesource.hawtbuf.DataByteArrayOutputStream v;
long v;
org.fusesource.hawtbuf.Buffer v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @this: org.apache.activemq.leveldb.LevelDBClient$;
v := @parameter: long;
v = new org.fusesource.hawtbuf.DataByteArrayOutputStream;
specialinvoke v.<org.fusesource.hawtbuf.DataByteArrayOutputStream: void <init>(int)>(8);
virtualinvoke v.<org.fusesource.hawtbuf.DataByteArrayOutputStream: void writeLong(long)>(v);
v = virtualinvoke v.<org.fusesource.hawtbuf.DataByteArrayOutputStream: org.fusesource.hawtbuf.Buffer toBuffer()>();
return v;
}
public byte[] encodeVLong(long)
{
byte[] v;
org.fusesource.hawtbuf.DataByteArrayOutputStream v;
int v;
long v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @this: org.apache.activemq.leveldb.LevelDBClient$;
v := @parameter: long;
v = new org.fusesource.hawtbuf.DataByteArrayOutputStream;
v = staticinvoke <org.fusesource.hawtbuf.AbstractVarIntSupport: int computeVarLongSize(long)>(v);
specialinvoke v.<org.fusesource.hawtbuf.DataByteArrayOutputStream: void <init>(int)>(v);
virtualinvoke v.<org.fusesource.hawtbuf.DataByteArrayOutputStream: void writeVarLong(long)>(v);
v = virtualinvoke v.<org.fusesource.hawtbuf.DataByteArrayOutputStream: byte[] getData()>();
return v;
}
public long decodeVLong(byte[])
{
byte[] v;
org.fusesource.hawtbuf.DataByteArrayInputStream v;
long v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @this: org.apache.activemq.leveldb.LevelDBClient$;
v := @parameter: byte[];
v = new org.fusesource.hawtbuf.DataByteArrayInputStream;
specialinvoke v.<org.fusesource.hawtbuf.DataByteArrayInputStream: void <init>(byte[])>(v);
v = virtualinvoke v.<org.fusesource.hawtbuf.DataByteArrayInputStream: long readVarLong()>();
return v;
}
public byte[] encodeLongKey(byte, long)
{
byte[] v;
byte v;
org.fusesource.hawtbuf.DataByteArrayOutputStream v;
long v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @this: org.apache.activemq.leveldb.LevelDBClient$;
v := @parameter: byte;
v := @parameter: long;
v = new org.fusesource.hawtbuf.DataByteArrayOutputStream;
specialinvoke v.<org.fusesource.hawtbuf.DataByteArrayOutputStream: void <init>(int)>(9);
virtualinvoke v.<org.fusesource.hawtbuf.DataByteArrayOutputStream: void writeByte(int)>(v);
virtualinvoke v.<org.fusesource.hawtbuf.DataByteArrayOutputStream: void writeLong(long)>(v);
v = virtualinvoke v.<org.fusesource.hawtbuf.DataByteArrayOutputStream: byte[] getData()>();
return v;
}
public scala.Tuple decodeLongKey(byte[])
{
byte[] v;
org.fusesource.hawtbuf.DataByteArrayInputStream v;
long v;
scala.Tuple v;
byte v;
java.lang.Long v;
java.lang.Byte v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @this: org.apache.activemq.leveldb.LevelDBClient$;
v := @parameter: byte[];
v = new org.fusesource.hawtbuf.DataByteArrayInputStream;
specialinvoke v.<org.fusesource.hawtbuf.DataByteArrayInputStream: void <init>(byte[])>(v);
v = new scala.Tuple;
v = virtualinvoke v.<org.fusesource.hawtbuf.DataByteArrayInputStream: byte readByte()>();
v = staticinvoke <scala.runtime.BoxesRunTime: java.lang.Byte boxToByte(byte)>(v);
v = virtualinvoke v.<org.fusesource.hawtbuf.DataByteArrayInputStream: long readLong()>();
v = staticinvoke <scala.runtime.BoxesRunTime: java.lang.Long boxToLong(long)>(v);
specialinvoke v.<scala.Tuple2: void <init>(java.lang.Object,java.lang.Object)>(v, v);
return v;
}
public long decodeLong(org.fusesource.hawtbuf.Buffer)
{
org.fusesource.hawtbuf.DataByteArrayInputStream v;
long v;
org.fusesource.hawtbuf.Buffer v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @this: org.apache.activemq.leveldb.LevelDBClient$;
v := @parameter: org.fusesource.hawtbuf.Buffer;
v = new org.fusesource.hawtbuf.DataByteArrayInputStream;
specialinvoke v.<org.fusesource.hawtbuf.DataByteArrayInputStream: void <init>(org.fusesource.hawtbuf.Buffer)>(v);
v = virtualinvoke v.<org.fusesource.hawtbuf.DataByteArrayInputStream: long readLong()>();
return v;
}
public long decodeLong(byte[])
{
byte[] v;
org.fusesource.hawtbuf.DataByteArrayInputStream v;
long v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @this: org.apache.activemq.leveldb.LevelDBClient$;
v := @parameter: byte[];
v = new org.fusesource.hawtbuf.DataByteArrayInputStream;
specialinvoke v.<org.fusesource.hawtbuf.DataByteArrayInputStream: void <init>(byte[])>(v);
v = virtualinvoke v.<org.fusesource.hawtbuf.DataByteArrayInputStream: long readLong()>();
return v;
}
public byte[] encodeEntryKey(byte, long, long)
{
byte[] v;
byte v;
org.fusesource.hawtbuf.DataByteArrayOutputStream v;
long v, v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @this: org.apache.activemq.leveldb.LevelDBClient$;
v := @parameter: byte;
v := @parameter: long;
v := @parameter: long;
v = new org.fusesource.hawtbuf.DataByteArrayOutputStream;
specialinvoke v.<org.fusesource.hawtbuf.DataByteArrayOutputStream: void <init>(int)>(17);
virtualinvoke v.<org.fusesource.hawtbuf.DataByteArrayOutputStream: void writeByte(int)>(v);
virtualinvoke v.<org.fusesource.hawtbuf.DataByteArrayOutputStream: void writeLong(long)>(v);
virtualinvoke v.<org.fusesource.hawtbuf.DataByteArrayOutputStream: void writeLong(long)>(v);
v = virtualinvoke v.<org.fusesource.hawtbuf.DataByteArrayOutputStream: byte[] getData()>();
return v;
}
public byte[] encodeEntryKey(byte, long, org.fusesource.hawtbuf.Buffer)
{
byte[] v;
org.fusesource.hawtbuf.DataByteArrayOutputStream v;
long v;
org.fusesource.hawtbuf.Buffer v;
byte v;
int v, v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @this: org.apache.activemq.leveldb.LevelDBClient$;
v := @parameter: byte;
v := @parameter: long;
v := @parameter: org.fusesource.hawtbuf.Buffer;
v = new org.fusesource.hawtbuf.DataByteArrayOutputStream;
v = v.<org.fusesource.hawtbuf.Buffer: int length>;
v = 9 + v;
specialinvoke v.<org.fusesource.hawtbuf.DataByteArrayOutputStream: void <init>(int)>(v);
virtualinvoke v.<org.fusesource.hawtbuf.DataByteArrayOutputStream: void writeByte(int)>(v);
virtualinvoke v.<org.fusesource.hawtbuf.DataByteArrayOutputStream: void writeLong(long)>(v);
virtualinvoke v.<org.fusesource.hawtbuf.DataByteArrayOutputStream: void write(org.fusesource.hawtbuf.Buffer)>(v);
v = virtualinvoke v.<org.fusesource.hawtbuf.DataByteArrayOutputStream: byte[] getData()>();
return v;
}
public scala.Tuple decodeEntryKey(byte[])
{
byte[] v;
org.fusesource.hawtbuf.DataByteArrayInputStream v;
long v;
org.fusesource.hawtbuf.Buffer v;
scala.Tuple v;
byte v;
java.lang.Long v;
int v;
java.lang.Byte v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @this: org.apache.activemq.leveldb.LevelDBClient$;
v := @parameter: byte[];
v = new org.fusesource.hawtbuf.DataByteArrayInputStream;
specialinvoke v.<org.fusesource.hawtbuf.DataByteArrayInputStream: void <init>(byte[])>(v);
v = new scala.Tuple;
v = virtualinvoke v.<org.fusesource.hawtbuf.DataByteArrayInputStream: byte readByte()>();
v = staticinvoke <scala.runtime.BoxesRunTime: java.lang.Byte boxToByte(byte)>(v);
v = virtualinvoke v.<org.fusesource.hawtbuf.DataByteArrayInputStream: long readLong()>();
v = staticinvoke <scala.runtime.BoxesRunTime: java.lang.Long boxToLong(long)>(v);
v = virtualinvoke v.<org.fusesource.hawtbuf.DataByteArrayInputStream: int available()>();
v = virtualinvoke v.<org.fusesource.hawtbuf.DataByteArrayInputStream: org.fusesource.hawtbuf.Buffer readBuffer(int)>(v);
specialinvoke v.<scala.Tuple3: void <init>(java.lang.Object,java.lang.Object,java.lang.Object)>(v, v, v);
return v;
}
public byte[] bytes(java.lang.String)
{
byte[] v;
java.lang.String v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @this: org.apache.activemq.leveldb.LevelDBClient$;
v := @parameter: java.lang.String;
v = virtualinvoke v.<java.lang.String: byte[] getBytes(java.lang.String)>("UTF-8");
return v;
}
public java.io.File create_sequence_file(java.io.File, long, java.lang.String)
{
scala.collection.mutable.WrappedArray v;
java.lang.Object[] v;
long v;
java.io.File v, v;
java.lang.Long v;
scala.Predef$ v, v;
java.lang.String v, v, v;
org.apache.activemq.leveldb.util.FileSupport$ v;
org.apache.activemq.leveldb.util.FileSupport$RichFile v;
scala.collection.immutable.StringOps v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @this: org.apache.activemq.leveldb.LevelDBClient$;
v := @parameter: java.io.File;
v := @parameter: long;
v := @parameter: java.lang.String;
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.immutable.StringOps;
v = <scala.Predef$: scala.Predef$ MODULE$>;
v = virtualinvoke v.<scala.Predef$: java.lang.String augmentString(java.lang.String)>("%016x%s");
specialinvoke v.<scala.collection.immutable.StringOps: void <init>(java.lang.String)>(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[1] = v;
v = virtualinvoke v.<scala.Predef$: scala.collection.mutable.WrappedArray genericWrapArray(java.lang.Object)>(v);
v = virtualinvoke v.<scala.collection.immutable.StringOps: java.lang.String format(scala.collection.Seq)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.util.FileSupport$RichFile: java.io.File $div(java.lang.String)>(v);
return v;
}
public scala.collection.immutable.TreeMap find_sequence_files(java.io.File, java.lang.String)
{
scala.reflect.ClassTag v;
org.apache.activemq.leveldb.LevelDBClient$$anonfun$find_sequence_files$1 v;
scala.Predef$ v, v;
scala.collection.SortedMap v;
scala.collection.mutable.ArrayOps v;
java.lang.String v;
org.apache.activemq.leveldb.util.FileSupport$ v;
org.apache.activemq.leveldb.util.FileSupport$RichFile v;
scala.collection.mutable.WrappedArray v;
scala.reflect.ClassTag$ v;
java.io.File v;
java.lang.Object v;
scala.Array$ v;
scala.collection.generic.CanBuildFrom v;
scala.math.Ordering$Long$ v;
java.io.File[] v;
scala.collection.immutable.TreeMap$ v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @this: org.apache.activemq.leveldb.LevelDBClient$;
v := @parameter: java.io.File;
v := @parameter: java.lang.String;
v = <scala.collection.immutable.TreeMap$: scala.collection.immutable.TreeMap$ MODULE$>;
v = <scala.Predef$: scala.Predef$ MODULE$>;
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.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$find_sequence_files$1;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anonfun$find_sequence_files$1: void <init>(java.lang.String)>(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 "Lscala/Tuple;");
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.WrappedArray wrapRefArray(java.lang.Object[])>(v);
v = <scala.math.Ordering$Long$: scala.math.Ordering$Long$ MODULE$>;
v = virtualinvoke v.<scala.collection.immutable.TreeMap$: scala.collection.SortedMap apply(scala.collection.Seq,scala.math.Ordering)>(v, v);
return v;
}
public void copyIndex(java.io.File, java.io.File)
{
org.apache.activemq.leveldb.LevelDBClient$$anonfun$copyIndex$1 v;
java.io.File v, v;
scala.Predef$ v;
scala.collection.mutable.ArrayOps v;
org.apache.activemq.leveldb.util.FileSupport$ v;
org.apache.activemq.leveldb.util.FileSupport$RichFile v;
java.io.File[] v;
org.apache.activemq.leveldb.LevelDBClient$ v;
v := @this: org.apache.activemq.leveldb.LevelDBClient$;
v := @parameter: java.io.File;
v := @parameter: java.io.File;
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.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$copyIndex$1;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anonfun$copyIndex$1: void <init>(java.io.File)>(v);
interfaceinvoke v.<scala.collection.mutable.ArrayOps: void foreach(scala.Function)>(v);
return;
}
private void <init>()
{
byte[] v, v, v, v, v, v, v, v, v;
java.lang.Integer v;
byte v, v, v, v, v, v, v, v, v, v, v;
org.apache.activemq.leveldb.LevelDBClient$$anon$1 v;
scala.collection.immutable.StringOps v;
org.apache.activemq.leveldb.LevelDBClient$ v;
long v;
scala.Predef$ v;
java.lang.String v, v, v;
org.iq.leveldb.WriteOptions v, v;
org.fusesource.hawtbuf.AsciiBuffer v;
v := @this: org.apache.activemq.leveldb.LevelDBClient$;
specialinvoke v.<java.lang.Object: void <init>()>();
<org.apache.activemq.leveldb.LevelDBClient$: org.apache.activemq.leveldb.LevelDBClient$ MODULE$> = v;
staticinvoke <org.apache.activemq.leveldb.util.Log$class: void $init$(org.apache.activemq.leveldb.util.Log)>(v);
v = new scala.collection.immutable.StringOps;
v = <scala.Predef$: scala.Predef$ MODULE$>;
v = staticinvoke <scala.runtime.BoxesRunTime: java.lang.Integer boxToInteger(int)>(524288);
v = staticinvoke <java.lang.String: java.lang.String valueOf(java.lang.Object)>(v);
v = staticinvoke <java.lang.System: java.lang.String getProperty(java.lang.String,java.lang.String)>("leveldb.thread.stack.size", v);
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: long toLong()>();
v.<org.apache.activemq.leveldb.LevelDBClient$: long THREAD_POOL_STACK_SIZE> = v;
v = new org.apache.activemq.leveldb.LevelDBClient$$anon$1;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBClient$$anon$1: void <init>()>();
v.<org.apache.activemq.leveldb.LevelDBClient$: java.util.concurrent.ThreadPoolExecutor THREAD_POOL> = v;
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)>(0);
v.<org.apache.activemq.leveldb.LevelDBClient$: org.iq.leveldb.WriteOptions PLIST_WRITE_OPTIONS> = v;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: byte[] bytes(java.lang.String)>(":dirty");
v.<org.apache.activemq.leveldb.LevelDBClient$: byte[] DIRTY_INDEX_KEY> = v;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: byte[] bytes(java.lang.String)>(":log-refs");
v.<org.apache.activemq.leveldb.LevelDBClient$: byte[] LOG_REF_INDEX_KEY> = v;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: byte[] bytes(java.lang.String)>(":logs");
v.<org.apache.activemq.leveldb.LevelDBClient$: byte[] LOGS_INDEX_KEY> = v;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: byte[] bytes(java.lang.String)>(":producer_ids");
v.<org.apache.activemq.leveldb.LevelDBClient$: byte[] PRODUCER_IDS_INDEX_KEY> = v;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: byte[] bytes(java.lang.String)>(":collection-meta");
v.<org.apache.activemq.leveldb.LevelDBClient$: byte[] COLLECTION_META_KEY> = v;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: byte[] bytes(java.lang.String)>("true");
v.<org.apache.activemq.leveldb.LevelDBClient$: byte[] TRUE> = v;
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: byte[] bytes(java.lang.String)>("false");
v.<org.apache.activemq.leveldb.LevelDBClient$: byte[] FALSE> = v;
v = new org.fusesource.hawtbuf.AsciiBuffer;
specialinvoke v.<org.fusesource.hawtbuf.AsciiBuffer: void <init>(java.lang.String)>("p");
v.<org.apache.activemq.leveldb.LevelDBClient$: org.fusesource.hawtbuf.AsciiBuffer ACK_POSITION> = v;
v = (byte) 99;
v.<org.apache.activemq.leveldb.LevelDBClient$: byte COLLECTION_PREFIX> = v;
v = newarray (byte)[1];
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: byte COLLECTION_PREFIX()>();
v[0] = v;
v.<org.apache.activemq.leveldb.LevelDBClient$: byte[] COLLECTION_PREFIX_ARRAY> = v;
v = (byte) 101;
v.<org.apache.activemq.leveldb.LevelDBClient$: byte ENTRY_PREFIX> = v;
v = newarray (byte)[1];
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient$: byte ENTRY_PREFIX()>();
v[0] = v;
v.<org.apache.activemq.leveldb.LevelDBClient$: byte[] ENTRY_PREFIX_ARRAY> = v;
v = (byte) 1;
v.<org.apache.activemq.leveldb.LevelDBClient$: byte LOG_ADD_COLLECTION> = v;
v = (byte) 2;
v.<org.apache.activemq.leveldb.LevelDBClient$: byte LOG_REMOVE_COLLECTION> = v;
v = (byte) 3;
v.<org.apache.activemq.leveldb.LevelDBClient$: byte LOG_ADD_ENTRY> = v;
v = (byte) 4;
v.<org.apache.activemq.leveldb.LevelDBClient$: byte LOG_REMOVE_ENTRY> = v;
v = (byte) 5;
v.<org.apache.activemq.leveldb.LevelDBClient$: byte LOG_DATA> = v;
v = (byte) 6;
v.<org.apache.activemq.leveldb.LevelDBClient$: byte LOG_TRACE> = v;
v = (byte) 7;
v.<org.apache.activemq.leveldb.LevelDBClient$: byte LOG_UPDATE_ENTRY> = v;
return;
}
}