public class org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup extends java.lang.Object implements org.linkedin.zookeeper.client.LifecycleListener, org.apache.activemq.leveldb.replicated.groups.ChangeListenerSupport
{
private final org.apache.activemq.leveldb.replicated.groups.ZKClient zk;
private final java.lang.String root;
private org.linkedin.zookeeper.tracker.ZooKeeperTreeTracker tree;
private boolean rebuildTree;
private final scala.collection.mutable.HashMap joins;
private java.util.LinkedHashMap members;
private org.linkedin.zookeeper.tracker.NodeEventsListener treeEventHandler;
private volatile boolean closed;
private scala.collection.immutable.List listeners;
public scala.collection.immutable.List listeners()
{
org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup v;
scala.collection.immutable.List v;
v := @this: org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup;
v = v.<org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup: scala.collection.immutable.List listeners>;
return v;
}
public void listeners_$eq(scala.collection.immutable.List)
{
org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup v;
scala.collection.immutable.List v;
v := @this: org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup;
v := @parameter: scala.collection.immutable.List;
v.<org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup: scala.collection.immutable.List listeners> = v;
return;
}
public void add(org.apache.activemq.leveldb.replicated.groups.ChangeListener)
{
org.apache.activemq.leveldb.replicated.groups.ChangeListener v;
org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup v;
v := @this: org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup;
v := @parameter: org.apache.activemq.leveldb.replicated.groups.ChangeListener;
staticinvoke <org.apache.activemq.leveldb.replicated.groups.ChangeListenerSupport$class: void add(org.apache.activemq.leveldb.replicated.groups.ChangeListenerSupport,org.apache.activemq.leveldb.replicated.groups.ChangeListener)>(v, v);
return;
}
public void remove(org.apache.activemq.leveldb.replicated.groups.ChangeListener)
{
org.apache.activemq.leveldb.replicated.groups.ChangeListener v;
org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup v;
v := @this: org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup;
v := @parameter: org.apache.activemq.leveldb.replicated.groups.ChangeListener;
staticinvoke <org.apache.activemq.leveldb.replicated.groups.ChangeListenerSupport$class: void remove(org.apache.activemq.leveldb.replicated.groups.ChangeListenerSupport,org.apache.activemq.leveldb.replicated.groups.ChangeListener)>(v, v);
return;
}
public void fireConnected()
{
org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup v;
v := @this: org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup;
staticinvoke <org.apache.activemq.leveldb.replicated.groups.ChangeListenerSupport$class: void fireConnected(org.apache.activemq.leveldb.replicated.groups.ChangeListenerSupport)>(v);
return;
}
public void fireDisconnected()
{
org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup v;
v := @this: org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup;
staticinvoke <org.apache.activemq.leveldb.replicated.groups.ChangeListenerSupport$class: void fireDisconnected(org.apache.activemq.leveldb.replicated.groups.ChangeListenerSupport)>(v);
return;
}
public void fireChanged()
{
org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup v;
v := @this: org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup;
staticinvoke <org.apache.activemq.leveldb.replicated.groups.ChangeListenerSupport$class: void fireChanged(org.apache.activemq.leveldb.replicated.groups.ChangeListenerSupport)>(v);
return;
}
public java.lang.Object check_elapsed_time(scala.Function)
{
scala.Function v;
java.lang.Object v;
org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup v;
v := @this: org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup;
v := @parameter: scala.Function;
v = staticinvoke <org.apache.activemq.leveldb.replicated.groups.ChangeListenerSupport$class: java.lang.Object check_elapsed_time(org.apache.activemq.leveldb.replicated.groups.ChangeListenerSupport,scala.Function)>(v, v);
return v;
}
public org.apache.activemq.leveldb.replicated.groups.ZKClient zk()
{
org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup v;
org.apache.activemq.leveldb.replicated.groups.ZKClient v;
v := @this: org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup;
v = v.<org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup: org.apache.activemq.leveldb.replicated.groups.ZKClient zk>;
return v;
}
public java.lang.String root()
{
java.lang.String v;
org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup v;
v := @this: org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup;
v = v.<org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup: java.lang.String root>;
return v;
}
public org.linkedin.zookeeper.tracker.ZooKeeperTreeTracker tree()
{
org.linkedin.zookeeper.tracker.ZooKeeperTreeTracker v;
org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup v;
v := @this: org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup;
v = v.<org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup: org.linkedin.zookeeper.tracker.ZooKeeperTreeTracker tree>;
return v;
}
public void tree_$eq(org.linkedin.zookeeper.tracker.ZooKeeperTreeTracker)
{
org.linkedin.zookeeper.tracker.ZooKeeperTreeTracker v;
org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup v;
v := @this: org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup;
v := @parameter: org.linkedin.zookeeper.tracker.ZooKeeperTreeTracker;
v.<org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup: org.linkedin.zookeeper.tracker.ZooKeeperTreeTracker tree> = v;
return;
}
public boolean rebuildTree()
{
org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup v;
boolean v;
v := @this: org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup;
v = v.<org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup: boolean rebuildTree>;
return v;
}
public void rebuildTree_$eq(boolean)
{
org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup v;
boolean v;
v := @this: org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup;
v := @parameter: boolean;
v.<org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup: boolean rebuildTree> = v;
return;
}
public scala.collection.mutable.HashMap joins()
{
org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup v;
scala.collection.mutable.HashMap v;
v := @this: org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup;
v = v.<org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup: scala.collection.mutable.HashMap joins>;
return v;
}
public java.util.LinkedHashMap members()
{
java.util.LinkedHashMap v;
org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup v;
v := @this: org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup;
v = v.<org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup: java.util.LinkedHashMap members>;
return v;
}
public void members_$eq(java.util.LinkedHashMap)
{
java.util.LinkedHashMap v;
org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup v;
v := @this: org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup;
v := @parameter: java.util.LinkedHashMap;
v.<org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup: java.util.LinkedHashMap members> = v;
return;
}
public java.lang.String org$apache$activemq$leveldb$replicated$groups$ZooKeeperGroup$$member_path_prefix()
{
org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup v;
java.lang.String v, v;
scala.collection.mutable.StringBuilder v, v, v;
v := @this: org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup;
v = new scala.collection.mutable.StringBuilder;
specialinvoke v.<scala.collection.mutable.StringBuilder: void <init>()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup: java.lang.String root()>();
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)>("/0");
v = virtualinvoke v.<scala.collection.mutable.StringBuilder: java.lang.String toString()>();
return v;
}
public org.linkedin.zookeeper.tracker.NodeEventsListener treeEventHandler()
{
org.linkedin.zookeeper.tracker.NodeEventsListener v;
org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup v;
v := @this: org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup;
v = v.<org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup: org.linkedin.zookeeper.tracker.NodeEventsListener treeEventHandler>;
return v;
}
public void treeEventHandler_$eq(org.linkedin.zookeeper.tracker.NodeEventsListener)
{
org.linkedin.zookeeper.tracker.NodeEventsListener v;
org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup v;
v := @this: org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup;
v := @parameter: org.linkedin.zookeeper.tracker.NodeEventsListener;
v.<org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup: org.linkedin.zookeeper.tracker.NodeEventsListener treeEventHandler> = v;
return;
}
public boolean closed()
{
org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup v;
boolean v;
v := @this: org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup;
v = v.<org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup: boolean closed>;
return v;
}
public void closed_$eq(boolean)
{
org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup v;
boolean v;
v := @this: org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup;
v := @parameter: boolean;
v.<org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup: boolean closed> = v;
return;
}
public synchronized void close()
{
org.linkedin.zookeeper.tracker.ZooKeeperTreeTracker v;
org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup v;
org.apache.activemq.leveldb.replicated.groups.ZKClient v;
org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup$$anonfun$close$1 v;
scala.collection.mutable.HashMap v, v;
v := @this: org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup;
virtualinvoke v.<org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup: void closed_$eq(boolean)>(1);
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup: scala.collection.mutable.HashMap joins()>();
v = new org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup$$anonfun$close$1;
specialinvoke v.<org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup$$anonfun$close$1: void <init>(org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup)>(v);
virtualinvoke v.<scala.collection.mutable.HashMap: void foreach(scala.Function)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup: scala.collection.mutable.HashMap joins()>();
virtualinvoke v.<scala.collection.mutable.HashMap: void clear()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup: org.linkedin.zookeeper.tracker.ZooKeeperTreeTracker tree()>();
virtualinvoke v.<org.linkedin.zookeeper.tracker.ZooKeeperTreeTracker: void destroy()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup: org.apache.activemq.leveldb.replicated.groups.ZKClient zk()>();
virtualinvoke v.<org.apache.activemq.leveldb.replicated.groups.ZKClient: void removeListener(org.linkedin.zookeeper.client.LifecycleListener)>(v);
return;
}
public boolean connected()
{
org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup v;
org.apache.activemq.leveldb.replicated.groups.ZKClient v;
boolean v;
v := @this: org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup: org.apache.activemq.leveldb.replicated.groups.ZKClient zk()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.groups.ZKClient: boolean isConnected()>();
return v;
}
public void onConnected()
{
java.lang.Throwable v;
org.linkedin.zookeeper.tracker.ZooKeeperTreeTracker v, v, v;
org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup v;
org.apache.activemq.leveldb.replicated.groups.ZKClient v;
scala.runtime.BoxedUnit v, v;
org.linkedin.zookeeper.tracker.NodeEventsListener v;
java.lang.String v;
org.linkedin.zookeeper.tracker.ZKByteArrayDataReader v;
boolean v;
v := @this: org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup;
entermonitor v;
label:
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup: boolean rebuildTree()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup: org.linkedin.zookeeper.tracker.ZooKeeperTreeTracker tree()>();
virtualinvoke v.<org.linkedin.zookeeper.tracker.ZooKeeperTreeTracker: void destroy()>();
v = new org.linkedin.zookeeper.tracker.ZooKeeperTreeTracker;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup: org.apache.activemq.leveldb.replicated.groups.ZKClient zk()>();
v = new org.linkedin.zookeeper.tracker.ZKByteArrayDataReader;
specialinvoke v.<org.linkedin.zookeeper.tracker.ZKByteArrayDataReader: void <init>()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup: java.lang.String root()>();
specialinvoke v.<org.linkedin.zookeeper.tracker.ZooKeeperTreeTracker: void <init>(org.linkedin.zookeeper.client.IZKClient,org.linkedin.zookeeper.tracker.ZKDataReader,java.lang.String,int)>(v, v, v, 1);
virtualinvoke v.<org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup: void tree_$eq(org.linkedin.zookeeper.tracker.ZooKeeperTreeTracker)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup: org.linkedin.zookeeper.tracker.ZooKeeperTreeTracker tree()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup: org.linkedin.zookeeper.tracker.NodeEventsListener treeEventHandler()>();
virtualinvoke v.<org.linkedin.zookeeper.tracker.ZooKeeperTreeTracker: void track(org.linkedin.zookeeper.tracker.NodeEventsListener)>(v);
v = <scala.runtime.BoxedUnit: scala.runtime.BoxedUnit UNIT>;
goto label;
label:
virtualinvoke v.<org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup: void rebuildTree_$eq(boolean)>(1);
v = <scala.runtime.BoxedUnit: scala.runtime.BoxedUnit UNIT>;
label:
exitmonitor v;
label:
virtualinvoke v.<org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup: void fireConnected()>();
return;
label:
v := @caughtexception;
exitmonitor v;
throw v;
catch java.lang.Throwable from label to label with label;
}
public void onDisconnected()
{
java.util.LinkedHashMap v;
org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup v;
v := @this: org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup;
v = new java.util.LinkedHashMap;
specialinvoke v.<java.util.LinkedHashMap: void <init>()>();
virtualinvoke v.<org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup: void members_$eq(java.util.LinkedHashMap)>(v);
virtualinvoke v.<org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup: void fireDisconnected()>();
return;
}
public synchronized java.lang.String join(byte[])
{
org.apache.zookeeper.CreateMode v;
byte[] v;
org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup v;
org.apache.activemq.leveldb.replicated.groups.ZKClient v;
java.lang.Integer v;
scala.Predef$ v;
java.lang.String v, v, v, v, v;
scala.collection.immutable.StringOps v;
scala.collection.mutable.HashMap v;
v := @this: org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup;
v := @parameter: byte[];
v = new scala.collection.immutable.StringOps;
v = <scala.Predef$: scala.Predef$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup: org.apache.activemq.leveldb.replicated.groups.ZKClient zk()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup: java.lang.String org$apache$activemq$leveldb$replicated$groups$ZooKeeperGroup$$member_path_prefix()>();
v = <org.apache.zookeeper.CreateMode: org.apache.zookeeper.CreateMode EPHEMERAL_SEQUENTIAL>;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.groups.ZKClient: java.lang.String createWithParents(java.lang.String,byte[],org.apache.zookeeper.CreateMode)>(v, v, v);
v = virtualinvoke v.<scala.Predef$: java.lang.String augmentString(java.lang.String)>(v);
specialinvoke v.<scala.collection.immutable.StringOps: void <init>(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup: java.lang.String org$apache$activemq$leveldb$replicated$groups$ZooKeeperGroup$$member_path_prefix()>();
v = virtualinvoke v.<scala.collection.immutable.StringOps: java.lang.String stripPrefix(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup: scala.collection.mutable.HashMap joins()>();
v = staticinvoke <scala.runtime.BoxesRunTime: java.lang.Integer boxToInteger(int)>(0);
virtualinvoke v.<scala.collection.mutable.HashMap: scala.Option put(java.lang.Object,java.lang.Object)>(v, v);
return v;
}
public byte[] join$default$1()
{
org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup v;
v := @this: org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup;
return null;
}
public void update(java.lang.String, byte[])
{
java.lang.Throwable v;
byte[] v;
org.apache.zookeeper.KeeperException$NoNodeException v;
scala.collection.mutable.StringBuilder v, v, v;
int v;
java.lang.String v, v;
scala.collection.mutable.HashMap v;
boolean v, v;
scala.MatchError v;
org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup v;
scala.Option v;
scala.None$ v;
java.lang.Object v;
v := @this: org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup;
v := @parameter: java.lang.String;
v := @parameter: byte[];
entermonitor v;
label:
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup: scala.collection.mutable.HashMap joins()>();
v = virtualinvoke v.<scala.collection.mutable.HashMap: scala.Option get(java.lang.Object)>(v);
v = v instanceof scala.Some;
if v == 0 goto label;
v = virtualinvoke v.<scala.Some: java.lang.Object x()>();
v = staticinvoke <scala.runtime.BoxesRunTime: int unboxToInt(java.lang.Object)>(v);
specialinvoke v.<org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup: scala.Option liftedTree1$1(java.lang.String,byte[],int)>(v, v, v);
exitmonitor v;
label:
return;
label:
v = <scala.None$: scala.None$ MODULE$>;
v = virtualinvoke v.<java.lang.Object: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = new org.apache.zookeeper.KeeperException$NoNodeException;
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)>("Has not joined locally: ");
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()>();
specialinvoke v.<org.apache.zookeeper.KeeperException$NoNodeException: void <init>(java.lang.String)>(v);
throw v;
label:
v = new scala.MatchError;
specialinvoke v.<scala.MatchError: void <init>(java.lang.Object)>(v);
throw v;
label:
v := @caughtexception;
exitmonitor v;
throw v;
catch java.lang.Throwable from label to label with label;
}
public byte[] update$default$2()
{
org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup v;
v := @this: org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup;
return null;
}
public synchronized void leave(java.lang.String)
{
org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup v;
java.lang.String v;
scala.Option v;
scala.collection.mutable.HashMap v;
org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup$$anonfun$leave$1 v;
v := @this: org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup;
v := @parameter: java.lang.String;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup: scala.collection.mutable.HashMap joins()>();
v = virtualinvoke v.<scala.collection.mutable.HashMap: scala.Option remove(java.lang.Object)>(v);
v = new org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup$$anonfun$leave$1;
specialinvoke v.<org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup$$anonfun$leave$1: void <init>(org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup,java.lang.String)>(v, v);
virtualinvoke v.<scala.Option: void foreach(scala.Function)>(v);
return;
}
public void org$apache$activemq$leveldb$replicated$groups$ZooKeeperGroup$$fire_cluster_change()
{
java.lang.Throwable v;
org.linkedin.zookeeper.tracker.ZooKeeperTreeTracker v;
org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup v;
scala.collection.immutable.List v;
scala.runtime.BoxedUnit v;
java.util.LinkedHashMap v;
org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup$$anonfun$org$apache$activemq$leveldb$replicated$groups$ZooKeeperGroup$$fire_cluster_change$2 v;
scala.collection.mutable.Map v;
org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup$$anonfun$org$apache$activemq$leveldb$replicated$groups$ZooKeeperGroup$$fire_cluster_change$1 v;
scala.collection.JavaConversions$ v;
java.util.Map v;
java.lang.Object v, v;
org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup$$anonfun$1 v;
v := @this: org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup;
entermonitor v;
label:
v = <scala.collection.JavaConversions$: scala.collection.JavaConversions$ MODULE$>;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup: org.linkedin.zookeeper.tracker.ZooKeeperTreeTracker tree()>();
v = virtualinvoke v.<org.linkedin.zookeeper.tracker.ZooKeeperTreeTracker: java.util.Map getTree()>();
v = virtualinvoke v.<scala.collection.JavaConversions$: scala.collection.mutable.Map mapAsScalaMap(java.util.Map)>(v);
v = interfaceinvoke v.<scala.collection.mutable.Map: scala.collection.immutable.List toList()>();
v = new org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup$$anonfun$1;
specialinvoke v.<org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup$$anonfun$1: void <init>(org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup)>(v);
v = virtualinvoke v.<scala.collection.immutable.List: java.lang.Object filterNot(scala.Function)>(v);
v = new java.util.LinkedHashMap;
specialinvoke v.<java.util.LinkedHashMap: void <init>()>();
virtualinvoke v.<org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup: void members_$eq(java.util.LinkedHashMap)>(v);
v = new org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup$$anonfun$org$apache$activemq$leveldb$replicated$groups$ZooKeeperGroup$$fire_cluster_change$1;
specialinvoke v.<org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup$$anonfun$org$apache$activemq$leveldb$replicated$groups$ZooKeeperGroup$$fire_cluster_change$1: void <init>(org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup)>(v);
v = virtualinvoke v.<scala.collection.immutable.List: java.lang.Object sortWith(scala.Function)>(v);
v = new org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup$$anonfun$org$apache$activemq$leveldb$replicated$groups$ZooKeeperGroup$$fire_cluster_change$2;
specialinvoke v.<org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup$$anonfun$org$apache$activemq$leveldb$replicated$groups$ZooKeeperGroup$$fire_cluster_change$2: void <init>(org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup)>(v);
virtualinvoke v.<scala.collection.immutable.List: void foreach(scala.Function)>(v);
v = <scala.runtime.BoxedUnit: scala.runtime.BoxedUnit UNIT>;
exitmonitor v;
label:
virtualinvoke v.<org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup: void fireChanged()>();
return;
label:
v := @caughtexception;
exitmonitor v;
throw v;
catch java.lang.Throwable from label to label with label;
}
private void create(java.lang.String, java.lang.Integer)
{
org.apache.zookeeper.CreateMode v;
org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup v;
org.apache.activemq.leveldb.replicated.groups.ZKClient v, v;
scala.runtime.BoxedUnit v;
org.apache.zookeeper.data.Stat v;
java.lang.Integer v;
java.lang.String v;
v := @this: org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup;
v := @parameter: java.lang.String;
v := @parameter: java.lang.Integer;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup: org.apache.activemq.leveldb.replicated.groups.ZKClient zk()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.groups.ZKClient: org.apache.zookeeper.data.Stat exists(java.lang.String,boolean)>(v, 0);
if v != null goto label;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup: org.apache.activemq.leveldb.replicated.groups.ZKClient zk()>();
v = <org.apache.zookeeper.CreateMode: org.apache.zookeeper.CreateMode PERSISTENT>;
virtualinvoke v.<org.apache.activemq.leveldb.replicated.groups.ZKClient: org.apache.zookeeper.data.Stat createOrSetWithParents(java.lang.String,java.lang.String,org.apache.zookeeper.CreateMode)>(v, "", v);
v = <scala.runtime.BoxedUnit: scala.runtime.BoxedUnit UNIT>;
goto label;
label:
return;
label:
return;
}
private java.lang.Integer create$default$2()
{
org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup v;
java.lang.Integer v;
scala.Predef$ v;
v := @this: org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup;
v = <scala.Predef$: scala.Predef$ MODULE$>;
v = virtualinvoke v.<scala.Predef$: java.lang.Integer int2Integer(int)>(0);
return v;
}
private final scala.Option liftedTree1$1(java.lang.String, byte[], int)
{
java.lang.Throwable v;
byte[] v;
org.apache.zookeeper.data.Stat v;
java.lang.Integer v;
scala.collection.mutable.StringBuilder v, v, v;
int v, v;
java.lang.String v, v, v;
scala.collection.mutable.HashMap v, v;
org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup v;
org.apache.activemq.leveldb.replicated.groups.ZKClient v;
scala.Option v;
v := @this: org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup;
v := @parameter: java.lang.String;
v := @parameter: byte[];
v := @parameter: int;
label:
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup: org.apache.activemq.leveldb.replicated.groups.ZKClient zk()>();
v = new scala.collection.mutable.StringBuilder;
specialinvoke v.<scala.collection.mutable.StringBuilder: void <init>()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup: java.lang.String org$apache$activemq$leveldb$replicated$groups$ZooKeeperGroup$$member_path_prefix()>();
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);
v = virtualinvoke v.<scala.collection.mutable.StringBuilder: java.lang.String toString()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.groups.ZKClient: org.apache.zookeeper.data.Stat setData(java.lang.String,byte[],int)>(v, v, v);
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup: scala.collection.mutable.HashMap joins()>();
v = virtualinvoke v.<org.apache.zookeeper.data.Stat: int getVersion()>();
v = staticinvoke <scala.runtime.BoxesRunTime: java.lang.Integer boxToInteger(int)>(v);
v = virtualinvoke v.<scala.collection.mutable.HashMap: scala.Option put(java.lang.Object,java.lang.Object)>(v, v);
label:
return v;
label:
v := @caughtexception;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup: scala.collection.mutable.HashMap joins()>();
virtualinvoke v.<scala.collection.mutable.HashMap: scala.Option remove(java.lang.Object)>(v);
throw v;
catch org.apache.zookeeper.KeeperException$NoNodeException from label to label with label;
}
public void <init>(org.apache.activemq.leveldb.replicated.groups.ZKClient, java.lang.String)
{
org.linkedin.zookeeper.tracker.ZooKeeperTreeTracker v, v;
org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup v;
org.apache.activemq.leveldb.replicated.groups.ZKClient v;
org.linkedin.zookeeper.tracker.NodeEventsListener v;
java.lang.Integer v;
org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup$$anon$1 v;
java.util.LinkedHashMap v;
scala.collection.mutable.HashMap$ v;
scala.collection.GenMap v;
java.lang.String v;
org.linkedin.zookeeper.tracker.ZKByteArrayDataReader v;
scala.collection.immutable.Nil$ v;
v := @this: org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup;
v := @parameter: org.apache.activemq.leveldb.replicated.groups.ZKClient;
v := @parameter: java.lang.String;
v.<org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup: org.apache.activemq.leveldb.replicated.groups.ZKClient zk> = v;
v.<org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup: java.lang.String root> = v;
specialinvoke v.<java.lang.Object: void <init>()>();
staticinvoke <org.apache.activemq.leveldb.replicated.groups.ChangeListenerSupport$class: void $init$(org.apache.activemq.leveldb.replicated.groups.ChangeListenerSupport)>(v);
v = new org.linkedin.zookeeper.tracker.ZooKeeperTreeTracker;
v = new org.linkedin.zookeeper.tracker.ZKByteArrayDataReader;
specialinvoke v.<org.linkedin.zookeeper.tracker.ZKByteArrayDataReader: void <init>()>();
specialinvoke v.<org.linkedin.zookeeper.tracker.ZooKeeperTreeTracker: void <init>(org.linkedin.zookeeper.client.IZKClient,org.linkedin.zookeeper.tracker.ZKDataReader,java.lang.String,int)>(v, v, v, 1);
v.<org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup: org.linkedin.zookeeper.tracker.ZooKeeperTreeTracker tree> = v;
v.<org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup: boolean rebuildTree> = 0;
v = <scala.collection.mutable.HashMap$: scala.collection.mutable.HashMap$ MODULE$>;
v = <scala.collection.immutable.Nil$: scala.collection.immutable.Nil$ MODULE$>;
v = virtualinvoke v.<scala.collection.mutable.HashMap$: scala.collection.GenMap apply(scala.collection.Seq)>(v);
v.<org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup: scala.collection.mutable.HashMap joins> = v;
v = new java.util.LinkedHashMap;
specialinvoke v.<java.util.LinkedHashMap: void <init>()>();
v.<org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup: java.util.LinkedHashMap members> = v;
virtualinvoke v.<org.apache.activemq.leveldb.replicated.groups.ZKClient: void registerListener(org.linkedin.zookeeper.client.LifecycleListener)>(v);
v = specialinvoke v.<org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup: java.lang.Integer create$default$2()>();
specialinvoke v.<org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup: void create(java.lang.String,java.lang.Integer)>(v, v);
v = new org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup$$anon$1;
specialinvoke v.<org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup$$anon$1: void <init>(org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup)>(v);
v.<org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup: org.linkedin.zookeeper.tracker.NodeEventsListener treeEventHandler> = v;
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup: org.linkedin.zookeeper.tracker.ZooKeeperTreeTracker tree()>();
v = virtualinvoke v.<org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup: org.linkedin.zookeeper.tracker.NodeEventsListener treeEventHandler()>();
virtualinvoke v.<org.linkedin.zookeeper.tracker.ZooKeeperTreeTracker: void track(org.linkedin.zookeeper.tracker.NodeEventsListener)>(v);
virtualinvoke v.<org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup: void org$apache$activemq$leveldb$replicated$groups$ZooKeeperGroup$$fire_cluster_change()>();
v.<org.apache.activemq.leveldb.replicated.groups.ZooKeeperGroup: boolean closed> = 0;
return;
}
}