class oadd.org.apache.drill.exec.rpc.user.QueryResultHandler$ChannelClosedHandler$1 extends java.lang.Object implements oadd.io.netty.util.concurrent.GenericFutureListener
{
final oadd.org.apache.drill.exec.rpc.user.UserClient$UserToBitConnection val$connection;
final oadd.org.apache.drill.exec.rpc.user.QueryResultHandler$ChannelClosedHandler this$1;
void <init>(oadd.org.apache.drill.exec.rpc.user.QueryResultHandler$ChannelClosedHandler, oadd.org.apache.drill.exec.rpc.user.UserClient$UserToBitConnection)
{
oadd.org.apache.drill.exec.rpc.user.QueryResultHandler$ChannelClosedHandler v;
oadd.org.apache.drill.exec.rpc.user.UserClient$UserToBitConnection v;
oadd.org.apache.drill.exec.rpc.user.QueryResultHandler$ChannelClosedHandler$1 v;
v := @this: oadd.org.apache.drill.exec.rpc.user.QueryResultHandler$ChannelClosedHandler$1;
v := @parameter: oadd.org.apache.drill.exec.rpc.user.QueryResultHandler$ChannelClosedHandler;
v := @parameter: oadd.org.apache.drill.exec.rpc.user.UserClient$UserToBitConnection;
v.<oadd.org.apache.drill.exec.rpc.user.QueryResultHandler$ChannelClosedHandler$1: oadd.org.apache.drill.exec.rpc.user.QueryResultHandler$ChannelClosedHandler this$1> = v;
v.<oadd.org.apache.drill.exec.rpc.user.QueryResultHandler$ChannelClosedHandler$1: oadd.org.apache.drill.exec.rpc.user.UserClient$UserToBitConnection val$connection> = v;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public void operationComplete(oadd.io.netty.util.concurrent.Future) throws java.lang.Exception
{
java.lang.Object[] v;
oadd.io.netty.util.concurrent.Future v;
oadd.org.apache.drill.exec.rpc.user.QueryResultHandler$ChannelClosedHandler v;
java.util.concurrent.ConcurrentMap v;
oadd.org.apache.drill.exec.rpc.user.UserClient$UserToBitConnection v;
java.lang.String v;
oadd.org.apache.drill.common.exceptions.UserException$Builder v, v;
boolean v, v;
oadd.org.apache.drill.common.exceptions.UserException v;
org.slf4j.Logger v, v;
java.util.Iterator v;
oadd.org.apache.drill.exec.rpc.user.QueryResultHandler v;
java.util.Collection v;
oadd.org.apache.drill.exec.rpc.user.QueryResultHandler$ChannelClosedHandler$1 v;
java.lang.Object v;
v := @this: oadd.org.apache.drill.exec.rpc.user.QueryResultHandler$ChannelClosedHandler$1;
v := @parameter: oadd.io.netty.util.concurrent.Future;
v = v.<oadd.org.apache.drill.exec.rpc.user.QueryResultHandler$ChannelClosedHandler$1: oadd.org.apache.drill.exec.rpc.user.QueryResultHandler$ChannelClosedHandler this$1>;
v = v.<oadd.org.apache.drill.exec.rpc.user.QueryResultHandler$ChannelClosedHandler: oadd.org.apache.drill.exec.rpc.user.QueryResultHandler this$0>;
v = v.<oadd.org.apache.drill.exec.rpc.user.QueryResultHandler: java.util.concurrent.ConcurrentMap queryIdToResultsListenersMap>;
v = interfaceinvoke v.<java.util.concurrent.ConcurrentMap: java.util.Collection values()>();
v = interfaceinvoke v.<java.util.Collection: 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 <oadd.org.apache.drill.common.exceptions.UserException: oadd.org.apache.drill.common.exceptions.UserException$Builder connectionError()>();
v = newarray (java.lang.Object)[1];
v = v.<oadd.org.apache.drill.exec.rpc.user.QueryResultHandler$ChannelClosedHandler$1: oadd.org.apache.drill.exec.rpc.user.UserClient$UserToBitConnection val$connection>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.rpc.user.UserClient$UserToBitConnection: java.lang.String getName()>();
v[0] = v;
v = virtualinvoke v.<oadd.org.apache.drill.common.exceptions.UserException$Builder: oadd.org.apache.drill.common.exceptions.UserException$Builder message(java.lang.String,java.lang.Object[])>("Connection %s closed unexpectedly. Drillbit down?", v);
v = <oadd.org.apache.drill.exec.rpc.user.QueryResultHandler: org.slf4j.Logger logger>;
v = virtualinvoke v.<oadd.org.apache.drill.common.exceptions.UserException$Builder: oadd.org.apache.drill.common.exceptions.UserException build(org.slf4j.Logger)>(v);
interfaceinvoke v.<oadd.org.apache.drill.exec.rpc.user.UserResultsListener: void submissionFailed(oadd.org.apache.drill.common.exceptions.UserException)>(v);
v = v instanceof oadd.org.apache.drill.exec.rpc.user.QueryResultHandler$BufferingResultsListener;
if v == 0 goto label;
v = <oadd.org.apache.drill.exec.rpc.user.QueryResultHandler: org.slf4j.Logger logger>;
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String)>("Buffering listener failed before results were transferred to the actual listener.");
goto label;
label:
return;
}
}