public class org.apache.qpid.proton.reactor.impl.IOHandler extends org.apache.qpid.proton.engine.BaseHandler
{
private static org.apache.qpid.proton.reactor.Selectable$Callback connectionReadable;
private static org.apache.qpid.proton.reactor.Selectable$Callback connectionWritable;
private static org.apache.qpid.proton.reactor.Selectable$Callback connectionError;
private static org.apache.qpid.proton.reactor.Selectable$Callback connectionExpired;
private static org.apache.qpid.proton.reactor.Selectable$Callback connectionFree;
public void <init>()
{
org.apache.qpid.proton.reactor.impl.IOHandler v;
v := @this: org.apache.qpid.proton.reactor.impl.IOHandler;
specialinvoke v.<org.apache.qpid.proton.engine.BaseHandler: void <init>()>();
return;
}
private void handleQuiesced(org.apache.qpid.proton.reactor.Reactor, org.apache.qpid.proton.reactor.Selector) throws java.io.IOException
{
org.apache.qpid.proton.reactor.Selector v;
long v;
boolean v, v, v, v, v;
org.apache.qpid.proton.reactor.impl.IOHandler v;
java.util.Iterator v, v, v, v;
org.apache.qpid.proton.reactor.Reactor v;
java.lang.Object v, v, v, v;
v := @this: org.apache.qpid.proton.reactor.impl.IOHandler;
v := @parameter: org.apache.qpid.proton.reactor.Reactor;
v := @parameter: org.apache.qpid.proton.reactor.Selector;
v = interfaceinvoke v.<org.apache.qpid.proton.reactor.Reactor: boolean quiesced()>();
if v != 0 goto label;
return;
label:
v = interfaceinvoke v.<org.apache.qpid.proton.reactor.Reactor: long getTimeout()>();
interfaceinvoke v.<org.apache.qpid.proton.reactor.Selector: void select(long)>(v);
interfaceinvoke v.<org.apache.qpid.proton.reactor.Reactor: long mark()>();
v = interfaceinvoke v.<org.apache.qpid.proton.reactor.Selector: java.util.Iterator readable()>();
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.qpid.proton.reactor.Selectable: void readable()>();
goto label;
label:
v = interfaceinvoke v.<org.apache.qpid.proton.reactor.Selector: java.util.Iterator writeable()>();
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.qpid.proton.reactor.Selectable: void writeable()>();
goto label;
label:
v = interfaceinvoke v.<org.apache.qpid.proton.reactor.Selector: java.util.Iterator expired()>();
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.qpid.proton.reactor.Selectable: void expired()>();
goto label;
label:
v = interfaceinvoke v.<org.apache.qpid.proton.reactor.Selector: java.util.Iterator error()>();
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.qpid.proton.reactor.Selectable: void error()>();
goto label;
label:
interfaceinvoke v.<org.apache.qpid.proton.reactor.Reactor: void yield()>();
return;
}
private void handleOpen(org.apache.qpid.proton.reactor.Reactor, org.apache.qpid.proton.engine.Event)
{
java.lang.String[] v;
org.apache.qpid.proton.reactor.impl.Address v;
int v;
org.apache.qpid.proton.engine.Connection v;
java.lang.String v, v, v;
boolean v, v;
org.apache.qpid.proton.reactor.impl.IOHandler v;
org.apache.qpid.proton.reactor.ReactorOptions v, v;
org.apache.qpid.proton.engine.Sasl v;
org.apache.qpid.proton.engine.Transport v;
org.apache.qpid.proton.reactor.Reactor v;
org.apache.qpid.proton.engine.EndpointState v, v;
org.apache.qpid.proton.engine.Event v;
v := @this: org.apache.qpid.proton.reactor.impl.IOHandler;
v := @parameter: org.apache.qpid.proton.reactor.Reactor;
v := @parameter: org.apache.qpid.proton.engine.Event;
v = interfaceinvoke v.<org.apache.qpid.proton.engine.Event: org.apache.qpid.proton.engine.Connection getConnection()>();
v = interfaceinvoke v.<org.apache.qpid.proton.engine.Connection: org.apache.qpid.proton.engine.EndpointState getRemoteState()>();
v = <org.apache.qpid.proton.engine.EndpointState: org.apache.qpid.proton.engine.EndpointState UNINITIALIZED>;
if v == v goto label;
return;
label:
v = interfaceinvoke v.<org.apache.qpid.proton.engine.Connection: java.lang.String getHostname()>();
if v != null goto label;
v = interfaceinvoke v.<org.apache.qpid.proton.reactor.Reactor: java.lang.String getConnectionAddress(org.apache.qpid.proton.engine.Connection)>(v);
if v == null goto label;
v = new org.apache.qpid.proton.reactor.impl.Address;
specialinvoke v.<org.apache.qpid.proton.reactor.impl.Address: void <init>(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.qpid.proton.reactor.impl.Address: java.lang.String getHost()>();
interfaceinvoke v.<org.apache.qpid.proton.engine.Connection: void setHostname(java.lang.String)>(v);
goto label;
label:
v = virtualinvoke v.<java.lang.String: boolean isEmpty()>();
if v == 0 goto label;
interfaceinvoke v.<org.apache.qpid.proton.engine.Connection: void setHostname(java.lang.String)>(null);
label:
v = staticinvoke <org.apache.qpid.proton.Proton: org.apache.qpid.proton.engine.Transport transport()>();
v = interfaceinvoke v.<org.apache.qpid.proton.reactor.Reactor: org.apache.qpid.proton.reactor.ReactorOptions getOptions()>();
v = virtualinvoke v.<org.apache.qpid.proton.reactor.ReactorOptions: int getMaxFrameSize()>();
if v == 0 goto label;
interfaceinvoke v.<org.apache.qpid.proton.engine.Transport: void setMaxFrameSize(int)>(v);
label:
v = interfaceinvoke v.<org.apache.qpid.proton.reactor.Reactor: org.apache.qpid.proton.reactor.ReactorOptions getOptions()>();
v = virtualinvoke v.<org.apache.qpid.proton.reactor.ReactorOptions: boolean isEnableSaslByDefault()>();
if v == 0 goto label;
v = interfaceinvoke v.<org.apache.qpid.proton.engine.Transport: org.apache.qpid.proton.engine.Sasl sasl()>();
interfaceinvoke v.<org.apache.qpid.proton.engine.Sasl: void client()>();
v = newarray (java.lang.String)[1];
v[0] = "ANONYMOUS";
interfaceinvoke v.<org.apache.qpid.proton.engine.Sasl: void setMechanisms(java.lang.String[])>(v);
label:
interfaceinvoke v.<org.apache.qpid.proton.engine.Transport: void bind(org.apache.qpid.proton.engine.Connection)>(v);
return;
}
private void handleBound(org.apache.qpid.proton.reactor.Reactor, org.apache.qpid.proton.engine.Event)
{
java.lang.IllegalStateException v;
java.nio.channels.SocketChannel v;
boolean v;
org.apache.qpid.proton.reactor.impl.IOHandler v;
java.net.InetSocketAddress v;
java.lang.Exception v;
org.apache.qpid.proton.engine.Transport v;
org.apache.qpid.proton.amqp.transport.ErrorCondition v;
java.net.Socket v;
org.apache.qpid.proton.reactor.impl.Address v;
org.apache.qpid.proton.reactor.impl.IO v;
org.apache.qpid.proton.amqp.Symbol v;
int v, v, v, v, v;
org.apache.qpid.proton.engine.Connection v, v;
java.lang.String v, v, v, v, v, v, v;
java.lang.NumberFormatException v, v;
java.lang.IllegalArgumentException v, v;
org.apache.qpid.proton.reactor.Reactor v;
org.apache.qpid.proton.engine.Event v;
java.lang.Object v;
org.apache.qpid.proton.engine.Record v;
v := @this: org.apache.qpid.proton.reactor.impl.IOHandler;
v := @parameter: org.apache.qpid.proton.reactor.Reactor;
v := @parameter: org.apache.qpid.proton.engine.Event;
v = interfaceinvoke v.<org.apache.qpid.proton.engine.Event: org.apache.qpid.proton.engine.Connection getConnection()>();
v = interfaceinvoke v.<org.apache.qpid.proton.engine.Connection: org.apache.qpid.proton.engine.Record attachments()>();
v = interfaceinvoke v.<org.apache.qpid.proton.engine.Record: java.lang.Object get(java.lang.Object,java.lang.Class)>("pn_reactor_connection_acceptor", class "Lorg/apache/qpid/proton/reactor/Acceptor;");
if v == null goto label;
return;
label:
v = interfaceinvoke v.<org.apache.qpid.proton.reactor.Reactor: java.lang.String getConnectionAddress(org.apache.qpid.proton.engine.Connection)>(v);
v = interfaceinvoke v.<org.apache.qpid.proton.engine.Connection: java.lang.String getHostname()>();
v = 5672;
if v == null goto label;
v = new org.apache.qpid.proton.reactor.impl.Address;
specialinvoke v.<org.apache.qpid.proton.reactor.impl.Address: void <init>(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.qpid.proton.reactor.impl.Address: java.lang.String getHost()>();
label:
v = virtualinvoke v.<org.apache.qpid.proton.reactor.impl.Address: java.lang.String getImpliedPort()>();
v = staticinvoke <java.lang.Integer: int parseInt(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
v = new java.lang.IllegalArgumentException;
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[])>("Not a valid host: \u0001");
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
label:
if v == null goto label;
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("");
if v != 0 goto label;
v = virtualinvoke v.<java.lang.String: int indexOf(int)>(58);
if v < 0 goto label;
label:
v = v + 1;
v = virtualinvoke v.<java.lang.String: java.lang.String substring(int)>(v);
v = staticinvoke <java.lang.Integer: int parseInt(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
v = new java.lang.IllegalArgumentException;
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[])>("Not a valid host: \u0001");
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
label:
v = virtualinvoke v.<java.lang.String: java.lang.String substring(int,int)>(0, v);
goto label;
label:
v = new java.lang.IllegalStateException;
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>("No address provided for Connection");
throw v;
label:
v = interfaceinvoke v.<org.apache.qpid.proton.engine.Event: org.apache.qpid.proton.engine.Connection getConnection()>();
v = interfaceinvoke v.<org.apache.qpid.proton.engine.Connection: org.apache.qpid.proton.engine.Transport getTransport()>();
v = null;
label:
v = virtualinvoke v.<org.apache.qpid.proton.reactor.impl.ReactorImpl: org.apache.qpid.proton.reactor.impl.IO getIO()>();
v = interfaceinvoke v.<org.apache.qpid.proton.reactor.impl.IO: java.nio.channels.SocketChannel socketChannel()>();
virtualinvoke v.<java.nio.channels.SocketChannel: java.nio.channels.SelectableChannel configureBlocking(boolean)>(0);
v = new java.net.InetSocketAddress;
specialinvoke v.<java.net.InetSocketAddress: void <init>(java.lang.String,int)>(v, v);
virtualinvoke v.<java.nio.channels.SocketChannel: boolean connect(java.net.SocketAddress)>(v);
v = virtualinvoke v.<java.nio.channels.SocketChannel: java.net.Socket socket()>();
label:
goto label;
label:
v := @caughtexception;
v = new org.apache.qpid.proton.amqp.transport.ErrorCondition;
specialinvoke v.<org.apache.qpid.proton.amqp.transport.ErrorCondition: void <init>()>();
v = staticinvoke <org.apache.qpid.proton.amqp.Symbol: org.apache.qpid.proton.amqp.Symbol getSymbol(java.lang.String)>("proton:io");
virtualinvoke v.<org.apache.qpid.proton.amqp.transport.ErrorCondition: void setCondition(org.apache.qpid.proton.amqp.Symbol)>(v);
v = virtualinvoke v.<java.lang.Exception: java.lang.String getMessage()>();
virtualinvoke v.<org.apache.qpid.proton.amqp.transport.ErrorCondition: void setDescription(java.lang.String)>(v);
interfaceinvoke v.<org.apache.qpid.proton.engine.Transport: void setCondition(org.apache.qpid.proton.amqp.transport.ErrorCondition)>(v);
interfaceinvoke v.<org.apache.qpid.proton.engine.Transport: void close_tail()>();
interfaceinvoke v.<org.apache.qpid.proton.engine.Transport: void close_head()>();
v = interfaceinvoke v.<org.apache.qpid.proton.engine.Transport: int pending()>();
v = staticinvoke <java.lang.Math: int max(int,int)>(0, v);
interfaceinvoke v.<org.apache.qpid.proton.engine.Transport: void pop(int)>(v);
label:
staticinvoke <org.apache.qpid.proton.reactor.impl.IOHandler: org.apache.qpid.proton.reactor.Selectable selectableTransport(org.apache.qpid.proton.reactor.Reactor,java.net.Socket,org.apache.qpid.proton.engine.Transport)>(v, v, v);
return;
catch java.lang.NumberFormatException from label to label with label;
catch java.lang.NumberFormatException from label to label with label;
catch java.lang.Exception from label to label with label;
}
private static int capacity(org.apache.qpid.proton.reactor.Selectable)
{
org.apache.qpid.proton.engine.Transport v;
int v;
org.apache.qpid.proton.reactor.Selectable v;
boolean v;
v := @parameter: org.apache.qpid.proton.reactor.Selectable;
v = virtualinvoke v.<org.apache.qpid.proton.reactor.impl.SelectableImpl: org.apache.qpid.proton.engine.Transport getTransport()>();
v = interfaceinvoke v.<org.apache.qpid.proton.engine.Transport: int capacity()>();
if v >= 0 goto label;
v = interfaceinvoke v.<org.apache.qpid.proton.engine.Transport: boolean isClosed()>();
if v == 0 goto label;
interfaceinvoke v.<org.apache.qpid.proton.reactor.Selectable: void terminate()>();
label:
return v;
}
private static int pending(org.apache.qpid.proton.reactor.Selectable)
{
org.apache.qpid.proton.engine.Transport v;
int v;
org.apache.qpid.proton.reactor.Selectable v;
boolean v;
v := @parameter: org.apache.qpid.proton.reactor.Selectable;
v = virtualinvoke v.<org.apache.qpid.proton.reactor.impl.SelectableImpl: org.apache.qpid.proton.engine.Transport getTransport()>();
v = interfaceinvoke v.<org.apache.qpid.proton.engine.Transport: int pending()>();
if v >= 0 goto label;
v = interfaceinvoke v.<org.apache.qpid.proton.engine.Transport: boolean isClosed()>();
if v == 0 goto label;
interfaceinvoke v.<org.apache.qpid.proton.reactor.Selectable: void terminate()>();
label:
return v;
}
private static long deadline(org.apache.qpid.proton.reactor.impl.SelectableImpl)
{
org.apache.qpid.proton.engine.Transport v;
org.apache.qpid.proton.reactor.Reactor v;
org.apache.qpid.proton.reactor.impl.SelectableImpl v;
long v, v;
v := @parameter: org.apache.qpid.proton.reactor.impl.SelectableImpl;
v = virtualinvoke v.<org.apache.qpid.proton.reactor.impl.SelectableImpl: org.apache.qpid.proton.reactor.Reactor getReactor()>();
v = virtualinvoke v.<org.apache.qpid.proton.reactor.impl.SelectableImpl: org.apache.qpid.proton.engine.Transport getTransport()>();
v = interfaceinvoke v.<org.apache.qpid.proton.reactor.Reactor: long now()>();
v = interfaceinvoke v.<org.apache.qpid.proton.engine.Transport: long tick(long)>(v);
return v;
}
private static void update(org.apache.qpid.proton.reactor.Selectable)
{
int v, v;
long v;
org.apache.qpid.proton.reactor.Selectable v;
boolean v, v;
v := @parameter: org.apache.qpid.proton.reactor.Selectable;
v = staticinvoke <org.apache.qpid.proton.reactor.impl.IOHandler: int capacity(org.apache.qpid.proton.reactor.Selectable)>(v);
v = staticinvoke <org.apache.qpid.proton.reactor.impl.IOHandler: int pending(org.apache.qpid.proton.reactor.Selectable)>(v);
if v <= 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
interfaceinvoke v.<org.apache.qpid.proton.reactor.Selectable: void setReading(boolean)>(v);
if v <= 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
interfaceinvoke v.<org.apache.qpid.proton.reactor.Selectable: void setWriting(boolean)>(v);
v = staticinvoke <org.apache.qpid.proton.reactor.impl.IOHandler: long deadline(org.apache.qpid.proton.reactor.impl.SelectableImpl)>(v);
interfaceinvoke v.<org.apache.qpid.proton.reactor.Selectable: void setDeadline(long)>(v);
return;
}
protected static org.apache.qpid.proton.reactor.Selectable selectableTransport(org.apache.qpid.proton.reactor.Reactor, java.net.Socket, org.apache.qpid.proton.engine.Transport)
{
java.net.Socket v;
org.apache.qpid.proton.engine.Transport v;
org.apache.qpid.proton.reactor.Reactor v;
java.nio.channels.SocketChannel v;
org.apache.qpid.proton.reactor.Selectable v;
org.apache.qpid.proton.reactor.Selectable$Callback v, v, v, v, v;
v := @parameter: org.apache.qpid.proton.reactor.Reactor;
v := @parameter: java.net.Socket;
v := @parameter: org.apache.qpid.proton.engine.Transport;
v = interfaceinvoke v.<org.apache.qpid.proton.reactor.Reactor: org.apache.qpid.proton.reactor.Selectable selectable()>();
if v == null goto label;
v = virtualinvoke v.<java.net.Socket: java.nio.channels.SocketChannel getChannel()>();
goto label;
label:
v = null;
label:
interfaceinvoke v.<org.apache.qpid.proton.reactor.Selectable: void setChannel(java.nio.channels.SelectableChannel)>(v);
v = <org.apache.qpid.proton.reactor.impl.IOHandler: org.apache.qpid.proton.reactor.Selectable$Callback connectionReadable>;
interfaceinvoke v.<org.apache.qpid.proton.reactor.Selectable: void onReadable(org.apache.qpid.proton.reactor.Selectable$Callback)>(v);
v = <org.apache.qpid.proton.reactor.impl.IOHandler: org.apache.qpid.proton.reactor.Selectable$Callback connectionWritable>;
interfaceinvoke v.<org.apache.qpid.proton.reactor.Selectable: void onWritable(org.apache.qpid.proton.reactor.Selectable$Callback)>(v);
v = <org.apache.qpid.proton.reactor.impl.IOHandler: org.apache.qpid.proton.reactor.Selectable$Callback connectionError>;
interfaceinvoke v.<org.apache.qpid.proton.reactor.Selectable: void onError(org.apache.qpid.proton.reactor.Selectable$Callback)>(v);
v = <org.apache.qpid.proton.reactor.impl.IOHandler: org.apache.qpid.proton.reactor.Selectable$Callback connectionExpired>;
interfaceinvoke v.<org.apache.qpid.proton.reactor.Selectable: void onExpired(org.apache.qpid.proton.reactor.Selectable$Callback)>(v);
v = <org.apache.qpid.proton.reactor.impl.IOHandler: org.apache.qpid.proton.reactor.Selectable$Callback connectionFree>;
interfaceinvoke v.<org.apache.qpid.proton.reactor.Selectable: void onFree(org.apache.qpid.proton.reactor.Selectable$Callback)>(v);
virtualinvoke v.<org.apache.qpid.proton.reactor.impl.SelectableImpl: void setTransport(org.apache.qpid.proton.engine.Transport)>(v);
virtualinvoke v.<org.apache.qpid.proton.engine.impl.TransportImpl: void setSelectable(org.apache.qpid.proton.reactor.Selectable)>(v);
virtualinvoke v.<org.apache.qpid.proton.engine.impl.TransportImpl: void setReactor(org.apache.qpid.proton.reactor.Reactor)>(v);
staticinvoke <org.apache.qpid.proton.reactor.impl.IOHandler: void update(org.apache.qpid.proton.reactor.Selectable)>(v);
interfaceinvoke v.<org.apache.qpid.proton.reactor.Reactor: void update(org.apache.qpid.proton.reactor.Selectable)>(v);
return v;
}
private void handleTransport(org.apache.qpid.proton.reactor.Reactor, org.apache.qpid.proton.engine.Event)
{
org.apache.qpid.proton.engine.Transport v;
org.apache.qpid.proton.reactor.impl.IOHandler v;
org.apache.qpid.proton.reactor.Reactor v;
org.apache.qpid.proton.engine.Event v;
org.apache.qpid.proton.reactor.Selectable v;
boolean v;
v := @this: org.apache.qpid.proton.reactor.impl.IOHandler;
v := @parameter: org.apache.qpid.proton.reactor.Reactor;
v := @parameter: org.apache.qpid.proton.engine.Event;
v = interfaceinvoke v.<org.apache.qpid.proton.engine.Event: org.apache.qpid.proton.engine.Transport getTransport()>();
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.TransportImpl: org.apache.qpid.proton.reactor.Selectable getSelectable()>();
if v == null goto label;
v = interfaceinvoke v.<org.apache.qpid.proton.reactor.Selectable: boolean isTerminal()>();
if v != 0 goto label;
staticinvoke <org.apache.qpid.proton.reactor.impl.IOHandler: void update(org.apache.qpid.proton.reactor.Selectable)>(v);
interfaceinvoke v.<org.apache.qpid.proton.reactor.Reactor: void update(org.apache.qpid.proton.reactor.Selectable)>(v);
label:
return;
}
public void onUnhandled(org.apache.qpid.proton.engine.Event)
{
org.apache.qpid.proton.reactor.Selector v;
org.apache.qpid.proton.reactor.impl.ReactorInternalException v;
org.apache.qpid.proton.reactor.impl.IO v;
int[] v;
int v, v;
org.apache.qpid.proton.reactor.impl.SelectorImpl v;
org.apache.qpid.proton.reactor.impl.IOHandler v;
java.io.IOException v;
org.apache.qpid.proton.engine.Transport v;
org.apache.qpid.proton.reactor.Reactor v;
org.apache.qpid.proton.engine.Event$Type v;
org.apache.qpid.proton.engine.Event v;
org.apache.qpid.proton.reactor.Selectable v, v, v;
v := @this: org.apache.qpid.proton.reactor.impl.IOHandler;
v := @parameter: org.apache.qpid.proton.engine.Event;
label:
v = interfaceinvoke v.<org.apache.qpid.proton.engine.Event: org.apache.qpid.proton.reactor.Reactor getReactor()>();
v = virtualinvoke v.<org.apache.qpid.proton.reactor.impl.ReactorImpl: org.apache.qpid.proton.reactor.Selector getSelector()>();
if v != null goto label;
v = new org.apache.qpid.proton.reactor.impl.SelectorImpl;
v = virtualinvoke v.<org.apache.qpid.proton.reactor.impl.ReactorImpl: org.apache.qpid.proton.reactor.impl.IO getIO()>();
specialinvoke v.<org.apache.qpid.proton.reactor.impl.SelectorImpl: void <init>(org.apache.qpid.proton.reactor.impl.IO)>(v);
v = v;
virtualinvoke v.<org.apache.qpid.proton.reactor.impl.ReactorImpl: void setSelector(org.apache.qpid.proton.reactor.Selector)>(v);
label:
v = <org.apache.qpid.proton.reactor.impl.IOHandler$6: int[] $SwitchMap$org$apache$qpid$proton$engine$Event$Type>;
v = interfaceinvoke v.<org.apache.qpid.proton.engine.Event: org.apache.qpid.proton.engine.Event$Type getType()>();
v = virtualinvoke v.<org.apache.qpid.proton.engine.Event$Type: int ordinal()>();
v = v[v];
tableswitch(v)
{
case 1: goto label;
case 2: goto label;
case 3: goto label;
case 4: goto label;
case 5: goto label;
case 6: goto label;
case 7: goto label;
case 8: goto label;
default: goto label;
};
label:
v = interfaceinvoke v.<org.apache.qpid.proton.engine.Event: org.apache.qpid.proton.reactor.Selectable getSelectable()>();
interfaceinvoke v.<org.apache.qpid.proton.reactor.Selector: void add(org.apache.qpid.proton.reactor.Selectable)>(v);
goto label;
label:
v = interfaceinvoke v.<org.apache.qpid.proton.engine.Event: org.apache.qpid.proton.reactor.Selectable getSelectable()>();
interfaceinvoke v.<org.apache.qpid.proton.reactor.Selector: void update(org.apache.qpid.proton.reactor.Selectable)>(v);
goto label;
label:
v = interfaceinvoke v.<org.apache.qpid.proton.engine.Event: org.apache.qpid.proton.reactor.Selectable getSelectable()>();
interfaceinvoke v.<org.apache.qpid.proton.reactor.Selector: void remove(org.apache.qpid.proton.reactor.Selectable)>(v);
interfaceinvoke v.<org.apache.qpid.proton.reactor.Selectable: void release()>();
goto label;
label:
specialinvoke v.<org.apache.qpid.proton.reactor.impl.IOHandler: void handleOpen(org.apache.qpid.proton.reactor.Reactor,org.apache.qpid.proton.engine.Event)>(v, v);
goto label;
label:
specialinvoke v.<org.apache.qpid.proton.reactor.impl.IOHandler: void handleBound(org.apache.qpid.proton.reactor.Reactor,org.apache.qpid.proton.engine.Event)>(v, v);
goto label;
label:
specialinvoke v.<org.apache.qpid.proton.reactor.impl.IOHandler: void handleTransport(org.apache.qpid.proton.reactor.Reactor,org.apache.qpid.proton.engine.Event)>(v, v);
goto label;
label:
v = interfaceinvoke v.<org.apache.qpid.proton.engine.Event: org.apache.qpid.proton.engine.Transport getTransport()>();
interfaceinvoke v.<org.apache.qpid.proton.engine.Transport: void unbind()>();
goto label;
label:
specialinvoke v.<org.apache.qpid.proton.reactor.impl.IOHandler: void handleQuiesced(org.apache.qpid.proton.reactor.Reactor,org.apache.qpid.proton.reactor.Selector)>(v, v);
label:
goto label;
label:
v := @caughtexception;
v = new org.apache.qpid.proton.reactor.impl.ReactorInternalException;
specialinvoke v.<org.apache.qpid.proton.reactor.impl.ReactorInternalException: void <init>(java.lang.Throwable)>(v);
throw v;
label:
return;
catch java.io.IOException from label to label with label;
}
static void <clinit>()
{
org.apache.qpid.proton.reactor.impl.IOHandler$1 v;
org.apache.qpid.proton.reactor.impl.IOHandler$3 v;
org.apache.qpid.proton.reactor.impl.IOHandler$2 v;
org.apache.qpid.proton.reactor.impl.IOHandler$5 v;
org.apache.qpid.proton.reactor.impl.IOHandler$4 v;
v = new org.apache.qpid.proton.reactor.impl.IOHandler$1;
specialinvoke v.<org.apache.qpid.proton.reactor.impl.IOHandler$1: void <init>()>();
<org.apache.qpid.proton.reactor.impl.IOHandler: org.apache.qpid.proton.reactor.Selectable$Callback connectionReadable> = v;
v = new org.apache.qpid.proton.reactor.impl.IOHandler$2;
specialinvoke v.<org.apache.qpid.proton.reactor.impl.IOHandler$2: void <init>()>();
<org.apache.qpid.proton.reactor.impl.IOHandler: org.apache.qpid.proton.reactor.Selectable$Callback connectionWritable> = v;
v = new org.apache.qpid.proton.reactor.impl.IOHandler$3;
specialinvoke v.<org.apache.qpid.proton.reactor.impl.IOHandler$3: void <init>()>();
<org.apache.qpid.proton.reactor.impl.IOHandler: org.apache.qpid.proton.reactor.Selectable$Callback connectionError> = v;
v = new org.apache.qpid.proton.reactor.impl.IOHandler$4;
specialinvoke v.<org.apache.qpid.proton.reactor.impl.IOHandler$4: void <init>()>();
<org.apache.qpid.proton.reactor.impl.IOHandler: org.apache.qpid.proton.reactor.Selectable$Callback connectionExpired> = v;
v = new org.apache.qpid.proton.reactor.impl.IOHandler$5;
specialinvoke v.<org.apache.qpid.proton.reactor.impl.IOHandler$5: void <init>()>();
<org.apache.qpid.proton.reactor.impl.IOHandler: org.apache.qpid.proton.reactor.Selectable$Callback connectionFree> = v;
return;
}
}