public final class org.glassfish.grizzly.nio.transport.TCPNIOTransport extends org.glassfish.grizzly.nio.NIOTransport implements org.glassfish.grizzly.asyncqueue.AsyncQueueEnabledTransport, org.glassfish.grizzly.filterchain.FilterChainEnabledTransport, org.glassfish.grizzly.nio.tmpselectors.TemporarySelectorsEnabledTransport
{
static final java.util.logging.Logger LOGGER;
public static final org.glassfish.grizzly.nio.ChannelConfigurator DEFAULT_CHANNEL_CONFIGURATOR;
public static final int MAX_RECEIVE_BUFFER_SIZE;
public static final int MAX_SEND_BUFFER_SIZE;
public static final boolean DEFAULT_TCP_NO_DELAY;
public static final boolean DEFAULT_KEEP_ALIVE;
public static final int DEFAULT_LINGER;
public static final int DEFAULT_SERVER_CONNECTION_BACKLOG;
private static final java.lang.String DEFAULT_TRANSPORT_NAME;
final java.util.Collection serverConnections;
final org.glassfish.grizzly.asyncqueue.AsyncQueueIO asyncQueueIO;
int linger;
int serverConnectionBackLog;
boolean tcpNoDelay;
boolean isKeepAlive;
private final org.glassfish.grizzly.filterchain.Filter defaultTransportFilter;
final org.glassfish.grizzly.nio.transport.TCPNIOTransport$RegisterChannelCompletionHandler selectorRegistrationHandler;
private final org.glassfish.grizzly.nio.transport.TCPNIOConnectorHandler connectorHandler;
private final org.glassfish.grizzly.nio.transport.TCPNIOBindingHandler bindingHandler;
public void <init>()
{
org.glassfish.grizzly.nio.transport.TCPNIOTransport v;
v := @this: org.glassfish.grizzly.nio.transport.TCPNIOTransport;
specialinvoke v.<org.glassfish.grizzly.nio.transport.TCPNIOTransport: void <init>(java.lang.String)>("TCPNIOTransport");
return;
}
void <init>(java.lang.String)
{
org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter v;
org.glassfish.grizzly.nio.transport.TCPNIOTransport v;
org.glassfish.grizzly.nio.transport.TCPNIOTransport$RegisterChannelCompletionHandler v;
org.glassfish.grizzly.nio.transport.TCPNIOBindingHandler v;
org.glassfish.grizzly.nio.transport.TCPNIOTransportFilter v;
org.glassfish.grizzly.nio.transport.TCPNIOTransport$TransportConnectorHandler v;
org.glassfish.grizzly.asyncqueue.AsyncQueueIO v;
org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueReader v;
org.glassfish.grizzly.attributes.AttributeBuilder v;
int v, v, v;
java.lang.String v, v;
java.util.concurrent.ConcurrentLinkedQueue v;
v := @this: org.glassfish.grizzly.nio.transport.TCPNIOTransport;
v := @parameter: java.lang.String;
if v == null goto label;
v = v;
goto label;
label:
v = "TCPNIOTransport";
label:
specialinvoke v.<org.glassfish.grizzly.nio.NIOTransport: void <init>(java.lang.String)>(v);
v = (int) -1;
v.<org.glassfish.grizzly.nio.transport.TCPNIOTransport: int linger> = v;
v.<org.glassfish.grizzly.nio.transport.TCPNIOTransport: int serverConnectionBackLog> = 4096;
v.<org.glassfish.grizzly.nio.transport.TCPNIOTransport: boolean tcpNoDelay> = 1;
v.<org.glassfish.grizzly.nio.transport.TCPNIOTransport: boolean isKeepAlive> = 1;
v = new org.glassfish.grizzly.nio.transport.TCPNIOTransport$TransportConnectorHandler;
specialinvoke v.<org.glassfish.grizzly.nio.transport.TCPNIOTransport$TransportConnectorHandler: void <init>(org.glassfish.grizzly.nio.transport.TCPNIOTransport)>(v);
v.<org.glassfish.grizzly.nio.transport.TCPNIOTransport: org.glassfish.grizzly.nio.transport.TCPNIOConnectorHandler connectorHandler> = v;
v = new org.glassfish.grizzly.nio.transport.TCPNIOBindingHandler;
specialinvoke v.<org.glassfish.grizzly.nio.transport.TCPNIOBindingHandler: void <init>(org.glassfish.grizzly.nio.transport.TCPNIOTransport)>(v);
v.<org.glassfish.grizzly.nio.transport.TCPNIOTransport: org.glassfish.grizzly.nio.transport.TCPNIOBindingHandler bindingHandler> = v;
v = (int) -1;
v.<org.glassfish.grizzly.nio.transport.TCPNIOTransport: int readBufferSize> = v;
v = (int) -1;
v.<org.glassfish.grizzly.nio.transport.TCPNIOTransport: int writeBufferSize> = v;
v = new org.glassfish.grizzly.nio.transport.TCPNIOTransport$RegisterChannelCompletionHandler;
specialinvoke v.<org.glassfish.grizzly.nio.transport.TCPNIOTransport$RegisterChannelCompletionHandler: void <init>(org.glassfish.grizzly.nio.transport.TCPNIOTransport)>(v);
v.<org.glassfish.grizzly.nio.transport.TCPNIOTransport: org.glassfish.grizzly.nio.transport.TCPNIOTransport$RegisterChannelCompletionHandler selectorRegistrationHandler> = v;
v = new org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueReader;
specialinvoke v.<org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueReader: void <init>(org.glassfish.grizzly.nio.NIOTransport)>(v);
v = new org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter;
specialinvoke v.<org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter: void <init>(org.glassfish.grizzly.nio.NIOTransport)>(v);
v = staticinvoke <org.glassfish.grizzly.asyncqueue.AsyncQueueIO$Factory: org.glassfish.grizzly.asyncqueue.AsyncQueueIO createImmutable(org.glassfish.grizzly.asyncqueue.AsyncQueueReader,org.glassfish.grizzly.asyncqueue.AsyncQueueWriter)>(v, v);
v.<org.glassfish.grizzly.nio.transport.TCPNIOTransport: org.glassfish.grizzly.asyncqueue.AsyncQueueIO asyncQueueIO> = v;
v = <org.glassfish.grizzly.Grizzly: org.glassfish.grizzly.attributes.AttributeBuilder DEFAULT_ATTRIBUTE_BUILDER>;
v.<org.glassfish.grizzly.nio.transport.TCPNIOTransport: org.glassfish.grizzly.attributes.AttributeBuilder attributeBuilder> = v;
v = new org.glassfish.grizzly.nio.transport.TCPNIOTransportFilter;
specialinvoke v.<org.glassfish.grizzly.nio.transport.TCPNIOTransportFilter: void <init>(org.glassfish.grizzly.nio.transport.TCPNIOTransport)>(v);
v.<org.glassfish.grizzly.nio.transport.TCPNIOTransport: org.glassfish.grizzly.filterchain.Filter defaultTransportFilter> = v;
v = new java.util.concurrent.ConcurrentLinkedQueue;
specialinvoke v.<java.util.concurrent.ConcurrentLinkedQueue: void <init>()>();
v.<org.glassfish.grizzly.nio.transport.TCPNIOTransport: java.util.Collection serverConnections> = v;
return;
}
protected org.glassfish.grizzly.nio.tmpselectors.TemporarySelectorIO createTemporarySelectorIO()
{
org.glassfish.grizzly.nio.transport.TCPNIOTemporarySelectorReader v;
org.glassfish.grizzly.nio.transport.TCPNIOTransport v;
org.glassfish.grizzly.nio.tmpselectors.TemporarySelectorIO v;
org.glassfish.grizzly.nio.transport.TCPNIOTemporarySelectorWriter v;
v := @this: org.glassfish.grizzly.nio.transport.TCPNIOTransport;
v = new org.glassfish.grizzly.nio.tmpselectors.TemporarySelectorIO;
v = new org.glassfish.grizzly.nio.transport.TCPNIOTemporarySelectorReader;
specialinvoke v.<org.glassfish.grizzly.nio.transport.TCPNIOTemporarySelectorReader: void <init>(org.glassfish.grizzly.nio.transport.TCPNIOTransport)>(v);
v = new org.glassfish.grizzly.nio.transport.TCPNIOTemporarySelectorWriter;
specialinvoke v.<org.glassfish.grizzly.nio.transport.TCPNIOTemporarySelectorWriter: void <init>(org.glassfish.grizzly.nio.transport.TCPNIOTransport)>(v);
specialinvoke v.<org.glassfish.grizzly.nio.tmpselectors.TemporarySelectorIO: void <init>(org.glassfish.grizzly.Reader,org.glassfish.grizzly.Writer)>(v, v);
return v;
}
protected void listen()
{
java.util.Iterator v;
org.glassfish.grizzly.nio.transport.TCPNIOTransport v;
java.util.Collection v;
java.util.logging.Logger v;
java.lang.Exception v;
java.util.logging.Level v;
java.lang.Object v;
java.lang.String v;
boolean v;
v := @this: org.glassfish.grizzly.nio.transport.TCPNIOTransport;
v = v.<org.glassfish.grizzly.nio.transport.TCPNIOTransport: java.util.Collection serverConnections>;
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()>();
label:
virtualinvoke v.<org.glassfish.grizzly.nio.transport.TCPNIOTransport: void listenServerConnection(org.glassfish.grizzly.nio.transport.TCPNIOServerConnection)>(v);
label:
goto label;
label:
v := @caughtexception;
v = <org.glassfish.grizzly.nio.transport.TCPNIOTransport: java.util.logging.Logger LOGGER>;
v = <java.util.logging.Level: java.util.logging.Level WARNING>;
v = staticinvoke <org.glassfish.grizzly.localization.LogMessages: java.lang.String WARNING_GRIZZLY_TRANSPORT_START_SERVER_CONNECTION_EXCEPTION(java.lang.Object)>(v);
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;
catch java.lang.Exception from label to label with label;
}
protected int getDefaultSelectorRunnersCount()
{
org.glassfish.grizzly.nio.transport.TCPNIOTransport v;
java.lang.Runtime v;
int v, v;
v := @this: org.glassfish.grizzly.nio.transport.TCPNIOTransport;
v = staticinvoke <java.lang.Runtime: java.lang.Runtime getRuntime()>();
v = virtualinvoke v.<java.lang.Runtime: int availableProcessors()>();
v = v + 1;
return v;
}
void listenServerConnection(org.glassfish.grizzly.nio.transport.TCPNIOServerConnection) throws java.io.IOException
{
org.glassfish.grizzly.nio.transport.TCPNIOServerConnection v;
org.glassfish.grizzly.nio.transport.TCPNIOTransport v;
v := @this: org.glassfish.grizzly.nio.transport.TCPNIOTransport;
v := @parameter: org.glassfish.grizzly.nio.transport.TCPNIOServerConnection;
virtualinvoke v.<org.glassfish.grizzly.nio.transport.TCPNIOServerConnection: void listen()>();
return;
}
public org.glassfish.grizzly.nio.transport.TCPNIOServerConnection bind(int) throws java.io.IOException
{
org.glassfish.grizzly.nio.transport.TCPNIOTransport v;
int v;
org.glassfish.grizzly.nio.transport.TCPNIOServerConnection v;
java.net.InetSocketAddress v;
v := @this: org.glassfish.grizzly.nio.transport.TCPNIOTransport;
v := @parameter: int;
v = new java.net.InetSocketAddress;
specialinvoke v.<java.net.InetSocketAddress: void <init>(int)>(v);
v = virtualinvoke v.<org.glassfish.grizzly.nio.transport.TCPNIOTransport: org.glassfish.grizzly.nio.transport.TCPNIOServerConnection bind(java.net.SocketAddress)>(v);
return v;
}
public org.glassfish.grizzly.nio.transport.TCPNIOServerConnection bind(java.lang.String, int) throws java.io.IOException
{
org.glassfish.grizzly.nio.transport.TCPNIOTransport v;
int v, v;
java.lang.String v;
org.glassfish.grizzly.nio.transport.TCPNIOServerConnection v;
v := @this: org.glassfish.grizzly.nio.transport.TCPNIOTransport;
v := @parameter: java.lang.String;
v := @parameter: int;
v = v.<org.glassfish.grizzly.nio.transport.TCPNIOTransport: int serverConnectionBackLog>;
v = virtualinvoke v.<org.glassfish.grizzly.nio.transport.TCPNIOTransport: org.glassfish.grizzly.nio.transport.TCPNIOServerConnection bind(java.lang.String,int,int)>(v, v, v);
return v;
}
public org.glassfish.grizzly.nio.transport.TCPNIOServerConnection bind(java.lang.String, int, int) throws java.io.IOException
{
org.glassfish.grizzly.nio.transport.TCPNIOTransport v;
int v, v;
java.lang.String v;
org.glassfish.grizzly.nio.transport.TCPNIOServerConnection v;
java.net.InetSocketAddress v;
v := @this: org.glassfish.grizzly.nio.transport.TCPNIOTransport;
v := @parameter: java.lang.String;
v := @parameter: int;
v := @parameter: int;
v = new java.net.InetSocketAddress;
specialinvoke v.<java.net.InetSocketAddress: void <init>(java.lang.String,int)>(v, v);
v = virtualinvoke v.<org.glassfish.grizzly.nio.transport.TCPNIOTransport: org.glassfish.grizzly.nio.transport.TCPNIOServerConnection bind(java.net.SocketAddress,int)>(v, v);
return v;
}
public org.glassfish.grizzly.nio.transport.TCPNIOServerConnection bind(java.net.SocketAddress) throws java.io.IOException
{
java.net.SocketAddress v;
org.glassfish.grizzly.nio.transport.TCPNIOTransport v;
int v;
org.glassfish.grizzly.nio.transport.TCPNIOServerConnection v;
v := @this: org.glassfish.grizzly.nio.transport.TCPNIOTransport;
v := @parameter: java.net.SocketAddress;
v = v.<org.glassfish.grizzly.nio.transport.TCPNIOTransport: int serverConnectionBackLog>;
v = virtualinvoke v.<org.glassfish.grizzly.nio.transport.TCPNIOTransport: org.glassfish.grizzly.nio.transport.TCPNIOServerConnection bind(java.net.SocketAddress,int)>(v, v);
return v;
}
public org.glassfish.grizzly.nio.transport.TCPNIOServerConnection bind(java.net.SocketAddress, int) throws java.io.IOException
{
java.net.SocketAddress v;
org.glassfish.grizzly.nio.transport.TCPNIOTransport v;
org.glassfish.grizzly.nio.transport.TCPNIOBindingHandler v;
int v;
org.glassfish.grizzly.nio.transport.TCPNIOServerConnection v;
v := @this: org.glassfish.grizzly.nio.transport.TCPNIOTransport;
v := @parameter: java.net.SocketAddress;
v := @parameter: int;
v = v.<org.glassfish.grizzly.nio.transport.TCPNIOTransport: org.glassfish.grizzly.nio.transport.TCPNIOBindingHandler bindingHandler>;
v = virtualinvoke v.<org.glassfish.grizzly.nio.transport.TCPNIOBindingHandler: org.glassfish.grizzly.nio.transport.TCPNIOServerConnection bind(java.net.SocketAddress,int)>(v, v);
return v;
}
public org.glassfish.grizzly.nio.transport.TCPNIOServerConnection bindToInherited() throws java.io.IOException
{
org.glassfish.grizzly.nio.transport.TCPNIOServerConnection v;
org.glassfish.grizzly.nio.transport.TCPNIOTransport v;
org.glassfish.grizzly.nio.transport.TCPNIOBindingHandler v;
v := @this: org.glassfish.grizzly.nio.transport.TCPNIOTransport;
v = v.<org.glassfish.grizzly.nio.transport.TCPNIOTransport: org.glassfish.grizzly.nio.transport.TCPNIOBindingHandler bindingHandler>;
v = virtualinvoke v.<org.glassfish.grizzly.nio.transport.TCPNIOBindingHandler: org.glassfish.grizzly.nio.transport.TCPNIOServerConnection bindToInherited()>();
return v;
}
public org.glassfish.grizzly.nio.transport.TCPNIOServerConnection bind(java.lang.String, org.glassfish.grizzly.PortRange, int) throws java.io.IOException
{
org.glassfish.grizzly.nio.transport.TCPNIOTransport v;
org.glassfish.grizzly.nio.transport.TCPNIOBindingHandler v;
int v;
org.glassfish.grizzly.Connection v;
org.glassfish.grizzly.PortRange v;
java.lang.String v;
v := @this: org.glassfish.grizzly.nio.transport.TCPNIOTransport;
v := @parameter: java.lang.String;
v := @parameter: org.glassfish.grizzly.PortRange;
v := @parameter: int;
v = v.<org.glassfish.grizzly.nio.transport.TCPNIOTransport: org.glassfish.grizzly.nio.transport.TCPNIOBindingHandler bindingHandler>;
v = virtualinvoke v.<org.glassfish.grizzly.nio.transport.TCPNIOBindingHandler: org.glassfish.grizzly.Connection bind(java.lang.String,org.glassfish.grizzly.PortRange,int)>(v, v, v);
return v;
}
public org.glassfish.grizzly.nio.transport.TCPNIOServerConnection bind(java.lang.String, org.glassfish.grizzly.PortRange, boolean, int) throws java.io.IOException
{
org.glassfish.grizzly.nio.transport.TCPNIOTransport v;
org.glassfish.grizzly.nio.transport.TCPNIOBindingHandler v;
int v;
org.glassfish.grizzly.Connection v;
org.glassfish.grizzly.PortRange v;
java.lang.String v;
boolean v;
v := @this: org.glassfish.grizzly.nio.transport.TCPNIOTransport;
v := @parameter: java.lang.String;
v := @parameter: org.glassfish.grizzly.PortRange;
v := @parameter: boolean;
v := @parameter: int;
v = v.<org.glassfish.grizzly.nio.transport.TCPNIOTransport: org.glassfish.grizzly.nio.transport.TCPNIOBindingHandler bindingHandler>;
v = virtualinvoke v.<org.glassfish.grizzly.nio.transport.TCPNIOBindingHandler: org.glassfish.grizzly.Connection bind(java.lang.String,org.glassfish.grizzly.PortRange,boolean,int)>(v, v, v, v);
return v;
}
public void unbind(org.glassfish.grizzly.Connection)
{
java.lang.Throwable v;
org.glassfish.grizzly.nio.transport.TCPNIOTransport v;
java.util.Collection v;
java.util.concurrent.locks.ReentrantReadWriteLock v;
java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock v;
java.util.logging.Logger v;
java.lang.Exception v;
org.glassfish.grizzly.utils.StateHolder v;
java.util.logging.Level v;
java.util.concurrent.TimeUnit v;
org.glassfish.grizzly.GrizzlyFuture v;
org.glassfish.grizzly.Connection v;
java.lang.String v;
boolean v;
v := @this: org.glassfish.grizzly.nio.transport.TCPNIOTransport;
v := @parameter: org.glassfish.grizzly.Connection;
v = v.<org.glassfish.grizzly.nio.transport.TCPNIOTransport: org.glassfish.grizzly.utils.StateHolder state>;
v = virtualinvoke v.<org.glassfish.grizzly.utils.StateHolder: java.util.concurrent.locks.ReentrantReadWriteLock getStateLocker()>();
v = virtualinvoke v.<java.util.concurrent.locks.ReentrantReadWriteLock: java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock writeLock()>();
interfaceinvoke v.<java.util.concurrent.locks.Lock: void lock()>();
label:
if v == null goto label;
v = v.<org.glassfish.grizzly.nio.transport.TCPNIOTransport: java.util.Collection serverConnections>;
v = interfaceinvoke v.<java.util.Collection: boolean remove(java.lang.Object)>(v);
if v == 0 goto label;
v = interfaceinvoke v.<org.glassfish.grizzly.Connection: org.glassfish.grizzly.GrizzlyFuture close()>();
label:
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit MILLISECONDS>;
interfaceinvoke v.<org.glassfish.grizzly.GrizzlyFuture: java.lang.Object get(long,java.util.concurrent.TimeUnit)>(1000L, v);
interfaceinvoke v.<org.glassfish.grizzly.GrizzlyFuture: void recycle(boolean)>(0);
label:
goto label;
label:
v := @caughtexception;
v = <org.glassfish.grizzly.nio.transport.TCPNIOTransport: java.util.logging.Logger LOGGER>;
v = <java.util.logging.Level: java.util.logging.Level WARNING>;
v = staticinvoke <org.glassfish.grizzly.localization.LogMessages: java.lang.String WARNING_GRIZZLY_TRANSPORT_UNBINDING_CONNECTION_EXCEPTION(java.lang.Object)>(v);
virtualinvoke v.<java.util.logging.Logger: void log(java.util.logging.Level,java.lang.String,java.lang.Throwable)>(v, v, v);
label:
interfaceinvoke v.<java.util.concurrent.locks.Lock: void unlock()>();
goto label;
label:
v := @caughtexception;
interfaceinvoke v.<java.util.concurrent.locks.Lock: void unlock()>();
throw v;
label:
return;
catch java.lang.Exception from label to label with label;
catch java.lang.Throwable from label to label with label;
}
public void unbindAll()
{
java.lang.Throwable v;
java.util.Iterator v;
org.glassfish.grizzly.nio.transport.TCPNIOTransport v;
java.util.Collection v, v;
java.util.concurrent.locks.ReentrantReadWriteLock v;
java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock v;
java.util.logging.Logger v;
java.lang.Exception v;
org.glassfish.grizzly.utils.StateHolder v;
java.util.logging.Level v;
java.lang.Object v;
java.lang.String v;
boolean v;
v := @this: org.glassfish.grizzly.nio.transport.TCPNIOTransport;
v = v.<org.glassfish.grizzly.nio.transport.TCPNIOTransport: org.glassfish.grizzly.utils.StateHolder state>;
v = virtualinvoke v.<org.glassfish.grizzly.utils.StateHolder: java.util.concurrent.locks.ReentrantReadWriteLock getStateLocker()>();
v = virtualinvoke v.<java.util.concurrent.locks.ReentrantReadWriteLock: java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock writeLock()>();
interfaceinvoke v.<java.util.concurrent.locks.Lock: void lock()>();
label:
v = v.<org.glassfish.grizzly.nio.transport.TCPNIOTransport: java.util.Collection serverConnections>;
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()>();
label:
virtualinvoke v.<org.glassfish.grizzly.nio.transport.TCPNIOTransport: void unbind(org.glassfish.grizzly.Connection)>(v);
label:
goto label;
label:
v := @caughtexception;
v = <org.glassfish.grizzly.nio.transport.TCPNIOTransport: java.util.logging.Logger LOGGER>;
v = <java.util.logging.Level: java.util.logging.Level FINE>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.glassfish.grizzly.Connection)>(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[])>("Exception occurred when closing server connection: \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:
v = v.<org.glassfish.grizzly.nio.transport.TCPNIOTransport: java.util.Collection serverConnections>;
interfaceinvoke v.<java.util.Collection: void clear()>();
label:
interfaceinvoke v.<java.util.concurrent.locks.Lock: void unlock()>();
goto label;
label:
v := @caughtexception;
interfaceinvoke v.<java.util.concurrent.locks.Lock: void unlock()>();
throw v;
label:
return;
catch java.lang.Exception from label to label with label;
catch java.lang.Throwable from label to label with label;
}
public org.glassfish.grizzly.GrizzlyFuture connect(java.lang.String, int)
{
org.glassfish.grizzly.nio.transport.TCPNIOConnectorHandler v;
org.glassfish.grizzly.nio.transport.TCPNIOTransport v;
org.glassfish.grizzly.GrizzlyFuture v;
int v;
java.lang.String v;
v := @this: org.glassfish.grizzly.nio.transport.TCPNIOTransport;
v := @parameter: java.lang.String;
v := @parameter: int;
v = v.<org.glassfish.grizzly.nio.transport.TCPNIOTransport: org.glassfish.grizzly.nio.transport.TCPNIOConnectorHandler connectorHandler>;
v = virtualinvoke v.<org.glassfish.grizzly.nio.transport.TCPNIOConnectorHandler: org.glassfish.grizzly.GrizzlyFuture connect(java.lang.String,int)>(v, v);
return v;
}
public org.glassfish.grizzly.GrizzlyFuture connect(java.net.SocketAddress)
{
org.glassfish.grizzly.nio.transport.TCPNIOConnectorHandler v;
java.net.SocketAddress v;
org.glassfish.grizzly.nio.transport.TCPNIOTransport v;
org.glassfish.grizzly.GrizzlyFuture v;
v := @this: org.glassfish.grizzly.nio.transport.TCPNIOTransport;
v := @parameter: java.net.SocketAddress;
v = v.<org.glassfish.grizzly.nio.transport.TCPNIOTransport: org.glassfish.grizzly.nio.transport.TCPNIOConnectorHandler connectorHandler>;
v = virtualinvoke v.<org.glassfish.grizzly.nio.transport.TCPNIOConnectorHandler: org.glassfish.grizzly.GrizzlyFuture connect(java.net.SocketAddress)>(v);
return v;
}
public void connect(java.net.SocketAddress, org.glassfish.grizzly.CompletionHandler)
{
org.glassfish.grizzly.nio.transport.TCPNIOConnectorHandler v;
java.net.SocketAddress v;
org.glassfish.grizzly.nio.transport.TCPNIOTransport v;
org.glassfish.grizzly.CompletionHandler v;
v := @this: org.glassfish.grizzly.nio.transport.TCPNIOTransport;
v := @parameter: java.net.SocketAddress;
v := @parameter: org.glassfish.grizzly.CompletionHandler;
v = v.<org.glassfish.grizzly.nio.transport.TCPNIOTransport: org.glassfish.grizzly.nio.transport.TCPNIOConnectorHandler connectorHandler>;
virtualinvoke v.<org.glassfish.grizzly.nio.transport.TCPNIOConnectorHandler: void connect(java.net.SocketAddress,org.glassfish.grizzly.CompletionHandler)>(v, v);
return;
}
public org.glassfish.grizzly.GrizzlyFuture connect(java.net.SocketAddress, java.net.SocketAddress)
{
org.glassfish.grizzly.nio.transport.TCPNIOConnectorHandler v;
java.net.SocketAddress v, v;
org.glassfish.grizzly.nio.transport.TCPNIOTransport v;
org.glassfish.grizzly.GrizzlyFuture v;
v := @this: org.glassfish.grizzly.nio.transport.TCPNIOTransport;
v := @parameter: java.net.SocketAddress;
v := @parameter: java.net.SocketAddress;
v = v.<org.glassfish.grizzly.nio.transport.TCPNIOTransport: org.glassfish.grizzly.nio.transport.TCPNIOConnectorHandler connectorHandler>;
v = virtualinvoke v.<org.glassfish.grizzly.nio.transport.TCPNIOConnectorHandler: org.glassfish.grizzly.GrizzlyFuture connect(java.net.SocketAddress,java.net.SocketAddress)>(v, v);
return v;
}
public void connect(java.net.SocketAddress, java.net.SocketAddress, org.glassfish.grizzly.CompletionHandler)
{
org.glassfish.grizzly.nio.transport.TCPNIOConnectorHandler v;
java.net.SocketAddress v, v;
org.glassfish.grizzly.nio.transport.TCPNIOTransport v;
org.glassfish.grizzly.CompletionHandler v;
v := @this: org.glassfish.grizzly.nio.transport.TCPNIOTransport;
v := @parameter: java.net.SocketAddress;
v := @parameter: java.net.SocketAddress;
v := @parameter: org.glassfish.grizzly.CompletionHandler;
v = v.<org.glassfish.grizzly.nio.transport.TCPNIOTransport: org.glassfish.grizzly.nio.transport.TCPNIOConnectorHandler connectorHandler>;
virtualinvoke v.<org.glassfish.grizzly.nio.transport.TCPNIOConnectorHandler: void connect(java.net.SocketAddress,java.net.SocketAddress,org.glassfish.grizzly.CompletionHandler)>(v, v, v);
return;
}
protected void closeConnection(org.glassfish.grizzly.Connection) throws java.io.IOException
{
org.glassfish.grizzly.asyncqueue.AsyncQueueWriter v;
org.glassfish.grizzly.nio.transport.TCPNIOTransport v;
org.glassfish.grizzly.asyncqueue.AsyncQueueIO v, v, v;
java.nio.channels.SelectableChannel v;
org.glassfish.grizzly.Connection v;
org.glassfish.grizzly.asyncqueue.AsyncQueueReader v;
v := @this: org.glassfish.grizzly.nio.transport.TCPNIOTransport;
v := @parameter: org.glassfish.grizzly.Connection;
virtualinvoke v.<org.glassfish.grizzly.nio.NIOConnection: java.nio.channels.SelectableChannel getChannel()>();
v = v.<org.glassfish.grizzly.nio.transport.TCPNIOTransport: org.glassfish.grizzly.asyncqueue.AsyncQueueIO asyncQueueIO>;
if v == null goto label;
v = v.<org.glassfish.grizzly.nio.transport.TCPNIOTransport: org.glassfish.grizzly.asyncqueue.AsyncQueueIO asyncQueueIO>;
v = interfaceinvoke v.<org.glassfish.grizzly.asyncqueue.AsyncQueueIO: org.glassfish.grizzly.asyncqueue.AsyncQueueReader getReader()>();
if v == null goto label;
interfaceinvoke v.<org.glassfish.grizzly.asyncqueue.AsyncQueueReader: void onClose(org.glassfish.grizzly.Connection)>(v);
label:
v = v.<org.glassfish.grizzly.nio.transport.TCPNIOTransport: org.glassfish.grizzly.asyncqueue.AsyncQueueIO asyncQueueIO>;
v = interfaceinvoke v.<org.glassfish.grizzly.asyncqueue.AsyncQueueIO: org.glassfish.grizzly.asyncqueue.AsyncQueueWriter getWriter()>();
if v == null goto label;
interfaceinvoke v.<org.glassfish.grizzly.asyncqueue.AsyncQueueWriter: void onClose(org.glassfish.grizzly.Connection)>(v);
label:
return;
}
org.glassfish.grizzly.nio.transport.TCPNIOConnection obtainNIOConnection(java.nio.channels.SocketChannel)
{
org.glassfish.grizzly.nio.transport.TCPNIOConnection v;
java.nio.channels.SocketChannel v;
org.glassfish.grizzly.nio.transport.TCPNIOTransport v;
v := @this: org.glassfish.grizzly.nio.transport.TCPNIOTransport;
v := @parameter: java.nio.channels.SocketChannel;
v = new org.glassfish.grizzly.nio.transport.TCPNIOConnection;
specialinvoke v.<org.glassfish.grizzly.nio.transport.TCPNIOConnection: void <init>(org.glassfish.grizzly.nio.transport.TCPNIOTransport,java.nio.channels.SelectableChannel)>(v, v);
virtualinvoke v.<org.glassfish.grizzly.nio.transport.TCPNIOTransport: void configureNIOConnection(org.glassfish.grizzly.nio.NIOConnection)>(v);
return v;
}
org.glassfish.grizzly.nio.transport.TCPNIOServerConnection obtainServerNIOConnection(java.nio.channels.ServerSocketChannel)
{
org.glassfish.grizzly.nio.transport.TCPNIOServerConnection v;
org.glassfish.grizzly.nio.transport.TCPNIOTransport v;
java.nio.channels.ServerSocketChannel v;
v := @this: org.glassfish.grizzly.nio.transport.TCPNIOTransport;
v := @parameter: java.nio.channels.ServerSocketChannel;
v = new org.glassfish.grizzly.nio.transport.TCPNIOServerConnection;
specialinvoke v.<org.glassfish.grizzly.nio.transport.TCPNIOServerConnection: void <init>(org.glassfish.grizzly.nio.transport.TCPNIOTransport,java.nio.channels.ServerSocketChannel)>(v, v);
virtualinvoke v.<org.glassfish.grizzly.nio.transport.TCPNIOTransport: void configureNIOConnection(org.glassfish.grizzly.nio.NIOConnection)>(v);
return v;
}
public org.glassfish.grizzly.nio.ChannelConfigurator getChannelConfigurator()
{
org.glassfish.grizzly.nio.transport.TCPNIOTransport v;
org.glassfish.grizzly.nio.ChannelConfigurator v, v;
v := @this: org.glassfish.grizzly.nio.transport.TCPNIOTransport;
v = v.<org.glassfish.grizzly.nio.transport.TCPNIOTransport: org.glassfish.grizzly.nio.ChannelConfigurator channelConfigurator>;
if v == null goto label;
v = v;
goto label;
label:
v = <org.glassfish.grizzly.nio.transport.TCPNIOTransport: org.glassfish.grizzly.nio.ChannelConfigurator DEFAULT_CHANNEL_CONFIGURATOR>;
label:
return v;
}
public org.glassfish.grizzly.asyncqueue.AsyncQueueIO getAsyncQueueIO()
{
org.glassfish.grizzly.asyncqueue.AsyncQueueIO v;
org.glassfish.grizzly.nio.transport.TCPNIOTransport v;
v := @this: org.glassfish.grizzly.nio.transport.TCPNIOTransport;
v = v.<org.glassfish.grizzly.nio.transport.TCPNIOTransport: org.glassfish.grizzly.asyncqueue.AsyncQueueIO asyncQueueIO>;
return v;
}
public synchronized void configureStandalone(boolean)
{
org.glassfish.grizzly.nio.transport.TCPNIOTransport v;
org.glassfish.grizzly.StandaloneProcessorSelector v;
org.glassfish.grizzly.StandaloneProcessor v;
boolean v, v;
v := @this: org.glassfish.grizzly.nio.transport.TCPNIOTransport;
v := @parameter: boolean;
v = v.<org.glassfish.grizzly.nio.transport.TCPNIOTransport: boolean isStandalone>;
if v == v goto label;
v.<org.glassfish.grizzly.nio.transport.TCPNIOTransport: boolean isStandalone> = v;
if v == 0 goto label;
v = <org.glassfish.grizzly.StandaloneProcessor: org.glassfish.grizzly.StandaloneProcessor INSTANCE>;
v.<org.glassfish.grizzly.nio.transport.TCPNIOTransport: org.glassfish.grizzly.Processor processor> = v;
v = <org.glassfish.grizzly.StandaloneProcessorSelector: org.glassfish.grizzly.StandaloneProcessorSelector INSTANCE>;
v.<org.glassfish.grizzly.nio.transport.TCPNIOTransport: org.glassfish.grizzly.ProcessorSelector processorSelector> = v;
goto label;
label:
v.<org.glassfish.grizzly.nio.transport.TCPNIOTransport: org.glassfish.grizzly.Processor processor> = null;
v.<org.glassfish.grizzly.nio.transport.TCPNIOTransport: org.glassfish.grizzly.ProcessorSelector processorSelector> = null;
label:
return;
}
public int getLinger()
{
int v;
org.glassfish.grizzly.nio.transport.TCPNIOTransport v;
v := @this: org.glassfish.grizzly.nio.transport.TCPNIOTransport;
v = v.<org.glassfish.grizzly.nio.transport.TCPNIOTransport: int linger>;
return v;
}
public void setLinger(int)
{
int v;
org.glassfish.grizzly.nio.transport.TCPNIOTransport v;
v := @this: org.glassfish.grizzly.nio.transport.TCPNIOTransport;
v := @parameter: int;
v.<org.glassfish.grizzly.nio.transport.TCPNIOTransport: int linger> = v;
staticinvoke <org.glassfish.grizzly.nio.transport.TCPNIOTransport: void notifyProbesConfigChanged(org.glassfish.grizzly.AbstractTransport)>(v);
return;
}
public boolean isKeepAlive()
{
org.glassfish.grizzly.nio.transport.TCPNIOTransport v;
boolean v;
v := @this: org.glassfish.grizzly.nio.transport.TCPNIOTransport;
v = v.<org.glassfish.grizzly.nio.transport.TCPNIOTransport: boolean isKeepAlive>;
return v;
}
public void setKeepAlive(boolean)
{
org.glassfish.grizzly.nio.transport.TCPNIOTransport v;
boolean v;
v := @this: org.glassfish.grizzly.nio.transport.TCPNIOTransport;
v := @parameter: boolean;
v.<org.glassfish.grizzly.nio.transport.TCPNIOTransport: boolean isKeepAlive> = v;
staticinvoke <org.glassfish.grizzly.nio.transport.TCPNIOTransport: void notifyProbesConfigChanged(org.glassfish.grizzly.AbstractTransport)>(v);
return;
}
public boolean isTcpNoDelay()
{
org.glassfish.grizzly.nio.transport.TCPNIOTransport v;
boolean v;
v := @this: org.glassfish.grizzly.nio.transport.TCPNIOTransport;
v = v.<org.glassfish.grizzly.nio.transport.TCPNIOTransport: boolean tcpNoDelay>;
return v;
}
public void setTcpNoDelay(boolean)
{
org.glassfish.grizzly.nio.transport.TCPNIOTransport v;
boolean v;
v := @this: org.glassfish.grizzly.nio.transport.TCPNIOTransport;
v := @parameter: boolean;
v.<org.glassfish.grizzly.nio.transport.TCPNIOTransport: boolean tcpNoDelay> = v;
staticinvoke <org.glassfish.grizzly.nio.transport.TCPNIOTransport: void notifyProbesConfigChanged(org.glassfish.grizzly.AbstractTransport)>(v);
return;
}
public int getServerConnectionBackLog()
{
int v;
org.glassfish.grizzly.nio.transport.TCPNIOTransport v;
v := @this: org.glassfish.grizzly.nio.transport.TCPNIOTransport;
v = v.<org.glassfish.grizzly.nio.transport.TCPNIOTransport: int serverConnectionBackLog>;
return v;
}
public void setServerConnectionBackLog(int)
{
int v;
org.glassfish.grizzly.nio.transport.TCPNIOTransport v;
v := @this: org.glassfish.grizzly.nio.transport.TCPNIOTransport;
v := @parameter: int;
v.<org.glassfish.grizzly.nio.transport.TCPNIOTransport: int serverConnectionBackLog> = v;
return;
}
public org.glassfish.grizzly.filterchain.Filter getTransportFilter()
{
org.glassfish.grizzly.nio.transport.TCPNIOTransport v;
org.glassfish.grizzly.filterchain.Filter v;
v := @this: org.glassfish.grizzly.nio.transport.TCPNIOTransport;
v = v.<org.glassfish.grizzly.nio.transport.TCPNIOTransport: org.glassfish.grizzly.filterchain.Filter defaultTransportFilter>;
return v;
}
public org.glassfish.grizzly.nio.tmpselectors.TemporarySelectorIO getTemporarySelectorIO()
{
org.glassfish.grizzly.nio.transport.TCPNIOTransport v;
org.glassfish.grizzly.nio.tmpselectors.TemporarySelectorIO v;
v := @this: org.glassfish.grizzly.nio.transport.TCPNIOTransport;
v = v.<org.glassfish.grizzly.nio.transport.TCPNIOTransport: org.glassfish.grizzly.nio.tmpselectors.TemporarySelectorIO temporarySelectorIO>;
return v;
}
public void fireIOEvent(org.glassfish.grizzly.IOEvent, org.glassfish.grizzly.Connection, org.glassfish.grizzly.IOEventLifeCycleListener)
{
org.glassfish.grizzly.IOEvent v, v, v;
java.util.logging.Level v, v;
org.glassfish.grizzly.IOEventLifeCycleListener v;
java.lang.String v;
boolean v;
org.glassfish.grizzly.nio.transport.TCPNIOTransport v;
java.io.IOException v, v, v;
org.glassfish.grizzly.Processor v;
java.util.logging.Logger v, v;
java.nio.channels.ClosedByInterruptException v;
org.glassfish.grizzly.Connection v;
java.lang.Object v;
org.glassfish.grizzly.Context v;
v := @this: org.glassfish.grizzly.nio.transport.TCPNIOTransport;
v := @parameter: org.glassfish.grizzly.IOEvent;
v := @parameter: org.glassfish.grizzly.Connection;
v := @parameter: org.glassfish.grizzly.IOEventLifeCycleListener;
v = <org.glassfish.grizzly.IOEvent: org.glassfish.grizzly.IOEvent SERVER_ACCEPT>;
if v != v goto label;
label:
virtualinvoke v.<org.glassfish.grizzly.nio.transport.TCPNIOServerConnection: void onAccept()>();
label:
goto label;
label:
v := @caughtexception;
staticinvoke <org.glassfish.grizzly.nio.transport.TCPNIOTransport: void failProcessingHandler(org.glassfish.grizzly.IOEvent,org.glassfish.grizzly.Connection,org.glassfish.grizzly.IOEventLifeCycleListener,java.io.IOException)>(v, v, v, v);
label:
specialinvoke v.<org.glassfish.grizzly.nio.transport.TCPNIOTransport: void rebindAddress(org.glassfish.grizzly.Connection)>(v);
label:
goto label;
label:
v := @caughtexception;
v = <org.glassfish.grizzly.nio.transport.TCPNIOTransport: java.util.logging.Logger LOGGER>;
v = <java.util.logging.Level: java.util.logging.Level SEVERE>;
v = virtualinvoke v.<java.util.logging.Logger: boolean isLoggable(java.util.logging.Level)>(v);
if v == 0 goto label;
v = <org.glassfish.grizzly.nio.transport.TCPNIOTransport: java.util.logging.Logger LOGGER>;
v = <java.util.logging.Level: java.util.logging.Level SEVERE>;
v = interfaceinvoke v.<org.glassfish.grizzly.Connection: java.lang.Object getLocalAddress()>();
v = staticinvoke <org.glassfish.grizzly.localization.LogMessages: java.lang.String SEVERE_GRIZZLY_TRANSPORT_LISTEN_INTERRUPTED_REBIND_EXCEPTION(java.lang.Object)>(v);
virtualinvoke v.<java.util.logging.Logger: void log(java.util.logging.Level,java.lang.String,java.lang.Throwable)>(v, v, v);
goto label;
label:
v := @caughtexception;
staticinvoke <org.glassfish.grizzly.nio.transport.TCPNIOTransport: void failProcessingHandler(org.glassfish.grizzly.IOEvent,org.glassfish.grizzly.Connection,org.glassfish.grizzly.IOEventLifeCycleListener,java.io.IOException)>(v, v, v, v);
label:
return;
label:
v = <org.glassfish.grizzly.IOEvent: org.glassfish.grizzly.IOEvent CLIENT_CONNECTED>;
if v != v goto label;
label:
virtualinvoke v.<org.glassfish.grizzly.nio.transport.TCPNIOConnection: void onConnect()>();
label:
goto label;
label:
v := @caughtexception;
staticinvoke <org.glassfish.grizzly.nio.transport.TCPNIOTransport: void failProcessingHandler(org.glassfish.grizzly.IOEvent,org.glassfish.grizzly.Connection,org.glassfish.grizzly.IOEventLifeCycleListener,java.io.IOException)>(v, v, v, v);
label:
return;
label:
v = interfaceinvoke v.<org.glassfish.grizzly.Connection: org.glassfish.grizzly.Processor obtainProcessor(org.glassfish.grizzly.IOEvent)>(v);
v = staticinvoke <org.glassfish.grizzly.Context: org.glassfish.grizzly.Context create(org.glassfish.grizzly.Connection,org.glassfish.grizzly.Processor,org.glassfish.grizzly.IOEvent,org.glassfish.grizzly.IOEventLifeCycleListener)>(v, v, v, v);
staticinvoke <org.glassfish.grizzly.ProcessorExecutor: void execute(org.glassfish.grizzly.Context)>(v);
return;
catch java.nio.channels.ClosedByInterruptException from label to label with label;
catch java.io.IOException from label to label with label;
catch java.io.IOException from label to label with label;
catch java.io.IOException from label to label with label;
}
public org.glassfish.grizzly.Reader getReader(org.glassfish.grizzly.Connection)
{
org.glassfish.grizzly.nio.transport.TCPNIOTransport v;
org.glassfish.grizzly.Connection v;
org.glassfish.grizzly.Reader v;
boolean v;
v := @this: org.glassfish.grizzly.nio.transport.TCPNIOTransport;
v := @parameter: org.glassfish.grizzly.Connection;
v = interfaceinvoke v.<org.glassfish.grizzly.Connection: boolean isBlocking()>();
v = virtualinvoke v.<org.glassfish.grizzly.nio.transport.TCPNIOTransport: org.glassfish.grizzly.Reader getReader(boolean)>(v);
return v;
}
public org.glassfish.grizzly.Reader getReader(boolean)
{
org.glassfish.grizzly.nio.transport.TCPNIOTransport v;
org.glassfish.grizzly.nio.tmpselectors.TemporarySelectorIO v;
org.glassfish.grizzly.asyncqueue.AsyncQueueIO v;
org.glassfish.grizzly.Reader v;
boolean v;
org.glassfish.grizzly.asyncqueue.AsyncQueueReader v;
v := @this: org.glassfish.grizzly.nio.transport.TCPNIOTransport;
v := @parameter: boolean;
if v == 0 goto label;
v = virtualinvoke v.<org.glassfish.grizzly.nio.transport.TCPNIOTransport: org.glassfish.grizzly.nio.tmpselectors.TemporarySelectorIO getTemporarySelectorIO()>();
v = virtualinvoke v.<org.glassfish.grizzly.nio.tmpselectors.TemporarySelectorIO: org.glassfish.grizzly.Reader getReader()>();
return v;
label:
v = virtualinvoke v.<org.glassfish.grizzly.nio.transport.TCPNIOTransport: org.glassfish.grizzly.asyncqueue.AsyncQueueIO getAsyncQueueIO()>();
v = interfaceinvoke v.<org.glassfish.grizzly.asyncqueue.AsyncQueueIO: org.glassfish.grizzly.asyncqueue.AsyncQueueReader getReader()>();
return v;
}
public org.glassfish.grizzly.Writer getWriter(org.glassfish.grizzly.Connection)
{
org.glassfish.grizzly.Writer v;
org.glassfish.grizzly.nio.transport.TCPNIOTransport v;
org.glassfish.grizzly.Connection v;
boolean v;
v := @this: org.glassfish.grizzly.nio.transport.TCPNIOTransport;
v := @parameter: org.glassfish.grizzly.Connection;
v = interfaceinvoke v.<org.glassfish.grizzly.Connection: boolean isBlocking()>();
v = virtualinvoke v.<org.glassfish.grizzly.nio.transport.TCPNIOTransport: org.glassfish.grizzly.Writer getWriter(boolean)>(v);
return v;
}
public org.glassfish.grizzly.Writer getWriter(boolean)
{
org.glassfish.grizzly.Writer v;
org.glassfish.grizzly.asyncqueue.AsyncQueueWriter v;
org.glassfish.grizzly.nio.transport.TCPNIOTransport v;
org.glassfish.grizzly.nio.tmpselectors.TemporarySelectorIO v;
org.glassfish.grizzly.asyncqueue.AsyncQueueIO v;
boolean v;
v := @this: org.glassfish.grizzly.nio.transport.TCPNIOTransport;
v := @parameter: boolean;
if v == 0 goto label;
v = virtualinvoke v.<org.glassfish.grizzly.nio.transport.TCPNIOTransport: org.glassfish.grizzly.nio.tmpselectors.TemporarySelectorIO getTemporarySelectorIO()>();
v = virtualinvoke v.<org.glassfish.grizzly.nio.tmpselectors.TemporarySelectorIO: org.glassfish.grizzly.Writer getWriter()>();
return v;
label:
v = virtualinvoke v.<org.glassfish.grizzly.nio.transport.TCPNIOTransport: org.glassfish.grizzly.asyncqueue.AsyncQueueIO getAsyncQueueIO()>();
v = interfaceinvoke v.<org.glassfish.grizzly.asyncqueue.AsyncQueueIO: org.glassfish.grizzly.asyncqueue.AsyncQueueWriter getWriter()>();
return v;
}
public org.glassfish.grizzly.Buffer read(org.glassfish.grizzly.Connection, org.glassfish.grizzly.Buffer) throws java.io.IOException
{
java.util.logging.Level v, v, v, v;
org.glassfish.grizzly.CloseType v, v;
int v, v, v, v;
java.lang.String v, v;
boolean v, v, v, v;
org.glassfish.grizzly.nio.transport.TCPNIOTransport v;
org.glassfish.grizzly.Buffer v;
java.util.logging.Logger v, v, v, v;
java.io.EOFException v, v;
java.lang.Exception v, v;
org.glassfish.grizzly.Connection v;
org.glassfish.grizzly.CloseReason v, v;
v := @this: org.glassfish.grizzly.nio.transport.TCPNIOTransport;
v := @parameter: org.glassfish.grizzly.Connection;
v := @parameter: org.glassfish.grizzly.Buffer;
if v != null goto label;
v = 1;
goto label;
label:
v = 0;
label:
if v == 0 goto label;
label:
v = staticinvoke <org.glassfish.grizzly.nio.transport.TCPNIOUtils: org.glassfish.grizzly.Buffer allocateAndReadBuffer(org.glassfish.grizzly.nio.transport.TCPNIOConnection)>(v);
v = interfaceinvoke v.<org.glassfish.grizzly.Buffer: int position()>();
virtualinvoke v.<org.glassfish.grizzly.nio.transport.TCPNIOConnection: void onRead(org.glassfish.grizzly.Buffer,int)>(v, v);
label:
goto label;
label:
v := @caughtexception;
v = <org.glassfish.grizzly.nio.transport.TCPNIOTransport: java.util.logging.Logger LOGGER>;
v = <java.util.logging.Level: java.util.logging.Level FINE>;
v = virtualinvoke v.<java.util.logging.Logger: boolean isLoggable(java.util.logging.Level)>(v);
if v == 0 goto label;
v = <org.glassfish.grizzly.nio.transport.TCPNIOTransport: java.util.logging.Logger LOGGER>;
v = <java.util.logging.Level: java.util.logging.Level FINE>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.glassfish.grizzly.Connection)>(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[])>("TCPNIOConnection (\u) (allocated) read exception");
virtualinvoke v.<java.util.logging.Logger: void log(java.util.logging.Level,java.lang.String,java.lang.Throwable)>(v, v, v);
label:
v = (int) -1;
v = v;
label:
if v != 0 goto label;
v = null;
goto label;
label:
if v >= 0 goto label;
v = new java.io.EOFException;
specialinvoke v.<java.io.EOFException: void <init>()>();
v = new org.glassfish.grizzly.CloseReason;
v = <org.glassfish.grizzly.CloseType: org.glassfish.grizzly.CloseType REMOTELY>;
specialinvoke v.<org.glassfish.grizzly.CloseReason: void <init>(org.glassfish.grizzly.CloseType,java.io.IOException)>(v, v);
virtualinvoke v.<org.glassfish.grizzly.nio.transport.TCPNIOConnection: void terminate0(org.glassfish.grizzly.CompletionHandler,org.glassfish.grizzly.CloseReason)>(null, v);
throw v;
label:
v = interfaceinvoke v.<org.glassfish.grizzly.Buffer: boolean hasRemaining()>();
if v == 0 goto label;
label:
v = staticinvoke <org.glassfish.grizzly.nio.transport.TCPNIOUtils: int readBuffer(org.glassfish.grizzly.nio.transport.TCPNIOConnection,org.glassfish.grizzly.Buffer)>(v, v);
label:
goto label;
label:
v := @caughtexception;
v = <org.glassfish.grizzly.nio.transport.TCPNIOTransport: java.util.logging.Logger LOGGER>;
v = <java.util.logging.Level: java.util.logging.Level FINE>;
v = virtualinvoke v.<java.util.logging.Logger: boolean isLoggable(java.util.logging.Level)>(v);
if v == 0 goto label;
v = <org.glassfish.grizzly.nio.transport.TCPNIOTransport: java.util.logging.Logger LOGGER>;
v = <java.util.logging.Level: java.util.logging.Level FINE>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.glassfish.grizzly.Connection)>(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[])>("TCPNIOConnection (\u) (existing) read exception");
virtualinvoke v.<java.util.logging.Logger: void log(java.util.logging.Level,java.lang.String,java.lang.Throwable)>(v, v, v);
label:
v = (int) -1;
v = v;
label:
virtualinvoke v.<org.glassfish.grizzly.nio.transport.TCPNIOConnection: void onRead(org.glassfish.grizzly.Buffer,int)>(v, v);
if v >= 0 goto label;
v = new java.io.EOFException;
specialinvoke v.<java.io.EOFException: void <init>()>();
v = new org.glassfish.grizzly.CloseReason;
v = <org.glassfish.grizzly.CloseType: org.glassfish.grizzly.CloseType REMOTELY>;
specialinvoke v.<org.glassfish.grizzly.CloseReason: void <init>(org.glassfish.grizzly.CloseType,java.io.IOException)>(v, v);
virtualinvoke v.<org.glassfish.grizzly.nio.transport.TCPNIOConnection: void terminate0(org.glassfish.grizzly.CompletionHandler,org.glassfish.grizzly.CloseReason)>(null, v);
throw v;
label:
return v;
catch java.lang.Exception from label to label with label;
catch java.lang.Exception from label to label with label;
}
public int write(org.glassfish.grizzly.nio.transport.TCPNIOConnection, org.glassfish.grizzly.asyncqueue.WritableMessage) throws java.io.IOException
{
org.glassfish.grizzly.nio.transport.TCPNIOConnection v;
org.glassfish.grizzly.nio.transport.TCPNIOTransport v;
int v;
org.glassfish.grizzly.asyncqueue.WritableMessage v;
v := @this: org.glassfish.grizzly.nio.transport.TCPNIOTransport;
v := @parameter: org.glassfish.grizzly.nio.transport.TCPNIOConnection;
v := @parameter: org.glassfish.grizzly.asyncqueue.WritableMessage;
v = virtualinvoke v.<org.glassfish.grizzly.nio.transport.TCPNIOTransport: int write(org.glassfish.grizzly.nio.transport.TCPNIOConnection,org.glassfish.grizzly.asyncqueue.WritableMessage,org.glassfish.grizzly.WriteResult)>(v, v, null);
return v;
}
public int write(org.glassfish.grizzly.nio.transport.TCPNIOConnection, org.glassfish.grizzly.asyncqueue.WritableMessage, org.glassfish.grizzly.WriteResult) throws java.io.IOException
{
java.lang.IllegalStateException v;
org.glassfish.grizzly.WriteResult v;
org.glassfish.grizzly.utils.Holder v;
long v, v, v;
org.glassfish.grizzly.nio.transport.TCPNIOConnection v;
org.glassfish.grizzly.CloseType v;
int v, v, v;
org.glassfish.grizzly.asyncqueue.WritableMessage v;
boolean v, v, v, v;
org.glassfish.grizzly.nio.transport.TCPNIOTransport v;
org.glassfish.grizzly.Buffer v;
java.io.IOException v;
java.nio.channels.SelectableChannel v;
org.glassfish.grizzly.CloseReason v;
v := @this: org.glassfish.grizzly.nio.transport.TCPNIOTransport;
v := @parameter: org.glassfish.grizzly.nio.transport.TCPNIOConnection;
v := @parameter: org.glassfish.grizzly.asyncqueue.WritableMessage;
v := @parameter: org.glassfish.grizzly.WriteResult;
v = interfaceinvoke v.<org.glassfish.grizzly.asyncqueue.WritableMessage: int remaining()>();
if v == 0 goto label;
v = v instanceof org.glassfish.grizzly.Buffer;
if v == 0 goto label;
label:
v = interfaceinvoke v.<org.glassfish.grizzly.Buffer: boolean isComposite()>();
if v == 0 goto label;
v = staticinvoke <org.glassfish.grizzly.nio.transport.TCPNIOUtils: int writeCompositeBuffer(org.glassfish.grizzly.nio.transport.TCPNIOConnection,org.glassfish.grizzly.memory.CompositeBuffer)>(v, v);
goto label;
label:
v = staticinvoke <org.glassfish.grizzly.nio.transport.TCPNIOUtils: int writeSimpleBuffer(org.glassfish.grizzly.nio.transport.TCPNIOConnection,org.glassfish.grizzly.Buffer)>(v, v);
label:
v = v;
if v < 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
virtualinvoke v.<org.glassfish.grizzly.nio.transport.TCPNIOConnection: void onWrite(org.glassfish.grizzly.Buffer,long)>(v, v);
if v == 0 goto label;
if v == null goto label;
virtualinvoke v.<org.glassfish.grizzly.WriteResult: void setMessage(java.lang.Object)>(v);
v = virtualinvoke v.<org.glassfish.grizzly.WriteResult: long getWrittenSize()>();
v = v + v;
virtualinvoke v.<org.glassfish.grizzly.WriteResult: void setWrittenSize(long)>(v);
v = v.<org.glassfish.grizzly.nio.transport.TCPNIOConnection: org.glassfish.grizzly.utils.Holder peerSocketAddressHolder>;
virtualinvoke v.<org.glassfish.grizzly.WriteResult: void setDstAddressHolder(org.glassfish.grizzly.utils.Holder)>(v);
label:
goto label;
label:
v := @caughtexception;
v = new org.glassfish.grizzly.CloseReason;
v = <org.glassfish.grizzly.CloseType: org.glassfish.grizzly.CloseType REMOTELY>;
specialinvoke v.<org.glassfish.grizzly.CloseReason: void <init>(org.glassfish.grizzly.CloseType,java.io.IOException)>(v, v);
virtualinvoke v.<org.glassfish.grizzly.nio.transport.TCPNIOConnection: void terminate0(org.glassfish.grizzly.CompletionHandler,org.glassfish.grizzly.CloseReason)>(null, v);
throw v;
label:
v = v instanceof org.glassfish.grizzly.FileChunk;
if v == 0 goto label;
v = virtualinvoke v.<org.glassfish.grizzly.nio.transport.TCPNIOConnection: java.nio.channels.SelectableChannel getChannel()>();
v = interfaceinvoke v.<org.glassfish.grizzly.FileChunk: long writeTo(java.nio.channels.WritableByteChannel)>(v);
goto label;
label:
v = new java.lang.IllegalStateException;
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>("Unhandled message type");
throw v;
label:
return v;
catch java.io.IOException from label to label with label;
}
private static void failProcessingHandler(org.glassfish.grizzly.IOEvent, org.glassfish.grizzly.Connection, org.glassfish.grizzly.IOEventLifeCycleListener, java.io.IOException)
{
org.glassfish.grizzly.Connection v;
java.io.IOException v, v;
org.glassfish.grizzly.IOEventLifeCycleListener v;
org.glassfish.grizzly.IOEvent v;
org.glassfish.grizzly.Context v;
v := @parameter: org.glassfish.grizzly.IOEvent;
v := @parameter: org.glassfish.grizzly.Connection;
v := @parameter: org.glassfish.grizzly.IOEventLifeCycleListener;
v := @parameter: java.io.IOException;
if v == null goto label;
label:
v = staticinvoke <org.glassfish.grizzly.Context: org.glassfish.grizzly.Context create(org.glassfish.grizzly.Connection,org.glassfish.grizzly.Processor,org.glassfish.grizzly.IOEvent,org.glassfish.grizzly.IOEventLifeCycleListener)>(v, null, v, v);
interfaceinvoke v.<org.glassfish.grizzly.IOEventLifeCycleListener: void onError(org.glassfish.grizzly.Context,java.lang.Object)>(v, v);
label:
goto label;
label:
v := @caughtexception;
label:
return;
catch java.io.IOException from label to label with label;
}
protected java.lang.Object createJmxManagementObject()
{
java.lang.Object v;
org.glassfish.grizzly.nio.transport.TCPNIOTransport v;
v := @this: org.glassfish.grizzly.nio.transport.TCPNIOTransport;
v = staticinvoke <org.glassfish.grizzly.monitoring.MonitoringUtils: java.lang.Object loadJmxObject(java.lang.String,java.lang.Object,java.lang.Class)>("org.glassfish.grizzly.nio.transport.jmx.TCPNIOTransport", v, class "Lorg/glassfish/grizzly/nio/transport/TCPNIOTransport;");
return v;
}
private void rebindAddress(org.glassfish.grizzly.Connection) throws java.io.IOException
{
java.lang.Throwable v;
org.glassfish.grizzly.nio.transport.TCPNIOTransport v;
java.util.Collection v;
java.util.concurrent.locks.ReentrantReadWriteLock v;
java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock v;
org.glassfish.grizzly.utils.StateHolder v;
java.lang.Thread v;
org.glassfish.grizzly.Connection v;
java.lang.Object v;
boolean v, v;
v := @this: org.glassfish.grizzly.nio.transport.TCPNIOTransport;
v := @parameter: org.glassfish.grizzly.Connection;
v = v.<org.glassfish.grizzly.nio.transport.TCPNIOTransport: org.glassfish.grizzly.utils.StateHolder state>;
v = virtualinvoke v.<org.glassfish.grizzly.utils.StateHolder: java.util.concurrent.locks.ReentrantReadWriteLock getStateLocker()>();
v = virtualinvoke v.<java.util.concurrent.locks.ReentrantReadWriteLock: java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock writeLock()>();
interfaceinvoke v.<java.util.concurrent.locks.Lock: void lock()>();
label:
v = staticinvoke <java.lang.Thread: java.lang.Thread currentThread()>();
v = virtualinvoke v.<java.lang.Thread: boolean isInterrupted()>();
if v == 0 goto label;
staticinvoke <java.lang.Thread: boolean interrupted()>();
label:
v = v.<org.glassfish.grizzly.nio.transport.TCPNIOTransport: java.util.Collection serverConnections>;
v = interfaceinvoke v.<java.util.Collection: boolean remove(java.lang.Object)>(v);
if v == 0 goto label;
v = interfaceinvoke v.<org.glassfish.grizzly.Connection: java.lang.Object getLocalAddress()>();
virtualinvoke v.<org.glassfish.grizzly.nio.transport.TCPNIOTransport: org.glassfish.grizzly.nio.transport.TCPNIOServerConnection bind(java.net.SocketAddress)>(v);
label:
interfaceinvoke v.<java.util.concurrent.locks.Lock: void unlock()>();
goto label;
label:
v := @caughtexception;
interfaceinvoke v.<java.util.concurrent.locks.Lock: void unlock()>();
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
static void <clinit>()
{
java.util.logging.Logger v;
java.lang.Integer v, v;
int v, v;
java.lang.Class v, v;
java.lang.String v, v, v, v;
org.glassfish.grizzly.nio.transport.TCPNIOTransport$DefaultChannelConfigurator v;
v = staticinvoke <org.glassfish.grizzly.Grizzly: java.util.logging.Logger logger(java.lang.Class)>(class "Lorg/glassfish/grizzly/nio/transport/TCPNIOTransport;");
<org.glassfish.grizzly.nio.transport.TCPNIOTransport: java.util.logging.Logger LOGGER> = v;
v = new org.glassfish.grizzly.nio.transport.TCPNIOTransport$DefaultChannelConfigurator;
specialinvoke v.<org.glassfish.grizzly.nio.transport.TCPNIOTransport$DefaultChannelConfigurator: void <init>()>();
<org.glassfish.grizzly.nio.transport.TCPNIOTransport: org.glassfish.grizzly.nio.ChannelConfigurator DEFAULT_CHANNEL_CONFIGURATOR> = v;
v = class "Lorg/glassfish/grizzly/nio/transport/TCPNIOTransport;";
v = virtualinvoke v.<java.lang.Class: java.lang.String getName()>();
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[])>("\u.max-receive-buffer-size");
v = staticinvoke <java.lang.Integer: java.lang.Integer getInteger(java.lang.String,int)>(v, 2147483647);
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
<org.glassfish.grizzly.nio.transport.TCPNIOTransport: int MAX_RECEIVE_BUFFER_SIZE> = v;
v = class "Lorg/glassfish/grizzly/nio/transport/TCPNIOTransport;";
v = virtualinvoke v.<java.lang.Class: java.lang.String getName()>();
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[])>("\u.max-send-buffer-size");
v = staticinvoke <java.lang.Integer: java.lang.Integer getInteger(java.lang.String,int)>(v, 2147483647);
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
<org.glassfish.grizzly.nio.transport.TCPNIOTransport: int MAX_SEND_BUFFER_SIZE> = v;
return;
}
}