public class org.apache.activemq.leveldb.DBManager extends java.lang.Object
{
private final org.apache.activemq.leveldb.LevelDBStore parent;
private java.util.concurrent.atomic.AtomicLong lastCollectionKey;
private java.util.concurrent.atomic.AtomicLong lastPListKey;
private final org.fusesource.hawtdispatch.DispatchQueue dispatchQueue;
private final java.util.concurrent.atomic.AtomicLong asyncCapacityRemaining;
private long uowEnqueueDelayReqested;
private long uowEnqueueNodelayReqested;
private long uowClosedCounter;
private long uowCanceledCounter;
private long uowStoringCounter;
private long uowStoredCounter;
private final org.apache.activemq.leveldb.util.TimeMetric uow_complete_latency;
private java.util.concurrent.ConcurrentHashMap pendingStores;
private java.util.HashMap cancelable_enqueue_actions;
private final java.util.concurrent.atomic.AtomicInteger lastUowId;
private org.apache.activemq.ActiveMQMessageAuditNoSync producerSequenceIdTracker;
private final java.util.LinkedHashMap flush_queue;
private final org.fusesource.hawtdispatch.CustomDispatchSource flushSource;
private boolean started;
public org.apache.activemq.leveldb.LevelDBStore parent()
{
org.apache.activemq.leveldb.DBManager v;
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.DBManager;
v = v.<org.apache.activemq.leveldb.DBManager: org.apache.activemq.leveldb.LevelDBStore parent>;
return v;
}
public java.util.concurrent.atomic.AtomicLong lastCollectionKey()
{
java.util.concurrent.atomic.AtomicLong v;
org.apache.activemq.leveldb.DBManager v;
v := @this: org.apache.activemq.leveldb.DBManager;
v = v.<org.apache.activemq.leveldb.DBManager: java.util.concurrent.atomic.AtomicLong lastCollectionKey>;
return v;
}
public void lastCollectionKey_$eq(java.util.concurrent.atomic.AtomicLong)
{
java.util.concurrent.atomic.AtomicLong v;
org.apache.activemq.leveldb.DBManager v;
v := @this: org.apache.activemq.leveldb.DBManager;
v := @parameter: java.util.concurrent.atomic.AtomicLong;
v.<org.apache.activemq.leveldb.DBManager: java.util.concurrent.atomic.AtomicLong lastCollectionKey> = v;
return;
}
public java.util.concurrent.atomic.AtomicLong lastPListKey()
{
java.util.concurrent.atomic.AtomicLong v;
org.apache.activemq.leveldb.DBManager v;
v := @this: org.apache.activemq.leveldb.DBManager;
v = v.<org.apache.activemq.leveldb.DBManager: java.util.concurrent.atomic.AtomicLong lastPListKey>;
return v;
}
public void lastPListKey_$eq(java.util.concurrent.atomic.AtomicLong)
{
java.util.concurrent.atomic.AtomicLong v;
org.apache.activemq.leveldb.DBManager v;
v := @this: org.apache.activemq.leveldb.DBManager;
v := @parameter: java.util.concurrent.atomic.AtomicLong;
v.<org.apache.activemq.leveldb.DBManager: java.util.concurrent.atomic.AtomicLong lastPListKey> = v;
return;
}
public org.apache.activemq.leveldb.LevelDBClient client()
{
org.apache.activemq.leveldb.DBManager v;
org.apache.activemq.leveldb.LevelDBClient v;
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.DBManager;
v = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: org.apache.activemq.leveldb.LevelDBStore parent()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.leveldb.LevelDBClient client()>();
return v;
}
public java.util.concurrent.ExecutorService writeExecutor()
{
org.apache.activemq.leveldb.DBManager v;
org.apache.activemq.leveldb.LevelDBClient v;
java.util.concurrent.ExecutorService v;
v := @this: org.apache.activemq.leveldb.DBManager;
v = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: org.apache.activemq.leveldb.LevelDBClient client()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: java.util.concurrent.ExecutorService writeExecutor()>();
return v;
}
public int flushDelay()
{
int v;
org.apache.activemq.leveldb.DBManager v;
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.DBManager;
v = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: org.apache.activemq.leveldb.LevelDBStore parent()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: int flushDelay()>();
return v;
}
public org.fusesource.hawtdispatch.DispatchQueue dispatchQueue()
{
org.apache.activemq.leveldb.DBManager v;
org.fusesource.hawtdispatch.DispatchQueue v;
v := @this: org.apache.activemq.leveldb.DBManager;
v = v.<org.apache.activemq.leveldb.DBManager: org.fusesource.hawtdispatch.DispatchQueue dispatchQueue>;
return v;
}
public java.util.concurrent.atomic.AtomicLong asyncCapacityRemaining()
{
java.util.concurrent.atomic.AtomicLong v;
org.apache.activemq.leveldb.DBManager v;
v := @this: org.apache.activemq.leveldb.DBManager;
v = v.<org.apache.activemq.leveldb.DBManager: java.util.concurrent.atomic.AtomicLong asyncCapacityRemaining>;
return v;
}
public org.apache.activemq.leveldb.DelayableUOW createUow()
{
org.apache.activemq.leveldb.DBManager v;
org.apache.activemq.leveldb.DelayableUOW v;
v := @this: org.apache.activemq.leveldb.DBManager;
v = new org.apache.activemq.leveldb.DelayableUOW;
specialinvoke v.<org.apache.activemq.leveldb.DelayableUOW: void <init>(org.apache.activemq.leveldb.DBManager)>(v);
return v;
}
public long uowEnqueueDelayReqested()
{
org.apache.activemq.leveldb.DBManager v;
long v;
v := @this: org.apache.activemq.leveldb.DBManager;
v = v.<org.apache.activemq.leveldb.DBManager: long uowEnqueueDelayReqested>;
return v;
}
public void uowEnqueueDelayReqested_$eq(long)
{
org.apache.activemq.leveldb.DBManager v;
long v;
v := @this: org.apache.activemq.leveldb.DBManager;
v := @parameter: long;
v.<org.apache.activemq.leveldb.DBManager: long uowEnqueueDelayReqested> = v;
return;
}
public long uowEnqueueNodelayReqested()
{
org.apache.activemq.leveldb.DBManager v;
long v;
v := @this: org.apache.activemq.leveldb.DBManager;
v = v.<org.apache.activemq.leveldb.DBManager: long uowEnqueueNodelayReqested>;
return v;
}
public void uowEnqueueNodelayReqested_$eq(long)
{
org.apache.activemq.leveldb.DBManager v;
long v;
v := @this: org.apache.activemq.leveldb.DBManager;
v := @parameter: long;
v.<org.apache.activemq.leveldb.DBManager: long uowEnqueueNodelayReqested> = v;
return;
}
public long uowClosedCounter()
{
org.apache.activemq.leveldb.DBManager v;
long v;
v := @this: org.apache.activemq.leveldb.DBManager;
v = v.<org.apache.activemq.leveldb.DBManager: long uowClosedCounter>;
return v;
}
public void uowClosedCounter_$eq(long)
{
org.apache.activemq.leveldb.DBManager v;
long v;
v := @this: org.apache.activemq.leveldb.DBManager;
v := @parameter: long;
v.<org.apache.activemq.leveldb.DBManager: long uowClosedCounter> = v;
return;
}
public long uowCanceledCounter()
{
org.apache.activemq.leveldb.DBManager v;
long v;
v := @this: org.apache.activemq.leveldb.DBManager;
v = v.<org.apache.activemq.leveldb.DBManager: long uowCanceledCounter>;
return v;
}
public void uowCanceledCounter_$eq(long)
{
org.apache.activemq.leveldb.DBManager v;
long v;
v := @this: org.apache.activemq.leveldb.DBManager;
v := @parameter: long;
v.<org.apache.activemq.leveldb.DBManager: long uowCanceledCounter> = v;
return;
}
public long uowStoringCounter()
{
org.apache.activemq.leveldb.DBManager v;
long v;
v := @this: org.apache.activemq.leveldb.DBManager;
v = v.<org.apache.activemq.leveldb.DBManager: long uowStoringCounter>;
return v;
}
public void uowStoringCounter_$eq(long)
{
org.apache.activemq.leveldb.DBManager v;
long v;
v := @this: org.apache.activemq.leveldb.DBManager;
v := @parameter: long;
v.<org.apache.activemq.leveldb.DBManager: long uowStoringCounter> = v;
return;
}
public long uowStoredCounter()
{
org.apache.activemq.leveldb.DBManager v;
long v;
v := @this: org.apache.activemq.leveldb.DBManager;
v = v.<org.apache.activemq.leveldb.DBManager: long uowStoredCounter>;
return v;
}
public void uowStoredCounter_$eq(long)
{
org.apache.activemq.leveldb.DBManager v;
long v;
v := @this: org.apache.activemq.leveldb.DBManager;
v := @parameter: long;
v.<org.apache.activemq.leveldb.DBManager: long uowStoredCounter> = v;
return;
}
public org.apache.activemq.leveldb.util.TimeMetric uow_complete_latency()
{
org.apache.activemq.leveldb.DBManager v;
org.apache.activemq.leveldb.util.TimeMetric v;
v := @this: org.apache.activemq.leveldb.DBManager;
v = v.<org.apache.activemq.leveldb.DBManager: org.apache.activemq.leveldb.util.TimeMetric uow_complete_latency>;
return v;
}
public java.util.concurrent.ConcurrentHashMap pendingStores()
{
java.util.concurrent.ConcurrentHashMap v;
org.apache.activemq.leveldb.DBManager v;
v := @this: org.apache.activemq.leveldb.DBManager;
v = v.<org.apache.activemq.leveldb.DBManager: java.util.concurrent.ConcurrentHashMap pendingStores>;
return v;
}
public void pendingStores_$eq(java.util.concurrent.ConcurrentHashMap)
{
java.util.concurrent.ConcurrentHashMap v;
org.apache.activemq.leveldb.DBManager v;
v := @this: org.apache.activemq.leveldb.DBManager;
v := @parameter: java.util.concurrent.ConcurrentHashMap;
v.<org.apache.activemq.leveldb.DBManager: java.util.concurrent.ConcurrentHashMap pendingStores> = v;
return;
}
public java.util.HashMap cancelable_enqueue_actions()
{
org.apache.activemq.leveldb.DBManager v;
java.util.HashMap v;
v := @this: org.apache.activemq.leveldb.DBManager;
v = v.<org.apache.activemq.leveldb.DBManager: java.util.HashMap cancelable_enqueue_actions>;
return v;
}
public void cancelable_enqueue_actions_$eq(java.util.HashMap)
{
org.apache.activemq.leveldb.DBManager v;
java.util.HashMap v;
v := @this: org.apache.activemq.leveldb.DBManager;
v := @parameter: java.util.HashMap;
v.<org.apache.activemq.leveldb.DBManager: java.util.HashMap cancelable_enqueue_actions> = v;
return;
}
public java.util.concurrent.atomic.AtomicInteger lastUowId()
{
org.apache.activemq.leveldb.DBManager v;
java.util.concurrent.atomic.AtomicInteger v;
v := @this: org.apache.activemq.leveldb.DBManager;
v = v.<org.apache.activemq.leveldb.DBManager: java.util.concurrent.atomic.AtomicInteger lastUowId>;
return v;
}
public org.apache.activemq.ActiveMQMessageAuditNoSync producerSequenceIdTracker()
{
org.apache.activemq.leveldb.DBManager v;
org.apache.activemq.ActiveMQMessageAuditNoSync v;
v := @this: org.apache.activemq.leveldb.DBManager;
v = v.<org.apache.activemq.leveldb.DBManager: org.apache.activemq.ActiveMQMessageAuditNoSync producerSequenceIdTracker>;
return v;
}
public void producerSequenceIdTracker_$eq(org.apache.activemq.ActiveMQMessageAuditNoSync)
{
org.apache.activemq.leveldb.DBManager v;
org.apache.activemq.ActiveMQMessageAuditNoSync v;
v := @this: org.apache.activemq.leveldb.DBManager;
v := @parameter: org.apache.activemq.ActiveMQMessageAuditNoSync;
v.<org.apache.activemq.leveldb.DBManager: org.apache.activemq.ActiveMQMessageAuditNoSync producerSequenceIdTracker> = v;
return;
}
public long getLastProducerSequenceId(org.apache.activemq.command.ProducerId)
{
org.apache.activemq.leveldb.DBManager$$anonfun$getLastProducerSequenceId$1 v;
long v;
org.fusesource.hawtdispatch.DispatchQueue v;
org.fusesource.hawtdispatch.package$RichDispatchQueue v;
org.apache.activemq.command.ProducerId v;
org.fusesource.hawtdispatch.package$ v;
org.apache.activemq.leveldb.DBManager v;
java.lang.Object v;
v := @this: org.apache.activemq.leveldb.DBManager;
v := @parameter: org.apache.activemq.command.ProducerId;
v = <org.fusesource.hawtdispatch.package$: org.fusesource.hawtdispatch.package$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: org.fusesource.hawtdispatch.DispatchQueue dispatchQueue()>();
v = virtualinvoke v.<org.fusesource.hawtdispatch.package$: org.fusesource.hawtdispatch.package$RichDispatchQueue DispatchQueueWrapper(org.fusesource.hawtdispatch.DispatchQueue)>(v);
v = new org.apache.activemq.leveldb.DBManager$$anonfun$getLastProducerSequenceId$1;
specialinvoke v.<org.apache.activemq.leveldb.DBManager$$anonfun$getLastProducerSequenceId$1: void <init>(org.apache.activemq.leveldb.DBManager,org.apache.activemq.command.ProducerId)>(v, v);
v = virtualinvoke v.<org.fusesource.hawtdispatch.package$RichDispatchQueue: java.lang.Object sync(scala.Function)>(v);
v = staticinvoke <scala.runtime.BoxesRunTime: long unboxToLong(java.lang.Object)>(v);
return v;
}
public void processClosed(org.apache.activemq.leveldb.DelayableUOW)
{
long v, v;
int v, v, v, v, v, v;
java.lang.ref.WeakReference v;
boolean v, v;
org.apache.activemq.leveldb.DBManager$$anonfun$processClosed$1 v;
org.apache.activemq.leveldb.UowDelayed$ v, v;
org.apache.activemq.leveldb.DelayableUOW v;
org.fusesource.hawtdispatch.DispatchQueue v;
org.apache.activemq.leveldb.UowFlushQueued$ v;
org.apache.activemq.leveldb.UowFlushing$ v;
scala.collection.immutable.Map v;
org.apache.activemq.leveldb.DBManager v;
org.apache.activemq.leveldb.UowState v, v, v;
v := @this: org.apache.activemq.leveldb.DBManager;
v := @parameter: org.apache.activemq.leveldb.DelayableUOW;
v = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: org.fusesource.hawtdispatch.DispatchQueue dispatchQueue()>();
interfaceinvoke v.<org.fusesource.hawtdispatch.DispatchQueue: void assertExecuting()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: long uowClosedCounter()>();
v = v + 1L;
virtualinvoke v.<org.apache.activemq.leveldb.DBManager: void uowClosedCounter_$eq(long)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.DelayableUOW: org.apache.activemq.leveldb.UowState state()>();
v = interfaceinvoke v.<org.apache.activemq.leveldb.UowState: int stage()>();
v = <org.apache.activemq.leveldb.UowDelayed$: org.apache.activemq.leveldb.UowDelayed$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.UowDelayed$: int stage()>();
if v >= v goto label;
v = <org.apache.activemq.leveldb.UowDelayed$: org.apache.activemq.leveldb.UowDelayed$ MODULE$>;
virtualinvoke v.<org.apache.activemq.leveldb.DelayableUOW: void state_$eq(org.apache.activemq.leveldb.UowState)>(v);
label:
v = virtualinvoke v.<org.apache.activemq.leveldb.DelayableUOW: org.apache.activemq.leveldb.UowState state()>();
v = interfaceinvoke v.<org.apache.activemq.leveldb.UowState: int stage()>();
v = <org.apache.activemq.leveldb.UowFlushing$: org.apache.activemq.leveldb.UowFlushing$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.UowFlushing$: int stage()>();
if v >= v goto label;
v = virtualinvoke v.<org.apache.activemq.leveldb.DelayableUOW: scala.collection.immutable.Map actions()>();
v = new org.apache.activemq.leveldb.DBManager$$anonfun$processClosed$1;
specialinvoke v.<org.apache.activemq.leveldb.DBManager$$anonfun$processClosed$1: void <init>(org.apache.activemq.leveldb.DBManager,org.apache.activemq.leveldb.DelayableUOW)>(v, v);
interfaceinvoke v.<scala.collection.immutable.Map: void foreach(scala.Function)>(v);
label:
v = virtualinvoke v.<org.apache.activemq.leveldb.DelayableUOW: boolean canceled()>();
if v != 0 goto label;
v = virtualinvoke v.<org.apache.activemq.leveldb.DelayableUOW: org.apache.activemq.leveldb.UowState state()>();
v = interfaceinvoke v.<org.apache.activemq.leveldb.UowState: int stage()>();
v = <org.apache.activemq.leveldb.UowFlushQueued$: org.apache.activemq.leveldb.UowFlushQueued$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.UowFlushQueued$: int stage()>();
if v >= v goto label;
v = virtualinvoke v.<org.apache.activemq.leveldb.DelayableUOW: boolean delayable()>();
if v == 0 goto label;
v = new java.lang.ref.WeakReference;
specialinvoke v.<java.lang.ref.WeakReference: void <init>(java.lang.Object)>(v);
specialinvoke v.<org.apache.activemq.leveldb.DBManager: void scheduleFlush(java.lang.ref.WeakReference)>(v);
goto label;
label:
virtualinvoke v.<org.apache.activemq.leveldb.DBManager: void enqueueFlush(org.apache.activemq.leveldb.DelayableUOW)>(v);
label:
return;
}
private void scheduleFlush(java.lang.ref.WeakReference)
{
org.fusesource.hawtdispatch.Task v;
org.apache.activemq.leveldb.DBManager$$anonfun$scheduleFlush$1 v;
org.fusesource.hawtdispatch.DispatchQueue v;
java.util.concurrent.TimeUnit v;
org.fusesource.hawtdispatch.package$ v;
int v;
org.apache.activemq.leveldb.DBManager v;
java.lang.ref.WeakReference v;
v := @this: org.apache.activemq.leveldb.DBManager;
v := @parameter: java.lang.ref.WeakReference;
v = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: org.fusesource.hawtdispatch.DispatchQueue dispatchQueue()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: int flushDelay()>();
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit MILLISECONDS>;
v = <org.fusesource.hawtdispatch.package$: org.fusesource.hawtdispatch.package$ MODULE$>;
v = new org.apache.activemq.leveldb.DBManager$$anonfun$scheduleFlush$1;
specialinvoke v.<org.apache.activemq.leveldb.DBManager$$anonfun$scheduleFlush$1: void <init>(org.apache.activemq.leveldb.DBManager,java.lang.ref.WeakReference)>(v, v);
v = virtualinvoke v.<org.fusesource.hawtdispatch.package$: org.fusesource.hawtdispatch.Task $up(scala.Function)>(v);
interfaceinvoke v.<org.fusesource.hawtdispatch.DispatchQueue: void executeAfter(long,java.util.concurrent.TimeUnit,org.fusesource.hawtdispatch.Task)>(v, v, v);
return;
}
public java.util.LinkedHashMap flush_queue()
{
java.util.LinkedHashMap v;
org.apache.activemq.leveldb.DBManager v;
v := @this: org.apache.activemq.leveldb.DBManager;
v = v.<org.apache.activemq.leveldb.DBManager: java.util.LinkedHashMap flush_queue>;
return v;
}
public void enqueueFlush(org.apache.activemq.leveldb.DelayableUOW)
{
org.apache.activemq.leveldb.DelayableUOW v;
org.fusesource.hawtdispatch.DispatchQueue v;
java.lang.Integer v;
org.apache.activemq.leveldb.UowFlushQueued$ v, v;
java.util.LinkedHashMap v;
org.fusesource.hawtdispatch.CustomDispatchSource v;
java.lang.Long v;
scala.Predef$ v;
int v, v, v;
org.apache.activemq.leveldb.DBManager v;
org.apache.activemq.leveldb.UowState v;
boolean v;
v := @this: org.apache.activemq.leveldb.DBManager;
v := @parameter: org.apache.activemq.leveldb.DelayableUOW;
v = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: org.fusesource.hawtdispatch.DispatchQueue dispatchQueue()>();
interfaceinvoke v.<org.fusesource.hawtdispatch.DispatchQueue: void assertExecuting()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.activemq.leveldb.DelayableUOW: boolean canceled()>();
if v != 0 goto label;
v = virtualinvoke v.<org.apache.activemq.leveldb.DelayableUOW: org.apache.activemq.leveldb.UowState state()>();
v = interfaceinvoke v.<org.apache.activemq.leveldb.UowState: int stage()>();
v = <org.apache.activemq.leveldb.UowFlushQueued$: org.apache.activemq.leveldb.UowFlushQueued$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.UowFlushQueued$: int stage()>();
if v >= v goto label;
v = <org.apache.activemq.leveldb.UowFlushQueued$: org.apache.activemq.leveldb.UowFlushQueued$ MODULE$>;
virtualinvoke v.<org.apache.activemq.leveldb.DelayableUOW: void state_$eq(org.apache.activemq.leveldb.UowState)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: java.util.LinkedHashMap flush_queue()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.DelayableUOW: int uowId()>();
v = staticinvoke <scala.runtime.BoxesRunTime: java.lang.Long boxToLong(long)>(v);
virtualinvoke v.<java.util.LinkedHashMap: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: org.fusesource.hawtdispatch.CustomDispatchSource flushSource()>();
v = <scala.Predef$: scala.Predef$ MODULE$>;
v = virtualinvoke v.<scala.Predef$: java.lang.Integer int2Integer(int)>(1);
interfaceinvoke v.<org.fusesource.hawtdispatch.CustomDispatchSource: void merge(java.lang.Object)>(v);
label:
return;
}
public org.fusesource.hawtdispatch.CustomDispatchSource flushSource()
{
org.apache.activemq.leveldb.DBManager v;
org.fusesource.hawtdispatch.CustomDispatchSource v;
v := @this: org.apache.activemq.leveldb.DBManager;
v = v.<org.apache.activemq.leveldb.DBManager: org.fusesource.hawtdispatch.CustomDispatchSource flushSource>;
return v;
}
public void drainFlushes()
{
org.fusesource.hawtdispatch.package$ v;
org.apache.activemq.leveldb.DBManager$$anonfun$2 v;
scala.collection.JavaConversions$ v;
scala.collection.mutable.ArrayOps v, v, v;
boolean v;
java.util.Collection v;
scala.collection.Seq v;
org.fusesource.hawtdispatch.DispatchQueue v;
org.apache.activemq.leveldb.DBManager v;
scala.Array$ v;
scala.collection.generic.CanBuildFrom v;
scala.reflect.ClassTag v, v;
org.apache.activemq.leveldb.DelayableUOW[] v, v;
long v, v;
java.util.LinkedHashMap v, v;
scala.Predef$ v, v, v;
int v;
java.util.concurrent.ExecutorService v;
org.fusesource.hawtdispatch.package$RichExecutor v;
org.apache.activemq.leveldb.DBManager$$anonfun$drainFlushes$1 v;
scala.collection.Iterable v;
scala.reflect.ClassTag$ v, v;
org.fusesource.hawtdispatch.CustomDispatchSource v;
java.lang.Object v;
v := @this: org.apache.activemq.leveldb.DBManager;
v = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: org.fusesource.hawtdispatch.DispatchQueue dispatchQueue()>();
interfaceinvoke v.<org.fusesource.hawtdispatch.DispatchQueue: void assertExecuting()>();
v = <scala.collection.JavaConversions$: scala.collection.JavaConversions$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: java.util.LinkedHashMap flush_queue()>();
v = virtualinvoke v.<java.util.LinkedHashMap: java.util.Collection values()>();
v = virtualinvoke v.<scala.collection.JavaConversions$: scala.collection.Iterable collectionAsScalaIterable(java.util.Collection)>(v);
v = interfaceinvoke v.<scala.collection.Iterable: scala.collection.Seq toSeq()>();
v = <scala.reflect.ClassTag$: scala.reflect.ClassTag$ MODULE$>;
v = virtualinvoke v.<scala.reflect.ClassTag$: scala.reflect.ClassTag apply(java.lang.Class)>(class "Lorg/apache/activemq/leveldb/DelayableUOW;");
interfaceinvoke v.<scala.collection.Seq: java.lang.Object toArray(scala.reflect.ClassTag)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: java.util.LinkedHashMap flush_queue()>();
virtualinvoke v.<java.util.LinkedHashMap: void clear()>();
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.DBManager$$anonfun$2;
specialinvoke v.<org.apache.activemq.leveldb.DBManager$$anonfun$2: void <init>(org.apache.activemq.leveldb.DBManager)>(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/apache/activemq/leveldb/DelayableUOW;");
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 = <scala.Predef$: scala.Predef$ MODULE$>;
v = virtualinvoke v.<scala.Predef$: scala.collection.mutable.ArrayOps refArrayOps(java.lang.Object[])>(v);
v = interfaceinvoke v.<scala.collection.mutable.ArrayOps: boolean isEmpty()>();
if v != 0 goto label;
v = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: long uowStoringCounter()>();
v = <scala.Predef$: scala.Predef$ MODULE$>;
v = virtualinvoke v.<scala.Predef$: scala.collection.mutable.ArrayOps refArrayOps(java.lang.Object[])>(v);
v = interfaceinvoke v.<scala.collection.mutable.ArrayOps: int size()>();
v = v + v;
virtualinvoke v.<org.apache.activemq.leveldb.DBManager: void uowStoringCounter_$eq(long)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: org.fusesource.hawtdispatch.CustomDispatchSource flushSource()>();
interfaceinvoke v.<org.fusesource.hawtdispatch.CustomDispatchSource: void suspend()>();
v = <org.fusesource.hawtdispatch.package$: org.fusesource.hawtdispatch.package$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: 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.DBManager$$anonfun$drainFlushes$1;
specialinvoke v.<org.apache.activemq.leveldb.DBManager$$anonfun$drainFlushes$1: void <init>(org.apache.activemq.leveldb.DBManager,org.apache.activemq.leveldb.DelayableUOW[])>(v, v);
virtualinvoke v.<org.fusesource.hawtdispatch.package$RichExecutor: void apply(scala.Function)>(v);
label:
return;
}
public boolean started()
{
org.apache.activemq.leveldb.DBManager v;
boolean v;
v := @this: org.apache.activemq.leveldb.DBManager;
v = v.<org.apache.activemq.leveldb.DBManager: boolean started>;
return v;
}
public void started_$eq(boolean)
{
org.apache.activemq.leveldb.DBManager v;
boolean v;
v := @this: org.apache.activemq.leveldb.DBManager;
v := @parameter: boolean;
v.<org.apache.activemq.leveldb.DBManager: boolean started> = v;
return;
}
public boolean snappyCompressLogs()
{
org.apache.activemq.leveldb.DBManager v;
org.apache.activemq.leveldb.LevelDBStore v;
boolean v;
v := @this: org.apache.activemq.leveldb.DBManager;
v = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: org.apache.activemq.leveldb.LevelDBStore parent()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: boolean snappyCompressLogs()>();
return v;
}
public void start()
{
org.fusesource.hawtdispatch.DispatchQueue v;
org.apache.activemq.leveldb.LevelDBStore v;
org.fusesource.hawtdispatch.package$RichDispatchQueue v;
java.util.concurrent.atomic.AtomicLong v;
org.apache.activemq.leveldb.LevelDBClient v;
org.fusesource.hawtdispatch.package$ v;
org.apache.activemq.leveldb.DBManager$$anonfun$start$1 v;
int v;
org.apache.activemq.leveldb.DBManager v;
v := @this: org.apache.activemq.leveldb.DBManager;
v = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: java.util.concurrent.atomic.AtomicLong asyncCapacityRemaining()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: org.apache.activemq.leveldb.LevelDBStore parent()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: int asyncBufferSize()>();
virtualinvoke v.<java.util.concurrent.atomic.AtomicLong: void set(long)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: org.apache.activemq.leveldb.LevelDBClient client()>();
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: void start()>();
v = <org.fusesource.hawtdispatch.package$: org.fusesource.hawtdispatch.package$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: org.fusesource.hawtdispatch.DispatchQueue dispatchQueue()>();
v = virtualinvoke v.<org.fusesource.hawtdispatch.package$: org.fusesource.hawtdispatch.package$RichDispatchQueue DispatchQueueWrapper(org.fusesource.hawtdispatch.DispatchQueue)>(v);
v = new org.apache.activemq.leveldb.DBManager$$anonfun$start$1;
specialinvoke v.<org.apache.activemq.leveldb.DBManager$$anonfun$start$1: void <init>(org.apache.activemq.leveldb.DBManager)>(v);
virtualinvoke v.<org.fusesource.hawtdispatch.package$RichDispatchQueue: java.lang.Object sync(scala.Function)>(v);
return;
}
public void stop()
{
org.apache.activemq.leveldb.LevelDBClient v;
org.fusesource.hawtdispatch.package$ v;
org.apache.activemq.leveldb.DBManager$$anonfun$stop$1 v;
org.apache.activemq.leveldb.DBManager v;
org.fusesource.hawtdispatch.DispatchQueue v;
org.fusesource.hawtdispatch.package$RichDispatchQueue v;
v := @this: org.apache.activemq.leveldb.DBManager;
v = <org.fusesource.hawtdispatch.package$: org.fusesource.hawtdispatch.package$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: org.fusesource.hawtdispatch.DispatchQueue dispatchQueue()>();
v = virtualinvoke v.<org.fusesource.hawtdispatch.package$: org.fusesource.hawtdispatch.package$RichDispatchQueue DispatchQueueWrapper(org.fusesource.hawtdispatch.DispatchQueue)>(v);
v = new org.apache.activemq.leveldb.DBManager$$anonfun$stop$1;
specialinvoke v.<org.apache.activemq.leveldb.DBManager$$anonfun$stop$1: void <init>(org.apache.activemq.leveldb.DBManager)>(v);
virtualinvoke v.<org.fusesource.hawtdispatch.package$RichDispatchQueue: java.lang.Object sync(scala.Function)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: org.apache.activemq.leveldb.LevelDBClient client()>();
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: void stop()>();
return;
}
public void pollGc()
{
java.util.concurrent.TimeUnit v;
org.fusesource.hawtdispatch.package$ v;
org.apache.activemq.leveldb.DBManager$$anonfun$pollGc$1 v;
org.apache.activemq.leveldb.DBManager v;
org.fusesource.hawtdispatch.DispatchQueue v;
org.fusesource.hawtdispatch.package$RichDispatchQueue v;
v := @this: org.apache.activemq.leveldb.DBManager;
v = <org.fusesource.hawtdispatch.package$: org.fusesource.hawtdispatch.package$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: org.fusesource.hawtdispatch.DispatchQueue dispatchQueue()>();
v = virtualinvoke v.<org.fusesource.hawtdispatch.package$: org.fusesource.hawtdispatch.package$RichDispatchQueue DispatchQueueWrapper(org.fusesource.hawtdispatch.DispatchQueue)>(v);
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit SECONDS>;
v = new org.apache.activemq.leveldb.DBManager$$anonfun$pollGc$1;
specialinvoke v.<org.apache.activemq.leveldb.DBManager$$anonfun$pollGc$1: void <init>(org.apache.activemq.leveldb.DBManager)>(v);
virtualinvoke v.<org.fusesource.hawtdispatch.package$RichDispatchQueue: void after(long,java.util.concurrent.TimeUnit,scala.Function)>(10L, v, v);
return;
}
public void monitorStats()
{
java.util.concurrent.TimeUnit v;
org.fusesource.hawtdispatch.package$ v;
org.apache.activemq.leveldb.DBManager$$anonfun$monitorStats$1 v;
org.apache.activemq.leveldb.DBManager v;
org.fusesource.hawtdispatch.DispatchQueue v;
org.fusesource.hawtdispatch.package$RichDispatchQueue v;
v := @this: org.apache.activemq.leveldb.DBManager;
v = <org.fusesource.hawtdispatch.package$: org.fusesource.hawtdispatch.package$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: org.fusesource.hawtdispatch.DispatchQueue dispatchQueue()>();
v = virtualinvoke v.<org.fusesource.hawtdispatch.package$: org.fusesource.hawtdispatch.package$RichDispatchQueue DispatchQueueWrapper(org.fusesource.hawtdispatch.DispatchQueue)>(v);
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit SECONDS>;
v = new org.apache.activemq.leveldb.DBManager$$anonfun$monitorStats$1;
specialinvoke v.<org.apache.activemq.leveldb.DBManager$$anonfun$monitorStats$1: void <init>(org.apache.activemq.leveldb.DBManager)>(v);
virtualinvoke v.<org.fusesource.hawtdispatch.package$RichDispatchQueue: void after(long,java.util.concurrent.TimeUnit,scala.Function)>(1L, v, v);
return;
}
public void checkpoint(boolean)
{
org.fusesource.hawtdispatch.package$RichExecutor v;
org.fusesource.hawtdispatch.package$ v;
org.apache.activemq.leveldb.DBManager v;
java.util.concurrent.ExecutorService v;
org.apache.activemq.leveldb.DBManager$$anonfun$checkpoint$1 v;
boolean v;
v := @this: org.apache.activemq.leveldb.DBManager;
v := @parameter: boolean;
v = <org.fusesource.hawtdispatch.package$: org.fusesource.hawtdispatch.package$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: 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.DBManager$$anonfun$checkpoint$1;
specialinvoke v.<org.apache.activemq.leveldb.DBManager$$anonfun$checkpoint$1: void <init>(org.apache.activemq.leveldb.DBManager,boolean)>(v, v);
virtualinvoke v.<org.fusesource.hawtdispatch.package$RichExecutor: java.lang.Object sync(scala.Function)>(v);
return;
}
public void purge()
{
org.fusesource.hawtdispatch.package$RichExecutor v;
org.fusesource.hawtdispatch.package$ v;
org.apache.activemq.leveldb.DBManager v;
org.apache.activemq.leveldb.DBManager$$anonfun$purge$1 v;
java.util.concurrent.ExecutorService v;
v := @this: org.apache.activemq.leveldb.DBManager;
v = <org.fusesource.hawtdispatch.package$: org.fusesource.hawtdispatch.package$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: 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.DBManager$$anonfun$purge$1;
specialinvoke v.<org.apache.activemq.leveldb.DBManager$$anonfun$purge$1: void <init>(org.apache.activemq.leveldb.DBManager)>(v);
virtualinvoke v.<org.fusesource.hawtdispatch.package$RichExecutor: java.lang.Object sync(scala.Function)>(v);
return;
}
public long getLastQueueEntrySeq(long)
{
org.apache.activemq.leveldb.LevelDBClient v;
org.apache.activemq.leveldb.DBManager v;
long v, v;
v := @this: org.apache.activemq.leveldb.DBManager;
v := @parameter: long;
v = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: org.apache.activemq.leveldb.LevelDBClient client()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: long getLastQueueEntrySeq(long)>(v);
return v;
}
public void collectionEmpty(long)
{
org.fusesource.hawtdispatch.package$RichExecutor v;
org.fusesource.hawtdispatch.package$ v;
org.apache.activemq.leveldb.DBManager$$anonfun$collectionEmpty$1 v;
org.apache.activemq.leveldb.DBManager v;
long v;
java.util.concurrent.ExecutorService v;
v := @this: org.apache.activemq.leveldb.DBManager;
v := @parameter: long;
v = <org.fusesource.hawtdispatch.package$: org.fusesource.hawtdispatch.package$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: 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.DBManager$$anonfun$collectionEmpty$1;
specialinvoke v.<org.apache.activemq.leveldb.DBManager$$anonfun$collectionEmpty$1: void <init>(org.apache.activemq.leveldb.DBManager,long)>(v, v);
virtualinvoke v.<org.fusesource.hawtdispatch.package$RichExecutor: java.lang.Object sync(scala.Function)>(v);
return;
}
public long collectionSize(long)
{
org.apache.activemq.leveldb.LevelDBClient v;
org.apache.activemq.leveldb.DBManager v;
long v, v;
v := @this: org.apache.activemq.leveldb.DBManager;
v := @parameter: long;
v = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: org.apache.activemq.leveldb.LevelDBClient client()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: long collectionSize(long)>(v);
return v;
}
public boolean collectionIsEmpty(long)
{
org.apache.activemq.leveldb.LevelDBClient v;
org.apache.activemq.leveldb.DBManager v;
long v;
boolean v;
v := @this: org.apache.activemq.leveldb.DBManager;
v := @parameter: long;
v = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: org.apache.activemq.leveldb.LevelDBClient client()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: boolean collectionIsEmpty(long)>(v);
return v;
}
public long cursorMessages(java.util.HashSet, long, org.apache.activemq.store.MessageRecoveryListener, long, long, long)
{
long v, v, v, v, v, v;
java.util.HashSet v;
org.apache.activemq.leveldb.LevelDBClient v;
org.apache.activemq.leveldb.DBManager$$anonfun$cursorMessages$1 v;
scala.runtime.LongRef v;
org.apache.activemq.leveldb.DBManager v;
java.lang.Object v, v, v;
scala.runtime.ObjectRef v;
org.apache.activemq.store.MessageRecoveryListener v;
v := @this: org.apache.activemq.leveldb.DBManager;
v := @parameter: java.util.HashSet;
v := @parameter: long;
v := @parameter: org.apache.activemq.store.MessageRecoveryListener;
v := @parameter: long;
v := @parameter: long;
v := @parameter: long;
v = staticinvoke <scala.runtime.ObjectRef: scala.runtime.ObjectRef create(java.lang.Object)>(null);
v = staticinvoke <scala.runtime.LongRef: scala.runtime.LongRef create(long)>(0L);
v = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: org.apache.activemq.leveldb.LevelDBClient client()>();
v = new org.apache.activemq.leveldb.DBManager$$anonfun$cursorMessages$1;
specialinvoke v.<org.apache.activemq.leveldb.DBManager$$anonfun$cursorMessages$1: void <init>(org.apache.activemq.leveldb.DBManager,java.util.HashSet,org.apache.activemq.store.MessageRecoveryListener,long,scala.runtime.ObjectRef,scala.runtime.LongRef)>(v, v, v, v, v, v);
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: void queueCursor(long,long,long,scala.Function)>(v, v, v, v);
v = v.<scala.runtime.ObjectRef: java.lang.Object elem>;
if v != null goto label;
v = v;
goto label;
label:
v = v.<scala.runtime.ObjectRef: java.lang.Object elem>;
v = virtualinvoke v.<org.apache.activemq.command.MessageId: java.lang.Object getEntryLocator()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.EntryLocator: long seq()>();
v = v + 1L;
label:
return v;
}
public long cursorMessages$default$5()
{
org.apache.activemq.leveldb.DBManager v;
v := @this: org.apache.activemq.leveldb.DBManager;
return 9223372036854775807L;
}
public long cursorMessages$default$6()
{
org.apache.activemq.leveldb.DBManager v;
v := @this: org.apache.activemq.leveldb.DBManager;
return 9223372036854775807L;
}
public scala.Tuple getXAActions(long)
{
long v;
scala.Tuple v;
org.apache.activemq.leveldb.DBManager$$anonfun$getXAActions$1 v;
org.apache.activemq.leveldb.LevelDBClient v;
org.apache.activemq.leveldb.DBManager v;
scala.collection.GenTraversable v, v;
scala.collection.mutable.ListBuffer$ v, v;
scala.collection.immutable.Nil$ v, v;
v := @this: org.apache.activemq.leveldb.DBManager;
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 = <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 = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: org.apache.activemq.leveldb.LevelDBClient client()>();
v = new org.apache.activemq.leveldb.DBManager$$anonfun$getXAActions$1;
specialinvoke v.<org.apache.activemq.leveldb.DBManager$$anonfun$getXAActions$1: void <init>(org.apache.activemq.leveldb.DBManager,scala.collection.mutable.ListBuffer,scala.collection.mutable.ListBuffer)>(v, v, v);
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: void transactionCursor(long,scala.Function)>(v, v);
v = new scala.Tuple;
specialinvoke v.<scala.Tuple2: void <init>(java.lang.Object,java.lang.Object)>(v, v);
return v;
}
public long queuePosition(org.apache.activemq.command.MessageId)
{
org.apache.activemq.command.MessageId v;
org.apache.activemq.leveldb.DBManager v;
java.lang.Object v;
long v;
v := @this: org.apache.activemq.leveldb.DBManager;
v := @parameter: org.apache.activemq.command.MessageId;
v = virtualinvoke v.<org.apache.activemq.command.MessageId: java.lang.Object getEntryLocator()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.EntryLocator: long seq()>();
return v;
}
public org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore createQueueStore(org.apache.activemq.command.ActiveMQQueue)
{
org.apache.activemq.leveldb.UowManagerConstants$ v;
org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore v;
long v;
org.apache.activemq.command.ActiveMQQueue v;
org.apache.activemq.leveldb.LevelDBStore v;
org.fusesource.hawtbuf.UTF8Buffer v;
int v;
org.apache.activemq.leveldb.DBManager v;
java.lang.String v;
v := @this: org.apache.activemq.leveldb.DBManager;
v := @parameter: org.apache.activemq.command.ActiveMQQueue;
v = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: org.apache.activemq.leveldb.LevelDBStore parent()>();
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQQueue: java.lang.String getQualifiedName()>();
v = staticinvoke <org.fusesource.hawtbuf.Buffer: org.fusesource.hawtbuf.UTF8Buffer utf8(java.lang.String)>(v);
v = <org.apache.activemq.leveldb.UowManagerConstants$: org.apache.activemq.leveldb.UowManagerConstants$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.UowManagerConstants$: int QUEUE_COLLECTION_TYPE()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: long createCollection(org.fusesource.hawtbuf.Buffer,int)>(v, v);
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.leveldb.LevelDBStore$LevelDBMessageStore createQueueMessageStore(org.apache.activemq.command.ActiveMQQueue,long)>(v, v);
return v;
}
public void destroyQueueStore(long)
{
org.fusesource.hawtdispatch.package$RichExecutor v;
org.fusesource.hawtdispatch.package$ v;
org.apache.activemq.leveldb.DBManager$$anonfun$destroyQueueStore$1 v;
org.apache.activemq.leveldb.DBManager v;
long v;
java.util.concurrent.ExecutorService v;
v := @this: org.apache.activemq.leveldb.DBManager;
v := @parameter: long;
v = <org.fusesource.hawtdispatch.package$: org.fusesource.hawtdispatch.package$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: 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.DBManager$$anonfun$destroyQueueStore$1;
specialinvoke v.<org.apache.activemq.leveldb.DBManager$$anonfun$destroyQueueStore$1: void <init>(org.apache.activemq.leveldb.DBManager,long)>(v, v);
virtualinvoke v.<org.fusesource.hawtdispatch.package$RichExecutor: java.lang.Object sync(scala.Function)>(v);
return;
}
public long getLogAppendPosition()
{
org.fusesource.hawtdispatch.package$RichExecutor v;
org.fusesource.hawtdispatch.package$ v;
org.apache.activemq.leveldb.DBManager v;
java.lang.Object v;
long v;
org.apache.activemq.leveldb.DBManager$$anonfun$getLogAppendPosition$1 v;
java.util.concurrent.ExecutorService v;
v := @this: org.apache.activemq.leveldb.DBManager;
v = <org.fusesource.hawtdispatch.package$: org.fusesource.hawtdispatch.package$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: 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.DBManager$$anonfun$getLogAppendPosition$1;
specialinvoke v.<org.apache.activemq.leveldb.DBManager$$anonfun$getLogAppendPosition$1: void <init>(org.apache.activemq.leveldb.DBManager)>(v);
v = virtualinvoke v.<org.fusesource.hawtdispatch.package$RichExecutor: java.lang.Object sync(scala.Function)>(v);
v = staticinvoke <scala.runtime.BoxesRunTime: long unboxToLong(java.lang.Object)>(v);
return v;
}
public org.apache.activemq.leveldb.DurableSubscription addSubscription(long, org.apache.activemq.command.SubscriptionInfo)
{
org.apache.activemq.leveldb.DBManager$$anonfun$addSubscription$1 v;
org.apache.activemq.leveldb.record.SubscriptionRecord$Bean v;
long v, v, v;
org.fusesource.hawtbuf.Buffer v;
org.apache.activemq.leveldb.record.CollectionRecord$Buffer v;
org.fusesource.hawtdispatch.package$ v;
int v;
org.apache.activemq.leveldb.DurableSubscription v;
java.lang.String v, v, v, v, v, v;
java.util.concurrent.ExecutorService v;
org.apache.activemq.command.SubscriptionInfo v;
org.fusesource.hawtdispatch.package$RichExecutor v;
org.apache.activemq.leveldb.UowManagerConstants$ v;
org.apache.activemq.leveldb.record.SubscriptionRecord$Buffer v;
scala.runtime.BoxedUnit v, v, v;
org.apache.activemq.command.ActiveMQDestination v, v, v, v;
java.util.concurrent.atomic.AtomicLong v;
org.apache.activemq.leveldb.record.CollectionRecord$Bean v;
org.apache.activemq.leveldb.DBManager v;
v := @this: org.apache.activemq.leveldb.DBManager;
v := @parameter: long;
v := @parameter: org.apache.activemq.command.SubscriptionInfo;
v = new org.apache.activemq.leveldb.record.SubscriptionRecord$Bean;
specialinvoke v.<org.apache.activemq.leveldb.record.SubscriptionRecord$Bean: void <init>()>();
virtualinvoke v.<org.apache.activemq.leveldb.record.SubscriptionRecord$Bean: org.apache.activemq.leveldb.record.SubscriptionRecord$Bean setTopicKey(long)>(v);
v = virtualinvoke v.<org.apache.activemq.command.SubscriptionInfo: java.lang.String getClientId()>();
virtualinvoke v.<org.apache.activemq.leveldb.record.SubscriptionRecord$Bean: org.apache.activemq.leveldb.record.SubscriptionRecord$Bean setClientId(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.activemq.command.SubscriptionInfo: java.lang.String getSubscriptionName()>();
virtualinvoke v.<org.apache.activemq.leveldb.record.SubscriptionRecord$Bean: org.apache.activemq.leveldb.record.SubscriptionRecord$Bean setSubscriptionName(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.activemq.command.SubscriptionInfo: java.lang.String getSelector()>();
if v != null goto label;
v = <scala.runtime.BoxedUnit: scala.runtime.BoxedUnit UNIT>;
goto label;
label:
v = virtualinvoke v.<org.apache.activemq.command.SubscriptionInfo: java.lang.String getSelector()>();
virtualinvoke v.<org.apache.activemq.leveldb.record.SubscriptionRecord$Bean: org.apache.activemq.leveldb.record.SubscriptionRecord$Bean setSelector(java.lang.String)>(v);
label:
v = virtualinvoke v.<org.apache.activemq.command.SubscriptionInfo: org.apache.activemq.command.ActiveMQDestination getDestination()>();
if v != null goto label;
v = <scala.runtime.BoxedUnit: scala.runtime.BoxedUnit UNIT>;
goto label;
label:
v = virtualinvoke v.<org.apache.activemq.command.SubscriptionInfo: org.apache.activemq.command.ActiveMQDestination getDestination()>();
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: java.lang.String getQualifiedName()>();
virtualinvoke v.<org.apache.activemq.leveldb.record.SubscriptionRecord$Bean: org.apache.activemq.leveldb.record.SubscriptionRecord$Bean setDestinationName(java.lang.String)>(v);
label:
v = virtualinvoke v.<org.apache.activemq.command.SubscriptionInfo: org.apache.activemq.command.ActiveMQDestination getSubscribedDestination()>();
if v != null goto label;
v = <scala.runtime.BoxedUnit: scala.runtime.BoxedUnit UNIT>;
goto label;
label:
v = virtualinvoke v.<org.apache.activemq.command.SubscriptionInfo: org.apache.activemq.command.ActiveMQDestination getSubscribedDestination()>();
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: java.lang.String getQualifiedName()>();
virtualinvoke v.<org.apache.activemq.leveldb.record.SubscriptionRecord$Bean: org.apache.activemq.leveldb.record.SubscriptionRecord$Bean setSubscribedDestinationName(java.lang.String)>(v);
label:
v = new org.apache.activemq.leveldb.record.CollectionRecord$Bean;
specialinvoke v.<org.apache.activemq.leveldb.record.CollectionRecord$Bean: void <init>()>();
v = <org.apache.activemq.leveldb.UowManagerConstants$: org.apache.activemq.leveldb.UowManagerConstants$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.UowManagerConstants$: int SUBSCRIPTION_COLLECTION_TYPE()>();
virtualinvoke v.<org.apache.activemq.leveldb.record.CollectionRecord$Bean: org.apache.activemq.leveldb.record.CollectionRecord$Bean setType(int)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: java.util.concurrent.atomic.AtomicLong lastCollectionKey()>();
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicLong: long incrementAndGet()>();
virtualinvoke v.<org.apache.activemq.leveldb.record.CollectionRecord$Bean: org.apache.activemq.leveldb.record.CollectionRecord$Bean setKey(long)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.record.SubscriptionRecord$Bean: org.apache.activemq.leveldb.record.SubscriptionRecord$Buffer freeze()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.record.SubscriptionRecord$Buffer: org.fusesource.hawtbuf.Buffer toUnframedBuffer()>();
virtualinvoke v.<org.apache.activemq.leveldb.record.CollectionRecord$Bean: org.apache.activemq.leveldb.record.CollectionRecord$Bean setMeta(org.fusesource.hawtbuf.Buffer)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.record.CollectionRecord$Bean: org.apache.activemq.leveldb.record.CollectionRecord$Buffer freeze()>();
virtualinvoke v.<org.apache.activemq.leveldb.record.CollectionRecord$Buffer: org.fusesource.hawtbuf.Buffer toFramedBuffer()>();
v = <org.fusesource.hawtdispatch.package$: org.fusesource.hawtdispatch.package$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: 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.DBManager$$anonfun$addSubscription$1;
specialinvoke v.<org.apache.activemq.leveldb.DBManager$$anonfun$addSubscription$1: void <init>(org.apache.activemq.leveldb.DBManager,org.apache.activemq.leveldb.record.CollectionRecord$Buffer)>(v, v);
virtualinvoke v.<org.fusesource.hawtdispatch.package$RichExecutor: java.lang.Object sync(scala.Function)>(v);
v = new org.apache.activemq.leveldb.DurableSubscription;
v = virtualinvoke v.<org.apache.activemq.leveldb.record.CollectionRecord$Bean: long getKey()>();
specialinvoke v.<org.apache.activemq.leveldb.DurableSubscription: void <init>(long,long,org.apache.activemq.command.SubscriptionInfo)>(v, v, v);
return v;
}
public void removeSubscription(org.apache.activemq.leveldb.DurableSubscription)
{
org.fusesource.hawtdispatch.package$RichExecutor v;
org.fusesource.hawtdispatch.package$ v;
org.apache.activemq.leveldb.DBManager v;
org.apache.activemq.leveldb.DurableSubscription v;
java.util.concurrent.ExecutorService v;
org.apache.activemq.leveldb.DBManager$$anonfun$removeSubscription$1 v;
v := @this: org.apache.activemq.leveldb.DBManager;
v := @parameter: org.apache.activemq.leveldb.DurableSubscription;
v = <org.fusesource.hawtdispatch.package$: org.fusesource.hawtdispatch.package$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: 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.DBManager$$anonfun$removeSubscription$1;
specialinvoke v.<org.apache.activemq.leveldb.DBManager$$anonfun$removeSubscription$1: void <init>(org.apache.activemq.leveldb.DBManager,org.apache.activemq.leveldb.DurableSubscription)>(v, v);
virtualinvoke v.<org.fusesource.hawtdispatch.package$RichExecutor: java.lang.Object sync(scala.Function)>(v);
return;
}
public org.apache.activemq.leveldb.LevelDBStore$LevelDBTopicMessageStore createTopicStore(org.apache.activemq.command.ActiveMQTopic)
{
org.apache.activemq.leveldb.UowManagerConstants$ v;
long v;
org.apache.activemq.leveldb.LevelDBStore v;
org.apache.activemq.leveldb.LevelDBStore$LevelDBTopicMessageStore v;
org.apache.activemq.command.ActiveMQTopic v;
org.fusesource.hawtbuf.UTF8Buffer v;
int v;
org.apache.activemq.leveldb.DBManager v;
java.lang.String v;
v := @this: org.apache.activemq.leveldb.DBManager;
v := @parameter: org.apache.activemq.command.ActiveMQTopic;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQTopic: java.lang.String getQualifiedName()>();
v = staticinvoke <org.fusesource.hawtbuf.Buffer: org.fusesource.hawtbuf.UTF8Buffer utf8(java.lang.String)>(v);
v = <org.apache.activemq.leveldb.UowManagerConstants$: org.apache.activemq.leveldb.UowManagerConstants$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.UowManagerConstants$: int TOPIC_COLLECTION_TYPE()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: long createCollection(org.fusesource.hawtbuf.Buffer,int)>(v, v);
v = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: org.apache.activemq.leveldb.LevelDBStore parent()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.leveldb.LevelDBStore$LevelDBTopicMessageStore createTopicMessageStore(org.apache.activemq.command.ActiveMQTopic,long)>(v, v);
return v;
}
public long createCollection(org.fusesource.hawtbuf.Buffer, int)
{
org.fusesource.hawtdispatch.package$RichExecutor v;
long v, v;
org.apache.activemq.leveldb.DBManager$$anonfun$createCollection$1 v;
org.fusesource.hawtbuf.Buffer v;
java.util.concurrent.atomic.AtomicLong v;
org.apache.activemq.leveldb.record.CollectionRecord$Buffer v;
org.fusesource.hawtdispatch.package$ v;
org.apache.activemq.leveldb.record.CollectionRecord$Bean v;
int v;
org.apache.activemq.leveldb.DBManager v;
java.util.concurrent.ExecutorService v;
v := @this: org.apache.activemq.leveldb.DBManager;
v := @parameter: org.fusesource.hawtbuf.Buffer;
v := @parameter: int;
v = new org.apache.activemq.leveldb.record.CollectionRecord$Bean;
specialinvoke v.<org.apache.activemq.leveldb.record.CollectionRecord$Bean: void <init>()>();
virtualinvoke v.<org.apache.activemq.leveldb.record.CollectionRecord$Bean: org.apache.activemq.leveldb.record.CollectionRecord$Bean setType(int)>(v);
virtualinvoke v.<org.apache.activemq.leveldb.record.CollectionRecord$Bean: org.apache.activemq.leveldb.record.CollectionRecord$Bean setMeta(org.fusesource.hawtbuf.Buffer)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: java.util.concurrent.atomic.AtomicLong lastCollectionKey()>();
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicLong: long incrementAndGet()>();
virtualinvoke v.<org.apache.activemq.leveldb.record.CollectionRecord$Bean: org.apache.activemq.leveldb.record.CollectionRecord$Bean setKey(long)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.record.CollectionRecord$Bean: org.apache.activemq.leveldb.record.CollectionRecord$Buffer freeze()>();
virtualinvoke v.<org.apache.activemq.leveldb.record.CollectionRecord$Buffer: org.fusesource.hawtbuf.Buffer toFramedBuffer()>();
v = <org.fusesource.hawtdispatch.package$: org.fusesource.hawtdispatch.package$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: 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.DBManager$$anonfun$createCollection$1;
specialinvoke v.<org.apache.activemq.leveldb.DBManager$$anonfun$createCollection$1: void <init>(org.apache.activemq.leveldb.DBManager,org.apache.activemq.leveldb.record.CollectionRecord$Buffer)>(v, v);
virtualinvoke v.<org.fusesource.hawtdispatch.package$RichExecutor: java.lang.Object sync(scala.Function)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.record.CollectionRecord$Bean: long getKey()>();
return v;
}
public org.fusesource.hawtbuf.Buffer buffer(org.apache.activemq.util.ByteSequence)
{
byte[] v;
int v, v;
org.apache.activemq.leveldb.DBManager v;
org.fusesource.hawtbuf.Buffer v;
org.apache.activemq.util.ByteSequence v;
v := @this: org.apache.activemq.leveldb.DBManager;
v := @parameter: org.apache.activemq.util.ByteSequence;
v = new org.fusesource.hawtbuf.Buffer;
v = v.<org.apache.activemq.util.ByteSequence: byte[] data>;
v = v.<org.apache.activemq.util.ByteSequence: int offset>;
v = v.<org.apache.activemq.util.ByteSequence: int length>;
specialinvoke v.<org.fusesource.hawtbuf.Buffer: void <init>(byte[],int,int)>(v, v, v);
return v;
}
public long createTransactionContainer(org.apache.activemq.command.XATransactionId)
{
org.apache.activemq.leveldb.UowManagerConstants$ v;
long v;
org.apache.activemq.leveldb.LevelDBStore v;
org.fusesource.hawtbuf.Buffer v;
org.apache.activemq.openwire.OpenWireFormat v;
int v;
org.apache.activemq.leveldb.DBManager v;
org.apache.activemq.command.XATransactionId v;
org.apache.activemq.util.ByteSequence v;
v := @this: org.apache.activemq.leveldb.DBManager;
v := @parameter: org.apache.activemq.command.XATransactionId;
v = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: org.apache.activemq.leveldb.LevelDBStore parent()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.openwire.OpenWireFormat wireFormat()>();
v = virtualinvoke v.<org.apache.activemq.openwire.OpenWireFormat: org.apache.activemq.util.ByteSequence marshal(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: org.fusesource.hawtbuf.Buffer buffer(org.apache.activemq.util.ByteSequence)>(v);
v = <org.apache.activemq.leveldb.UowManagerConstants$: org.apache.activemq.leveldb.UowManagerConstants$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.UowManagerConstants$: int TRANSACTION_COLLECTION_TYPE()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: long createCollection(org.fusesource.hawtbuf.Buffer,int)>(v, v);
return v;
}
public void removeTransactionContainer(long)
{
org.apache.activemq.leveldb.DBManager$$anonfun$removeTransactionContainer$1 v;
org.fusesource.hawtdispatch.package$RichExecutor v;
org.fusesource.hawtdispatch.package$ v;
org.apache.activemq.leveldb.DBManager v;
long v;
java.util.concurrent.ExecutorService v;
v := @this: org.apache.activemq.leveldb.DBManager;
v := @parameter: long;
v = <org.fusesource.hawtdispatch.package$: org.fusesource.hawtdispatch.package$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: 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.DBManager$$anonfun$removeTransactionContainer$1;
specialinvoke v.<org.apache.activemq.leveldb.DBManager$$anonfun$removeTransactionContainer$1: void <init>(org.apache.activemq.leveldb.DBManager,long)>(v, v);
virtualinvoke v.<org.fusesource.hawtdispatch.package$RichExecutor: java.lang.Object sync(scala.Function)>(v);
return;
}
public void loadCollections()
{
org.fusesource.hawtdispatch.package$RichExecutor v;
long v;
java.util.concurrent.atomic.AtomicLong v;
org.fusesource.hawtdispatch.package$ v;
org.apache.activemq.leveldb.DBManager$$anonfun$3 v;
scala.runtime.LongRef v;
org.apache.activemq.leveldb.DBManager v;
java.lang.Object v;
java.util.concurrent.ExecutorService v;
org.apache.activemq.leveldb.DBManager$$anonfun$loadCollections$1 v;
v := @this: org.apache.activemq.leveldb.DBManager;
v = <org.fusesource.hawtdispatch.package$: org.fusesource.hawtdispatch.package$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: 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.DBManager$$anonfun$3;
specialinvoke v.<org.apache.activemq.leveldb.DBManager$$anonfun$3: void <init>(org.apache.activemq.leveldb.DBManager)>(v);
v = virtualinvoke v.<org.fusesource.hawtdispatch.package$RichExecutor: java.lang.Object sync(scala.Function)>(v);
v = staticinvoke <scala.runtime.LongRef: scala.runtime.LongRef create(long)>(0L);
v = new org.apache.activemq.leveldb.DBManager$$anonfun$loadCollections$1;
specialinvoke v.<org.apache.activemq.leveldb.DBManager$$anonfun$loadCollections$1: void <init>(org.apache.activemq.leveldb.DBManager,scala.runtime.LongRef)>(v, v);
interfaceinvoke v.<scala.collection.Seq: void foreach(scala.Function)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: java.util.concurrent.atomic.AtomicLong lastCollectionKey()>();
v = v.<scala.runtime.LongRef: long elem>;
virtualinvoke v.<java.util.concurrent.atomic.AtomicLong: void set(long)>(v);
return;
}
public org.apache.activemq.leveldb.LevelDBStore$LevelDBPList createPList(java.lang.String)
{
java.util.concurrent.atomic.AtomicLong v;
org.apache.activemq.leveldb.LevelDBStore$LevelDBPList v;
org.apache.activemq.leveldb.DBManager v;
long v;
java.lang.String v;
org.apache.activemq.leveldb.LevelDBStore v;
v := @this: org.apache.activemq.leveldb.DBManager;
v := @parameter: java.lang.String;
v = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: org.apache.activemq.leveldb.LevelDBStore parent()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: java.util.concurrent.atomic.AtomicLong lastPListKey()>();
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicLong: long incrementAndGet()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBStore: org.apache.activemq.leveldb.LevelDBStore$LevelDBPList createPList(java.lang.String,long)>(v, v);
return v;
}
public void destroyPList(long)
{
org.fusesource.hawtdispatch.package$RichExecutor v;
org.fusesource.hawtdispatch.package$ v;
org.apache.activemq.leveldb.DBManager$$anonfun$destroyPList$1 v;
org.apache.activemq.leveldb.DBManager v;
long v;
java.util.concurrent.ExecutorService v;
v := @this: org.apache.activemq.leveldb.DBManager;
v := @parameter: long;
v = <org.fusesource.hawtdispatch.package$: org.fusesource.hawtdispatch.package$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: 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.DBManager$$anonfun$destroyPList$1;
specialinvoke v.<org.apache.activemq.leveldb.DBManager$$anonfun$destroyPList$1: void <init>(org.apache.activemq.leveldb.DBManager,long)>(v, v);
virtualinvoke v.<org.fusesource.hawtdispatch.package$RichExecutor: java.lang.Object sync(scala.Function)>(v);
return;
}
public void plistPut(byte[], byte[])
{
byte[] v, v;
org.apache.activemq.leveldb.LevelDBClient v;
org.apache.activemq.leveldb.DBManager v;
v := @this: org.apache.activemq.leveldb.DBManager;
v := @parameter: byte[];
v := @parameter: byte[];
v = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: org.apache.activemq.leveldb.LevelDBClient client()>();
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: void plistPut(byte[],byte[])>(v, v);
return;
}
public scala.Option plistGet(byte[])
{
byte[] v;
org.apache.activemq.leveldb.LevelDBClient v;
org.apache.activemq.leveldb.DBManager v;
scala.Option v;
v := @this: org.apache.activemq.leveldb.DBManager;
v := @parameter: byte[];
v = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: org.apache.activemq.leveldb.LevelDBClient client()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: scala.Option plistGet(byte[])>(v);
return v;
}
public void plistDelete(byte[])
{
byte[] v;
org.apache.activemq.leveldb.DBManager v;
org.apache.activemq.leveldb.LevelDBClient v;
v := @this: org.apache.activemq.leveldb.DBManager;
v := @parameter: byte[];
v = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: org.apache.activemq.leveldb.LevelDBClient client()>();
virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: void plistDelete(byte[])>(v);
return;
}
public org.iq.leveldb.DBIterator plistIterator()
{
org.apache.activemq.leveldb.DBManager v;
org.apache.activemq.leveldb.LevelDBClient v;
org.iq.leveldb.DBIterator v;
v := @this: org.apache.activemq.leveldb.DBManager;
v = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: org.apache.activemq.leveldb.LevelDBClient client()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: org.iq.leveldb.DBIterator plistIterator()>();
return v;
}
public org.apache.activemq.command.Message getMessage(org.apache.activemq.command.MessageId)
{
java.lang.Object[] v;
org.apache.activemq.leveldb.DBManager$$anonfun$6 v;
org.apache.activemq.command.Message v;
scala.Option$ v;
org.apache.activemq.leveldb.LevelDBClient v;
scala.Predef$ v;
org.apache.activemq.leveldb.DBManager$$anonfun$4 v;
org.apache.activemq.leveldb.DBManager$$anonfun$5 v;
scala.collection.mutable.WrappedArray v;
org.apache.activemq.command.MessageId v;
java.util.concurrent.ConcurrentHashMap v;
org.apache.activemq.leveldb.LevelDBStore$ v;
scala.Option v, v, v;
org.apache.activemq.leveldb.DBManager$$anonfun$getMessage$1 v;
org.apache.activemq.leveldb.DBManager v;
java.lang.Object v, v, v;
v := @this: org.apache.activemq.leveldb.DBManager;
v := @parameter: org.apache.activemq.command.MessageId;
v = <scala.Option$: scala.Option$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: java.util.concurrent.ConcurrentHashMap pendingStores()>();
v = virtualinvoke v.<java.util.concurrent.ConcurrentHashMap: java.lang.Object get(java.lang.Object)>(v);
v = virtualinvoke v.<scala.Option$: scala.Option apply(java.lang.Object)>(v);
v = new org.apache.activemq.leveldb.DBManager$$anonfun$4;
specialinvoke v.<org.apache.activemq.leveldb.DBManager$$anonfun$4: void <init>(org.apache.activemq.leveldb.DBManager)>(v);
v = virtualinvoke v.<scala.Option: scala.Option flatMap(scala.Function)>(v);
v = new org.apache.activemq.leveldb.DBManager$$anonfun$5;
specialinvoke v.<org.apache.activemq.leveldb.DBManager$$anonfun$5: void <init>(org.apache.activemq.leveldb.DBManager)>(v);
v = virtualinvoke v.<scala.Option: scala.Option map(scala.Function)>(v);
v = new org.apache.activemq.leveldb.DBManager$$anonfun$6;
specialinvoke v.<org.apache.activemq.leveldb.DBManager$$anonfun$6: void <init>(org.apache.activemq.leveldb.DBManager,org.apache.activemq.command.MessageId)>(v, v);
v = virtualinvoke v.<scala.Option: java.lang.Object getOrElse(scala.Function)>(v);
v = virtualinvoke v.<org.apache.activemq.command.MessageId: java.lang.Object getDataLocator()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: org.apache.activemq.leveldb.LevelDBClient client()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.command.Message getMessage(java.lang.Object)>(v);
if v != null goto label;
v = <org.apache.activemq.leveldb.LevelDBStore$: org.apache.activemq.leveldb.LevelDBStore$ MODULE$>;
v = new org.apache.activemq.leveldb.DBManager$$anonfun$getMessage$1;
specialinvoke v.<org.apache.activemq.leveldb.DBManager$$anonfun$getMessage$1: void <init>(org.apache.activemq.leveldb.DBManager,org.apache.activemq.command.MessageId,java.lang.Object)>(v, 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.LevelDBStore$: void warn(scala.Function,scala.collection.Seq)>(v, v);
goto label;
label:
virtualinvoke v.<org.apache.activemq.command.Message: void setMessageId(org.apache.activemq.command.MessageId)>(v);
label:
return v;
}
public void <init>(org.apache.activemq.leveldb.LevelDBStore)
{
java.util.HashMap v;
org.apache.activemq.ActiveMQMessageAuditNoSync v;
org.fusesource.hawtdispatch.EventAggregator v;
java.util.LinkedHashMap v;
org.apache.activemq.leveldb.DBManager$$anonfun$1 v;
org.fusesource.hawtdispatch.package$ v, v, v;
java.util.concurrent.atomic.AtomicInteger v;
java.lang.String v;
org.apache.activemq.leveldb.util.TimeMetric v;
org.fusesource.hawtdispatch.Task v;
java.util.concurrent.ConcurrentHashMap v;
org.fusesource.hawtdispatch.DispatchQueue v, v;
org.apache.activemq.leveldb.LevelDBStore v;
java.util.concurrent.atomic.AtomicLong v, v, v;
org.fusesource.hawtdispatch.CustomDispatchSource v, v, v;
org.apache.activemq.leveldb.DBManager v;
v := @this: org.apache.activemq.leveldb.DBManager;
v := @parameter: org.apache.activemq.leveldb.LevelDBStore;
v.<org.apache.activemq.leveldb.DBManager: org.apache.activemq.leveldb.LevelDBStore parent> = v;
specialinvoke v.<java.lang.Object: void <init>()>();
v = new java.util.concurrent.atomic.AtomicLong;
specialinvoke v.<java.util.concurrent.atomic.AtomicLong: void <init>(long)>(0L);
v.<org.apache.activemq.leveldb.DBManager: java.util.concurrent.atomic.AtomicLong lastCollectionKey> = v;
v = new java.util.concurrent.atomic.AtomicLong;
specialinvoke v.<java.util.concurrent.atomic.AtomicLong: void <init>(long)>(0L);
v.<org.apache.activemq.leveldb.DBManager: java.util.concurrent.atomic.AtomicLong lastPListKey> = v;
v = <org.fusesource.hawtdispatch.package$: org.fusesource.hawtdispatch.package$ MODULE$>;
v = virtualinvoke v.<java.lang.Object: java.lang.String toString()>();
v = virtualinvoke v.<org.fusesource.hawtdispatch.package$: org.fusesource.hawtdispatch.DispatchQueue createQueue(java.lang.String)>(v);
v.<org.apache.activemq.leveldb.DBManager: org.fusesource.hawtdispatch.DispatchQueue dispatchQueue> = v;
v = new java.util.concurrent.atomic.AtomicLong;
specialinvoke v.<java.util.concurrent.atomic.AtomicLong: void <init>(long)>(0L);
v.<org.apache.activemq.leveldb.DBManager: java.util.concurrent.atomic.AtomicLong asyncCapacityRemaining> = v;
v.<org.apache.activemq.leveldb.DBManager: long uowEnqueueDelayReqested> = 0L;
v.<org.apache.activemq.leveldb.DBManager: long uowEnqueueNodelayReqested> = 0L;
v.<org.apache.activemq.leveldb.DBManager: long uowClosedCounter> = 0L;
v.<org.apache.activemq.leveldb.DBManager: long uowCanceledCounter> = 0L;
v.<org.apache.activemq.leveldb.DBManager: long uowStoringCounter> = 0L;
v.<org.apache.activemq.leveldb.DBManager: long uowStoredCounter> = 0L;
v = new org.apache.activemq.leveldb.util.TimeMetric;
specialinvoke v.<org.apache.activemq.leveldb.util.TimeMetric: void <init>()>();
v.<org.apache.activemq.leveldb.DBManager: org.apache.activemq.leveldb.util.TimeMetric uow_complete_latency> = v;
v = new java.util.concurrent.ConcurrentHashMap;
specialinvoke v.<java.util.concurrent.ConcurrentHashMap: void <init>()>();
v.<org.apache.activemq.leveldb.DBManager: java.util.concurrent.ConcurrentHashMap pendingStores> = v;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v.<org.apache.activemq.leveldb.DBManager: java.util.HashMap cancelable_enqueue_actions> = v;
v = new java.util.concurrent.atomic.AtomicInteger;
specialinvoke v.<java.util.concurrent.atomic.AtomicInteger: void <init>(int)>(1);
v.<org.apache.activemq.leveldb.DBManager: java.util.concurrent.atomic.AtomicInteger lastUowId> = v;
v = new org.apache.activemq.ActiveMQMessageAuditNoSync;
specialinvoke v.<org.apache.activemq.ActiveMQMessageAuditNoSync: void <init>()>();
v.<org.apache.activemq.leveldb.DBManager: org.apache.activemq.ActiveMQMessageAuditNoSync producerSequenceIdTracker> = v;
v = new java.util.LinkedHashMap;
specialinvoke v.<java.util.LinkedHashMap: void <init>()>();
v.<org.apache.activemq.leveldb.DBManager: java.util.LinkedHashMap flush_queue> = v;
v = <org.fusesource.hawtdispatch.package$: org.fusesource.hawtdispatch.package$ MODULE$>;
v = <org.fusesource.hawtdispatch.EventAggregators: org.fusesource.hawtdispatch.EventAggregator INTEGER_ADD>;
v = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: org.fusesource.hawtdispatch.DispatchQueue dispatchQueue()>();
v = virtualinvoke v.<org.fusesource.hawtdispatch.package$: org.fusesource.hawtdispatch.CustomDispatchSource createSource(org.fusesource.hawtdispatch.EventAggregator,org.fusesource.hawtdispatch.DispatchQueue)>(v, v);
v.<org.apache.activemq.leveldb.DBManager: org.fusesource.hawtdispatch.CustomDispatchSource flushSource> = v;
v = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: org.fusesource.hawtdispatch.CustomDispatchSource flushSource()>();
v = <org.fusesource.hawtdispatch.package$: org.fusesource.hawtdispatch.package$ MODULE$>;
v = new org.apache.activemq.leveldb.DBManager$$anonfun$1;
specialinvoke v.<org.apache.activemq.leveldb.DBManager$$anonfun$1: void <init>(org.apache.activemq.leveldb.DBManager)>(v);
v = virtualinvoke v.<org.fusesource.hawtdispatch.package$: org.fusesource.hawtdispatch.Task $up(scala.Function)>(v);
interfaceinvoke v.<org.fusesource.hawtdispatch.CustomDispatchSource: void setEventHandler(org.fusesource.hawtdispatch.Task)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.DBManager: org.fusesource.hawtdispatch.CustomDispatchSource flushSource()>();
interfaceinvoke v.<org.fusesource.hawtdispatch.CustomDispatchSource: void resume()>();
v.<org.apache.activemq.leveldb.DBManager: boolean started> = 0;
return;
}
}