public class org.apache.activemq.leveldb.replicated.MasterLevelDBStore extends org.apache.activemq.leveldb.LevelDBStore implements org.apache.activemq.leveldb.replicated.ReplicatedLevelDBStoreTrait
{
private java.lang.String bind;
private int replicas;
private java.lang.String _syncTo;
private int syncToMask;
private final java.util.concurrent.ConcurrentHashMap slaves;
private org.fusesource.hawtdispatch.transport.TransportServer transport_server;
private final java.util.concurrent.CountDownLatch start_latch;
private volatile org.apache.activemq.leveldb.replicated.PositionSync position_sync;
private volatile long wal_date;
private java.lang.String securityToken;
public static void trace(java.lang.Throwable)
{
java.lang.Throwable v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$ v;
v := @parameter: java.lang.Throwable;
v = <org.apache.activemq.leveldb.replicated.MasterLevelDBStore$: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$ MODULE$>;
virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$: void trace(java.lang.Throwable)>(v);
return;
}
public static void trace(java.lang.Throwable, scala.Function, scala.collection.Seq)
{
java.lang.Throwable v;
scala.collection.Seq v;
scala.Function v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$ v;
v := @parameter: java.lang.Throwable;
v := @parameter: scala.Function;
v := @parameter: scala.collection.Seq;
v = <org.apache.activemq.leveldb.replicated.MasterLevelDBStore$: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$ MODULE$>;
virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$: void trace(java.lang.Throwable,scala.Function,scala.collection.Seq)>(v, v, v);
return;
}
public static void trace(scala.Function, scala.collection.Seq)
{
scala.Function v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$ v;
scala.collection.Seq v;
v := @parameter: scala.Function;
v := @parameter: scala.collection.Seq;
v = <org.apache.activemq.leveldb.replicated.MasterLevelDBStore$: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$ MODULE$>;
virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$: void trace(scala.Function,scala.collection.Seq)>(v, v);
return;
}
public static void debug(java.lang.Throwable)
{
java.lang.Throwable v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$ v;
v := @parameter: java.lang.Throwable;
v = <org.apache.activemq.leveldb.replicated.MasterLevelDBStore$: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$ MODULE$>;
virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$: void debug(java.lang.Throwable)>(v);
return;
}
public static void debug(java.lang.Throwable, scala.Function, scala.collection.Seq)
{
java.lang.Throwable v;
scala.collection.Seq v;
scala.Function v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$ v;
v := @parameter: java.lang.Throwable;
v := @parameter: scala.Function;
v := @parameter: scala.collection.Seq;
v = <org.apache.activemq.leveldb.replicated.MasterLevelDBStore$: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$ MODULE$>;
virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$: void debug(java.lang.Throwable,scala.Function,scala.collection.Seq)>(v, v, v);
return;
}
public static void debug(scala.Function, scala.collection.Seq)
{
scala.Function v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$ v;
scala.collection.Seq v;
v := @parameter: scala.Function;
v := @parameter: scala.collection.Seq;
v = <org.apache.activemq.leveldb.replicated.MasterLevelDBStore$: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$ MODULE$>;
virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$: void debug(scala.Function,scala.collection.Seq)>(v, v);
return;
}
public static void info(java.lang.Throwable)
{
java.lang.Throwable v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$ v;
v := @parameter: java.lang.Throwable;
v = <org.apache.activemq.leveldb.replicated.MasterLevelDBStore$: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$ MODULE$>;
virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$: void info(java.lang.Throwable)>(v);
return;
}
public static void info(java.lang.Throwable, scala.Function, scala.collection.Seq)
{
java.lang.Throwable v;
scala.collection.Seq v;
scala.Function v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$ v;
v := @parameter: java.lang.Throwable;
v := @parameter: scala.Function;
v := @parameter: scala.collection.Seq;
v = <org.apache.activemq.leveldb.replicated.MasterLevelDBStore$: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$ MODULE$>;
virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$: void info(java.lang.Throwable,scala.Function,scala.collection.Seq)>(v, v, v);
return;
}
public static void info(scala.Function, scala.collection.Seq)
{
scala.Function v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$ v;
scala.collection.Seq v;
v := @parameter: scala.Function;
v := @parameter: scala.collection.Seq;
v = <org.apache.activemq.leveldb.replicated.MasterLevelDBStore$: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$ MODULE$>;
virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$: void info(scala.Function,scala.collection.Seq)>(v, v);
return;
}
public static void warn(java.lang.Throwable)
{
java.lang.Throwable v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$ v;
v := @parameter: java.lang.Throwable;
v = <org.apache.activemq.leveldb.replicated.MasterLevelDBStore$: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$ MODULE$>;
virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$: void warn(java.lang.Throwable)>(v);
return;
}
public static void warn(java.lang.Throwable, scala.Function, scala.collection.Seq)
{
java.lang.Throwable v;
scala.collection.Seq v;
scala.Function v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$ v;
v := @parameter: java.lang.Throwable;
v := @parameter: scala.Function;
v := @parameter: scala.collection.Seq;
v = <org.apache.activemq.leveldb.replicated.MasterLevelDBStore$: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$ MODULE$>;
virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$: void warn(java.lang.Throwable,scala.Function,scala.collection.Seq)>(v, v, v);
return;
}
public static void warn(scala.Function, scala.collection.Seq)
{
scala.Function v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$ v;
scala.collection.Seq v;
v := @parameter: scala.Function;
v := @parameter: scala.collection.Seq;
v = <org.apache.activemq.leveldb.replicated.MasterLevelDBStore$: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$ MODULE$>;
virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$: void warn(scala.Function,scala.collection.Seq)>(v, v);
return;
}
public static void error(java.lang.Throwable)
{
java.lang.Throwable v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$ v;
v := @parameter: java.lang.Throwable;
v = <org.apache.activemq.leveldb.replicated.MasterLevelDBStore$: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$ MODULE$>;
virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$: void error(java.lang.Throwable)>(v);
return;
}
public static void error(java.lang.Throwable, scala.Function, scala.collection.Seq)
{
java.lang.Throwable v;
scala.collection.Seq v;
scala.Function v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$ v;
v := @parameter: java.lang.Throwable;
v := @parameter: scala.Function;
v := @parameter: scala.collection.Seq;
v = <org.apache.activemq.leveldb.replicated.MasterLevelDBStore$: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$ MODULE$>;
virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$: void error(java.lang.Throwable,scala.Function,scala.collection.Seq)>(v, v, v);
return;
}
public static void error(scala.Function, scala.collection.Seq)
{
scala.Function v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$ v;
scala.collection.Seq v;
v := @parameter: scala.Function;
v := @parameter: scala.collection.Seq;
v = <org.apache.activemq.leveldb.replicated.MasterLevelDBStore$: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$ MODULE$>;
virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$: void error(scala.Function,scala.collection.Seq)>(v, v);
return;
}
public static void org$apache$activemq$leveldb$util$Log$_setter_$log_$eq(org.slf4j.Logger)
{
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$ v;
org.slf4j.Logger v;
v := @parameter: org.slf4j.Logger;
v = <org.apache.activemq.leveldb.replicated.MasterLevelDBStore$: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$ MODULE$>;
virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$: void org$apache$activemq$leveldb$util$Log$_setter_$log_$eq(org.slf4j.Logger)>(v);
return;
}
public static org.slf4j.Logger log()
{
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$ v;
org.slf4j.Logger v;
v = <org.apache.activemq.leveldb.replicated.MasterLevelDBStore$: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$: org.slf4j.Logger log()>();
return v;
}
public static int SYNC_TO_REMOTE_DISK()
{
int v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$ v;
v = <org.apache.activemq.leveldb.replicated.MasterLevelDBStore$: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$: int SYNC_TO_REMOTE_DISK()>();
return v;
}
public static int SYNC_TO_REMOTE_MEMORY()
{
int v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$ v;
v = <org.apache.activemq.leveldb.replicated.MasterLevelDBStore$: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$: int SYNC_TO_REMOTE_MEMORY()>();
return v;
}
public static int SYNC_TO_REMOTE()
{
int v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$ v;
v = <org.apache.activemq.leveldb.replicated.MasterLevelDBStore$: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$: int SYNC_TO_REMOTE()>();
return v;
}
public static int SYNC_TO_DISK()
{
int v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$ v;
v = <org.apache.activemq.leveldb.replicated.MasterLevelDBStore$: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$: int SYNC_TO_DISK()>();
return v;
}
public java.lang.String securityToken()
{
java.lang.String v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore;
v = v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: java.lang.String securityToken>;
return v;
}
public void securityToken_$eq(java.lang.String)
{
java.lang.String v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore;
v := @parameter: java.lang.String;
v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: java.lang.String securityToken> = v;
return;
}
public java.lang.String getSecurityToken()
{
java.lang.String v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore;
v = staticinvoke <org.apache.activemq.leveldb.replicated.ReplicatedLevelDBStoreTrait$class: java.lang.String getSecurityToken(org.apache.activemq.leveldb.replicated.ReplicatedLevelDBStoreTrait)>(v);
return v;
}
public void setSecurityToken(java.lang.String)
{
java.lang.String v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore;
v := @parameter: java.lang.String;
staticinvoke <org.apache.activemq.leveldb.replicated.ReplicatedLevelDBStoreTrait$class: void setSecurityToken(org.apache.activemq.leveldb.replicated.ReplicatedLevelDBStoreTrait,java.lang.String)>(v, v);
return;
}
public java.lang.String node_id()
{
java.lang.String v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore;
v = staticinvoke <org.apache.activemq.leveldb.replicated.ReplicatedLevelDBStoreTrait$class: java.lang.String node_id(org.apache.activemq.leveldb.replicated.ReplicatedLevelDBStoreTrait)>(v);
return v;
}
public java.lang.String storeId()
{
java.lang.String v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore;
v = staticinvoke <org.apache.activemq.leveldb.replicated.ReplicatedLevelDBStoreTrait$class: java.lang.String storeId(org.apache.activemq.leveldb.replicated.ReplicatedLevelDBStoreTrait)>(v);
return v;
}
public void storeId_$eq(java.lang.String)
{
java.lang.String v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore;
v := @parameter: java.lang.String;
staticinvoke <org.apache.activemq.leveldb.replicated.ReplicatedLevelDBStoreTrait$class: void storeId_$eq(org.apache.activemq.leveldb.replicated.ReplicatedLevelDBStoreTrait,java.lang.String)>(v, v);
return;
}
public java.lang.String bind()
{
java.lang.String v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore;
v = v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: java.lang.String bind>;
return v;
}
public void bind_$eq(java.lang.String)
{
java.lang.String v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore;
v := @parameter: java.lang.String;
v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: java.lang.String bind> = v;
return;
}
public void setBind(java.lang.String)
{
java.lang.String v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore;
v := @parameter: java.lang.String;
v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: java.lang.String bind> = v;
return;
}
public int replicas()
{
int v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore;
v = v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: int replicas>;
return v;
}
public void replicas_$eq(int)
{
int v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore;
v := @parameter: int;
v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: int replicas> = v;
return;
}
public void setReplicas(int)
{
int v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore;
v := @parameter: int;
v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: int replicas> = v;
return;
}
public int minSlaveAcks()
{
int v, v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: int replicas()>();
v = v / 2;
return v;
}
public java.lang.String _syncTo()
{
java.lang.String v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore;
v = v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: java.lang.String _syncTo>;
return v;
}
public void _syncTo_$eq(java.lang.String)
{
java.lang.String v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore;
v := @parameter: java.lang.String;
v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: java.lang.String _syncTo> = v;
return;
}
public int syncToMask()
{
int v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore;
v = v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: int syncToMask>;
return v;
}
public void syncToMask_$eq(int)
{
int v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore;
v := @parameter: int;
v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: int syncToMask> = v;
return;
}
public java.lang.String syncTo()
{
java.lang.String v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: java.lang.String _syncTo()>();
return v;
}
public void syncTo_$eq(java.lang.String)
{
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$$anonfun$syncTo_$eq$1 v;
scala.reflect.ClassTag v;
java.lang.String[] v;
scala.reflect.ClassTag$ v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore v;
scala.Predef$ v, v;
java.lang.Object v;
scala.collection.mutable.ArrayOps v, v;
java.lang.String v;
scala.Array$ v;
scala.collection.generic.CanBuildFrom v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$$anonfun$syncTo_$eq$2 v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore;
v := @parameter: java.lang.String;
virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: void _syncTo_$eq(java.lang.String)>(v);
virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: void syncToMask_$eq(int)>(0);
v = <scala.Predef$: scala.Predef$ MODULE$>;
v = <scala.Predef$: scala.Predef$ MODULE$>;
v = virtualinvoke v.<java.lang.String: java.lang.String[] split(java.lang.String)>(",");
v = virtualinvoke v.<scala.Predef$: scala.collection.mutable.ArrayOps refArrayOps(java.lang.Object[])>(v);
v = new org.apache.activemq.leveldb.replicated.MasterLevelDBStore$$anonfun$syncTo_$eq$1;
specialinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$$anonfun$syncTo_$eq$1: void <init>(org.apache.activemq.leveldb.replicated.MasterLevelDBStore)>(v);
v = <scala.Array$: scala.Array$ MODULE$>;
v = <scala.reflect.ClassTag$: scala.reflect.ClassTag$ MODULE$>;
v = virtualinvoke v.<scala.reflect.ClassTag$: scala.reflect.ClassTag apply(java.lang.Class)>(class "Ljava/lang/String;");
v = virtualinvoke v.<scala.Array$: scala.collection.generic.CanBuildFrom canBuildFrom(scala.reflect.ClassTag)>(v);
v = interfaceinvoke v.<scala.collection.mutable.ArrayOps: java.lang.Object map(scala.Function,scala.collection.generic.CanBuildFrom)>(v, v);
v = virtualinvoke v.<scala.Predef$: scala.collection.mutable.ArrayOps refArrayOps(java.lang.Object[])>(v);
v = new org.apache.activemq.leveldb.replicated.MasterLevelDBStore$$anonfun$syncTo_$eq$2;
specialinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$$anonfun$syncTo_$eq$2: void <init>(org.apache.activemq.leveldb.replicated.MasterLevelDBStore)>(v);
interfaceinvoke v.<scala.collection.mutable.ArrayOps: void foreach(scala.Function)>(v);
return;
}
public java.util.concurrent.ConcurrentHashMap slaves()
{
java.util.concurrent.ConcurrentHashMap v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore;
v = v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: java.util.concurrent.ConcurrentHashMap slaves>;
return v;
}
public scala.collection.Iterable slaves_status()
{
java.util.Collection v;
java.util.concurrent.ConcurrentHashMap v;
scala.collection.Iterable v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore v;
scala.collection.JavaConversions$ v;
java.lang.Object v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$$anonfun$slaves_status$1 v;
scala.collection.generic.CanBuildFrom v;
scala.collection.Iterable$ v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore;
v = <scala.collection.JavaConversions$: scala.collection.JavaConversions$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: java.util.concurrent.ConcurrentHashMap slaves()>();
v = virtualinvoke v.<java.util.concurrent.ConcurrentHashMap: java.util.Collection values()>();
v = virtualinvoke v.<scala.collection.JavaConversions$: scala.collection.Iterable collectionAsScalaIterable(java.util.Collection)>(v);
v = new org.apache.activemq.leveldb.replicated.MasterLevelDBStore$$anonfun$slaves_status$1;
specialinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$$anonfun$slaves_status$1: void <init>(org.apache.activemq.leveldb.replicated.MasterLevelDBStore)>(v);
v = <scala.collection.Iterable$: scala.collection.Iterable$ MODULE$>;
v = virtualinvoke v.<scala.collection.Iterable$: scala.collection.generic.CanBuildFrom canBuildFrom()>();
v = interfaceinvoke v.<scala.collection.Iterable: java.lang.Object map(scala.Function,scala.collection.generic.CanBuildFrom)>(v, v);
return v;
}
public java.lang.String status()
{
java.lang.Integer v, v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore v;
scala.collection.JavaConversions$ v;
java.util.Collection v;
java.util.concurrent.ConcurrentHashMap v;
scala.collection.immutable.StringOps v, v;
java.lang.Object[] v, v;
scala.collection.mutable.StringBuilder v, v, v, v, v, v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$$anonfun$status$1 v;
scala.Predef$ v, v, v, v;
int v, v, v, v;
java.lang.String v, v, v, v, v;
scala.collection.mutable.WrappedArray v, v;
scala.runtime.IntRef v, v;
scala.collection.Iterable v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore;
v = staticinvoke <scala.runtime.IntRef: scala.runtime.IntRef create(int)>(0);
v = staticinvoke <scala.runtime.IntRef: scala.runtime.IntRef create(int)>(0);
v = <scala.collection.JavaConversions$: scala.collection.JavaConversions$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: java.util.concurrent.ConcurrentHashMap slaves()>();
v = virtualinvoke v.<java.util.concurrent.ConcurrentHashMap: java.util.Collection values()>();
v = virtualinvoke v.<scala.collection.JavaConversions$: scala.collection.Iterable collectionAsScalaIterable(java.util.Collection)>(v);
v = new org.apache.activemq.leveldb.replicated.MasterLevelDBStore$$anonfun$status$1;
specialinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$$anonfun$status$1: void <init>(org.apache.activemq.leveldb.replicated.MasterLevelDBStore,scala.runtime.IntRef,scala.runtime.IntRef)>(v, v, v);
interfaceinvoke v.<scala.collection.Iterable: void foreach(scala.Function)>(v);
v = "";
v = v.<scala.runtime.IntRef: int elem>;
if v <= 0 goto label;
v = new scala.collection.mutable.StringBuilder;
specialinvoke v.<scala.collection.mutable.StringBuilder: void <init>()>();
v = virtualinvoke v.<scala.collection.mutable.StringBuilder: scala.collection.mutable.StringBuilder append(java.lang.Object)>("");
v = new scala.collection.immutable.StringOps;
v = <scala.Predef$: scala.Predef$ MODULE$>;
v = virtualinvoke v.<scala.Predef$: java.lang.String augmentString(java.lang.String)>("%d slave nodes attaching. ");
specialinvoke v.<scala.collection.immutable.StringOps: void <init>(java.lang.String)>(v);
v = <scala.Predef$: scala.Predef$ MODULE$>;
v = newarray (java.lang.Object)[1];
v = v.<scala.runtime.IntRef: int elem>;
v = staticinvoke <scala.runtime.BoxesRunTime: java.lang.Integer boxToInteger(int)>(v);
v[0] = v;
v = virtualinvoke v.<scala.Predef$: scala.collection.mutable.WrappedArray genericWrapArray(java.lang.Object)>(v);
v = virtualinvoke v.<scala.collection.immutable.StringOps: java.lang.String format(scala.collection.Seq)>(v);
v = virtualinvoke v.<scala.collection.mutable.StringBuilder: scala.collection.mutable.StringBuilder append(java.lang.Object)>(v);
v = virtualinvoke v.<scala.collection.mutable.StringBuilder: java.lang.String toString()>();
label:
v = v.<scala.runtime.IntRef: int elem>;
if v <= 0 goto label;
v = new scala.collection.mutable.StringBuilder;
specialinvoke v.<scala.collection.mutable.StringBuilder: void <init>()>();
v = virtualinvoke v.<scala.collection.mutable.StringBuilder: scala.collection.mutable.StringBuilder append(java.lang.Object)>(v);
v = new scala.collection.immutable.StringOps;
v = <scala.Predef$: scala.Predef$ MODULE$>;
v = virtualinvoke v.<scala.Predef$: java.lang.String augmentString(java.lang.String)>("%d slave nodes attached. ");
specialinvoke v.<scala.collection.immutable.StringOps: void <init>(java.lang.String)>(v);
v = <scala.Predef$: scala.Predef$ MODULE$>;
v = newarray (java.lang.Object)[1];
v = v.<scala.runtime.IntRef: int elem>;
v = staticinvoke <scala.runtime.BoxesRunTime: java.lang.Integer boxToInteger(int)>(v);
v[0] = v;
v = virtualinvoke v.<scala.Predef$: scala.collection.mutable.WrappedArray genericWrapArray(java.lang.Object)>(v);
v = virtualinvoke v.<scala.collection.immutable.StringOps: java.lang.String format(scala.collection.Seq)>(v);
v = virtualinvoke v.<scala.collection.mutable.StringBuilder: scala.collection.mutable.StringBuilder append(java.lang.Object)>(v);
v = virtualinvoke v.<scala.collection.mutable.StringBuilder: java.lang.String toString()>();
label:
return v;
}
public void doStart()
{
org.apache.activemq.leveldb.replicated.MasterLevelDBStore v;
long v;
org.apache.activemq.leveldb.replicated.ReplicationSupport$ v;
java.io.File v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore;
v = <org.apache.activemq.leveldb.replicated.ReplicationSupport$: org.apache.activemq.leveldb.replicated.ReplicationSupport$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: java.io.File directory()>();
virtualinvoke v.<org.apache.activemq.leveldb.replicated.ReplicationSupport$: void unstash(java.io.File)>(v);
specialinvoke v.<org.apache.activemq.leveldb.LevelDBStore: void doStart()>();
virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: void start_protocol_server()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: long wal_append_position()>();
virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: void wal_sync_to(long)>(v);
return;
}
public void doStop(org.apache.activemq.util.ServiceStopper)
{
org.apache.activemq.leveldb.replicated.MasterLevelDBStore v;
org.apache.activemq.util.ServiceStopper v;
org.fusesource.hawtdispatch.transport.TransportServer v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore;
v := @parameter: org.apache.activemq.util.ServiceStopper;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: org.fusesource.hawtdispatch.transport.TransportServer transport_server()>();
if v == null goto label;
virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: void stop_protocol_server()>();
virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: void transport_server_$eq(org.fusesource.hawtdispatch.transport.TransportServer)>(null);
label:
specialinvoke v.<org.apache.activemq.leveldb.LevelDBStore: void doStop(org.apache.activemq.util.ServiceStopper)>(v);
return;
}
public org.apache.activemq.leveldb.replicated.MasterLevelDBClient createClient()
{
org.apache.activemq.leveldb.replicated.MasterLevelDBStore v;
org.apache.activemq.leveldb.replicated.MasterLevelDBClient v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore;
v = new org.apache.activemq.leveldb.replicated.MasterLevelDBClient;
specialinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBClient: void <init>(org.apache.activemq.leveldb.replicated.MasterLevelDBStore)>(v);
return v;
}
public org.apache.activemq.leveldb.replicated.MasterLevelDBClient master_client()
{
org.apache.activemq.leveldb.LevelDBClient v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: org.apache.activemq.leveldb.LevelDBClient client()>();
return v;
}
public org.fusesource.hawtdispatch.transport.TransportServer transport_server()
{
org.apache.activemq.leveldb.replicated.MasterLevelDBStore v;
org.fusesource.hawtdispatch.transport.TransportServer v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore;
v = v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: org.fusesource.hawtdispatch.transport.TransportServer transport_server>;
return v;
}
public void transport_server_$eq(org.fusesource.hawtdispatch.transport.TransportServer)
{
org.apache.activemq.leveldb.replicated.MasterLevelDBStore v;
org.fusesource.hawtdispatch.transport.TransportServer v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore;
v := @parameter: org.fusesource.hawtdispatch.transport.TransportServer;
v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: org.fusesource.hawtdispatch.transport.TransportServer transport_server> = v;
return;
}
public java.util.concurrent.CountDownLatch start_latch()
{
java.util.concurrent.CountDownLatch v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore;
v = v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: java.util.concurrent.CountDownLatch start_latch>;
return v;
}
public void start_protocol_server()
{
org.fusesource.hawtdispatch.transport.TransportServer v, v, v, v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$$anonfun$start_protocol_server$1 v;
org.fusesource.hawtdispatch.transport.TcpTransportServer v;
scala.collection.mutable.StringBuilder v, v, v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$$anon$1 v;
org.fusesource.hawtdispatch.package$ v, v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore v;
java.lang.String v, v, v;
java.net.URI v;
org.fusesource.hawtdispatch.Task v;
java.util.concurrent.Executor v;
org.fusesource.hawtdispatch.DispatchQueue v;
java.util.concurrent.CountDownLatch v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore;
v = new org.fusesource.hawtdispatch.transport.TcpTransportServer;
v = new java.net.URI;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: java.lang.String bind()>();
specialinvoke v.<java.net.URI: void <init>(java.lang.String)>(v);
specialinvoke v.<org.fusesource.hawtdispatch.transport.TcpTransportServer: void <init>(java.net.URI)>(v);
virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: void transport_server_$eq(org.fusesource.hawtdispatch.transport.TransportServer)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: org.fusesource.hawtdispatch.transport.TransportServer transport_server()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: java.util.concurrent.Executor blocking_executor()>();
interfaceinvoke v.<org.fusesource.hawtdispatch.transport.TransportServer: void setBlockingExecutor(java.util.concurrent.Executor)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: org.fusesource.hawtdispatch.transport.TransportServer transport_server()>();
v = <org.fusesource.hawtdispatch.package$: org.fusesource.hawtdispatch.package$ MODULE$>;
v = new scala.collection.mutable.StringBuilder;
specialinvoke v.<scala.collection.mutable.StringBuilder: void <init>()>();
v = virtualinvoke v.<scala.collection.mutable.StringBuilder: scala.collection.mutable.StringBuilder append(java.lang.Object)>("master: ");
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: java.lang.String node_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()>();
v = virtualinvoke v.<org.fusesource.hawtdispatch.package$: org.fusesource.hawtdispatch.DispatchQueue createQueue(java.lang.String)>(v);
interfaceinvoke v.<org.fusesource.hawtdispatch.transport.TransportServer: void setDispatchQueue(org.fusesource.hawtdispatch.DispatchQueue)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: org.fusesource.hawtdispatch.transport.TransportServer transport_server()>();
v = new org.apache.activemq.leveldb.replicated.MasterLevelDBStore$$anon$1;
specialinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$$anon$1: void <init>(org.apache.activemq.leveldb.replicated.MasterLevelDBStore)>(v);
interfaceinvoke v.<org.fusesource.hawtdispatch.transport.TransportServer: void setTransportServerListener(org.fusesource.hawtdispatch.transport.TransportServerListener)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: org.fusesource.hawtdispatch.transport.TransportServer transport_server()>();
v = <org.fusesource.hawtdispatch.package$: org.fusesource.hawtdispatch.package$ MODULE$>;
v = new org.apache.activemq.leveldb.replicated.MasterLevelDBStore$$anonfun$start_protocol_server$1;
specialinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$$anonfun$start_protocol_server$1: void <init>(org.apache.activemq.leveldb.replicated.MasterLevelDBStore)>(v);
v = virtualinvoke v.<org.fusesource.hawtdispatch.package$: org.fusesource.hawtdispatch.Task $up(scala.Function)>(v);
interfaceinvoke v.<org.fusesource.hawtdispatch.transport.TransportServer: void start(org.fusesource.hawtdispatch.Task)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: java.util.concurrent.CountDownLatch start_latch()>();
virtualinvoke v.<java.util.concurrent.CountDownLatch: void await()>();
return;
}
public int getPort()
{
java.util.concurrent.CountDownLatch v;
java.net.SocketAddress v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore v;
org.fusesource.hawtdispatch.transport.TransportServer v;
int v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: java.util.concurrent.CountDownLatch start_latch()>();
virtualinvoke v.<java.util.concurrent.CountDownLatch: void await()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: org.fusesource.hawtdispatch.transport.TransportServer transport_server()>();
v = interfaceinvoke v.<org.fusesource.hawtdispatch.transport.TransportServer: java.net.SocketAddress getSocketAddress()>();
v = virtualinvoke v.<java.net.InetSocketAddress: int getPort()>();
return v;
}
public void stop_protocol_server()
{
org.fusesource.hawtdispatch.Task v;
org.fusesource.hawtdispatch.package$ v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore v;
org.fusesource.hawtdispatch.transport.TransportServer v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: org.fusesource.hawtdispatch.transport.TransportServer transport_server()>();
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.TransportServer: void stop(org.fusesource.hawtdispatch.Task)>(v);
return;
}
public org.apache.activemq.leveldb.replicated.PositionSync position_sync()
{
org.apache.activemq.leveldb.replicated.PositionSync v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore;
v = v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: org.apache.activemq.leveldb.replicated.PositionSync position_sync>;
return v;
}
public void position_sync_$eq(org.apache.activemq.leveldb.replicated.PositionSync)
{
org.apache.activemq.leveldb.replicated.PositionSync v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore;
v := @parameter: org.apache.activemq.leveldb.replicated.PositionSync;
v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: org.apache.activemq.leveldb.replicated.PositionSync position_sync> = v;
return;
}
public void wal_sync_to(long)
{
java.lang.IllegalStateException v, v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$$anonfun$wal_sync_to$2 v;
java.lang.Object[] v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$$anonfun$wal_sync_to$1 v;
long v;
java.lang.Integer v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore v;
java.lang.Long v;
scala.Predef$ v;
scala.collection.JavaConversions$ v;
int v, v, v, v, v, v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$ v, v;
java.lang.String v;
org.apache.activemq.leveldb.replicated.PositionSync v;
boolean v, v, v;
scala.collection.mutable.WrappedArray v;
java.util.Collection v;
java.util.concurrent.ConcurrentHashMap v;
scala.collection.Iterable v;
java.util.concurrent.TimeUnit v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore;
v := @parameter: long;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: int minSlaveAcks()>();
if v < 1 goto label;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: int syncToMask()>();
v = <org.apache.activemq.leveldb.replicated.MasterLevelDBStore$: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$: int SYNC_TO_REMOTE()>();
v = v & v;
if v != 0 goto label;
label:
return;
label:
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: boolean isStoppedOrStopping()>();
if v == 0 goto label;
v = new java.lang.IllegalStateException;
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>("Store replication stopped");
throw v;
label:
v = new org.apache.activemq.leveldb.replicated.PositionSync;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: int minSlaveAcks()>();
specialinvoke v.<org.apache.activemq.leveldb.replicated.PositionSync: void <init>(long,int)>(v, v);
virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: void position_sync_$eq(org.apache.activemq.leveldb.replicated.PositionSync)>(v);
v = <scala.collection.JavaConversions$: scala.collection.JavaConversions$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: java.util.concurrent.ConcurrentHashMap slaves()>();
v = virtualinvoke v.<java.util.concurrent.ConcurrentHashMap: java.util.Collection values()>();
v = virtualinvoke v.<scala.collection.JavaConversions$: scala.collection.Iterable collectionAsScalaIterable(java.util.Collection)>(v);
v = new org.apache.activemq.leveldb.replicated.MasterLevelDBStore$$anonfun$wal_sync_to$1;
specialinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$$anonfun$wal_sync_to$1: void <init>(org.apache.activemq.leveldb.replicated.MasterLevelDBStore)>(v);
interfaceinvoke v.<scala.collection.Iterable: void foreach(scala.Function)>(v);
label:
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit SECONDS>;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.PositionSync: boolean await(long,java.util.concurrent.TimeUnit)>(1L, v);
if v == 0 goto label;
return;
label:
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: boolean isStoppedOrStopping()>();
if v == 0 goto label;
v = new java.lang.IllegalStateException;
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>("Store replication stopped");
throw v;
label:
v = <org.apache.activemq.leveldb.replicated.MasterLevelDBStore$: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$ MODULE$>;
v = new org.apache.activemq.leveldb.replicated.MasterLevelDBStore$$anonfun$wal_sync_to$2;
specialinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$$anonfun$wal_sync_to$2: void <init>(org.apache.activemq.leveldb.replicated.MasterLevelDBStore)>(v);
v = <scala.Predef$: scala.Predef$ MODULE$>;
v = newarray (java.lang.Object)[3];
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: int minSlaveAcks()>();
v = staticinvoke <scala.runtime.BoxesRunTime: java.lang.Integer boxToInteger(int)>(v);
v[0] = v;
v = staticinvoke <scala.runtime.BoxesRunTime: java.lang.Long boxToLong(long)>(v);
v[1] = v;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: java.lang.String status()>();
v[2] = v;
v = virtualinvoke v.<scala.Predef$: scala.collection.mutable.WrappedArray genericWrapArray(java.lang.Object)>(v);
virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$: void warn(scala.Function,scala.collection.Seq)>(v, v);
goto label;
}
public boolean isStoppedOrStopping()
{
org.apache.activemq.broker.BrokerService v, v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore v;
boolean v, v, v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: boolean isStopped()>();
if v != 0 goto label;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: boolean isStopping()>();
if v == 0 goto label;
label:
return 1;
label:
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: org.apache.activemq.broker.BrokerService broker_service()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: org.apache.activemq.broker.BrokerService broker_service()>();
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: boolean isStopping()>();
if v == 0 goto label;
return 1;
label:
return 0;
}
public long date()
{
long v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore;
v = staticinvoke <java.lang.System: long currentTimeMillis()>();
return v;
}
public void replicate_wal(java.io.File, long, long, long)
{
java.util.Collection v;
java.util.concurrent.ConcurrentHashMap v;
long v, v, v;
scala.collection.Iterable v;
java.io.File v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$$anonfun$replicate_wal$1 v;
byte v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore v;
scala.collection.JavaConversions$ v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore;
v := @parameter: java.io.File;
v := @parameter: long;
v := @parameter: long;
v := @parameter: long;
v = v cmp 0L;
if v <= 0 goto label;
v = <scala.collection.JavaConversions$: scala.collection.JavaConversions$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: java.util.concurrent.ConcurrentHashMap slaves()>();
v = virtualinvoke v.<java.util.concurrent.ConcurrentHashMap: java.util.Collection values()>();
v = virtualinvoke v.<scala.collection.JavaConversions$: scala.collection.Iterable collectionAsScalaIterable(java.util.Collection)>(v);
v = new org.apache.activemq.leveldb.replicated.MasterLevelDBStore$$anonfun$replicate_wal$1;
specialinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$$anonfun$replicate_wal$1: void <init>(org.apache.activemq.leveldb.replicated.MasterLevelDBStore,java.io.File,long,long,long)>(v, v, v, v, v);
interfaceinvoke v.<scala.collection.Iterable: void foreach(scala.Function)>(v);
label:
return;
}
public void replicate_log_delete(long)
{
java.util.Collection v;
java.util.concurrent.ConcurrentHashMap v;
long v;
scala.collection.Iterable v;
org.apache.activemq.leveldb.replicated.dto.LogDelete v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore v;
scala.collection.JavaConversions$ v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$$anonfun$replicate_log_delete$1 v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore;
v := @parameter: long;
v = new org.apache.activemq.leveldb.replicated.dto.LogDelete;
specialinvoke v.<org.apache.activemq.leveldb.replicated.dto.LogDelete: void <init>()>();
v.<org.apache.activemq.leveldb.replicated.dto.LogDelete: long log> = v;
v = <scala.collection.JavaConversions$: scala.collection.JavaConversions$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: java.util.concurrent.ConcurrentHashMap slaves()>();
v = virtualinvoke v.<java.util.concurrent.ConcurrentHashMap: java.util.Collection values()>();
v = virtualinvoke v.<scala.collection.JavaConversions$: scala.collection.Iterable collectionAsScalaIterable(java.util.Collection)>(v);
v = new org.apache.activemq.leveldb.replicated.MasterLevelDBStore$$anonfun$replicate_log_delete$1;
specialinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$$anonfun$replicate_log_delete$1: void <init>(org.apache.activemq.leveldb.replicated.MasterLevelDBStore,org.apache.activemq.leveldb.replicated.dto.LogDelete)>(v, v);
interfaceinvoke v.<scala.collection.Iterable: void foreach(scala.Function)>(v);
return;
}
public long wal_append_position()
{
long v;
org.apache.activemq.leveldb.LevelDBClient v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: org.apache.activemq.leveldb.LevelDBClient client()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.LevelDBClient: long wal_append_position()>();
return v;
}
public long wal_date()
{
long v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore;
v = v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: long wal_date>;
return v;
}
public void wal_date_$eq(long)
{
long v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore;
v := @parameter: long;
v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: long wal_date> = v;
return;
}
public java.lang.String getBind()
{
java.lang.String v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: java.lang.String bind()>();
return v;
}
public int getReplicas()
{
int v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: int replicas()>();
return v;
}
public void <init>()
{
java.util.concurrent.CountDownLatch v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore v;
int v;
java.util.concurrent.ConcurrentHashMap v;
org.apache.activemq.leveldb.replicated.MasterLevelDBStore$ v;
org.apache.activemq.leveldb.replicated.PositionSync v;
v := @this: org.apache.activemq.leveldb.replicated.MasterLevelDBStore;
specialinvoke v.<org.apache.activemq.leveldb.LevelDBStore: void <init>()>();
staticinvoke <org.apache.activemq.leveldb.replicated.ReplicatedLevelDBStoreTrait$class: void $init$(org.apache.activemq.leveldb.replicated.ReplicatedLevelDBStoreTrait)>(v);
v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: java.lang.String bind> = "tcp://0.0.0.0:61619";
v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: int replicas> = 3;
v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: java.lang.String _syncTo> = "quorum_mem";
v = <org.apache.activemq.leveldb.replicated.MasterLevelDBStore$: org.apache.activemq.leveldb.replicated.MasterLevelDBStore$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore$: int SYNC_TO_REMOTE_MEMORY()>();
v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: int syncToMask> = v;
v = new java.util.concurrent.ConcurrentHashMap;
specialinvoke v.<java.util.concurrent.ConcurrentHashMap: void <init>()>();
v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: java.util.concurrent.ConcurrentHashMap slaves> = v;
v = new java.util.concurrent.CountDownLatch;
specialinvoke v.<java.util.concurrent.CountDownLatch: void <init>(int)>(1);
v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: java.util.concurrent.CountDownLatch start_latch> = v;
v = new org.apache.activemq.leveldb.replicated.PositionSync;
specialinvoke v.<org.apache.activemq.leveldb.replicated.PositionSync: void <init>(long,int)>(0L, 0);
v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: org.apache.activemq.leveldb.replicated.PositionSync position_sync> = v;
v.<org.apache.activemq.leveldb.replicated.MasterLevelDBStore: long wal_date> = 0L;
return;
}
}