public final class org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager extends java.lang.Object
{
private static final java.util.logging.Logger logger;
private static final org.apache.drill.shaded.guava.com.google.common.util.concurrent.ListenerCallQueue$Event HEALTHY_EVENT;
private static final org.apache.drill.shaded.guava.com.google.common.util.concurrent.ListenerCallQueue$Event STOPPED_EVENT;
private final org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager$ServiceManagerState state;
private final org.apache.drill.shaded.guava.com.google.common.collect.ImmutableList services;
public void <init>(java.lang.Iterable)
{
org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager$ServiceListener v;
java.lang.Iterable v;
java.util.logging.Level v;
java.lang.ref.WeakReference v;
org.apache.drill.shaded.guava.com.google.common.collect.UnmodifiableIterator v;
boolean v, v, v;
org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager$EmptyServiceManagerWarning v;
java.util.concurrent.Executor v;
org.apache.drill.shaded.guava.com.google.common.util.concurrent.Service$State v, v;
org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager$NoOpService v;
java.util.logging.Logger v;
org.apache.drill.shaded.guava.com.google.common.collect.ImmutableList v;
org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager$ServiceManagerState v, v, v;
java.lang.Object v;
org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager v;
v := @this: org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager;
v := @parameter: java.lang.Iterable;
specialinvoke v.<java.lang.Object: void <init>()>();
v = staticinvoke <org.apache.drill.shaded.guava.com.google.common.collect.ImmutableList: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableList copyOf(java.lang.Iterable)>(v);
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableList: boolean isEmpty()>();
if v == 0 goto label;
v = <org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager: java.util.logging.Logger logger>;
v = <java.util.logging.Level: java.util.logging.Level WARNING>;
v = new org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager$EmptyServiceManagerWarning;
specialinvoke v.<org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager$EmptyServiceManagerWarning: void <init>()>();
virtualinvoke v.<java.util.logging.Logger: void log(java.util.logging.Level,java.lang.String,java.lang.Throwable)>(v, "ServiceManager configured with no services.  Is your application configured properly?", v);
v = new org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager$NoOpService;
specialinvoke v.<org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager$NoOpService: void <init>()>();
v = staticinvoke <org.apache.drill.shaded.guava.com.google.common.collect.ImmutableList: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableList of(java.lang.Object)>(v);
label:
v = new org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager$ServiceManagerState;
specialinvoke v.<org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager$ServiceManagerState: void <init>(org.apache.drill.shaded.guava.com.google.common.collect.ImmutableCollection)>(v);
v.<org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager: org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager$ServiceManagerState state> = v;
v.<org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableList services> = v;
v = new java.lang.ref.WeakReference;
v = v.<org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager: org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager$ServiceManagerState state>;
specialinvoke v.<java.lang.ref.WeakReference: void <init>(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableList: org.apache.drill.shaded.guava.com.google.common.collect.UnmodifiableIterator 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 = new org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager$ServiceListener;
specialinvoke v.<org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager$ServiceListener: void <init>(org.apache.drill.shaded.guava.com.google.common.util.concurrent.Service,java.lang.ref.WeakReference)>(v, v);
v = staticinvoke <org.apache.drill.shaded.guava.com.google.common.util.concurrent.MoreExecutors: java.util.concurrent.Executor directExecutor()>();
interfaceinvoke v.<org.apache.drill.shaded.guava.com.google.common.util.concurrent.Service: void addListener(org.apache.drill.shaded.guava.com.google.common.util.concurrent.Service$Listener,java.util.concurrent.Executor)>(v, v);
v = interfaceinvoke v.<org.apache.drill.shaded.guava.com.google.common.util.concurrent.Service: org.apache.drill.shaded.guava.com.google.common.util.concurrent.Service$State state()>();
v = <org.apache.drill.shaded.guava.com.google.common.util.concurrent.Service$State: org.apache.drill.shaded.guava.com.google.common.util.concurrent.Service$State NEW>;
if v != v goto label;
v = 1;
goto label;
label:
v = 0;
label:
staticinvoke <org.apache.drill.shaded.guava.com.google.common.base.Preconditions: void checkArgument(boolean,java.lang.String,java.lang.Object)>(v, "Can only manage NEW services, %s", v);
goto label;
label:
v = v.<org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager: org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager$ServiceManagerState state>;
virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager$ServiceManagerState: void markReady()>();
return;
}
public void addListener(org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager$Listener, java.util.concurrent.Executor)
{
org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager$Listener v;
java.util.concurrent.Executor v;
org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager v;
org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager$ServiceManagerState v;
v := @this: org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager;
v := @parameter: org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager$Listener;
v := @parameter: java.util.concurrent.Executor;
v = v.<org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager: org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager$ServiceManagerState state>;
virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager$ServiceManagerState: void addListener(org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager$Listener,java.util.concurrent.Executor)>(v, v);
return;
}
public void addListener(org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager$Listener)
{
org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager$Listener v;
java.util.concurrent.Executor v;
org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager v;
org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager$ServiceManagerState v;
v := @this: org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager;
v := @parameter: org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager$Listener;
v = v.<org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager: org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager$ServiceManagerState state>;
v = staticinvoke <org.apache.drill.shaded.guava.com.google.common.util.concurrent.MoreExecutors: java.util.concurrent.Executor directExecutor()>();
virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager$ServiceManagerState: void addListener(org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager$Listener,java.util.concurrent.Executor)>(v, v);
return;
}
public org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager startAsync()
{
java.lang.IllegalStateException v;
java.util.logging.Level v;
java.lang.String v;
org.apache.drill.shaded.guava.com.google.common.collect.UnmodifiableIterator v, v;
boolean v, v, v;
org.apache.drill.shaded.guava.com.google.common.util.concurrent.Service$State v, v;
java.util.logging.Logger v;
org.apache.drill.shaded.guava.com.google.common.collect.ImmutableList v, v;
org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager$ServiceManagerState v;
java.lang.Object v, v;
org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager v;
v := @this: org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager;
v = v.<org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableList services>;
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableList: org.apache.drill.shaded.guava.com.google.common.collect.UnmodifiableIterator 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 = interfaceinvoke v.<org.apache.drill.shaded.guava.com.google.common.util.concurrent.Service: org.apache.drill.shaded.guava.com.google.common.util.concurrent.Service$State state()>();
v = <org.apache.drill.shaded.guava.com.google.common.util.concurrent.Service$State: org.apache.drill.shaded.guava.com.google.common.util.concurrent.Service$State NEW>;
if v != v goto label;
v = 1;
goto label;
label:
v = 0;
label:
staticinvoke <org.apache.drill.shaded.guava.com.google.common.base.Preconditions: void checkState(boolean,java.lang.String,java.lang.Object,java.lang.Object)>(v, "Service %s is %s, cannot start it.", v, v);
goto label;
label:
v = v.<org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableList services>;
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableList: org.apache.drill.shaded.guava.com.google.common.collect.UnmodifiableIterator 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()>();
label:
v = v.<org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager: org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager$ServiceManagerState state>;
virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager$ServiceManagerState: void tryStartTiming(org.apache.drill.shaded.guava.com.google.common.util.concurrent.Service)>(v);
interfaceinvoke v.<org.apache.drill.shaded.guava.com.google.common.util.concurrent.Service: org.apache.drill.shaded.guava.com.google.common.util.concurrent.Service startAsync()>();
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager: java.util.logging.Logger logger>;
v = <java.util.logging.Level: java.util.logging.Level WARNING>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.drill.shaded.guava.com.google.common.util.concurrent.Service)>(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[])>("Unable to start Service \u0001");
virtualinvoke v.<java.util.logging.Logger: void log(java.util.logging.Level,java.lang.String,java.lang.Throwable)>(v, v, v);
goto label;
label:
return v;
catch java.lang.IllegalStateException from label to label with label;
}
public void awaitHealthy()
{
org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager v;
org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager$ServiceManagerState v;
v := @this: org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager;
v = v.<org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager: org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager$ServiceManagerState state>;
virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager$ServiceManagerState: void awaitHealthy()>();
return;
}
public void awaitHealthy(java.time.Duration) throws java.util.concurrent.TimeoutException
{
java.util.concurrent.TimeUnit v;
java.time.Duration v;
long v;
org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager v;
v := @this: org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager;
v := @parameter: java.time.Duration;
v = staticinvoke <org.apache.drill.shaded.guava.com.google.common.util.concurrent.Internal: long toNanosSaturated(java.time.Duration)>(v);
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit NANOSECONDS>;
virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager: void awaitHealthy(long,java.util.concurrent.TimeUnit)>(v, v);
return;
}
public void awaitHealthy(long, java.util.concurrent.TimeUnit) throws java.util.concurrent.TimeoutException
{
java.util.concurrent.TimeUnit v;
long v;
org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager v;
org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager$ServiceManagerState v;
v := @this: org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager;
v := @parameter: long;
v := @parameter: java.util.concurrent.TimeUnit;
v = v.<org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager: org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager$ServiceManagerState state>;
virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager$ServiceManagerState: void awaitHealthy(long,java.util.concurrent.TimeUnit)>(v, v);
return;
}
public org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager stopAsync()
{
java.lang.Object v;
org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager v;
org.apache.drill.shaded.guava.com.google.common.collect.ImmutableList v;
org.apache.drill.shaded.guava.com.google.common.collect.UnmodifiableIterator v;
boolean v;
v := @this: org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager;
v = v.<org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableList services>;
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableList: org.apache.drill.shaded.guava.com.google.common.collect.UnmodifiableIterator 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()>();
interfaceinvoke v.<org.apache.drill.shaded.guava.com.google.common.util.concurrent.Service: org.apache.drill.shaded.guava.com.google.common.util.concurrent.Service stopAsync()>();
goto label;
label:
return v;
}
public void awaitStopped()
{
org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager v;
org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager$ServiceManagerState v;
v := @this: org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager;
v = v.<org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager: org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager$ServiceManagerState state>;
virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager$ServiceManagerState: void awaitStopped()>();
return;
}
public void awaitStopped(java.time.Duration) throws java.util.concurrent.TimeoutException
{
java.util.concurrent.TimeUnit v;
java.time.Duration v;
long v;
org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager v;
v := @this: org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager;
v := @parameter: java.time.Duration;
v = staticinvoke <org.apache.drill.shaded.guava.com.google.common.util.concurrent.Internal: long toNanosSaturated(java.time.Duration)>(v);
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit NANOSECONDS>;
virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager: void awaitStopped(long,java.util.concurrent.TimeUnit)>(v, v);
return;
}
public void awaitStopped(long, java.util.concurrent.TimeUnit) throws java.util.concurrent.TimeoutException
{
java.util.concurrent.TimeUnit v;
long v;
org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager v;
org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager$ServiceManagerState v;
v := @this: org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager;
v := @parameter: long;
v := @parameter: java.util.concurrent.TimeUnit;
v = v.<org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager: org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager$ServiceManagerState state>;
virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager$ServiceManagerState: void awaitStopped(long,java.util.concurrent.TimeUnit)>(v, v);
return;
}
public boolean isHealthy()
{
java.lang.Object v;
org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager v;
org.apache.drill.shaded.guava.com.google.common.collect.ImmutableList v;
org.apache.drill.shaded.guava.com.google.common.collect.UnmodifiableIterator v;
boolean v, v;
v := @this: org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager;
v = v.<org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableList services>;
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableList: org.apache.drill.shaded.guava.com.google.common.collect.UnmodifiableIterator 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 = interfaceinvoke v.<org.apache.drill.shaded.guava.com.google.common.util.concurrent.Service: boolean isRunning()>();
if v != 0 goto label;
return 0;
label:
return 1;
}
public org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMultimap servicesByState()
{
org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager v;
org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager$ServiceManagerState v;
org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMultimap v;
v := @this: org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager;
v = v.<org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager: org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager$ServiceManagerState state>;
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager$ServiceManagerState: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMultimap servicesByState()>();
return v;
}
public org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap startupTimes()
{
org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager v;
org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap v;
org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager$ServiceManagerState v;
v := @this: org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager;
v = v.<org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager: org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager$ServiceManagerState state>;
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager$ServiceManagerState: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap startupTimes()>();
return v;
}
public java.lang.String toString()
{
org.apache.drill.shaded.guava.com.google.common.base.MoreObjects$ToStringHelper v, v;
java.util.Collection v;
org.apache.drill.shaded.guava.com.google.common.collect.ImmutableList v;
org.apache.drill.shaded.guava.com.google.common.base.Predicate v, v;
org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager v;
java.lang.String v;
v := @this: org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager;
v = staticinvoke <org.apache.drill.shaded.guava.com.google.common.base.MoreObjects: org.apache.drill.shaded.guava.com.google.common.base.MoreObjects$ToStringHelper toStringHelper(java.lang.Class)>(class "Lorg/apache/drill/shaded/guava/com/google/common/util/concurrent/ServiceManager;");
v = v.<org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableList services>;
v = staticinvoke <org.apache.drill.shaded.guava.com.google.common.base.Predicates: org.apache.drill.shaded.guava.com.google.common.base.Predicate instanceOf(java.lang.Class)>(class "Lorg/apache/drill/shaded/guava/com/google/common/util/concurrent/ServiceManager$NoOpService;");
v = staticinvoke <org.apache.drill.shaded.guava.com.google.common.base.Predicates: org.apache.drill.shaded.guava.com.google.common.base.Predicate not(org.apache.drill.shaded.guava.com.google.common.base.Predicate)>(v);
v = staticinvoke <org.apache.drill.shaded.guava.com.google.common.collect.Collections2: java.util.Collection filter(java.util.Collection,org.apache.drill.shaded.guava.com.google.common.base.Predicate)>(v, v);
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.base.MoreObjects$ToStringHelper: org.apache.drill.shaded.guava.com.google.common.base.MoreObjects$ToStringHelper add(java.lang.String,java.lang.Object)>("services", v);
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.base.MoreObjects$ToStringHelper: java.lang.String toString()>();
return v;
}
static void <clinit>()
{
org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager$1 v;
org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager$2 v;
java.lang.Class v;
java.lang.String v;
java.util.logging.Logger v;
v = class "Lorg/apache/drill/shaded/guava/com/google/common/util/concurrent/ServiceManager;";
v = virtualinvoke v.<java.lang.Class: java.lang.String getName()>();
v = staticinvoke <java.util.logging.Logger: java.util.logging.Logger getLogger(java.lang.String)>(v);
<org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager: java.util.logging.Logger logger> = v;
v = new org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager$1;
specialinvoke v.<org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager$1: void <init>()>();
<org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager: org.apache.drill.shaded.guava.com.google.common.util.concurrent.ListenerCallQueue$Event HEALTHY_EVENT> = v;
v = new org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager$2;
specialinvoke v.<org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager$2: void <init>()>();
<org.apache.drill.shaded.guava.com.google.common.util.concurrent.ServiceManager: org.apache.drill.shaded.guava.com.google.common.util.concurrent.ListenerCallQueue$Event STOPPED_EVENT> = v;
return;
}
}