public class org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState extends java.lang.Object
{
private final java.lang.String slave_id;
private scala.Option held_snapshot;
private org.apache.activemq.leveldb.replicated.MasterLevelDBStore$Session session;
private java.util.concurrent.atomic.AtomicLong position;
private java.util.concurrent.atomic.AtomicBoolean caughtUp;
private java.net.SocketAddress socketAddress;
private org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState$DeferredReplicationFrame unflushed_replication_frame;
private volatile org.apache.activemq.leveldb.replicated.PositionSync last_position_sync;
public final org.apache.activemq.leveldb.replicated.MasterLevelDBStore $outer;
public java.lang.String slave_id()
{
java.lang.String v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState;
v = v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState: java.lang.String slave_id>;
return v;
}
public scala.Option held_snapshot()
{
scala.Option v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState;
v = v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState: scala.Option held_snapshot>;
return v;
}
public void held_snapshot_$eq(scala.Option)
{
scala.Option v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState;
v := @parameter: scala.Option;
v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState: scala.Option held_snapshot> = v;
return;
}
public org.apache.activemq.leveldb.replicated.MasterLevelDBStore$Session session()
{
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$Session v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState;
v = v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$Session session>;
return v;
}
public void session_$eq(org.apache.activemq.leveldb.replicated.MasterLevelDBStore$Session)
{
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$Session v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState;
v := @parameter: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$Session;
v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$Session session> = v;
return;
}
public java.util.concurrent.atomic.AtomicLong position()
{
java.util.concurrent.atomic.AtomicLong v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState;
v = v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState: java.util.concurrent.atomic.AtomicLong position>;
return v;
}
public void position_$eq(java.util.concurrent.atomic.AtomicLong)
{
java.util.concurrent.atomic.AtomicLong v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState;
v := @parameter: java.util.concurrent.atomic.AtomicLong;
v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState: java.util.concurrent.atomic.AtomicLong position> = v;
return;
}
public java.util.concurrent.atomic.AtomicBoolean caughtUp()
{
java.util.concurrent.atomic.AtomicBoolean v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState;
v = v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState: java.util.concurrent.atomic.AtomicBoolean caughtUp>;
return v;
}
public void caughtUp_$eq(java.util.concurrent.atomic.AtomicBoolean)
{
java.util.concurrent.atomic.AtomicBoolean v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState;
v := @parameter: java.util.concurrent.atomic.AtomicBoolean;
v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState: java.util.concurrent.atomic.AtomicBoolean caughtUp> = v;
return;
}
public java.net.SocketAddress socketAddress()
{
java.net.SocketAddress v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState;
v = v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState: java.net.SocketAddress socketAddress>;
return v;
}
public void socketAddress_$eq(java.net.SocketAddress)
{
java.net.SocketAddress v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState;
v := @parameter: java.net.SocketAddress;
v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState: java.net.SocketAddress socketAddress> = v;
return;
}
public void start(org.apache.activemq.leveldb.replicated.MasterLevelDBStore$Session)
{
java.net.SocketAddress v;
org.apache.activemq.leveldb.LevelDBClient v;
org.fusesource.hawtdispatch.package$ v, v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore v, v, v;
java.lang.Long v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$ v, v;
org.fusesource.hawtdispatch.DispatchQueue v, v, v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$Session v, v, v;
java.lang.Throwable v;
java.lang.Object[] v, v;
org.fusesource.hawtdispatch.transport.TransportServer v;
long v;
org.fusesource.hawtdispatch.package$RichDispatchQueue v;
scala.collection.mutable.StringBuilder v, v, v, v;
scala.Option$ v;
org.fusesource.hawtdispatch.transport.Transport v, v;
scala.Predef$ v, v;
java.lang.String v, v, v;
scala.collection.mutable.WrappedArray v, v;
org.fusesource.hawtdispatch.Task v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState$$anonfun$start$2 v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState$$anonfun$start$1 v;
scala.Option v;
org.apache.activemq.leveldb.replicated.dto.SyncResponse v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState$$anonfun$start$3 v;
java.util.concurrent.atomic.AtomicLong v;
org.apache.activemq.leveldb.replicated.MasterLevelDBClient v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState;
v := @parameter: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$Session;
v = <org.apache.activemq.leveldb.replicated.MasterLevelDBStore$: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$ MODULE$>;
v = new org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState$$anonfun$start$2;
specialinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState$$anonfun$start$2: void <init>(org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState)>(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.MasterLevelDBStore$: void debug(scala.Function,scala.collection.Seq)>(v, v);
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$Session: org.fusesource.hawtdispatch.transport.Transport transport()>();
v = interfaceinvoke v.<org.fusesource.hawtdispatch.transport.Transport: java.net.SocketAddress getRemoteAddress()>();
virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState: void socketAddress_$eq(java.net.SocketAddress)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$Session: org.fusesource.hawtdispatch.DispatchQueue queue()>();
v = new scala.collection.mutable.StringBuilder;
specialinvoke v.<scala.collection.mutable.StringBuilder: void <init>()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState: org.apache.activemq.leveldb.replicated.MasterLevelDBStore org$apache$activemq$leveldb$replicated$MasterLevelDBStore$SlaveState$$$outer()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: org.fusesource.hawtdispatch.transport.TransportServer transport_server()>();
v = interfaceinvoke v.<org.fusesource.hawtdispatch.transport.TransportServer: org.fusesource.hawtdispatch.DispatchQueue getDispatchQueue()>();
v = interfaceinvoke v.<org.fusesource.hawtdispatch.DispatchQueue: java.lang.String getLabel()>();
v = virtualinvoke v.<scala.collection.mutable.StringBuilder: scala.collection.mutable.StringBuilder append(java.lang.Object)>(v);
v = virtualinvoke v.<scala.collection.mutable.StringBuilder: scala.collection.mutable.StringBuilder append(java.lang.Object)>(" -> ");
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState: java.lang.String slave_id()>();
v = virtualinvoke v.<scala.collection.mutable.StringBuilder: scala.collection.mutable.StringBuilder append(java.lang.Object)>(v);
v = virtualinvoke v.<scala.collection.mutable.StringBuilder: java.lang.String toString()>();
interfaceinvoke v.<org.fusesource.hawtdispatch.DispatchQueue: void setLabel(java.lang.String)>(v);
entermonitor v;
label:
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$Session session()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$Session session()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$Session: org.fusesource.hawtdispatch.transport.Transport transport()>();
v = <org.fusesource.hawtdispatch.package$: org.fusesource.hawtdispatch.package$ MODULE$>;
v = virtualinvoke v.<org.fusesource.hawtdispatch.package$: org.fusesource.hawtdispatch.Task NOOP()>();
interfaceinvoke v.<org.fusesource.hawtdispatch.transport.Transport: void stop(org.fusesource.hawtdispatch.Task)>(v);
label:
virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState: void session_$eq(org.apache.activemq.leveldb.replicated.MasterLevelDBStore$Session)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState: org.apache.activemq.leveldb.replicated.MasterLevelDBStore org$apache$activemq$leveldb$replicated$MasterLevelDBStore$SlaveState$$$outer()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: org.apache.activemq.leveldb.LevelDBClient client()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: long lastIndexSnapshotPos()>();
v = <scala.Option$: scala.Option$ MODULE$>;
v = staticinvoke <scala.runtime.BoxesRunTime: java.lang.Long boxToLong(long)>(v);
v = virtualinvoke v.<scala.Option$: scala.Option apply(java.lang.Object)>(v);
virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState: void held_snapshot_$eq(scala.Option)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState: java.util.concurrent.atomic.AtomicLong position()>();
virtualinvoke v.<java.util.concurrent.atomic.AtomicLong: void set(long)>(0L);
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState: org.apache.activemq.leveldb.replicated.MasterLevelDBStore org$apache$activemq$leveldb$replicated$MasterLevelDBStore$SlaveState$$$outer()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: org.apache.activemq.leveldb.replicated.MasterLevelDBClient master_client()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBClient: org.apache.activemq.leveldb.replicated.dto.SyncResponse snapshot_state(long)>(v);
exitmonitor v;
label:
v = <org.apache.activemq.leveldb.replicated.MasterLevelDBStore$: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$ MODULE$>;
v = new org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState$$anonfun$start$3;
specialinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState$$anonfun$start$3: void <init>(org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState)>(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.MasterLevelDBStore$: void info(scala.Function,scala.collection.Seq)>(v, v);
v = <org.fusesource.hawtdispatch.package$: org.fusesource.hawtdispatch.package$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$Session: org.fusesource.hawtdispatch.DispatchQueue queue()>();
v = virtualinvoke v.<org.fusesource.hawtdispatch.package$: org.fusesource.hawtdispatch.package$RichDispatchQueue DispatchQueueWrapper(org.fusesource.hawtdispatch.DispatchQueue)>(v);
v = new org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState$$anonfun$start$1;
specialinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState$$anonfun$start$1: void <init>(org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState,org.apache.activemq.leveldb.replicated.MasterLevelDBStore$Session,org.apache.activemq.leveldb.replicated.dto.SyncResponse)>(v, v, v);
virtualinvoke v.<org.fusesource.hawtdispatch.package$RichDispatchQueue: void apply(scala.Function)>(v);
return;
label:
v := @caughtexception;
exitmonitor v;
throw v;
catch java.lang.Throwable from label to label with label;
}
public synchronized boolean stop(org.apache.activemq.leveldb.replicated.MasterLevelDBStore$Session)
{
scala.collection.mutable.WrappedArray v;
java.lang.Object[] v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState$$anonfun$stop$1 v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$Session v, v;
scala.Predef$ v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$ v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState v;
boolean v, v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState;
v := @parameter: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$Session;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$Session session()>();
if v != null goto label;
if v == null goto label;
goto label;
label:
v = virtualinvoke v.<java.lang.Object: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
label:
v = <org.apache.activemq.leveldb.replicated.MasterLevelDBStore$: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$ MODULE$>;
v = new org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState$$anonfun$stop$1;
specialinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState$$anonfun$stop$1: void <init>(org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState)>(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.MasterLevelDBStore$: void info(scala.Function,scala.collection.Seq)>(v, v);
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public void queue(scala.Function)
{
java.lang.Throwable v;
scala.Function v;
org.fusesource.hawtdispatch.DispatchQueue v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$Session v;
org.fusesource.hawtdispatch.package$RichDispatchQueue v;
org.fusesource.hawtdispatch.package$ v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState$$anonfun$queue$1 v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState;
v := @parameter: scala.Function;
entermonitor v;
label:
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$Session session()>();
exitmonitor v;
label:
if v == null goto label;
v = <org.fusesource.hawtdispatch.package$: org.fusesource.hawtdispatch.package$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$Session: org.fusesource.hawtdispatch.DispatchQueue queue()>();
v = virtualinvoke v.<org.fusesource.hawtdispatch.package$: org.fusesource.hawtdispatch.package$RichDispatchQueue DispatchQueueWrapper(org.fusesource.hawtdispatch.DispatchQueue)>(v);
v = new org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState$$anonfun$queue$1;
specialinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState$$anonfun$queue$1: void <init>(org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState,scala.Function)>(v, v);
virtualinvoke v.<org.fusesource.hawtdispatch.package$RichDispatchQueue: void apply(scala.Function)>(v);
label:
return;
label:
v := @caughtexception;
exitmonitor v;
throw v;
catch java.lang.Throwable from label to label with label;
}
public void replicate(org.apache.activemq.leveldb.replicated.dto.LogDelete)
{
org.apache.activemq.leveldb.util.JsonCodec$ v;
org.fusesource.hawtbuf.Buffer v;
org.apache.activemq.leveldb.replicated.dto.LogDelete v;
org.apache.activemq.leveldb.replicated.ReplicationFrame v;
org.fusesource.hawtbuf.AsciiBuffer v;
org.apache.activemq.leveldb.replicated.ReplicationSupport$ v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState$$anonfun$replicate$1 v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState;
v := @parameter: org.apache.activemq.leveldb.replicated.dto.LogDelete;
v = new org.apache.activemq.leveldb.replicated.ReplicationFrame;
v = <org.apache.activemq.leveldb.replicated.ReplicationSupport$: org.apache.activemq.leveldb.replicated.ReplicationSupport$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.ReplicationSupport$: org.fusesource.hawtbuf.AsciiBuffer LOG_DELETE_ACTION()>();
v = <org.apache.activemq.leveldb.util.JsonCodec$: org.apache.activemq.leveldb.util.JsonCodec$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.util.JsonCodec$: org.fusesource.hawtbuf.Buffer encode(java.lang.Object)>(v);
specialinvoke v.<org.apache.activemq.leveldb.replicated.ReplicationFrame: void <init>(org.fusesource.hawtbuf.AsciiBuffer,org.fusesource.hawtbuf.Buffer)>(v, v);
v = new org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState$$anonfun$replicate$1;
specialinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState$$anonfun$replicate$1: void <init>(org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState,org.apache.activemq.leveldb.replicated.ReplicationFrame)>(v, v);
virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState: void queue(scala.Function)>(v);
return;
}
public org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState$DeferredReplicationFrame unflushed_replication_frame()
{
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState$DeferredReplicationFrame v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState;
v = v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState$DeferredReplicationFrame unflushed_replication_frame>;
return v;
}
public void unflushed_replication_frame_$eq(org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState$DeferredReplicationFrame)
{
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState$DeferredReplicationFrame v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState;
v := @parameter: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState$DeferredReplicationFrame;
v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState$DeferredReplicationFrame unflushed_replication_frame> = v;
return;
}
public void replicate(java.io.File, long, long, long)
{
long v, v, v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState v;
java.io.File v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState$$anonfun$replicate$2 v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState;
v := @parameter: java.io.File;
v := @parameter: long;
v := @parameter: long;
v := @parameter: long;
v = new org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState$$anonfun$replicate$2;
specialinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState$$anonfun$replicate$2: void <init>(org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState,java.io.File,long,long,long)>(v, v, v, v, v);
virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState: void queue(scala.Function)>(v);
return;
}
public void position_update(long)
{
java.util.concurrent.atomic.AtomicLong v;
long v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState;
v := @parameter: long;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState: java.util.concurrent.atomic.AtomicLong position()>();
virtualinvoke v.<java.util.concurrent.atomic.AtomicLong: long getAndSet(long)>(v);
virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState: void check_position_sync()>();
return;
}
public org.apache.activemq.leveldb.replicated.PositionSync last_position_sync()
{
org.apache.activemq.leveldb.replicated.PositionSync v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState;
v = v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState: org.apache.activemq.leveldb.replicated.PositionSync last_position_sync>;
return v;
}
public void last_position_sync_$eq(org.apache.activemq.leveldb.replicated.PositionSync)
{
org.apache.activemq.leveldb.replicated.PositionSync v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState;
v := @parameter: org.apache.activemq.leveldb.replicated.PositionSync;
v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState: org.apache.activemq.leveldb.replicated.PositionSync last_position_sync> = v;
return;
}
public void check_position_sync()
{
java.lang.Throwable v;
java.lang.Object[] v;
java.util.concurrent.atomic.AtomicBoolean v;
long v, v;
byte v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore v;
scala.Predef$ v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$ v;
org.apache.activemq.leveldb.replicated.PositionSync v, v;
boolean v, v;
scala.collection.mutable.WrappedArray v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState$$anonfun$check_position_sync$1 v;
scala.runtime.BoxedUnit v, v;
scala.None$ v;
java.util.concurrent.atomic.AtomicLong v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState: org.apache.activemq.leveldb.replicated.MasterLevelDBStore org$apache$activemq$leveldb$replicated$MasterLevelDBStore$SlaveState$$$outer()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: org.apache.activemq.leveldb.replicated.PositionSync position_sync()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState: org.apache.activemq.leveldb.replicated.PositionSync last_position_sync()>();
if v != null goto label;
if v == null goto label;
goto label;
label:
v = virtualinvoke v.<java.lang.Object: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
label:
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState: java.util.concurrent.atomic.AtomicLong position()>();
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicLong: long get()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.PositionSync: long position()>();
v = v cmp v;
if v < 0 goto label;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState: java.util.concurrent.atomic.AtomicBoolean caughtUp()>();
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: boolean compareAndSet(boolean,boolean)>(0, 1);
if v == 0 goto label;
v = <org.apache.activemq.leveldb.replicated.MasterLevelDBStore$: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$ MODULE$>;
v = new org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState$$anonfun$check_position_sync$1;
specialinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState$$anonfun$check_position_sync$1: void <init>(org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState)>(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.MasterLevelDBStore$: void info(scala.Function,scala.collection.Seq)>(v, v);
entermonitor v;
label:
v = <scala.None$: scala.None$ MODULE$>;
virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState: void held_snapshot_$eq(scala.Option)>(v);
v = <scala.runtime.BoxedUnit: scala.runtime.BoxedUnit UNIT>;
exitmonitor v;
label:
goto label;
label:
v = <scala.runtime.BoxedUnit: scala.runtime.BoxedUnit UNIT>;
label:
virtualinvoke v.<org.apache.activemq.leveldb.replicated.PositionSync: void countDown()>();
virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState: void last_position_sync_$eq(org.apache.activemq.leveldb.replicated.PositionSync)>(v);
label:
return;
label:
v := @caughtexception;
exitmonitor v;
throw v;
catch java.lang.Throwable from label to label with label;
}
public boolean isCaughtUp()
{
java.util.concurrent.atomic.AtomicBoolean v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState v;
boolean v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState: java.util.concurrent.atomic.AtomicBoolean caughtUp()>();
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: boolean get()>();
return v;
}
public org.apache.activemq.leveldb.replicated.SlaveStatus status()
{
java.net.SocketAddress v;
long v;
java.util.concurrent.atomic.AtomicLong v;
org.apache.activemq.leveldb.replicated.SlaveStatus v;
java.lang.String v, v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState v;
boolean v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState;
v = new org.apache.activemq.leveldb.replicated.SlaveStatus;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState: java.lang.String slave_id()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState: java.net.SocketAddress socketAddress()>();
v = virtualinvoke v.<java.lang.Object: java.lang.String toString()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState: boolean isCaughtUp()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState: java.util.concurrent.atomic.AtomicLong position()>();
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicLong: long get()>();
specialinvoke v.<org.apache.activemq.leveldb.replicated.SlaveStatus: void <init>(java.lang.String,java.lang.String,boolean,long)>(v, v, v, v);
return v;
}
public void <init>(org.apache.activemq.leveldb.replicated.MasterLevelDBStore, java.lang.String)
{
java.util.concurrent.atomic.AtomicLong v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore v;
java.util.concurrent.atomic.AtomicBoolean v;
java.lang.String v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState v;
scala.None$ v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState;
v := @parameter: org.apache.activemq.leveldb.replicated.MasterLevelDBStore;
v := @parameter: java.lang.String;
v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState: java.lang.String slave_id> = v;
if v != null goto label;
throw null;
label:
v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState: org.apache.activemq.leveldb.replicated.MasterLevelDBStore $outer> = v;
specialinvoke v.<java.lang.Object: void <init>()>();
v = <scala.None$: scala.None$ MODULE$>;
v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState: scala.Option held_snapshot> = v;
v = new java.util.concurrent.atomic.AtomicLong;
specialinvoke v.<java.util.concurrent.atomic.AtomicLong: void <init>(long)>(0L);
v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState: java.util.concurrent.atomic.AtomicLong position> = v;
v = new java.util.concurrent.atomic.AtomicBoolean;
specialinvoke v.<java.util.concurrent.atomic.AtomicBoolean: void <init>(boolean)>(0);
v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState: java.util.concurrent.atomic.AtomicBoolean caughtUp> = v;
v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState$DeferredReplicationFrame unflushed_replication_frame> = null;
v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$SlaveState: org.apache.activemq.leveldb.replicated.PositionSync last_position_sync> = null;
return;
}
}