public class org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$transfer_missing$2$$anonfun$apply$18 extends scala.runtime.AbstractFunction implements scala.Serializable
{
public static final long serialVersionUID;
private final org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$transfer_missing$2 $outer;
private final scala.runtime.LongRef append_offset$1;
public final void apply(org.fusesource.hawtbuf.Buffer)
{
org.apache.activemq.leveldb.RecordLog v;
byte v;
scala.collection.JavaConversions$ v;
org.fusesource.hawtdispatch.transport.TcpTransport v;
scala.collection.mutable.Buffer v;
org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$transfer_missing$2$$anonfun$apply$18 v;
java.lang.Object[] v;
long v, v, v, v, v, v;
org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$transfer_missing$2$$anonfun$apply$18$$anonfun$apply$4 v;
org.fusesource.hawtbuf.Buffer v;
org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$transfer_missing$2$$anonfun$apply$18$$anonfun$apply$5 v;
java.util.ArrayList v, v;
scala.collection.mutable.WrappedArray v;
org.fusesource.hawtdispatch.package$RichExecutor v;
org.fusesource.hawtdispatch.Task v;
java.io.File v;
org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$transfer_missing$2 v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.activemq.leveldb.replicated.ReplicationSupport$ v;
org.apache.activemq.leveldb.LevelDBClient v, v;
org.fusesource.hawtdispatch.package$ v, v;
org.apache.activemq.leveldb.replicated.SlaveLevelDBStore v, v, v, v, v, v, v, v, v, v, v, v, v, v;
scala.Predef$ v;
org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$transfer_missing$2$$anonfun$apply$18$$anonfun$apply$19 v;
java.util.concurrent.ExecutorService v;
org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$ v;
org.apache.activemq.leveldb.replicated.dto.SyncResponse v, v, v;
scala.runtime.LongRef v;
v := @this: org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$transfer_missing$2$$anonfun$apply$18;
v := @parameter: org.fusesource.hawtbuf.Buffer;
v = v.<org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$transfer_missing$2$$anonfun$apply$18: org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$transfer_missing$2 $outer>;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$transfer_missing$2: org.apache.activemq.leveldb.replicated.SlaveLevelDBStore org$apache$activemq$leveldb$replicated$SlaveLevelDBStore$$anonfun$$$outer()>();
virtualinvoke v.<org.apache.activemq.leveldb.replicated.SlaveLevelDBStore: void status_$eq(java.lang.String)>("Attached");
v = <org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$: org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$ MODULE$>;
v = new org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$transfer_missing$2$$anonfun$apply$18$$anonfun$apply$19;
specialinvoke v.<org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$transfer_missing$2$$anonfun$apply$18$$anonfun$apply$19: void <init>(org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$transfer_missing$2$$anonfun$apply$18)>(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.replicated.SlaveLevelDBStore$: void info(scala.Function,scala.collection.Seq)>(v, v);
v = <org.apache.activemq.leveldb.replicated.ReplicationSupport$: org.apache.activemq.leveldb.replicated.ReplicationSupport$ MODULE$>;
v = v.<org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$transfer_missing$2$$anonfun$apply$18: org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$transfer_missing$2 $outer>;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$transfer_missing$2: org.apache.activemq.leveldb.replicated.SlaveLevelDBStore org$apache$activemq$leveldb$replicated$SlaveLevelDBStore$$anonfun$$$outer()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.SlaveLevelDBStore: java.io.File directory()>();
virtualinvoke v.<org.apache.activemq.leveldb.replicated.ReplicationSupport$: void stash_clear(java.io.File)>(v);
v = v.<org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$transfer_missing$2$$anonfun$apply$18: org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$transfer_missing$2 $outer>;
v = v.<org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$transfer_missing$2: org.fusesource.hawtdispatch.transport.TcpTransport transport$1>;
v = <org.fusesource.hawtdispatch.package$: org.fusesource.hawtdispatch.package$ MODULE$>;
v = virtualinvoke v.<org.fusesource.hawtdispatch.package$: org.fusesource.hawtdispatch.Task NOOP()>();
virtualinvoke v.<org.fusesource.hawtdispatch.transport.TcpTransport: void stop(org.fusesource.hawtdispatch.Task)>(v);
v = v.<org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$transfer_missing$2$$anonfun$apply$18: org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$transfer_missing$2 $outer>;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$transfer_missing$2: org.apache.activemq.leveldb.replicated.SlaveLevelDBStore org$apache$activemq$leveldb$replicated$SlaveLevelDBStore$$anonfun$$$outer()>();
virtualinvoke v.<org.apache.activemq.leveldb.replicated.SlaveLevelDBStore: void transfer_session_$eq(org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$Session)>(null);
v = v.<org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$transfer_missing$2$$anonfun$apply$18: org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$transfer_missing$2 $outer>;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$transfer_missing$2: org.apache.activemq.leveldb.replicated.SlaveLevelDBStore org$apache$activemq$leveldb$replicated$SlaveLevelDBStore$$anonfun$$$outer()>();
v = v.<org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$transfer_missing$2$$anonfun$apply$18: org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$transfer_missing$2 $outer>;
v = v.<org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$transfer_missing$2: org.apache.activemq.leveldb.replicated.dto.SyncResponse state$1>;
v = v.<org.apache.activemq.leveldb.replicated.dto.SyncResponse: long snapshot_position>;
virtualinvoke v.<org.apache.activemq.leveldb.replicated.SlaveLevelDBStore: void replay_from_$eq(long)>(v);
v = v.<org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$transfer_missing$2$$anonfun$apply$18: org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$transfer_missing$2 $outer>;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$transfer_missing$2: org.apache.activemq.leveldb.replicated.SlaveLevelDBStore org$apache$activemq$leveldb$replicated$SlaveLevelDBStore$$anonfun$$$outer()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.SlaveLevelDBStore: long wal_append_position()>();
v = v.<org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$transfer_missing$2$$anonfun$apply$18: org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$transfer_missing$2 $outer>;
v = v.<org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$transfer_missing$2: org.apache.activemq.leveldb.replicated.dto.SyncResponse state$1>;
v = v.<org.apache.activemq.leveldb.replicated.dto.SyncResponse: long wal_append_position>;
v = v cmp v;
if v >= 0 goto label;
v = v.<org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$transfer_missing$2$$anonfun$apply$18: org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$transfer_missing$2 $outer>;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$transfer_missing$2: org.apache.activemq.leveldb.replicated.SlaveLevelDBStore org$apache$activemq$leveldb$replicated$SlaveLevelDBStore$$anonfun$$$outer()>();
v = v.<org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$transfer_missing$2$$anonfun$apply$18: org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$transfer_missing$2 $outer>;
v = v.<org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$transfer_missing$2: org.apache.activemq.leveldb.replicated.dto.SyncResponse state$1>;
v = v.<org.apache.activemq.leveldb.replicated.dto.SyncResponse: long wal_append_position>;
virtualinvoke v.<org.apache.activemq.leveldb.replicated.SlaveLevelDBStore: void wal_append_position_$eq(long)>(v);
v = v.<org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$transfer_missing$2$$anonfun$apply$18: org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$transfer_missing$2 $outer>;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$transfer_missing$2: org.apache.activemq.leveldb.replicated.SlaveLevelDBStore org$apache$activemq$leveldb$replicated$SlaveLevelDBStore$$anonfun$$$outer()>();
v = v.<org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$transfer_missing$2$$anonfun$apply$18: scala.runtime.LongRef append_offset$1>;
v = v.<scala.runtime.LongRef: long elem>;
virtualinvoke v.<org.apache.activemq.leveldb.replicated.SlaveLevelDBStore: void wal_append_offset_$eq(long)>(v);
label:
v = <org.fusesource.hawtdispatch.package$: org.fusesource.hawtdispatch.package$ MODULE$>;
v = v.<org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$transfer_missing$2$$anonfun$apply$18: org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$transfer_missing$2 $outer>;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$transfer_missing$2: org.apache.activemq.leveldb.replicated.SlaveLevelDBStore org$apache$activemq$leveldb$replicated$SlaveLevelDBStore$$anonfun$$$outer()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.SlaveLevelDBStore: org.apache.activemq.leveldb.LevelDBClient client()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: java.util.concurrent.ExecutorService writeExecutor()>();
v = virtualinvoke v.<org.fusesource.hawtdispatch.package$: org.fusesource.hawtdispatch.package$RichExecutor ExecutorWrapper(java.util.concurrent.Executor)>(v);
v = new org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$transfer_missing$2$$anonfun$apply$18$$anonfun$apply$4;
specialinvoke v.<org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$transfer_missing$2$$anonfun$apply$18$$anonfun$apply$4: void <init>(org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$transfer_missing$2$$anonfun$apply$18)>(v);
virtualinvoke v.<org.fusesource.hawtdispatch.package$RichExecutor: void apply(scala.Function)>(v);
v = v.<org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$transfer_missing$2$$anonfun$apply$18: org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$transfer_missing$2 $outer>;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$transfer_missing$2: org.apache.activemq.leveldb.replicated.SlaveLevelDBStore org$apache$activemq$leveldb$replicated$SlaveLevelDBStore$$anonfun$$$outer()>();
virtualinvoke v.<org.apache.activemq.leveldb.replicated.SlaveLevelDBStore: void caughtUp_$eq(boolean)>(1);
v = v.<org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$transfer_missing$2$$anonfun$apply$18: org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$transfer_missing$2 $outer>;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$transfer_missing$2: org.apache.activemq.leveldb.replicated.SlaveLevelDBStore org$apache$activemq$leveldb$replicated$SlaveLevelDBStore$$anonfun$$$outer()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.SlaveLevelDBStore: org.apache.activemq.leveldb.LevelDBClient client()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: org.apache.activemq.leveldb.RecordLog log()>();
v = v.<org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$transfer_missing$2$$anonfun$apply$18: org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$transfer_missing$2 $outer>;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$transfer_missing$2: org.apache.activemq.leveldb.replicated.SlaveLevelDBStore org$apache$activemq$leveldb$replicated$SlaveLevelDBStore$$anonfun$$$outer()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.SlaveLevelDBStore: long wal_append_offset()>();
virtualinvoke v.<org.apache.activemq.leveldb.RecordLog: java.lang.Object open(long)>(v);
v = v.<org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$transfer_missing$2$$anonfun$apply$18: org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$transfer_missing$2 $outer>;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$transfer_missing$2: org.apache.activemq.leveldb.replicated.SlaveLevelDBStore org$apache$activemq$leveldb$replicated$SlaveLevelDBStore$$anonfun$$$outer()>();
virtualinvoke v.<org.apache.activemq.leveldb.replicated.SlaveLevelDBStore: void send_wal_ack()>();
v = <scala.collection.JavaConversions$: scala.collection.JavaConversions$ MODULE$>;
v = v.<org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$transfer_missing$2$$anonfun$apply$18: org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$transfer_missing$2 $outer>;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$transfer_missing$2: org.apache.activemq.leveldb.replicated.SlaveLevelDBStore org$apache$activemq$leveldb$replicated$SlaveLevelDBStore$$anonfun$$$outer()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.SlaveLevelDBStore: java.util.ArrayList pending_log_removes()>();
v = virtualinvoke v.<scala.collection.JavaConversions$: scala.collection.mutable.Buffer asScalaBuffer(java.util.List)>(v);
v = new org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$transfer_missing$2$$anonfun$apply$18$$anonfun$apply$5;
specialinvoke v.<org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$transfer_missing$2$$anonfun$apply$18$$anonfun$apply$5: void <init>(org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$transfer_missing$2$$anonfun$apply$18)>(v);
interfaceinvoke v.<scala.collection.mutable.Buffer: void foreach(scala.Function)>(v);
v = v.<org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$transfer_missing$2$$anonfun$apply$18: org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$transfer_missing$2 $outer>;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$transfer_missing$2: org.apache.activemq.leveldb.replicated.SlaveLevelDBStore org$apache$activemq$leveldb$replicated$SlaveLevelDBStore$$anonfun$$$outer()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.SlaveLevelDBStore: java.util.ArrayList pending_log_removes()>();
virtualinvoke v.<java.util.ArrayList: void clear()>();
return;
}
public void <init>(org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$transfer_missing$2, scala.runtime.LongRef)
{
org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$transfer_missing$2 v;
scala.runtime.LongRef v;
org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$transfer_missing$2$$anonfun$apply$18 v;
v := @this: org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$transfer_missing$2$$anonfun$apply$18;
v := @parameter: org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$transfer_missing$2;
v := @parameter: scala.runtime.LongRef;
if v != null goto label;
throw null;
label:
v.<org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$transfer_missing$2$$anonfun$apply$18: org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$transfer_missing$2 $outer> = v;
v.<org.apache.activemq.leveldb.replicated.SlaveLevelDBStore$$anonfun$transfer_missing$2$$anonfun$apply$18: scala.runtime.LongRef append_offset$1> = v;
specialinvoke v.<scala.runtime.AbstractFunction1: void <init>()>();
return;
}
}