public class org.apache.drill.yarn.zk.TestZkRegistry extends org.apache.drill.test.BaseTest
{
private static final java.lang.String BARNEY_HOST;
private static final java.lang.String WILMA_HOST;
private static final java.lang.String TEST_HOST;
private static final java.lang.String FRED_HOST;
public static final int TEST_USER_PORT;
public static final int TEST_CONTROL_PORT;
public static final int TEST_DATA_PORT;
public static final java.lang.String ZK_ROOT;
public static final java.lang.String CLUSTER_ID;
public void <init>()
{
org.apache.drill.yarn.zk.TestZkRegistry v;
v := @this: org.apache.drill.yarn.zk.TestZkRegistry;
specialinvoke v.<org.apache.drill.test.BaseTest: void <init>()>();
return;
}
public void testFormat()
{
org.apache.drill.yarn.zk.TestZkRegistry v;
org.apache.drill.yarn.zk.ZKClusterCoordinatorDriver v, v, v;
java.lang.String v, v, v, v, v;
org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint v;
v := @this: org.apache.drill.yarn.zk.TestZkRegistry;
v = specialinvoke v.<org.apache.drill.yarn.zk.TestZkRegistry: org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint makeEndpoint(java.lang.String)>("host");
v = staticinvoke <org.apache.drill.yarn.zk.TestZkRegistry: java.lang.String makeKey(java.lang.String)>("host");
v = staticinvoke <org.apache.drill.yarn.zk.ZKClusterCoordinatorDriver: java.lang.String asString(org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint)>(v);
staticinvoke <org.junit.Assert: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = new org.apache.drill.yarn.zk.ZKClusterCoordinatorDriver;
specialinvoke v.<org.apache.drill.yarn.zk.ZKClusterCoordinatorDriver: void <init>()>();
v = virtualinvoke v.<org.apache.drill.yarn.zk.ZKClusterCoordinatorDriver: org.apache.drill.yarn.zk.ZKClusterCoordinatorDriver setPorts(int,int,int)>(123, 456, 789);
v = staticinvoke <org.apache.drill.yarn.zk.TestZkRegistry: java.lang.String makeKey(java.lang.String)>("host");
v = virtualinvoke v.<org.apache.drill.yarn.zk.ZKClusterCoordinatorDriver: java.lang.String toKey(java.lang.String)>("host");
staticinvoke <org.junit.Assert: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = new org.apache.drill.yarn.zk.ZKClusterCoordinatorDriver;
specialinvoke v.<org.apache.drill.yarn.zk.ZKClusterCoordinatorDriver: void <init>()>();
v = virtualinvoke v.<org.apache.drill.yarn.zk.ZKClusterCoordinatorDriver: java.lang.String toKey(java.lang.String)>("fred");
staticinvoke <org.junit.Assert: void assertEquals(java.lang.Object,java.lang.Object)>("fred:31010:31011:31012", v);
return;
}
public static java.lang.String makeKey(java.lang.String)
{
java.lang.String v, v;
v := @parameter: java.lang.String;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001:123:456:789");
return v;
}
public void testBasics() throws java.lang.Exception
{
java.lang.Throwable v;
org.apache.drill.yarn.zk.TestZkRegistry v;
java.util.List v;
org.apache.drill.yarn.zk.ZKClusterCoordinatorDriver v, v, v;
org.apache.curator.test.TestingServer v;
java.lang.String v;
boolean v;
v := @this: org.apache.drill.yarn.zk.TestZkRegistry;
v = new org.apache.curator.test.TestingServer;
specialinvoke v.<org.apache.curator.test.TestingServer: void <init>()>();
label:
virtualinvoke v.<org.apache.curator.test.TestingServer: void start()>();
v = virtualinvoke v.<org.apache.curator.test.TestingServer: java.lang.String getConnectString()>();
v = new org.apache.drill.yarn.zk.ZKClusterCoordinatorDriver;
specialinvoke v.<org.apache.drill.yarn.zk.ZKClusterCoordinatorDriver: void <init>()>();
v = virtualinvoke v.<org.apache.drill.yarn.zk.ZKClusterCoordinatorDriver: org.apache.drill.yarn.zk.ZKClusterCoordinatorDriver setConnect(java.lang.String,java.lang.String,java.lang.String)>(v, "drill", "drillbits");
v = virtualinvoke v.<org.apache.drill.yarn.zk.ZKClusterCoordinatorDriver: org.apache.drill.yarn.zk.ZKClusterCoordinatorDriver build()>();
v = virtualinvoke v.<org.apache.drill.yarn.zk.ZKClusterCoordinatorDriver: java.util.List getInitialEndpoints()>();
v = interfaceinvoke v.<java.util.List: boolean isEmpty()>();
staticinvoke <org.junit.Assert: void assertTrue(boolean)>(v);
virtualinvoke v.<org.apache.drill.yarn.zk.ZKClusterCoordinatorDriver: void close()>();
virtualinvoke v.<org.apache.curator.test.TestingServer: void stop()>();
label:
virtualinvoke v.<org.apache.curator.test.TestingServer: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
public void testCycle() throws java.lang.Exception
{
org.apache.drill.yarn.zk.ZKClusterCoordinatorDriver v, v, v;
boolean v, v;
org.apache.drill.yarn.zk.TestZkRegistry$TestDrillbitStatusListener v;
java.util.Set v, v, v, v, v, v, v, v;
java.util.List v;
org.apache.curator.framework.CuratorFramework v;
int v, v, v;
org.apache.curator.test.TestingServer v;
java.lang.String v, v, v, v, v, v, v;
java.util.Iterator v, v;
org.apache.drill.yarn.zk.TestZkRegistry v;
java.lang.Object v, v, v;
v := @this: org.apache.drill.yarn.zk.TestZkRegistry;
v = new org.apache.curator.test.TestingServer;
specialinvoke v.<org.apache.curator.test.TestingServer: void <init>()>();
virtualinvoke v.<org.apache.curator.test.TestingServer: void start()>();
v = virtualinvoke v.<org.apache.curator.test.TestingServer: java.lang.String getConnectString()>();
v = staticinvoke <org.apache.drill.yarn.zk.TestZkRegistry: org.apache.curator.framework.CuratorFramework connectToZk(java.lang.String)>(v);
specialinvoke v.<org.apache.drill.yarn.zk.TestZkRegistry: void addDrillbit(org.apache.curator.framework.CuratorFramework,java.lang.String)>(v, "fred");
v = new org.apache.drill.yarn.zk.ZKClusterCoordinatorDriver;
specialinvoke v.<org.apache.drill.yarn.zk.ZKClusterCoordinatorDriver: void <init>()>();
v = virtualinvoke v.<org.apache.drill.yarn.zk.ZKClusterCoordinatorDriver: org.apache.drill.yarn.zk.ZKClusterCoordinatorDriver setConnect(java.lang.String,java.lang.String,java.lang.String)>(v, "test-root", "test-cluster");
v = virtualinvoke v.<org.apache.drill.yarn.zk.ZKClusterCoordinatorDriver: org.apache.drill.yarn.zk.ZKClusterCoordinatorDriver build()>();
v = virtualinvoke v.<org.apache.drill.yarn.zk.ZKClusterCoordinatorDriver: java.util.List getInitialEndpoints()>();
v = interfaceinvoke v.<java.util.List: int size()>();
staticinvoke <org.junit.Assert: void assertEquals(long,long)>(1L, v);
v = staticinvoke <org.apache.drill.yarn.zk.TestZkRegistry: java.lang.String makeKey(java.lang.String)>("fred");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = staticinvoke <org.apache.drill.yarn.zk.ZKClusterCoordinatorDriver: java.lang.String asString(org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint)>(v);
staticinvoke <org.junit.Assert: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = new org.apache.drill.yarn.zk.TestZkRegistry$TestDrillbitStatusListener;
specialinvoke v.<org.apache.drill.yarn.zk.TestZkRegistry$TestDrillbitStatusListener: void <init>(org.apache.drill.yarn.zk.TestZkRegistry)>(v);
virtualinvoke v.<org.apache.drill.yarn.zk.ZKClusterCoordinatorDriver: void addDrillbitListener(org.apache.drill.exec.work.foreman.DrillbitStatusListener)>(v);
specialinvoke v.<org.apache.drill.yarn.zk.TestZkRegistry: void addDrillbit(org.apache.curator.framework.CuratorFramework,java.lang.String)>(v, "wilma");
staticinvoke <java.lang.Thread: void sleep(long)>(50L);
v = v.<org.apache.drill.yarn.zk.TestZkRegistry$TestDrillbitStatusListener: java.util.Set removed>;
staticinvoke <org.junit.Assert: void assertNull(java.lang.Object)>(v);
v = v.<org.apache.drill.yarn.zk.TestZkRegistry$TestDrillbitStatusListener: java.util.Set added>;
staticinvoke <org.junit.Assert: void assertNotNull(java.lang.Object)>(v);
v = v.<org.apache.drill.yarn.zk.TestZkRegistry$TestDrillbitStatusListener: java.util.Set added>;
v = interfaceinvoke v.<java.util.Set: int size()>();
staticinvoke <org.junit.Assert: void assertEquals(long,long)>(1L, v);
v = v.<org.apache.drill.yarn.zk.TestZkRegistry$TestDrillbitStatusListener: java.util.Set added>;
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = staticinvoke <org.apache.drill.yarn.zk.TestZkRegistry: java.lang.String makeKey(java.lang.String)>("wilma");
v = staticinvoke <org.apache.drill.yarn.zk.ZKClusterCoordinatorDriver: java.lang.String asString(org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint)>(v);
staticinvoke <org.junit.Assert: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
goto label;
label:
virtualinvoke v.<org.apache.drill.yarn.zk.TestZkRegistry$TestDrillbitStatusListener: void clear()>();
specialinvoke v.<org.apache.drill.yarn.zk.TestZkRegistry: void removeDrillbit(org.apache.curator.framework.CuratorFramework,java.lang.String)>(v, "fred");
staticinvoke <java.lang.Thread: void sleep(long)>(50L);
v = v.<org.apache.drill.yarn.zk.TestZkRegistry$TestDrillbitStatusListener: java.util.Set added>;
staticinvoke <org.junit.Assert: void assertNull(java.lang.Object)>(v);
v = v.<org.apache.drill.yarn.zk.TestZkRegistry$TestDrillbitStatusListener: java.util.Set removed>;
staticinvoke <org.junit.Assert: void assertNotNull(java.lang.Object)>(v);
v = v.<org.apache.drill.yarn.zk.TestZkRegistry$TestDrillbitStatusListener: java.util.Set removed>;
v = interfaceinvoke v.<java.util.Set: int size()>();
staticinvoke <org.junit.Assert: void assertEquals(long,long)>(1L, v);
v = v.<org.apache.drill.yarn.zk.TestZkRegistry$TestDrillbitStatusListener: java.util.Set removed>;
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = staticinvoke <org.apache.drill.yarn.zk.TestZkRegistry: java.lang.String makeKey(java.lang.String)>("fred");
v = staticinvoke <org.apache.drill.yarn.zk.ZKClusterCoordinatorDriver: java.lang.String asString(org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint)>(v);
staticinvoke <org.junit.Assert: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
goto label;
label:
interfaceinvoke v.<org.apache.curator.framework.CuratorFramework: void close()>();
virtualinvoke v.<org.apache.drill.yarn.zk.ZKClusterCoordinatorDriver: void close()>();
virtualinvoke v.<org.apache.curator.test.TestingServer: void stop()>();
virtualinvoke v.<org.apache.curator.test.TestingServer: void close()>();
return;
}
private org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint makeEndpoint(java.lang.String)
{
org.apache.drill.yarn.zk.TestZkRegistry v;
java.lang.String v;
org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint$Builder v, v, v, v, v;
org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint v;
v := @this: org.apache.drill.yarn.zk.TestZkRegistry;
v := @parameter: java.lang.String;
v = staticinvoke <org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint: org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint$Builder newBuilder()>();
v = virtualinvoke v.<org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint$Builder: org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint$Builder setAddress(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint$Builder: org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint$Builder setControlPort(int)>(456);
v = virtualinvoke v.<org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint$Builder: org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint$Builder setDataPort(int)>(789);
v = virtualinvoke v.<org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint$Builder: org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint$Builder setUserPort(int)>(123);
v = virtualinvoke v.<org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint$Builder: org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint build()>();
return v;
}
private void addDrillbit(org.apache.curator.framework.CuratorFramework, java.lang.String) throws java.lang.Exception
{
byte[] v;
org.apache.curator.x.discovery.ServiceInstance v;
org.apache.curator.framework.api.CreateBuilder v;
org.apache.drill.yarn.zk.TestZkRegistry v;
org.apache.curator.framework.CuratorFramework v;
org.apache.curator.x.discovery.ServiceInstanceBuilder v, v, v;
java.lang.String v, v;
org.apache.curator.x.discovery.details.InstanceSerializer v;
org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint v;
v := @this: org.apache.drill.yarn.zk.TestZkRegistry;
v := @parameter: org.apache.curator.framework.CuratorFramework;
v := @parameter: java.lang.String;
v = specialinvoke v.<org.apache.drill.yarn.zk.TestZkRegistry: org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint makeEndpoint(java.lang.String)>(v);
v = staticinvoke <org.apache.curator.x.discovery.ServiceInstance: org.apache.curator.x.discovery.ServiceInstanceBuilder builder()>();
v = virtualinvoke v.<org.apache.curator.x.discovery.ServiceInstanceBuilder: org.apache.curator.x.discovery.ServiceInstanceBuilder name(java.lang.String)>("test-cluster");
v = virtualinvoke v.<org.apache.curator.x.discovery.ServiceInstanceBuilder: org.apache.curator.x.discovery.ServiceInstanceBuilder payload(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.curator.x.discovery.ServiceInstanceBuilder: org.apache.curator.x.discovery.ServiceInstance build()>();
v = <org.apache.drill.exec.coord.DrillServiceInstanceHelper: org.apache.curator.x.discovery.details.InstanceSerializer SERIALIZER>;
v = interfaceinvoke v.<org.apache.curator.x.discovery.details.InstanceSerializer: byte[] serialize(org.apache.curator.x.discovery.ServiceInstance)>(v);
v = interfaceinvoke v.<org.apache.curator.framework.CuratorFramework: org.apache.curator.framework.api.CreateBuilder create()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("/\u0001");
interfaceinvoke v.<org.apache.curator.framework.api.CreateBuilder: java.lang.Object forPath(java.lang.String,byte[])>(v, v);
return;
}
private void removeDrillbit(org.apache.curator.framework.CuratorFramework, java.lang.String) throws java.lang.Exception
{
org.apache.curator.framework.CuratorFramework v;
org.apache.curator.framework.api.DeleteBuilder v;
java.lang.String v, v;
org.apache.drill.yarn.zk.TestZkRegistry v;
v := @this: org.apache.drill.yarn.zk.TestZkRegistry;
v := @parameter: org.apache.curator.framework.CuratorFramework;
v := @parameter: java.lang.String;
v = interfaceinvoke v.<org.apache.curator.framework.CuratorFramework: org.apache.curator.framework.api.DeleteBuilder delete()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("/\u0001");
interfaceinvoke v.<org.apache.curator.framework.api.DeleteBuilder: java.lang.Object forPath(java.lang.String)>(v);
return;
}
public static org.apache.curator.framework.CuratorFramework connectToZk(java.lang.String)
{
org.apache.curator.framework.CuratorFramework v;
org.apache.curator.framework.CuratorFrameworkFactory$Builder v, v, v, v;
java.lang.String v;
org.apache.curator.retry.RetryNTimes v;
v := @parameter: java.lang.String;
v = staticinvoke <org.apache.curator.framework.CuratorFrameworkFactory: org.apache.curator.framework.CuratorFrameworkFactory$Builder builder()>();
v = virtualinvoke v.<org.apache.curator.framework.CuratorFrameworkFactory$Builder: org.apache.curator.framework.CuratorFrameworkFactory$Builder namespace(java.lang.String)>("test-root/test-cluster");
v = virtualinvoke v.<org.apache.curator.framework.CuratorFrameworkFactory$Builder: org.apache.curator.framework.CuratorFrameworkFactory$Builder connectString(java.lang.String)>(v);
v = new org.apache.curator.retry.RetryNTimes;
specialinvoke v.<org.apache.curator.retry.RetryNTimes: void <init>(int,int)>(3, 1000);
v = virtualinvoke v.<org.apache.curator.framework.CuratorFrameworkFactory$Builder: org.apache.curator.framework.CuratorFrameworkFactory$Builder retryPolicy(org.apache.curator.RetryPolicy)>(v);
v = virtualinvoke v.<org.apache.curator.framework.CuratorFrameworkFactory$Builder: org.apache.curator.framework.CuratorFramework build()>();
interfaceinvoke v.<org.apache.curator.framework.CuratorFramework: void start()>();
return v;
}
public void testZKRegistry() throws java.lang.Exception
{
java.util.Map v, v, v, v, v, v, v, v, v, v, v;
org.apache.drill.yarn.zk.TestZkRegistry$TestTask v, v;
org.apache.drill.yarn.appMaster.Task v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.drill.yarn.zk.ZKRegistry$DrillbitTracker$State v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.curator.test.TestingServer v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.drill.yarn.zk.ZKClusterCoordinatorDriver v, v, v, v;
boolean v, v;
org.apache.drill.yarn.zk.TestZkRegistry$TestRegistryHandler v;
org.apache.drill.yarn.appMaster.TaskLifecycleListener$Event v, v, v, v, v, v;
java.util.List v, v, v;
org.apache.curator.framework.CuratorFramework v;
org.apache.drill.yarn.zk.ZKRegistry v;
int v, v, v, v, v, v;
org.apache.drill.yarn.zk.TestZkRegistry v;
org.apache.drill.yarn.appMaster.EventContext v, v, v;
java.lang.Object v, v, v, v, v, v, v, v, v;
org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint v, v;
v := @this: org.apache.drill.yarn.zk.TestZkRegistry;
v = new org.apache.curator.test.TestingServer;
specialinvoke v.<org.apache.curator.test.TestingServer: void <init>()>();
virtualinvoke v.<org.apache.curator.test.TestingServer: void start()>();
v = virtualinvoke v.<org.apache.curator.test.TestingServer: java.lang.String getConnectString()>();
v = staticinvoke <org.apache.drill.yarn.zk.TestZkRegistry: org.apache.curator.framework.CuratorFramework connectToZk(java.lang.String)>(v);
specialinvoke v.<org.apache.drill.yarn.zk.TestZkRegistry: void addDrillbit(org.apache.curator.framework.CuratorFramework,java.lang.String)>(v, "fred");
v = new org.apache.drill.yarn.zk.ZKClusterCoordinatorDriver;
specialinvoke v.<org.apache.drill.yarn.zk.ZKClusterCoordinatorDriver: void <init>()>();
v = virtualinvoke v.<org.apache.drill.yarn.zk.ZKClusterCoordinatorDriver: org.apache.drill.yarn.zk.ZKClusterCoordinatorDriver setConnect(java.lang.String,java.lang.String,java.lang.String)>(v, "test-root", "test-cluster");
v = virtualinvoke v.<org.apache.drill.yarn.zk.ZKClusterCoordinatorDriver: org.apache.drill.yarn.zk.ZKClusterCoordinatorDriver setPorts(int,int,int)>(123, 456, 789);
v = virtualinvoke v.<org.apache.drill.yarn.zk.ZKClusterCoordinatorDriver: org.apache.drill.yarn.zk.ZKClusterCoordinatorDriver build()>();
v = new org.apache.drill.yarn.zk.ZKRegistry;
specialinvoke v.<org.apache.drill.yarn.zk.ZKRegistry: void <init>(org.apache.drill.yarn.zk.ZKClusterCoordinatorDriver)>(v);
v = new org.apache.drill.yarn.zk.TestZkRegistry$TestRegistryHandler;
specialinvoke v.<org.apache.drill.yarn.zk.TestZkRegistry$TestRegistryHandler: void <init>()>();
virtualinvoke v.<org.apache.drill.yarn.zk.ZKRegistry: void start(org.apache.drill.yarn.appMaster.RegistryHandler)>(v);
v = v.<org.apache.drill.yarn.zk.TestZkRegistry$TestRegistryHandler: java.lang.String reserved>;
staticinvoke <org.junit.Assert: void assertEquals(java.lang.Object,java.lang.Object)>("fred", v);
v = virtualinvoke v.<org.apache.drill.yarn.zk.ZKRegistry: java.util.List listUnmanagedDrillits()>();
v = interfaceinvoke v.<java.util.List: int size()>();
staticinvoke <org.junit.Assert: void assertEquals(long,long)>(1L, v);
v = staticinvoke <org.apache.drill.yarn.zk.TestZkRegistry: java.lang.String makeKey(java.lang.String)>("fred");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
staticinvoke <org.junit.Assert: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = virtualinvoke v.<org.apache.drill.yarn.zk.ZKRegistry: java.util.Map getRegistryForTesting()>();
v = interfaceinvoke v.<java.util.Map: int size()>();
staticinvoke <org.junit.Assert: void assertEquals(long,long)>(1L, v);
v = interfaceinvoke v.<java.util.Map: boolean containsKey(java.lang.Object)>(v);
staticinvoke <org.junit.Assert: void assertTrue(boolean)>(v);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
v = v.<org.apache.drill.yarn.zk.ZKRegistry$DrillbitTracker: java.lang.String key>;
staticinvoke <org.junit.Assert: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = <org.apache.drill.yarn.zk.ZKRegistry$DrillbitTracker$State: org.apache.drill.yarn.zk.ZKRegistry$DrillbitTracker$State UNMANAGED>;
v = v.<org.apache.drill.yarn.zk.ZKRegistry$DrillbitTracker: org.apache.drill.yarn.zk.ZKRegistry$DrillbitTracker$State state>;
staticinvoke <org.junit.Assert: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = v.<org.apache.drill.yarn.zk.ZKRegistry$DrillbitTracker: org.apache.drill.yarn.appMaster.Task task>;
staticinvoke <org.junit.Assert: void assertNull(java.lang.Object)>(v);
v = v.<org.apache.drill.yarn.zk.ZKRegistry$DrillbitTracker: org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint endpoint>;
v = staticinvoke <org.apache.drill.yarn.zk.ZKClusterCoordinatorDriver: java.lang.String asString(org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint)>(v);
staticinvoke <org.junit.Assert: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = v.<org.apache.drill.yarn.zk.TestZkRegistry$TestRegistryHandler: java.lang.String reserved>;
staticinvoke <org.junit.Assert: void assertEquals(java.lang.Object,java.lang.Object)>("fred", v);
v = new org.apache.drill.yarn.zk.TestZkRegistry$TestTask;
specialinvoke v.<org.apache.drill.yarn.zk.TestZkRegistry$TestTask: void <init>(java.lang.String)>("wilma");
v = new org.apache.drill.yarn.appMaster.EventContext;
specialinvoke v.<org.apache.drill.yarn.appMaster.EventContext: void <init>(org.apache.drill.yarn.appMaster.Task)>(v);
v = <org.apache.drill.yarn.appMaster.TaskLifecycleListener$Event: org.apache.drill.yarn.appMaster.TaskLifecycleListener$Event CREATED>;
virtualinvoke v.<org.apache.drill.yarn.zk.ZKRegistry: void stateChange(org.apache.drill.yarn.appMaster.TaskLifecycleListener$Event,org.apache.drill.yarn.appMaster.EventContext)>(v, v);
v = virtualinvoke v.<org.apache.drill.yarn.zk.ZKRegistry: java.util.Map getRegistryForTesting()>();
v = interfaceinvoke v.<java.util.Map: int size()>();
staticinvoke <org.junit.Assert: void assertEquals(long,long)>(1L, v);
v = <org.apache.drill.yarn.appMaster.TaskLifecycleListener$Event: org.apache.drill.yarn.appMaster.TaskLifecycleListener$Event ALLOCATED>;
virtualinvoke v.<org.apache.drill.yarn.zk.ZKRegistry: void stateChange(org.apache.drill.yarn.appMaster.TaskLifecycleListener$Event,org.apache.drill.yarn.appMaster.EventContext)>(v, v);
v = virtualinvoke v.<org.apache.drill.yarn.zk.ZKRegistry: java.util.Map getRegistryForTesting()>();
v = interfaceinvoke v.<java.util.Map: int size()>();
staticinvoke <org.junit.Assert: void assertEquals(long,long)>(2L, v);
v = staticinvoke <org.apache.drill.yarn.zk.TestZkRegistry: java.lang.String makeKey(java.lang.String)>("wilma");
v = virtualinvoke v.<org.apache.drill.yarn.zk.ZKRegistry: java.util.Map getRegistryForTesting()>();
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
staticinvoke <org.junit.Assert: void assertNotNull(java.lang.Object)>(v);
v = v.<org.apache.drill.yarn.zk.ZKRegistry$DrillbitTracker: org.apache.drill.yarn.appMaster.Task task>;
staticinvoke <org.junit.Assert: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = v.<org.apache.drill.yarn.zk.ZKRegistry$DrillbitTracker: org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint endpoint>;
staticinvoke <org.junit.Assert: void assertNull(java.lang.Object)>(v);
v = v.<org.apache.drill.yarn.zk.ZKRegistry$DrillbitTracker: java.lang.String key>;
staticinvoke <org.junit.Assert: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = <org.apache.drill.yarn.zk.ZKRegistry$DrillbitTracker$State: org.apache.drill.yarn.zk.ZKRegistry$DrillbitTracker$State NEW>;
v = v.<org.apache.drill.yarn.zk.ZKRegistry$DrillbitTracker: org.apache.drill.yarn.zk.ZKRegistry$DrillbitTracker$State state>;
staticinvoke <org.junit.Assert: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
virtualinvoke v.<org.apache.drill.yarn.zk.TestZkRegistry$TestRegistryHandler: void clear()>();
specialinvoke v.<org.apache.drill.yarn.zk.TestZkRegistry: void addDrillbit(org.apache.curator.framework.CuratorFramework,java.lang.String)>(v, "wilma");
staticinvoke <java.lang.Thread: void sleep(long)>(100L);
v = v.<org.apache.drill.yarn.zk.TestZkRegistry$TestRegistryHandler: org.apache.drill.yarn.appMaster.Task start>;
staticinvoke <org.junit.Assert: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = <org.apache.drill.yarn.zk.ZKRegistry$DrillbitTracker$State: org.apache.drill.yarn.zk.ZKRegistry$DrillbitTracker$State REGISTERED>;
v = v.<org.apache.drill.yarn.zk.ZKRegistry$DrillbitTracker: org.apache.drill.yarn.zk.ZKRegistry$DrillbitTracker$State state>;
staticinvoke <org.junit.Assert: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = v.<org.apache.drill.yarn.zk.TestZkRegistry$TestRegistryHandler: org.apache.drill.yarn.appMaster.Task start>;
staticinvoke <org.junit.Assert: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = new org.apache.drill.yarn.zk.TestZkRegistry$TestTask;
specialinvoke v.<org.apache.drill.yarn.zk.TestZkRegistry$TestTask: void <init>(java.lang.String)>("barney");
v = new org.apache.drill.yarn.appMaster.EventContext;
specialinvoke v.<org.apache.drill.yarn.appMaster.EventContext: void <init>(org.apache.drill.yarn.appMaster.Task)>(v);
v = <org.apache.drill.yarn.appMaster.TaskLifecycleListener$Event: org.apache.drill.yarn.appMaster.TaskLifecycleListener$Event CREATED>;
virtualinvoke v.<org.apache.drill.yarn.zk.ZKRegistry: void stateChange(org.apache.drill.yarn.appMaster.TaskLifecycleListener$Event,org.apache.drill.yarn.appMaster.EventContext)>(v, v);
virtualinvoke v.<org.apache.drill.yarn.zk.TestZkRegistry$TestRegistryHandler: void clear()>();
specialinvoke v.<org.apache.drill.yarn.zk.TestZkRegistry: void addDrillbit(org.apache.curator.framework.CuratorFramework,java.lang.String)>(v, "barney");
staticinvoke <java.lang.Thread: void sleep(long)>(100L);
v = v.<org.apache.drill.yarn.zk.TestZkRegistry$TestRegistryHandler: java.lang.String reserved>;
staticinvoke <org.junit.Assert: void assertEquals(java.lang.Object,java.lang.Object)>("barney", v);
v = staticinvoke <org.apache.drill.yarn.zk.TestZkRegistry: java.lang.String makeKey(java.lang.String)>("barney");
v = virtualinvoke v.<org.apache.drill.yarn.zk.ZKRegistry: java.util.Map getRegistryForTesting()>();
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
staticinvoke <org.junit.Assert: void assertNotNull(java.lang.Object)>(v);
v = <org.apache.drill.yarn.zk.ZKRegistry$DrillbitTracker$State: org.apache.drill.yarn.zk.ZKRegistry$DrillbitTracker$State UNMANAGED>;
v = v.<org.apache.drill.yarn.zk.ZKRegistry$DrillbitTracker: org.apache.drill.yarn.zk.ZKRegistry$DrillbitTracker$State state>;
staticinvoke <org.junit.Assert: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = v.<org.apache.drill.yarn.zk.ZKRegistry$DrillbitTracker: org.apache.drill.yarn.appMaster.Task task>;
staticinvoke <org.junit.Assert: void assertNull(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.drill.yarn.zk.ZKRegistry: java.util.List listUnmanagedDrillits()>();
v = interfaceinvoke v.<java.util.List: int size()>();
staticinvoke <org.junit.Assert: void assertEquals(long,long)>(2L, v);
virtualinvoke v.<org.apache.drill.yarn.zk.TestZkRegistry$TestRegistryHandler: void clear()>();
v = <org.apache.drill.yarn.appMaster.TaskLifecycleListener$Event: org.apache.drill.yarn.appMaster.TaskLifecycleListener$Event ALLOCATED>;
virtualinvoke v.<org.apache.drill.yarn.zk.ZKRegistry: void stateChange(org.apache.drill.yarn.appMaster.TaskLifecycleListener$Event,org.apache.drill.yarn.appMaster.EventContext)>(v, v);
v = <org.apache.drill.yarn.zk.ZKRegistry$DrillbitTracker$State: org.apache.drill.yarn.zk.ZKRegistry$DrillbitTracker$State REGISTERED>;
v = v.<org.apache.drill.yarn.zk.ZKRegistry$DrillbitTracker: org.apache.drill.yarn.zk.ZKRegistry$DrillbitTracker$State state>;
staticinvoke <org.junit.Assert: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = v.<org.apache.drill.yarn.zk.TestZkRegistry$TestRegistryHandler: org.apache.drill.yarn.appMaster.Task start>;
staticinvoke <org.junit.Assert: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = v.<org.apache.drill.yarn.zk.ZKRegistry$DrillbitTracker: org.apache.drill.yarn.appMaster.Task task>;
staticinvoke <org.junit.Assert: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = virtualinvoke v.<org.apache.drill.yarn.zk.ZKRegistry: java.util.List listUnmanagedDrillits()>();
v = interfaceinvoke v.<java.util.List: int size()>();
staticinvoke <org.junit.Assert: void assertEquals(long,long)>(1L, v);
virtualinvoke v.<org.apache.drill.yarn.zk.TestZkRegistry$TestRegistryHandler: void clear()>();
specialinvoke v.<org.apache.drill.yarn.zk.TestZkRegistry: void removeDrillbit(org.apache.curator.framework.CuratorFramework,java.lang.String)>(v, "barney");
staticinvoke <java.lang.Thread: void sleep(long)>(100L);
v = v.<org.apache.drill.yarn.zk.TestZkRegistry$TestRegistryHandler: org.apache.drill.yarn.appMaster.Task end>;
staticinvoke <org.junit.Assert: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = <org.apache.drill.yarn.zk.ZKRegistry$DrillbitTracker$State: org.apache.drill.yarn.zk.ZKRegistry$DrillbitTracker$State DEREGISTERED>;
v = v.<org.apache.drill.yarn.zk.ZKRegistry$DrillbitTracker: org.apache.drill.yarn.zk.ZKRegistry$DrillbitTracker$State state>;
staticinvoke <org.junit.Assert: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
virtualinvoke v.<org.apache.drill.yarn.zk.TestZkRegistry$TestRegistryHandler: void clear()>();
specialinvoke v.<org.apache.drill.yarn.zk.TestZkRegistry: void addDrillbit(org.apache.curator.framework.CuratorFramework,java.lang.String)>(v, "barney");
staticinvoke <java.lang.Thread: void sleep(long)>(100L);
v = v.<org.apache.drill.yarn.zk.TestZkRegistry$TestRegistryHandler: org.apache.drill.yarn.appMaster.Task start>;
staticinvoke <org.junit.Assert: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = <org.apache.drill.yarn.zk.ZKRegistry$DrillbitTracker$State: org.apache.drill.yarn.zk.ZKRegistry$DrillbitTracker$State REGISTERED>;
v = v.<org.apache.drill.yarn.zk.ZKRegistry$DrillbitTracker: org.apache.drill.yarn.zk.ZKRegistry$DrillbitTracker$State state>;
staticinvoke <org.junit.Assert: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
virtualinvoke v.<org.apache.drill.yarn.zk.TestZkRegistry$TestRegistryHandler: void clear()>();
specialinvoke v.<org.apache.drill.yarn.zk.TestZkRegistry: void removeDrillbit(org.apache.curator.framework.CuratorFramework,java.lang.String)>(v, "barney");
staticinvoke <java.lang.Thread: void sleep(long)>(100L);
v = virtualinvoke v.<org.apache.drill.yarn.zk.ZKRegistry: java.util.Map getRegistryForTesting()>();
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
staticinvoke <org.junit.Assert: void assertNotNull(java.lang.Object)>(v);
v = v.<org.apache.drill.yarn.zk.TestZkRegistry$TestRegistryHandler: org.apache.drill.yarn.appMaster.Task end>;
staticinvoke <org.junit.Assert: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
virtualinvoke v.<org.apache.drill.yarn.zk.TestZkRegistry$TestRegistryHandler: void clear()>();
v = <org.apache.drill.yarn.appMaster.TaskLifecycleListener$Event: org.apache.drill.yarn.appMaster.TaskLifecycleListener$Event ENDED>;
virtualinvoke v.<org.apache.drill.yarn.zk.ZKRegistry: void stateChange(org.apache.drill.yarn.appMaster.TaskLifecycleListener$Event,org.apache.drill.yarn.appMaster.EventContext)>(v, v);
v = v.<org.apache.drill.yarn.zk.TestZkRegistry$TestRegistryHandler: org.apache.drill.yarn.appMaster.Task end>;
staticinvoke <org.junit.Assert: void assertNull(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.drill.yarn.zk.ZKRegistry: java.util.Map getRegistryForTesting()>();
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
staticinvoke <org.junit.Assert: void assertNull(java.lang.Object)>(v);
virtualinvoke v.<org.apache.drill.yarn.zk.TestZkRegistry$TestRegistryHandler: void clear()>();
specialinvoke v.<org.apache.drill.yarn.zk.TestZkRegistry: void removeDrillbit(org.apache.curator.framework.CuratorFramework,java.lang.String)>(v, "fred");
staticinvoke <java.lang.Thread: void sleep(long)>(100L);
v = virtualinvoke v.<org.apache.drill.yarn.zk.ZKRegistry: java.util.Map getRegistryForTesting()>();
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
staticinvoke <org.junit.Assert: void assertNull(java.lang.Object)>(v);
v = v.<org.apache.drill.yarn.zk.TestZkRegistry$TestRegistryHandler: org.apache.drill.yarn.appMaster.Task end>;
staticinvoke <org.junit.Assert: void assertNull(java.lang.Object)>(v);
v = v.<org.apache.drill.yarn.zk.TestZkRegistry$TestRegistryHandler: java.lang.String released>;
staticinvoke <org.junit.Assert: void assertEquals(java.lang.Object,java.lang.Object)>("fred", v);
virtualinvoke v.<org.apache.drill.yarn.zk.TestZkRegistry$TestRegistryHandler: void clear()>();
specialinvoke v.<org.apache.drill.yarn.zk.TestZkRegistry: void removeDrillbit(org.apache.curator.framework.CuratorFramework,java.lang.String)>(v, "wilma");
staticinvoke <java.lang.Thread: void sleep(long)>(100L);
v = v.<org.apache.drill.yarn.zk.TestZkRegistry$TestRegistryHandler: org.apache.drill.yarn.appMaster.Task end>;
staticinvoke <org.junit.Assert: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = v.<org.apache.drill.yarn.zk.TestZkRegistry$TestRegistryHandler: java.lang.String released>;
staticinvoke <org.junit.Assert: void assertNull(java.lang.Object)>(v);
v = <org.apache.drill.yarn.zk.ZKRegistry$DrillbitTracker$State: org.apache.drill.yarn.zk.ZKRegistry$DrillbitTracker$State DEREGISTERED>;
v = v.<org.apache.drill.yarn.zk.ZKRegistry$DrillbitTracker: org.apache.drill.yarn.zk.ZKRegistry$DrillbitTracker$State state>;
staticinvoke <org.junit.Assert: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = virtualinvoke v.<org.apache.drill.yarn.zk.ZKRegistry: java.util.Map getRegistryForTesting()>();
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
staticinvoke <org.junit.Assert: void assertNotNull(java.lang.Object)>(v);
virtualinvoke v.<org.apache.drill.yarn.zk.TestZkRegistry$TestRegistryHandler: void clear()>();
v = new org.apache.drill.yarn.appMaster.EventContext;
specialinvoke v.<org.apache.drill.yarn.appMaster.EventContext: void <init>(org.apache.drill.yarn.appMaster.Task)>(v);
v = <org.apache.drill.yarn.appMaster.TaskLifecycleListener$Event: org.apache.drill.yarn.appMaster.TaskLifecycleListener$Event ENDED>;
virtualinvoke v.<org.apache.drill.yarn.zk.ZKRegistry: void stateChange(org.apache.drill.yarn.appMaster.TaskLifecycleListener$Event,org.apache.drill.yarn.appMaster.EventContext)>(v, v);
v = virtualinvoke v.<org.apache.drill.yarn.zk.ZKRegistry: java.util.Map getRegistryForTesting()>();
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
staticinvoke <org.junit.Assert: void assertNull(java.lang.Object)>(v);
v = v.<org.apache.drill.yarn.zk.TestZkRegistry$TestRegistryHandler: java.lang.String released>;
staticinvoke <org.junit.Assert: void assertNull(java.lang.Object)>(v);
v = v.<org.apache.drill.yarn.zk.TestZkRegistry$TestRegistryHandler: org.apache.drill.yarn.appMaster.Task end>;
staticinvoke <org.junit.Assert: void assertNull(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.drill.yarn.zk.ZKRegistry: java.util.Map getRegistryForTesting()>();
v = interfaceinvoke v.<java.util.Map: boolean isEmpty()>();
staticinvoke <org.junit.Assert: void assertTrue(boolean)>(v);
interfaceinvoke v.<org.apache.curator.framework.CuratorFramework: void close()>();
virtualinvoke v.<org.apache.drill.yarn.zk.ZKClusterCoordinatorDriver: void close()>();
virtualinvoke v.<org.apache.curator.test.TestingServer: void stop()>();
virtualinvoke v.<org.apache.curator.test.TestingServer: void close()>();
return;
}
}